PHPとデータベース - PDOのソースを表示

== 概要 ==
PDO(PHP Data Objects)拡張モジュールは、PHPからデータベースにアクセスするための軽量で高性能なインターフェイスである。<br>
PDOインターフェイスを実装する各データベースドライバは、正規表現のようなデータベース固有の機能を提供する。<br>
ただし、PDO拡張モジュールは、データベースのあらゆる関数を実行できるわけではない。<br>
<br>
データベースサーバにアクセスするには、データベース固有のPDOドライバを使用する必要がある。<br>
<br>
PDOは、データアクセスの抽象化レイヤを提供する。<br>
つまり、使用しているデータベースの種類に関わらず、同じ関数を使用してクエリの発行やデータの取得が行うことができる。<br>
<br>
PDOは、PHP 5.1以降にバンドルされており、PHP 5.0ではPECL拡張モジュールとして使用可能である。<br>
PHP 5の新機能であるオブジェクト指向で設計されているため、それより前のPHPでは動作しない。<br>
<br><br>

== PDOのインストール ==
==== Linux ====
PDOおよびPDO_SQLITEドライバは、PHP 5.1.0以降では標準で有効となっている。<br>
必要に応じて、使用するデータベース用のPDOドライバを有効にすることができる。<br>
データベースごとのPDOドライバについての詳細は、[https://www.php.net/manual/ja/pdo.drivers.php こちらのWebサイト]を参照すること。<br>
<br>
<u>※注意</u><br>
<u>PDOを共有モジュールとしてビルドする場合(非推奨)、全てのPDOドライバはPDO自体の後にロードしなければならない。</u><br>
<br>
PDOを共有モジュールとしてインストールする場合、php.iniファイルを編集して、PHPの実行時にPDOが自動的に読み込むように設定する。<br>
データベースごとのドライバについても同様、ドライバはpdo.soの後に記述する。<br>
これは、ドライバを読み込む前にPDOの初期化を済ませておく必要があるからである。<br>
<br>
もし、PDOおよびデータベースドライバを静的にビルドした場合、この部分は読み飛ばして構わない。<br>
 extension=pdo.so
<br>
==== Windows ====
# PDOおよび主要なドライバは、共有モジュールとしてPHPに同梱されているため、php.iniファイルを編集するだけで使用できる。
#: extension=php_pdo.dll
#: <u>※注意</u>
#: <u>PHP 5.3以降では、上記の設定は不要である。これは、PDOのDLLは必須ではなくなったためである。</u>
#: <br>
# 次に、その他のデータベース固有のDLLを読み込む方法は、以下の2つがある。
#* 実行時に<code>dl</code>関数で読み込む。
#* php.iniファイルで、php_pdo.dllに続いて指定する。<br>例えば、以下のように追記する。<br>以下のDLLは、php.iniファイルにある<code>extension_dir</code>項目で指定したディレクトリに配置しなければならない。
#*: extension=php_pdo.dll
#*: extension=php_pdo_firebird.dll
#*: extension=php_pdo_informix.dll
#*: extension=php_pdo_mssql.dll
#*: extension=php_pdo_mysql.dll
#*: extension=php_pdo_oci.dll
#*: extension=php_pdo_oci8.dll
#*: extension=php_pdo_odbc.dll
#*: extension=php_pdo_pgsql.dll
#*: extension=php_pdo_sqlite.dll  
#: <br>
#: <u>※注意</u>
#: <u>php.iniファイルの変更後は、設定を有効にするためにPHPを再起動する必要がある。</u>
#: <code>sudo systemctl restart apache2</code>
<br><br>

== データベースの接続と管理 ==
PDOクラスのインスタンスを作成することにより、接続が確立される。<br>
コンストラクタには、データソース(DSN)、ユーザ名、パスワードを指定する。<br>
<br>
==== MySQLへの接続 ====
データベース接続時になんらかのエラーが発生した場合、<code>PDOException</code>クラスがスローされる。<br>
エラー処理を行う場合はこの例外をキャッチする。<br>
または、エラーを無視して、<code>set_exception_handler</code>関数で設定したグローバル例外ハンドラに処理を任せることもできる。<br>
<br>
<u>※注意</u><br>
<u>PDOコンストラクタからの例外をキャッチしない場合、zendエンジンはPHPスクリプトを終了して、バックトレースを表示する。</u><br>
<u>このバックトレースは、データベースへの接続の詳細(ユーザ名やパスワード等)を誰でも閲覧することができるため、</u><br>
<u>必ず、例外処理を記述すること。</u><br>
<br>
データベースへの接続に成功する場合、PDOクラスのインスタンスが返る。このインスタンスが存在する間、接続がアクティブであり続ける。<br>
データベースへの接続を閉じる時、インスタンスに<code>null</code>を代入して、インスタンスを破棄する。<br>
<code>null</code>を代入しない場合、PHPスクリプトの終了時に自動的に接続が閉じられる。<br>
<br>
<u>※注意</u><br>
<u>PDOのインスタンスへの参照(<code>PDOStatement</code>クラスのインスタンスからの参照や別のPDOのインスタンスからの参照等)が残っている場合、</u><br>
<u>それらも併せて削除する必要がある。(<code>PDOStatement</code>クラスのインスタンスに<code>null</code>を代入する等)</u><br>
 <syntaxhighlight lang="php">
 <?php
    try
    {
       $dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass);
       foreach($dbh->query('SELECT * from FOO') as $row)
       {
          print_r($row);
       }
       $dbh = null;
    }
    catch(PDOException $e)
    {
       print "エラー!: " . $e->getMessage() . "<br/>";
       die();
    }
 ?>
 </syntaxhighlight>
