1、Db.class.php
<?php
// 連接數據庫
class Db {
static public function getDB() {
try {
$pdo = new PDO(DB_DSN, DB_USER, DB_PWD);
$pdo->setAttribute(PDO::ATTR_PERSISTENT, true); // 設置數據庫連接為持久連接
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 設置拋出錯誤
$pdo->setAttribute(PDO::ATTR_ORACLE_NULLS, true); // 設置當字符串為空轉換為 SQL 的 NULL
$pdo->query('SET NAMES utf8'); // 設置數據庫編碼
} catch (PDOException $e) {
exit('數據庫連接錯誤，錯誤信息：'. $e->getMessage());
}
return $pdo;
}
}
?>
<?php
// 連接數據庫
class Db {
static public function getDB() {
try {
$pdo = new PDO(DB_DSN, DB_USER, DB_PWD);
$pdo->setAttribute(PDO::ATTR_PERSISTENT, true); // 設置數據庫連接為持久連接
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 設置拋出錯誤
$pdo->setAttribute(PDO::ATTR_ORACLE_NULLS, true); // 設置當字符串為空轉換為 SQL 的 NULL
$pdo->query('SET NAMES utf8'); // 設置數據庫編碼
} catch (PDOException $e) {
exit('數據庫連接錯誤，錯誤信息：'. $e->getMessage());
}
return $pdo;
}
}
?>
2、Model.class.php
<?php
// 操作 SQL
class Model {
/**
* SQL 增刪改操作，返回受影響的行數
* @param string $sql
* @return int
*/
public function aud($sql) {
try {
$pdo = Db::getDB();
$row = $pdo->exec($sql);
} catch (PDOException $e) {
exit($e->getMessage());
}
return $row;
}
/**
* 返回全部數據，返回 PDOStatement 對象
* @param string $sql
* @return PDOStatement
*/
public function getAll($sql) {
try {
$pdo = Db::getDB();
$result = $pdo->query($sql);
return $result;
} catch (PDOException $e) {
exit($e->getMessage());
}
}
}
?>
