达梦数据库ODBC编程

这两天安装试用了达梦数据库(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  注：先建自定义安装目录unixODBC
make && 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/dmdba
all:test_odbc
test_odbc:test_odbc.o
        gcc -ggdb  -Wall -o $@  $^ -L$(DM_DIR)/unixODBC/lib -L$(DM_DIR)/dmdbms/bin -I$(DM_DIR)/unixODBC/include -lodbc
clean:
        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