<br>
==== データベースの接続を閉じる ====
データベースの接続は、PHPスクリプトが終了しても閉じられずにキャッシュされ、他のPHPスクリプトが同じ内容の接続を要求する時に再利用される。<br>
このキャッシュにより、新しい接続を確立するオーバーヘッドを避けることができるため、Webアプリケーションを高速化できるようになる。<br>
 <syntaxhighlight lang="php">
 <?php
    $dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass);
    
    $sth = $dbh->query('SELECT * FROM foo');
 
    // 使用を終了したので、閉じます
    $sth = null;
    $dbh = null;
 ?>
 </syntaxhighlight>
<br>
==== 持続的な接続 ====
<code>PDO::ATTR_PERSISTENT</code>オプションの値は、string型の値が設定されない限り、bool型(持続的な接続の有無を示す)に変換される。<br>
string型の値を設定する場合、複数の接続プールを使用することができる。<br>
<br>
これは、互換性の無い異なる接続を使用する場合に便利である。<br>
例えば、異なる<code>PDO::MYSQL_ATTR_USE_BUFFERED_QUERY</code>の値を設定する場合が挙げられる。<br>
<br>
<u>※注意1</u><br>
<u>持続的な接続をする場合、ドライバのオプションに<code>PDO::ATTR_PERSISTENT</code>を設定して、PDOクラスのコンストラクタに渡す必要がある。</u><br>
<u>この属性を、インスタンスの生成後に<code>PDO::setAttribute</code>メソッドを使用して設定する場合、ドライバは持続的な接続を使用しない。</u><br>
<br>
<u>※注意2</u><br>
<u>PDO ODBCドライバを使用しており、ODBCライブラリがODBC接続プーリングをサポートしている場合は、</u><br>
<u>PDOの持続的な接続を使用せずに、ODBCの接続プーリングに接続キャッシュ処理を任せることを推奨する。</u><br>
<br>
<u>ODBCの接続プールは、プロセス内で他のモジュールと共有されている。</u><br>
<u>PDOが接続をキャッシュすると、その接続はODBCの接続プールに返されなくなり、他のモジュールによって新たな接続が作成されてしまう。</u><br>
 <syntaxhighlight lang="php">
 <?php
    $dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass, array(PDO::ATTR_PERSISTENT => true));
 ?>
 </syntaxhighlight>
<br><br>

