首頁  >  文章  >  後端開發  >  PHP+MySQL處理高併發加鎖事務步驟詳解

PHP+MySQL處理高併發加鎖事務步驟詳解

php中世界最好的语言
php中世界最好的语言原創
2018-05-16 11:38:072690瀏覽

PHP+MySQL處理高併發加鎖事務步驟詳解

這次帶給大家PHP MySQL處理高並發加鎖事務步驟詳解,PHP MySQL處理高並發加鎖事務的注意事項有哪些,下面就是實戰案例,一起來看一下。

1、背景:

現在有這樣的需求,插入資料時,判斷test表有無username為'mraz'的數據,無則插入,有則提示“已插入”,目的就是想只插入一條username為'mraz'的記錄。

2、一般程式邏輯如下:

$conn = mysqli_connect('127.0.0.1', 'root', '111111') or die(mysqli_error());
mysqli_select_db($conn, 'mraz');
$rs = mysqli_query($conn, 'SELECT count(*) as total FROM test WHERE username = "mraz" ');
$row = mysqli_fetch_array($rs);
if($row['total']>0){
  exit('exist');
}
mysqli_query($conn, "insert into test(username) values ('mraz')");
var_dump('error:'.mysqli_errno($conn));
$insert_id = mysqli_insert_id($conn);
echo 'insert_id:'.$insert_id.'<br>';
mysqli_free_result($rs);
mysqli_close($conn);

#3、一般少量請求的時候,程式邏輯不會有問題。但一旦高並發請求執行的話,程式並沒有如預期執行,會插入多條username為‘mraz'的記錄。

4、解決方案利用mysql的FOR UPDATE 語句和交易的隔離性。注意的是FOR UPDATE僅適用於InnoDB,且必須在交易(BEGIN/COMMIT)中才能生效。

調整程式碼後如下:

$conn = mysqli_connect('127.0.0.1', 'root', '111111') or die(mysqli_error());
mysqli_select_db($conn, 'mraz');
mysqli_query($conn, 'BEGIN');
$rs = mysqli_query($conn, 'SELECT count(*) as total FROM test WHERE username = "mraz" FOR UPDATE');
$row = mysqli_fetch_array($rs);
if($row['total']>0){
  exit('exist');
}
mysqli_query($conn, "insert into test(username) values ('mraz')");
var_dump('error:'.mysqli_errno($conn));
$insert_id = mysqli_insert_id($conn);
mysqli_query($conn, 'COMMIT');
echo 'insert_id:'.$insert_id.'<br>';
mysqli_free_result($rs);
mysqli_close($conn);

相信看了本文案例你已經掌握了方法,更多精彩請關注php中文網其它相關文章!

推薦閱讀:

PHP產生二維碼海報案例分析

#PHP動態壓縮js與css檔案步驟詳解

PHPExcel修改步驟詳解

#

以上是PHP+MySQL處理高併發加鎖事務步驟詳解的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn