达梦数据库怎么做表达梦数据库ODBC编程

导读这两天安装试用了达梦数据库(DM8)，下面记录对达梦数据库ODBC接口编程的探索过程。Linux环境中，达梦数据库的odbc接口依赖unixODBC库。1.....

这两天安装试用了达梦数据库(DM8)，下面记录对达梦数据库ODBC接口编程的探索过程。

Linux环境中，达梦数据库的odbc接口依赖unixODBC库。

1.安装unixODBC库

下载：wget ftp://ftp.unixodbc.org/pub/unixODBC/unixODBC-2.3.9.tar.gz 解压：tar -zxvf unixODBC-2.3.9.tar.gz 进入解压目录安装：cd unixODBC-2.3.9/ ./configure --prefix=/home/dmdba/unixODBC --enable-gui=no 注：先建自定义安装目录unixODBCmake && make install

按上面安装后，unixODBC的lib、include和etc配置生成在$HOME/unixODBC下，如下图：

unixODBC安装后

但这时etc下的odbc.ini和odbcinst.ini尚且为空，需要配置。

配置后的odbc.int和odbcinst.ini文件

配置注意:odbcinst.int的节点名称（红框2）是odbc.int的Driver值。

安装完成后，把unixODBC的lib库目录加到LD_LIBRARY_PATH环境变量中。

现在LD_LIBRARY_PATH值如下：

[dmdba@wen ~]$ echo $LD_LIBRARY_PATH/home/dmdba/dmdbms/bin:/home/dmdba/unixODBC/lib:/home/dmdba/iconv/lib

测试odbc接口是否可用：

测试odbc接口可用

2.ODBC编程接口

达梦ODBC接口用会用到转码库libiconv.so.2，若没有先安装之，自定义安装目录时要把安装位置加入LD_LIBRARY_PATH路径中。

至此环境准备完毕，可以进行测试代码编译了。

下面是改造后的代码示例：

[dmdba@wen ~]$ cat test_odbc.c

