Trả về dữ liệu Pandas từ truy vấn PostgreSQL với sqlalchemy

Question

Tôi muốn truy vấn cơ sở dữ liệu PostgreSQL và trả về kết xuất dưới dạng một khung dữ liệu Pandas.

tôi sử dụng sqlalchemy để tạo ra một kết nối các cơ sở dữ liệu:

from sqlalchemy import create_engine 
engine = create_engine('postgresql://user@localhost:5432/mydb') 

tôi viết một dataframe Pandas vào một bảng cơ sở dữ liệu:

i=pd.read_csv(path) 
i.to_sql('Stat_Table',engine,if_exists='replace') 

Dựa trên docs, trông giống như pd.read_sql_query () nên chấp nhận công cụ SQLAlchemy:

a=pd.read_sql_query('select * from Stat_Table',con=engine) 

Nhưng nó t có lỗi:

ProgrammingError: (ProgrammingError) relation "stat_table" does not exist 

Tôi đang sử dụng phiên bản Pandas 0.14.1.

Cách thích hợp để thực hiện việc này là gì?

Answer 1

Bạn bị các vấn đề về độ nhạy (in) nhạy cảm với PostgreSQL. Nếu bạn trích dẫn tên bảng trong truy vấn, nó sẽ làm việc:

df = pd.read_sql_query('select * from "Stat_Table"',con=engine) 

Nhưng cá nhân tôi, tôi sẽ tư vấn để chỉ luôn luôn sử dụng tên bảng chữ thường (và tên cột), cũng có khi viết bảng để các cơ sở dữ liệu ngăn chặn các vấn đề như vậy.

---

Từ các tài liệu PostgreSQL (http://www.postgresql.org/docs/8.0/static/sql-syntax.html#SQL-SYNTAX-IDENTIFIERS):

Quoting an identifier also makes it case-sensitive, whereas unquoted names are always folded to lower case

Để giải thích thêm một chút: bạn đã viết một bảng với tên Stat_Table cơ sở dữ liệu (và SQLAlchemy sẽ báo tên này, vì vậy nó sẽ được viết là "Stat_Table" trong cơ sở dữ liệu postgres). Khi thực hiện truy vấn 'select * from Stat_Table' tên bảng không được bỏ phiếu sẽ được chuyển đổi thành chữ thường stat_table và vì vậy bạn sẽ nhận được thông báo rằng bảng này không được tìm thấy.

Xem ví dụ: Are PostgreSQL column names case-sensitive?

Answer 2

Các thông báo lỗi được nói với bạn rằng một bảng tên là:

stat_table 

không tồn tại (một quan là một bảng trong postgres nói). Vì vậy, tất nhiên bạn không thể chọn các hàng từ nó. Kiểm tra db của bạn sau khi thực hiện:

i.to_sql('Stat_Table',engine,if_exists='replace') 

và xem bảng có tên đó được tạo trong db của bạn không.

Khi tôi sử dụng tuyên bố đọc của bạn:

df = pd.read_sql_query('select * from Stat_Table',con=engine) 

tôi nhận được dữ liệu trở lại từ một postgres db, vì vậy không có gì sai với nó.