pip install psycopg2 -i https://pypi.tuna.tsinghua.edu.cn/simple

[postgresql]
host = [ip地址]
port = 5432
database = xxx
user = xxx
password = xxx

# 導(dǎo)入 psycopg2 模塊和 Error 對象
import psycopg2
from psycopg2 import DatabaseError
from configparser import ConfigParser
def read_db_config(filename='dbconfig.ini', section='postgresql'):
    """ 讀取數(shù)據(jù)庫配置文件，返回一個字典對象"""
    # 創(chuàng)建解析器，讀取配置文件
    parser = ConfigParser()
    parser.read(filename)
 
    # 獲取 postgresql 部分的配置
    db = {}
    if parser.has_section(section):
        items = parser.items(section)
        for item in items:
            db[item[0]] = item[1]
    else:
        raise Exception('文件 {1} 中未找到 {0} 配置信息！'.format(section, filename))
    return db
 
if __name__ == '__main__':
    db_config = read_db_config()
    connection = None
 
    try:
        # 使用 psycopg2.connect 方法連接 PostgreSQL 數(shù)據(jù)庫
        connection = psycopg2.connect(**db_config)
        cur = connection.cursor()    # 創(chuàng)建一個游標
        cur.execute('SELECT version()')    # 獲取 PostgreSQL 版本號
        db_version = cur.fetchone()
        print("連接成功，PostgreSQL 服務(wù)器版本：", db_version)    # 輸出 PostgreSQL 版本
 
        # `在這里插入代碼片`
 
        cur.close()    # 關(guān)閉游標
    except (Exception, DatabaseError) as e:
        print("連接 PostgreSQL 失敗：", e)
    finally:
        if connection is not None:    # 釋放數(shù)據(jù)庫連接
            connection.close()
            print("PostgreSQL 數(shù)據(jù)庫連接已關(guān)閉。")

# 導(dǎo)入 psycopg2 模塊和 Error 對象
import psycopg2
from psycopg2 import DatabaseError
from configparser import ConfigParser
 
def read_db_config(filename='dbconfig.ini', section='postgresql'):
    """ 讀取數(shù)據(jù)庫配置文件，返回一個字典對象
    """
    # 創(chuàng)建解析器，讀取配置文件
    parser = ConfigParser()
    parser.read(filename)
 
    # 獲取 postgresql 部分的配置
    db = {}
    if parser.has_section(section):
        items = parser.items(section)
        for item in items:
            db[item[0]] = item[1]
    else:
        raise Exception('文件 {1} 中未找到 {0} 配置信息！'.format(section, filename))
 
    return db
 
 
if __name__ == '__main__':
    db_config = read_db_config()
    connection = None
 
    try:
        connection = psycopg2.connect(**db_config)        # 使用 psycopg2.connect 方法連接 PostgreSQL 數(shù)據(jù)庫
        cur = connection.cursor()        # 創(chuàng)建一個游標
 
        # 定義 SQL 語句
        sql = """ select id, name, age from users"""
        cur.execute(sql)        # 執(zhí)行 SQL 命令
        print("用戶數(shù)量：", cur.rowcount)
 
        # 獲取結(jié)果
        user = cur.fetchone()
        while user is not None:
            print(user)
            user = cur.fetchone()
 
        cur.close()        # 關(guān)閉游標
    except (Exception, DatabaseError) as e:
        print("操作失敗：", e)
    finally:
        if connection is not None:        # 釋放數(shù)據(jù)庫連接
            connection.close()

用戶數(shù)量： 2
(1, 'lane', False)
(2, 'lane_dynamic', False)