多地数据同步服务双11活动

import sqlite3
import hashlib

def get_last_sync_hash(db_path):
    conn = sqlite3.connect(db_path)
    cursor = conn.cursor()
    cursor.execute("SELECT hash FROM sync_info ORDER BY timestamp DESC LIMIT 1")
    result = cursor.fetchone()
    conn.close()
    return result[0] if result else None

def update_data(db_path, new_data):
    conn = sqlite3.connect(db_path)
    cursor = conn.cursor()
    cursor.execute("INSERT INTO data_table (content) VALUES (?)", (new_data,))
    conn.commit()
    conn.close()

def calculate_hash(data):
    return hashlib.sha256(data.encode()).hexdigest()

def sync_data(source_db, target_db):
    last_sync_hash = get_last_sync_hash(target_db)
    conn_source = sqlite3.connect(source_db)
    cursor_source = conn_source.cursor()
    cursor_source.execute("SELECT content FROM data_table WHERE hash > ?", (last_sync_hash,))
    new_data = cursor_source.fetchall()
    conn_source.close()

    for data in new_data:
        update_data(target_db, data[0])

# 示例调用
source_db = 'source.db'
target_db = 'target.db'
sync_data(source_db, target_db)