当前位置: 亚洲城ca88 > ca88 > 正文

php实现的pdo公共类定义与用法示例,包含增删改

时间:2019-07-26 17:08来源:ca88
还要在实践的进度中, 假如在那之中的某条实施倒闭, 能够回滚全体已改变的操作.如若试行成功, 那么这一文山会海操作都会恒久有效.事务很好的缓慢解决了在操作数据库的时候不一同

还要在实践的进度中, 假如在那之中的某条实施倒闭, 能够回滚全体已改变的操作. 如若试行成功, 那么这一文山会海操作都会恒久有效. 事务很好的缓慢解决了在操作数据库的时候不一同的标题. 同不经常候, 通过业务去执行大数据量的时候, 实践功效能够增加广大相当多.

本文实例叙述了php达成的pdo公共类定义与用法。分享给大家供大家参照他事他说加以考察,具体如下:

正文实例叙述了PHP基于PDO完成的SQLite操作类。分享给大家供大家参谋,具体如下:

在 PDO 中, 事务已经显示煞是简单. 上边多少个大旨的事例, 演示了向 SQLite 数据库插入 一千000 条数据, 况兼在阴差阳错的时候回滚.

db.class.php :

一向代码:

复制代码 代码如下:

<?php
class db extends PDO {
  private static $_instance = null;
  protected $dbName = '';
  protected $dsn;
  protected $dbh;
  public function __construct($dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset='utf8') {
    try {
      $this->dsn = 'mysql:host=' . $dbHost . ';dbname=' . $dbName;
      $this->dbh = new PDO($this->dsn, $dbUser, $dbPasswd);
      $this->dbh->setAttribute(PDO::ATTR_EMULATE_PREPARES, false);
      $this->dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
      $this->dbh->exec('SET character_set_connection='.$dbCharset.';SET character_set_client='.$dbCharset.';SET character_set_results='.$dbCharset);
    } catch (Exception $e) {
      $this->outputError($e->getMessage()); 
    }
  }
  public static function getInstance($dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset='utf8') {
    if (self::$_instance === null) {
      self::$_instance = new self($dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset);
    }
    return self::$_instance;
  }
  public function fetchAll($sql, $params = array()) {
    try {
      $stm = $this->dbh->prepare($sql);
      if ($stm && $stm->execute($params)) {
        return $stm->fetchAll(PDO::FETCH_ASSOC);
      }
    } catch (Exception $e) {
      $this->outputError($e->getMessage());
    }
  }
  public function fetchOne($sql, $params = array()) {
    try {
      $result = false;
      $stm = $this->dbh->prepare($sql);
      if ($stm && $stm->execute($params)) {
        $result = $stm->fetch(PDO::FETCH_ASSOC);
      }
      return $result;
    } catch (Exception $e) {
      $this->outputError($e->getMessage());
    }
  }
  public function fetchColumn($sql, $params = array()) {
    $result = '';
    try {
      $stm = $this->dbh->prepare($sql);
      if ($stm && $stm->execute($params)) {
        $result = $stm->fetchColumn();
      }
      return $result;
    } catch (Exception $e) {
      $this->outputError($e->getMessage());
    }
  }
  public function insert($table, $params = array(), $returnLastId = true) {
    $_implode_field = '';
    $fields = array_keys($params);
    $_implode_field = implode(',', $fields);
    $_implode_value = '';
    foreach ($fields as $value) {
      $_implode_value .= ':'. $value.',';
    }
    $_implode_value = trim($_implode_value, ',');
    $sql = 'INSERT INTO ' . $table . '(' . $_implode_field . ') VALUES ('.$_implode_value.')';
    try {
      $stm = $this->dbh->prepare($sql);
      $result = $stm->execute($params);
      if ( $returnLastId ) {
        $result = $this->dbh->lastInsertId();
      }
      return $result;
    } catch (Exception $e) {
      $this->outputError($e->getMessage());
    }
  }
  public function update($table, $params = array(), $where = null) {
    $_implode_field = '';
    $_implode_field_arr = array();
    if ( empty($where) ) {
      return false;
    }
    $fields = array_keys($params);
    foreach ($fields as $key) {
      $_implode_field_arr[] = $key . '=' . ':'.$key;
    }
    $_implode_field = implode(',', $_implode_field_arr);
    $sql = 'UPDATE ' . $table . ' SET ' . $_implode_field . ' WHERE ' . $where;
    try {
      $stm = $this->dbh->prepare($sql);
      $result = $stm->execute($params);
      return $result;
    } catch (Exception $e) {
      $this->outputError($e->getMessage());
    }
  }
  public function delete($sql, $params = array()) {
    try {
      $stm = $this->dbh->prepare($sql);
      $result = $stm->execute($params);
      return $result;
    } catch (Exception $e) {
      $this->outputError($e->getMessage());
    }
  }
  public function exec($sql, $params = array()) {
    try {
      $stm = $this->dbh->prepare($sql);
      $result = $stm->execute($params);
      return $result;
    } catch (Exception $e) {
      $this->outputError($e->getMessage());
    }
  }
  private function outputError($strErrMsg) {
    throw new Exception("MySQL Error: " . $strErrMsg);
  }
  public function __destruct() {
    $this->dbh = null;
  }
}

