时时商务社区

标题: PHP实现PDO的mysql数据库操作类 [打印本页]

作者: wx_pylelnL4 时间: 2018-2-14 05:51

         本文实例讲述了PHP实现PDO的mysql数据库操作类。分享给大家供大家参考。具体分析如下：
dbconfig类负责配置数据库访问信息,包括:服务器地址、端口、数据库实例名、用户名、用户密码、字符集等.
dbtemplate类集合了对数据库的访问操作,主要有以下几个操作:
1. queryrows:返回多行记录
2. queryrow:返回为单条记录
3. queryforint:查询单字段,返回整数
4. queryforfloat:查询单字段,返回浮点数(float)
5. queryfordouble:查询单字段,返回浮点数(double)
6. queryforobject:查询单字段,返回对象,实际类型有数据库决定
7. update : 执行一条更新语句. insert / upadate / delete
具体代码如下：
[U]复制代码[/U] 代码如下:class dbconfig {
private static $dbms = "mysql";
private static $host = '127.0.0.1';
private static $port = '3306';
private static $username = '';
private static $password = '';
private static $dbname = '';
private static $charset = 'utf-8';
private static $dsn;

/**
   *
   * @return 返回pdo dsn配置
   */
public static function getdsn() {
      if (!isset(self:

dsn)) {
self:

dsn = self:

dbms . ':host=' . self:

host . ';port=' .
self:

port . ';dbname=' . self:

dbname;
if (strlen(self:

charset) > 0) {
self:

dsn = self:

dsn . ';charset=' . self:

charset;
         }
      }
      return self::$dsn;
}

/**
   * 设置mysql数据库服务器主机
   * @param  $host 主机的ip地址
   */
public static function sethost($host) {
      if (isset($host) && strlen($host) > 0)
         self::$host = trim($host);
}

/**
   * 设置mysql数据库服务器的端口
   * @param  $port 端口
   */
public static function setport($port) {
      if (isset($port) && strlen($port) > 0)
         self::$port = trim($port);
}

/**
   * 设置mysql数据库服务器的登陆用户名
   * @param  $username
   */
public static function setusername($username) {
      if (isset($username) && strlen($username) > 0)
         self::$username = $username;
}

/**
   * 设置mysql数据库服务器的登陆密码
   * @param  $password
   */
public static function setpassword($password) {
      if (isset($password) && strlen($password) > 0)
         self::$password = $password;
}

/**
   * 设置mysql数据库服务器的数据库实例名
   * @param  $dbname 数据库实例名
   */
public static function setdbname($dbname) {
      if (isset($dbname) && strlen($dbname) > 0)
         self::$dbname = $dbname;
}

/**
   * 设置数据库编码
   * @param  $charset
   */
public static function setcharset($charset) {
      if (isset($charset) && strlen($charset) > 0)
         self::$charset = $charset;
}

}

/**
* 一个数据库操作工具类
*
* @author zhjiun@gmail.com
*/
class dbtemplate {

/**
   * 返回多行记录
   * @param  $sql
   * @param  $parameters
   * @return  记录数据
   */
public function queryrows($sql, $parameters = null) {
      return $this->exequery($sql, $parameters);
}

/**
   * 返回为单条记录
   * @param  $sql
   * @param  $parameters
   * @return
   */
public function queryrow($sql, $parameters = null) {
      $rs = $this->exequery($sql, $parameters);
      if (count($rs) > 0) {
         return $rs[0];
      } else {
         return null;
      }
}

/**
   * 查询单字段，返回整数
   * @param  $sql
   * @param  $parameters
   * @return
   */
public function queryforint($sql, $parameters = null) {
      $rs = $this->exequery($sql, $parameters);
      if (count($rs) > 0) {
         return intval($rs[0][0]);
      } else {
         return null;
      }
}

/**
   * 查询单字段，返回浮点数(float)
   * @param  $sql
   * @param  $parameters
   * @return
   */
public function queryforfloat($sql, $parameters = null) {
      $rs = $this->exequery($sql, $parameters);
      if (count($rs) > 0) {
         return floatval($rs[0][0]);
      } else {
         return null;
      }
}

/**
   * 查询单字段，返回浮点数(double)
   * @param  $sql
   * @param  $parameters
   * @return
   */
public function queryfordouble($sql, $parameters = null) {
      $rs = $this->exequery($sql, $parameters);
      if (count($rs) > 0) {
         return doubleval($rs[0][0]);
      } else {
         return null;
      }
}

/**
   * 查询单字段，返回对象，实际类型有数据库决定
   * @param  $sql
   * @param  $parameters
   * @return
   */
public function queryforobject($sql, $parameters = null) {
      $rs = $this->exequery($sql, $parameters);
      if (count($rs) > 0) {
         return $rs[0][0];
      } else {
         return null;
      }
}

/**
   * 执行一条更新语句.insert / upadate / delete
   * @param  $sql
   * @param  $parameters
   * @return  影响行数
   */
public function update($sql, $parameters = null) {
      return $this->exeupdate($sql, $parameters);
}

private function getconnection() {
      $conn = new pdo(dbconfig::getdsn(), dbconfig::getusername(), dbconfig::getpassword());
      $conn->setattribute(pdo::attr_case, pdo::case_upper);
      return $conn;
}

private function exequery($sql, $parameters = null) {
      $conn = $this->getconnection();
      $stmt = $conn->prepare($sql);
      $stmt->execute($parameters);
      $rs = $stmt->fetchall();
      $stmt = null;
      $conn = null;
      return $rs;
}

private function exeupdate($sql, $parameters = null) {
      $conn = $this->getconnection();
      $stmt = $conn->prepare($sql);
      $stmt->execute($parameters);
      $affectedrows = $stmt->rowcount();
      $stmt = null;
      $conn = null;
      return $affectedrows;
}
}
pdo始于php5,php6中将默认使用pdo,不同于以前版本中混乱的数据库操作方式,pdo统一了对数据库的访问方式,给编程带来了极大的便利性,本工具类就是基于pdo,模拟了java世界spring框架中的jdbctemplate操作类.
希望本文所述对大家的PHP程序设计有所帮助。


您可能感兴趣的文章:

支持php4、php5的mysql数据库操作类

php mysql数据库操作类

discuz7 phpMysql操作类

php下mysql数据库操作类(改自discuz)

全新的PDO数据库操作类php版（仅适用Mysql）

PHP数据库操作之基于Mysqli的数据库操作类库

php实现可用于mysql,mssql,pg数据库操作类

php实现Mysql简易操作类

php实现的mysqldb读写分离操作类示例

php mysql数据库操作类(实例讲解)

PHP实现的mysql操作类【MySQL与MySQLi方式】

欢迎光临时时商务社区 (http://bbs.4435.cn/)