Python+GaussDB实战：5分钟掌握Psycopg的使用技巧

# 创建代码目录
mkdir -p opt/py/db/basic
# 验证Python环境
python3 -V  # 要求3.6+版本
# 下载并解压驱动包
wget https://opengauss.obs.cn-south-1.myhuaweicloud.com/3.0.0/x86/openGauss-3.0.0-CentOS-x86_64-Python.tar.gz
tar -zxvf openGauss-3.0.0-CentOS-x86_64-Python.tar.gz
# 部署驱动文件
mv psycopg2/ usr/local/lib/python3.6/site-packages/
mv lib/* usr/local/lib
# 配置环境变量
echo 'export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:/usr/local/lib' >> ~/.bash_profile
source ~/.bash_profile
复制

# opt/py/db/basic/conn.py
import psycopg2
conn = psycopg2.connect(
    database="demo",
    user="db_dev", 
    password="gaussdb#_1",  # 替换实际密码
    host="192.168.0.32",     # 替换实际IP
    port=8000
)
print("数据库连接成功！")
复制

python3 conn.py
# 输出：数据库连接成功！
复制

# 导入PostgreSQL数据库适配器（适用于GaussDB）
import psycopg2


# 1. 建立数据库连接（对应GaussDB实例）
conn = psycopg2.connect(
    database="demo",        # 数据库名称
    user="db_dev",          # 用户名
    password="gaussdb#_1",  # 密码
    host="192.168.0.32",    # 数据库主节点IP
    port=8000               # 数据库端口
)


# 2. 创建游标对象（用于执行SQL操作）
cur = conn.cursor()


# 3. 执行建表SQL（创建员工表）
cur.execute("""
    CREATE TABLE employee(
        id integer,         -- 员工ID（整数类型）
        name varchar,       -- 姓名（可变长度字符串）
        sex varchar         -- 性别（可变长度字符串）
    );
""")


# 4. 插入数据（使用参数化查询防止SQL注入）
# 注意：%s是参数占位符，非字符串拼接，更安全！
cur.execute("""
    INSERT INTO employee(id,name,sex) 
    VALUES(%s,%s,%s)""", (1, 'Steve', 'M'))  # 插入第一条记录


cur.execute("""
    INSERT INTO employee(id,name,sex) 
    VALUES(%s,%s,%s)""", (2, 'Emma', 'F'))   # 插入第二条记录


cur.execute("""
    INSERT INTO employee(id,name,sex) 
    VALUES(%s,%s,%s)""", (3, 'Chris', 'M'))  # 插入第三条记录


# 5. 执行查询并获取结果
cur.execute('SELECT * FROM employee')  # 查询所有数据
results = cur.fetchall()               # 获取全部结果集
print(results)                         # 输出：[ (1, 'Steve', 'M'), (2, 'Emma', 'F'), (3, 'Chris', 'M') ]


# 6. 提交事务并释放资源
conn.commit()  # 提交所有操作（重要！否则数据不会持久化）
cur.close()    # 关闭游标
conn.close()   # 关闭连接


复制

python3 demo.py 
[(1, 'Steve', 'M'), (2, 'Emma', 'F'), (3, 'Chris', 'M')]
复制