细心:一定要写好数据库保存路线

try
{
$conn = new PDO('sqlite:Transactioion.s3db');
$conn->beginTransaction();
for($i=0; $i<1000000; $i )
{
$conn->exec("insert into [users] values(null,'username')");
}
ca88,$conn->commit();
}
catch(PDOException $ex)
{
$conn->rollBack();
}

实例:

<?php
// sqlite分页类
class SqliteDB{
  public function __construct(){
    // 初始化数据库,并且连接数据库 数据库配置
    $this->db = new PDO('sqlite:'.dirname(__FILE__).'log.db');
    $this->table_name=$tab;
    $this->tab_init();
  }
  public function tab_init()
  {
    # 表初始化,创建表
    $this->db->exec("CREATE TABLE log(
      id integer PRIMARY KEY autoincrement,
      urls varchar(200),
      ip varchar(200),
      datetimes datetime default (datetime('now', 'localtime'))
      )");
  }
  public function insert($tab_name,$key_list,$value_list)
  {
    // echo "INSERT INTO ".$tab_name." (".$key_list.") values(".$value_list.")";
    $result=$this->db->exec("INSERT INTO ".$tab_name." (".$key_list.") values(".$value_list.")");
    if (!$result) {
      return false;
    }
    // echo "{{{INSERT INTO ".$tab_name." (".$key_list.") values(".$value_list.")}}}}";
    $res=$this->db->beginTransaction();//事务回gun
  }
  public function total($tab_name,$tj='')//求总记录数目
  {
    $sth = $this->db->prepare('SELECT count(id) as c FROM '.$tab_name.' '.$tj);
    $sth->execute();
    $result = $sth->fetchAll();
    return $result[0]['c'];
  }
  public function update()
  {
    # 修改
  }
  function delete($value='')
  {
    # 删除
  }
  public function query($tab_name,$tj='')//表名称和条件
  {
    $sth = $this->db->prepare('SELECT * FROM '.$tab_name.' '.$tj);
    // echo 'SELECT * FROM '.$tab_name.' '.$tj;
    $sth->execute();
    $result = $sth->fetchAll();
    return $result;
  }
}
// $db=new SqliteDB();
// $res=$db->insert('log','ip,urls,datetimes','"127.0.0.1","www.baidu.com","2012-12-12 00:00:00"');//添加案例
// $res=$db->query('log');//查询案例
// $res=$db->total('log');//查询案例
// print_r($res);
// foreach ($res as $key => $row) {
// echo $row['urls'];
// }
?>

