PHP MySQL Transaction (original) (raw)

Summary: in this tutorial, you will learn how to handle MySQL transactions in PHP to ensure the data integrity of the database.

Introduction to PHP MySQL Transaction

A transaction is a set of SQL statements that need to be executed in an all-or-nothing manner.

A transaction is considered successful only if all SQL statements are executed successfully. The failure of any statement will trigger the database to roll back to the original state to prevent data inconsistency.

A classic example of a transaction is a money transfer transaction from one bank account to another, involving three steps:

First, check the balance of the sender to ensure it is sufficient for the transfer.
Second, if the amount is sufficient, deduct it from the balance of the sender’s account.
Third, add the amount to the balance of the receiver account.

If an error occurs in the second step, the third step should not proceed. Similarly, if an error occurs in the third step, the second step must be reversed.

The amounts of both accounts remain intact in case of failure or are adjusted correctly if the transaction is completed successfully.

When you use PDO to create a connection to the database that supports transactions, the auto-commit mode is set. This means that every query you issue is wrapped inside an implicit transaction.

Please be aware that not all storage engines in MySQL support transactions. For example, MyISAM does not support transactions, while InnoDB does.

To handle MySQL transactions in PHP, you follow these steps:

Start the transaction by calling the beginTransaction() method of the PDO object.
Place the SQL statements and the commit() method call in a try block.
In the catch block, roll back the transaction by calling the rollBack() method of the PDO object.

Setting up a sample table

We will create a table named accounts to demonstrate the money transfer between two bank accounts.

First, execute the following statement to create the accounts table:

CREATE TABLE accounts ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR (50) NOT NULL, amount DECIMAL (19, 4) NOT NULL );Code language: SQL (Structured Query Language) (sql)

Second, insert two rows into the accounts table:

INSERT INTO accounts(name,amount) VALUES('John',25000), ('Mary',95000);Code language: SQL (Structured Query Language) (sql)

Third, query the accounts table:

SELECT * FROM accounts;Code language: PHP (php)

Output:

+----+------+------------+ | id | name | amount | +----+------+------------+ | 1 | John | 25000.0000 | | 2 | Mary | 95000.0000 | +----+------+------------+ 2 rows in set (0.00 sec)Code language: JavaScript (javascript)

Handling transactions in PHP

The following script illustrates how to handle transactions in PHP:

