PHPでPDOを使用したDBの追加で同時接続された時、先にアクセスした処理のみ反映させたい

Question

閲覧頂きありがとうございます
PHPのPDOを利用した同時接続の件で質問です。

例えばAとB二人のユーザーがいたとして、Aがまずページにアクセスし5秒後にBがアクセスしたとします。
その時AのDB追加処理のみうごかし、BはDBを参照するだけ。というふうにしたいです。

調べた所、Aがアクセスした段階でロックをかければいい。という感じの記載がありましたので自分なりにやってみたのですが、どうにもうまくいきません。

どなたかご教授いただけませんでしょうか？

require( dirname( __file__ ) . "/sample.php" ); //DBを$pdoに格納

$sql = "SELECT * FROM sample ";
$result = $pdo->query( $sql );
$datas = $result->fetch( PDO::FETCH_ASSOC );
print_r( $datas );
//ここまでは必ず出るように
try {

	$pdo->beginTransaction();
	//新規追加が動いていなければ10秒待ってから追加	
	sleep( 10 );
	$sql = 'INSERT INTO (name,url,bangou) VALUE (?,?,?)';
	$prepare = $pdo->prepare( $sql );
	$prepare->bindValue( 1, "yamada" );
	$prepare->bindValue( 2, 11 );
	$prepare->bindValue( 3, 22 );
	$prepare->execute();
　　　　  $pdo->commit();
} catch ( PDOException $e ) {

	//すでに新規追加が動いていれば下記のechoを出力
	$dbh->rollBack();
	echo "エラー出力";
}

追加は基本的に問題なくされますが、Aがアクセスしてから5秒後にBがアクセスしても、２つとも新規で追加されてしまいます。
これをAのみ追加され、BはDBを参照はできるが、追加はされず、DB内のデータと”エラー出力"とだけ出るようにしたいです。
なにか根本的に間違えているのでしょうか？

またもう一つききたいのですが、
$pdo->commit();
これで一時的にためていたものをDBに追加する。と書いていたのですが、これを外した場合も、問題なく追加されます。

なぜなのかご教授いただけると幸いです。

よろしくお願いいたします！

追記
ikedasさん
ご返答ありがとうございます。
指定頂いたページは一通り目を通しておりました・・・ただ理解力がないため、出来ませんでした。
データベースはMySQL 5.6.36です。

Kosuke_Shibuyaさん
ご返答ありがとうございます。
たとえば、1時間に一度、自分の他のサイトを見に行き、データを取ってきて、それをDBに格納する。という処理を考えております。
そのため、AとBがほぼ同時に来た場合、ロックを掛けておかないと取得している時に、Bも同じものを取得してきて、同じモノが2度登録されてしまうのでは無いかと考えておりました。

別の方法でも、なにかいい方法があればご教授頂けると幸いです。

Comments

[ikedas]

このページは読まれましたか。
あと念のため、使っているデータベースの種類 (例: MySQLバージョンX.X) も質問文に追記くださいませんか。

[ikedas]

意味不明になってました。「このページ」とはこれです。
http://php.net/manual/ja/pdo.transactions.php

[退会済みユーザー]

普通、UPDATEの時にロックするなら分かるけど、INSERTでロックする意味はないと思いますが。

[ikedas]

先着順でなにかもらえるのかもしれません。

Answer 1

たとえば、1時間に一度、自分の他のサイトを見に行き、データを取ってきて、それをDBに格納する。という処理を考えております。

そのため、AとBがほぼ同時に来た場合、ロックを掛けておかないと取得している時に、Bも同じものを取得してきて、同じモノが2度登録されてしまうのでは無いかと考えておりました。

こういう処理を行いたい時になぜトランザクション？と素朴な疑問。
トランザクションでは同一接続内でのデータの整合性を担保するために使う。

MySQLのデフォルトのINNODBでは行ロックとなり、Aがロックするのは挿入しようとする行だけであり、Bが挿入する行には無関係。

設計の是非は別として、テーブル全体をロックするのは別のコマンド。
https://dev.mysql.com/doc/refman/5.6/ja/lock-tables.html

Bも同じものを取得してきて、同じモノが2度登録されてしまうのでは無いか

ただし、「同じものじゃない」ときもロックされるので、「設計がおかしいのでは」と思います。

Answer 2

そもそも、やりたいことの仕様が明確でないと思います。

例えばAとB二人のユーザーがいたとして、Aがまずページにアクセスし5秒後にBがアクセスしたとします。
その時AのDB追加処理のみうごかし、BはDBを参照するだけ。というふうにしたいです。

5秒というのは、コンピュータ処理にとっては「長い」時間です。ロックの話は、AとBが 0.001秒差でアクセスするようなケースと考えてください。5秒だとユーザAの処理はもう終わっているでしょうから、ロックをかけても、Bには影響しません。

想像してみましたが、例えば、以下のような仕様でしょうか?

• 誰かが挿入処理をしたら、その後 1分間（この数字は仮のもので、実際の数字は仕様として定義する）は誰も挿入処理はできず、参照のみとなる

上記はあくまで例ですが、このような形で、明確にやりたいことを仕様として定義しないと、プログラムを作ることはできません。

Answer 3

同じモノが2度登録されてしまう

のを防止するだけなら、同じものにあたるカラムにunique属性を付けておけば
よいでしょう。

なお、競合が起きたとき、あとからのデータは

• 入力エラーになる
• エラーを起こさずに無視される
• データを更新する

のどれかになると思うので適宜処理を入れればよいでしょう

Answer 4

たとえば、1時間に一度、自分の他のサイトを見に行き、データを取ってきて、それをDBに格納する。という処理を考えております。
そのため、AとBがほぼ同時に来た場合、ロックを掛けておかないと取得している時に、Bも同じものを取得してきて、同じモノが2度登録されてしまうのでは無いかと考えておりました。

「同じもの」ということですが、逆に言えば、データベースのテーブルに格納されたデータは区別できる、ということですね。データのどこで区別するのでしょうか。

仮に、URLで区別するのだとします。であれば、url列に一意のインデクス (キー) を付けてやれば、すでにテーブル中にある行のURLと同じURLを含んだ行を追加することはできません (あとから追加しようとしたほうのSQL文の実行が失敗します)。

テーブルの構造をSQL文で書けば、次のようなものでしょう (あくまでも例です)。

CREATE TABLE sample (
    name varchar(100),
    url varchar(191) UNIQUE KEY,
    bangou int
) CHARACTER SET utf8;

url列に一意キー (UNIQUE KEY) を使うか主キー (PRIMARY KEY) を使うかは実際のテーブル定義にあわせて決めてください。