Python 使用 Ksycopg2 驱动连接和操作 Kingbase 数据库

配置（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 驱动成功导入。

代码开发与测试

创建文件夹

创建测试程序文件夹 test_ksycopg2，新建源码文件 test_ksycopg2.py，目录示例如下：

test_ksycopg2 └── test_ksycopg2.py 

开发源程序 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()

运行与调试

执行

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

python test_ksycopg2.py 

输出如下所示：

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

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 驱动包的父目录")