Python驱动Ksycopg2连接和使用Kingbase:国产数据库实战指南

Python驱动Ksycopg2连接和使用Kingbase:国产数据库实战指南

引言

在国产数据库蓬勃发展的今天,KingbaseES作为国产数据库的佼佼者,凭借其高兼容性、高性能和高安全性,在金融、政府、能源等关键领域得到了广泛应用。本文将介绍如何通过Python的ksycopg2驱动连接并操作Kingbase数据库,从基础连接到高级操作全面掌握这一技术栈。

KingbaseES 数据库【系列篇章】

No.文章地址(点击进入)
1电科金仓KingbaseES数据库解析:国产数据库的崛起与技术创新
2KingBase数据库迁移利器:KDTS工具深度解析与实战指南
3KingBase数据库迁移利器:KDTS工具 MySQL数据迁移到KingbaseES实战
4电科金仓KingbaseES V9数据库:国产数据库的自主创新与行业实践深度解析
5KingbaseES客户端工具Ksql使用全指南:从安装到高级操作
6Spring JDBC与KingbaseES深度集成:构建高性能国产数据库应用实战
7深度解析:基于 ODBC连接 KingbaseES 数据库的完整操作与实践

一、ksycopg2驱动:连接Kingbase的桥梁

1.1 驱动架构深度剖析

ksycopg2 是 Python 编程语言的 KingbaseES 数据库适配器。
在Kingbase场景下展现出完美的兼容性。其底层采用C扩展实现,通过libpq库与数据库进行通信。该驱动完整实现了DB API 2.0规范,支持线程安全、异步通信、二进制协议传输等高级特性。

1.2 ksycopg2兼容Python版本信息

数据库版本包默认支持 Python 2.7 和 Python 3.5 的 64 位 ksycopg2 驱动,如需其他版本,可在官网下载(点击进入)的接口模块中获取更多版本支持。

驱动支持 Python 2.7 及 Python 3.5 至 3.10 版本,具体兼容性如下表所示:

在这里插入图片描述

1.3 环境配置要求

  1. 安装与驱动对应版本的数据库,且数据库连接可用
  2. 确保 Ksycopg2 支持开发环境:
    Linux:x86_64、arm、loongarch、mips、sw
    Windows:提供64位支持
  3. 编译器:
    Linux:仅支持依赖 glibc 的编译的 Python。
    Windows:依赖 msvc120 的运行时库。
  4. Python 环境:
    见目录1.2中的版本兼容表

满足以上条件后,可通过已发布版本的数据库安装包、官网下载接口、或联系技服人员获取对应版本架构的 Ksycopg2 驱动

官网下载接口路径(点击进入)展示:

版本列表选取对应的版本文件

在这里插入图片描述

选择接口驱动

在这里插入图片描述

二、安装部署驱动

检测系统架构及 Python 版本信息,选择适配的 Ksycopg2 数据库驱动

查看 Python 版本

$ python -V Python 3.5.6 

当前环境使用的是 Python3.5,若对应架构是 x86_64,则应该选用 x86 架构的 Python3.5 版本的 Ksycopg2 驱动包安装

解压适用于对应架构和 Python 版本的 Ksycopg2 驱动包后,Linux 环境下 Python 3.5 版本的驱动目录结构如下:

在这里插入图片描述


_ksycopg 开头的这个库就是 Python 驱动,后缀为 .py 的文件是 Ksycopg2 驱动提供的可拓展的 Python 文件,包括了一些游标工厂、批量执行、连接池等功能。

将 ksycopg2 这个文件夹拷贝到对应 Python 安装目录下的 site-packages 路径下(site-packages 路径是 Python 默认加载模块的搜索路径),以下是模块路径示例:

在这里插入图片描述


安装完成后,在Python命令行中执行import psycopg2命令,检查是否出现错误提示。

在确认驱动包使用无误的前提,若导入模块仍然报错

错误信息

