postgresql并发事务

以下是一个使用PostgreSQL并发事务的示例代码：

import psycopg2
from psycopg2 import Error
from concurrent.futures import ThreadPoolExecutor

def execute_transaction(transaction_id):
    try:
        # 连接到PostgreSQL数据库
        connection = psycopg2.connect(user="your_username",
                                      password="your_password",
                                      host="your_host",
                                      port="your_port",
                                      database="your_database")
        
        # 创建一个游标对象
        cursor = connection.cursor()
        
        # 开始事务
        cursor.execute("BEGIN")
        
        # 执行事务操作
        cursor.execute(f"INSERT INTO your_table (transaction_id) VALUES ({transaction_id});")
        
        # 提交事务
        connection.commit()
        
        # 关闭游标和连接
        cursor.close()
        connection.close()
        
        print(f"事务 {transaction_id} 执行成功")
        
    except (Exception, Error) as error:
        print(f"事务 {transaction_id} 执行失败: {error}")

# 创建一个线程池执行器
executor = ThreadPoolExecutor(max_workers=5)

# 提交并发事务
for i in range(1, 6):
    executor.submit(execute_transaction, i)

# 等待所有事务执行完成
executor.shutdown(wait=True)

在上面的代码中，我们使用了psycopg2库来连接和操作PostgreSQL数据库。我们创建了一个execute_transaction函数来执行并发事务操作。在该函数中，我们首先连接到数据库，然后开始事务，执行事务操作，最后提交事务并关闭连接。我们使用ThreadPoolExecutor来创建一个具有5个线程的线程池执行器，并使用executor.submit方法来提交并发事务。最后，我们使用executor.shutdown(wait=True)来等待所有事务执行完成。