如何用PDO::beginTransaction結合PDO::rollBack實現事務回滾操作？

gitbox 2025-08-11

在數據庫操作中，事務管理是一個非常重要的概念，它保證了數據操作的原子性、一致性、隔離性和持久性（即ACID特性）。在PHP中，我們可以使用PDO（PHP Data Objects）來與數據庫進行交互，而事務管理則可以通過PDO提供的beginTransaction() 、 commit()和rollBack()方法來實現。本文將詳細介紹如何使用PDO的beginTransaction結合rollBack來實現事務回滾操作。

1. 什麼是事務？

事務（Transaction）是指一組操作的集合，這些操作要么全部成功，要么全部失敗。事務確保了數據庫操作的一致性和完整性。在數據庫系統中，事務的基本特性可以通過ACID來描述：

原子性（Atomicity） ：事務中的所有操作要么全部完成，要么全部不做。
一致性（Consistency） ：事務的執行會使數據庫從一個一致性狀態轉變到另一個一致性狀態。
隔離性（Isolation） ：多個事務並發執行時，一個事務的執行不應受其他事務的干擾。
持久性（Durability） ：一旦事務提交，對數據庫的更改就會永久保存。

2. 事務的基本操作

在PDO中，事務的基本操作包括：

beginTransaction() ：開始事務。
commit() ：提交事務。
rollBack() ：回滾事務。

通常，在數據庫操作過程中，如果某個步驟出錯，可以使用rollBack()方法回滾事務，撤銷之前的所有操作。

3. 使用beginTransaction()和rollBack()的示例

假設我們需要執行多個數據庫操作，如插入記錄、更新記錄等。如果其中一個操作失敗，我們希望能夠撤銷之前的所有操作，以確保數據庫的一致性。這時，我們就可以使用beginTransaction()和rollBack()方法。

 <span><span><span class="hljs-meta">&lt;?php</span></span><span>
</span><span><span class="hljs-keyword">try</span></span><span> {
    </span><span><span class="hljs-comment">// 創建PDO連接</span></span><span>
    </span><span><span class="hljs-variable">$pdo</span></span><span> = </span><span><span class="hljs-keyword">new</span></span><span> </span><span><span class="hljs-title function_ invoke__">PDO</span></span><span>(</span><span><span class="hljs-string">'mysql:host=localhost;dbname=testdb'</span></span><span>, </span><span><span class="hljs-string">'username'</span></span><span>, </span><span><span class="hljs-string">'password'</span></span><span>);
    </span><span><span class="hljs-comment">// 設置錯誤模式為異常</span></span><span>
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">setAttribute</span></span><span>(PDO::</span><span><span class="hljs-variable constant_">ATTR_ERRMODE</span></span><span>, PDO::</span><span><span class="hljs-variable constant_">ERRMODE_EXCEPTION</span></span><span>);

    </span><span><span class="hljs-comment">// 開始事務</span></span><span>
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">beginTransaction</span></span><span>();

    </span><span><span class="hljs-comment">// 執行第一個SQL操作</span></span><span>
    </span><span><span class="hljs-variable">$sql1</span></span><span> = </span><span><span class="hljs-string">"INSERT INTO users (username, email) VALUES ('john_doe', '[email protected]')"</span></span><span>;
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">exec</span></span><span>(</span><span><span class="hljs-variable">$sql1</span></span><span>);

    </span><span><span class="hljs-comment">// 執行第二個SQL操作</span></span><span>
    </span><span><span class="hljs-variable">$sql2</span></span><span> = </span><span><span class="hljs-string">"UPDATE accounts SET balance = balance - 100 WHERE username = 'john_doe'"</span></span><span>;
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">exec</span></span><span>(</span><span><span class="hljs-variable">$sql2</span></span><span>);

    </span><span><span class="hljs-comment">// 如果一切正常，提交事務</span></span><span>
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">commit</span></span><span>();
    </span><span><span class="hljs-keyword">echo</span></span><span> </span><span><span class="hljs-string">"事務提交成功！"</span></span><span>;

} </span><span><span class="hljs-keyword">catch</span></span><span> (</span><span><span class="hljs-built_in">Exception</span></span><span> </span><span><span class="hljs-variable">$e</span></span><span>) {
    </span><span><span class="hljs-comment">// 如果發生錯誤，回滾事務</span></span><span>
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">rollBack</span></span><span>();
    </span><span><span class="hljs-keyword">echo</span></span><span> </span><span><span class="hljs-string">"事務回滾："</span></span><span>, </span><span><span class="hljs-variable">$e</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">getMessage</span></span><span>();
}
</span><span><span class="hljs-meta">?&gt;</span></span><span>
</span></span>

4. 解釋代碼流程

建立PDO連接：首先，我們通過PDO連接到MySQL數據庫，並設置錯誤模式為PDO::ERRMODE_EXCEPTION ，以便在發生錯誤時拋出異常。
開始事務：通過調用$pdo->beginTransaction() ，我們告訴PDO開始一個事務。此時，所有的數據庫操作都處於事務管理之下，任何一項操作失敗，其他操作將不會被提交。
執行SQL操作：
- 第一個SQL操作是插入一個用戶記錄。
- 第二個SQL操作是更新一個用戶賬戶的餘額。
提交事務：如果所有操作都成功，我們通過調用$pdo->commit()提交事務，將所有操作永久保存到數據庫中。
回滾事務：如果在執行過程中發生異常（比如第二個SQL操作失敗），就會觸發catch塊中的代碼，調用$pdo->rollBack()進行事務回滾，撤銷所有未提交的操作。

5. 注意事項

事務的原子性：使用beginTransaction()後，所有的數據庫操作都將視為一個整體。如果發生錯誤， rollBack()可以撤銷整個事務，保證數據一致性。
異常處理：務必使用try-catch塊來捕獲異常，確保在操作失敗時能及時回滾事務。
多次事務操作：在一個事務中執行多次操作時，只要在事務提交之前沒有出現錯誤，所有操作都會生效。

6. 總結

通過PDO的beginTransaction()和rollBack()方法，我們可以在PHP中高效地管理事務，並在出現錯誤時進行事務回滾操作，確保數據庫操作的原子性和一致性。這種方式在需要執行多個數據庫操作的場景中非常有用，尤其是在處理資金交易、訂單處理等敏感操作時，事務回滾可以避免數據不一致的問題。

相關標籤:
PDO

PDO::beginTransaction