為什麼這篇php寫入資料庫鄉民發文收入到精華區:因為在php寫入資料庫這個討論話題中,有許多相關的文章在討論,這篇最有參考價值!作者sunz5010 (FoFo)看板PHP標題Re: [請益] 同時寫入資料庫的問題時間Fri M...
: : → 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