原生phpmysqli使用事务示例

追影

1. <?php
   
2. 
   
3. /* Tell mysqli to throw an exception if an error occurs */
   
4. mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
   
5. 
   
6. $mysqli = new mysqli("localhost", "my_user", "my_password", "world");
   
7. 
   
8. /* The table engine has to support transactions */
   
9. $mysqli->query("CREATE TABLE IF NOT EXISTS language (
   
10. Code text NOT NULL,
    
11. Speakers int(11) NOT NULL
    
12. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;");
    
13. 
    
14. /* Start transaction */
    
15. $mysqli->begin_transaction();
    
16. 
    
17. try {
    
18. /* Insert some values */
    
19. $mysqli->query("INSERT INTO language(Code, Speakers) VALUES ('DE', 42000123)");
    
20. 
    
21. /* Try to insert invalid values */
    
22. $language_code = 'FR';
    
23. $native_speakers = 'Unknown';
    
24. $stmt = $mysqli->prepare('INSERT INTO language(Code, Speakers) VALUES (?,?)');
    
25. $stmt->bind_param('ss', $language_code, $native_speakers);
    
26. $stmt->execute();
    
27. 
    
28. /* If code reaches this point without errors then commit the data in the database */
    
29. $mysqli->commit();
    
30. } catch (mysqli_sql_exception $exception) {
    
31. $mysqli->rollback();
    
32. 
    
33. throw $exception;
    
34. }

复制代码