/**
* 得到結(jié)果集的一條記錄
* @param null $sql
* @return mixed
*/
public function getRow($sql = null)
{
if ($sql != null) {
self::query($sql);
}
$result = self::$PDOStatement->fetch(constant("PDO::FETCH_ASSOC"));
return $result;
}
PdoMYSQL.class.php
<?php
class PdoMYSQL
{
public static $config = array();//設(shè)置配置參數(shù)鄙币，配置信息
public static $link = null;//保存連接標(biāo)識(shí)符
public static $pconnect = false;//是否開(kāi)啟長(zhǎng)連接
public static $dbVersion = null;//保存數(shù)據(jù)庫(kù)版本
public static $connected = false;//判斷是否連接成功
public static $PDOStatement = null;//保存PDOStatement對(duì)象
public static $queryStr = null;//保存最后執(zhí)行的操作
public static $error = null;//保存錯(cuò)誤信息
public function __construct($dbConfig = '')
{
if (!class_exists("PDO")) {
self::throw_exception('不支持PDO柳琢，請(qǐng)先開(kāi)啟');
}
if (!is_array($dbConfig)) {
$dbConfig = array(
'hostname' => DB_HOST,
'username' => DB_USER,
'password' => DB_PWD,
'database' => DB_NAME,
'hostport' => DB_PORT,
'dsn' => DB_TYPE . ":host=" . DB_HOST . ";dbname=" . DB_NAME);
}
if (empty($dbConfig['hostname']))
self::throw_exception('沒(méi)有定義數(shù)據(jù)庫(kù)配置竹祷，請(qǐng)先定義');
self::$config = $dbConfig;
if (empty(self::$config['params']))
self::$config['params'] = array();
if (!isset(self::$link)) {
$configs = self::$config;
if (self::$pconnect) {
//開(kāi)啟長(zhǎng)連接，添加到配置數(shù)組中
$configs['params'][constant("PDO::ATTR_PERSISTENT")] = true;
}
try {
self::$link = new PDO($configs['dsn'], $configs['username'], $configs['password'], $configs['params']);
} catch (PDOException $e) {
self::throw_exception($e->getMessage());
}
if (!self::$link) {
self::throw_exception('PDO連接錯(cuò)誤');
return false;
}
self::$link->exec('SET NAMES ' . DB_CHARSET);
self::$dbVersion = self::$link->getAttribute(constant("PDO::ATTR_SERVER_VERSION"));
self::$connected = true;
unset($configs);
}
}
/**得到所有記錄
* @param null $sql
* @return mixed
*/
public static function getAll($sql = null)
{
if ($sql != null) {
self::query($sql);
}
$result = self::$PDOStatement->fetchAll(constant("PDO::FETCH_ASSOC"));
return $result;
}
/**
* 得到結(jié)果集的一條記錄
* @param null $sql
* @return mixed
*/
public function getRow($sql = null)
{
if ($sql != null) {
self::query($sql);
}
$result = self::$PDOStatement->fetch(constant("PDO::FETCH_ASSOC"));
return $result;
}
/**
* 釋放結(jié)果集
*/
public static function free()
{
self::$PDOStatement = null;
}
public static function query($sql = '')
{
$link = self::$link;
if (!$link) return false;
//判斷之前是否有結(jié)果集漏设，如果有昙衅，釋放結(jié)果集
if (!empty(self::$PDOStatement)) self::free();
self::$queryStr = $sql;
self::$PDOStatement = $link->prepare(self::$queryStr);
$res = self::$PDOStatement->execute();
self::haveErrorThrowException();
return $res;
}
public static function haveErrorThrowException()
{
$obj = empty(self::$PDOStatement) ? self::$link : self::$PDOStatement;
$arrError = $obj->errorInfo();
/**
* Array
* (
* [0] => 42S02
* [1] => 1146
* [2] => Table 'test.user1' doesn't exist
* )
*/
// print_r($arrError);
if ($arrError[0] != '00000') {
self::$error = 'SQLSTATE ' . $arrError[0] . 'SQL Error: ' . $arrError[2] . '<br/>Error SQL: ' . self::$queryStr;
self::throw_exception(self::$error);
return false;
}
if (self::$queryStr == '') {
self::throw_exception('沒(méi)有執(zhí)行SQL語(yǔ)句');
return false;
}
}
/**
* 自定義錯(cuò)誤處理
* @param $errMsg
*/
public
static function throw_exception($errMsg)
{
echo '<div style="width:80%;background-color:#ABCDEF;color: black;font-size: 20px;padding: 20px 0px">
' . $errMsg . '</div>';
}
}
require_once 'config.php';
$PdoMySQL = new PdoMYSQL();
//var_dump($PdoMySQL);//object(PdoMYSQL)[1]
//$sql = 'select * from user';
//print_r($PdoMySQL::getAll($sql));
$sql = 'SELECT * FROM user WHERE id>4';
print_r($PdoMySQL->getRow($sql));//Array ( [id] => 13 [username] => king4 [password] => king1 [email] => imoooc1@qq.com )
Paste_Image.png
/**執(zhí)行增刪改操作愁憔，返回受影響的記錄的條數(shù)
* @param null $sql
* @return bool|int
*/
public static function execute($sql = null)
{
$link = self::$link;
if (!$link) return false;
self::$queryStr = $sql;
if (!empty(self::$PDOStatement)) self::free();
$result = $link->exec(self::$queryStr);
self::haveErrorThrowException();
if ($result) {
self::$lastInsertId = $link->lastInsertId();
self::$numRows = $result;
return self::$numRows;
} else {
return false;
}
}
PdoMYSQL.class.php
<?php
class PdoMYSQL
{
public static $config = array();//設(shè)置配置參數(shù)抹锄，配置信息
public static $link = null;//保存連接標(biāo)識(shí)符
public static $pconnect = false;//是否開(kāi)啟長(zhǎng)連接
public static $dbVersion = null;//保存數(shù)據(jù)庫(kù)版本
public static $connected = false;//判斷是否連接成功
public static $PDOStatement = null;//保存PDOStatement對(duì)象
public static $queryStr = null;//保存最后執(zhí)行的操作
public static $error = null;//保存錯(cuò)誤信息
public static $lastInsertId = null;//保存上一步插入操作產(chǎn)生AUTO_INCREMENT
public static $numRows = 0;//上一步操作產(chǎn)生受影響的記錄的條數(shù)
public function __construct($dbConfig = '')
{
if (!class_exists("PDO")) {
self::throw_exception('不支持PDO，請(qǐng)先開(kāi)啟');
}
if (!is_array($dbConfig)) {
$dbConfig = array(
'hostname' => DB_HOST,
'username' => DB_USER,
'password' => DB_PWD,
'database' => DB_NAME,
'hostport' => DB_PORT,
'dsn' => DB_TYPE . ":host=" . DB_HOST . ";dbname=" . DB_NAME);
}
if (empty($dbConfig['hostname']))
self::throw_exception('沒(méi)有定義數(shù)據(jù)庫(kù)配置糟描，請(qǐng)先定義');
self::$config = $dbConfig;
if (empty(self::$config['params']))
self::$config['params'] = array();
if (!isset(self::$link)) {
$configs = self::$config;
if (self::$pconnect) {
//開(kāi)啟長(zhǎng)連接怀喉，添加到配置數(shù)組中
$configs['params'][constant("PDO::ATTR_PERSISTENT")] = true;
}
try {
self::$link = new PDO($configs['dsn'], $configs['username'], $configs['password'], $configs['params']);
} catch (PDOException $e) {
self::throw_exception($e->getMessage());
}
if (!self::$link) {
self::throw_exception('PDO連接錯(cuò)誤');
return false;
}
self::$link->exec('SET NAMES ' . DB_CHARSET);
self::$dbVersion = self::$link->getAttribute(constant("PDO::ATTR_SERVER_VERSION"));
self::$connected = true;
unset($configs);
}
}
/**得到所有記錄
* @param null $sql
* @return mixed
*/
public static function getAll($sql = null)
{
if ($sql != null) {
self::query($sql);
}
$result = self::$PDOStatement->fetchAll(constant("PDO::FETCH_ASSOC"));
return $result;
}
/**
* 得到結(jié)果集的一條記錄
* @param null $sql
* @return mixed
*/
public static function getRow($sql = null)
{
if ($sql != null) {
self::query($sql);
}
$result = self::$PDOStatement->fetch(constant("PDO::FETCH_ASSOC"));
return $result;
}
/**執(zhí)行增刪改操作，返回受影響的記錄的條數(shù)
* @param null $sql
* @return bool|int
*/
public static function execute($sql = null)
{
$link = self::$link;
if (!$link) return false;
self::$queryStr = $sql;
if (!empty(self::$PDOStatement)) self::free();
$result = $link->exec(self::$queryStr);
self::haveErrorThrowException();
if ($result) {
self::$lastInsertId = $link->lastInsertId();
self::$numRows = $result;
return self::$numRows;
} else {
return false;
}
}
/**
* 釋放結(jié)果集
*/
public static function free()
{
self::$PDOStatement = null;
}
public static function query($sql = '')
{
$link = self::$link;
if (!$link) return false;
//判斷之前是否有結(jié)果集船响，如果有躬拢，釋放結(jié)果集
if (!empty(self::$PDOStatement)) self::free();
self::$queryStr = $sql;
self::$PDOStatement = $link->prepare(self::$queryStr);
$res = self::$PDOStatement->execute();
self::haveErrorThrowException();
return $res;
}
public static function haveErrorThrowException()
{
$obj = empty(self::$PDOStatement) ? self::$link : self::$PDOStatement;
$arrError = $obj->errorInfo();
/**
* Array
* (
* [0] => 42S02
* [1] => 1146
* [2] => Table 'test.user1' doesn't exist
* )
*/
// print_r($arrError);
if ($arrError[0] != '00000') {
self::$error = 'SQLSTATE ' . $arrError[0] . 'SQL Error: ' . $arrError[2] . '<br/>Error SQL: ' . self::$queryStr;
self::throw_exception(self::$error);
return false;
}
if (self::$queryStr == '') {
self::throw_exception('沒(méi)有執(zhí)行SQL語(yǔ)句');
return false;
}
}
/**
* 自定義錯(cuò)誤處理
* @param $errMsg
*/
public
static function throw_exception($errMsg)
{
echo '<div style="width:80%;background-color:#ABCDEF;color: black;font-size: 20px;padding: 20px 0px">
' . $errMsg . '</div>';
}
}
require_once 'config.php';
$PdoMySQL = new PdoMYSQL();
//$sql = 'INSERT user(username,password,email) ';
//$sql .= "VALUES('imooc111','imooc122','imooc@imooc.com')";
//var_dump($PdoMySQL::execute($sql));//int 1
//echo $PdoMySQL::$lastInsertId;//65
//$sql = 'DELETE FROM user WHERE id>15';
//var_dump($PdoMySQL::execute($sql));//int 22
$sql = 'UPDATE user SET username="king1234" WHERE id=14';
var_dump($PdoMySQL::execute($sql));//int 1