`<?php require_once 'config.php';

function transfer($conn, sender,sender, sender,receiver, $amount) { try { $conn->beginTransaction();

    // get balance of the sender
    $sql = 'SELECT amount FROM accounts WHERE id=:sender';
    <span class="katex"><span class="katex-mathml"><math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>=</mo></mrow><annotation encoding="application/x-tex">stmt = </annotation></semantics></math></span><span class="katex-html" aria-hidden="true"><span class="base"><span class="strut" style="height:0.6151em;"></span><span class="mord mathnormal">s</span><span class="mord mathnormal">t</span><span class="mord mathnormal">m</span><span class="mord mathnormal">t</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">=</span></span></span></span>conn->prepare($sql);
    <span class="katex"><span class="katex-mathml"><math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>−</mo><mo>&gt;</mo><mi>e</mi><mi>x</mi><mi>e</mi><mi>c</mi><mi>u</mi><mi>t</mi><mi>e</mi><mo stretchy="false">(</mo><mo stretchy="false">[</mo><mi mathvariant="normal">&quot;</mi><mo>:</mo><mi>s</mi><mi>e</mi><mi>n</mi><mi>d</mi><mi>e</mi><mi>r</mi><mi mathvariant="normal">&quot;</mi><mo>=</mo><mo>&gt;</mo></mrow><annotation encoding="application/x-tex">stmt-&gt;execute([&quot;:sender&quot; =&gt; </annotation></semantics></math></span><span class="katex-html" aria-hidden="true"><span class="base"><span class="strut" style="height:0.6984em;vertical-align:-0.0833em;"></span><span class="mord mathnormal">s</span><span class="mord mathnormal">t</span><span class="mord mathnormal">m</span><span class="mord mathnormal">t</span><span class="mord">−</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">&gt;</span><span class="mspace" style="margin-right:0.2778em;"></span></span><span class="base"><span class="strut" style="height:1em;vertical-align:-0.25em;"></span><span class="mord mathnormal">e</span><span class="mord mathnormal">x</span><span class="mord mathnormal">ec</span><span class="mord mathnormal">u</span><span class="mord mathnormal">t</span><span class="mord mathnormal">e</span><span class="mopen">([</span><span class="mord">&quot;</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">:</span><span class="mspace" style="margin-right:0.2778em;"></span></span><span class="base"><span class="strut" style="height:0.7335em;vertical-align:-0.0391em;"></span><span class="mord mathnormal">se</span><span class="mord mathnormal">n</span><span class="mord mathnormal">d</span><span class="mord mathnormal" style="margin-right:0.02778em;">er</span><span class="mord">&quot;</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">=&gt;</span></span></span></span>sender]);
    <span class="katex"><span class="katex-mathml"><math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>a</mi><mi>v</mi><mi>a</mi><mi>i</mi><mi>l</mi><mi>a</mi><mi>b</mi><mi>l</mi><mi>e</mi><mi>A</mi><mi>m</mi><mi>o</mi><mi>u</mi><mi>n</mi><mi>t</mi><mo>=</mo></mrow><annotation encoding="application/x-tex">availableAmount = </annotation></semantics></math></span><span class="katex-html" aria-hidden="true"><span class="base"><span class="strut" style="height:0.6944em;"></span><span class="mord mathnormal">a</span><span class="mord mathnormal" style="margin-right:0.03588em;">v</span><span class="mord mathnormal">ai</span><span class="mord mathnormal" style="margin-right:0.01968em;">l</span><span class="mord mathnormal">ab</span><span class="mord mathnormal" style="margin-right:0.01968em;">l</span><span class="mord mathnormal">e</span><span class="mord mathnormal">A</span><span class="mord mathnormal">m</span><span class="mord mathnormal">o</span><span class="mord mathnormal">u</span><span class="mord mathnormal">n</span><span class="mord mathnormal">t</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">=</span></span></span></span>stmt->fetchColumn();
    $stmt->closeCursor();

    if ($availableAmount < $amount) {
        echo 'Insufficient amount to transfer';
        return $conn->rollBack();
    }

    // deduct from the sender
    $sql_deduct = 'UPDATE accounts
                   SET amount = amount - :amount
                   WHERE id = :sender';

    <span class="katex"><span class="katex-mathml"><math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>=</mo></mrow><annotation encoding="application/x-tex">stmt = </annotation></semantics></math></span><span class="katex-html" aria-hidden="true"><span class="base"><span class="strut" style="height:0.6151em;"></span><span class="mord mathnormal">s</span><span class="mord mathnormal">t</span><span class="mord mathnormal">m</span><span class="mord mathnormal">t</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">=</span></span></span></span>conn->prepare($sql_deduct);
    <span class="katex"><span class="katex-mathml"><math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>−</mo><mo>&gt;</mo><mi>e</mi><mi>x</mi><mi>e</mi><mi>c</mi><mi>u</mi><mi>t</mi><mi>e</mi><mo stretchy="false">(</mo><mo stretchy="false">[</mo><mi mathvariant="normal">&quot;</mi><mo>:</mo><mi>s</mi><mi>e</mi><mi>n</mi><mi>d</mi><mi>e</mi><mi>r</mi><mi mathvariant="normal">&quot;</mi><mo>=</mo><mo>&gt;</mo></mrow><annotation encoding="application/x-tex">stmt-&gt;execute([&quot;:sender&quot; =&gt; </annotation></semantics></math></span><span class="katex-html" aria-hidden="true"><span class="base"><span class="strut" style="height:0.6984em;vertical-align:-0.0833em;"></span><span class="mord mathnormal">s</span><span class="mord mathnormal">t</span><span class="mord mathnormal">m</span><span class="mord mathnormal">t</span><span class="mord">−</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">&gt;</span><span class="mspace" style="margin-right:0.2778em;"></span></span><span class="base"><span class="strut" style="height:1em;vertical-align:-0.25em;"></span><span class="mord mathnormal">e</span><span class="mord mathnormal">x</span><span class="mord mathnormal">ec</span><span class="mord mathnormal">u</span><span class="mord mathnormal">t</span><span class="mord mathnormal">e</span><span class="mopen">([</span><span class="mord">&quot;</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">:</span><span class="mspace" style="margin-right:0.2778em;"></span></span><span class="base"><span class="strut" style="height:0.7335em;vertical-align:-0.0391em;"></span><span class="mord mathnormal">se</span><span class="mord mathnormal">n</span><span class="mord mathnormal">d</span><span class="mord mathnormal" style="margin-right:0.02778em;">er</span><span class="mord">&quot;</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">=&gt;</span></span></span></span>sender, ":amount" => $amount]);
    $stmt->closeCursor();

    // add amount to the receiver
    $sql_add = 'UPDATE accounts
                SET amount = amount + :amount
                WHERE id = :receiver';

    <span class="katex"><span class="katex-mathml"><math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>=</mo></mrow><annotation encoding="application/x-tex">stmt = </annotation></semantics></math></span><span class="katex-html" aria-hidden="true"><span class="base"><span class="strut" style="height:0.6151em;"></span><span class="mord mathnormal">s</span><span class="mord mathnormal">t</span><span class="mord mathnormal">m</span><span class="mord mathnormal">t</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">=</span></span></span></span>conn->prepare($sql_add);
    <span class="katex"><span class="katex-mathml"><math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>−</mo><mo>&gt;</mo><mi>e</mi><mi>x</mi><mi>e</mi><mi>c</mi><mi>u</mi><mi>t</mi><mi>e</mi><mo stretchy="false">(</mo><mo stretchy="false">[</mo><mi mathvariant="normal">&quot;</mi><mo>:</mo><mi>r</mi><mi>e</mi><mi>c</mi><mi>e</mi><mi>i</mi><mi>v</mi><mi>e</mi><mi>r</mi><mi mathvariant="normal">&quot;</mi><mo>=</mo><mo>&gt;</mo></mrow><annotation encoding="application/x-tex">stmt-&gt;execute([&quot;:receiver&quot; =&gt; </annotation></semantics></math></span><span class="katex-html" aria-hidden="true"><span class="base"><span class="strut" style="height:0.6984em;vertical-align:-0.0833em;"></span><span class="mord mathnormal">s</span><span class="mord mathnormal">t</span><span class="mord mathnormal">m</span><span class="mord mathnormal">t</span><span class="mord">−</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">&gt;</span><span class="mspace" style="margin-right:0.2778em;"></span></span><span class="base"><span class="strut" style="height:1em;vertical-align:-0.25em;"></span><span class="mord mathnormal">e</span><span class="mord mathnormal">x</span><span class="mord mathnormal">ec</span><span class="mord mathnormal">u</span><span class="mord mathnormal">t</span><span class="mord mathnormal">e</span><span class="mopen">([</span><span class="mord">&quot;</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">:</span><span class="mspace" style="margin-right:0.2778em;"></span></span><span class="base"><span class="strut" style="height:0.7335em;vertical-align:-0.0391em;"></span><span class="mord mathnormal">rece</span><span class="mord mathnormal">i</span><span class="mord mathnormal" style="margin-right:0.03588em;">v</span><span class="mord mathnormal" style="margin-right:0.02778em;">er</span><span class="mord">&quot;</span><span class="mspace" style="margin-right:0.2778em;"></span><span class="mrel">=&gt;</span></span></span></span>receiver, ":amount" => $amount]);

    // commit the transaction
    $conn->commit();
    echo 'The amount has been transferred successfully';
} catch (PDOException $e) {
    if($conn) {
        $conn->rollBack();
    }
    die($e);
}

}

// connect the database conn=newPDO("mysql:host=conn = new PDO("mysql:host=conn=newPDO("mysql:host=host;dbname=$dbname", username,username, username,password);

// transfer 30K from from account 1 to 2 transfer($conn, 1, 2, 30000); // failed

// transfer 5K from from account 1 to 2 transfer($conn, 1, 2, 5000); // success `Code language: PHP (php)

