更新日期：2024年09月11日
语法
record 类型的语法参见图17-1。
GBase 8c V5 开发者手册
南大通用数据技术股份有限公司
626
图17-1 record 类型的语法
对以上语法格式的解释如下：
record_type：声明的类型名称。
field：record 类型中的成员名称。
datatype：record 类型中成员的类型。
expression：设置默认值的表达式。
说明
在GBase 8c 中：
record 类型变量的赋值支持：
在函数或存储过程的声明阶段，
声明一个record 类型，
并且可以在该类型中定义成
员变量。
一个record 变量到另一个record 变量的赋值。
SELECT INTO 和FETCH 向一个record 类型的变量中赋值。
将一个NULL 值赋值给一个record 变量。
不支持INSERT 和UPDATE 语句使用record 变量进行插入数据和更新数据。
如果成员有复合类型，
在声明阶段不支持指定默认值，
该行为同声明阶段的变量一
样。
datatype 可以为存储过程中定义record 类型、
数组类型和集合类型
（匿名块不支持）
。
GBase 8c V5 开发者手册
南大通用数据技术股份有限公司
627
库级别增量同步要求源数据库与目标数据库下的所有表的表名及列名完全
一致。如果有部分表不需要同步，可以使用排除表功能排除掉这些表。
下面按照步骤详细介绍：
修改任务文件config_task.xml，该文件在读端，管理端各有一份，如果
同步工具安装后再修改该文件请确保两处配置文件一致。
mqType="kafka" queueName="8tto8aMQ" dataRecoveryMode="file"
isHighAvailable="false">
openMonitor="true" monitorInterval="300" rpcPort="9191" sshPort="22"/>
GBase RTSync 同步工具手册
- 136 -
南大通用数据技术股份有限公司
charset="UTF8"
type="SQLSERVER"
startLSN="0"
fetchSize="500"
maxRecordsPerRead="200"
maxSizeOfPerRecord="1024"
timeOut="2"
driver="com.microsoft.sqlserver.jdbc.SQLServerDriver"
url="jdbc:sqlserver://192.168.4.206:1433;DatabaseName=master "
user="cdccp"
password="sqlserver"
catalog="test"
columnTypeFormat="time=hh:mm:ss.SSSSSS;date=yyyy-MM-dd;datetime=yyyy
-MM-dd HH:mm:ss.SSSSSS;smalldatetime=yyyy-MM-dd
HH:mm:ss.SSSSSS;datetime2=yyyy-MM-dd HH:mm:ss.SSSSSS"
>
type="GCLUSTER"
commitSize="100"
queueSize="20000"
user="gbase"
password="gbase20110531"
driver="com.gbase.jdbc.Driver"
catalog="testdb"
timeOut="2"
isInitMetadata="false"
url="jdbc:gbase://192.168.5.5:5258/gbase?useOldAliasMetadataBehavior
=true&rewriteBatchedStatements=true&connectTimeout=0&socketT
imeout=0"
>
GBase RTSync 同步工具手册
南大通用数据技术股份有限公司
- 137 -sourcePkColName="" targetTableName="" targetPkColName="" />
sourcePkColName="" targetTableName="t2" targetPkColName="" />
修改消息队列配置文件：config_kafka_8tto8aMQ.properties。
GBase RTSync 同步工具手册
- 138 -
南大通用数据技术股份有限公司
#kafka 主题
topic.name=8tto8a
#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 同步工具手册
南大通用数据技术股份有限公司
- 139 -
命令启动同步工具组件：
# cd /opt/RTSync /
# sh RTSyncManagerServer.sh start
启动后，同步工具将开始同步数据工作。
可以使用如下命令监控同步工具运行状况。
# tail -f logs/sync.log