ホームページ >バックエンド開発 >PHPチュートリアル >php pdoクラスライブラリの使用例、php pdoモジュールの入門例

php pdoクラスライブラリの使用例、php pdoモジュールの入門例

WBOY
WBOYオリジナル
2016-07-25 08:51:451055ブラウズ
  1. $dbh = 新しい PDO('mysql:host=localhost;dbname=access_control', 'root', '');
  2. $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  3. $dbh->exec('set names utf8');
  4. /*追加*/
  5. //$sql = "INSERT INTO `user` SET `login`=:login AND `password`=:password";
  6. $sql = "INSERT INTO `user` (`login` ,`password`)VALUES (:login, :password)"; $stmt = $dbh->prepare($sql); $stmt->execute(array(':login'=>'kevin2',':password'=>''));
  7. echo $dbh->lastinsertid();
  8. /*修正*/
  9. $sql = "UPDATE `user` SET `password`=:password WHERE `user_id`=:userId";
  10. $stmt = $dbh->prepare($sql);
  11. $stmt->execute(array(':userId'=>'7', ':password'=>'4607e782c4d86fd5364d7e4508bb10d9'));
  12. echo $stmt->rowCount();
  13. /*删除*/
  14. $sql = "DELETE FROM `user` WHERE `login` LIKE 'kevin_'"; //kevin%
  15. $stmt = $dbh->prepare($sql);
  16. $stmt->execute();
  17. echo $stmt->rowCount();
  18. /*查询*/
  19. $login = 'kevin%';
  20. $sql = "SELECT * FROM `user` WHERE `login` LIKE :login";
  21. $stmt = $dbh->prepare($sql);
  22. $stmt->execute(array(':login'=>$login));
  23. while($row = $stmt->fetch(PDO::FETCH_ASSOC)){
  24. print_r($row);
  25. }
  26. print_r( $stmt->fetchAll(PDO::FETCH_ASSOC));
  27. ?>
复制代

1、建立连接

  1. $dbh=newPDO('mysql:host=localhost;port=3306; dbname=test',$user,$pass,array(
  2. PDO::ATTR_PERSISTENT=>true
  3. ) ));
  4. ?>
复制代

持久性链接PDO::ATTR_PERSISTENT=>true

