Re: [請益] 同時寫入資料庫的問題

看板PHP作者sunz5010 (FoFo)時間14年前 (2011/03/25 10:55)推噓0(0推 0噓 4→)

留言4則, 1人參與討論串3/4 (看更多)

: : → cokellen:樓上,MySql ,innodb, transaction : : → sunz5010:我用一個新的table的PK、然後用insert去做 : : → sunz5010:要寫入資料庫之前、先inset這個PK、可以insert就寫入 : : → sunz5010:不能insert就等待別人delete之後再做寫入資料庫 : : → sunz5010:因為用mysql insert一個pk不會有重複的問題 : : → sunz5010:如果有人先搶先寫入、後來的人會出現1064的error code : : → sunz5010:等第一個人delete之後、第二個人就能正常inset : : → sunz5010:利用這個功能就可以達到[LOCK]的效果、還不錯用＠＠ : 假設您有個欄位紀錄數字，叫做 qty 然後有個 pkey 叫做 id 。 : 提供一個作法給您參考： : /** : CREATE TABLE `scart` ( : `id` int(11) NOT NULL AUTO_INCREMENT, : `title` varchar(10) NOT NULL, : `qty` int(11) NOT NULL, : PRIMARY KEY (`id`) : ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 : */ : $id = 1; : $qty = 2; : $dbh = new PDO('mysql:host=localhost;dbname=benchmark','test','password', : array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8")); : $dbh->beginTransaction(); : $sth = $dbh->prepare("SELECT qty FROM scart WHERE id = :id FOR UPDATE"); : 用 select for update 在 commit (rollback) 前都會有 exclusive lock (row level) : $sth->execute(array(':id'=> $id)); : $result = $sth->fetch(); : if(($result['qty'] - $qty) >= 0) : { : $sth = $dbh->prepare("UPDATE scart SET qty = qty - :qty WHERE id = :id"); : $sth->execute(array(':qty' => $qty, ':id' => $id)); : $dbh->commit(); : } : else : { : echo "not enough stock." . PHP_EOL; : $dbh->rollback(); : } : 以上是先拿出庫存再來算數量，但是您要考慮 innodb_lock_wait_timeout ， : 這個預設是 50 秒，等起來有點久。或是考慮另一種作法，不要 select 直接計算 : $sth = $dbh->prepare("UPDATE scart SET qty = qty - :qty : WHERE id = :id and qty - :qty > 0"); : $sth->execute(array(':qty'=>$qty, ':id'=>$id)); : 然後 update 失敗就代表庫存不夠，叫使用者重新回頁面購買。謝謝你的分享、我也順便分享一下我的作法我原本的問題是「倉庫」:1顆蘋果「甲」=>想買蘋果「乙」=>想買蘋果而買蘋果的機制如為(1)先檢查有沒有蘋果 (2)有的話就買但要讓整個機制都在Critical Secion底下、就需要一個lock 觀念是「Lock資源」=>籃子機制是=>誰先搶到「籃子」、就能購買 if(籃子) { (1)檢查有沒有蘋果 (2)有的話就買 } else //拿不到籃子的情況 { 等待拿籃子、並且嘗試拿取 } 讓我困擾的是、要製作這個Lock資源、必須要有一個具有實現lock功能的工具於是我想到了MySQL的Primary Key 我的作法是、創造一個「MyLock」的Table 裡面可以有很多資訊、但主要的就是要有一個LockName這個PrimaryKey (我這個Table其實也只放了這一個欄位) 所以作法如下： /*****Start*****/ //買東西之前 reslut = MySQL(insert into MyLock (LockName) value ("籃子")) while(result=>ErrorCode == 1062) //1062：重複的PK { //有人拿了籃子、等待一秒、之後嘗試拿籃子 sleep(1); //先等待一個時間 result = MySQL(insert into MyLock (LockName) vlaue ("籃子"); } //Critical Secion [Start] (1)檢查倉庫有沒有蘋果 (2)有的話就買 //Critical Secion [End] MySQL(delete from MyLock where LockName = '籃子') //釋放籃子資源 /*******End*******/ 這個方式挺容易的而且沒有複雜的MySQL判斷跟指令另外跟原本的lock 觀念也一致分享給大家＠＠、如果我的方法有什麼問題也歡迎討論 -- ※ 發信站: 批踢踢實業坊(ptt.cc) ◆ From: 175.180.127.239