sqlalchemy を使って PostgreSQL のクエリから Pandas のデータフレームを返す
質問
PostgreSQLのデータベースに問い合わせを行い、その出力をPandasのデータフレームとして返したいのですが、可能でしょうか?
SqlAlchemy'でデータベースへの接続を作成しました。
from sqlalchemy import create_engine
engine = create_engine('postgresql://user@localhost:5432/mydb')
Pandasのdataframeをデータベースのテーブルに書き込んでいます。
i=pd.read_csv(path)
i.to_sql('Stat_Table',engine,if_exists='replace')
をベースに docs を見ると、pd.read_sql_query() は SQLAlchemy エンジンを受け入れるべきのようです。
a=pd.read_sql_query('select * from Stat_Table',con=engine)
しかし、それはエラーを投げます。
ProgrammingError: (ProgrammingError) relation "stat_table" does not exist
Pandasのバージョン0.14.1を使っています。
どのような方法が正しいのでしょうか?
どのように解決するのですか?
PostgreSQL の大文字と小文字の区別の問題に悩まされています。クエリの中でテーブル名を引用すれば、動作します。
df = pd.read_sql_query('select * from "Stat_Table"',con=engine)
しかし個人的には、このような問題を防ぐために、データベースにテーブルを書き込む際にも、常に小文字のテーブル名(およびカラム名)を使用することをお勧めします。
PostgreSQLのドキュメントから ( http://www.postgresql.org/docs/8.0/static/sql-syntax.html#SQL-SYNTAX-IDENTIFIERS ):
識別子をクォートすると、大文字と小文字が区別されます。
もう少し説明すると、テーブルの名前を
Stat_Table
という名前のテーブルをデータベースに書きました (そして sqlalchemy はこの名前を引用するので、postgres データベースでは "Stat_Table" と書かれることになります)。クエリを実行するとき
'select * from Stat_Table'
というクエリを実行すると、引用符で囲まれていないテーブル名は小文字に変換されます。
stat_table
に変換されるため、このテーブルが見つからないというメッセージが表示されます。
例えば、次のようなものもあります。 PostgreSQL の列名は大文字と小文字を区別しますか?
関連
-
[解決済み] PandasでDataFrameの行を反復処理する方法
-
[解決済み] 列の値に基づいてDataFrameから行を選択するにはどうすればよいですか?
-
[解決済み] PostgreSQL コマンドラインユーティリティ: psql を終了する方法
-
[解決済み] Pandas DataFrameからカラムを削除する
-
[解決済み] Pandasのデータフレームで複数の列を選択する
-
[解決済み] Pandas DataFrameの行数を取得する方法は?
-
[解決済み] 一行ずつ追加してPandas Dataframeを作成する
-
[解決済み] Pandasのデータフレームから行を選択するために値のリストを使用する
-
[解決済み] Pandasシリーズ/DataFrame全体をプリティプリントする
-
[解決済み】Pandas DataFrameのカラムヘッダからリストを取得する。
最新
-
nginxです。[emerg] 0.0.0.0:80 への bind() に失敗しました (98: アドレスは既に使用中です)
-
htmlページでギリシャ文字を使うには
-
ピュアhtml+cssでの要素読み込み効果
-
純粋なhtml + cssで五輪を実現するサンプルコード
-
ナビゲーションバー・ドロップダウンメニューのHTML+CSSサンプルコード
-
タイピング効果を実現するピュアhtml+css
-
htmlの選択ボックスのプレースホルダー作成に関する質問
-
html css3 伸縮しない 画像表示効果
-
トップナビゲーションバーメニュー作成用HTML+CSS
-
html+css 実装 サイバーパンク風ボタン
おすすめ
-
[解決済み】PostgreSQLのカラム名は大文字・小文字を区別する?
-
[解決済み] Pythonのマルチプロセッシングプールimap_unorderedの呼び出しの進捗を表示しますか?
-
[解決済み] Pythonでコード行間にかかる時間を測定するには?
-
[解決済み] python-requests モジュールからのすべてのリクエストをログに記録します。
-
[解決済み] Flask でグローバル変数はスレッドセーフか?リクエスト間でデータを共有するには?
-
[解決済み] Pythonによる一対のクロスプロダクト [重複] (英語)
-
[解決済み] virtualenv の `--no-site-packages` オプションを元に戻す。
-
[解決済み] Python 言語を決定するには?
-
[解決済み] virtualenvsはどこに作成するのですか?
-
[解決済み] Django filter queryset __in for *every* item in list