# 数据库连接参数
conn = psycopg2.connect(database=database, user=user,password=password, host=host, port=port)
cur = conn.cursor()
cur.execute("SELECT  * from user where sex=\"男\" ;")
rows = cur.fetchall()        # all rows in table
# 将查询到的结果放入dataframe
df = pd.DataFrame(rows, columns=['ID','name','sex','phone'])

 

扫码关注我们
微信号：SRE实战
拒绝背锅 运筹帷幄

SRE实战 互联网时代守护先锋，助力企业售后服务体系运筹帷幄！一键直达领取阿里云限量特价优惠。