質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

87.59%

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

解決済

回答 4

投稿 編集

  • 評価
  • クリップ 1
  • VIEW 1,596

score 17

閲覧頂きありがとうございます
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がアクセスしても、2つとも新規で追加されてしまいます。
これをAのみ追加され、BはDBを参照はできるが、追加はされず、DB内のデータと”エラー出力"とだけ出るようにしたいです。
なにか根本的に間違えているのでしょうか?

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

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

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

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

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

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

  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 過去に投稿した質問と同じ内容の質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

質問への追記・修正、ベストアンサー選択の依頼

  • ikedas

    2019/03/22 22:56

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

    キャンセル

  • ikedas

    2019/03/22 22:57

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

    キャンセル

  • 退会済みユーザー

    退会済みユーザー

    2019/03/22 23:48 編集

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

    キャンセル

  • ikedas

    2019/03/23 00:17

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

    キャンセル

回答 4

+3

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

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

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

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

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

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

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

checkベストアンサー

+2

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

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

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

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

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

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

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

0

たとえば、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) を使うかは実際のテーブル定義にあわせて決めてください。

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

0

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

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

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

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

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

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

15分調べてもわからないことは、teratailで質問しよう!

  • ただいまの回答率 87.59%
  • 質問をまとめることで、思考を整理して素早く解決
  • テンプレート機能で、簡単に質問をまとめられる

関連した質問

同じタグがついた質問を見る

  • トップ
  • PHPに関する質問
  • PHPでPDOを使用したDBの追加で同時接続された時、先にアクセスした処理のみ反映させたい