green_plum.py 398 B

123456789101112
  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", host="eip-greenplum-2.qa.mlamp.cn", client_encoding="UTF-8")
  6. df = pd.read_sql(sql, con=conn)
  7. ## 关闭数据库连接
  8. conn.close()
  9. return df
  10. df = queryGP("select * from pg_tables")
  11. print(df)