更新日期：2024年09月11日
GBaseDataReader 成员
公共属性
属 性
描 述
YieldCount
获取当前行的列数。
HasRows
获取一个数值指明GBaseDataReader
是否包含一行或多行。
IsClosed
获得一个值指明GBaseDataReader 是
否关闭。
Item
重载函数。
根据给定的列索引，
返回指
GBase 8a 程序员手册ADO.NET 篇
- 206 -
南大通用数据技术股份有限公司
属 性
描 述
定列的原始列值。
RecordsAffected
得到由SQL 语句更改的，
插入的，
或者
删除的行数。
公共方法
方 法
描 述
Close
关闭GBaseDataReader 对象。
Equals （继承于Object）
判断指定的对象是否等于当前的对象。
GetBoolean
获取指定列的Boolean 值。
GetByte
获取指定列的字节值。
GetBytes
获取指定列的字节数组值。
GetChar
获取指定列的单个字符值。
GetChars
获取指定列的字符数组值。
GetDataTypeName
获取指定列的数据类型的字符串。
GetDateTime
获取指定列的DateTime 类型值。
GetDecimal
获取指定列的Decimal 值。
GetDouble
获取指定列的双精度浮点数值。
GetFieldType
获取指定列的数据类型对象。
GetFloat
获取指定列的单精度浮点数值类型。
GetInt16
获取指定列的16 位有符号整数值。
GetInt32
获取指定列的32 位有符号整数值。
GetInt64
获取指定列的64 位有符号整数值。
GetGBaseDateTime
获取指定列的GBaseDateTime 值。
GetName
获得指定列的名字。
GetOrdinal
通过给定的列名，获得列序号。
GetSchemaTable
返回描述GBaseDataReader 列元数据
的DataTable。
GetString
得到指定列的String 值。
GetTimeSpan
得到指定列的TimeSpan 值。
GetType （继承于 Object）
获取当前实例的类型。
GBase 8a 程序员手册ADO.NET 篇
南大通用数据技术股份有限公司
- 207 -
方 法
描 述
GetUInt16
获取指定列的16 位无符号整数值。
GetUInt32
获取指定列的32 位无符号整数值。
GetUInt64
获取指定列的64 位无符号整数值。
GetValue
获取指定列的原类型数值，返回
Object。
GetValues
获得当前行中所有属性，
返回属性的数
量。
IsDBNull
获得一个值，判断指定列的值是否为
空。
NextResult
当获取多条SQL 语句对应的结果集时，
此方法获取下一个结果集。
Read
使数据读取器读取下一条记录。
ToString （继承于 Object）
返回类的完全限定名。
步骤4
执行GDR 和GDS 初始化安装。
init-up-connect --clearAllConnector # 删除当前confluent 下所有connector
#IF(初始化GDR)
init-up-connect
--coorHost=192.168.6.89:5258 # 本域up 的一个coordinator 节点的ip 和端口。多个节
点用','分割
--localPipeNum=3 # 本域内各引擎之间数据管道数
--kafkahost=10.10.10.11 # kafka 集群的节点IP --kafkaport=9092 # kafka 集群
的port
# IF(初始化GDR 和GDS)
init-up-connect
--coorHost=192.168.6.89:5258 # 本域up 的一个coordinator 节点的ip 和端口。多个节
点用','分割
--localPipeNum=3 # 本域内各引擎之间数据管道数
--outRemotePipeInfo=domain-89:2 # 本域的标识 和 从本域流出到其它域的数据管道数，
用':'分割
--RemoteCrossServerInfo=192.168.6.88:7911 # 其它域接收跨域数据的一个主机IP 和端口
--inRemotePipeInfo=domain-88:2 # 其它域的标识 和 从其它域流入到本域的数据管道
数，用':'分割
--LocalCrossServerPort=7911 # 本域接收跨域数据的端口
--kafkahost=10.10.10.11 # kafka 集群的节点IP
--kafkaport=9092 # kafka 集群的port
#IF(使用kerbers 认证)增加如下参数
--keytabUser=KEYTABUSER kerbors keytab user
--keytabPath=KEYTABPATH kerbors keytab path
只使用GDR 的初始化例子(只使用域内数据流转)。
GBase UP 产品手册 4 管理员指南
文档版本04（2021-04-21） 南大通用数据技术股份有限公司 204
init-up-connect --coorHost=192.168.6.89:5258 --localPipeNum=30
使用GDR 和GDS 的初始化例子（使用域内和跨域数据流转）。
GBaseUP1 初始化命令
init-up-connect
--coorHost=192.168.6.89:5258
--localPipeNum=30
--outRemotePipeInfo=up1:20
--RemoteCrossServerInfo=192.168.6.199:7911
--inRemotePipeInfo=up2:20
--LocalCrossServerPort=7911
--kafkahost=10.10.10.11
GBaseUP2 初始化命令
init-up-connect
--coorHost=192.168.6.88:5258
--localPipeNum=30
--outRemotePipeInfo=up2:20
--RemoteCrossServerInfo=192.168.6.97:7911
--inRemotePipeInfo=up1:20
--LocalCrossServerPort=7911
--kafkahost=192.168.6.199
步骤5
再次查看kafka connect 集群上运行的connector。curl 10.10.10.11:8083/
Connectors。
步骤6
登陆gccli 执行show processlist 可以看到如下任务。
ataflow 'up_remote_up1_1' get task
dataflow 'up_local_1' get task
步骤7
修改gclusterd 配置文件中up_kfk_connect_hosts 参数值，
指定kafka connect 集群的
所有节点IP 和端口，多个节点用','分割。
up_kfk_connect_hosts= 10.10.10.11:8083,10.10.10.12:8083,10.10.10.13:8083