Python实现跨数据库表不匹配记录插入功能故障求助

原代码中的核心问题： #

• 查询结果被浪费：执行fetch_table1 = table1.fetchall()后，游标已耗尽，list(table1)会得到空列表，导致mylist为空，对比逻辑完全失效。
• 函数未调用+递归错误：non_match_elements函数定义后从未被调用，且函数内部存在无意义的递归调用，会导致逻辑混乱甚至栈溢出。
• SQL语法错误：INSERT INTO table 1中的表名包含空格，SQL会识别为两个标识符，导致执行失败。
• 插入逻辑位置错误：executemany被放在循环内部，且每次匹配失败就触发递归，完全不符合批量插入的逻辑。
• 冗余变量处理：fetchall()返回的已经是列表，无需再用list()转换。

修正后的完整代码： #

import sqlite3

# 连接数据库并获取表数据
def get_table_data(db_path, table_name):
    con = sqlite3.connect(db_path)
    cur = con.cursor()
    cur.execute(f"SELECT * FROM {table_name}")
    data = cur.fetchall()
    con.close()
    return data

# 找出list2中有但list1中没有的记录
def find_non_matching(list1, list2):
    return [item for item in list2 if item not in list1]

# 插入缺失记录到目标数据库
def insert_missing_records(db_path, table_name, records):
    if not records:
        print("没有缺失记录需要插入")
        return
    con = sqlite3.connect(db_path)
    cur = con.cursor()
    # 根据表的实际字段数量动态生成占位符
    placeholders = ", ".join(["?"] * len(records[0]))
    cur.executemany(f"INSERT INTO {table_name} VALUES ({placeholders})", records)
    con.commit()
    con.close()
    print(f"成功插入{len(records)}条记录")

# 主逻辑
if __name__ == "__main__":
    # 获取两个表的数据
    table1_data = get_table_data("database1.db", "table1")
    table2_data = get_table_data("database2.db", "table2")

    # 找出table2中有但table1中没有的记录，插入到table1
    missing_in_table1 = find_non_matching(table1_data, table2_data)
    insert_missing_records("database1.db", "table1", missing_in_table1)

    # 验证结果
    con = sqlite3.connect("database1.db")
    cur = con.cursor()
    res = cur.execute("SELECT * FROM table1")
    print("当前table1的所有记录：")
    print(res.fetchall())
    con.close()

关键修正说明： #

1. 拆分功能函数：把数据获取、缺失记录查找、插入操作拆分为独立函数，代码更清晰易维护。
2. 正确处理查询结果：直接使用fetchall()返回的列表，避免游标耗尽导致空数据。
3. 修复SQL语法：移除表名中的空格，动态生成占位符适配不同字段数量的表。
4. 避免递归与错误逻辑：用列表推导式简洁查找缺失记录，批量插入放在所有记录收集完成后执行。
5. 资源管理：每次操作后关闭数据库连接，避免资源泄漏。

内容的提问来源于stack exchange，提问作者imnot200123