200字范文,内容丰富有趣,生活中的好帮手!
200字范文 > PHP基于pdo的数据库操作类【可支持mysql sqlserver及oracle】

PHP基于pdo的数据库操作类【可支持mysql sqlserver及oracle】

时间:2018-10-05 07:47:21

相关推荐

PHP基于pdo的数据库操作类【可支持mysql sqlserver及oracle】

后端开发|php教程

mysql,可支持,数据库

后端开发-php教程工作中需要操作sqlserver、oracle都是使用的这个类,当时是在别人的基础上改进了,现在分享下

微商城系统 源码,vscode 粘贴时对齐,ubuntu图标桌面,tomcat 连接原理,手机sqlite汉化版下载,爬虫使用什么计算机语言,php 安卓应用,长治seo推广推荐公司,网站管理登录界面,win10 发布asp网站模板lzw

Config = $config; $this->connect(); } /*数据库连接*/ public function connect(){ try { $this->pdo= new PDO($this->Config[dsn], $this->Config[username], $this->Config[password]);//$dbh = new PDO(mysql:host=localhost;dbname=test, $user, $pass); $this->pdo->query("set names utf8"); }catch(Exception $e){echo 数据库连接失败,详情: . $e->getMessage () . 请在配置文件中数据库连接信息;exit (); } /* if($this->Config[ ype]==oracle){$this->pdo->query("set names {$this->Config[charset]};"); }else{$this->pdo->query("set names {$this->Config[charset]};"); } */ //把结果序列化成stdClass //$this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ); //自己写代码捕获Exception //$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); $this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);//属性名 属性值 数组以关联数组返回 } /*数据库关闭*/ public function close(){ $this->pdo = null; } //用于有记录结果返回的操作,特别是SELECT操作 public function query($sql,$return=false){ $res = $this->pdo->query($sql); if($res){$this->res = $res; // 未返回 return $this->res; } if($return){return $res; } } //主要是针对没有结果集合返回的操作,比如INSERT、UPDATE、DELETE等操作 public function exec($sql,$return=false){ $res = $this->pdo->exec($sql); if($res){$this->res = $res; } if($return){//返回操作是否成功 成功返回1 失败0return $res; } } //将$this->res以数组返回(全部返回) public function fetchAll(){ return $this->res->fetchAll(); } //将$this->res以数组返回(一条记录) public function fetch(){ return $this->res->fetch(); } //返回所有字段 public function fetchColumn(){ return $this->res->fetchColumn(); } //返回最后插入的id public function lastInsertId(){ return $this->res->lastInsertId(); } //返回最后插入的id public function lastInsertId2(){ return $this->pdo->lastInsertId(); } /** * 参数说明 * string/array $table 数据库表,两种传值模式 * 普通模式: * b_member, tb_money * 数组模式: * array( b_member, b_money) * string/array $fields 需要查询的数据库字段,允许为空,默认为查找全部,两种传值模式 * 普通模式: * username, password * 数组模式: * array(username, password) * string/array $sqlwhere 查询条件,允许为空,两种传值模式 * 普通模式(必须加上and,$sqlwhere为空 1=1 正常查询): * and type = 1 and username like "%os%" * 数组模式: * array( ype = 1, username like "%os%") * string $orderby 排序,默认为id倒序 *int $debug 是否开启调试,开启则输出sql语句 * 0 不开启 * 1 开启 * 2 开启并终止程序 * int $mode 返回类型 * 0 返回多条记录 * 1 返回单条记录 * 2 返回行数 */ public function select($table, $fields="*", $sqlwhere="", $orderby="", $debug=0, $mode=0){ //参数处理 if(is_array($table)){$table = implode(, , $table); } if(is_array($fields)){$fields = implode(,,$fields);/*if($this->Config[ ype]==oracle){ //$fields = implode(,,$fields);//CUSTOMER_ID,FIRST_NAME,LAST_NAME,EMAIL //$fields = implode(",UTF8,HS16GBK) ,convert(",$fields); //$fields="convert(".$fields.",UTF8,HS16GBK)";}else{ $fields = implode(,,$fields);}*/ } if(is_array($sqlwhere)){$sqlwhere = and .implode( and , $sqlwhere); } //数据库操作 if($debug === 0){if($mode === 2){ //统计 $this->query("select count(*) from $table where 1=1 $sqlwhere"); $return = $this->fetchColumn();}else if($mode === 1){ //返回一条 $this->query("select $fields from $table where 1=1 $sqlwhere $orderby"); $return = $this->fetch();}else{ $this->query("select $fields from $table where 1=1 $sqlwhere $orderby"); $return = $this->fetchAll();//如果 $this->res为空即sql语句错误 会提示Call to a member function fetchAll() on a non-object}return $return; }else{ if($mode === 2){echo "select count(*) from $table where 1=1 $sqlwhere"; }else if($mode === 1){echo "select $fields from $table where 1=1 $sqlwhere $orderby"; }else{echo "select $fields from $table where 1=1 $sqlwhere $orderby"; } if($debug === 2){exit; } } } /** * 参数说明 * string/array $table 数据库表,两种传值模式 * 普通模式: * b_member, tb_money * 数组模式: * array( b_member, b_money) * string/array $set 需要插入的字段及内容,两种传值模式 * 普通模式: * username = "test", type = 1, dt = now() * 数组模式: * array(username = "test", ype = 1, dt = now()) * int $debug 是否开启调试,开启则输出sql语句 * 0 不开启 * 1 开启 * 2 开启并终止程序 * int $mode 返回类型 * 0 无返回信息 * 1 返回执行条目数 * 2 返回最后一次插入记录的id */ public function oic_insert($table, $set, $debug=0, $mode=0){ //参数处理 if(is_array($table)){$table = implode(, , $table); } if(is_array($set)){$s=\;$i=0;foreach($set as $k=>$v){ $i++; $s[$i]=$k;//,连接 $val[$i]=$v;}$sarr=implode(",",$s);//去掉最后一个,//array_pop($sarr);$set=implode(",\",$val);////15221579236,张三,\,2001,8,4,女,是//$set = implode(, , $set); } //数据库操作 if($debug === 0){if($mode === 2){ $this->query("insert into $table ($sarr) values(\".$set.")"); //$return = $this->lastInsertId();}else if($mode === 1){ $this->exec("insert into $table ($sarr) values(\".$set.")"); $return = $this->res;}else{ $this->query("insert into $table ($sarr) values(\".$set.")"); $return = NULL;}return $return; }else{echo "insert into $table ($sarr) values(\".$set.")";if($debug === 2){ exit;} } } public function insert($table, $set, $debug=0, $mode=0){ //参数处理 if(is_array($table)){$table = implode(, , $table); } if(is_array($set)){$s=\;foreach($set as $k=>$v){ $s.=$k."=\".$v.",";//,连接}$sarr=explode(,,$s);//去掉最后一个,array_pop($sarr);$set=implode(,,$sarr);//$set = implode(, , $set); } //数据库操作 if($debug === 0){if($mode === 2){ $this->query("insert into $table set $set"); $return = $this->pdo->lastInsertId();}else if($mode === 1){ $this->exec("insert into $table set $set"); $return = $this->res;}else{ $this->query("insert into $table set $set"); $return = NULL;}return $return; }else{echo "insert into $table set $set";if($debug === 2){ exit;} } } /** * 参数说明 * string $table 数据库表,两种传值模式 * 普通模式: * b_member, tb_money * 数组模式: * array( b_member, b_money) * string/array $set 需要更新的字段及内容,两种传值模式 * 普通模式: * username = "test", type = 1, dt = now() * 数组模式: * array(username = "test", ype = 1, dt = now()) * string/array $sqlwhere 修改条件,允许为空,两种传值模式 * 普通模式: * and type = 1 and username like "%os%" * 数组模式: * array( ype = 1, username like "%os%") * int $debug 是否开启调试,开启则输出sql语句 * 0 不开启 * 1 开启 * 2 开启并终止程序 * int $mode 返回类型 * 0 无返回信息 * 1 返回执行条目数 */ public function update($table, $set, $sqlwhere="", $debug=0, $mode=0){ //参数处理 if(is_array($table)){$table = implode(, , $table); } if(is_array($set)){$s=\;foreach($set as $k=>$v){ $s.=$k."=\".$v.",";}$sarr=explode(,,$s);//去掉最后一个,array_pop($sarr);$set=implode(,,$sarr);//$set = implode(, , $set); } if(is_array($sqlwhere)){$sqlwhere = and .implode( and , $sqlwhere); } //数据库操作 if($debug === 0){if($mode === 1){ $this->exec("update $table set $set where 1=1 $sqlwhere"); $return = $this->res;}else{ $this->query("update $table set $set where 1=1 $sqlwhere"); $return = true;}return $return; }else{echo "update $table set $set where 1=1 $sqlwhere";if($debug === 2){ exit;} } } /** * 参数说明 * string $table 数据库表 * string/array $sqlwhere 删除条件,允许为空,两种传值模式 * 普通模式: * and type = 1 and username like "%os%" * 数组模式: * array( ype = 1, username like "%os%") * int $debug 是否开启调试,开启则输出sql语句 * 0 不开启 * 1 开启 * 2 开启并终止程序 * int $mode 返回类型 * 0 无返回信息 * 1 返回执行条目数 */ public function delete($table, $sqlwhere="", $debug=0, $mode=0){ //参数处理 if(is_array($sqlwhere)){$sqlwhere = and .implode( and , $sqlwhere); //是字符串需自己加上and } //数据库操作 if($debug === 0){if($mode === 1){ $this->exec("delete from $table where 1=1 $sqlwhere"); $return = $this->res;}else{ $this->query("delete from $table where 1=1 $sqlwhere"); $return = NULL;}return $return; }else{echo "delete from $table where 1=1 $sqlwhere";if($debug === 2){ exit;} } }}/*sqlserver 配置 extension=php_pdo_mssql.dll和extension=php_pdo_sqlsrv.dll 安装对应的 ntwdblib.dll/en-us/library/cc296170.aspx 下载php版本对应的sqlsrv扩展sqlserver 配置 odbc连接需开启extension=php_pdo_odbc.dll*/$mssql_config=array( dsn=>odbc:Driver={SQL Server};Server=192.168.1.60;Database=his,//数据库服务器地址 username=>sa, password=>xxxxx,);$mssql=new Pdodb($mssql_config);$sql="select * from( select row_number()over(order by tempcolumn)temprownumber,* from (select top 10 tempcolumn=0,a.*from DA_GR_HBFS awhere 1=1 ) t) ttwhere temprownumber>0";$mssql->query($sql);while($res=$mssql->fetch()){ $data[]=$res;}print_r($data);exit;//mysql 操作$msyql_config=array( dsn=>mysql:host=localhost;dbname=talk, username=> oot, password=>123456);$mysql=new PDO_DB($msyql_config);$sql = SELECT user_id, user_name, nickname FROM et_users ;$mysql->query($sql);$data=$mysql->fetchAll();print_r($data);exit;//oracle 操作$oci_config=array( dsn=>oci:dbname=orcl, username=>BAOCRM, password=>BAOCRM);$oracle=new PDO_DB($oci_config);//print_r($oracle);exit;//PDO_DB Object ( [pdo:protected] => PDO Object ( ) [res:protected] => [config:protected] => [Config] => Array ( [dsn] => oci:dbname=orcl [name] => PWACRM [password] => PWACRM ) )$sql="select * from CUSTOMER_LEVEL t";$oracle->query($sql);$data=$oracle->fetchAll();print_r($data);exit;/*Array( [0] => Array ([LEVEL_ID] => 1[0] => 1[LEVEL_NAME] => 普通会员[1] => 普通会员[LEVEL_DETAIL] => 普通会员[2] => 普通会员[SORT_NUMBER] => 15[3] => 15[CREATE_TIME] => 12-7月 -12[4] => 12-7月 -12[CREATE_BY] => 1[5] => 1[UPDATE_TIME] => 12-7月 -12[6] => 12-7月 -12[UPDATE_BY] => 1[7] => 1[STATE] => 正常[8] => 正常 ))*/?>

乐尚app源码,ubuntu 打不开目录,tomcat的启动快捷键,c 网络爬虫设计,php外包项目代码栏学习,软件优化seolzw

PHP实现的mysql读写分离操作

qq华夏易语言源码,vscode联想输入选择不了,ubuntu 添加文件,tomcat怎么取消自动启动,sqlite错误11,网页设计要求,服务器所有端口被关闭,一款独立的下载页面插件,前端框架带源码,r实现爬虫,免杀php大马,seo靠谱吗,异步入库springboot,扁平化中文网站模板下载,网页注册psd文件,轻应用模板,phpcms默认后台路径,html注册页面图片,图片管理系统php,android程序锁源码lzw

PHP实现防止表单重复提交功能(基于token验证)

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。