== トランザクションおよび自動コミット ==
トランザクション内で実行された作業は、データベースに安全に反映されることが保証されている。<br>
トランザクションのコミット時は、他の接続の干渉を受けることはない。<br>
また、未コミット時では、トランザクション内での作業はいつでも取り消すことができる。<br>
<br>
PDOクラスを使用してデータベースへ接続する場合、自動コミットモードで動作する。<br>
自動コミットモードとは、データベースがトランザクションをサポートしている場合、クエリが暗黙的にトランザクションのもとで実行される。<br>
データベースがトランザクションをサポートしていない場合、トランザクションを使用せずに実行される。<br>
<br>
トランザクションを使用する場合は、<code>PDO::beginTransaction</code>メソッドを使用して、トランザクションを初期化する必要がある。<br>
使用しているドライバがトランザクションをサポートしていない場合、必ず、<code>PDOException</code>クラスがスローされる。<br>
<br>
トランザクションを終了する場合は、<code>PDO::commit</code>メソッドあるいは<code>PDO::rollBack</code>メソッドを使用する。<br>
<br>
以下の例では、データベースのテーブルに対して、新しい2つのレコードを追加している。<br>
トランザクションがアクティブな間は、作業中のデータについては、他から一切変更が加えられないことが保証されている。<br>
もし何か問題が発生すれば、catchブロック内でトランザクション開始以降の全ての変更がロールバックされる。<br>
 <syntaxhighlight lang="php">
 <?php
    try
    {
       $dbh = new PDO('odbc:SAMPLE', 'db2inst1', 'ibmdb2', array(PDO::ATTR_PERSISTENT => true));
       echo "接続しました\n";
    }
    catch (Exception $e)
    {
       die("接続できません: " . $e->getMessage());
    }
 
    try
    {  
       $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
 
       $dbh->beginTransaction();
       $dbh->exec("insert into staff (id, first, last) values (23, 'Joe', 'Bloggs')");
       $dbh->exec("insert into salarychange (id, amount, changedate) values (23, 50000, NOW())");
       $dbh->commit();
    }
    catch(Exception $e)
    {
       $dbh->rollBack();
       echo "失敗しました。" . $e->getMessage();
    }
 ?>
 </syntaxhighlight>
<br>
データベースの接続を閉じる場合またはPHPスクリプトが終了する場合、<br>
コミットが完了していないトランザクションがあるならば、自動的にロールバックされる。<br>
これは、明示的にコミットしていない場合、予期せぬ状態で終了したと推測されるため、データの不整合が発生するのを避けるための機能である。<br>
<br>
<u>※注意</u><br>
<u>自動的にロールバックが行われる時は、<code>PDO::beginTransaction</code>メソッドを実行した場合のみである。</u><br>
<u>トランザクションを開始するクエリを手動で発行した場合、PDOはそれを知ることができないため、問題が発生してもロールバックできない。</u><br>
<br><br>

== プリペアドステートメントおよびストアドプロシージャ ==
プリペアドステートメントとは、実行するSQLをコンパイルしたテンプレートのようなものである。<br>
パラメータ変数を使用することで、SQLをカスタマイズすることができる。<br>
<br>
プリペアドステートメントには、以下に示す2つの大きな利点がある。<br>
* 一般的に、クエリを実行する時、クエリの解析、コンパイル、実行プランの最適化が行われる。<br>プリペアドステートメントを使用する場合、これらの解析、コンパイル、最適化の繰り返しを避けることができる。<br>端的に言うと、プリペアドステートメントは使用するリソースが少ないため、高速に動作するということである。<br><br>
* プリペアドステートメントに渡すパラメータは、引用符で括る必要は無く、ドライバが自動的に行う。<br>プリペアドステートメントでは、SQLインジェクションは発生しない。
<br>
プリペアドステートメントは、データベースの種類や機能に関わらず同じ仕組みで データベースへのアクセスができる。<br>
<br>
==== Insert (1)====
以下の例では、nameおよびvalueを名前付きプレースホルダで置き換えて、INSERT句を実行する。<br>
 <syntaxhighlight lang="php">
 <?php
    $stmt = $dbh->prepare("INSERT INTO REGISTRY (name, value) VALUES (:name, :value)");
    $stmt->bindParam(':name', $name);
    $stmt->bindParam(':value', $value);
 
    // 1レコード目の挿入
    $name = 'one';
    $value = 1;
    $stmt->execute();
 
    // パラメータを変更して、2レコード目の挿入
    $name = 'two';
    $value = 2;
    $stmt->execute();
 ?>
 </syntaxhighlight>
