Pandas 数据框架和 SQL 查询连接

Question

我有一个以 ID 作为主键的 pandas 数据框，我想将其与 SQL 查询连接起来。 SQL数据库太大了，我不能先执行SELECT *然后join，它会崩溃。 示例：pandas 数据框 df 包含列名 ID，它包含 id1abc、id2abc、id3abc 等值。 SQL数据库WORK.EMP_TABLE包含列ID，其值为id1abc、id2abc、id3abc等，多达数十亿。我如何编写 SQL 查询代码或类似代码以从 SQL 表中仅获取 pandas 数据框的匹配记录。

Answer 1

将 pandas 导入为 pd

假设您有一个到数据库的连接对象（

engine

）

df.to_sql('temp_df',engine,index=False,if_exists='replace')

sql_query = """ 选择 df. 等 来自 temp_df df INNER JOIN WORK.EMP_TABLE et ON df.ID = et.ID; ”“”

result_df = pd.read_sql(sql_query, 引擎) engine.execute("DROP TABLE temp_df") # 清理临时表