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

　　本文实例讲述了PHP基于pdo的数据库操作类。分享给大家供大家参考，具体如下：

　　工作中需要操作sqlserver、oracle都是使用的这个类，当时是在别人的基础上改进了，现在分享下

　　 <?php class Pdodb{ protected $pdo; protected $res; protected $config; /*构造函数*/ function __construct($config){ $this->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[type]==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 失败0 return $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 数据库表，两种传值模式 * 普通模式： * tb_member, tb_money * 数组模式： * array(tb_member, tb_money) * string/array $fields 需要查询的数据库字段，允许为空，默认为查找全部，两种传值模式 * 普通模式： * username, password * 数组模式： * array(username, password) * string/array $sqlwhere 查询条件，允许为空，两种传值模式 * 普通模式(必须加上and,$sqlwhere为空 1=1 正常查询)： * and type = 1 and username like %os% * 数组模式： * array(type = 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[type]==oracle){ //$fields = implode(,,$fields);//CUSTOMER_ID,FIRST_NAME,LAST_NAME,EMAIL //$fields = implode(,UTF8,ZHS16GBK) ,convert(,$fields); //$fields=convert(.$fields.,UTF8,ZHS16GBK); }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 数据库表，两种传值模式 * 普通模式： * tb_member, tb_money * 数组模式： * array(tb_member, tb_money) * string/array $set 需要插入的字段及内容，两种传值模式 * 普通模式： * username = test, type = 1, dt = now() * 数组模式： * array(username = test, type = 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 数据库表，两种传值模式 * 普通模式： * tb_member, tb_money * 数组模式： * array(tb_member, tb_money) * string/array $set 需要更新的字段及内容，两种传值模式 * 普通模式： * username = test, type = 1, dt = now() * 数组模式： * array(username = test, type = 1, dt = now()) * string/array $sqlwhere 修改条件，允许为空，两种传值模式 * 普通模式： * and type = 1 and username like %os% * 数组模式： * array(type = 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(type = 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 下载php版本对应的sqlsrv扩展 sqlserver 配置 odbc连接需开启extension=php_pdo_odbc.dll */ $mssql2008_config=array( dsn=>odbc:Driver={SQL Server};Server=192.168.1.60;Database=his,//数据库服务器地址 username=>sa, password=>xxxxx, ); $mssql=new Pdodb($mssql2008_config); $sql=select * from ( select row_number()over(order by tempcolumn)temprownumber,* from ( select top 10 tempcolumn=0,a.* from DA_GR_HBFS a where 1=1 ) t ) tt where 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=>root, 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] => 正常 ) )*/ ?>

　　更多关于PHP相关内容感兴趣的读者可查看本站专题：《PHP基于pdo操作数据库技巧总结》、《php+Oracle数据库程序设计技巧总结》、《PHP+MongoDB数据库操作技巧大全》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

　　希望本文所述对大家PHP程序设计有所帮助。