教程集 www.jiaochengji.com
教程集 >  脚本编程  >  php  >  正文 一个php pdo mysql操作类

一个php pdo mysql操作类

发布时间:2017-10-29   编辑:jiaochengji.com
分享一个简单的PDO mysql数据库操作类,实现增、删、改、查功能,用来学习php pdo的用法很不错。

例子,pdo操作类,学习下php pdo的用法。
 

复制代码 代码示例:

<?php
/**
 * PDO 操作
 * Created by PhpStorm.
 * User: sumiaowen
 * Date: 13-11-28
 * Time: 下午9:12
 * To change this template use File | Settings | File Templates.
 */
class Pdo_db
{
 private $dns = null;
 private $username = null;
 private $password = null;
 private $conn = null;
 private static $_instance = null;

 private function __construct($params = array())
 {
  $this->dns      = $params['dns'];
  $this->username = $params['username'];
  $this->password = $params['password'];

  $this->_connect();
 }

 private function __clone() { }

 public function get_instance($params = array())
 {
  if(!(self::$_instance instanceof self))
  {
   self::$_instance = new self($params);
  }

  return self::$_instance;
 }

 private function _connect()
 {
  try
  {
   $this->conn = new PDO($this->dns, $this->username, $this->password);
   $this->conn->query('set names utf8');
  }
  catch(PDOException $e)
  {
   exit('PDOException: ' . $e->getMessage());
  }
 }

 /**
  * 查询一条SQL语句
  * @param string $sql
  * @param array  $parameters 需要绑定的参数
  * @param int    $option
  * @return array
  */
 public function query($sql, $parameters = array(), $option = PDO::FETCH_ASSOC)
 {
  $stmt = $this->conn->prepare($sql);
  $stmt->execute($parameters);

  $tmp = array();
  while($row = $stmt->fetch($option))
  {
   $tmp[] = $row;
  }

  return $tmp;
 }

 /**
  * 插入一条数据
  * @param string $sql
  * @param array  $parameters
  * @return int  1 or 0 返回影响行数
  */
 public function insert($sql, $parameters = array())
 {
  $stmt = $this->conn->prepare($sql);
  $stmt->execute($parameters);

  return $stmt->rowCount();
 }

 /**
  * 更新一条数据
  * @param string $sql
  * @param array  $parameters
  * @return int  1 or 0 返回影响行数
  */ www.jbxue.com
 public function update($sql, $parameters = array())
 {
  $stmt = $this->conn->prepare($sql);
  $stmt->execute($parameters);

  return $stmt->rowCount();
 }

 /**
  * 删除一条数据
  * @param string $sql
  * @param array  $parameters
  * @return int  1 or 0 返回影响行数
  */
 public function delete($sql, $parameters = array())
 {
  $stmt = $this->conn->prepare($sql);
  $stmt->execute($parameters);

  return $stmt->rowCount();
 }
}

代码链接地址:https://github.com/sumiaowen/mynotes/tree/master/pdo_mysql_class

您可能感兴趣的文章:
php pdo函数库用法详解
PHP PDO数据库类的insert操作
php5使用pdo连接数据库实例
PHP PDO数据库类update操作
PHP PDO数据库类delete操作
学习使用PDO查询Mysql来避免SQL注入风险
php mysqli和mysql区别详解
php中pdo错误处理方法详解
深入分析PHP PDO配置及使用方法
有关PHP中PDO连接数据库的详细教程与实际操作演示

关键词: pdo  php mysql类  php pdo   
[关闭]
~ ~