PHP基于pdo的数据库操作类

内容导读

收集整理的这篇技术教程文章主要介绍了PHP基于pdo的数据库操作类，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含9960字，纯文字阅读大概需要15分钟。

内容图文

这篇文章主要介绍了PHP基于pdo的数据库操作类,可实现基本的数据库连接、增删改查、关闭连接等操作,还支持针对mysql、sqlserver及oracle等数据库的操作,需要的朋友可以参考下

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

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

<?phpclass 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.dllhttp://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) 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'=>'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实现的mysql读写分离相关内容

PHP实现将多个文件压缩成zip格式并下载到本地的方法

PHP递归遍历文件夹去除注释并压缩php源代码的方法示例

以上就是PHP基于pdo的数据库操作类的详细内容，更多请关注Gxl网其它相关文章！

内容总结

以上是为您收集整理的PHP基于pdo的数据库操作类全部内容，希望文章能够帮你解决PHP基于pdo的数据库操作类所遇到的程序开发问题。 如果觉得技术教程内容还不错，欢迎将网站推荐给程序员好友。

内容备注

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