PHP implements PDO's mysql database operation class, phppdomysql database_PHP tutorial

PHP implements PDO’s mysql database operation class, phppdomysql database

The example in this article describes the mysql database operation class that implements PDO in PHP. Share it with everyone for your reference. The specific analysis is as follows:

The dbconfig class is responsible for configuring database access information, including: server address, port, database instance name, user name, user password, character set, etc.

The dbtemplate class collects database access operations , which mainly include the following operations:

1. queryrows: return multiple rows of records

2. queryrow: returns a single record

3. queryforint: Query a single field and return an integer

4. queryforfloat: Query a single field and return a floating point number (float)

5. queryfordouble: Query a single field and return a floating point number (double)

6. queryforobject: Query a single field and return an object. The actual type is determined by the database

7. update: execute an update statement. insert / upadate / delete

The specific code is as follows:

Copy code The code is as follows:

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 Return pdo dsn configuration
​​*/
    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;
    }
 
    /**
* * Set up mysql database server host
* @param $host IP address of the host
​​*/
    public static function sethost($host) {
        if (isset($host) && strlen($host) > 0)
            self::$host = trim($host);
    }
 
    /**
* *Set the port of mysql database server
* @param $port port
​​*/
    public static function setport($port) {
        if (isset($port) && strlen($port) > 0)
            self::$port = trim($port);
    }
 
    /**
* * Set the login user name of the mysql database server
* @param $username
​​*/
    public static function setusername($username) {
        if (isset($username) && strlen($username) > 0)
            self::$username = $username;
    }
 
    /**
* *Set the login password for the mysql database server
* @param $password
​​*/
    public static function setpassword($password) {
        if (isset($password) && strlen($password) > 0)
            self::$password = $password;
    }
 
    /**
* * Set the database instance name of the mysql database server
* @param $dbname database instance name
​​*/
    public static function setdbname($dbname) {
        if (isset($dbname) && strlen($dbname) > 0)
            self::$dbname = $dbname;
    }
 
    /**
* Set database encoding
* @param $charset
​​*/
    public static function setcharset($charset) {
        if (isset($charset) && strlen($charset) > 0)
            self::$charset = $charset;
    }
 
}
 
/**
* A database operation tool class
*
* @author zhjiun@gmail.com
​*/
class dbtemplate {
 
    /**
     * 返回多行记录
     * @param  $sql
     * @param  $parameters
     * @return  记录数据
     */
    public function queryrows($sql, $parameters = null) {
        return $this->exequery($sql, $parameters);
    }
 
    /**
* Return as a single record
* @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;
        }
    }
 
    /**
* Query a single field and return an integer
* @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;
        }
    }
 
    /**
* Query a single field and return a floating point number (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;
        }
    }
 
    /**
* Query a single field and return a floating point number (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;
        }
    }
 
    /**
* Query a single field and return an object. The actual type is determined by the database
* @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程序设计有所帮助。

http://www.bkjia.com/PHPjc/926869.htmlwww.bkjia.comtruehttp://www.bkjia.com/PHPjc/926869.htmlTechArticlePHP实现PDO的mysql数据库操作类，phppdomysql数据库 本文实例讲述了PHP实现PDO的mysql数据库操作类。分享给大家供大家参考。具体分析如下： d...