17.5 Manejo de Transacciones en Python

¡Claro! Aquí tienes una explicación sobre cómo manejar transacciones en Python.

Las transacciones de base de datos proporcionan una manera de procesar un conjunto de operaciones de base de datos en una sola unidad. Si todas las operaciones son exitosas, los cambios se confirman en la base de datos. Si alguna operación falla, ninguno de los cambios se aplica.

En una transacción, si un grupo de operaciones interdependientes son parte de una transacción, o todas las operaciones se ejecutan o ninguna. Esta propiedad de las transacciones a menudo se resume como ACID (Atomicidad, Consistencia, Aislamiento y Durabilidad).

La DB-API de Python proporciona una forma de manejar transacciones. Después de iniciar una transacción, puedes commitirla si no se encuentran errores. Si hay algún error, puedes revertir la transacción al estado antes de que se iniciara la transacción.

Ejemplo:

import sqlite3

try:
    # connect to the database
    conn = sqlite3.connect('test.db')

    # create a cursor
    cur = conn.cursor()

    # start a transaction
    cur.execute("BEGIN TRANSACTION")

    # execute some SQL queries
    cur.execute("INSERT INTO COMPANY (ID, NAME, AGE, ADDRESS, SALARY) \\
          VALUES (1, 'Paul', 32, 'California', 20000.00)")
    cur.execute("INSERT INTO COMPANY (ID, NAME, AGE, ADDRESS, SALARY) \\
          VALUES (2, 'Allen', 25, 'Texas', 15000.00)")

    # commit the transaction
    conn.commit()

    print("Records inserted successfully")

except sqlite3.Error as error:
    # rollback the transaction in case of error
    conn.rollback()
    print("Failed to insert data into sqlite table", error)

finally:
    # close the connection
    if conn:
        conn.close()
        print("the sqlite connection is closed")

En este código:

Primero nos conectamos a la base de datos usando sqlite3.connect() y creamos un objeto de cursor.
Iniciamos una transacción con cur.execute("BEGIN TRANSACTION").
Ejecutamos algunas consultas SQL para insertar datos en la tabla COMPANY.
Si todas las operaciones son exitosas, confirmamos la transacción usando conn.commit().
Si ocurre algún error durante cualquier operación, revertimos la transacción usando conn.rollback(). Esto asegura que nuestra base de datos permanezca en un estado consistente.
Al final, cerramos la conexión de la base de datos usando conn.close().

Recuerda, es importante manejar las excepciones cuando trabajas con transacciones para asegurarte de que un error en una sola operación no deje tu base de datos en un estado inconsistente.

Este enfoque de manejo de transacciones es común en otras bases de datos como MySQL y PostgreSQL con ligeras modificaciones dependiendo de los métodos específicos del controlador de la base de datos.

Ahora, aunque ya hemos cubierto el manejo de transacciones manualmente en Python, vale la pena mencionar que la DB-API de Python también admite un modelo de transacción simplificado para aquellos que solo ejecutan comandos individuales.

Por defecto, el módulo sqlite3 abre una transacción automáticamente antes de cualquier operación que modifique datos (como INSERT, UPDATE, DELETE, etc.), y confirma las transacciones automáticamente cuando se ejecuta el cursor.

Sin embargo, si estás ejecutando más de un comando como parte de una transacción, generalmente es una buena idea gestionar las transacciones manualmente como se muestra en el ejemplo anterior, ya que te brinda un control más fino sobre cuándo se confirma o revierte una transacción.

Además, mientras que SQLite y PostgreSQL siguen el estándar SQL para transacciones (BEGIN TRANSACTION, COMMIT y ROLLBACK), MySQL usa comandos ligeramente diferentes. En lugar de "BEGIN TRANSACTION", usarías "START TRANSACTION" en MySQL.

Aquí tienes un ejemplo de cómo manejar transacciones en Python con MySQL usando el módulo mysql-connector-python:

import mysql.connector
from mysql.connector import Error

try:
    # connect to the MySQL server
    conn = mysql.connector.connect(user='username', password='password',
                                   host='127.0.0.1', database='testdb')

    # create a new cursor
    cur = conn.cursor()

    # start a new transaction
    cur.execute("START TRANSACTION")

    # execute some SQL queries
    cur.execute("INSERT INTO employees (id, name, salary) VALUES (1, 'John Doe', 70000)")
    cur.execute("INSERT INTO employees (id, name, salary) VALUES (2, 'Jane Doe', 80000)")

    # commit the transaction
    conn.commit()

    print("Data inserted successfully")

except Error as error:
    # rollback the transaction in case of error
    conn.rollback()
    print("Failed to insert data into MySQL table", error)

finally:
    # close the connection
    if conn:
        conn.close()
        print("MySQL connection is closed")

Este ejemplo es similar al de SQLite, pero con la notable diferencia de usar "START TRANSACTION" para iniciar una transacción en MySQL.

En general, el principio de gestión de transacciones sigue siendo el mismo en diferentes bases de datos SQL, aunque los comandos y métodos específicos pueden diferir ligeramente. Es importante consultar la documentación de tu base de datos específica y del controlador de la base de datos cuando trabajes con transacciones en Python.