本文實例講述了PHP基于pdo的數據庫操作類。分享給大家供大家參考，具體如下：

工作中需要操作sqlserver、oracle都是使用的這個類，當時是在別人的基礎上改進了，現在分享下

 ?phphtml' target='_blank'>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-  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-  }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-  }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-  }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-  }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=1where 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的數據庫操作類的詳細內容，PHP教程

鄭重聲明：本文版權歸原作者所有，轉載文章僅為傳播更多信息之目的，如作者信息標記有誤，請第一時間聯系我們修改或刪除，多謝。