共有:PDOベースmysqlデータベース操作ツールクラス


PHPではデータベースを操作してPDOを使用することが多くなり、PDOはPHP 5から始まり、PHP 6ではデフォルトでPDOが使用されます.以前のバージョンで混乱していたデータベースの操作方式とは異なり、PDOはデータベースへのアクセス方式を統一し、プログラミングに大きな利便性をもたらした.このツールクラスはPDOに基づいてjava世界springフレームワークのJdbcTemplate操作クラスをシミュレートしています.2つのクラスがあります:*DbConfigクラスは、サーバアドレス、ポート、データベースインスタンス名、ユーザー名、ユーザーパスワード、文字セットなど、データベースアクセス情報の構成を担当します.*DbTemplateクラスには、データベースへのアクセス操作が集合しています.主に次の操作があります.1.QueryRows:複数行のレコードを返します.QueryRow:単一レコードに戻る3.QueryForInt:単一フィールドをクエリーし、整数4を返します.QueryForFloat:単一フィールドを問合せ、浮動小数点数(float)5を返します.QueryForDouble:単一フィールドをクエリーし、浮動小数点数(double)6を返します.QueryForObject:クエリーシートフィールド、オブジェクトを返します.実際のタイプはデータベースによって決まります.update:更新文を実行します.Insert/upadate/deleteはどのように使用しますか?
DbConfig::setHost('127.0.0.1');
DbConfig::setPort('3306');
DbConfig::setDbname('xxxx');
DbConfig::setUsername('xxxx');
DbConfig::setPassword('xxxx');
DbConfig::setCharset('utf-8');

//    
$sql = 'select id from table_name where id = ?';
$db = new DbTemplate();
$row = $db->queryRow($sql, array($id));
print $row['ID'];  //        

//    
$sql = 'select id from table_name';
$db = new DbTemplate();
$rows = $db->queryRow($sql);
foreach ($row as $rows) {
    print $row['ID']; //        
}

ソースコード
/**
 *         
 *
 * @author [email protected]
 */
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 [email protected]
 */
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;
    }
}


 
原文住所:http://buzheng.org/blog/mysql-pdo-utils