green_plum.py 428 B

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