PHP は PDO を使用してデータベースクラスを操作します (Mysql に適用)

/*** 著者: Hu Rui * 日付: 2012/07/21 * 電子メール: hooray0905@foxmail.com */ class HRDB{ protected $pdo; protected $res; protected $config;

/*コンストラクター*/ function __construct($config){ $this->Config = $config; $this->connect(); }

public function connect(){ $this->pdo = new PDO($this->Config['dsn'], $this->Config['name'], $ this ->Config['password']); $this->pdo->query('set names utf8;'); //結果を stdClass にシリアル化します //$this->pdo- &gt ;setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ); //例外をキャッチする独自のコードを作成します $this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); }&lt ; /p> /*データベースを閉じる*/ パブリック関数 close(){ $this->pdo = null; }

パブリック関数クエリ($sql) ) { $res = $this->pdo->query($sql); if($res){ $this->res = $res; } } public function exec($sql) ) { $res = $this->pdo->exec($sql); if($res){ $this->res = $res; } } public function fetchAll(){ return $this->res->fetchAll(); } public function fetch(){ return $this->res->fetch(); } public function fetchColumn(){ return $ this->res->fetchColumn(); } public function lastInsertId(){ return $this->res->lastInsertId(); }

/ * * * パラメータの説明 * int $debug デバッグを有効にするかどうか、有効にするとSQL文が出力されます * 0 無効にする * 1 有効にする * 2 プログラムを有効にして終了する * int $mode 戻り値の型 * 0 Return複数のレコード * 1 単一のレコードを返します * 2 行数を返します * 文字列/配列 $table データベーステーブル、2 つの値渡しモード * 通常モード: * 'tb_member, tb_money' * 配列モード: * array('tb_member', 'tb_money') * string/array $fields クエリ対象のデータベース フィールド。空にすることができます。デフォルトはすべてを検索します。2 つの値渡しモード * 通常モード: * 'username,パスワード' * 配列モード: * array('username', 'password') * string/array $sqlwhere クエリ条件、空許可、2 つの値渡しモード * 通常モード: * 'and type = 1 およびusername like "%os%"' * 配列モード: * array('type = 1', 'username like "%os%"') * string $orderby 並べ替え、デフォルトは ID 逆順です */ public function select($debug, $mode, $table, $fields="*", $sqlwhere="", $orderby="tbid desc"){ //パラメータ処理 if ( is_array($table)){ $table = implode(', ', $table); } if(is_array($fields)){ $fields = implode(', ', $fields); } if(is_array($sqlwhere)){ $sqlwhere = ' and '.implode(' and ', $sqlwhere); } //データベース操作 if($debug === 0){ if($ mode === 2){ $this->query("select count(tbid) from $table where 1=1 $sqlwhere"); $return = $this->fetchColumn(); }else if ( $mode === 1){ $this->query("select $fields from $table where 1=1 $sqlwhere order by $orderby"); $return = $this->fetch(); }else{ $this->query("select $fields from $table where 1=1 $sqlwhere order by $orderby"); $return = $this->fetchAll(); } return $ return ; }else{ if($mode === 2){ echo "select count(tbid) from $table where 1=1 $sqlwhere"; }else if($mode === 1){ echo "$table から $fields を選択します where 1=1 $sqlwhere order by $orderby"; } else{ echo "select $fields from $table where 1=1 $sqlwhere order by $orderby"; } if ( $debug === 2){ exit; } } }

/** * パラメータの説明 * int $debug デバッグを有効にするかどうか、有効にするとSQL文が出力されます * 0 無効にする * 1 有効にする * 2 プログラムを有効にして終了する * int $mode 戻り値の型 * 0 No情報を返す * 1 実行エントリの数を返します * 2 最後に挿入されたレコードのIDを返します * 文字列/配列 $table データベーステーブル、2つの値渡しモード * 通常モード: * 'tb_member, tb_money' * 配列モード: * array( 'tb_member', 'tb_money') * string/array $set 挿入するフィールドとコンテンツ、2 つの値渡しモード * 通常モード: * 'username = "test"、type = 1, dt = now() ' * 配列モード: * array('username = "test"', 'type = 1', 'dt = now()') */ public function insert($debug, $mode, $table, $ set){ //パラメータ処理 if(is_array($table)){ $table = implode(', ', $table); } if(is_array($set)){ $set = implode ( ', ', $set); } //データベース库操作 if($debug === 0){ if($mode === 2){ $this->query("insert into $table set $set"); $return = $this->lastInsertId(); }else if($mode === 1){ $this->exec("$table set $set に挿入"); $return = $this->> res; }else{ $this->query("$table セット $set に挿入"); $return = NULL; } return $return; }else{ echo "$table セットに挿入$set"; if($debug === 2){ exit; } } }

/** * パラメータの説明 * int $debug デバッグを有効にするかどうか、有効にするとSQL文が出力されます * 0 無効にする * 1 有効にする * 2 プログラムを有効にして終了する * int $mode 戻り値の型 * 0 No戻り情報 * 1 実行エントリの数を返します * string $table データベーステーブル、2 つの値渡しモード * 通常モード: * 'tb_member, tb_money' * 配列モード: * array('tb_member', ' tb_money') * string/ array $set 更新する必要があるフィールドと内容、2 つの値渡しモード * 通常モード: * 'username = "test"、type = 1、dt = now()' *配列モード: * array('username = "test"', 'type = 1', 'dt = now()') * string/array $sqlwhere 条件を変更し、空の 2 つの値渡しモードを許可します *通常モード: * 'および type = 1 および "%os%" のようなユーザー名' * 配列モード: * array('type = 1', 'username like "%os%"') */ public function update($debug, $mode, $table, $set, $sqlwhere=""){ //パラメータ处理 if(is_array($table)){ $table = implode(', ', $table); } if( is_array($set)){ $set = implode(', ', $set); } if(is_array($sqlwhere)){ $sqlwhere = ' and '.implode(' and ', $sqlwhere) ; } //数据库操作 if($debug === 0){ if($mode === 1){ $this->exec("update $table set $set where 1=1 $ sqlwhere"); $return = $this->res; }else{ $this->query("update $table set $set where 1=1 $sqlwhere"); $return = NULL; } return $return; }else{ echo "update $table set $set where 1=1 $sqlwhere"; if($debug === 2){ exit; } } } /** * パラメータの説明 * int $debug デバッグを有効にするかどうか、有効にするとSQL文が出力されます * 0 無効です * 1 有効になります * 2 プログラムを開いて終了します * int $mode 戻り値の型 * 0戻り情報なし * 1 実行エントリの数を返します * string $table データベーステーブル * string/array $sqlwhere 削除条件、空でも可、2 つの値渡しモード * 通常モード: * 'and type = 1 およびユーザー名 like "%os%" ' * 配列モード: * array('type = 1', 'ユーザー名 like "%os%"') */ public function delete($debug, $mode, $table, $sqlwhere=""){ //パラメータ处理 if(is_array($sqlwhere)) { $sqlwhere = ' and '.implode(' and ', $sqlwhere); } //データ库操作 if($debug === 0){ if($mode === 1){ $ this->exec("$table where 1=1 $sqlwhere から削除"); $return = $this->res; }else{ $this->query("$table where 1 から削除=1 $sqlwhere"); $return = NULL; } return $return; }else{ echo "$table where 1=1 $sqlwhere から削除"; if($debug === 2){ exit; } } } }

複制暗号 その使用上、および前の位相差は大きくなく、目的は成功者向けの移植です。 今回重写着重处処理了几个问题： ①语太句复杂，フィールドと値对应が容易に出現する误差 以下の最もよくある句を参照してください。

tb_member (username, type, dt) の値 ('test', 1, now()) に挿入します 复制牌 传统モード下、fields と value パラメータは分断入力です、ただし、両方のパラメータの伝達順序が一致している必要があります。これは、シーケンス乱数または特定のパラメータの伝達を引き起こす可能性があります。 今回は、mysql 独自の挿入法が採用されており、上記の機能と同様に、このような書き込み法に置き換えることができます。

insert into tb_member set username = "test"、type = 1、lastlogindt = now() 复制代网 就像更新一样、完然。

② 一部のパラメータは数組で置き換えることができます 以下のようなSQL:

1=1、tbid = 1、およびユーザー名 = "hooray" の tb_member から削除します 复制牌 在原先调使用方法的時候、手動拼装好条件、このような操作の本很が必要です高、この形式は完全に使用できます

$where = array( 'tbid = 1', 'username = "hooray"' ); $db->delete(1, 0, 'tb_member', $where); コードをコピー どれだけ多くの条件があっても、あなたの思考は妨げられません。同様に、where パラメーターだけでなく、更新時のセットもこの形式にすることができます (詳細については完全なソース コードを参照してください)。

$set = array('username = "123"', 'type = 1', 'lastlogindt = now()'); $where = array('tbid = 1' ); $db->update(1, 0, 'tb_member', $set, $where); コードをコピー ③ カスタマイズ可能な SQL ステートメント SQL が複雑すぎるため、クラスで提供されているメソッドを使用して SQL ステートメントを組み立てることができない場合があります。このとき、作成した SQL ステートメントを直接渡して実行して情報を返す関数が必要になります。この機能も利用できるようになりました。

$db->query('tb_memberからユーザー名、パスワードを選択'); $rs = $db->fetchAll(); コードをコピー pdo の本来の書き方とよく似ているでしょうか？

④ 複数のデータベース接続の作成をサポート 元の方法は単なるデータベース操作方法であるため、複数のデータベース接続をサポートしていないため、実装では同じファイルを 2 つコピーし、いくつかの変数を変更する必要があり、非常に複雑です。この問題は現在解決されています。

$db_hoorayos_config = array( 'dsn'=>'mysql:host=localhost;dbname=hoorayos', 'name'=>'root' , 'パスワード'=>'万歳' ); $db = 新しい HRDB($db_hoorayos_config);

$db_hoorayos_config2 = array( 'dsn'=>'mysql: host=localhost;dbname=hoorayos2', 'name'=>'root', 'password'=>'hoorayos' ); $db2 = new HRDB($db_hoorayos_config2);

コードをコピーします この方法で、2 つのデータベース接続を同時に作成して、データベース間の相互作用の処理を容易にすることができます。

テストコード(呼び出し例):

require_once('global.php'); require_once('inc/setting.inc.php');

$ db = new HRDB($db_hoorayos_config);

echo ' select test '; echo '通常モード、直接文字パス文字列内 '; $rs = $db->select(1, 0, 'tb_member', 'ユーザー名, パスワード', 'and type = 1 and username like "%os%"'); echo ' 配列モード、配列を渡すことができます '; $fields = array('username', 'password'); $where = array('type = 1', 'username like "%os%"'); $rs = $db->select(1, 0, 'tb_member', $fields, $where);

echo ' insert test '; echo '通常モード、文字列を直接渡します '; $db->insert(1, 0, 'tb_member', 'username = "test", type = 1, lastlogindt = now()'); echo ' 配列モード、配列を渡すことができます '; $set = array('username = "test " ', 'type = 1', 'lastlogindt = now()'); $db->insert(1, 0, 'tb_member', $set);

echo ' &lt ;hr> update test '; echo '通常モード、文字列を直接 に渡します'; $db->update(1, 0, 'tb_member' , 'username = "123", type = 1, lastlogindt = now()', 'and tbid = 7'); echo ' 配列モード、配列を渡すことができます '; set = array('username = "123"', 'type = 1', 'lastlogindt = now()'); $where = array('tbid = 1'); $db->update( 1, 0, 'tb_member', $set, $where);

echo ' テストの削除 '; echo '通常モード、文字列を直接渡します '; $db->delete(1, 0, 'tb_member', 'and tbid = 1 and username = "hooray"'); echo ' '; $where = array( 'tbid = 1', 'username = "hooray"' ); $db->delete(1, 0 , 'tb_member' , $where);

echo ' カスタムSQL '; $db->query( 'ユーザー名、パスワードを選択tb_member から'); $rs = $db->fetchAll(); var_dump($rs);

$db->close(); ?> コードをコピー

PHP は PDO を使用してデータベース クラスを操作します (Mysql に適用)

PHP は PDO を使用してデータベースクラスを操作します (Mysql に適用)