gbase数据、南大通用产品文档：GBase8aExecuteDataRow 方法

执行一句SQL 命令并返回结果中的首行。方法执行期间，一个新的
GBaseConnection 对象会被创建、打开和关闭。返回DataRow。

语法
[Visual Basic]
Public Shared Function ExecuteDataRow ( _

connectionString As String, _

commandText As String, _

ParamArray parms As GBaseParameter() _
) As DataRow
[C#]
public static DataRow ExecuteDataRow(



GBase 8a 程序员手册ADO.NET 篇
南大通用数据技术股份有限公司

- 257 -

string connectionString,

string commandText,

params GBaseParameter[] parms
)

参数
1) connectionString ：用于连接的设置；
2) commandText ：要执行的命令；
3) parms ：命令的参数。

返回值
包含结果集首行的DataRow。

列级别同步需要在config_task.xml 文件配置源数据库和目标数
据库的表的列的映射关系。
下面按照步骤详细介绍：
修改任务文件config_task.xml，该文件在读端，写端，管理端各有一份，
如果同步工具安装后再修改该文件请确保三处配置文件一致。列级别配置需要
在表级别的基础上修改配置，在table 标签的下级增加column-mapping 标签，
并配置好源端列名与目标端列名。


...
type="CDCFILE"
separator="\x7C\x1C"
logRetentionDays="3"
logRetentionCheckIntervals="1800"
logArchivedIntervals="60"
/>
...

sourceTableName="testdb.t1" sourcePkColName=""
targetTableName="testdb.t1" targetPkColName="" >






...

修改消息队列配置文件：config_kafka_cdcfileto8aMQ.properties。

GBase RTSync 同步工具手册
- 132 -
南大通用数据技术股份有限公司
#kafka 主题
topic.name=cdcfileto8a
#producer conf
#kafka集群ip及服务端口
bootstrap.servers=192.168.5.11:9092,192.168.5.12:9092
#批量发送数据到kafka的批次数
kafka.batch.commit.count=400
#批量发送数据到kafka等待的超时时间，单位毫秒
kafka.batch.commit.time=100
#kafka 发送数据到kafka异常重发的次数，超过该次数仍然未成功同步工具将退出服务
kafka.resend.max.retries=3
#kafka 接收数据的应答机制。
0代表立即返回，
无论数据是否成功写入kafka;1代表leader
节点成功写入磁盘后才返回结果；all代表所有节点都要写入磁盘才返回结果。根据数据安
全性要求可以实际配置。
kafka.acks=all
#kafka生产者其他必要参数配置，参数信息为标准的kafka生产者参数。
kafka.producer.paramers=request.timeout.ms=30000;metadata.fetch.timeout.
ms=30000
#consumer conf
#kafka所使用zookeeper信息
zookeeper.connect=192.168.5.21:2181,192.168.5.22:2181,192.168.5.23:2181
#kafka消费者组名称
group.id=test
#自动提交时间间隔，一般不用修改
auto.commit.interval.ms=1000
#zookeeper follower能落后leader多久还被认为是活着的
zookeeper.sync.time.ms=2000
#zookeeper session超时时间，如果这段时间没有收到zk的心跳，则认为kafka服务异常
zookeeper.session.timeout.ms=4000
#发送数据到kafka单条数据的最大值，单位字节，超过该大小经进行分包发送
send.data.max.size=1000000
#从kafka获取单条数据的最大值，单位字节，该值应该大于等于send.data.max.size
fetch.message.max.bytes=1000000
完成后，既可启动同步工具。使用root 用户登录192.168.5.3，执行如下
命令启动同步工具组件：

GBase RTSync 同步工具手册
南大通用数据技术股份有限公司
- 133 -
# cd /opt/RTSync /
# sh RTSyncManagerServer.sh start
启动后，同步工具将开始同步数据工作。
可以使用如下命令监控同步工具运行状况。
# tail -f logs/sync.log
# tail –f logs/Reader_INFOCompontSync.log

语法
NULLIF(expr1,expr2)
函数说明
如果expr1 = expr2 成立，返回值为NULL，否则返回值为expr1。
等价于CASE WHEN expr1 = expr2 THEN NULL ELSE expr1 END。
示例
示例1：expr1 = expr2，返回值为NULL。
gbase> SELECT NULLIF(1,1) FROM dual;
+-------------+
| NULLIF(1,1) |
+-------------+
|
NULL |
+-------------+
1 row in set
示例2：expr1 != expr2，返回值为expr1。
gbase> SELECT NULLIF(1,2) FROM dual;
+-------------+
| NULLIF(1,2) |
+-------------+
|
1 |
+-------------+
1 row in set