Python使用psycopg2库来连接redshift

import psycopg2

在连接前，先要进行下面这些配置

Port = '端口'
DbUser = '用户名'
DbName='数据库名'
Password = '密码'
Host = '数据库host名'

常见操作 A: 更新数据库表

#设置连接和游标
con = psycopg2.connect(dbname= DbName, host=Host, 
                       port= Port, user= DbUser, password= Password)
cur = con.cursor()

#跑SQL
query = 'INSERT INTO ...;'
cur.execute(query)

# commit掉事物
con.commit()

#close掉，防止因为排它锁导致无法后续操作
cur.close()
con.close()

常见操作 B: 查询数据库表

#设置连接和游标
con=psycopg2.connect(dbname= DbName, host=Host, 
             port= Port, user= DbUser, password= Password)
cur = con.cursor()

#跑SQL
query = """SELECT ...;"""
cur.execute(query)

#得到搜索值
res = cur.fetchall()

#close掉
cur.close()
con.close()

#输出值
print(res)