云服务器本地数据库同步

import psycopg2
from psycopg2 import sql

# 本地数据库连接配置
local_conn = psycopg2.connect(
    host="localhost",
    database="local_db",
    user="local_user",
    password="local_password"
)

# 云端数据库连接配置
cloud_conn = psycopg2.connect(
    host="your_cloud_host",
    database="cloud_db",
    user="cloud_user",
    password="cloud_password"
)

def sync_data(table_name):
    with local_conn.cursor() as local_cur, cloud_conn.cursor() as cloud_cur:
        # 获取本地数据
        local_cur.execute(sql.SQL("SELECT * FROM {}").format(sql.Identifier(table_name)))
        local_data = local_cur.fetchall()

        # 删除云端旧数据
        cloud_cur.execute(sql.SQL("DELETE FROM {}").format(sql.Identifier(table_name)))

        # 插入新数据
        for row in local_data:
            cloud_cur.execute(
                sql.SQL("INSERT INTO {} VALUES ({})").format(
                    sql.Identifier(table_name),
                    sql.SQL(', ').join(sql.Placeholder() * len(row))
                ),
                row
            )

        # 提交事务
        cloud_conn.commit()

# 同步指定表的数据
sync_data("your_table_name")

# 关闭连接
local_conn.close()
cloud_conn.close()