How it works.

First, define a function transfer() that transfers an amount from sender to receiver.

Second, start a new transaction by calling the beginTransaction() method:

$conn->beginTransaction();Code language: PHP (php)

Third, get the sender’s balance:

// get balance of the sender <math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>q</mi><mi>l</mi><msup><mo>=</mo><mo mathvariant="normal" lspace="0em" rspace="0em">′</mo></msup><mi>S</mi><mi>E</mi><mi>L</mi><mi>E</mi><mi>C</mi><mi>T</mi><mi>a</mi><mi>m</mi><mi>o</mi><mi>u</mi><mi>n</mi><mi>t</mi><mi>F</mi><mi>R</mi><mi>O</mi><mi>M</mi><mi>a</mi><mi>c</mi><mi>c</mi><mi>o</mi><mi>u</mi><mi>n</mi><mi>t</mi><mi>s</mi><mi>W</mi><mi>H</mi><mi>E</mi><mi>R</mi><mi>E</mi><mi>i</mi><mi>d</mi><mo>=</mo><mo>:</mo><mi>s</mi><mi>e</mi><mi>n</mi><mi>d</mi><mi>e</mi><msup><mi>r</mi><mo mathvariant="normal" lspace="0em" rspace="0em">′</mo></msup><mo separator="true">;</mo><mo><</mo><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mi>c</mi><mi>l</mi><mi>a</mi><mi>s</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>k</mi><mi>a</mi><mi>t</mi><mi>e</mi><mi>x</mi><mi mathvariant="normal">"</mi><mo>></mo><mo><</mo><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mi>c</mi><mi>l</mi><mi>a</mi><mi>s</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>k</mi><mi>a</mi><mi>t</mi><mi>e</mi><mi>x</mi><mo>−</mo><mi>m</mi><mi>a</mi><mi>t</mi><mi>h</mi><mi>m</mi><mi>l</mi><mi mathvariant="normal">"</mi><mo>></mo><mo><</mo><mi>m</mi><mi>a</mi><mi>t</mi><mi>h</mi><mi>x</mi><mi>m</mi><mi>l</mi><mi>n</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>h</mi><mi>t</mi><mi>t</mi><mi>p</mi><mo>:</mo><mi mathvariant="normal">/</mi><mi mathvariant="normal">/</mi><mi>w</mi><mi>w</mi><mi>w</mi><mi mathvariant="normal">.</mi><mi>w</mi><mn>3.</mn><mi>o</mi><mi>r</mi><mi>g</mi><mi mathvariant="normal">/</mi><mn>1998</mn><mi mathvariant="normal">/</mi><mi>M</mi><mi>a</mi><mi>t</mi><mi>h</mi><mi mathvariant="normal">/</mi><mi>M</mi><mi>a</mi><mi>t</mi><mi>h</mi><mi>M</mi><mi>L</mi><mi mathvariant="normal">"</mi><mo>></mo><mo><</mo><mi>s</mi><mi>e</mi><mi>m</mi><mi>a</mi><mi>n</mi><mi>t</mi><mi>i</mi><mi>c</mi><mi>s</mi><mo>></mo><mo><</mo><mi>m</mi><mi>r</mi><mi>o</mi><mi>w</mi><mo>></mo><mo><</mo><mi>m</mi><mi>i</mi><mo>></mo><mi>s</mi><mo><</mo><mi mathvariant="normal">/</mi><mi>m</mi><mi>i</mi><mo>></mo><mo><</mo><mi>m</mi><mi>i</mi><mo>></mo><mi>t</mi><mo><</mo><mi mathvariant="normal">/</mi><mi>m</mi><mi>i</mi><mo>></mo><mo><</mo><mi>m</mi><mi>i</mi><mo>></mo><mi>m</mi><mo><</mo><mi mathvariant="normal">/</mi><mi>m</mi><mi>i</mi><mo>></mo><mo><</mo><mi>m</mi><mi>i</mi><mo>></mo><mi>t</mi><mo><</mo><mi mathvariant="normal">/</mi><mi>m</mi><mi>i</mi><mo>></mo><mo><</mo><mi>m</mi><mi>o</mi><mo>></mo><mo>=</mo><mo><</mo><mi mathvariant="normal">/</mi><mi>m</mi><mi>o</mi><mo>></mo><mo><</mo><mi mathvariant="normal">/</mi><mi>m</mi><mi>r</mi><mi>o</mi><mi>w</mi><mo>></mo><mo><</mo><mi>a</mi><mi>n</mi><mi>n</mi><mi>o</mi><mi>t</mi><mi>a</mi><mi>t</mi><mi>i</mi><mi>o</mi><mi>n</mi><mi>e</mi><mi>n</mi><mi>c</mi><mi>o</mi><mi>d</mi><mi>i</mi><mi>n</mi><mi>g</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>a</mi><mi>p</mi><mi>p</mi><mi>l</mi><mi>i</mi><mi>c</mi><mi>a</mi><mi>t</mi><mi>i</mi><mi>o</mi><mi>n</mi><mi mathvariant="normal">/</mi><mi>x</mi><mo>−</mo><mi>t</mi><mi>e</mi><mi>x</mi><mi mathvariant="normal">"</mi><mo>></mo><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>=</mo><mo><</mo><mi mathvariant="normal">/</mi><mi>a</mi><mi>n</mi><mi>n</mi><mi>o</mi><mi>t</mi><mi>a</mi><mi>t</mi><mi>i</mi><mi>o</mi><mi>n</mi><mo>></mo><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>e</mi><mi>m</mi><mi>a</mi><mi>n</mi><mi>t</mi><mi>i</mi><mi>c</mi><mi>s</mi><mo>></mo><mo><</mo><mi mathvariant="normal">/</mi><mi>m</mi><mi>a</mi><mi>t</mi><mi>h</mi><mo>></mo><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mo>></mo><mo><</mo><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mi>c</mi><mi>l</mi><mi>a</mi><mi>s</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>k</mi><mi>a</mi><mi>t</mi><mi>e</mi><mi>x</mi><mo>−</mo><mi>h</mi><mi>t</mi><mi>m</mi><mi>l</mi><mi mathvariant="normal">"</mi><mi>a</mi><mi>r</mi><mi>i</mi><mi>a</mi><mo>−</mo><mi>h</mi><mi>i</mi><mi>d</mi><mi>d</mi><mi>e</mi><mi>n</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>t</mi><mi>r</mi><mi>u</mi><mi>e</mi><mi mathvariant="normal">"</mi><mo>></mo><mo><</mo><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mi>c</mi><mi>l</mi><mi>a</mi><mi>s</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>b</mi><mi>a</mi><mi>s</mi><mi>e</mi><mi mathvariant="normal">"</mi><mo>></mo><mo><</mo><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mi>c</mi><mi>l</mi><mi>a</mi><mi>s</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>s</mi><mi>t</mi><mi>r</mi><mi>u</mi><mi>t</mi><mi mathvariant="normal">"</mi><mi>s</mi><mi>t</mi><mi>y</mi><mi>l</mi><mi>e</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>h</mi><mi>e</mi><mi>i</mi><mi>g</mi><mi>h</mi><mi>t</mi><mo>:</mo><mn>0.6151</mn><mi>e</mi><mi>m</mi><mo separator="true">;</mo><mi mathvariant="normal">"</mi><mo>></mo><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mo>></mo><mo><</mo><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mi>c</mi><mi>l</mi><mi>a</mi><mi>s</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>m</mi><mi>o</mi><mi>r</mi><mi>d</mi><mi>m</mi><mi>a</mi><mi>t</mi><mi>h</mi><mi>n</mi><mi>o</mi><mi>r</mi><mi>m</mi><mi>a</mi><mi>l</mi><mi mathvariant="normal">"</mi><mo>></mo><mi>s</mi><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mo>></mo><mo><</mo><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mi>c</mi><mi>l</mi><mi>a</mi><mi>s</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>m</mi><mi>o</mi><mi>r</mi><mi>d</mi><mi>m</mi><mi>a</mi><mi>t</mi><mi>h</mi><mi>n</mi><mi>o</mi><mi>r</mi><mi>m</mi><mi>a</mi><mi>l</mi><mi mathvariant="normal">"</mi><mo>></mo><mi>t</mi><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mo>></mo><mo><</mo><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mi>c</mi><mi>l</mi><mi>a</mi><mi>s</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>m</mi><mi>o</mi><mi>r</mi><mi>d</mi><mi>m</mi><mi>a</mi><mi>t</mi><mi>h</mi><mi>n</mi><mi>o</mi><mi>r</mi><mi>m</mi><mi>a</mi><mi>l</mi><mi mathvariant="normal">"</mi><mo>></mo><mi>m</mi><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mo>></mo><mo><</mo><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mi>c</mi><mi>l</mi><mi>a</mi><mi>s</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>m</mi><mi>o</mi><mi>r</mi><mi>d</mi><mi>m</mi><mi>a</mi><mi>t</mi><mi>h</mi><mi>n</mi><mi>o</mi><mi>r</mi><mi>m</mi><mi>a</mi><mi>l</mi><mi mathvariant="normal">"</mi><mo>></mo><mi>t</mi><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mo>></mo><mo><</mo><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mi>c</mi><mi>l</mi><mi>a</mi><mi>s</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>m</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>c</mi><mi>e</mi><mi mathvariant="normal">"</mi><mi>s</mi><mi>t</mi><mi>y</mi><mi>l</mi><mi>e</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>m</mi><mi>a</mi><mi>r</mi><mi>g</mi><mi>i</mi><mi>n</mi><mo>−</mo><mi>r</mi><mi>i</mi><mi>g</mi><mi>h</mi><mi>t</mi><mo>:</mo><mn>0.2778</mn><mi>e</mi><mi>m</mi><mo separator="true">;</mo><mi mathvariant="normal">"</mi><mo>></mo><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mo>></mo><mo><</mo><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mi>c</mi><mi>l</mi><mi>a</mi><mi>s</mi><mi>s</mi><mo>=</mo><mi mathvariant="normal">"</mi><mi>m</mi><mi>r</mi><mi>e</mi><mi>l</mi><mi mathvariant="normal">"</mi><mo>></mo><mo>=</mo><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mo>></mo><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mo>></mo><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mo>></mo><mo><</mo><mi mathvariant="normal">/</mi><mi>s</mi><mi>p</mi><mi>a</mi><mi>n</mi><mo>></mo><mi>c</mi><mi>o</mi><mi>n</mi><mi>n</mi><mo>−</mo><mo>></mo><mi>p</mi><mi>r</mi><mi>e</mi><mi>p</mi><mi>a</mi><mi>r</mi><mi>e</mi><mo stretchy="false">(</mo></mrow><annotation encoding="application/x-tex">sql = 'SELECT amount FROM accounts WHERE id=:sender'; <math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>=</mo></mrow><annotation encoding="application/x-tex">stmt = </annotation></semantics></math>stmt=conn->prepare(</annotation></semantics></math>sql=′SELECTamountFROMaccountsWHEREid=:sender′;<spanclass="katex"><spanclass="katex−mathml"><mathxmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>=</mo></mrow><annotationencoding="application/x−tex">stmt=</annotation></semantics></math></span><spanclass="katex−html"aria−hidden="true"><spanclass="base"><spanclass="strut"style="height:0.6151em;"></span><spanclass="mordmathnormal">s</span><spanclass="mordmathnormal">t</span><spanclass="mordmathnormal">m</span><spanclass="mordmathnormal">t</span><spanclass="mspace"style="margin−right:0.2778em;"></span><spanclass="mrel">=</span></span></span></span>conn−>prepare(sql); <math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>−</mo><mo>></mo><mi>e</mi><mi>x</mi><mi>e</mi><mi>c</mi><mi>u</mi><mi>t</mi><mi>e</mi><mo stretchy="false">(</mo><mo stretchy="false">[</mo><mi mathvariant="normal">"</mi><mo>:</mo><mi>s</mi><mi>e</mi><mi>n</mi><mi>d</mi><mi>e</mi><mi>r</mi><mi mathvariant="normal">"</mi><mo>=</mo><mo>></mo></mrow><annotation encoding="application/x-tex">stmt->execute([":sender" => </annotation></semantics></math>stmt−>execute([":sender"=>sender]); <math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>a</mi><mi>v</mi><mi>a</mi><mi>i</mi><mi>l</mi><mi>a</mi><mi>b</mi><mi>l</mi><mi>e</mi><mi>A</mi><mi>m</mi><mi>o</mi><mi>u</mi><mi>n</mi><mi>t</mi><mo>=</mo></mrow><annotation encoding="application/x-tex">availableAmount = </annotation></semantics></math>availableAmount=stmt->fetchColumn(); $stmt->closeCursor();Code language: PHP (php)

