Q&A
トランザクションが効かないとは具体的にどういう状態なのかよくわかりません。できればコードを記載して、発生している事象についてどこが想定と違うのか記載してください。
cakephp2でリンクを叩いたらajax(php)が走るような処理を作っています。
このajaxの中でMysqlのトランザクションの処理があるのですがリンクを連打するとトランザクションが効かない時があって困っています。
トランザクションが100%効くことはありえないのでしょうか？
addとcancelを交互に実行しています。
php
1 public function add() 2 { 3 4 // 記事ID取得 5 $article_id = $this->_get_article_id(); 6 if (!$article_id) { 7 return; 8 } 9 10 // セッションID取得 11 $session_id = $this->_get_session_id(); 12 if (!$session_id) { 13 return; 14 } 15 16 // トランザクション開始 17 $this->model->begin(); 18 $query_log = $this->model->getDataSource()->getLog(); 19 $this->log('add-'.$query_log['log'][0]['query'],LOG_DEBUG); 20 21 // 既に同じ人で同じ記事IDで登録されていないかチェック 22 $count = $this->model->find('count', array( 23 'fields' => array('id'), 24 'conditions' => array( 25 'article_id' => $article_id, 26 'session' => $session_id, 27 ), 28 )); 29 $query_log = $this->model->getDataSource()->getLog(); 30 $this->log('add-1'.$query_log['log'][0]['query'],LOG_DEBUG); 31 32 if ($count >= 1) { 33 // ロールバック 34 $this->model->rollback(); 35 $query_log = $this->model->getDataSource()->getLog(); 36 $this->log('add-cnt(1):'.$query_log['log'][0]['query'],LOG_DEBUG); 37 $this->_error('failed added article_id'); 38 return; 39 } 40 41 // save用配列作成 42 $data['action_datetime'] = date('Y/m/d H:i:s'); 43 $data['article_id'] = $article_id; 44 $data['session'] = $session_id; 45 $data['ip_address'] = env('REMOTE_ADDR'); 46 $data['user_agent'] = env('HTTP_USER_AGENT'); 47 48 // データ保存 49 if ($this->model->save($data)) { 50 $this->log("add article_id: $article_id", 'article_useful'); 51 $query_log = $this->model->getDataSource()->getLog(); 52 $this->log('add-2'.$query_log['log'][0]['query'],LOG_DEBUG); 53 54 // コミット 55 $this->model->commit(); 56 $query_log = $this->model->getDataSource()->getLog(); 57 $this->log('add-3'.$query_log['log'][0]['query'],LOG_DEBUG); 58 59 } else { 60 $query_log = $this->model->getDataSource()->getLog(); 61 $this->log('add-4'.$query_log['log'][0]['query'],LOG_DEBUG); 62 // ロールバック 63 $this->model->rollback(); 64 $query_log = $this->model->getDataSource()->getLog(); 65 $this->log('add-5'.$query_log['log'][0]['query'],LOG_DEBUG); 66 debug('save failed'); 67 exit; 68 } 69 70 $this->set('result', true); 71 $this->set('message', "add ok"); 72 $this->set('_serialize', array('result', 'message')); 73 74 } 75 public function cancel() 76 { 77 78 // 記事ID取得 79 $article_id = $this->_get_article_id(); 80 if (!$article_id) { 81 return; 82 } 83 84 // セッションID取得 85 $session_id = $this->_get_session_id(); 86 if (!$session_id) { 87 return; 88 } 89 90 // トランザクション開始 91 $this->model->begin(); 92 $query_log = $this->model->getDataSource()->getLog(); 93 $this->log('del-'.$query_log['log'][0]['query'],LOG_DEBUG); 94 95 // 対象レコードのIDを取得するためにfindする 96 $data = $this->model->find('first', array( 97 'fields' => array('id'), 98 'conditions' => array( 99 'article_id' => $article_id, 100 'session' => $session_id, 101 ), 102 )); 103 $query_log = $this->model->getDataSource()->getLog(); 104 $this->log('del-1'.$query_log['log'][0]['query'],LOG_DEBUG); 105 106 if (!$data) { 107 // ロールバック 108 $this->model->rollback(); 109 $query_log = $this->model->getDataSource()->getLog(); 110 $this->log('del-cnt(0):'.$query_log['log'][0]['query'],LOG_DEBUG); 111 $this->_error('delete target not found'); 112 return; 113 } 114 115 // レコード削除 116 $id = $data['model']['id']; 117 if($this->model->delete($id)){ 118 $query_log = $this->model->getDataSource()->getLog(); 119 $this->log('del-2'.$query_log['log'][0]['query'],LOG_DEBUG); 120 121 // コミット 122 $this->model->commit(); 123 $query_log = $this->model->getDataSource()->getLog(); 124 $this->log('del-3'.$query_log['log'][0]['query'],LOG_DEBUG); 125 } else { 126 $query_log = $this->model->getDataSource()->getLog(); 127 $this->log('del-4'.$query_log['log'][0]['query'],LOG_DEBUG); 128 129 // ロールバック 130 $this->model->rollback(); 131 $query_log = $this->model->getDataSource()->getLog(); 132 $this->log('del-5'.$query_log['log'][0]['query'],LOG_DEBUG); 133 debug('del failed'); 134 exit; 135 136 } 137 138 139 $this->set('result', true); 140 $this->set('message', 'cancel ok'); 141 142 $this->set('_serialize', array('result', 'message')); 143 144 } 145
下記のようなログの状態が正しいのですが
add-begin add-1SELECT add-2SELECT add-3commit del-bigin del-1 del-2 del-3commit
たまに下記のようなログの状態になります。
add-bigin del-bigin del-1 add-1 add-cnt(1):rollback del-2 del-3commit
_get_article_id() メソッドおよび _get_session_id() メソッドの内容と、データを保存/削除しているテーブルのテーブル定義（SHOW CREATE TABE table_name; の実行結果）も質問欄に追記してください。そうすれば より詳しい状況が分かるので、具体的な回答を得やすくなると思います。
回答4件
0
いえ、後者の方でもトランザクションは働いています。むしろ、トランザクションはデータベースアクセスをブロックさせずに、どれだけ並列で流せるかを考えて作られているシステムです。
どうしてもaddとdeleteの並列処理をさせたくないのであれば、SELECT FOR UPDATEなどで適切にロックをかける必要があります。
投稿2016/10/26 09:18
総合スコア145183
0
自己解決
ajaxでフラグ管理することで解決できました。
ご回答いただいた皆様ありがとうございました。
投稿2016/10/27 06:23
総合スコア35
0
トランザクションは一定レベル（分離レベルに応じた）一貫性を担保することを目的としているので、他の処理との順序を制御したりはできません。詳しくは分離レベルについて調べるといいと思います。
なお、この記事の投稿と削除の処理においては、トランザクション自体いらない気がします。
- 追加は、article_idを事前に採番していますが、それがあまり良くないと思います。article_idは自動採番（AUTO_INCREMENT)にしておいて、INSERT時に自動的に採番するようにすれば、それで排他制御ができると思います。
- 削除は、事前にarticle_idが該当するレコードをfindで調べていますが、その必要もなく単にdeleteすればいいと思います。もし該当データがなかったら、スルーされるだけです。
むしろ、以下のような場合に、よくトランザクションを使いますね
例えば、記事データに関連するタグ情報があって、それらを別のinsertで実行する場合、途中までinsertした状態で他のユーザにselectされたら一貫性が保てない。なので、複数のinsertをトランザクションにする。また最初のinsertは成功したけど、後のinsertが失敗したので、ロールバックして最初のinsertを取り消す場合など。
なお、どうしてもロックをかけたかったらmaisumakunさんの回答のようにSELECT ... FOR UPDATEを使えばできると思います。
投稿2016/10/26 20:31
編集2016/10/26 20:40総合スコア6586
article_idについては固定IDで自動採番するべきものではないんです、、
自動採番すべきIDは別にありそのIDは正しく自動採番できています。
分離レベルについては調べてみようと思います。
ご回答いただきありがとうございました。
なるほどこれは記事のお気に入りみたいな機能なんですかね...。
そうだとしてもやっぱりトランザクションはいらない気がしますけど。
0
正しく書いてあればトランザクションは有効に機能すると思いますが
なにをみてトランザクションが効かないと判断されているのでしょうか？
ajaxの戻り値を見て判断しているのであれば
場合によってはなんらかのキャッシュのせいかもしれません
投稿2016/10/26 08:33
総合スコア114779
ソースを記載しましたがSQLのログから判断しています。
う~ん、掲示板でちょこちょこっと回答するにはちょっと複雑かもしれません。
ロールバックやコミットの条件がきちんとトランザクションの範囲に
収まっているのかどうかも提示されたソースの範囲では判断がつきません。
もう少し簡単なモデルにしてsleepなど併用しながら後発のタスクに
追い越させるなどテストしてみないと挙動がわかりませんね
現状ちょっとお役に立つような回答はできそうにありません、申し訳ないです
ご回答いただきありがとうございます。
あなたの回答
tips
プレビュー
