123456789101112 |
- import pandas as pd
- import psycopg2
- def queryGP(sql):
- ## 连接到一个给定的数据库
- conn = psycopg2.connect(dbname="cdpqa", user="cdpqa", password="Cdpqa@123456",port="5432", host="eip-greenplum-2.qa.mlamp.cn", client_encoding="UTF-8")
- df = pd.read_sql(sql, con=conn)
- ## 关闭数据库连接
- conn.close()
- return df
- df = queryGP("select * from pg_tables")
- print(df)
|