数据库同步首购活动

import psycopg2
from psycopg2 import sql

def sync_data(source_conn_str, dest_conn_str):
    try:
        # 连接源数据库
        source_conn = psycopg2.connect(source_conn_str)
        source_cursor = source_conn.cursor()
        
        # 连接目标数据库
        dest_conn = psycopg2.connect(dest_conn_str)
        dest_cursor = dest_conn.cursor()
        
        # 查询源数据库中的最新数据
        source_cursor.execute("SELECT * FROM orders WHERE status = 'pending'")
        orders = source_cursor.fetchall()
        
        # 将数据插入目标数据库
        for order in orders:
            dest_cursor.execute(
                sql.SQL("INSERT INTO orders (id, user_id, product_id, status) VALUES {}").format(
                    sql.Placeholder() * len(order)
                ), order
            )
        
        # 提交事务
        dest_conn.commit()
        
    except Exception as e:
        print(f"Error during sync: {e}")
        dest_conn.rollback()
        
    finally:
        source_cursor.close()
        source_conn.close()
        dest_cursor.close()
        dest_conn.close()

# 使用示例
source_conn_str = "your_source_db_connection_string"
dest_conn_str = "your_destination_db_connection_string"
sync_data(source_conn_str, dest_conn_str)