Python 驱动 Ksycopg2 连接和使用 Kingbase 数据库实战

解决：建议通过配置环境变量 LD_LIBRARY_PATH 来设置 Linux 系统的默认库搜索路径。该路径可指定 Psycopg2 驱动包自带的依赖库。

配置（Ksycopg2 驱动包内一般会提供依赖库）：

export LD_LIBRARY_PATH=/home/python/py-3.5/lib/python3.5/site-packages/ksycopg2:$LD_LIBRARY_PATH 

在 Windows 环境下，系统通常会自动识别 site-packages/ksycopg2 目录中的依赖库，无需额外配置环境变量。但需要注意的是，必须安装 MSVC120（VS2013）运行时库，否则将无法加载驱动程序。

无报错的话，表示 Ksycopg2 驱动成功导入。

三、程序源码开发

3.1 创建文件夹

创建测试程序文件夹 test_ksycopg2，新建源码文件 test_ksycopg2.py。

3.2 开发源程序 test_ksycopg2.py

导入 Ksycopg2：

import ksycopg2 

使用 ksycopg2.connect() 创建连接，并连接到数据库：

conn = ksycopg2.connect("dbname=dbname user=user password=pwd host=host port=port")
# 例：
conn = ksycopg2.connect("dbname=test user=system password=123456 host=127.0.0.1 port=54321")

创建连接后，使用刚刚创建的连接新建一个 Cursor 对象，用于操作数据库：

cur = conn.cursor()

使用 cur.execute() 执行 SQL 语句：

# 创建新表
cur.execute('drop table if exists test_ksy')
cur.execute('create table test_ksy(id integer, name TEXT)')
# 插入数据
cur.execute("insert into test_ksy values(%s, %s)",(1,"John"))
cur.execute("insert into test_ksy values(%s, %s)",(2,'中文测试文字'))
cur.execute("insert into test_ksy values(%s, %s)",(3,'！@#￥%……'))

插入成功后，使用 cur.execute() 执行查询，接着使用 cur.fetchall() 获取结果集并打印：

# 执行查询，并获取结果集
cur.execute("select * from test_ksy")
rows = cur.fetchall()
# 打印结果集
print("result for query:")
for row in rows:
    print("\t", row)

查询结束后，需要关闭游标及连接。

完整示例，示例使用 Python 语法：

# -*- coding: utf-8 -*-
import ksycopg2 
database ="TEST"
user ="SYSTEM"
password ="123456"
host ="127.0.0.1"
port ="54321"
try:
    conn = ksycopg2.connect("dbname={} user={} password={} host={} port={}".format(database, user, password, host, port))
    cur = conn.cursor()
    cur.execute('drop table if exists test_ksy')
    cur.execute('create table test_ksy(id integer, name TEXT)')
    cur.execute("insert into test_ksy values(%s, %s)",(1,"John"))
    cur.execute("insert into test_ksy values(%s, %s)",(2,'中文测试文字'))
    cur.execute("insert into test_ksy values(%s, %s)",(3,'！@#￥%……'))
    cur.execute("select * from test_ksy")
    rows = cur.fetchall()
    print(type(rows),type(rows[0]))
    print("result for query:")
    for row in rows:
        print("\t", row)
    cur.close()
    conn.close()
except Exception as e:
    print(e)
    exit()

四、运行程序

4.1 执行

编写好测试相关代码后，使用 Python 执行即可：

python test_ksycopg2.py 

输出如下所示：

<class'list'><class'tuple'> result for query:(1,'John')(2,'中文测试文字')(3,'！@#￥%……')

4.2 Bug 处理流程

1. 驱动包 SSL 库与系统环境的 SSL 库冲突
   • 原因：系统环境中存在依赖库版本过高的问题，或者应用程序在运行时错误地加载了系统环境的 SSL 库。
   • 解决：执行 ldd _ksycopg 命令检查驱动依赖关系，确保应用程序运行时正确加载驱动包提供的 SSL 库。若仍出现 SSL 相关报错，说明当前环境无法使用驱动包自带的 SSL 库，此时请联系技术支持获取包含静态依赖 SSL 库的 Ksycopg2 驱动包以解决冲突问题。
2. Ksycopg2 加载失败
   • 报错信息：No module named 'ksycopg2._ksycopg'
   • 原因：驱动包可能因架构不匹配、Python 版本冲突或安装路径错误导致无法被 Python 识别。
   • 解决：请确保安装与系统架构及 Python 版本匹配的驱动包。若驱动包已正确安装但仍出现问题，可能是 Python 未能识别 Ksycopg2 模块，此时可通过强制设置 Python 模块搜索路径来解决：

   >>>import sys
   >>> sys.path.insert(0,"Ksycopg2 驱动包的父目录")