<br>
==== Insert (2) ====
以下の例では、nameおよびvalueをプレースホルダ<code>?</code>で置き換えて、INSERT句を実行する。<br>
 <syntaxhighlight lang="php">
 <?php
    $stmt = $dbh->prepare("INSERT INTO REGISTRY (name, value) VALUES (?, ?)");
    $stmt->bindParam(1, $name);
    $stmt->bindParam(2, $value);
 
    // 1レコード目の挿入
    $name = 'one';
    $value = 1;
    $stmt->execute();
 
    // パラメータを変更して、2レコード目の挿入
    $name = 'two';
    $value = 2;
    $stmt->execute();
 ?>
 </syntaxhighlight>
<br>
==== SELECT ====
以下の例では、フォームで入力したキーの値に応じたデータを取得している。<br>
ユーザの入力内容は自動的に引用符で括られるため、SQLインジェクション攻撃の恐れは無い。<br>
 <syntaxhighlight lang="php">
 <?php
    $stmt = $dbh->prepare("SELECT * FROM REGISTRY where name = ?");
    if($stmt->execute(array($_GET['name'])))
    {
       while($row = $stmt->fetch())
       {
          print_r($row);
       }
    }
 ?>
 </syntaxhighlight>
<br>
==== ストアドプロシージャの呼び出し : 出力パラメータの指定 ====
データベースドライバがサポートしている時、入力パラメータだけでなく、出力パラメータもバインドすることが可能である。<br>
<br>
出力パラメータは、ストアドプロシージャから値を取得するために使用する。<br>
この場合、返される値の大きさがどの程度になるのかをバインド時に知る必要がある。<br>
指定した大きさよりも大きな値が返される場合は、エラーが発生する。<br>
 <syntaxhighlight lang="php">
 <?php
    $stmt = $dbh->prepare("CALL sp_returns_string(?)");
    $stmt->bindParam(1, $return_value, PDO::PARAM_STR, 4000); 
 
    // ストアドプロシージャを呼び出す
    $stmt->execute();
 
    print "プロシージャが返した値は $return_value です\n";
 ?>
 </syntaxhighlight>
<br>
==== ストアドプロシージャの呼び出し : 入出力パラメータの指定 ====
入出力の両方に使用するパラメータを指定することもできる。<br>
入出力パラメータの書式は、出力パラメータと同じである。<br>
<br>
以下の例では、ストアドプロシージャに文字列'hello'を渡している。<br>
プロシージャの結果が返ってくると、文字列'hello'はプロシージャの返す値に置き換えられる。<br>
 <syntaxhighlight lang="php">
 <?php
    $stmt = $dbh->prepare("CALL sp_takes_string_returns_string(?)");
    $value = 'hello';
    $stmt->bindParam(1, $value, PDO::PARAM_STR|PDO::PARAM_INPUT_OUTPUT, 4000); 
 
    // ストアドプロシージャの呼び出し
    $stmt->execute();
 
    print "プロシージャが返した値は $value です\n";
 ?>
 </syntaxhighlight>
<br>
==== プレースホルダの間違った使用例 ====
 <syntaxhighlight lang="php">
 <?php
    $stmt = $dbh->prepare("SELECT * FROM REGISTRY where name LIKE '%?%'");
    $stmt->execute(array($_GET['name']));
 
    // プレースホルダは、値全体に対して使用しなければなりません
    $stmt = $dbh->prepare("SELECT * FROM REGISTRY where name LIKE ?");
    $stmt->execute(array("%$_GET[name]%"));
 ?>
 </syntaxhighlight>
<br><br>

__FORCETOC__
[[カテゴリ:Web]]