你可能感兴趣的文章:

  • php下pdo的mysql事务管理用法实例
  • PHP中PDO的事务管理深入分析
  • php的PDO事务处理体制实例解析
  • php完成基于pdo的事务管理方法躬体力行
  • PHP中PDO事务管理操作示例
  • php使用PDO事务合营表格读取大批量数码插入操作落成格局
  • php PDO实现的作业回滚示例
  • PHP基于PDO达成的SQLite操作类【包含增加和删除改查及业务等操作】
  • PHP使用pdo实现事务管理操作示例
<?php
require_once './db.class.php';
$pdo = db::getInstance('127.0.0.1', 'root', '111111', 'php_cms');
$sql = "select id, title1 from cms_wz where id = :id limit 1";
$parame = array('id' => 12,);
$res = $pdo->fetchOne($sql, $parame);
var_dump($res);
$sql = 'SELECT * FROM cms_link';
$result = $db->fetchAll($sql);
print_r($result);
//查询记录数量
$sql = 'SELECT COUNT(*) FROM cms_link';
$count = $db->fetchColumn($sql);
echo $count;
$data = array(
  'siteid' => 1,
  'linktype' => 1,
  'name' => 'google',
  'url' => 'http://www.google.com',
  'listorder' => 0,
  'elite' => 0,
  'passed' => 1,
  'addtime' => time()
  );
$lastInsertId = $db->insert('cms_link', $data);
echo $lastInsertId;
//用 try
 try {
     $result = $pdo->insert('news', $essay);
   } catch (Exception $e) {
     error_log($e->getMessage());
     error_log($e->getMessage() . ' in ' . __FILE__ . ' on line ' . __LINE__);
     saveLog('url文章 : ' . $essay['link'] . '  数据插入失败<br>');
     continue;
   }
$data = array(
  'siteid' => 1,
  'linktype' => 1,
  'name' => 'google',
  'url' => 'http://www.google.com',
  'listorder' => 0,
  'elite' => 0,
  'passed' => 1,
  'addtime' => time()
  );
$db->insert('cms_link', $data);
$sql = 'DELETE FROM cms_link WHERE linkid=4';
$result = $db->delete($sql);
var_dump($result);

越来越多关于PHP相关内容感兴趣的读者可查看本站专项论题:《PHP基于pdo操作数据库技巧总计》、《php Oracle数据库程序设计手艺计算》、《PHP MongoDB数据库操作技能大全》、《php面向对象程序设计入门教程》、《php字符串(string)用法计算》、《php mysql数据库操作入门教程》及《php常见数据库操作本事汇总》

越多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP基于pdo操作数据库技术总计》、《php Oracle数据库程序设计手艺总计》、《PHP MongoDB数据库操作手艺大全》、《php面向对象程序设计入门教程》、《php字符串(string)用法总计》、《php mysql数据库操作入门教程》及《php常见数据库操作才能汇总》

仰望本文所述对大家PHP程序设计具备支持。

意在本文所述对大家PHP程序设计有着援助。

您也许感兴趣的小说:

  • php下pdo的mysql事务管理用法实例
  • PHP中PDO的事务管理解析
  • php的PDO事务管理体制实例剖判
  • php达成基于pdo的事务管理方法身体力行
  • PHP中PDO事务管理操作示例
  • php中在PDO中使用专业(Transaction)
  • php使用PDO事务合营表格读取一大波数目插入操作达成格局
  • php PDO完结的事体回滚示例
  • PHP使用pdo完毕事务管理操作示例

您或者感兴趣的小说:

  • PHP基于PDO完结的SQLite操作类【富含增删改查及业务等操作】
  • php PDO完结的作业回滚示例
  • php使用PDO事务合作表格读取一大波多少插入操作完结格局
  • php的PDO事务管理机制实例深入分析
  • PHP中PDO的事务管理分析
  • php下pdo的mysql事务管理用法实例
  • php中在PDO中使用工作(Transaction)
  • ThinkPHP完毕专门的学业回滚示例代码
  • PHP操作MySQL事务实例
  • php mysql事务rollback&commit示例
  • php达成基于pdo的事务管理方法身体力行

编辑:ca88 本文来源:php实现的pdo公共类定义与用法示例,包含增删改

关键词: 亚洲城ca88