class TencentCloud::Ckafka::V20190819::PostgreSQLParam

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

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