本文主要讲解golang通过odbc连接GBase8s
环境配置
unixODBC安装
yum -y install unixODBC unixODBC-devel
配置 gbase8s-odbc-driver
wget https://gbasedbt.com/dl/odbc/GBase8s_3.0.0_1-Linux64-ODBC-Driver.tar.gz --no-check-certificate
tar -zxf GBase8s_3.0.0_1-Linux64-ODBC-Driver.tar.gz
配置 sqlhosts
gbase01 onsoctcp ip9088g=db_group
cm_update group - - i=2,c=0
w1 onsoctcp ip18888g=cm_update
cm_read group - - i=3,c=0
r1 onsoctcp ip19999g=cm_read
配置环境变量 (使用 root)
vim /etc/profile
export GBASEDBTDIR=/home/gbase8s-odbc-driver
export GBASEDBTSERVER=gbase01
export PATH=
G
B
A
S
E
D
B
T
D
I
R
/
b
i
n
:
GBASEDBTDIR/bin:
GBASEDBTDIR/bin:PATH
export GBASEDBTSQLHOSTS=
G
B
A
S
E
D
B
T
D
I
R
/
e
t
c
/
s
q
l
h
o
s
t
s
e
x
p
o
r
t
L
D
L
I
B
R
A
R
Y
P
A
T
H
=
GBASEDBTDIR/etc/sqlhosts export LD_LIBRARY_PATH=
GBASEDBTDIR/etc/sqlhostsexportLDLIBRARYPATH=GBASEDBTDIR/lib:
G
B
A
S
E
D
B
T
D
I
R
/
l
i
b
/
e
s
q
l
:
GBASEDBTDIR/lib/esql:
GBASEDBTDIR/lib/esql:GBASEDBTDIR/lib/cli:$LD_LIBRARY_PATH
export ODBCINI=/home/gbase8s-odbc-driver/odbc.ini
执行source /etc/profile生效
配置 驱动 (使用 root)
vim /etc/odbcinst.ini
[com.gbasedbt.jdbc.Driver]
Driver=/home/gbase8s-odbc-driver/lib/cli/iclit09b.so
Setup=/home/gbase8s-odbc-driver/lib/cli/iclit09b.so
APILevel=1
ConnectFunctions=YYY
DriverODBCVer=03.51
FileUsage=0
SQLLevel=1
smProcessPerConnect=Y
配置 odbc.ini
vim /home/linkdood/gbase8s-odbc-driver/odbc.ini
[ODBC]
UNICODE=UCS-2
测试驱动连接
isql -v -k “DRIVER={com.gbasedbt.jdbc.Driver};DB=testdataserver;UID=gbasedbt;pwd=GBase123;Server=gbase01;CLIENT_LOCALE=zh_CN.57372;DB_LOCALE=zh_CN.57372;”
golang通过odbc连接国产数据库
funcinit(){
file, err := os.Open("config.xml")if err !=nil{
Log.Info("error:%v", err)return}defer file.Close()
config, err := ioutil.ReadAll(file)if err !=nil{
Log.Info("error:%v", err)return}
configValue := SConfig{}
err = xml.Unmarshal(config,&configValue)if err !=nil{
Log.Error("error:%v", err)return}
strKey := configValue.Server.Aid + configValue.Server.Elogo
var strPassword stringvar strUsername string
strPassword = configValue.DataBase.Password
strUsername = configValue.DataBase.User
fmt.Printf("strPassword:%v\n", strPassword)
fmt.Printf("strUsername:%v\n", strUsername)
ServerPort = configValue.Server.Port
var dbDSN =""//dataSourceNamevar driverName =""//驱动名var DbServer = configValue.DataBase.Host +":"+ configValue.DataBase.Port
if configValue.DataBase.DbType =="mysql"{
fmt.Printf("mysql database\n")
driverName ="mysql"
dbDSN = fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=%s", strUsername, strPassword, configValue.DataBase.Host, configValue.DataBase.Port, configValue.DataBase.DBName, configValue.DataBase.Charset)}elseif configValue.DataBase.DbType =="shentong"{
fmt.Printf("shentongsql database\n")/*driverName = "odbc"
dbDSN = fmt.Sprintf("driver={%s};server=%s;port=%s;database=%s;uid=%s;pwd=%s;charset=%s", configValue.DataBase.Driver, configValue.DataBase.Host, configValue.DataBase.Port, configValue.DataBase.DBName, strUsername, strPassword, configValue.DataBase.Charset)*/
driverName ="aci"
dbDSN = fmt.Sprintf("%s/%s@%s:%s/%s", strUsername, strPassword, configValue.DataBase.Host, configValue.DataBase.Port, configValue.DataBase.DBName)}elseif configValue.DataBase.DbType =="dameng"{
strPassword =CheckAndModifyString(strPassword)
fmt.Printf("dmsql database\n")
driverName ="dm"//dbDSN = fmt.Sprintf("driver={%s};server=%s;database=%s;uid=%s;pwd=%s;charset=%s", configValue.DataBase.Driver, DbServer, configValue.DataBase.DBName, strUsername, strPassword, configValue.DataBase.Charset)
dbDSN = fmt.Sprintf("%s://%s:%s@%s?schema=%s", driverName, strUsername, strPassword, DbServer, configValue.DataBase.DBName)}elseif configValue.DataBase.DbType =="kingbase"{
fmt.Printf("kingbase database\n")
driverName ="odbc"
dbDSN = fmt.Sprintf("driver={%s};server=%s;port=%s;database=%s;uid=%s;pwd=%s;charset=%s", configValue.DataBase.Driver, configValue.DataBase.Host, configValue.DataBase.Port, configValue.DataBase.DBName, strUsername, strPassword, configValue.DataBase.Charset)}elseif configValue.DataBase.DbType =="GBase8s"{
fmt.Printf("GBase8s database\n")
driverName ="odbc"
dbDSN = fmt.Sprintf("driver={%s};server=%s;port=%s;database=%s;uid=%s;pwd=%s;charset=%s", configValue.DataBase.Driver, configValue.DataBase.Host, configValue.DataBase.Port, configValue.DataBase.DBName, strUsername, strPassword, configValue.DataBase.Charset)}
dbType = configValue.DataBase.DbType
// 打开连接失败
MysqlDb, MysqlDbErr = sql.Open(driverName, dbDSN)//defer MysqlDb.Close();if MysqlDbErr !=nil{panic("数据源配置不正确: "+ MysqlDbErr.Error())}// 最大连接数
MysqlDb.SetMaxOpenConns(100)// 闲置连接数
MysqlDb.SetMaxIdleConns(20)// 最大连接周期
MysqlDb.SetConnMaxLifetime(100* time.Second)if MysqlDbErr = MysqlDb.Ping();nil!= MysqlDbErr {panic("数据库链接失败: "+ MysqlDbErr.Error())}}
Go测试程序运行测试
go run .-dsn="DRIVER={com.gbasedbt.jdbc.Driver};DB=testdataserver;UID=gbasedbt;pwd=GBase123;Server=gbase01;CLIENT_LOCALE=zh_CN.57372;DB_LOCALE=zh_CN.57372;"
./gbase-test -dsn="DRIVER={com.gbasedbt.jdbc.Driver};DB=testdataserver;UID=gbasedbt;pwd=GBase123;Server=gbase01;CLIENT_LOCALE=zh_CN.57372;DB_LOCALE=zh_CN.57372;"
问题&&解决方式
- 异常：
SQLDriverConnect: {01000} [unixODBC][Driver Manager]Can not open lib "com.gbasedbt.jdbc.Driver" : file not found- 解决方式- 使用ldd gbase-test查看so依赖linux-vdso.so.1 =>(0x00007fff083d1000)libodbc.so.2 => /data/libodbc.so.2 (0x00007f95d721c000)libpthread.so.0 => /lib64/libpthread.so.0 (0x00007f95d7000000)libc.so.6 => /lib64/libc.so.6 (0x00007f95d6c32000)libdl.so.2 => /lib64/libdl.so.2 (0x00007f95d6a2e000)libiconv.so.2 => /data/linkdood/im/cpp/libs/libiconv.so.2 (0x00007f95d6745000)/lib64/ld-linux-x86-64.so.2 (0x00007f95d7494000)- 查看依赖的so是否存在- - 如果/data/linkdood/im/cpp/libs/libodbc.so.2版本较老，请联系运维替换- 使用grep "cbuilder" /data/libs/*如果匹配到则说明 odbc so库是老的，内部写死了odbcinst.ini地址 - 异常
查询异常： SQLDriverConnect: {H} [ {0} [- 解决方式- 使用vim $ODBCINI查看配置 是否配置一下参数[ODBC]UNICODE=UCS-2 - 异常 出现
xxx.so不存在`- 解决方式- 确认so库是否存在，如果存在检测依赖是否存在- 使用ldd xxx.so查看so依赖是否存在
总结
国产化是大势所趋，目前主流的国产数据库有达梦，金仓，神通，优炫等，博主会在后续补充其他国产数据库的适配，敬请期待。
本文转载自: https://blog.csdn.net/LittleBoy_IT/article/details/138998070
版权归原作者 webrtc&ffmpeg&study 所有， 如有侵权，请联系我们删除。
版权归原作者 webrtc&ffmpeg&study 所有， 如有侵权，请联系我们删除。