Class: TencentCloud::Ckafka::V20190819::PostgreSQLParam

Inherits:
TencentCloud::Common::AbstractModel
  • Object
show all
Defined in:
lib/v20190819/models.rb

Overview

PostgreSQL类型入参

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(database = nil, table = nil, resource = nil, pluginname = nil, snapshotmode = nil, dataformat = nil, datatargetinsertmode = nil, datatargetprimarykeyfield = nil, datatargetrecordmapping = nil, dropinvalidmessage = nil, istableregular = nil, keycolumns = nil, recordwithschema = nil) ⇒ PostgreSQLParam

Returns a new instance of PostgreSQLParam.



10469
10470
10471
10472
10473
10474
10475
10476
10477
10478
10479
10480
10481
10482
10483
 
# File 'lib/v20190819/models.rb', line 10469

def initialize(database=nil, table=nil, resource=nil, pluginname=nil, snapshotmode=nil, dataformat=nil, datatargetinsertmode=nil, datatargetprimarykeyfield=nil, datatargetrecordmapping=nil, dropinvalidmessage=nil, istableregular=nil, keycolumns=nil, recordwithschema=nil)
  @Database = database
  @Table = table
  @Resource = resource
  @PluginName = pluginname
  @SnapshotMode = snapshotmode
  @DataFormat = dataformat
  @DataTargetInsertMode = datatargetinsertmode
  @DataTargetPrimaryKeyField = datatargetprimarykeyfield
  @DataTargetRecordMapping = datatargetrecordmapping
  @DropInvalidMessage = dropinvalidmessage
  @IsTableRegular = istableregular
  @KeyColumns = keycolumns
  @RecordWithSchema = recordwithschema
end

Instance Attribute Details

#Database ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def Database
  @Database
end

#DataFormat ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def DataFormat
  @DataFormat
end

#DataTargetInsertMode ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def DataTargetInsertMode
  @DataTargetInsertMode
end

#DataTargetPrimaryKeyField ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def DataTargetPrimaryKeyField
  @DataTargetPrimaryKeyField
end

#DataTargetRecordMapping ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def DataTargetRecordMapping
  @DataTargetRecordMapping
end

#DropInvalidMessage ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def DropInvalidMessage
  @DropInvalidMessage
end

#IsTableRegular ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def IsTableRegular
  @IsTableRegular
end

#KeyColumns ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def KeyColumns
  @KeyColumns
end

#PluginName ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def PluginName
  @PluginName
end

#RecordWithSchema ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def RecordWithSchema
  @RecordWithSchema
end

#Resource ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def Resource
  @Resource
end

#SnapshotMode ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def SnapshotMode
  @SnapshotMode
end

#Table ⇒ Object

Parameters:

  • Database: —

    PostgreSQL的数据库名称

  • Table: —

    PostgreSQL的数据表名称，"*"为所监听的所有数据库中的非系统表，可以","间隔，监听多个数据表，但数据表需要以"Schema名.数据表名"的格式进行填写，需要填入正则表达式时，格式为"Schema名\.数据表名"

  • Resource: —

    该PostgreSQL在连接管理内的Id

  • PluginName: —

    插件名(decoderbufs/pgoutput)，默认为decoderbufs

  • SnapshotMode: —

    复制存量信息(never增量, initial全量)，默认为initial

  • DataFormat: —

    上游数据格式(JSON/Debezium), 当数据库同步模式为默认字段匹配时,必填

  • DataTargetInsertMode:表示使用Insert模式插入，表示使用Upsert模式插入 ("INSERT""UPSERT") —

    ataTargetInsertMode: "INSERT" 表示使用 Insert 模式插入，"UPSERT" 表示使用 Upsert 模式插入

  • DataTargetPrimaryKeyField: —

    当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键

  • DataTargetRecordMapping: —

    表与消息间的映射关系

  • DropInvalidMessage: —

    是否抛弃解析失败的消息，默认为true

  • IsTableRegular: —

    输入的table是否为正则表达式

  • KeyColumns: —

    格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键

  • RecordWithSchema: —

    如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带



10467
10468
10469
 
# File 'lib/v20190819/models.rb', line 10467

def Table
  @Table
end

Instance Method Details

#deserialize(params) ⇒ Object 



10485
10486
10487
10488
10489
10490
10491
10492
10493
10494
10495
10496
10497
10498
10499
10500
10501
10502
10503
10504
10505
10506
 
# File 'lib/v20190819/models.rb', line 10485

def deserialize(params)
  @Database = params['Database']
  @Table = params['Table']
  @Resource = params['Resource']
  @PluginName = params['PluginName']
  @SnapshotMode = params['SnapshotMode']
  @DataFormat = params['DataFormat']
  @DataTargetInsertMode = params['DataTargetInsertMode']
  @DataTargetPrimaryKeyField = params['DataTargetPrimaryKeyField']
  unless params['DataTargetRecordMapping'].nil?
    @DataTargetRecordMapping = []
    params['DataTargetRecordMapping'].each do |i|
      recordmapping_tmp = RecordMapping.new
      recordmapping_tmp.deserialize(i)
      @DataTargetRecordMapping << recordmapping_tmp
    end
  end
  @DropInvalidMessage = params['DropInvalidMessage']
  @IsTableRegular = params['IsTableRegular']
  @KeyColumns = params['KeyColumns']
  @RecordWithSchema = params['RecordWithSchema']
end