MySQLへの接続とアクセス

■ mysqliでの接続とトランザクション

MySQLへの接続とDBデータ取得テスト <?php $mysqli = new mysqli("localhost", "myuser", "mypass", "mydb"); /* if ($mysqli->connect_errno) { die("Connect failed: " . $mysqli->connect_error); } */ if (($result=$mysqli->query("select 1")) === false) { $mysqli->close(); die("Query failed: " . $mysqli->error); } while ($row=$result->fetch_row()) { echo $row[0]; } $mysqli->close();

接続は運用の最初のほうで調整する部分なので
接続部分のエラーハンドリングを行わないことで、最初に接続が行われたかどうか確認しやすくする。

@new mysqli()という書き方もできるが、接続エラーをわかりにくくするのでこれはやめておく

トランザクション処理 <?php $mysqli = new mysqli("localhost", "myuser", "mypass", "mydb"); $mysqli->autocommit(false); $mysqli->query("insert into mytab(id, name) values(1, 'foo')"); $mysqli->query("insert into mytab(id, name) values(1, 'foo')"); if (!$mysqli->commit()) { $mysqli->rollback(); echo "エラー発生！"; } else { echo "成功"; } $mysqli->close();

mysqliは例外を投げないのでtry/catchブロックを使えない

命令文のいずれかがエラーになった場合、mysqli::commit()呼び出しの返り値がfalseとなる。
このことを利用してトランザクションを行う。

■ PDOでの接続とトランザクション

MySQLへの接続とDBデータ取得テスト <?php $dsn = 'mysql:host=localhost;dbname=mydb'; $dbh = new PDO($dsn, 'myuser', 'mypass'); $sql = "select * from mytab"; foreach ($dbh->query($sql) as $row) { echo "{$row['id']}: {$row['name']}<br />\n"; }

トランザクション処理 <?php try { $dsn = 'mysql:host=localhost;dbname=mydb'; $dbh = new PDO($dsn, 'myuser', 'mypass'); // 発行不可能なプリペアステートメントを発行可能なようにエミュレート $dbh->setAttribute(PDO::ATTR_EMULATE_PREPARES, TRUE); // エラー時にPDOExceptionをスローするように $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); $dbh->beginTransaction(); $dbh->exec("insert into mytab(id, name) values(1, 'foo')"); $dbh->exec("insert into mytab(id, name) values(1, 'foo')"); $dbh->commit(); echo "成功"; } catch (PDOException $e) { $dbh->rollBack(); echo 'エラー発生: ' . $e->getMessage(); }