pyodbc/sqlalchemy -使用pd.read_sql_query读取表中的每一列。通过查询传递变量

import pyodbc
from sqlalchemy import create_engine
import pandas as pd

# 使用pyodbc建立数据库连接
conn = pyodbc.connect('DRIVER={ODBC Driver};SERVER=服务器地址;DATABASE=数据库名;UID=用户名;PWD=密码')

# 使用sqlalchemy建立数据库连接
engine = create_engine('数据库类型+数据库驱动://用户名:密码@服务器地址:端口号/数据库名')

# 假设要查询的表名为"table_name"，要传递的变量为"variable"
sql_query = f"SELECT * FROM table_name WHERE column_name = '{variable}'"

# 使用pyodbc执行查询并获取结果
cursor = conn.cursor()
cursor.execute(sql_query)
result = cursor.fetchall()

# 使用sqlalchemy执行查询并获取结果
result = engine.execute(sql_query)

# 将结果转换为DataFrame
df = pd.DataFrame(result.fetchall(), columns=result.keys())