python - 对数据框的 SQL 查询

Question

学习如何使用数据框。我做错了什么？

我的尝试:

import pyodbc
import pandas as pd
from pandas import read_csv
from sqlalchemy import create_engine
from sqlalchemy.engine.url import URL
import time
import csv
import sys

Class Query(object):
  def do_something(self):
     con={'drivername':'mssql+pymssql','host': 'host-name', 'port': number, 'database': 'databasename','username':'username','password':'asdf'}

     query = """ select column1 from schema.table1 """

     df=pd.read_sql_query('parse',con,index_col=None,coerce_float=True,params=None,parse_dates=None,chunksize=None)

x=Query()
x.do_something()

目标是最终将此 df 存储到 CSV 文件中。然后，我需要运行查询

query = """ select column2 from schema.table2 """ 

并将该列附加到 CSV 文件中。请帮忙。

Answer 1

我used这段代码:

from sqlalchemy import create_engine
import psycopg2
mydb = create_engine('postgresql://user@host.domain:5432/database')
df = pd.read_sql_query('''SELECT sections, ...''', con=mydb)
print(df) 

您也可以使用pd.read_sql_table并向其传递一个列列表。看起来加载表格更方便。