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)