在pandas数据框上逐行循环SQL查询

import pandas as pd
import sqlite3

# 创建一个示例数据框
data = {'id': [1, 2, 3, 4, 5],
        'name': ['Alice', 'Bob', 'Charlie', 'Dave', 'Eve']}
df = pd.DataFrame(data)

# 建立与数据库的连接
conn = sqlite3.connect(':memory:')
cursor = conn.cursor()

# 在数据库中创建表格
cursor.execute('''CREATE TABLE employees
                  (id INT PRIMARY KEY NOT NULL,
                   name TEXT NOT NULL);''')

# 将数据框中的数据插入到数据库表格中
for index, row in df.iterrows():
    cursor.execute("INSERT INTO employees (id, name) VALUES (?, ?)",
                   (row['id'], row['name']))

# 提交事务并关闭连接
conn.commit()
conn.close()

# 建立与数据库的连接
conn = sqlite3.connect(':memory:')
cursor = conn.cursor()

# 执行逐行循环SQL查询
results = []
for index, row in df.iterrows():
    cursor.execute("SELECT * FROM employees WHERE id = ?", (row['id'],))
    result = cursor.fetchall()
    results.append(result)

# 关闭连接
conn.close()