pdo 기반의 PHP 데이터베이스 연산 클래스

이 글에서는 기본적인 데이터베이스 연결, 추가, 삭제, 수정, 연결 등을 구현할 수 있는 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[&#39;dsn&#39;], $this->Config[&#39;username&#39;], $this->Config[&#39;password&#39;]);//$dbh = new PDO(&#39;mysql:host=localhost;dbname=test&#39;, $user, $pass);
       $this->pdo->query("set names utf8");
    }catch(Exception $e){
      echo &#39;数据库连接失败,详情: &#39; . $e->getMessage () . &#39; 请在配置文件中数据库连接信息&#39;;
      exit ();
    }
    /*
    if($this->Config[&#39;type&#39;]==&#39;oracle&#39;){
      $this->pdo->query("set names {$this->Config[&#39;charset&#39;]};");
    }else{
      $this->pdo->query("set names {$this->Config[&#39;charset&#39;]};");
    }
    */
    //把结果序列化成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 数据库表，两种传值模式
  * 普通模式：
  * &#39;tb_member, tb_money&#39;
  * 数组模式：
  * array(&#39;tb_member&#39;, &#39;tb_money&#39;)
  * string/array $fields 需要查询的数据库字段，允许为空，默认为查找全部，两种传值模式
  * 普通模式：
  * &#39;username, password&#39;
  * 数组模式：
  * array(&#39;username&#39;, &#39;password&#39;)
  * string/array $sqlwhere 查询条件，允许为空，两种传值模式
  * 普通模式(必须加上and,$sqlwhere为空 1=1 正常查询)：
  * &#39;and type = 1 and username like "%os%"&#39;
  * 数组模式：
  * array(&#39;type = 1&#39;, &#39;username like "%os%"&#39;)
  * 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(&#39;, &#39;, $table);
    }
    if(is_array($fields)){
      $fields = implode(&#39;,&#39;,$fields);
      /*
      if($this->Config[&#39;type&#39;]==&#39;oracle&#39;){
        //$fields = implode(&#39;,&#39;,$fields);//CUSTOMER_ID,FIRST_NAME,LAST_NAME,EMAIL
        //$fields = implode(",&#39;UTF8&#39;,&#39;ZHS16GBK&#39;) ,convert(",$fields);
        //$fields="convert(".$fields.",&#39;UTF8&#39;,&#39;ZHS16GBK&#39;)";
      }else{
        $fields = implode(&#39;,&#39;,$fields);
      }
      */
    }
    if(is_array($sqlwhere)){
      $sqlwhere = &#39; and &#39;.implode(&#39; and &#39;, $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 数据库表，两种传值模式
  * 普通模式：
  * &#39;tb_member, tb_money&#39;
  * 数组模式：
  * array(&#39;tb_member&#39;, &#39;tb_money&#39;)
  * string/array $set 需要插入的字段及内容，两种传值模式
  * 普通模式：
  * &#39;username = "test", type = 1, dt = now()&#39;
  * 数组模式：
  * array(&#39;username = "test"&#39;, &#39;type = 1&#39;, &#39;dt = now()&#39;)
  * 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(&#39;, &#39;, $table);
    }
    if(is_array($set)){
      $s=&#39;&#39;;$i=0;
      foreach($set as $k=>$v){
        $i++;
        $s[$i]=$k;//,连接
        $val[$i]=$v;
      }
      $sarr=implode(",",$s);//去掉最后一个,
      //array_pop($sarr);
      $set=implode("&#39;,&#39;",$val);////15221579236&#39;,&#39;张三&#39;,&#39;&#39;,&#39;2001&#39;,&#39;8&#39;,&#39;4&#39;,&#39;女&#39;,&#39;是
      //$set = implode(&#39;, &#39;, $set);
    }
    //数据库操作
    if($debug === 0){
      if($mode === 2){
        $this->query("insert into $table ($sarr) values(&#39;".$set."&#39;)");
        //$return = $this->lastInsertId();
      }else if($mode === 1){
        $this->exec("insert into $table ($sarr) values(&#39;".$set."&#39;)");
        $return = $this->res;
      }else{
        $this->query("insert into $table ($sarr) values(&#39;".$set."&#39;)");
        $return = NULL;
      }
      return $return;
    }else{
      echo "insert into $table ($sarr) values(&#39;".$set."&#39;)";
      if($debug === 2){
        exit;
      }
    }
  }
  public function insert($table, $set, $debug=0, $mode=0){
    //参数处理
    if(is_array($table)){
      $table = implode(&#39;, &#39;, $table);
    }
    if(is_array($set)){
      $s=&#39;&#39;;
      foreach($set as $k=>$v){
        $s.=$k."=&#39;".$v."&#39;,";//,连接
      }
      $sarr=explode(&#39;,&#39;,$s);//去掉最后一个,
      array_pop($sarr);
      $set=implode(&#39;,&#39;,$sarr);
      //$set = implode(&#39;, &#39;, $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 数据库表，两种传值模式
  * 普通模式：
  * &#39;tb_member, tb_money&#39;
  * 数组模式：
  * array(&#39;tb_member&#39;, &#39;tb_money&#39;)
  * string/array $set 需要更新的字段及内容，两种传值模式
  * 普通模式：
  * &#39;username = "test", type = 1, dt = now()&#39;
  * 数组模式：
  * array(&#39;username = "test"&#39;, &#39;type = 1&#39;, &#39;dt = now()&#39;)
  * string/array $sqlwhere 修改条件，允许为空，两种传值模式
  * 普通模式：
  * &#39;and type = 1 and username like "%os%"&#39;
  * 数组模式：
  * array(&#39;type = 1&#39;, &#39;username like "%os%"&#39;)
  * 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(&#39;, &#39;, $table);
    }
    if(is_array($set)){
      $s=&#39;&#39;;
      foreach($set as $k=>$v){
        $s.=$k."=&#39;".$v."&#39;,";
      }
      $sarr=explode(&#39;,&#39;,$s);//去掉最后一个,
      array_pop($sarr);
      $set=implode(&#39;,&#39;,$sarr);
      //$set = implode(&#39;, &#39;, $set);
    }
    if(is_array($sqlwhere)){
      $sqlwhere = &#39; and &#39;.implode(&#39; and &#39;, $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 删除条件，允许为空，两种传值模式
  * 普通模式：
  * &#39;and type = 1 and username like "%os%"&#39;
  * 数组模式：
  * array(&#39;type = 1&#39;, &#39;username like "%os%"&#39;)
  * int $debug 是否开启调试，开启则输出sql语句
  * 0 不开启
  * 1 开启
  * 2 开启并终止程序
  * int $mode 返回类型
  * 0 无返回信息
  * 1 返回执行条目数
  */
  public function delete($table, $sqlwhere="", $debug=0, $mode=0){
    //参数处理
    if(is_array($sqlwhere)){
      $sqlwhere = &#39; and &#39;.implode(&#39; and &#39;, $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(
  &#39;dsn&#39;=>&#39;odbc:Driver={SQL Server};Server=192.168.1.60;Database=his&#39;,//数据库服务器地址
  &#39;username&#39;=>&#39;sa&#39;,
  &#39;password&#39;=>&#39;xxxxx&#39;,
);
$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(
  &#39;dsn&#39;=>&#39;mysql:host=localhost;dbname=talk&#39;,
  &#39;username&#39;=>&#39;root&#39;,
  &#39;password&#39;=>&#39;123456&#39;
);
$mysql=new PDO_DB($msyql_config);
$sql = &#39;SELECT user_id, user_name, nickname FROM et_users &#39;;
$mysql->query($sql);
$data=$mysql->fetchAll();
print_r($data);exit;
//oracle 操作
$oci_config=array(
  &#39;dsn&#39;=>&#39;oci:dbname=orcl&#39;,
  &#39;username&#39;=>&#39;BAOCRM&#39;,
  &#39;password&#39;=>&#39;BAOCRM&#39;
);
$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는 여러 파일을 zip 형식으로 압축하여 로컬로 다운로드하는 방법을 구현합니다.

PHP는 폴더를 재귀적으로 탐색하여 주석을 제거하고 PHP를 압축합니다. 소스 코드 방법 예

위 내용은 pdo 기반의 PHP 데이터베이스 연산 클래스의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!