PHP基于pdo的數(shù)據(jù)庫(kù)操作類【可支持mysql、sqlserver及oracle】

?php
class Pdodb{
  protected $pdo;
  protected $res;
  protected $config;
  /*構(gòu)造函數(shù)*/
  function __construct($config){
    $this->Config = $config;
    $this->connect();
  }
  /*數(shù)據(jù)庫(kù)連接*/
  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 '數(shù)據(jù)庫(kù)連接失敗,詳情: ' . $e->getMessage () . ' 請(qǐng)?jiān)谂渲梦募袛?shù)據(jù)庫(kù)連接信息';
      exit ();
    }
    /*
    if($this->Config['type']=='oracle'){
      $this->pdo->query("set names {$this->Config['charset']};");
    }else{
      $this->pdo->query("set names {$this->Config['charset']};");
    }
    */
    //把結(jié)果序列化成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);//屬性名 屬性值 數(shù)組以關(guān)聯(lián)數(shù)組返回
  }
  /*數(shù)據(jù)庫(kù)關(guān)閉*/
  public function close(){
    $this->pdo = null;
  }
  //用于有記錄結(jié)果返回的操作，特別是SELECT操作
  public function query($sql,$return=false){
    $res = $this->pdo->query($sql);
    if($res){
      $this->res = $res; // 未返回 return $this->res;
    }
    if($return){
      return $res;
    }
  }
  //主要是針對(duì)沒(méi)有結(jié)果集合返回的操作，比如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以數(shù)組返回(全部返回)
  public function fetchAll(){
    return $this->res->fetchAll();
  }
  //將$this->res以數(shù)組返回(一條記錄)
  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();
  }
  /**
  * 參數(shù)說(shuō)明
  * string/array $table 數(shù)據(jù)庫(kù)表，兩種傳值模式
  * 普通模式：
  * 'tb_member, tb_money'
  * 數(shù)組模式：
  * array('tb_member', 'tb_money')
  * string/array $fields 需要查詢的數(shù)據(jù)庫(kù)字段，允許為空，默認(rèn)為查找全部，兩種傳值模式
  * 普通模式：
  * 'username, password'
  * 數(shù)組模式：
  * array('username', 'password')
  * string/array $sqlwhere 查詢條件，允許為空，兩種傳值模式
  * 普通模式(必須加上and,$sqlwhere為空 1=1 正常查詢)：
  * 'and type = 1 and username like "%os%"'
  * 數(shù)組模式：
  * array('type = 1', 'username like "%os%"')
  * string $orderby 排序，默認(rèn)為id倒序
  *int $debug 是否開啟調(diào)試，開啟則輸出sql語(yǔ)句
  * 0 不開啟
  * 1 開啟
  * 2 開啟并終止程序
  * int $mode 返回類型
  * 0 返回多條記錄
  * 1 返回單條記錄
  * 2 返回行數(shù)
  */
  public function select($table, $fields="*", $sqlwhere="", $orderby="", $debug=0, $mode=0){
    //參數(shù)處理
    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);
    }
    //數(shù)據(jù)庫(kù)操作
    if($debug === 0){
      if($mode === 2){ //統(tǒng)計(jì)
        $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語(yǔ)句錯(cuò)誤 會(huì)提示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;
        }
    }
  }
  /**
  * 參數(shù)說(shuō)明
  * string/array $table 數(shù)據(jù)庫(kù)表，兩種傳值模式
  * 普通模式：
  * 'tb_member, tb_money'
  * 數(shù)組模式：
  * array('tb_member', 'tb_money')
  * string/array $set 需要插入的字段及內(nèi)容，兩種傳值模式
  * 普通模式：
  * 'username = "test", type = 1, dt = now()'
  * 數(shù)組模式：
  * array('username = "test"', 'type = 1', 'dt = now()')
  * int $debug 是否開啟調(diào)試，開啟則輸出sql語(yǔ)句
  * 0 不開啟
  * 1 開啟
  * 2 開啟并終止程序
  * int $mode 返回類型
  * 0 無(wú)返回信息
  * 1 返回執(zhí)行條目數(shù)
  * 2 返回最后一次插入記錄的id
  */
  public function oic_insert($table, $set, $debug=0, $mode=0){
    //參數(shù)處理
    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);//去掉最后一個(gè),
      //array_pop($sarr);
      $set=implode("','",$val);////15221579236','張三','','2001','8','4','女','是
      //$set = implode(', ', $set);
    }
    //數(shù)據(jù)庫(kù)操作
    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){
    //參數(shù)處理
    if(is_array($table)){
      $table = implode(', ', $table);
    }
    if(is_array($set)){
      $s='';
      foreach($set as $k=>$v){
        $s.=$k."='".$v."',";//,連接
      }
      $sarr=explode(',',$s);//去掉最后一個(gè),
      array_pop($sarr);
      $set=implode(',',$sarr);
      //$set = implode(', ', $set);
    }
    //數(shù)據(jù)庫(kù)操作
    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;
      }
    }
  }
  /**
  * 參數(shù)說(shuō)明
  * string $table 數(shù)據(jù)庫(kù)表，兩種傳值模式
  * 普通模式：
  * 'tb_member, tb_money'
  * 數(shù)組模式：
  * array('tb_member', 'tb_money')
  * string/array $set 需要更新的字段及內(nèi)容，兩種傳值模式
  * 普通模式：
  * 'username = "test", type = 1, dt = now()'
  * 數(shù)組模式：
  * array('username = "test"', 'type = 1', 'dt = now()')
  * string/array $sqlwhere 修改條件，允許為空，兩種傳值模式
  * 普通模式：
  * 'and type = 1 and username like "%os%"'
  * 數(shù)組模式：
  * array('type = 1', 'username like "%os%"')
  * int $debug 是否開啟調(diào)試，開啟則輸出sql語(yǔ)句
  * 0 不開啟
  * 1 開啟
  * 2 開啟并終止程序
  * int $mode 返回類型
  * 0 無(wú)返回信息
  * 1 返回執(zhí)行條目數(shù)
  */
  public function update($table, $set, $sqlwhere="", $debug=0, $mode=0){
    //參數(shù)處理
    if(is_array($table)){
      $table = implode(', ', $table);
    }
    if(is_array($set)){
      $s='';
      foreach($set as $k=>$v){
        $s.=$k."='".$v."',";
      }
      $sarr=explode(',',$s);//去掉最后一個(gè),
      array_pop($sarr);
      $set=implode(',',$sarr);
      //$set = implode(', ', $set);
    }
    if(is_array($sqlwhere)){
      $sqlwhere = ' and '.implode(' and ', $sqlwhere);
    }
    //數(shù)據(jù)庫(kù)操作
    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;
      }
    }
  }
  /**
  * 參數(shù)說(shuō)明
  * string $table 數(shù)據(jù)庫(kù)表
  * string/array $sqlwhere 刪除條件，允許為空，兩種傳值模式
  * 普通模式：
  * 'and type = 1 and username like "%os%"'
  * 數(shù)組模式：
  * array('type = 1', 'username like "%os%"')
  * int $debug 是否開啟調(diào)試，開啟則輸出sql語(yǔ)句
  * 0 不開啟
  * 1 開啟
  * 2 開啟并終止程序
  * int $mode 返回類型
  * 0 無(wú)返回信息
  * 1 返回執(zhí)行條目數(shù)
  */
  public function delete($table, $sqlwhere="", $debug=0, $mode=0){
    //參數(shù)處理
    if(is_array($sqlwhere)){
      $sqlwhere = ' and '.implode(' and ', $sqlwhere); //是字符串需自己加上and
    }
    //數(shù)據(jù)庫(kù)操作
    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 安裝對(duì)應(yīng)的 ntwdblib.dll
http://msdn.microsoft.com/en-us/library/cc296170.aspx 下載php版本對(duì)應(yīng)的sqlsrv擴(kuò)展
sqlserver 配置 odbc連接需開啟extension=php_pdo_odbc.dll
*/
$mssql2008_config=array(
  'dsn'=>'odbc:Driver={SQL Server};Server=192.168.1.60;Database=his',//數(shù)據(jù)庫(kù)服務(wù)器地址
  '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] => 普通會(huì)員
      [1] => 普通會(huì)員
      [LEVEL_DETAIL] => 普通會(huì)員
      [2] => 普通會(huì)員
      [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] => 正常
    )
)*/
?>