ZendFramework2(ZF2)流の『取得』『追加』『更新』『削除』とデータベース接続アダプタの生成

今回は、基本的な処理として『取得』『追加』『更新』『削除』のクエリの作成と、
実際にデータベースへアクセスする為のアダプタの作成方法を
ソースコード付きで解説します。

1. ZendFramework2(ZF2)流のデータベース接続用アダプタを作成しよう
2. ZendFramework2(ZF2)流の簡単なクエリの作成と実行
3. ZendFramework2(ZF2)流のセレクト文を使用してみよう
4. ZendFramework2(ZF2)流のインサート文を使用してみよう
5. ZendFramework2(ZF2)流にレコードを更新してみよう
6. ZendFramework2(ZF2)流にレコードを削除しよう

ZendFramework2(ZF2)流のデータベース接続用アダプタを作成しよう

データベースを操作する為のアダプターを作成します。
これからはアダプターを介してクエリを発行していきます。
まずはアダプターの作成方法です。

$adapter = new Zend\Db\Adapter\Adapter($configArray);

データベース用のアダプタークラスをnewします。
その際に、データベースへアクセスする為の情報を連想配列として引数で渡してあげます。

連想配列で設定する項目のkeyとvalueは下記の通りです。

driver	Mysqli, Sqlsrv, Pdo_Sqlite, Pdo_Mysql, Pdo=その他のPDOドライバー
database	データベース名
username	ユーザー名
password	パスワード
hostname	ホスト名
port	ポート
charset	文字コード

MySQLの場合は下記の様な作成になるかと思います。

$adapter = new Zend\Db\Adapter\Adapter(array(
    'driver' => 'Pdo_Mysql',
    'database' => 'zend_db_example',
    'username' => 'developer',
    'password' => 'developer-password'
 ));

ZendFramework2(ZF2)流の簡単なクエリの作成と実行

これでデータベース接続用のアダプターが出来ました。
後はこのアダプターを返してクエリを発行します。


クエリを発行するのは

$result = $adapter->query('SELECT * FROM `artist` WHERE `id` = ?', array(5));

のように、作成したアダプターのquery()メソッドを使用します。

第一引数にクエリを下記、第二引数で配列としてクエリの中に入れる値を定義します。
第一引数内に記述した『?』に第二引数の値が順に当てはめられるイメージですね。


また、SQL文を生成してくれるクラスも存在します。

WEBアプリケーションで基本となる『取得』『追加』『更新』『削除』が
とても手軽に出来るのでお勧めです。


それぞれのSQLオブジェクトの作成方法は下記を参考にして下さい。

use Zend\Db\Sql\Sql;
$sql = new Sql($adapter);
$select = $sql->select(); // @return Zend\Db\Sql\Select
$insert = $sql->insert(); // @return Zend\Db\Sql\Insert
$update = $sql->update(); // @return Zend\Db\Sql\Update
$delete = $sql->delete(); // @return Zend\Db\Sql\Delete

それぞれのSQLオブジェクトが取得出来ます。
後はそのオブジェクトに対して様々な条件を追加していきます。

ZendFramework2(ZF2)流のセレクト文を使用してみよう

まずは『取得』に当たる『select』を例にとって見てみましょう

use Zend\Db\Sql\Sql;

// SQLのインスタンスを生成
$sql = new Sql($adapter);

// セレクト用クエリの取得
$select = $sql->select();

// 対象テーブルを設定
$select->from('foo');

// 対象カラムを指定
$select->columns(array('foo', 'bar'));

// where 条件を設定
$select->where(array('id' => 2));

// 昇降順を指定
$select->order('id ASC');

// リミットを設定
$select->limit(5);

// オフセットを設定
$select->offset(10);

// 作成したクエリを使用してステートメントを作成する
$statement = $sql->prepareStatementForSqlObject($select);

// ステートメントを実行して結果セットを取得する
$results = $statement->execute();

カラム指定時のas文は下記の用に記述します。

$select->columns(array('foo' => 'bar', 'baz' => 'bax'));

join句は下記の様にfromに続けて指定します

$select->from(array('f' => 'foo'))  // base table
    ->join(array('b' => 'bar'),     // join table with alias
    'f.foo_id = b.foo_id');         // join expression

ZendFramework2(ZF2)流のインサート文を使用してみよう

続きまして、テーブルにレコードを追加する『insert』を使用して見ましょう。

use Zend\Db\Sql\Sql;

// SQLのインスタンスを生成
$sql = new Sql($adapter);

// 追加用クエリの取得
$insert = $sql->insert();

// 追加先テーブルを指定します。
$insert->into('table');

// カラムを指定します
$insert->columns(array('foo', 'bar')); 

// 追加する値を設定します
$insert->values(array(
     'foo' => 'value1',
     'bar' => 'value2'
));

// 作成したクエリを使用してステートメントを作成する
$statement = $sql->prepareStatementForSqlObject($insert);

// ステートメントを実行して結果を取得する
$results = $statement->execute();

ZendFramework2(ZF2)流にレコードを更新してみよう

続いてはレコードの『更新』用クエリの使い方です。

use Zend\Db\Sql\Sql;

// SQLのインスタンスを生成
$sql = new Sql($adapter);

// 更新用クエリの取得
$update = $sql->update();

// 対象テーブルを指定
$update->table('table');

// 更新する値をセットする
$update->set(array('foo' => 'bar', 'baz' => 'bax'));

// 更新先レコードの条件を指定する
$update->where(array('id' => 2));

// 作成したクエリを使用してステートメントを作成する
$statement = $sql->prepareStatementForSqlObject($update);

// ステートメントを実行して結果を取得する
$results = $statement->execute();

ZendFramework2(ZF2)流にレコードを削除しよう

続いては削除です。これは論理削除ではなく、レコード事態を削除する完全削除ですので、
使用する際には気をつけましょう。

use Zend\Db\Sql\Sql;

// SQLのインスタンスを生成
$sql = new Sql($adapter);

// 削除用クエリの取得
$delete = $sql->delete();


// 対象テーブルを指定する
$delete->from('table');

// 削除対象の条件を指定する
$delete->where(array('id' => 2));

これで基本的なデータベースを扱ったサイトの構築が可能です。
上記の四つのクエリパターンはとても良く使うので、
しっかりと身に付けてしまいましょう。