Traceback (most recent call last): File "<stdin>", line 1, in <module> File "/home/python/py-3.5/lib/python3.5/site-packages/ksycopg2/__init__.py", line 51, in <module> from ksycopg2._ksycopg import ( # noqa ImportError: libkci.so.5: cannot open shared object file: No such file or directory 

原因:这是因为 Ksycopg2 驱动以动态库形式存在,且依赖 Libkci 库。当 Python 加载 Ksycopg2 时,只能识别到主库本身,而未能检测到其依赖库,因此产生了错误提示

解决:建议通过配置环境变量 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,目录示例如下:

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

五、结语

数据库技术的发展永无止境,Kingbase作为国产数据库的代表,正在书写着属于中国数据库的辉煌篇章。掌握其与Python的集成技术,不仅是技术能力的体现,更是参与国产化替代战略的重要实践。本文介绍了Python驱动Ksycopg2连接和使用Kingbase,后续博主会继续介绍其他语言的连接与数据库的开发。

Read more

将现有 REST API 转换为 MCP Server工具 -higress

将现有 REST API 转换为 MCP Server工具 -higress

Higress 是一款云原生 API 网关,集成了流量网关、微服务网关、安全网关和 AI 网关的功能。 它基于 Istio 和 Envoy 开发,支持使用 Go/Rust/JS 等语言编写 Wasm 插件。 提供了数十个通用插件和开箱即用的控制台。 Higress AI 网关支持多种 AI 服务提供商,如 OpenAI、DeepSeek、通义千问等,并具备令牌限流、消费者鉴权、WAF 防护、语义缓存等功能。 MCP Server 插件配置 higress 功能说明 * mcp-server 插件基于 Model Context Protocol (MCP),专为 AI 助手设计,

By Ne0inhk
MCP 工具速成:npx vs. uvx 全流程安装指南

MCP 工具速成:npx vs. uvx 全流程安装指南

在现代 AI 开发中,Model Context Protocol(MCP)允许通过外部进程扩展模型能力,而 npx(Node.js 生态)和 uvx(Python 生态)则是两种即装即用的客户端工具,帮助你快速下载并运行 MCP 服务器或工具包,无需全局安装。本文将从原理和对比入手,提供面向 Windows、macOS、Linux 的详细安装、验证及使用示例,确保你能在本地或 CI/CD 流程中无缝集成 MCP 服务器。 1. 工具简介 1.1 npx(Node.js/npm) npx 是 npm CLI(≥v5.2.0)

By Ne0inhk
解锁Dify与MySQL的深度融合:MCP魔法开启数据新旅程

解锁Dify与MySQL的深度融合:MCP魔法开启数据新旅程

文章目录 * 解锁Dify与MySQL的深度融合:MCP魔法开启数据新旅程 * 引言:技术融合的奇妙开篇 * 认识主角:Dify、MCP 与 MySQL * (一)Dify:大语言模型应用开发利器 * (二)MCP:连接的桥梁 * (三)MySQL:经典数据库 * 准备工作:搭建融合舞台 * (一)环境搭建 * (二)安装与配置 Dify * (三)安装与配置 MySQL * 关键步骤:Dify 与 MySQL 的牵手过程 * (一)安装必要插件 * (二)配置 MCP SSE * (三)创建 Dify 工作流 * (四)配置 Agent 策略 * (五)搭建MCP

By Ne0inhk
如何在Cursor中使用MCP服务

如何在Cursor中使用MCP服务

前言 随着AI编程助手的普及,越来越多开发者选择在Cursor等智能IDE中进行高效开发。Cursor不仅支持代码补全、智能搜索,还能通过MCP(Multi-Cloud Platform)服务,轻松调用如高德地图API、数据库等多种外部服务,实现数据采集、处理和自动化办公。 本文以“北京一日游自动化攻略”为例,详细讲解如何在 Cursor 中使用 MCP 服务,完成数据采集、数据库操作、文件生成和前端页面展示的全流程。 学习视频:cursor中使用MCP服务 一、什么是MCP服务? MCP(Multi-Cloud Platform)是Cursor内置的多云服务接口,支持调用地图、数据库、文件系统等多种API。通过MCP,开发者无需手动写HTTP请求或繁琐配置,只需在对话中描述需求,AI助手即可自动调用相关服务,极大提升开发效率。 二、环境准备 2.1 cursor Cursor重置机器码-解决Too many free trials. 2.

By Ne0inhk