Python从sql查询结果创建数据框

Question

我有多个临时表创建和一个最终选择语句的 sql 查询。

让我们想象一下查询示例：

select 
        t1.Variable11,
        t1.Variable12,
        t2.Variable13
    into #R1
    from t1
    join t2
    on t1.Key1= t2.key1 and t1.Key2= t2.key2
    where t1.Variable1 > 100

select 
        t3.Variable21,
        t3.Variable22,
        t4.Variable23
    into #R2
    from t3
    join t4
    on t3.Key1= t4.key1 and t3.Key2= t4.key2
    where t3.Variable1 > 200


select 
        #R1.*,
        #R2.*
    from #R1
    join #R2
    on #R1.Variable11= #R2.Variable21

我使用 pyodbc 连接器连接到 sql server：

connection = pyodbc.connect(driver='{SQL Server Native Client 11.0}', server=server_name,
                            database=db_name, trusted_connection='yes', MARS_Connection='yes')

我不想重写代码。 我只想编写将返回熊猫数据框的函数。 当我尝试使用pandas.read_sql() 函数时，我收到错误：

TypeError: 'NoneType' 对象不可迭代

当我尝试使用pyodbs.execute() 时收到错误：

没有结果。以前的 SQL 不是查询。

如何处理创建多个临时表和一个最终选择语句的 sql 脚本？

Answer 1

import pandas as pd
from sqlalchemy import *
engine = create_engine('mssql+pyodbc://python:python@Database/Tablename?driver=SQL+Server+Native+Client+11.0')
connection = engine.connect()
SQL='select * from ' + Tablename
Tfrom_sql=pd.read_sql(SQL, connection)
connection.close()