Fourth, issue an error if the available amount is less than the amount that will be transferred:

if ($availableAmount < $amount) { echo 'Insufficient amount to transfer'; return $conn->rollBack(); }Code language: PHP (php)

Fifth, deduct from the sender’s balance:

$sql_deduct = 'UPDATE accounts SET amount = amount - :amount WHERE id = :sender'; <math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>=</mo></mrow><annotation encoding="application/x-tex">stmt = </annotation></semantics></math>stmt=conn->prepare($sql_deduct); <math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>−</mo><mo>></mo><mi>e</mi><mi>x</mi><mi>e</mi><mi>c</mi><mi>u</mi><mi>t</mi><mi>e</mi><mo stretchy="false">(</mo><mo stretchy="false">[</mo><mi mathvariant="normal">"</mi><mo>:</mo><mi>s</mi><mi>e</mi><mi>n</mi><mi>d</mi><mi>e</mi><mi>r</mi><mi mathvariant="normal">"</mi><mo>=</mo><mo>></mo></mrow><annotation encoding="application/x-tex">stmt->execute([":sender" => </annotation></semantics></math>stmt−>execute([":sender"=>sender, ":amount" => $amount]); $stmt->closeCursor();Code language: PHP (php)

Sixth, add the amount to the receiver’s balance:

$sql_add = 'UPDATE accounts SET amount = amount + :amount WHERE id = :receiver'; <math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>=</mo></mrow><annotation encoding="application/x-tex">stmt = </annotation></semantics></math>stmt=conn->prepare($sql_add); <math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>s</mi><mi>t</mi><mi>m</mi><mi>t</mi><mo>−</mo><mo>></mo><mi>e</mi><mi>x</mi><mi>e</mi><mi>c</mi><mi>u</mi><mi>t</mi><mi>e</mi><mo stretchy="false">(</mo><mo stretchy="false">[</mo><mi mathvariant="normal">"</mi><mo>:</mo><mi>r</mi><mi>e</mi><mi>c</mi><mi>e</mi><mi>i</mi><mi>v</mi><mi>e</mi><mi>r</mi><mi mathvariant="normal">"</mi><mo>=</mo><mo>></mo></mrow><annotation encoding="application/x-tex">stmt->execute([":receiver" => </annotation></semantics></math>stmt−>execute([":receiver"=>receiver, ":amount" => $amount]);Code language: PHP (php)

Seventh, commit the transaction by calling the commit() method:

$conn->commit();Code language: PHP (php)

Eighth, roll back the transaction (in the catch block) if any error occurs:

$conn->rollBack();Code language: PHP (php)

Testing

First, connect to the database:

$conn = new PDO("mysql:host=$host;dbname=$dbname", <math xmlns="http://www.w3.org/1998/Math/MathML"><semantics><mrow><mi>u</mi><mi>s</mi><mi>e</mi><mi>r</mi><mi>n</mi><mi>a</mi><mi>m</mi><mi>e</mi><mo separator="true">,</mo></mrow><annotation encoding="application/x-tex">username, </annotation></semantics></math>username,password);Code language: PHP (php)

Second, transfer 30K from account 1 to account 2:

$obj->transfer(1, 2, 30000);Code language: PHP (php)

Error:

Insufficient amount to transfer

Third, make another transfer that transfers 5K from account 1 to account 2:

$obj->transfer(1, 2, 5000);Code language: PHP (php)

Output:

The amount has been transferred successfully.

Summary

Use the beginTransaction() method of the PDO object to start a transaction.
Call the commit() method of the PDO object to commit the changes made during the transaction to the database.
Call the rollback() method of the PDO object to roll back the changes made during the transaction.

Was this tutorial helpful?