澳门新葡萄京娱乐场PDO的mysql数据库操作类

在做项目中要动用ACCESS数据库,所以就写了三个ACCESS管理类.函数名跟ADODB类相像.

pdo的mysql教程数据库教程操作类
*
dbconfig类肩负计划数据库访谈音讯,满含:服务器地址、端口、数据库实例名、顾客名、顾客密码、字符集等。
  * dbtemplate类集结了对数据库的拜见操作,重要有以下多少个操作:
  1. queryrows : 再次来到多行记录
  2. queryrow : 重回为单条记录
  3. queryforint : 查询单字段,重临整数
  4. queryforfloat : 查询单字段,再次回到浮点数(float卡塔尔(قطر‎
  5. queryfordouble : 查询单字段,再次来到浮点数(double卡塔尔(قطر‎
  6. queryforobject : 查询单字段,再次来到对象,实际类型有数据库决定
  7. update : 实行一条立异语句. insert / upadate / delete

?php/**ACCESS数据库操作类*2008-3-26*LIQUAN*$dsn=DRIVER={MicrosoftAccessDriver(*.mdb)};DBQ=.PATH_ROOT.databasedata.mdb;*$conn=newAccess();*$conn-Connnect($dsn);*$conn-GetArray(select*fromtest);*/classAccess{var$conn;var$田野同志sName;functionAccess(State of Qatar{}//connectionfunctionConnect($dsnState of Qatar{$this-conn=newCOM(ADODB.Connection卡塔尔国ordie(CannotstartADO卡塔尔;$this-conn-Open($dsn卡塔尔国;}//重临三个functionGetOne($sql卡塔尔国{$rs=$this-conn-Execute($sql卡塔尔(قطر‎;while(!$rs-EOF){$value=$rs-Fields(0)-value;$rs-MoveNext();}$rs-Close();$rs=null;if(!empty($value卡塔尔国卡塔尔国{return$value;}else{return;}unset($valueState of Qatar;}//重返大数组functionGetArray($sql卡塔尔(قطر‎{$rs=$this-conn-Execute($sql卡塔尔;$num_columns=$rs-Fields-Count();$rowcount=0;while(!$rs-EOF){for($i=0;$i$num_澳门新葡萄京娱乐场,columns;$i++){$fieldName[$rowcount][$rs-Fields($i)-name]=$rs-Fields($i)-value;}$rowcount++;$rs-MoveNext();}$rs-Close();$rs=null;if(!empty($田野(fieldState of QatarName卡塔尔卡塔尔{return$田野(field卡塔尔Name;}else{return;}unset($田野同志Name卡塔尔;}//再次来到小数组functionGetRow($sqlState of Qatar{$rs=$this-conn-Execute($sql卡塔尔(قطر‎;$num_columns=$rs-Fields-Count();while(!$rs-EOF){for($i=0;$i$num_columns;$i++){$fieldName[$rs-Fields($i)-name]=$rs-Fields($i)-value;}$rs-MoveNext();}$rs-Close();$rs=null;if(!empty($fieldName)){return$fieldName;}else{return;}unset($fieldName);}//executeSQLfunctionExecute($sql){if($this-conn-Execute($sql)){returntrue;}else{returnfalse;}}functionClose(){$this-conn-Close();}function__destruct(){//$this-conn-Close();}}?

 */

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始于php教程5,php6准将私下认可使用pdo。差异于早先版本中混杂的数据库操作方法,pdo统一了对数据库的访谈方式,给编制程序带来了宏大的便利性。本工具类正是基于pdo,模拟了java世界spring框架中的jdbctemplate操作类
 */

发表评论

电子邮件地址不会被公开。 必填项已用*标注