class TencentCloud::Ckafka::V20190819::MySQLParam

MySQL类型入参

def deserialize(params)

def deserialize(params)
  @Database = params['Database']
  @Table = params['Table']
  @Resource = params['Resource']
  @SnapshotMode = params['SnapshotMode']
  @DdlTopic = params['DdlTopic']
  @DataSourceMonitorMode = params['DataSourceMonitorMode']
  @DataSourceMonitorResource = params['DataSourceMonitorResource']
  @DataSourceIncrementMode = params['DataSourceIncrementMode']
  @DataSourceIncrementColumn = params['DataSourceIncrementColumn']
  @DataSourceStartFrom = params['DataSourceStartFrom']
  @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
  @TopicRegex = params['TopicRegex']
  @TopicReplacement = params['TopicReplacement']
  @KeyColumns = params['KeyColumns']
  @DropInvalidMessage = params['DropInvalidMessage']
  unless params['DropCls'].nil?
    @DropCls = DropCls.new
    @DropCls.deserialize(params['DropCls'])
  end
  @OutputFormat = params['OutputFormat']
  @IsTablePrefix = params['IsTablePrefix']
  @IncludeContentChanges = params['IncludeContentChanges']
  @IncludeQuery = params['IncludeQuery']
  @RecordWithSchema = params['RecordWithSchema']
  @SignalDatabase = params['SignalDatabase']
  @IsTableRegular = params['IsTableRegular']
  @SignalTable = params['SignalTable']
  @DateTimeZone = params['DateTimeZone']
  @SelfBuilt = params['SelfBuilt']
end

def initialize(database=nil, table=nil, resource=nil, snapshotmode=nil, ddltopic=nil, datasourcemonitormode=nil, datasourcemonitorresource=nil, datasourceincrementmode=nil, datasourceincrementcolumn=nil, datasourcestartfrom=nil, datatargetinsertmode=nil, datatargetprimarykeyfield=nil, datatargetrecordmapping=nil, topicregex=nil, topicreplacement=nil, keycolumns=nil, dropinvalidmessage=nil, dropcls=nil, outputformat=nil, istableprefix=nil, includecontentchanges=nil, includequery=nil, recordwithschema=nil, signaldatabase=nil, istableregular=nil, signaltable=nil, datetimezone=nil, selfbuilt=nil)

def initialize(database=nil, table=nil, resource=nil, snapshotmode=nil, ddltopic=nil, datasourcemonitormode=nil, datasourcemonitorresource=nil, datasourceincrementmode=nil, datasourceincrementcolumn=nil, datasourcestartfrom=nil, datatargetinsertmode=nil, datatargetprimarykeyfield=nil, datatargetrecordmapping=nil, topicregex=nil, topicreplacement=nil, keycolumns=nil, dropinvalidmessage=nil, dropcls=nil, outputformat=nil, istableprefix=nil, includecontentchanges=nil, includequery=nil, recordwithschema=nil, signaldatabase=nil, istableregular=nil, signaltable=nil, datetimezone=nil, selfbuilt=nil)
  @Database = database
  @Table = table
  @Resource = resource
  @SnapshotMode = snapshotmode
  @DdlTopic = ddltopic
  @DataSourceMonitorMode = datasourcemonitormode
  @DataSourceMonitorResource = datasourcemonitorresource
  @DataSourceIncrementMode = datasourceincrementmode
  @DataSourceIncrementColumn = datasourceincrementcolumn
  @DataSourceStartFrom = datasourcestartfrom
  @DataTargetInsertMode = datatargetinsertmode
  @DataTargetPrimaryKeyField = datatargetprimarykeyfield
  @DataTargetRecordMapping = datatargetrecordmapping
  @TopicRegex = topicregex
  @TopicReplacement = topicreplacement
  @KeyColumns = keycolumns
  @DropInvalidMessage = dropinvalidmessage
  @DropCls = dropcls
  @OutputFormat = outputformat
  @IsTablePrefix = istableprefix
  @IncludeContentChanges = includecontentchanges
  @IncludeQuery = includequery
  @RecordWithSchema = recordwithschema
  @SignalDatabase = signaldatabase
  @IsTableRegular = istableregular
  @SignalTable = signaltable
  @DateTimeZone = datetimezone
  @SelfBuilt = selfbuilt
end