import pymssql import pandas as pd def execuete_sql(conn, sqlstr) -> pd.DataFrame: try: cursor = conn.cursor() cursor.execute(sqlstr) df = pd.DataFrame(cursor.fetchall()) return df except Exception as e: print(e) conn.close() def get_connection(host, user, pwd, db): conn = pymssql.connect(host, user, pwd, db) if conn: print(db, '连接成功') return conn a = get_connection('127.0.0.1', 'sa', '1a2b3c4D', 'HYCX.Noise.ShunDe') b = execuete_sql(a, 'SELECT Id, Name FROM [HYCX.Noise.ShunDe].[dbo].[T_Road]') print('ok') 这段代码执行后是不是将查询的sql数据写入df中?我要怎么打印这个df数据
时间: 2024-04-14 19:29:33 浏览: 154
PyPI 官网下载 | pd_sql_loader-1.0.tar.gz
是的,这段代码执行后会将查询的SQL数据写入DataFrame `df`中。你可以使用`print(b)`来打印DataFrame的内容,因为在`execuete_sql`函数中,查询结果被赋值给了变量`b`。
以下是修改后的代码示例:
```python
import pymssql
import pandas as pd
def execuete_sql(conn, sqlstr) -> pd.DataFrame:
try:
cursor = conn.cursor()
cursor.execute(sqlstr)
df = pd.DataFrame(cursor.fetchall())
return df
except Exception as e:
print(e)
conn.close()
def get_connection(host, user, pwd, db):
conn = pymssql.connect(host, user, pwd, db)
if conn:
print(db, '连接成功')
return conn
a = get_connection('127.0.0.1', 'sa', '1a2b3c4D', 'HYCX.Noise.ShunDe')
b = execuete_sql(a, 'SELECT Id, Name FROM [HYCX.Noise.ShunDe].[dbo].[T_Road]')
print(b) # 打印DataFrame的内容
```
在上述代码中,我们通过`print(b)`来打印DataFrame `b`的内容,即查询结果。你可以根据需要对DataFrame进行进一步处理或输出。
阅读全文