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

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

三、程序源码开发

3.1 创建文件夹

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

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

五、结语

掌握 Python 与 Kingbase 的集成技术，是参与国产化替代战略的重要实践。