psycopg2.connect(
    dsn         #指定連接參數(shù)?？梢允褂脜?shù)形式或 DSN 形式指定。
    host        #指定連接數(shù)據(jù)庫的主機名。
    dbname      #指定數(shù)據(jù)庫名。
    user        #指定連接數(shù)據(jù)庫使用的用戶名。
    password    #指定連接數(shù)據(jù)庫使用的密碼。
    port        #指定連接數(shù)據(jù)庫的端口號。
    connection_factory  #指定創(chuàng)建連接對象的工廠類。
    cursor_factory      #指定創(chuàng)建游標對象的工廠類。
    async_      #指定是否異步連接(默認False)。
    sslmode     #指定 SSL 模式。
    sslrootcert #指定證書文件名。
    sslkey      #指定私鑰文件名。
    sslcert     #指定公鑰文件名。
)

import psycopg2
# 連接數(shù)據(jù)庫
conn_pg = psycopg2.connect("host=localhost dbname=test user=postgres password=123456 port=5432")
# 創(chuàng)建一個游標
cur = conn_pg.cursor()
# 執(zhí)行SQL語句
cur.execute("select * from t1 limit 10;")
# 獲取返回的結(jié)果
rows = cur.fetchall()
# 遍歷每行結(jié)果(也可以直接打印，輸出格式為列表)
for i in rows:
    print(i)
# 關(guān)閉游標
cur.close()
# 關(guān)閉連接
conn_pg.close()

import psycopg2
# 編寫要執(zhí)行的SQL語句
sql_statements = """
    SELECT * FROM t1 WHERE c1 = 1;
    UPDATE t1 SET c2 = 'yt' WHERE c1 = 1;
    SELECT * FROM t1 WHERE c1 = 1;
"""
# 連接數(shù)據(jù)庫
with  psycopg2.connect("host=localhost dbname=test user=postgres password=123456 port=5432") as conn_pg:
    with conn_pg.cursor() as cur:
        # 執(zhí)行SQL語句
        cur.execute(sql_statements)
        # 獲取返回的結(jié)果
        rows = cur.fetchall()
        # 輸出結(jié)果
        print(rows)
        # 提交事務
        conn_pg.commit()

#!/usr/bin/python
import psycopg2
# 連接數(shù)據(jù)庫
with  psycopg2.connect("host=localhost dbname=test user=postgres password=123456 port=5432") as conn_pg:
    with conn_pg.cursor() as cur:
        try:
            cur.execute("BEGIN") #開始事務
            cur.execute("INSERT INTO t1 VALUES (1, 'abc');")
            cur.execute("UPDATE t1 SET c2 = 'def' WHERE c1 = 1;")
            conn_pg.commit()     #提交事務
        except:
            conn.rollback()      #回滾事務