PHP PDO 操作 MYSQL カプセル化クラス-PHPチュートリアル-php.cn

/**
* 著者 soulence
* データクラスファイルを呼び出す
* 2015/06/12 を修正
*/
class DBConnect
{
private $dbname = null;
private $pdo = null;
private $persistent = false;
private $statement = null;
private $lastInsID = null;
private static $_instance = [];
private function __construct($dbname,$attr)
{
$this->dbname = $dbname;
$this->persistent = $ attr;
}
public static function db($flag='r',$persistent=false)
{
if(!isset($flag)){
$flag = 'r';
}
if ( !class_exists('PDO'))
{
throw new Exception('not found PDO');
return false;
}
$mysql_server = Yaf_Registry::get('mysql');
if(!isset($mysql_server[$flag])){
return false;
}
$options_arr = array(PDO::MYSQL_ATTR_INIT_COMMAND => ; 'SET NAMES '.$mysql_server[$flag]['charset'],PDO::ATTR_DEFAULT_FETCH_MODE=>PDO::FETCH_ASSOC);
if($persistent === true){
$options_arr[PDO::ATTR_PERSISTENT ] = true;
}
try {
$pdo = new PDO($mysql_server[$flag]['connectionString'],$mysql_server[$flag]['username'],$mysql_server[$flag]['password '],$options_arr);
} catch (PDOException $e) {
throw new Exception($e->getMessage());
//exit('连接失败:'.$e->getMessage());
false を返します。
}
if(!$pdo) {
throw new Exception('PDO CONNECT ERROR');
false を返します。
}
return $pdo;
}
/**
* 操作データベースオブジェクトを取得します
* @param string $dbname 対応するデータベースは誰ですか?
* @param bool $attr 接続が長いかどうか
* false を返すと、指定されたデータベースが存在しないことを示します
*/
public static function getInstance($dbname = 'r',$attr = false)
{
$mysql_server = Yaf_Registry::get(' mysql');
if(!isset($mysql_server[$dbname])){
return false;
}
$key = md5(md5($dbname.$attr,true));
if (!isset(self) ::$_instance[$key]) || !is_object(self::$_instance[$key]))
self::$_instance[$key] = 新しい self($dbname,$attr);
return self: :$_instance[$key];
}
プライベート関数 getConnect(){
$this->pdo = self::db($this->dbname,$this->persistent);
}
/**
* クエリ操作
* @param string $sql クエリを実行する SQL 文
* @param array $data クエリの条件付き形式は [':id'=>$id,':name'=>$ name](推奨) または [1=>$id,2=>$name]
* @param bool $one コンテンツの一部を返すかどうか、デフォルトは no です
*/
public function query($sql, $data = [], $one = false)
{
if (!is_array($data) || empty($sql) || !is_string( $sql))
return false;
$this->free();
return $this->queryCommon($data,$sql,$one);
}
/**
* 内部クエリの一般的なメソッド
* /
プライベート関数 queryCommon($data,$sql,$one)
{
$this->pdoExec($data,$sql);
if ($one){
return $this->statement-> ;fetch(PDO::FETCH_ASSOC);
}else{
return $this->statement->fetchAll(PDO::FETCH_ASSOC);
}
}
/**
* 複数のSQL文のクエリ操作
* @param array $arr_sql クエリを実行するSQL文の配列形式は[$sql1,$sql2]です
* @param array $arr_data クエリ$arr_sqlに対応する条件付き形式は[ [' :id'=>$id,':name'=>$name],[':id'=>$id,':name'=>$name]] (推奨) または [[ 1 =>$id,2=>$name],[1=>$id,2=>$name]]
* @param bool $one コンテンツを返すかどうか。デフォルトは no です。 true に設定すると、各 SQL は 1 つのデータのみを返します
*/
パブリック関数クエリ($arr_sql, $arr_data = [], $one = false)
{
if(!is_array($arr_sql) ||空($arr_sql) || !is_array($arr_data))
return false;
$this->free();
$res = [];$i = 0;
foreach ($arr_sql as $val) {
if(!isset ($arr_data[$i]))
$arr_data[$i] = [];
elseif(!is_array($arr_data[$i]))
throw new Exception('SQL: をクエリするエラー'.$val. ' ここで:'.$arr_data[$i]);
$res[] = $this->queryCommon($arr_data[$i],$val,$one);
$i++;
}
return $レス;
}
/**
* ページングのカプセル化
*
* @param string $sql
* @param int $page はどのページから開始するかを示します
* @param int $pageSize はページあたりの項目数を示します
* @param array $data クエリ条件
*/
public function limitQuery($sql, $page=0, $pageSize=20, $data = [])
{
$page = intval($page);
if ($ page return [];
}
$pageSize = intval($pageSize);
if ($pageSize > 0) { // pageSize が 0 のときはすべてのデータを表示
$sql .= ' LIMIT ' 。 $pageSize;
if ($page > 0) {
$start_limit = ($page - 1) * $pageSize;
$sql .= ' OFFSET ' 。 $start_limit;
}
}
return $this->query($sql, $data);
}
/**
* トランザクション操作による操作の追加、削除、変更に使用されます
* @param string $sql クエリを実行するSQL文
* @param array $data クエリの条件付き形式は [':id'=>] ;$id,' :name'=>$name] (推奨) または [1=>$id,2=>$name]
* @param bool $Transaction トランザクション操作のデフォルトが No かどうか
*/
public functionexecuteDDL($sql, $data = [],$ Transaction = false){
if (!is_array($data) || !is_string($sql))
return false;
$this->free();
if($Transaction)
$this-> ;pdo->beginTransaction();//开启事务
try{
$this->gt;execRes($data,$sql);
if($Transaction)
$this->gt;pdo->commit() ;//事务提交
return $this->lastInsID;
} catch (Exception $e) {
if($Transaction)
$this->pdo->rollBack();//事务回滚
throw new Exception('Error DDLExecute <=====>'.$e->getMessage());
return false;
}
}
/**
* トランザクション操作を使用して追加、削除、変更操作を実行するために使用されます
* 複数の項目を実行します
* @param array $arr_sql 実行する必要がある SQL ステートメントの配列
* @param array $arr_data配列に対応する SQL 文
* @param bool $Transaction トランザクション操作のデフォルトが No かどうか
*/
public functionexecuteDDLes( $arr_sql, $arr_data = [],$Transaction = false){
if(!is_array($arr_sql) || empty($arr_sql) || !is_array($arr_data))
return false;
$res = [];
$this->free();
if($Transaction)
$this->pdo->beginTransaction();//开启事务
try{
$i = 0;
foreach ($arr_sql as $val){
if(!isset($arr_data[$i]))
$arr_data[$i] = [];
elseif(!is_array($arr_data[$i])){
if ($Transaction)
$this->pdo->rollBack();//事务回滚
throw new Exception('DDLExecutees sql:'.$val.' where:'.$arr_data[$i] );
}
$this->execRes($arr_data[$i],$val);
$res[] = $this->lastInsID;
$i++;
}
if($Transaction)
$this->pdo->commit();//事务提交
return $res;
} catch (Exception $e) {
if($Transaction)
$this->pdo->rollBack ();//事务回滚
throw new Exception('Error DDLExecutees array_sql:'.json_encode($arr_sql).' <=====>'.$e->getMessage());
return false;
}
return $res;
}
/**
* このメソッドは、クエリによって返される項目の数を計算するために使用されます。 SELECT COUNT(*) FROM TABLE... または SELECT COUNT(0) FROM TABLE... のみをサポートしていることに注意してください。
* @param string $sqlクエリのSQL文
* @param array $data SQL文の条件
*/
public function countRows($sql,$data = []){
if (!is_array($data) ||空($sql) || !is_string($sql))
return false;
$this->free();
$res = $this->pdoExec($data,$sql);
if($res == false)
return false;
return $this->statement->fetchColumn();
}
/**
* このメソッドは、クエリによって返される項目の数を計算するために使用されます。
* @param string $sql クエリの SQL ステートメント
* @param array $data の条件。 SQL ステートメント
*/
public function countRowses($arr_sql,$arr_data = []){
if(!is_array($arr_sql) || empty($arr_sql) || !is_array($arr_data) )
return false;
$res = [];
$this->free();
$i = 0;
foreach ($arr_sql as $val) {
if(!isset($arr_data[$ i]))
$arr_data[$i] = [];
elseif(!is_array($arr_data[$i]))
throw new Exception('Error where CountRowses sql:'.$val.' where:'. $arr_data[$i]);
$res1 = $this->pdoExec($arr_data[$i],$val);
if($res1 == false)
$res[] = false;
else
$res[] = $this->statement->fetchColumn();
}
return $res;
}
/**
* プロジェクトではトランザクションを開いて操作を実行し、最後に送信する必要が多数あるため、ここでは別の方法を示します
* @param bool $Transaction トランザクション操作を実行するかどうか、デフォルトは no です
*/
public function getDB($Transaction=false)
{
$this->Transaction = $Transaction;
$this->getConnect();
if($Transaction === true)
$this->pdo->beginTransaction();//开启事务
return $this;
}
/**
* このメソッドは複数回実行できます。DDL ステートメントを実行するために使用されます。
* getDB および sQCommit と一緒に使用する必要があることに注意してください。
* トランザクション sQCommit メソッドが有効になっていない場合は、呼び出す必要はありません
* @param string $sql query SQL文
* @param array $data SQL文の条件
*/
public function execSq($sql,$data = [])
{
if($this->checkParams($sql,$data) === false)
return false;
try{
$this->execRes($data,$sql);
return $this->lastInsID;
} catch (Exception $e) {
if(isset) ($this->Transaction) && $this->Transaction === true)
$this->pdo->rollBack();//事务回滚
throw new Exception('Error execSq<== ===>'.$e->getMessage());
return false;
}finally {
if (!empty($this->statement))
{
$this->statement-> ;closeCursor();
unset($this->statement);
}
}
}
/**
* クエリを実行するメソッドには接続データベースオブジェクトを渡す必要があります
* @param string $sql クエリを実行する SQL ステートメント
* @param array $data クエリの条件付き形式は [':id'=>] です。 $id,': name'=>$name] (推奨) または [1=>$id,2=>$name]
* @param bool $one コンテンツの一部を返すかどうか、デフォルトはいや
*/
public function querySq($sql,$data = [],$one = false )
{
if($this->checkParams($sql,$data) === false)
return false;
return $this->pdoExecSq($sql,$data,[1,$one] );
}
/**
* ページングのカプセル化
*
* @param string $sql
* @param int $page はどのページから開始するかを示します
* @param int $pageSize はページあたりの項目数を示します
* @param array $data クエリ条件
*/
public function limitQuerySq($sql, $page=0, $pageSize=20, $data = [])
{
$page = intval($page);
if ($page return [];
}
$pageSize = intval($pageSize);
if ($pageSize > 0) { // pageSize が 0 の場合はすべてのデータを表示
$sql .= ' LIMIT ' . $pageSize;
if ($page > 0) {
$start_limit = ($page - 1) * $pageSize;
$sql .= ' OFFSET ' 。 $start_limit;
}
}
return $this->querySq($sql, $data);
}
/**
* このメソッドは、クエリによって返される項目の数を計算するために使用されます。 SELECT COUNT(*) FROM TABLE... または SELECT COUNT(0) FROM TABLE... のみをサポートしていることに注意してください。
* @param string $sqlクエリのSQL文
* @param array $data SQL文の条件
*/
public function countRowsSq($sql,$data = []){
if($this->checkParams($sql,$data) === false)
return false;
return $this->pdoExecSq($sql,$data,[2]);
}
/**
* これは最後のコミット操作です。トランザクションが開始されていない場合、このメソッドを最後に呼び出す必要はありません。*/
public function sQCommit()
{
if(empty($this->pdo) || !is_object($this->pdo))
return false;
if( isset($this->Transaction) && $this->Transaction === true)
$this->pdo->commit();//提交事务
unset($this->pdo);
}
/**
* 内部呼び出しメソッド
*/
public function checkParams($sql,$data)
{
if (empty($this->pdo) || !is_object($this->pdo) | | !is_array($data) || empty($sql) || !is_string($sql))
return false;
return true;
}
/**
* 内部呼び出しメソッド
*/
プライベート関数 pdoExecSq($ sql,$data,$select = []){
try{
$res = $this->pdoExec($data,$sql);
if(empty($select))
return $res;
else{
if($select[0] === 1){
if($select[1] === true)
return $this->statement->fetch(PDO::FETCH_ASSOC);
else
return $this->statement->fetchAll(PDO::FETCH_ASSOC);
}elseif($select[0] === 2)
return $this->statement->fetchColumn();
else
return false;
}
} catch (Exception $e) {
throw new Exception($e->getMessage());
return false;
}finally {
if (!empty($this->statement))
{
$this->statement->closeCursor();
unset($this->statement);
}
}
}
/**
* 内部呼び出しメソッド
*/
プライベート関数 execRes($data ,$sql){
$res = $this->pdoExec($data,$sql);
$in_id = $this->pdo->lastInsertId();
if (preg_match("/ ^s*(INSERTs+INTO|REPLACEs+INTO)s+/i", $sql) && !empty($in_id))
$this->lastInsID = $in_id;
else
$this->lastInsID = $ res;
}
/**
* SQLステートメントを直接実行するために使用される内部呼び出しメソッド
*/
プライベート関数 pdoExec($data,$sql){
$this->statement = $this->pdo->prepare($sql);
if (false === $this->statement)
return false;
if (!empty($data))
{
foreach ($data as $k => $v)
{
$this->statement->bindValue($k, $v);
}
}
$res = $this->statement->execute();
if (!$ res)
{
throw new Exception('sql:'.$sql.'<====>where:'.json_encode($data).'<====>error:'.json_encode ($this->statement->errorInfo()));
}else{
return $res;
}
}
/**
* 解放に使用される内部呼び出しメソッド
*/
private function free()
{
if ( is_null($this->pdo))
$this->getConnect();
if (!empty($this->statement))
{
$this->statement->closeCursor() ;
$this->statement = null;
}
}
}
?>

复制代

PHP、PDO、MYSQL