PHP & mySQL: Mã đơn giản để thực hiện giao dịch - Commit & Rollback

Question

PLATFORM MY:

PHP & mySQL

TÌNH CỦA TÔI:

Tôi cố gắng để thực hiện các giao dịch trong mã của tôi . Tôi đã cố gắng làm theo các ví dụ, nhưng nó không giúp được gì nhiều. Tôi đang chạy 3 truy vấn và tôi muốn viết một giao dịch theo cách sao cho nếu có bất kỳ truy vấn nào bị lỗi, toàn bộ giao dịch sẽ quay trở lại. Tôi thực sự đánh giá cao một mã PHP theo định hướng không đối tượng đơn giản, hiệu quả và không phải đối tượng để đạt được mục tiêu này. Cảm ơn bạn trước.

PHP MY Mã sản phẩm:

//db_res calls a custom function that performs a mysql_query on the query 
$res1 = db_res("SELECT c1, c2 FROM t1 WHERE c5 = 3"); 
$res2 = db_res("UPDATE t2 SET c1 = 5 WHERE c2 = 10"); 
$res3 = db_res("DELETE FROM t3 WHERE c1 = 20"); 

if($res1 && $res2 && $res3) 
{ 
//commit --- but how? 
} 
else 
{ 
//rollback --- but how? 
} 

Answer 1

Bạn cần phải sử dụng mysqli extension để sử dụng chức năng này.

Xem: autocommit(), commit(), và rollback()

<?php 
$link = mysqli_connect("localhost", "my_user", "my_password", "world"); 

/* check connection */ 
if (mysqli_connect_errno()) { 
    printf("Connect failed: %s\n", mysqli_connect_error()); 
    exit(); 
} 

/* disable autocommit */ 
mysqli_autocommit($link, FALSE); 

mysqli_query($link, "CREATE TABLE myCity LIKE City"); 
mysqli_query($link, "ALTER TABLE myCity Type=InnoDB"); 
mysqli_query($link, "INSERT INTO myCity SELECT * FROM City LIMIT 50"); 

/* commit insert */ 
mysqli_commit($link); 

/* delete all rows */ 
mysqli_query($link, "DELETE FROM myCity"); 

if ($result = mysqli_query($link, "SELECT COUNT(*) FROM myCity")) { 
    $row = mysqli_fetch_row($result); 
    printf("%d rows in table myCity.\n", $row[0]); 
    /* Free result */ 
    mysqli_free_result($result); 
} 

/* Rollback */ 
mysqli_rollback($link); 

if ($result = mysqli_query($link, "SELECT COUNT(*) FROM myCity")) { 
    $row = mysqli_fetch_row($result); 
    printf("%d rows in table myCity (after rollback).\n", $row[0]); 
    /* Free result */ 
    mysqli_free_result($result); 
} 

/* Drop table myCity */ 
mysqli_query($link, "DROP TABLE myCity"); 

mysqli_close($link); 
?> 

Answer 2

Bạn không cần phải sử dụng mysqli. Bạn chỉ có thể phát hành lệnh giao dịch dưới dạng truy vấn.

Vì vậy, ví dụ bạn:

mysql_query("start transaction;"); 

//db_res calls a custom function that performs a mysql_query on the query 
$res1 = db_res("SELECT c1, c2 FROM t1 WHERE c5 = 3"); 
$res2 = db_res("UPDATE t2 SET c1 = 5 WHERE c2 = 10"); 
$res3 = db_res("DELETE FROM t3 WHERE c1 = 20"); 

if($res1 && $res2 && $res3) 
{ 
    mysql_query("commit;"); 
} 
else 
{ 
    mysql_query("rollback;"); 
} 

Bởi họ cách nếu bạn đang nghĩ về việc nâng cấp để MySQLi, xin vui lòng không. Nâng cấp lên PDO thay vào đó, nó sane hơn nhiều.