2. 捕捉错误

  1. try{
  2. $dbh=newPDO('mysql:host=localhost;dbname=test',$user,$pass);
  3. $dbh->setAttribute(PDO:: ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
  4. $dbh->exec("SET CHARACTER SET utf8");
  5. $dbh=null; //断开连接
  6. }catch(PDOException$e){
  7. print"Error!:".$e->getMessage()."
    ";
  8. die();
  9. }
  10. ?> ;
复制代

3. 事务

  1. try{

  2. $dbh->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
  3. $dbh->beginTransaction();//开启事务
  4. $dbh->exec("insertintostaff(id,first,last)values(23,'Joe','Bloggs')");
  5. $dbh->exec("insertintosalarychange(id,amount,changedate) )
  6. values(23,50000,NOW())");
  7. $dbh->commit();//提交事务

  8. }catch(Exception$e){

  9. $dbh ->rollBack();//错误回滚
  10. echo"Failed:".$e->getMessage();
  11. }
  12. ?>

复制代网

4. 错误処理 a. 静默モード(默认モード)

  1. try{
  2. $dbh = 新しい PDO($dsn, $user, $password);
  3. $sql = ' CountryCode =:country の都市から * を選択';
  4. $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
  5. $stmt = $dbh->prepare($sql);
  6. $stmt->bindParam(':country', $country, PDO::PARAM_STR);
  7. $stmt->execute();
  8. while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
  9. print $row['Name'] . "/t";
  10. }
  11. } // 問題がある場合は、ここで処理できます
  12. catch (PDOException $e) {
  13. echo 'PDO 例外をキャッチしました。 ';
  14. echo 'データベースのエラー:
    ';
  15. echo 'SQL クエリ: ', $sql;
  16. echo 'エラー: ' 。 $e->getMessage();
  17. }
  18. ?>
复制代

1. クエリ()を使用する

  1. $dbh->query($sql); 現在 $sql 中量は $dbh->quote($params); を使用できます。 //转义文字列の数列

  2. $sql = 'Select * from city where CountryCode ='.$dbh->quote($country);

  3. foreach ($dbh->query($sql) as $row) {
  4. print $row['Name'] . "/t";
  5. $row[' CountryCode'] を印刷します。 "/t";
  6. $row['Population'] を出力します。 "/n";
  7. }
  8. ?>

复制代

2. prepare、bindParam を使用して実行します [推奨ですが、追加、変更、削除にも使用できます]

  1. $dbh->prepare($sql); は PDOStatement オブジェクトを生成します
  2. PDOStatement->bindParam()
  3. PDOStatement->execute();//ここに置くことができます対応するバインドされた変数
  4. ?>
コードをコピー

3.

  1. try {
  2. $dbh = new PDO('mysql:host=localhost;dbname=test', 'root', '');
  3. $dbh->query('set) names utf8;');
  4. $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  5. $dbh->beginTransaction(); `test` に挿入します。 `table` (`name` ,`age`)VALUES ('mick', 22);");
  6. $dbh->exec("Insert INTO `test`.`table` (`name` ,`age` )VALUES ('lily', 29);");
  7. $dbh->exec("Insert INTO `test`.`table` (`name` ,`age`)VALUES ('susan', 21);" );
  8. $dbh->commit();
  9. } catch (Exception $e) {
  10. $e->getMessage();
  11. ?>
  12. コードをコピー
一般的な PDO メソッド: PDO::query() は主に、レコード結果 (PDOStatement) を返す操作、特に選択操作に使用されます。
PDO::exec() は主に結果セットを返さない操作用です。挿入、更新、その他の操作など。影響を受ける行の数を返します。 PDO::lastInsertId() は最後の挿入操作の最後の ID を返しますが、次の点に注意してください: insert into tb(col1,col2) value(v1,v2),(v11,v22).. を使用して複数のレコードを挿入する場合1 回だけ、 lastinsertid() は、最後に挿入されたレコードのレコード ID ではなく、最初の (v1、v2) 挿入の ID のみを返します。 PDOStatement::fetch() を使用してレコードを取得します。 while を使用してトラバースします。 PDOStatement::fetchAll() は、すべてのレコードを 1 つにフェッチします。 PDOStatement::fetchcolumn([int column_indexnum]) は、列に直接アクセスするために使用されます。パラメーター column_indexnum は、0 から始まる行内の列のインデックス値です。ただし、このメソッドは一度に同じ行の 1 つの列しか取得できません。一度実行すると次の行に進みます。したがって、特定の列に直接アクセスする場合には使いやすいですが、複数の列を横断する場合には役に立ちません。 PDOStatement::rowcount() は、query("select...") メソッドの使用時にレコード数を取得するのに適しています。前処理にも使用できます。 $stmt->rowcount(); PDOStatement::columncount() は、query("select...") メソッドの使用時にレコード内の列数を取得するのに適しています。

注: 1. fetch または fetchall を選択しますか? レコード セットが小さい場合は、fetchall を使用すると効率的であり、データベースからの取得回数が減ります。ただし、結果セットが大きい場合、fetchall を使用するとシステムに大きな負担がかかります。データベースが Web フロントエンドに送信する必要があるデータの量が多すぎるため、非効率的です。 2. fetch() または fetchall() にはいくつかのパラメータがあります。

混合 pdostatement::fetch([int fetch_style [,int Cursor_orientation [,int Cursor_offset]]]) 配列 pdostatement::fetchAll(int fetch_style)

fetch_style パラメータ:

$row=$rs->fetchAll(PDO::FETCH_BOTH); FETCH_BOTH はデフォルトであり、省略可能であり、関連付けとインデックスを返します。 $row=$rs->fetchAll(PDO::FETCH_ASSOC); FETCH_ASSOC パラメーターは、連想配列のみが返されることを決定します。 $row=$rs->fetchAll(PDO::FETCH_NUM); インデックス配列を返します。 $row=$rs->fetchAll(PDO::FETCH_OBJ); fetch() がオブジェクトを返す場合、fetchall() がオブジェクトで構成される 2 次元配列を返す場合

声明:
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。