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

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

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

rush:PHP;"> 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.",'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') * 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,$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,$table); } if(is_array($set)){ $s=''; foreach($set as $k=>$v){ $s.=$k."='".$v."',";//,连接 } $sarr=explode(',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') * string/array $set 需要更新的字段及内容,两种传值模式 * 普通模式: * 'username = "test",'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,"; } $sarr=explode(',$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,$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 http://msdn.microsoft.com/en-us/library/cc296170.aspx 下载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常见数据库操作技巧汇总》

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

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


服务器优化必备:深入了解PHP8底层开发原理
Golang的网络编程:如何快速构建高性能的网络应用?
Golang和其他编程语言的对比:为什么它的开发效率更高?
PHP8底层开发原理揭秘:如何利用新特性创建出色的Web应用
将字符重新排列以形成回文(如果可能)在C++中
掌握PHP8底层开发原理和新特性:创建高效可扩展的应用程序
服务器性能优化必学:掌握PHP8底层开发原理
PHP8新特性和底层开发原理详解:优化应用性能的终极指南
将 C/C++ 代码转换为汇编语言
深入研究PHP8底层开发原理:创建高效可扩展的应用程序
C++程序查找法向量和迹
PHP8底层开发原理实战指南:提升服务器效能
重排数组,使得当 i 为偶数时,arr[i] >= arr[j],当 i 为奇数时,arr[i] <= arr[j],其中 j < i,使用 C++ 语言实现
Golang的垃圾回收:为什么它可以减少开发人员的负担?
C++程序:将一个数组的所有元素复制到另一个数组中
Golang:构建智能系统的基石
为什么AI开发者应该关注Golang?
在C和C++中,逗号(comma)的用法是用来分隔表达式或语句
PHP8底层开发原理解析及新特性应用实例
利用PHP8底层开发原理解析新特性:如何构建出色的Web应用