如何在Python中处理多行SQL查询？(子查询作为变量)

import pymysql

# 连接数据库
conn = pymysql.connect(host='localhost', user='root', password='password', db='database')
cursor = conn.cursor()

# 定义子查询语句
subquery = '''
SELECT column1, column2
FROM table1
WHERE condition
'''

# 构建多行SQL查询语句
sql = '''
SELECT *
FROM table2
WHERE column3 IN ({subquery})
'''.format(subquery=subquery)

# 执行查询
cursor.execute(sql)

# 获取结果
results = cursor.fetchall()

# 处理结果
for row in results:
    # 处理每一行数据

# 关闭数据库连接
cursor.close()
conn.close()

from sqlalchemy import create_engine, text

# 创建数据库引擎
engine = create_engine('mysql+pymysql://root:password@localhost/database')

# 定义子查询语句
subquery = '''
SELECT column1, column2
FROM table1
WHERE condition
'''

# 构建多行SQL查询语句
sql = '''
SELECT *
FROM table2
WHERE column3 IN ({subquery})
'''.format(subquery=subquery)

# 执行查询
results = engine.execute(text(sql))

# 处理结果
for row in results:
    # 处理每一行数据