php pdoカプセル化クラスはmysqlデータの追加、削除、チェック、変更を実装します

define('DSN', 'mysql:host=127.0.0.1;dbname=baozhong_tour') //データベースアドレス+データベース名の定数
define('DB_USERNAME) ', 'root'); //データベース ユーザー名
define('DB_USERPWD', ''); //データベース パスワード

/**
* @作者シュイムガン
* @バージョン 0.2
* @return PDOStatement
*/
function getConn() {
try {
$db = new PDO(DSN, DB_USERNAME, DB_USERPWD) //pdo オブジェクトを作成し、データベースパラメータ情報を渡します
$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); / データベースエラー情報を設定します
$db->query('set names utf8;'); // エンコードを utf8 に設定します
return $db;
catch (PDOException $e) {
echo 'データ処理エラーです。ウェブサイト管理者に連絡してください!';
print_r($e);//この文はオンラインになった後にコメントする必要があります!
/**
* @author shuimugan
* @version 0.2
* @param String $tablename テーブル名、型は string です
* @param Array $column_name 列名、配列の形式は必須です
* @param String $condition 条件、など'where name=? and pws=?' または 'name like?'
* @param Array $condition_value 条件に対応するデータは、'name=? および pws=? などの配列である必要があります。 ',
* @return 配列は結果セット配列形式を返します
* @example $column_name=array('*');
$limit='limit 0,10'; $res=easy_select('user', $column_name, 'where id=? ', $condition_value,$limit
);*/
function easy_select( $tablename,$column_name,$condition,$condition_value,$limit) {
try {
$db=getConn();
$sql='select ';// SQL ステートメントを初期化します
foreach ($column_name as $col_name) {
// SQL ステートメントに列名を動的に追加します
if($col_name=='*'){
$sql.='*'
break;
}
if($col_name==end($column_name))
 {
$sql.=$col_name." ";//それが最後のステートメントである場合、ステートメントはカンマを結合しません
}else {
$sql.=$col_name.", ";//列名 + カンマを結合します
}
}
$sql.="from ".$tablename." ";//結合テーブル名
$sql.=$condition.' ';//結合条件文
if(strlen($limit)> 0){
 $sql.=$limit;//limit ステートメントを結合します
}
$db = new PDO(DSN, DB_USERNAME, DB_USERPWD);// PDO オブジェクトを作成し、データベース パラメーター情報を渡します
$db- >setAttribute(PDO:: ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);// データベースのエラー情報を設定します
$db->query('set names utf8;');// エンコードを utf8 に設定します
$stmt = $db- >prepare($sql) ;
$i=1;//カウントを開始します
$j=count($condition_value);
for (; $i $ stmt->bindParam($i , $condition_value[$i-1]);//バインドパラメータ
$i++;
//Query
$stmt->setFetchMode(PDO::FETCH_ASSOC);//Setフィールドを通じてデータを取得する
$stmt ->execute();
//データを取得する
return $stmt->fetchAll();
//return $stmt->rowCount(); e) {
return false;
 echo 'データ処理エラー。Web サイト管理者に連絡してください!';
print_r($e);//この文はオンラインになった後にコメントする必要があります。 /**
* @author shuimugan
* @version 0.2
* @param String $tablename テーブル名、型は string です
* @param Array $column_name 列名、配列の形式は必須です
* @param String $condition 条件、などas 'where name=? and pws=?' または 'name like?'
* @param Array $condition_value 条件に対応するデータは、'name=? および pws=? などの配列である必要があります。 ',
* @return int はレコードの数を返します
* @example $column_name=array('*');
$limit='limit 0,10'; $res=easy_selectCount('user', $column_name , 'where id=? ', $condition_value,$limit
);*/
function easy_selectCount($tablename,$column_name,$condition,$condition_value,$limit) {
try {
$db=getConn();
$sql='select ';//初期化sql ステートメント
foreach ($column_name as $col_name) {
// SQL ステートメントに列名を動的に追加します
if($col_name=='*'){
$sql.='*'
}
if; ($col_name==end($ column_name))
{
$sql.=$col_name." ";//それが最後のものに属する場合、ステートメントはカンマを接続しません
}else {
$sql.= $col_name.", ";//列名 + カンマを結合します
}
}
$sql.="from ".$tablename." ";//テーブル名を結合します
$sql.=$condition.'; //スプライシング条件文
if(strlen($limit)> 0){
$sql.=$limit;//スプライシング制限文
}
;
$db = new PDO(DSN, DB_USERNAME, DB_USERPWD);// PDO オブジェクトを作成し、データベースパラメータ情報を渡します
$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//データベースのエラー メッセージを設定します
$db->query('set names utf8;');//エンコーディングを utf8 に設定します
$stmt = $db->prepare($sql);//カウントを開始し、
$j=count($condition_value); の数を計算します
for (; $i $stmt->bindParam($i, $condition_value[$i-1] );/ / バインドパラメータ
$i++;
}
// クエリ
//$stmt->setFetchMode(PDO::FETCH_ASSOC);// フィールドを通じてデータを取得するように設定
$stmt->execute();
// データを取得します
return $stmt->rowCount();
} catch (PDOException $e) {
echo 'データ処理エラー。Web サイト管理者に問い合わせてください!'; ;// 非常に詳細なエラー メッセージです。オンラインになった後、この文をコメントする必要があります。
}
}
/**
* @author shuimugan
* @version 0.2
* @param String $tablename テーブル名、型はstringです
* @param Array $column_name カラム名、配列の形式は必須です
* @param Array $column_value 対応するデータ、要件 配列の形式
* @return int は最後に増分された ID を返します
* @example $column_name=array('pwd','ip','name');
$column_value=array('1246','11.11) .11.11 ','張三');
echo easy_insert('user',$column_name,$column_value);*/
function easy_insert($tablename,$column_name,$column_value) {
try {
$db =getConn( );
$sql='INSERT INTO ';// SQL ステートメントを初期化します
$sql.=$tablename.' (';// テーブル名
foreach ($column_name as $col_name) {
//動的列名を追加 SQL ステートメントを入力します
if($col_name==end($column_name))
{
$sql.=$col_name." )";// 最後の場合は、右括弧を結合します
}else {
$sql.=$col_name.", ";//列名 + カンマを結合
}
}
$sql.=' VALUES (';//$condition_value ステートメントを結合
for ($i=0; $i $sql.='?) ;'; $sql.='?,' ;
}
}
$db = new PDO(DSN, DB_USERNAME, DB_USERPWD);//PDO オブジェクトを作成し、データベース パラメーター情報を渡します
$db->setAttribute(PDO: :ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);/ /データベースエラー情報を設定
$db->query('set names utf8;');//エンコードをutf8に設定
$stmt = $db->prepare($sql );
for ($i=1; $i }
// クエリ
// echo $sql;
$stmt->setFetchMode(PDO::FETCH_ASSOC);// フィールドを介してデータを取得するように設定します
$stmt->execute();データの取得
return $db->lastInsertId() ;
} catch (PDOException $e) {
echo 'データ処理エラー。Web サイト管理者に問い合わせてください!'
print_r($e);//非常に詳細なエラー メッセージ。この文はオンラインになった後にコメントする必要があります。 {
try {
$db=getConn();
 $sql='UPDATE ';// SQL ステートメントを初期化します
$sql.=$tablename.' SET ';// テーブル名を結合します
foreach ($column_name $col_name) {
//列名を SQL ステートメントに動的に追加します
 if($col_name==end($column_name))
{
$sql.=$col_name." = ? ";// に属している場合最後の
}else {
$sql.=$col_name." = ?, " ;//列名 + カンマの結合
}
}
$sql.=$condition;// 条件文の結合
if(strlen($ limit)>0){
$sql.=$limit;//スプライシング制限ステートメント
}
$db = new PDO(DSN, DB_USERNAME, DB_USERPWD);// PDO オブジェクトを作成し、データベース パラメータ情報を渡します
 $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//データベースエラーメッセージを設定します
$db->query('set names utf8;');//エンコーディングを utf8 に設定します
$stmt = $db->prepare($sql);//準備ステートメント
$i=1;
$total=count($column_name)+count($condition_value)
for (;$i $stmt->bindParam($i, $column_value[$i- 1]);//列名に対応するデータパラメータをバインドします
$i++;
$j=1; (;$i $stmt->bindParam($i, $condition_value[$j-1]);//バインディング条件に対応するデータパラメータ
$i++; ;
}
//Query
$stmt->setFetchMode(PDO::FETCH_ASSOC);//フィールドを通じてデータを取得するように設定
$stmt->execute();
//データを取得
return $stmt->rowCount( ) ;
} catch (PDOException $e) {
return false;
echo 'データ処理エラー。Web サイト管理者に連絡してください!'//この文は後にコメントする必要があります。 Word をオンラインにします
}
}
/**
* @author shuimugan
* @version 0.2
* @param String $tablename テーブル名
* @param String $condition 条件 (例: where id= ?)
* @param Array $condition_value 条件に対応する値は? に対応する値
* @param String $limit 'limit 0,1' などの制限ステートメント
* @return int 影響を受ける結果の数を返す
* @example $condition_value=array('83');
echo easy_delete( 'ユーザー'、'どこ ID =?'、$condition_value、null);*/
function easy_delete($tablename,$condition,$condition_value,$limit) {
try {
$db=getConn(); DELETE FROM ';//SQL文を初期化
$sql.=$tablename.' ';//テーブル名を結合
$sql.=$condition;//条件文を結合
if(strlen($limit)>0) {
 $sql.=$limit;//limit ステートメントを結合します
}
$db = new PDO(DSN, DB_USERNAME, DB_USERPWD);// PDO オブジェクトを作成し、データベース パラメーター情報を渡します
$db-> setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);//データベースエラー情報を設定します
$db->query('set names utf8;');//エンコードを utf8 に設定します
$stmt = $db-> prepare($sql) ;//準備ステートメント
for ($i=1;$i $stmt->bindParam($i, $condition_value[$i-1] );// 特定の条件に対応するデータ パラメーターをバインド
$i++;
}
// クエリ
$stmt->setFetchMode(PDO::FETCH_ASSOC);// フィールドを通じてデータを取得するように設定
$stmt->execute ();
// データを取得
return $stmt->rowCount();
 return false;
echo 'データ処理エラー。Web サイト管理者に問い合わせてください!'; $e);//非常に詳細なエラー メッセージです。オンラインになった後にこの文をコメントする必要があります!
}
?>


コードをコピーしてください