データフレームへの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() 

目標は、最終的にはCSVファイルにこのDFを格納することです。次に、クエリを実行して、CSVファイルにその列を追加する必要があります。助けてください。

Answer 1

I 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を使用し、それに列のリストを渡すことができます。テーブルを読み込む方が便利だと思われます。

Answer 2

解決しました。まだCSVに保存する方法やそのCSVに追加する方法はわかりません。

con={'drivername':'mssql+pymssql','host': 'host-name', 'port': number,  'database': 'databasename','username':'username','password':'asdf'} 
db_uri = URL(**database_dict) 
engine = create_engine(db_uri) 
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)