PHP封装的PDO数据库操作类实例

<?php
class databasehandler {
    /**
     * sql语句查询
     */
    public static function query_data ($dataname,$sql,$query=array()) {
      $result = array();
      if (!empty($sql)) {
        $data = bj_pdodb::factory($dataname)->allprepare($sql, $query);
        if (!$data->isempty()) {
          $result = $data->data;
        }
      }
      return $result;
    }
    /**
     * 查询数据
     */
    public static function select_data ($dataname,$tablename,$where,$param=array(),$desc='') {
      $result = array();
      $query = array();
      $query_str = '1=1';
      $tmp = '';
      $str_arr = '';
      if (!empty($param)) {
        $str = '';
        foreach ($param as $val) {
          $str .= '`'.$val.'`,';
        }
        $str = substr($str,0,-1);
      }
      $str_arr = !empty($str) ? $str : '*';
      if ( !empty($where) ) {
        foreach ($where as $key => $value) {
          $tmp .= ' and '.$key.'=:'.$key.'';
          $query[':'.$key] = $value;
        }
      }
      $query_str .= $tmp;
      if (!empty($desc)) {
        $query_str .= $desc;
      }
      $sql = "select {$str_arr} from `".$tablename."` where {$query_str} ";
      $query_data = bj_pdodb::factory($dataname)->allprepare($sql, $query);
      if ( !$query_data->isempty() ) {
        $result = $query_data->data;
      }
      return $result;
    }
    /**
     * 批量添加信息
     */
    public static function insert_data($dataname,$tablename,$add_param){
      $flag = false;
      if (!empty($add_param)) {
        $fileds = array();
        $str = '';
        foreach($add_param as $k=>$val){
          $str .= '(';
          $i = 0;
          foreach ($val as $key=>$vl) {
            $fileds[$i] = '`'.$key.'`';
            $str .= "'".addslashes($vl)."',";
            $i++;
          }
          $str = substr($str,0,-1);
          $str .= '),';
        }
        $filed_str = implode(',',$fileds);
        $val_str = substr($str,0,-1);
        $sql = "insert into `".$tablename."` ({$filed_str}) values {$val_str}";
        $ret = bj_pdodb::factory($dataname)->insertprepare($sql);
        if ( !$ret->isempty() ) {
            $insertid = $ret->data;
            if($insertid > 0){
              return $insertid;
            }
        }
      }
      return $flag;
    }
  /**
   * 删除数据
   */
  public static function delete_data ($dataname,$tablename,$id) {
    $query = array(':id' => $id);
    $sql = "delete from ". $tablename. " where `id`=:id";
    $db_res = bj_pdodb::factory($dataname)->simpleprepare($sql,$query);
    return $db_res->data;
  }
  /**
   * 更新数据
   */
  public static function update_data ($dataname,$tablename,$id,$array) {
    $flag = false;
    if ( !empty($array) && !empty($id)) {
      $query = array(':id' => $id);
      $up_str = '';
      foreach($array as $key=>$val) {
        $query[':'.$key] = addslashes($val);
        $up_str .= '`'.$key.'`=:'.$key.',';
      }
      $up_str = substr($up_str,0,-1);
      $sql = "update `".$tablename."` set ".$up_str." where `id`=:id";
      $db_res = bj_pdodb::factory($dataname)->changeprepare($sql, $query);
      $flag = true;
    }
    return $flag;
  }
  /**
   * 事务
   */
  public static function transactionhandler($dataname,$type){
    switch ($type) {
      case 'begin':
        return bj_pdodb::factory($dataname)->begintransaction();
        break;
      case 'commit':
        return bj_pdodb::factory($dataname)->commit();
        break;
      case 'rollback':
        return bj_pdodb::factory($dataname)->rollback();
        break;
      default :
        exit;
    }
  }
  /**
   * curl获取数据get
   */
  public static function curl_data ($curl_url){
    if (!empty($curl_url)) {
      $ch = curl_init();
      curl_setopt($ch, curlopt_url, $curl_url);
      curl_setopt($ch, curlopt_returntransfer, 1);
      curl_setopt($ch, curlopt_header, 0);
      $output = curl_exec($ch);
      curl_close($ch);
      return $output;
    }
    return false;
  }
  /**
   * curl提交数据
   */
  public static function curl_data_post ($ch_url,$param) {
    $result = array();
    if (!empty($ch_url) && !empty($param)) {
      $query_string = http_build_query($param);
      $ch = curl_init();
      curl_setopt($ch, curlopt_url, $ch_url);
      curl_setopt($ch, curlopt_returntransfer,1);
      curl_setopt($ch, curlopt_post,1);
      curl_setopt($ch, curlopt_postfields, $query_string);
      curl_setopt($ch, curlopt_httpheader,array("application/x-www-form-urlencoded; charset=utf-8"));
      $output = curl_exec($ch);
      curl_close($ch);
      $result = !empty($output) ? json_decode($output,true) : array();
    }
    return $result;
  }
}