#include <stdio.h>#include <string.h>#include <stdlib.h>#include <SQL.h>#include <sqltypes.h>#include <sqlext.h>/* * SQLEndTran：提交或者回滚事务。 * 调用 SQLFreeHandle 释放语句句柄，关闭所有打开的游标，释放相关的语句句柄( 在非自动提交模式下，需事先提交当前的事务) * * *//* 检测返回代码是否为成功标志，当为成功标志返回 TRUE，否则返回 FALSE */#define RC_SUCCESSFUL(rc) ((rc) == SQL_SUCCESS || (rc) == SQL_SUCCESS_WITH_INFO)/* 检测返回代码是否为失败标志，当为失败标志返回 TRUE，否则返回 FALSE */#define RC_NOTSUCCESSFUL(rc) (!(RC_SUCCESSFUL(rc)))HENV henv; /* 环境句柄 */HDBC hdbc; /* 连接句柄 */HSTMT hsmt; /* 语句句柄 */SQLRETURN sret; /* 返回代码 */void main(void){printf("begin\n");char szpersonid[11]; /*人员编号*/SQLLEN cbpersonid=0;char szname[51]; /*人员姓名*/SQLLEN cbname=0;SQLRETURN retcode=SQL_ERROR ; /* 返回代码 -1 *//* 申请一个环境句柄 */retcode= SQLAllocHandle(SQL_HANDLE_ENV, NULL, &henv);if (SQL_SUCCESS == retcode || SQL_SUCCESS_WITH_INFO == retcode ){printf("SQLAllocHandle ok\n");}else{printf("retcode=%d\n",retcode);exit(-1);}/* 设置环境句柄的 ODBC 版本 */SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, SQL_IS_INTEGER);/* 申请一个连接句柄 */SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc);///home/dmdba/unixODBC/etc/odbc.int的[dm8]节点名retcode = SQLConnect(hdbc, (SQLCHAR *)"dm8", SQL_NTS, (SQLCHAR *)"dmdbuser1", SQL_NTS, (SQLCHAR *)"dmdbuser1", SQL_NTS);if (SQL_SUCCESS == retcode || SQL_SUCCESS_WITH_INFO == retcode ){printf("SQLConnect ok\n");}else{SQLFreeHandle(SQL_HANDLE_ENV, henv);printf("retcode=%d\n",retcode);exit(-1);}SQLINTEGER AUTOCOMMIT_MODE;/* 设置连接句柄属性，关闭自动提交功能 */SQLSetConnectAttr(hdbc, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_OFF, SQL_IS_INTEGER);//SQLSetConnectAttr(hdbc, SQL_ATTR_AUTOCOMMIT, (SQLPOINTER)SQL_AUTOCOMMIT_ON, SQL_IS_INTEGER); AUTOCIMMIT_ON is default /* 申请一个语句句柄 */SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hsmt);SQLExecDirect(hsmt, (SQLCHAR *)"insert into city values(5,cp);", SQL_NTS);SQLExecDirect(hsmt, (SQLCHAR *)"insert into city values(6,北京);", SQL_NTS);SQLExecDirect(hsmt, (SQLCHAR *)"insert into city values(6,china);", SQL_NTS);/* 立即执行查询人员信息表的语句 */SQLExecDirect(hsmt, (SQLCHAR *)"SELECT f1, f2 FROM city;", SQL_NTS);/* 绑定数据缓冲区 */SQLBindCol(hsmt, 1, SQL_C_CHAR, szpersonid, sizeof(szpersonid), &cbpersonid);SQLBindCol(hsmt, 2, SQL_C_CHAR, szname, sizeof(szname), &cbname);/* 取得数据并且打印数据 */for (;;) {sret = SQLFetchScroll(hsmt, SQL_FETCH_NEXT, 0);if (sret == SQL_NO_DATA_FOUND){break;} /*SQLRETURN SQL_API SQLGetData(SQLHSTMT StatementHandle, SQLUSMALLINT ColumnNumber, SQLSMALLINT TargetType, SQLPOINTER TargetValue, SQLLEN BufferLength, SQLLEN *StrLen_or_Ind);*/printf("%s %s. len=%d\n", szpersonid, szname,cbname);bzero(szpersonid,sizeof szpersonid);bzero(szname,sizeof szname);}/* 关闭游标，终止语句执行 */SQLCloseCursor(hsmt);SQLExecDirect(hsmt, (SQLCHAR *)"delete from city where f1=3;", SQL_NTS);SQLExecDirect(hsmt, (SQLCHAR *)"delete from city where f1=5;", SQL_NTS);SQLExecDirect(hsmt, (SQLCHAR *)"update city set f2=LN where f1=2;", SQL_NTS);//提交连接上的事务SQLEndTran(SQL_HANDLE_DBC, hdbc, SQL_COMMIT);//回滚连接上的事务//SQLEndTran(SQL_HANDLE_DBC, hdbc, SQL_ROLLBACK);/* 释放语句句柄 */SQLFreeHandle(SQL_HANDLE_STMT, hsmt);/* 断开与数据源之间的连接 */SQLDisconnect(hdbc);/* 释放连接句柄 */SQLFreeHandle(SQL_HANDLE_DBC, hdbc);/* 释放环境句柄*/SQLFreeHandle(SQL_HANDLE_ENV, henv);printf("end ok\n");return 0;}

这是编译test_odbc.c的Makefile文件：

DM_DIR=/home/dmdbaall:test_odbctest_odbc:test_odbc.o gcc -ggdb -Wall -o $@ $^ -L$(DM_DIR)/unixODBC/lib -L$(DM_DIR)/dmdbms/bin -I$(DM_DIR)/unixODBC/include -lodbcclean: rm test_odbc rm test_odbc.o

编译后生成test_odbc程序，可以正确读取和修改测试库（dmdbuser1)中的表数据。

ODBC接口调用存储过程、函数方法见《DM8程序员手册.pdf》，相关资料在数据库安装目录的doc里可找到。

tips:

客户端工具可用DBeaver，它依赖的驱动DmJDBCDriver17.jar可在达梦安装包的drivers目录里获取。驱动设置时：

类名：dm.jdbc.driver.DmDriver

JDBC URL: jdbc:dm://<ip>:<port>/<DBNAME>

---

铁锈笔记 2022-01-13