В системах баз данных распространение транзакций означает процесс передачи транзакционных изменений от одного соединения с базой данных к другому. Это позволяет нескольким транзакциям работать вместе, обеспечивая целостность и согласованность данных. В этой статье мы подробно рассмотрим концепцию распространения транзакций и обсудим различные методы, используемые для ее достижения, а также примеры кода.

Методы распространения транзакций:

1. Неявное распространение транзакций:

   • Описание. Неявное распространение транзакции происходит, когда транзакция автоматически распространяется от одного подключения к базе данных к другому в том же потоке или процессе.

   • Пример кода (Java – JDBC):

     Connection connection1 = DriverManager.getConnection("jdbc:database1");
     Connection connection2 = DriverManager.getConnection("jdbc:database2");
     
     // Enable implicit transaction propagation
     connection1.setAutoCommit(false);
     connection2.setAutoCommit(false);
     
     // Execute queries and updates within a transaction
     connection1.prepareStatement("UPDATE table1 SET column1 = 'value'").executeUpdate();
     connection2.prepareStatement("INSERT INTO table2 (column1) VALUES ('value')").executeUpdate();
     
     // Commit the changes
     connection1.commit();
     connection2.commit();

2. Явное распространение транзакций:

   • Описание. Явное распространение транзакций предполагает ручной запуск и управление транзакциями между несколькими подключениями к базе данных.

   • Пример кода (C# – ADO.NET):

     using (var connection1 = new SqlConnection("connectionString1"))
     using (var connection2 = new SqlConnection("connectionString2"))
     {
      connection1.Open();
      connection2.Open();
     
      // Start explicit transactions
      SqlTransaction transaction1 = connection1.BeginTransaction();
      SqlTransaction transaction2 = connection2.BeginTransaction();
     
      try
      {
          // Execute queries and updates within transactions
          SqlCommand command1 = connection1.CreateCommand();
          command1.CommandText = "UPDATE table1 SET column1 = 'value'";
          command1.Transaction = transaction1;
          command1.ExecuteNonQuery();
     
          SqlCommand command2 = connection2.CreateCommand();
          command2.CommandText = "INSERT INTO table2 (column1) VALUES ('value')";
          command2.Transaction = transaction2;
          command2.ExecuteNonQuery();
     
          // Commit the changes
          transaction1.Commit();
          transaction2.Commit();
      }
      catch (Exception)
      {
          // Rollback the changes if an error occurs
          transaction1.Rollback();
          transaction2.Rollback();
          throw;
      }
     }

3. Распространение распределенных транзакций:

   • Описание. Распределенное распространение транзакций используется, когда транзакции охватывают несколько систем баз данных или узлов.

   • Пример кода (Python – SQLAlchemy):

     from sqlalchemy import create_engine
     from sqlalchemy.orm import sessionmaker
     
     # Create engine and session for database1
     engine1 = create_engine("database1_connection_string")
     Session1 = sessionmaker(bind=engine1)
     
     # Create engine and session for database2
     engine2 = create_engine("database2_connection_string")
     Session2 = sessionmaker(bind=engine2)
     
     # Start a distributed transaction
     session1 = Session1()
     session2 = Session2()
     session1.begin()
     session2.begin()
     
     try:
      # Execute queries and updates across databases within the transaction
      session1.execute("UPDATE table1 SET column1 = 'value'")
      session2.execute("INSERT INTO table2 (column1) VALUES ('value')")
     
      # Commit the changes
      session1.commit()
      session2.commit()
     except Exception:
      # Rollback the changes if an error occurs
      session1.rollback()
      session2.rollback()
      raise
     finally:
      # Close the sessions
      session1.close()
      session2.close()