DeleteEndpoint Foxpro Example
LOCAL loRest
LOCAL lnSuccess
LOCAL loAuthAws
LOCAL loJson
LOCAL loSbRequestBody
LOCAL loSbResponseBody
LOCAL lnRespStatusCode
LOCAL loJResp
LOCAL lnIntVal
LOCAL lcCertificateArn
LOCAL lcDatabaseName
LOCAL lcBucketName
LOCAL lcServiceAccessRoleArn
LOCAL lcDocDbSettingsDatabaseName
LOCAL lnDocsToInvestigate
LOCAL lnExtractDocId
LOCAL lcKmsKeyId
LOCAL lcNestingLevel
LOCAL lcPassword
LOCAL lnPort
LOCAL lcSecretsManagerAccessRoleArn
LOCAL lcSecretsManagerSecretId
LOCAL lcServerName
LOCAL lcUsername
LOCAL lcDynamoDbSettingsServiceAccessRoleArn
LOCAL lcEndpointUri
LOCAL lnErrorRetryDuration
LOCAL lnFullLoadErrorPercentage
LOCAL lcElasticsearchSettingsServiceAccessRoleArn
LOCAL lcEndpointArn
LOCAL lcEndpointIdentifier
LOCAL lcEndpointType
LOCAL lcEngineDisplayName
LOCAL lcEngineName
LOCAL lcExternalId
LOCAL lcExternalTableDefinition
LOCAL lcExtraConnectionAttributes
LOCAL lcAfterConnectScript
LOCAL lnCleanSourceMetadataOnMismatch
LOCAL lcGcpMySQLSettingsDatabaseName
LOCAL lnEventsPollInterval
LOCAL lnMaxFileSize
LOCAL lnParallelLoadThreads
LOCAL lcGcpMySQLSettingsPassword
LOCAL lnGcpMySQLSettingsPort
LOCAL lcGcpMySQLSettingsSecretsManagerAccessRoleArn
LOCAL lcGcpMySQLSettingsSecretsManagerSecretId
LOCAL lcGcpMySQLSettingsServerName
LOCAL lcServerTimezone
LOCAL lcTargetDbType
LOCAL lcGcpMySQLSettingsUsername
LOCAL lcCurrentLsn
LOCAL lcIBMDb2SettingsDatabaseName
LOCAL lnMaxKBytesPerRead
LOCAL lcIBMDb2SettingsPassword
LOCAL lnIBMDb2SettingsPort
LOCAL lcIBMDb2SettingsSecretsManagerAccessRoleArn
LOCAL lcIBMDb2SettingsSecretsManagerSecretId
LOCAL lcIBMDb2SettingsServerName
LOCAL lnSetDataCaptureChanges
LOCAL lcIBMDb2SettingsUsername
LOCAL lcBroker
LOCAL lnIncludeControlDetails
LOCAL lnIncludeNullAndEmpty
LOCAL lnIncludePartitionValue
LOCAL lnIncludeTableAlterOperations
LOCAL lnIncludeTransactionDetails
LOCAL lcMessageFormat
LOCAL lnMessageMaxBytes
LOCAL lnNoHexPrefix
LOCAL lnPartitionIncludeSchemaTable
LOCAL lcSaslPassword
LOCAL lcSaslUsername
LOCAL lcSecurityProtocol
LOCAL lcSslCaCertificateArn
LOCAL lcSslClientCertificateArn
LOCAL lcSslClientKeyArn
LOCAL lcSslClientKeyPassword
LOCAL lcTopic
LOCAL lnKinesisSettingsIncludeControlDetails
LOCAL lnKinesisSettingsIncludeNullAndEmpty
LOCAL lnKinesisSettingsIncludePartitionValue
LOCAL lnKinesisSettingsIncludeTableAlterOperations
LOCAL lnKinesisSettingsIncludeTransactionDetails
LOCAL lcKinesisSettingsMessageFormat
LOCAL lnKinesisSettingsNoHexPrefix
LOCAL lnKinesisSettingsPartitionIncludeSchemaTable
LOCAL lcKinesisSettingsServiceAccessRoleArn
LOCAL lcStreamArn
LOCAL lcEndpointKmsKeyId
LOCAL lnBcpPacketSize
LOCAL lcControlTablesFileGroup
LOCAL lcMicrosoftSQLServerSettingsDatabaseName
LOCAL lcMicrosoftSQLServerSettingsPassword
LOCAL lnMicrosoftSQLServerSettingsPort
LOCAL lnQuerySingleAlwaysOnNode
LOCAL lnReadBackupOnly
LOCAL lcSafeguardPolicy
LOCAL lcMicrosoftSQLServerSettingsSecretsManagerAccessRoleArn
LOCAL lcMicrosoftSQLServerSettingsSecretsManagerSecretId
LOCAL lcMicrosoftSQLServerSettingsServerName
LOCAL lnUseBcpFullLoad
LOCAL lcMicrosoftSQLServerSettingsUsername
LOCAL lnUseThirdPartyBackupDevice
LOCAL lcAuthMechanism
LOCAL lcAuthSource
LOCAL lcAuthType
LOCAL lcMongoDbSettingsDatabaseName
LOCAL lcMongoDbSettingsDocsToInvestigate
LOCAL lcMongoDbSettingsExtractDocId
LOCAL lcMongoDbSettingsKmsKeyId
LOCAL lcMongoDbSettingsNestingLevel
LOCAL lcMongoDbSettingsPassword
LOCAL lnMongoDbSettingsPort
LOCAL lcMongoDbSettingsSecretsManagerAccessRoleArn
LOCAL lcMongoDbSettingsSecretsManagerSecretId
LOCAL lcMongoDbSettingsServerName
LOCAL lcMongoDbSettingsUsername
LOCAL lcMySQLSettingsAfterConnectScript
LOCAL lnMySQLSettingsCleanSourceMetadataOnMismatch
LOCAL lcMySQLSettingsDatabaseName
LOCAL lnMySQLSettingsEventsPollInterval
LOCAL lnMySQLSettingsMaxFileSize
LOCAL lnMySQLSettingsParallelLoadThreads
LOCAL lcMySQLSettingsPassword
LOCAL lnMySQLSettingsPort
LOCAL lcMySQLSettingsSecretsManagerAccessRoleArn
LOCAL lcMySQLSettingsSecretsManagerSecretId
LOCAL lcMySQLSettingsServerName
LOCAL lcMySQLSettingsServerTimezone
LOCAL lcMySQLSettingsTargetDbType
LOCAL lcMySQLSettingsUsername
LOCAL lnNeptuneSettingsErrorRetryDuration
LOCAL lnIamAuthEnabled
LOCAL lnNeptuneSettingsMaxFileSize
LOCAL lnMaxRetryCount
LOCAL lcS3BucketFolder
LOCAL lcS3BucketName
LOCAL lcNeptuneSettingsServiceAccessRoleArn
LOCAL lnAccessAlternateDirectly
LOCAL lnAdditionalArchivedLogDestId
LOCAL lnAddSupplementalLogging
LOCAL lnAllowSelectNestedTables
LOCAL lnArchivedLogDestId
LOCAL lnArchivedLogsOnly
LOCAL lcAsmPassword
LOCAL lcAsmServer
LOCAL lcAsmUser
LOCAL lcCharLengthSemantics
LOCAL lcOracleSettingsDatabaseName
LOCAL lnDirectPathNoLog
LOCAL lnDirectPathParallelLoad
LOCAL lnEnableHomogenousTablespace
LOCAL lnFailTasksOnLobTruncation
LOCAL lnNumberDatatypeScale
LOCAL lcOraclePathPrefix
LOCAL lnParallelAsmReadThreads
LOCAL lcOracleSettingsPassword
LOCAL lnOracleSettingsPort
LOCAL lnReadAheadBlocks
LOCAL lnReadTableSpaceName
LOCAL lnReplacePathPrefix
LOCAL lnRetryInterval
LOCAL lcOracleSettingsSecretsManagerAccessRoleArn
LOCAL lcSecretsManagerOracleAsmAccessRoleArn
LOCAL lcSecretsManagerOracleAsmSecretId
LOCAL lcOracleSettingsSecretsManagerSecretId
LOCAL lcSecurityDbEncryption
LOCAL lcSecurityDbEncryptionName
LOCAL lcOracleSettingsServerName
LOCAL lcSpatialDataOptionToGeoJsonFunctionName
LOCAL lnStandbyDelayTime
LOCAL lnUseAlternateFolderForOnline
LOCAL lnUseBFile
LOCAL lnUseDirectPathFullLoad
LOCAL lnUseLogminerReader
LOCAL lcUsePathPrefix
LOCAL lcOracleSettingsUsername
LOCAL lnEndpointPort
LOCAL lcPostgreSQLSettingsAfterConnectScript
LOCAL lnCaptureDdls
LOCAL lcPostgreSQLSettingsDatabaseName
LOCAL lcDdlArtifactsSchema
LOCAL lnExecuteTimeout
LOCAL lnPostgreSQLSettingsFailTasksOnLobTruncation
LOCAL lnHeartbeatEnable
LOCAL lnHeartbeatFrequency
LOCAL lcHeartbeatSchema
LOCAL lnPostgreSQLSettingsMaxFileSize
LOCAL lcPostgreSQLSettingsPassword
LOCAL lcPluginName
LOCAL lnPostgreSQLSettingsPort
LOCAL lcPostgreSQLSettingsSecretsManagerAccessRoleArn
LOCAL lcPostgreSQLSettingsSecretsManagerSecretId
LOCAL lcPostgreSQLSettingsServerName
LOCAL lcSlotName
LOCAL lcPostgreSQLSettingsUsername
LOCAL lcAuthPassword
LOCAL lcRedisSettingsAuthType
LOCAL lcAuthUserName
LOCAL lnRedisSettingsPort
LOCAL lcRedisSettingsServerName
LOCAL lcRedisSettingsSslCaCertificateArn
LOCAL lcSslSecurityProtocol
LOCAL lnAcceptAnyDate
LOCAL lcRedshiftSettingsAfterConnectScript
LOCAL lcBucketFolder
LOCAL lcRedshiftSettingsBucketName
LOCAL lnCaseSensitiveNames
LOCAL lnCompUpdate
LOCAL lnConnectionTimeout
LOCAL lcRedshiftSettingsDatabaseName
LOCAL lcDateFormat
LOCAL lnEmptyAsNull
LOCAL lcEncryptionMode
LOCAL lnExplicitIds
LOCAL lnFileTransferUploadStreams
LOCAL lnLoadTimeout
LOCAL lnRedshiftSettingsMaxFileSize
LOCAL lcRedshiftSettingsPassword
LOCAL lnRedshiftSettingsPort
LOCAL lnRemoveQuotes
LOCAL lcReplaceChars
LOCAL lcReplaceInvalidChars
LOCAL lcRedshiftSettingsSecretsManagerAccessRoleArn
LOCAL lcRedshiftSettingsSecretsManagerSecretId
LOCAL lcRedshiftSettingsServerName
LOCAL lcServerSideEncryptionKmsKeyId
LOCAL lcRedshiftSettingsServiceAccessRoleArn
LOCAL lcTimeFormat
LOCAL lnTrimBlanks
LOCAL lnTruncateColumns
LOCAL lcRedshiftSettingsUsername
LOCAL lnWriteBufferSize
LOCAL lnAddColumnName
LOCAL lcS3SettingsBucketFolder
LOCAL lcS3SettingsBucketName
LOCAL lcCannedAclForObjects
LOCAL lnCdcInsertsAndUpdates
LOCAL lnCdcInsertsOnly
LOCAL lnCdcMaxBatchInterval
LOCAL lnCdcMinFileSize
LOCAL lcCdcPath
LOCAL lcCompressionType
LOCAL lcCsvDelimiter
LOCAL lcCsvNoSupValue
LOCAL lcCsvNullValue
LOCAL lcCsvRowDelimiter
LOCAL lcDataFormat
LOCAL lnDataPageSize
LOCAL lcDatePartitionDelimiter
LOCAL lnDatePartitionEnabled
LOCAL lcDatePartitionSequence
LOCAL lcDatePartitionTimezone
LOCAL lnDictPageSizeLimit
LOCAL lnEnableStatistics
LOCAL lcEncodingType
LOCAL lcS3SettingsEncryptionMode
LOCAL lcS3SettingsExternalTableDefinition
LOCAL lnIgnoreHeaderRows
LOCAL lnIncludeOpForFullLoad
LOCAL lnS3SettingsMaxFileSize
LOCAL lnParquetTimestampInMillisecond
LOCAL lcParquetVersion
LOCAL lnPreserveTransactions
LOCAL lnRfc4180
LOCAL lnRowGroupLength
LOCAL lcS3SettingsServerSideEncryptionKmsKeyId
LOCAL lcS3SettingsServiceAccessRoleArn
LOCAL lcTimestampColumnName
LOCAL lnUseCsvNoSupValue
LOCAL lnUseTaskStartTimeForFullLoadTimestamp
LOCAL lcEndpointServerName
LOCAL lcEndpointServiceAccessRoleArn
LOCAL lcSslMode
LOCAL lcStatus
LOCAL lcSybaseSettingsDatabaseName
LOCAL lcSybaseSettingsPassword
LOCAL lnSybaseSettingsPort
LOCAL lcSybaseSettingsSecretsManagerAccessRoleArn
LOCAL lcSybaseSettingsSecretsManagerSecretId
LOCAL lcSybaseSettingsServerName
LOCAL lcSybaseSettingsUsername
LOCAL lcEndpointUsername
LOCAL i
LOCAL lnCount_i
* This example requires the Chilkat API to have been previously unlocked.
* See Global Unlock Sample for sample code.
loRest = CreateObject('Chilkat_9_5_0.Rest')
loAuthAws = CreateObject('Chilkat_9_5_0.AuthAws')
loAuthAws.AccessKey = "AWS_ACCESS_KEY"
loAuthAws.SecretKey = "AWS_SECRET_KEY"
* Don't forget to change the region to your particular region. (Also make the same change in the call to Connect below.)
loAuthAws.Region = "us-west-2"
loAuthAws.ServiceName = "dms"
* SetAuthAws causes Chilkat to automatically add the following headers: Authorization, X-Amz-Date
loRest.SetAuthAws(loAuthAws)
* URL: https://dms.us-west-2.amazonaws.com/
* Use the same region as specified above.
lnSuccess = loRest.Connect("dms.us-west-2.amazonaws.com",443,1,1)
IF (lnSuccess <> 1) THEN
? "ConnectFailReason: " + STR(loRest.ConnectFailReason)
? loRest.LastErrorText
RELEASE loRest
RELEASE loAuthAws
CANCEL
ENDIF
* The following code creates the JSON request body.
* The JSON created by this code is shown below.
* Use this online tool to generate code from sample JSON:
* Generate Code to Create JSON
loJson = CreateObject('Chilkat_9_5_0.JsonObject')
loJson.UpdateString("EndpointArn","string")
* The JSON request body created by the above code:
* {
* "EndpointArn": "string"
* }
loRest.AddHeader("Content-Type","application/x-amz-json-1.1")
loRest.AddHeader("X-Amz-Target","AmazonDMSv20160101.DeleteEndpoint")
loSbRequestBody = CreateObject('Chilkat_9_5_0.StringBuilder')
loJson.EmitSb(loSbRequestBody)
loSbResponseBody = CreateObject('Chilkat_9_5_0.StringBuilder')
lnSuccess = loRest.FullRequestSb("POST","/",loSbRequestBody,loSbResponseBody)
IF (lnSuccess <> 1) THEN
? loRest.LastErrorText
RELEASE loRest
RELEASE loAuthAws
RELEASE loJson
RELEASE loSbRequestBody
RELEASE loSbResponseBody
CANCEL
ENDIF
lnRespStatusCode = loRest.ResponseStatusCode
? "response status code = " + STR(lnRespStatusCode)
IF (lnRespStatusCode <> 200) THEN
? "Response Header:"
? loRest.ResponseHeader
? "Response Body:"
? loSbResponseBody.GetAsString()
RELEASE loRest
RELEASE loAuthAws
RELEASE loJson
RELEASE loSbRequestBody
RELEASE loSbResponseBody
CANCEL
ENDIF
loJResp = CreateObject('Chilkat_9_5_0.JsonObject')
loJResp.LoadSb(loSbResponseBody)
* The following code parses the JSON response.
* A sample JSON response is shown below the sample code.
* Use this online tool to generate parsing code from sample JSON:
* Generate Parsing Code from JSON
lcCertificateArn = loJResp.StringOf("Endpoint.CertificateArn")
lcDatabaseName = loJResp.StringOf("Endpoint.DatabaseName")
lcBucketName = loJResp.StringOf("Endpoint.DmsTransferSettings.BucketName")
lcServiceAccessRoleArn = loJResp.StringOf("Endpoint.DmsTransferSettings.ServiceAccessRoleArn")
lcDocDbSettingsDatabaseName = loJResp.StringOf("Endpoint.DocDbSettings.DatabaseName")
lnDocsToInvestigate = loJResp.IntOf("Endpoint.DocDbSettings.DocsToInvestigate")
lnExtractDocId = loJResp.IntOf("Endpoint.DocDbSettings.ExtractDocId")
lcKmsKeyId = loJResp.StringOf("Endpoint.DocDbSettings.KmsKeyId")
lcNestingLevel = loJResp.StringOf("Endpoint.DocDbSettings.NestingLevel")
lcPassword = loJResp.StringOf("Endpoint.DocDbSettings.Password")
lnPort = loJResp.IntOf("Endpoint.DocDbSettings.Port")
lcSecretsManagerAccessRoleArn = loJResp.StringOf("Endpoint.DocDbSettings.SecretsManagerAccessRoleArn")
lcSecretsManagerSecretId = loJResp.StringOf("Endpoint.DocDbSettings.SecretsManagerSecretId")
lcServerName = loJResp.StringOf("Endpoint.DocDbSettings.ServerName")
lcUsername = loJResp.StringOf("Endpoint.DocDbSettings.Username")
lcDynamoDbSettingsServiceAccessRoleArn = loJResp.StringOf("Endpoint.DynamoDbSettings.ServiceAccessRoleArn")
lcEndpointUri = loJResp.StringOf("Endpoint.ElasticsearchSettings.EndpointUri")
lnErrorRetryDuration = loJResp.IntOf("Endpoint.ElasticsearchSettings.ErrorRetryDuration")
lnFullLoadErrorPercentage = loJResp.IntOf("Endpoint.ElasticsearchSettings.FullLoadErrorPercentage")
lcElasticsearchSettingsServiceAccessRoleArn = loJResp.StringOf("Endpoint.ElasticsearchSettings.ServiceAccessRoleArn")
lcEndpointArn = loJResp.StringOf("Endpoint.EndpointArn")
lcEndpointIdentifier = loJResp.StringOf("Endpoint.EndpointIdentifier")
lcEndpointType = loJResp.StringOf("Endpoint.EndpointType")
lcEngineDisplayName = loJResp.StringOf("Endpoint.EngineDisplayName")
lcEngineName = loJResp.StringOf("Endpoint.EngineName")
lcExternalId = loJResp.StringOf("Endpoint.ExternalId")
lcExternalTableDefinition = loJResp.StringOf("Endpoint.ExternalTableDefinition")
lcExtraConnectionAttributes = loJResp.StringOf("Endpoint.ExtraConnectionAttributes")
lcAfterConnectScript = loJResp.StringOf("Endpoint.GcpMySQLSettings.AfterConnectScript")
lnCleanSourceMetadataOnMismatch = loJResp.IntOf("Endpoint.GcpMySQLSettings.CleanSourceMetadataOnMismatch")
lcGcpMySQLSettingsDatabaseName = loJResp.StringOf("Endpoint.GcpMySQLSettings.DatabaseName")
lnEventsPollInterval = loJResp.IntOf("Endpoint.GcpMySQLSettings.EventsPollInterval")
lnMaxFileSize = loJResp.IntOf("Endpoint.GcpMySQLSettings.MaxFileSize")
lnParallelLoadThreads = loJResp.IntOf("Endpoint.GcpMySQLSettings.ParallelLoadThreads")
lcGcpMySQLSettingsPassword = loJResp.StringOf("Endpoint.GcpMySQLSettings.Password")
lnGcpMySQLSettingsPort = loJResp.IntOf("Endpoint.GcpMySQLSettings.Port")
lcGcpMySQLSettingsSecretsManagerAccessRoleArn = loJResp.StringOf("Endpoint.GcpMySQLSettings.SecretsManagerAccessRoleArn")
lcGcpMySQLSettingsSecretsManagerSecretId = loJResp.StringOf("Endpoint.GcpMySQLSettings.SecretsManagerSecretId")
lcGcpMySQLSettingsServerName = loJResp.StringOf("Endpoint.GcpMySQLSettings.ServerName")
lcServerTimezone = loJResp.StringOf("Endpoint.GcpMySQLSettings.ServerTimezone")
lcTargetDbType = loJResp.StringOf("Endpoint.GcpMySQLSettings.TargetDbType")
lcGcpMySQLSettingsUsername = loJResp.StringOf("Endpoint.GcpMySQLSettings.Username")
lcCurrentLsn = loJResp.StringOf("Endpoint.IBMDb2Settings.CurrentLsn")
lcIBMDb2SettingsDatabaseName = loJResp.StringOf("Endpoint.IBMDb2Settings.DatabaseName")
lnMaxKBytesPerRead = loJResp.IntOf("Endpoint.IBMDb2Settings.MaxKBytesPerRead")
lcIBMDb2SettingsPassword = loJResp.StringOf("Endpoint.IBMDb2Settings.Password")
lnIBMDb2SettingsPort = loJResp.IntOf("Endpoint.IBMDb2Settings.Port")
lcIBMDb2SettingsSecretsManagerAccessRoleArn = loJResp.StringOf("Endpoint.IBMDb2Settings.SecretsManagerAccessRoleArn")
lcIBMDb2SettingsSecretsManagerSecretId = loJResp.StringOf("Endpoint.IBMDb2Settings.SecretsManagerSecretId")
lcIBMDb2SettingsServerName = loJResp.StringOf("Endpoint.IBMDb2Settings.ServerName")
lnSetDataCaptureChanges = loJResp.IntOf("Endpoint.IBMDb2Settings.SetDataCaptureChanges")
lcIBMDb2SettingsUsername = loJResp.StringOf("Endpoint.IBMDb2Settings.Username")
lcBroker = loJResp.StringOf("Endpoint.KafkaSettings.Broker")
lnIncludeControlDetails = loJResp.IntOf("Endpoint.KafkaSettings.IncludeControlDetails")
lnIncludeNullAndEmpty = loJResp.IntOf("Endpoint.KafkaSettings.IncludeNullAndEmpty")
lnIncludePartitionValue = loJResp.IntOf("Endpoint.KafkaSettings.IncludePartitionValue")
lnIncludeTableAlterOperations = loJResp.IntOf("Endpoint.KafkaSettings.IncludeTableAlterOperations")
lnIncludeTransactionDetails = loJResp.IntOf("Endpoint.KafkaSettings.IncludeTransactionDetails")
lcMessageFormat = loJResp.StringOf("Endpoint.KafkaSettings.MessageFormat")
lnMessageMaxBytes = loJResp.IntOf("Endpoint.KafkaSettings.MessageMaxBytes")
lnNoHexPrefix = loJResp.IntOf("Endpoint.KafkaSettings.NoHexPrefix")
lnPartitionIncludeSchemaTable = loJResp.IntOf("Endpoint.KafkaSettings.PartitionIncludeSchemaTable")
lcSaslPassword = loJResp.StringOf("Endpoint.KafkaSettings.SaslPassword")
lcSaslUsername = loJResp.StringOf("Endpoint.KafkaSettings.SaslUsername")
lcSecurityProtocol = loJResp.StringOf("Endpoint.KafkaSettings.SecurityProtocol")
lcSslCaCertificateArn = loJResp.StringOf("Endpoint.KafkaSettings.SslCaCertificateArn")
lcSslClientCertificateArn = loJResp.StringOf("Endpoint.KafkaSettings.SslClientCertificateArn")
lcSslClientKeyArn = loJResp.StringOf("Endpoint.KafkaSettings.SslClientKeyArn")
lcSslClientKeyPassword = loJResp.StringOf("Endpoint.KafkaSettings.SslClientKeyPassword")
lcTopic = loJResp.StringOf("Endpoint.KafkaSettings.Topic")
lnKinesisSettingsIncludeControlDetails = loJResp.IntOf("Endpoint.KinesisSettings.IncludeControlDetails")
lnKinesisSettingsIncludeNullAndEmpty = loJResp.IntOf("Endpoint.KinesisSettings.IncludeNullAndEmpty")
lnKinesisSettingsIncludePartitionValue = loJResp.IntOf("Endpoint.KinesisSettings.IncludePartitionValue")
lnKinesisSettingsIncludeTableAlterOperations = loJResp.IntOf("Endpoint.KinesisSettings.IncludeTableAlterOperations")
lnKinesisSettingsIncludeTransactionDetails = loJResp.IntOf("Endpoint.KinesisSettings.IncludeTransactionDetails")
lcKinesisSettingsMessageFormat = loJResp.StringOf("Endpoint.KinesisSettings.MessageFormat")
lnKinesisSettingsNoHexPrefix = loJResp.IntOf("Endpoint.KinesisSettings.NoHexPrefix")
lnKinesisSettingsPartitionIncludeSchemaTable = loJResp.IntOf("Endpoint.KinesisSettings.PartitionIncludeSchemaTable")
lcKinesisSettingsServiceAccessRoleArn = loJResp.StringOf("Endpoint.KinesisSettings.ServiceAccessRoleArn")
lcStreamArn = loJResp.StringOf("Endpoint.KinesisSettings.StreamArn")
lcEndpointKmsKeyId = loJResp.StringOf("Endpoint.KmsKeyId")
lnBcpPacketSize = loJResp.IntOf("Endpoint.MicrosoftSQLServerSettings.BcpPacketSize")
lcControlTablesFileGroup = loJResp.StringOf("Endpoint.MicrosoftSQLServerSettings.ControlTablesFileGroup")
lcMicrosoftSQLServerSettingsDatabaseName = loJResp.StringOf("Endpoint.MicrosoftSQLServerSettings.DatabaseName")
lcMicrosoftSQLServerSettingsPassword = loJResp.StringOf("Endpoint.MicrosoftSQLServerSettings.Password")
lnMicrosoftSQLServerSettingsPort = loJResp.IntOf("Endpoint.MicrosoftSQLServerSettings.Port")
lnQuerySingleAlwaysOnNode = loJResp.IntOf("Endpoint.MicrosoftSQLServerSettings.QuerySingleAlwaysOnNode")
lnReadBackupOnly = loJResp.IntOf("Endpoint.MicrosoftSQLServerSettings.ReadBackupOnly")
lcSafeguardPolicy = loJResp.StringOf("Endpoint.MicrosoftSQLServerSettings.SafeguardPolicy")
lcMicrosoftSQLServerSettingsSecretsManagerAccessRoleArn = loJResp.StringOf("Endpoint.MicrosoftSQLServerSettings.SecretsManagerAccessRoleArn")
lcMicrosoftSQLServerSettingsSecretsManagerSecretId = loJResp.StringOf("Endpoint.MicrosoftSQLServerSettings.SecretsManagerSecretId")
lcMicrosoftSQLServerSettingsServerName = loJResp.StringOf("Endpoint.MicrosoftSQLServerSettings.ServerName")
lnUseBcpFullLoad = loJResp.IntOf("Endpoint.MicrosoftSQLServerSettings.UseBcpFullLoad")
lcMicrosoftSQLServerSettingsUsername = loJResp.StringOf("Endpoint.MicrosoftSQLServerSettings.Username")
lnUseThirdPartyBackupDevice = loJResp.IntOf("Endpoint.MicrosoftSQLServerSettings.UseThirdPartyBackupDevice")
lcAuthMechanism = loJResp.StringOf("Endpoint.MongoDbSettings.AuthMechanism")
lcAuthSource = loJResp.StringOf("Endpoint.MongoDbSettings.AuthSource")
lcAuthType = loJResp.StringOf("Endpoint.MongoDbSettings.AuthType")
lcMongoDbSettingsDatabaseName = loJResp.StringOf("Endpoint.MongoDbSettings.DatabaseName")
lcMongoDbSettingsDocsToInvestigate = loJResp.StringOf("Endpoint.MongoDbSettings.DocsToInvestigate")
lcMongoDbSettingsExtractDocId = loJResp.StringOf("Endpoint.MongoDbSettings.ExtractDocId")
lcMongoDbSettingsKmsKeyId = loJResp.StringOf("Endpoint.MongoDbSettings.KmsKeyId")
lcMongoDbSettingsNestingLevel = loJResp.StringOf("Endpoint.MongoDbSettings.NestingLevel")
lcMongoDbSettingsPassword = loJResp.StringOf("Endpoint.MongoDbSettings.Password")
lnMongoDbSettingsPort = loJResp.IntOf("Endpoint.MongoDbSettings.Port")
lcMongoDbSettingsSecretsManagerAccessRoleArn = loJResp.StringOf("Endpoint.MongoDbSettings.SecretsManagerAccessRoleArn")
lcMongoDbSettingsSecretsManagerSecretId = loJResp.StringOf("Endpoint.MongoDbSettings.SecretsManagerSecretId")
lcMongoDbSettingsServerName = loJResp.StringOf("Endpoint.MongoDbSettings.ServerName")
lcMongoDbSettingsUsername = loJResp.StringOf("Endpoint.MongoDbSettings.Username")
lcMySQLSettingsAfterConnectScript = loJResp.StringOf("Endpoint.MySQLSettings.AfterConnectScript")
lnMySQLSettingsCleanSourceMetadataOnMismatch = loJResp.IntOf("Endpoint.MySQLSettings.CleanSourceMetadataOnMismatch")
lcMySQLSettingsDatabaseName = loJResp.StringOf("Endpoint.MySQLSettings.DatabaseName")
lnMySQLSettingsEventsPollInterval = loJResp.IntOf("Endpoint.MySQLSettings.EventsPollInterval")
lnMySQLSettingsMaxFileSize = loJResp.IntOf("Endpoint.MySQLSettings.MaxFileSize")
lnMySQLSettingsParallelLoadThreads = loJResp.IntOf("Endpoint.MySQLSettings.ParallelLoadThreads")
lcMySQLSettingsPassword = loJResp.StringOf("Endpoint.MySQLSettings.Password")
lnMySQLSettingsPort = loJResp.IntOf("Endpoint.MySQLSettings.Port")
lcMySQLSettingsSecretsManagerAccessRoleArn = loJResp.StringOf("Endpoint.MySQLSettings.SecretsManagerAccessRoleArn")
lcMySQLSettingsSecretsManagerSecretId = loJResp.StringOf("Endpoint.MySQLSettings.SecretsManagerSecretId")
lcMySQLSettingsServerName = loJResp.StringOf("Endpoint.MySQLSettings.ServerName")
lcMySQLSettingsServerTimezone = loJResp.StringOf("Endpoint.MySQLSettings.ServerTimezone")
lcMySQLSettingsTargetDbType = loJResp.StringOf("Endpoint.MySQLSettings.TargetDbType")
lcMySQLSettingsUsername = loJResp.StringOf("Endpoint.MySQLSettings.Username")
lnNeptuneSettingsErrorRetryDuration = loJResp.IntOf("Endpoint.NeptuneSettings.ErrorRetryDuration")
lnIamAuthEnabled = loJResp.IntOf("Endpoint.NeptuneSettings.IamAuthEnabled")
lnNeptuneSettingsMaxFileSize = loJResp.IntOf("Endpoint.NeptuneSettings.MaxFileSize")
lnMaxRetryCount = loJResp.IntOf("Endpoint.NeptuneSettings.MaxRetryCount")
lcS3BucketFolder = loJResp.StringOf("Endpoint.NeptuneSettings.S3BucketFolder")
lcS3BucketName = loJResp.StringOf("Endpoint.NeptuneSettings.S3BucketName")
lcNeptuneSettingsServiceAccessRoleArn = loJResp.StringOf("Endpoint.NeptuneSettings.ServiceAccessRoleArn")
lnAccessAlternateDirectly = loJResp.IntOf("Endpoint.OracleSettings.AccessAlternateDirectly")
lnAdditionalArchivedLogDestId = loJResp.IntOf("Endpoint.OracleSettings.AdditionalArchivedLogDestId")
lnAddSupplementalLogging = loJResp.IntOf("Endpoint.OracleSettings.AddSupplementalLogging")
lnAllowSelectNestedTables = loJResp.IntOf("Endpoint.OracleSettings.AllowSelectNestedTables")
lnArchivedLogDestId = loJResp.IntOf("Endpoint.OracleSettings.ArchivedLogDestId")
lnArchivedLogsOnly = loJResp.IntOf("Endpoint.OracleSettings.ArchivedLogsOnly")
lcAsmPassword = loJResp.StringOf("Endpoint.OracleSettings.AsmPassword")
lcAsmServer = loJResp.StringOf("Endpoint.OracleSettings.AsmServer")
lcAsmUser = loJResp.StringOf("Endpoint.OracleSettings.AsmUser")
lcCharLengthSemantics = loJResp.StringOf("Endpoint.OracleSettings.CharLengthSemantics")
lcOracleSettingsDatabaseName = loJResp.StringOf("Endpoint.OracleSettings.DatabaseName")
lnDirectPathNoLog = loJResp.IntOf("Endpoint.OracleSettings.DirectPathNoLog")
lnDirectPathParallelLoad = loJResp.IntOf("Endpoint.OracleSettings.DirectPathParallelLoad")
lnEnableHomogenousTablespace = loJResp.IntOf("Endpoint.OracleSettings.EnableHomogenousTablespace")
lnFailTasksOnLobTruncation = loJResp.IntOf("Endpoint.OracleSettings.FailTasksOnLobTruncation")
lnNumberDatatypeScale = loJResp.IntOf("Endpoint.OracleSettings.NumberDatatypeScale")
lcOraclePathPrefix = loJResp.StringOf("Endpoint.OracleSettings.OraclePathPrefix")
lnParallelAsmReadThreads = loJResp.IntOf("Endpoint.OracleSettings.ParallelAsmReadThreads")
lcOracleSettingsPassword = loJResp.StringOf("Endpoint.OracleSettings.Password")
lnOracleSettingsPort = loJResp.IntOf("Endpoint.OracleSettings.Port")
lnReadAheadBlocks = loJResp.IntOf("Endpoint.OracleSettings.ReadAheadBlocks")
lnReadTableSpaceName = loJResp.IntOf("Endpoint.OracleSettings.ReadTableSpaceName")
lnReplacePathPrefix = loJResp.IntOf("Endpoint.OracleSettings.ReplacePathPrefix")
lnRetryInterval = loJResp.IntOf("Endpoint.OracleSettings.RetryInterval")
lcOracleSettingsSecretsManagerAccessRoleArn = loJResp.StringOf("Endpoint.OracleSettings.SecretsManagerAccessRoleArn")
lcSecretsManagerOracleAsmAccessRoleArn = loJResp.StringOf("Endpoint.OracleSettings.SecretsManagerOracleAsmAccessRoleArn")
lcSecretsManagerOracleAsmSecretId = loJResp.StringOf("Endpoint.OracleSettings.SecretsManagerOracleAsmSecretId")
lcOracleSettingsSecretsManagerSecretId = loJResp.StringOf("Endpoint.OracleSettings.SecretsManagerSecretId")
lcSecurityDbEncryption = loJResp.StringOf("Endpoint.OracleSettings.SecurityDbEncryption")
lcSecurityDbEncryptionName = loJResp.StringOf("Endpoint.OracleSettings.SecurityDbEncryptionName")
lcOracleSettingsServerName = loJResp.StringOf("Endpoint.OracleSettings.ServerName")
lcSpatialDataOptionToGeoJsonFunctionName = loJResp.StringOf("Endpoint.OracleSettings.SpatialDataOptionToGeoJsonFunctionName")
lnStandbyDelayTime = loJResp.IntOf("Endpoint.OracleSettings.StandbyDelayTime")
lnUseAlternateFolderForOnline = loJResp.IntOf("Endpoint.OracleSettings.UseAlternateFolderForOnline")
lnUseBFile = loJResp.IntOf("Endpoint.OracleSettings.UseBFile")
lnUseDirectPathFullLoad = loJResp.IntOf("Endpoint.OracleSettings.UseDirectPathFullLoad")
lnUseLogminerReader = loJResp.IntOf("Endpoint.OracleSettings.UseLogminerReader")
lcUsePathPrefix = loJResp.StringOf("Endpoint.OracleSettings.UsePathPrefix")
lcOracleSettingsUsername = loJResp.StringOf("Endpoint.OracleSettings.Username")
lnEndpointPort = loJResp.IntOf("Endpoint.Port")
lcPostgreSQLSettingsAfterConnectScript = loJResp.StringOf("Endpoint.PostgreSQLSettings.AfterConnectScript")
lnCaptureDdls = loJResp.IntOf("Endpoint.PostgreSQLSettings.CaptureDdls")
lcPostgreSQLSettingsDatabaseName = loJResp.StringOf("Endpoint.PostgreSQLSettings.DatabaseName")
lcDdlArtifactsSchema = loJResp.StringOf("Endpoint.PostgreSQLSettings.DdlArtifactsSchema")
lnExecuteTimeout = loJResp.IntOf("Endpoint.PostgreSQLSettings.ExecuteTimeout")
lnPostgreSQLSettingsFailTasksOnLobTruncation = loJResp.IntOf("Endpoint.PostgreSQLSettings.FailTasksOnLobTruncation")
lnHeartbeatEnable = loJResp.IntOf("Endpoint.PostgreSQLSettings.HeartbeatEnable")
lnHeartbeatFrequency = loJResp.IntOf("Endpoint.PostgreSQLSettings.HeartbeatFrequency")
lcHeartbeatSchema = loJResp.StringOf("Endpoint.PostgreSQLSettings.HeartbeatSchema")
lnPostgreSQLSettingsMaxFileSize = loJResp.IntOf("Endpoint.PostgreSQLSettings.MaxFileSize")
lcPostgreSQLSettingsPassword = loJResp.StringOf("Endpoint.PostgreSQLSettings.Password")
lcPluginName = loJResp.StringOf("Endpoint.PostgreSQLSettings.PluginName")
lnPostgreSQLSettingsPort = loJResp.IntOf("Endpoint.PostgreSQLSettings.Port")
lcPostgreSQLSettingsSecretsManagerAccessRoleArn = loJResp.StringOf("Endpoint.PostgreSQLSettings.SecretsManagerAccessRoleArn")
lcPostgreSQLSettingsSecretsManagerSecretId = loJResp.StringOf("Endpoint.PostgreSQLSettings.SecretsManagerSecretId")
lcPostgreSQLSettingsServerName = loJResp.StringOf("Endpoint.PostgreSQLSettings.ServerName")
lcSlotName = loJResp.StringOf("Endpoint.PostgreSQLSettings.SlotName")
lcPostgreSQLSettingsUsername = loJResp.StringOf("Endpoint.PostgreSQLSettings.Username")
lcAuthPassword = loJResp.StringOf("Endpoint.RedisSettings.AuthPassword")
lcRedisSettingsAuthType = loJResp.StringOf("Endpoint.RedisSettings.AuthType")
lcAuthUserName = loJResp.StringOf("Endpoint.RedisSettings.AuthUserName")
lnRedisSettingsPort = loJResp.IntOf("Endpoint.RedisSettings.Port")
lcRedisSettingsServerName = loJResp.StringOf("Endpoint.RedisSettings.ServerName")
lcRedisSettingsSslCaCertificateArn = loJResp.StringOf("Endpoint.RedisSettings.SslCaCertificateArn")
lcSslSecurityProtocol = loJResp.StringOf("Endpoint.RedisSettings.SslSecurityProtocol")
lnAcceptAnyDate = loJResp.IntOf("Endpoint.RedshiftSettings.AcceptAnyDate")
lcRedshiftSettingsAfterConnectScript = loJResp.StringOf("Endpoint.RedshiftSettings.AfterConnectScript")
lcBucketFolder = loJResp.StringOf("Endpoint.RedshiftSettings.BucketFolder")
lcRedshiftSettingsBucketName = loJResp.StringOf("Endpoint.RedshiftSettings.BucketName")
lnCaseSensitiveNames = loJResp.IntOf("Endpoint.RedshiftSettings.CaseSensitiveNames")
lnCompUpdate = loJResp.IntOf("Endpoint.RedshiftSettings.CompUpdate")
lnConnectionTimeout = loJResp.IntOf("Endpoint.RedshiftSettings.ConnectionTimeout")
lcRedshiftSettingsDatabaseName = loJResp.StringOf("Endpoint.RedshiftSettings.DatabaseName")
lcDateFormat = loJResp.StringOf("Endpoint.RedshiftSettings.DateFormat")
lnEmptyAsNull = loJResp.IntOf("Endpoint.RedshiftSettings.EmptyAsNull")
lcEncryptionMode = loJResp.StringOf("Endpoint.RedshiftSettings.EncryptionMode")
lnExplicitIds = loJResp.IntOf("Endpoint.RedshiftSettings.ExplicitIds")
lnFileTransferUploadStreams = loJResp.IntOf("Endpoint.RedshiftSettings.FileTransferUploadStreams")
lnLoadTimeout = loJResp.IntOf("Endpoint.RedshiftSettings.LoadTimeout")
lnRedshiftSettingsMaxFileSize = loJResp.IntOf("Endpoint.RedshiftSettings.MaxFileSize")
lcRedshiftSettingsPassword = loJResp.StringOf("Endpoint.RedshiftSettings.Password")
lnRedshiftSettingsPort = loJResp.IntOf("Endpoint.RedshiftSettings.Port")
lnRemoveQuotes = loJResp.IntOf("Endpoint.RedshiftSettings.RemoveQuotes")
lcReplaceChars = loJResp.StringOf("Endpoint.RedshiftSettings.ReplaceChars")
lcReplaceInvalidChars = loJResp.StringOf("Endpoint.RedshiftSettings.ReplaceInvalidChars")
lcRedshiftSettingsSecretsManagerAccessRoleArn = loJResp.StringOf("Endpoint.RedshiftSettings.SecretsManagerAccessRoleArn")
lcRedshiftSettingsSecretsManagerSecretId = loJResp.StringOf("Endpoint.RedshiftSettings.SecretsManagerSecretId")
lcRedshiftSettingsServerName = loJResp.StringOf("Endpoint.RedshiftSettings.ServerName")
lcServerSideEncryptionKmsKeyId = loJResp.StringOf("Endpoint.RedshiftSettings.ServerSideEncryptionKmsKeyId")
lcRedshiftSettingsServiceAccessRoleArn = loJResp.StringOf("Endpoint.RedshiftSettings.ServiceAccessRoleArn")
lcTimeFormat = loJResp.StringOf("Endpoint.RedshiftSettings.TimeFormat")
lnTrimBlanks = loJResp.IntOf("Endpoint.RedshiftSettings.TrimBlanks")
lnTruncateColumns = loJResp.IntOf("Endpoint.RedshiftSettings.TruncateColumns")
lcRedshiftSettingsUsername = loJResp.StringOf("Endpoint.RedshiftSettings.Username")
lnWriteBufferSize = loJResp.IntOf("Endpoint.RedshiftSettings.WriteBufferSize")
lnAddColumnName = loJResp.IntOf("Endpoint.S3Settings.AddColumnName")
lcS3SettingsBucketFolder = loJResp.StringOf("Endpoint.S3Settings.BucketFolder")
lcS3SettingsBucketName = loJResp.StringOf("Endpoint.S3Settings.BucketName")
lcCannedAclForObjects = loJResp.StringOf("Endpoint.S3Settings.CannedAclForObjects")
lnCdcInsertsAndUpdates = loJResp.IntOf("Endpoint.S3Settings.CdcInsertsAndUpdates")
lnCdcInsertsOnly = loJResp.IntOf("Endpoint.S3Settings.CdcInsertsOnly")
lnCdcMaxBatchInterval = loJResp.IntOf("Endpoint.S3Settings.CdcMaxBatchInterval")
lnCdcMinFileSize = loJResp.IntOf("Endpoint.S3Settings.CdcMinFileSize")
lcCdcPath = loJResp.StringOf("Endpoint.S3Settings.CdcPath")
lcCompressionType = loJResp.StringOf("Endpoint.S3Settings.CompressionType")
lcCsvDelimiter = loJResp.StringOf("Endpoint.S3Settings.CsvDelimiter")
lcCsvNoSupValue = loJResp.StringOf("Endpoint.S3Settings.CsvNoSupValue")
lcCsvNullValue = loJResp.StringOf("Endpoint.S3Settings.CsvNullValue")
lcCsvRowDelimiter = loJResp.StringOf("Endpoint.S3Settings.CsvRowDelimiter")
lcDataFormat = loJResp.StringOf("Endpoint.S3Settings.DataFormat")
lnDataPageSize = loJResp.IntOf("Endpoint.S3Settings.DataPageSize")
lcDatePartitionDelimiter = loJResp.StringOf("Endpoint.S3Settings.DatePartitionDelimiter")
lnDatePartitionEnabled = loJResp.IntOf("Endpoint.S3Settings.DatePartitionEnabled")
lcDatePartitionSequence = loJResp.StringOf("Endpoint.S3Settings.DatePartitionSequence")
lcDatePartitionTimezone = loJResp.StringOf("Endpoint.S3Settings.DatePartitionTimezone")
lnDictPageSizeLimit = loJResp.IntOf("Endpoint.S3Settings.DictPageSizeLimit")
lnEnableStatistics = loJResp.IntOf("Endpoint.S3Settings.EnableStatistics")
lcEncodingType = loJResp.StringOf("Endpoint.S3Settings.EncodingType")
lcS3SettingsEncryptionMode = loJResp.StringOf("Endpoint.S3Settings.EncryptionMode")
lcS3SettingsExternalTableDefinition = loJResp.StringOf("Endpoint.S3Settings.ExternalTableDefinition")
lnIgnoreHeaderRows = loJResp.IntOf("Endpoint.S3Settings.IgnoreHeaderRows")
lnIncludeOpForFullLoad = loJResp.IntOf("Endpoint.S3Settings.IncludeOpForFullLoad")
lnS3SettingsMaxFileSize = loJResp.IntOf("Endpoint.S3Settings.MaxFileSize")
lnParquetTimestampInMillisecond = loJResp.IntOf("Endpoint.S3Settings.ParquetTimestampInMillisecond")
lcParquetVersion = loJResp.StringOf("Endpoint.S3Settings.ParquetVersion")
lnPreserveTransactions = loJResp.IntOf("Endpoint.S3Settings.PreserveTransactions")
lnRfc4180 = loJResp.IntOf("Endpoint.S3Settings.Rfc4180")
lnRowGroupLength = loJResp.IntOf("Endpoint.S3Settings.RowGroupLength")
lcS3SettingsServerSideEncryptionKmsKeyId = loJResp.StringOf("Endpoint.S3Settings.ServerSideEncryptionKmsKeyId")
lcS3SettingsServiceAccessRoleArn = loJResp.StringOf("Endpoint.S3Settings.ServiceAccessRoleArn")
lcTimestampColumnName = loJResp.StringOf("Endpoint.S3Settings.TimestampColumnName")
lnUseCsvNoSupValue = loJResp.IntOf("Endpoint.S3Settings.UseCsvNoSupValue")
lnUseTaskStartTimeForFullLoadTimestamp = loJResp.IntOf("Endpoint.S3Settings.UseTaskStartTimeForFullLoadTimestamp")
lcEndpointServerName = loJResp.StringOf("Endpoint.ServerName")
lcEndpointServiceAccessRoleArn = loJResp.StringOf("Endpoint.ServiceAccessRoleArn")
lcSslMode = loJResp.StringOf("Endpoint.SslMode")
lcStatus = loJResp.StringOf("Endpoint.Status")
lcSybaseSettingsDatabaseName = loJResp.StringOf("Endpoint.SybaseSettings.DatabaseName")
lcSybaseSettingsPassword = loJResp.StringOf("Endpoint.SybaseSettings.Password")
lnSybaseSettingsPort = loJResp.IntOf("Endpoint.SybaseSettings.Port")
lcSybaseSettingsSecretsManagerAccessRoleArn = loJResp.StringOf("Endpoint.SybaseSettings.SecretsManagerAccessRoleArn")
lcSybaseSettingsSecretsManagerSecretId = loJResp.StringOf("Endpoint.SybaseSettings.SecretsManagerSecretId")
lcSybaseSettingsServerName = loJResp.StringOf("Endpoint.SybaseSettings.ServerName")
lcSybaseSettingsUsername = loJResp.StringOf("Endpoint.SybaseSettings.Username")
lcEndpointUsername = loJResp.StringOf("Endpoint.Username")
i = 0
lnCount_i = loJResp.SizeOfArray("Endpoint.OracleSettings.ExtraArchivedLogDestIds")
DO WHILE i < lnCount_i
loJResp.I = i
lnIntVal = loJResp.IntOf("Endpoint.OracleSettings.ExtraArchivedLogDestIds[i]")
i = i + 1
ENDDO
* A sample JSON response body parsed by the above code:
* {
* "Endpoint": {
* "CertificateArn": "string",
* "DatabaseName": "string",
* "DmsTransferSettings": {
* "BucketName": "string",
* "ServiceAccessRoleArn": "string"
* },
* "DocDbSettings": {
* "DatabaseName": "string",
* "DocsToInvestigate": number,
* "ExtractDocId": boolean,
* "KmsKeyId": "string",
* "NestingLevel": "string",
* "Password": "string",
* "Port": number,
* "SecretsManagerAccessRoleArn": "string",
* "SecretsManagerSecretId": "string",
* "ServerName": "string",
* "Username": "string"
* },
* "DynamoDbSettings": {
* "ServiceAccessRoleArn": "string"
* },
* "ElasticsearchSettings": {
* "EndpointUri": "string",
* "ErrorRetryDuration": number,
* "FullLoadErrorPercentage": number,
* "ServiceAccessRoleArn": "string"
* },
* "EndpointArn": "string",
* "EndpointIdentifier": "string",
* "EndpointType": "string",
* "EngineDisplayName": "string",
* "EngineName": "string",
* "ExternalId": "string",
* "ExternalTableDefinition": "string",
* "ExtraConnectionAttributes": "string",
* "GcpMySQLSettings": {
* "AfterConnectScript": "string",
* "CleanSourceMetadataOnMismatch": boolean,
* "DatabaseName": "string",
* "EventsPollInterval": number,
* "MaxFileSize": number,
* "ParallelLoadThreads": number,
* "Password": "string",
* "Port": number,
* "SecretsManagerAccessRoleArn": "string",
* "SecretsManagerSecretId": "string",
* "ServerName": "string",
* "ServerTimezone": "string",
* "TargetDbType": "string",
* "Username": "string"
* },
* "IBMDb2Settings": {
* "CurrentLsn": "string",
* "DatabaseName": "string",
* "MaxKBytesPerRead": number,
* "Password": "string",
* "Port": number,
* "SecretsManagerAccessRoleArn": "string",
* "SecretsManagerSecretId": "string",
* "ServerName": "string",
* "SetDataCaptureChanges": boolean,
* "Username": "string"
* },
* "KafkaSettings": {
* "Broker": "string",
* "IncludeControlDetails": boolean,
* "IncludeNullAndEmpty": boolean,
* "IncludePartitionValue": boolean,
* "IncludeTableAlterOperations": boolean,
* "IncludeTransactionDetails": boolean,
* "MessageFormat": "string",
* "MessageMaxBytes": number,
* "NoHexPrefix": boolean,
* "PartitionIncludeSchemaTable": boolean,
* "SaslPassword": "string",
* "SaslUsername": "string",
* "SecurityProtocol": "string",
* "SslCaCertificateArn": "string",
* "SslClientCertificateArn": "string",
* "SslClientKeyArn": "string",
* "SslClientKeyPassword": "string",
* "Topic": "string"
* },
* "KinesisSettings": {
* "IncludeControlDetails": boolean,
* "IncludeNullAndEmpty": boolean,
* "IncludePartitionValue": boolean,
* "IncludeTableAlterOperations": boolean,
* "IncludeTransactionDetails": boolean,
* "MessageFormat": "string",
* "NoHexPrefix": boolean,
* "PartitionIncludeSchemaTable": boolean,
* "ServiceAccessRoleArn": "string",
* "StreamArn": "string"
* },
* "KmsKeyId": "string",
* "MicrosoftSQLServerSettings": {
* "BcpPacketSize": number,
* "ControlTablesFileGroup": "string",
* "DatabaseName": "string",
* "Password": "string",
* "Port": number,
* "QuerySingleAlwaysOnNode": boolean,
* "ReadBackupOnly": boolean,
* "SafeguardPolicy": "string",
* "SecretsManagerAccessRoleArn": "string",
* "SecretsManagerSecretId": "string",
* "ServerName": "string",
* "UseBcpFullLoad": boolean,
* "Username": "string",
* "UseThirdPartyBackupDevice": boolean
* },
* "MongoDbSettings": {
* "AuthMechanism": "string",
* "AuthSource": "string",
* "AuthType": "string",
* "DatabaseName": "string",
* "DocsToInvestigate": "string",
* "ExtractDocId": "string",
* "KmsKeyId": "string",
* "NestingLevel": "string",
* "Password": "string",
* "Port": number,
* "SecretsManagerAccessRoleArn": "string",
* "SecretsManagerSecretId": "string",
* "ServerName": "string",
* "Username": "string"
* },
* "MySQLSettings": {
* "AfterConnectScript": "string",
* "CleanSourceMetadataOnMismatch": boolean,
* "DatabaseName": "string",
* "EventsPollInterval": number,
* "MaxFileSize": number,
* "ParallelLoadThreads": number,
* "Password": "string",
* "Port": number,
* "SecretsManagerAccessRoleArn": "string",
* "SecretsManagerSecretId": "string",
* "ServerName": "string",
* "ServerTimezone": "string",
* "TargetDbType": "string",
* "Username": "string"
* },
* "NeptuneSettings": {
* "ErrorRetryDuration": number,
* "IamAuthEnabled": boolean,
* "MaxFileSize": number,
* "MaxRetryCount": number,
* "S3BucketFolder": "string",
* "S3BucketName": "string",
* "ServiceAccessRoleArn": "string"
* },
* "OracleSettings": {
* "AccessAlternateDirectly": boolean,
* "AdditionalArchivedLogDestId": number,
* "AddSupplementalLogging": boolean,
* "AllowSelectNestedTables": boolean,
* "ArchivedLogDestId": number,
* "ArchivedLogsOnly": boolean,
* "AsmPassword": "string",
* "AsmServer": "string",
* "AsmUser": "string",
* "CharLengthSemantics": "string",
* "DatabaseName": "string",
* "DirectPathNoLog": boolean,
* "DirectPathParallelLoad": boolean,
* "EnableHomogenousTablespace": boolean,
* "ExtraArchivedLogDestIds": [
* number
* ],
* "FailTasksOnLobTruncation": boolean,
* "NumberDatatypeScale": number,
* "OraclePathPrefix": "string",
* "ParallelAsmReadThreads": number,
* "Password": "string",
* "Port": number,
* "ReadAheadBlocks": number,
* "ReadTableSpaceName": boolean,
* "ReplacePathPrefix": boolean,
* "RetryInterval": number,
* "SecretsManagerAccessRoleArn": "string",
* "SecretsManagerOracleAsmAccessRoleArn": "string",
* "SecretsManagerOracleAsmSecretId": "string",
* "SecretsManagerSecretId": "string",
* "SecurityDbEncryption": "string",
* "SecurityDbEncryptionName": "string",
* "ServerName": "string",
* "SpatialDataOptionToGeoJsonFunctionName": "string",
* "StandbyDelayTime": number,
* "UseAlternateFolderForOnline": boolean,
* "UseBFile": boolean,
* "UseDirectPathFullLoad": boolean,
* "UseLogminerReader": boolean,
* "UsePathPrefix": "string",
* "Username": "string"
* },
* "Port": number,
* "PostgreSQLSettings": {
* "AfterConnectScript": "string",
* "CaptureDdls": boolean,
* "DatabaseName": "string",
* "DdlArtifactsSchema": "string",
* "ExecuteTimeout": number,
* "FailTasksOnLobTruncation": boolean,
* "HeartbeatEnable": boolean,
* "HeartbeatFrequency": number,
* "HeartbeatSchema": "string",
* "MaxFileSize": number,
* "Password": "string",
* "PluginName": "string",
* "Port": number,
* "SecretsManagerAccessRoleArn": "string",
* "SecretsManagerSecretId": "string",
* "ServerName": "string",
* "SlotName": "string",
* "Username": "string"
* },
* "RedisSettings": {
* "AuthPassword": "string",
* "AuthType": "string",
* "AuthUserName": "string",
* "Port": number,
* "ServerName": "string",
* "SslCaCertificateArn": "string",
* "SslSecurityProtocol": "string"
* },
* "RedshiftSettings": {
* "AcceptAnyDate": boolean,
* "AfterConnectScript": "string",
* "BucketFolder": "string",
* "BucketName": "string",
* "CaseSensitiveNames": boolean,
* "CompUpdate": boolean,
* "ConnectionTimeout": number,
* "DatabaseName": "string",
* "DateFormat": "string",
* "EmptyAsNull": boolean,
* "EncryptionMode": "string",
* "ExplicitIds": boolean,
* "FileTransferUploadStreams": number,
* "LoadTimeout": number,
* "MaxFileSize": number,
* "Password": "string",
* "Port": number,
* "RemoveQuotes": boolean,
* "ReplaceChars": "string",
* "ReplaceInvalidChars": "string",
* "SecretsManagerAccessRoleArn": "string",
* "SecretsManagerSecretId": "string",
* "ServerName": "string",
* "ServerSideEncryptionKmsKeyId": "string",
* "ServiceAccessRoleArn": "string",
* "TimeFormat": "string",
* "TrimBlanks": boolean,
* "TruncateColumns": boolean,
* "Username": "string",
* "WriteBufferSize": number
* },
* "S3Settings": {
* "AddColumnName": boolean,
* "BucketFolder": "string",
* "BucketName": "string",
* "CannedAclForObjects": "string",
* "CdcInsertsAndUpdates": boolean,
* "CdcInsertsOnly": boolean,
* "CdcMaxBatchInterval": number,
* "CdcMinFileSize": number,
* "CdcPath": "string",
* "CompressionType": "string",
* "CsvDelimiter": "string",
* "CsvNoSupValue": "string",
* "CsvNullValue": "string",
* "CsvRowDelimiter": "string",
* "DataFormat": "string",
* "DataPageSize": number,
* "DatePartitionDelimiter": "string",
* "DatePartitionEnabled": boolean,
* "DatePartitionSequence": "string",
* "DatePartitionTimezone": "string",
* "DictPageSizeLimit": number,
* "EnableStatistics": boolean,
* "EncodingType": "string",
* "EncryptionMode": "string",
* "ExternalTableDefinition": "string",
* "IgnoreHeaderRows": number,
* "IncludeOpForFullLoad": boolean,
* "MaxFileSize": number,
* "ParquetTimestampInMillisecond": boolean,
* "ParquetVersion": "string",
* "PreserveTransactions": boolean,
* "Rfc4180": boolean,
* "RowGroupLength": number,
* "ServerSideEncryptionKmsKeyId": "string",
* "ServiceAccessRoleArn": "string",
* "TimestampColumnName": "string",
* "UseCsvNoSupValue": boolean,
* "UseTaskStartTimeForFullLoadTimestamp": boolean
* },
* "ServerName": "string",
* "ServiceAccessRoleArn": "string",
* "SslMode": "string",
* "Status": "string",
* "SybaseSettings": {
* "DatabaseName": "string",
* "Password": "string",
* "Port": number,
* "SecretsManagerAccessRoleArn": "string",
* "SecretsManagerSecretId": "string",
* "ServerName": "string",
* "Username": "string"
* },
* "Username": "string"
* }
* }
RELEASE loRest
RELEASE loAuthAws
RELEASE loJson
RELEASE loSbRequestBody
RELEASE loSbResponseBody
RELEASE loJResp
