CreateEndpoint Xojo Example
// This example requires the Chilkat API to have been previously unlocked.
// See Global Unlock Sample for sample code.
Dim rest As New Chilkat.Rest
Dim success As Boolean
Dim authAws As New Chilkat.AuthAws
authAws.AccessKey = "AWS_ACCESS_KEY"
authAws.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.)
authAws.Region = "us-west-2"
authAws.ServiceName = "dms"
// SetAuthAws causes Chilkat to automatically add the following headers: Authorization, X-Amz-Date
success = rest.SetAuthAws(authAws)
// URL: https://dms.us-west-2.amazonaws.com/
// Use the same region as specified above.
success = rest.Connect("dms.us-west-2.amazonaws.com",443,True,True)
If (success <> True) Then
System.DebugLog("ConnectFailReason: " + Str(rest.ConnectFailReason))
System.DebugLog(rest.LastErrorText)
Return
End If
// 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
Dim json As New Chilkat.JsonObject
success = json.UpdateString("CertificateArn","string")
success = json.UpdateString("DatabaseName","string")
success = json.UpdateString("DmsTransferSettings.BucketName","string")
success = json.UpdateString("DmsTransferSettings.ServiceAccessRoleArn","string")
success = json.UpdateString("DocDbSettings.DatabaseName","string")
success = json.UpdateInt("DocDbSettings.DocsToInvestigate",123)
success = json.UpdateInt("DocDbSettings.ExtractDocId",123)
success = json.UpdateString("DocDbSettings.KmsKeyId","string")
success = json.UpdateString("DocDbSettings.NestingLevel","string")
success = json.UpdateString("DocDbSettings.Password","string")
success = json.UpdateInt("DocDbSettings.Port",123)
success = json.UpdateString("DocDbSettings.SecretsManagerAccessRoleArn","string")
success = json.UpdateString("DocDbSettings.SecretsManagerSecretId","string")
success = json.UpdateString("DocDbSettings.ServerName","string")
success = json.UpdateString("DocDbSettings.Username","string")
success = json.UpdateString("DynamoDbSettings.ServiceAccessRoleArn","string")
success = json.UpdateString("ElasticsearchSettings.EndpointUri","string")
success = json.UpdateInt("ElasticsearchSettings.ErrorRetryDuration",123)
success = json.UpdateInt("ElasticsearchSettings.FullLoadErrorPercentage",123)
success = json.UpdateString("ElasticsearchSettings.ServiceAccessRoleArn","string")
success = json.UpdateString("EndpointIdentifier","string")
success = json.UpdateString("EndpointType","string")
success = json.UpdateString("EngineName","string")
success = json.UpdateString("ExternalTableDefinition","string")
success = json.UpdateString("ExtraConnectionAttributes","string")
success = json.UpdateString("GcpMySQLSettings.AfterConnectScript","string")
success = json.UpdateInt("GcpMySQLSettings.CleanSourceMetadataOnMismatch",123)
success = json.UpdateString("GcpMySQLSettings.DatabaseName","string")
success = json.UpdateInt("GcpMySQLSettings.EventsPollInterval",123)
success = json.UpdateInt("GcpMySQLSettings.MaxFileSize",123)
success = json.UpdateInt("GcpMySQLSettings.ParallelLoadThreads",123)
success = json.UpdateString("GcpMySQLSettings.Password","string")
success = json.UpdateInt("GcpMySQLSettings.Port",123)
success = json.UpdateString("GcpMySQLSettings.SecretsManagerAccessRoleArn","string")
success = json.UpdateString("GcpMySQLSettings.SecretsManagerSecretId","string")
success = json.UpdateString("GcpMySQLSettings.ServerName","string")
success = json.UpdateString("GcpMySQLSettings.ServerTimezone","string")
success = json.UpdateString("GcpMySQLSettings.TargetDbType","string")
success = json.UpdateString("GcpMySQLSettings.Username","string")
success = json.UpdateString("IBMDb2Settings.CurrentLsn","string")
success = json.UpdateString("IBMDb2Settings.DatabaseName","string")
success = json.UpdateInt("IBMDb2Settings.MaxKBytesPerRead",123)
success = json.UpdateString("IBMDb2Settings.Password","string")
success = json.UpdateInt("IBMDb2Settings.Port",123)
success = json.UpdateString("IBMDb2Settings.SecretsManagerAccessRoleArn","string")
success = json.UpdateString("IBMDb2Settings.SecretsManagerSecretId","string")
success = json.UpdateString("IBMDb2Settings.ServerName","string")
success = json.UpdateInt("IBMDb2Settings.SetDataCaptureChanges",123)
success = json.UpdateString("IBMDb2Settings.Username","string")
success = json.UpdateString("KafkaSettings.Broker","string")
success = json.UpdateInt("KafkaSettings.IncludeControlDetails",123)
success = json.UpdateInt("KafkaSettings.IncludeNullAndEmpty",123)
success = json.UpdateInt("KafkaSettings.IncludePartitionValue",123)
success = json.UpdateInt("KafkaSettings.IncludeTableAlterOperations",123)
success = json.UpdateInt("KafkaSettings.IncludeTransactionDetails",123)
success = json.UpdateString("KafkaSettings.MessageFormat","string")
success = json.UpdateInt("KafkaSettings.MessageMaxBytes",123)
success = json.UpdateInt("KafkaSettings.NoHexPrefix",123)
success = json.UpdateInt("KafkaSettings.PartitionIncludeSchemaTable",123)
success = json.UpdateString("KafkaSettings.SaslPassword","string")
success = json.UpdateString("KafkaSettings.SaslUsername","string")
success = json.UpdateString("KafkaSettings.SecurityProtocol","string")
success = json.UpdateString("KafkaSettings.SslCaCertificateArn","string")
success = json.UpdateString("KafkaSettings.SslClientCertificateArn","string")
success = json.UpdateString("KafkaSettings.SslClientKeyArn","string")
success = json.UpdateString("KafkaSettings.SslClientKeyPassword","string")
success = json.UpdateString("KafkaSettings.Topic","string")
success = json.UpdateInt("KinesisSettings.IncludeControlDetails",123)
success = json.UpdateInt("KinesisSettings.IncludeNullAndEmpty",123)
success = json.UpdateInt("KinesisSettings.IncludePartitionValue",123)
success = json.UpdateInt("KinesisSettings.IncludeTableAlterOperations",123)
success = json.UpdateInt("KinesisSettings.IncludeTransactionDetails",123)
success = json.UpdateString("KinesisSettings.MessageFormat","string")
success = json.UpdateInt("KinesisSettings.NoHexPrefix",123)
success = json.UpdateInt("KinesisSettings.PartitionIncludeSchemaTable",123)
success = json.UpdateString("KinesisSettings.ServiceAccessRoleArn","string")
success = json.UpdateString("KinesisSettings.StreamArn","string")
success = json.UpdateString("KmsKeyId","string")
success = json.UpdateInt("MicrosoftSQLServerSettings.BcpPacketSize",123)
success = json.UpdateString("MicrosoftSQLServerSettings.ControlTablesFileGroup","string")
success = json.UpdateString("MicrosoftSQLServerSettings.DatabaseName","string")
success = json.UpdateString("MicrosoftSQLServerSettings.Password","string")
success = json.UpdateInt("MicrosoftSQLServerSettings.Port",123)
success = json.UpdateInt("MicrosoftSQLServerSettings.QuerySingleAlwaysOnNode",123)
success = json.UpdateInt("MicrosoftSQLServerSettings.ReadBackupOnly",123)
success = json.UpdateString("MicrosoftSQLServerSettings.SafeguardPolicy","string")
success = json.UpdateString("MicrosoftSQLServerSettings.SecretsManagerAccessRoleArn","string")
success = json.UpdateString("MicrosoftSQLServerSettings.SecretsManagerSecretId","string")
success = json.UpdateString("MicrosoftSQLServerSettings.ServerName","string")
success = json.UpdateInt("MicrosoftSQLServerSettings.UseBcpFullLoad",123)
success = json.UpdateString("MicrosoftSQLServerSettings.Username","string")
success = json.UpdateInt("MicrosoftSQLServerSettings.UseThirdPartyBackupDevice",123)
success = json.UpdateString("MongoDbSettings.AuthMechanism","string")
success = json.UpdateString("MongoDbSettings.AuthSource","string")
success = json.UpdateString("MongoDbSettings.AuthType","string")
success = json.UpdateString("MongoDbSettings.DatabaseName","string")
success = json.UpdateString("MongoDbSettings.DocsToInvestigate","string")
success = json.UpdateString("MongoDbSettings.ExtractDocId","string")
success = json.UpdateString("MongoDbSettings.KmsKeyId","string")
success = json.UpdateString("MongoDbSettings.NestingLevel","string")
success = json.UpdateString("MongoDbSettings.Password","string")
success = json.UpdateInt("MongoDbSettings.Port",123)
success = json.UpdateString("MongoDbSettings.SecretsManagerAccessRoleArn","string")
success = json.UpdateString("MongoDbSettings.SecretsManagerSecretId","string")
success = json.UpdateString("MongoDbSettings.ServerName","string")
success = json.UpdateString("MongoDbSettings.Username","string")
success = json.UpdateString("MySQLSettings.AfterConnectScript","string")
success = json.UpdateInt("MySQLSettings.CleanSourceMetadataOnMismatch",123)
success = json.UpdateString("MySQLSettings.DatabaseName","string")
success = json.UpdateInt("MySQLSettings.EventsPollInterval",123)
success = json.UpdateInt("MySQLSettings.MaxFileSize",123)
success = json.UpdateInt("MySQLSettings.ParallelLoadThreads",123)
success = json.UpdateString("MySQLSettings.Password","string")
success = json.UpdateInt("MySQLSettings.Port",123)
success = json.UpdateString("MySQLSettings.SecretsManagerAccessRoleArn","string")
success = json.UpdateString("MySQLSettings.SecretsManagerSecretId","string")
success = json.UpdateString("MySQLSettings.ServerName","string")
success = json.UpdateString("MySQLSettings.ServerTimezone","string")
success = json.UpdateString("MySQLSettings.TargetDbType","string")
success = json.UpdateString("MySQLSettings.Username","string")
success = json.UpdateInt("NeptuneSettings.ErrorRetryDuration",123)
success = json.UpdateInt("NeptuneSettings.IamAuthEnabled",123)
success = json.UpdateInt("NeptuneSettings.MaxFileSize",123)
success = json.UpdateInt("NeptuneSettings.MaxRetryCount",123)
success = json.UpdateString("NeptuneSettings.S3BucketFolder","string")
success = json.UpdateString("NeptuneSettings.S3BucketName","string")
success = json.UpdateString("NeptuneSettings.ServiceAccessRoleArn","string")
success = json.UpdateInt("OracleSettings.AccessAlternateDirectly",123)
success = json.UpdateInt("OracleSettings.AdditionalArchivedLogDestId",123)
success = json.UpdateInt("OracleSettings.AddSupplementalLogging",123)
success = json.UpdateInt("OracleSettings.AllowSelectNestedTables",123)
success = json.UpdateInt("OracleSettings.ArchivedLogDestId",123)
success = json.UpdateInt("OracleSettings.ArchivedLogsOnly",123)
success = json.UpdateString("OracleSettings.AsmPassword","string")
success = json.UpdateString("OracleSettings.AsmServer","string")
success = json.UpdateString("OracleSettings.AsmUser","string")
success = json.UpdateString("OracleSettings.CharLengthSemantics","string")
success = json.UpdateString("OracleSettings.DatabaseName","string")
success = json.UpdateInt("OracleSettings.DirectPathNoLog",123)
success = json.UpdateInt("OracleSettings.DirectPathParallelLoad",123)
success = json.UpdateInt("OracleSettings.EnableHomogenousTablespace",123)
ERROR: Undefined variable(number)
ERROR: Undefined variable(number)
ERROR: Undefined variable(number)
ERROR: Undefined variable(number)
ERROR: Undefined variable(number)
ERROR: Undefined variable(number)
ERROR: Undefined variable(number)
success = json.UpdateInt("OracleSettings.ExtraArchivedLogDestIds[0]",number)ERROR: Undefined variable(number)
success = json.UpdateInt("OracleSettings.FailTasksOnLobTruncation",123)
success = json.UpdateInt("OracleSettings.NumberDatatypeScale",123)
success = json.UpdateString("OracleSettings.OraclePathPrefix","string")
success = json.UpdateInt("OracleSettings.ParallelAsmReadThreads",123)
success = json.UpdateString("OracleSettings.Password","string")
success = json.UpdateInt("OracleSettings.Port",123)
success = json.UpdateInt("OracleSettings.ReadAheadBlocks",123)
success = json.UpdateInt("OracleSettings.ReadTableSpaceName",123)
success = json.UpdateInt("OracleSettings.ReplacePathPrefix",123)
success = json.UpdateInt("OracleSettings.RetryInterval",123)
success = json.UpdateString("OracleSettings.SecretsManagerAccessRoleArn","string")
success = json.UpdateString("OracleSettings.SecretsManagerOracleAsmAccessRoleArn","string")
success = json.UpdateString("OracleSettings.SecretsManagerOracleAsmSecretId","string")
success = json.UpdateString("OracleSettings.SecretsManagerSecretId","string")
success = json.UpdateString("OracleSettings.SecurityDbEncryption","string")
success = json.UpdateString("OracleSettings.SecurityDbEncryptionName","string")
success = json.UpdateString("OracleSettings.ServerName","string")
success = json.UpdateString("OracleSettings.SpatialDataOptionToGeoJsonFunctionName","string")
success = json.UpdateInt("OracleSettings.StandbyDelayTime",123)
success = json.UpdateInt("OracleSettings.UseAlternateFolderForOnline",123)
success = json.UpdateInt("OracleSettings.UseBFile",123)
success = json.UpdateInt("OracleSettings.UseDirectPathFullLoad",123)
success = json.UpdateInt("OracleSettings.UseLogminerReader",123)
success = json.UpdateString("OracleSettings.UsePathPrefix","string")
success = json.UpdateString("OracleSettings.Username","string")
success = json.UpdateString("Password","string")
success = json.UpdateInt("Port",123)
success = json.UpdateString("PostgreSQLSettings.AfterConnectScript","string")
success = json.UpdateInt("PostgreSQLSettings.CaptureDdls",123)
success = json.UpdateString("PostgreSQLSettings.DatabaseName","string")
success = json.UpdateString("PostgreSQLSettings.DdlArtifactsSchema","string")
success = json.UpdateInt("PostgreSQLSettings.ExecuteTimeout",123)
success = json.UpdateInt("PostgreSQLSettings.FailTasksOnLobTruncation",123)
success = json.UpdateInt("PostgreSQLSettings.HeartbeatEnable",123)
success = json.UpdateInt("PostgreSQLSettings.HeartbeatFrequency",123)
success = json.UpdateString("PostgreSQLSettings.HeartbeatSchema","string")
success = json.UpdateInt("PostgreSQLSettings.MaxFileSize",123)
success = json.UpdateString("PostgreSQLSettings.Password","string")
success = json.UpdateString("PostgreSQLSettings.PluginName","string")
success = json.UpdateInt("PostgreSQLSettings.Port",123)
success = json.UpdateString("PostgreSQLSettings.SecretsManagerAccessRoleArn","string")
success = json.UpdateString("PostgreSQLSettings.SecretsManagerSecretId","string")
success = json.UpdateString("PostgreSQLSettings.ServerName","string")
success = json.UpdateString("PostgreSQLSettings.SlotName","string")
success = json.UpdateString("PostgreSQLSettings.Username","string")
success = json.UpdateString("RedisSettings.AuthPassword","string")
success = json.UpdateString("RedisSettings.AuthType","string")
success = json.UpdateString("RedisSettings.AuthUserName","string")
success = json.UpdateInt("RedisSettings.Port",123)
success = json.UpdateString("RedisSettings.ServerName","string")
success = json.UpdateString("RedisSettings.SslCaCertificateArn","string")
success = json.UpdateString("RedisSettings.SslSecurityProtocol","string")
success = json.UpdateInt("RedshiftSettings.AcceptAnyDate",123)
success = json.UpdateString("RedshiftSettings.AfterConnectScript","string")
success = json.UpdateString("RedshiftSettings.BucketFolder","string")
success = json.UpdateString("RedshiftSettings.BucketName","string")
success = json.UpdateInt("RedshiftSettings.CaseSensitiveNames",123)
success = json.UpdateInt("RedshiftSettings.CompUpdate",123)
success = json.UpdateInt("RedshiftSettings.ConnectionTimeout",123)
success = json.UpdateString("RedshiftSettings.DatabaseName","string")
success = json.UpdateString("RedshiftSettings.DateFormat","string")
success = json.UpdateInt("RedshiftSettings.EmptyAsNull",123)
success = json.UpdateString("RedshiftSettings.EncryptionMode","string")
success = json.UpdateInt("RedshiftSettings.ExplicitIds",123)
success = json.UpdateInt("RedshiftSettings.FileTransferUploadStreams",123)
success = json.UpdateInt("RedshiftSettings.LoadTimeout",123)
success = json.UpdateInt("RedshiftSettings.MaxFileSize",123)
success = json.UpdateString("RedshiftSettings.Password","string")
success = json.UpdateInt("RedshiftSettings.Port",123)
success = json.UpdateInt("RedshiftSettings.RemoveQuotes",123)
success = json.UpdateString("RedshiftSettings.ReplaceChars","string")
success = json.UpdateString("RedshiftSettings.ReplaceInvalidChars","string")
success = json.UpdateString("RedshiftSettings.SecretsManagerAccessRoleArn","string")
success = json.UpdateString("RedshiftSettings.SecretsManagerSecretId","string")
success = json.UpdateString("RedshiftSettings.ServerName","string")
success = json.UpdateString("RedshiftSettings.ServerSideEncryptionKmsKeyId","string")
success = json.UpdateString("RedshiftSettings.ServiceAccessRoleArn","string")
success = json.UpdateString("RedshiftSettings.TimeFormat","string")
success = json.UpdateInt("RedshiftSettings.TrimBlanks",123)
success = json.UpdateInt("RedshiftSettings.TruncateColumns",123)
success = json.UpdateString("RedshiftSettings.Username","string")
success = json.UpdateInt("RedshiftSettings.WriteBufferSize",123)
success = json.UpdateString("ResourceIdentifier","string")
success = json.UpdateInt("S3Settings.AddColumnName",123)
success = json.UpdateString("S3Settings.BucketFolder","string")
success = json.UpdateString("S3Settings.BucketName","string")
success = json.UpdateString("S3Settings.CannedAclForObjects","string")
success = json.UpdateInt("S3Settings.CdcInsertsAndUpdates",123)
success = json.UpdateInt("S3Settings.CdcInsertsOnly",123)
success = json.UpdateInt("S3Settings.CdcMaxBatchInterval",123)
success = json.UpdateInt("S3Settings.CdcMinFileSize",123)
success = json.UpdateString("S3Settings.CdcPath","string")
success = json.UpdateString("S3Settings.CompressionType","string")
success = json.UpdateString("S3Settings.CsvDelimiter","string")
success = json.UpdateString("S3Settings.CsvNoSupValue","string")
success = json.UpdateString("S3Settings.CsvNullValue","string")
success = json.UpdateString("S3Settings.CsvRowDelimiter","string")
success = json.UpdateString("S3Settings.DataFormat","string")
success = json.UpdateInt("S3Settings.DataPageSize",123)
success = json.UpdateString("S3Settings.DatePartitionDelimiter","string")
success = json.UpdateInt("S3Settings.DatePartitionEnabled",123)
success = json.UpdateString("S3Settings.DatePartitionSequence","string")
success = json.UpdateString("S3Settings.DatePartitionTimezone","string")
success = json.UpdateInt("S3Settings.DictPageSizeLimit",123)
success = json.UpdateInt("S3Settings.EnableStatistics",123)
success = json.UpdateString("S3Settings.EncodingType","string")
success = json.UpdateString("S3Settings.EncryptionMode","string")
success = json.UpdateString("S3Settings.ExternalTableDefinition","string")
success = json.UpdateInt("S3Settings.IgnoreHeaderRows",123)
success = json.UpdateInt("S3Settings.IncludeOpForFullLoad",123)
success = json.UpdateInt("S3Settings.MaxFileSize",123)
success = json.UpdateInt("S3Settings.ParquetTimestampInMillisecond",123)
success = json.UpdateString("S3Settings.ParquetVersion","string")
success = json.UpdateInt("S3Settings.PreserveTransactions",123)
success = json.UpdateInt("S3Settings.Rfc4180",123)
success = json.UpdateInt("S3Settings.RowGroupLength",123)
success = json.UpdateString("S3Settings.ServerSideEncryptionKmsKeyId","string")
success = json.UpdateString("S3Settings.ServiceAccessRoleArn","string")
success = json.UpdateString("S3Settings.TimestampColumnName","string")
success = json.UpdateInt("S3Settings.UseCsvNoSupValue",123)
success = json.UpdateInt("S3Settings.UseTaskStartTimeForFullLoadTimestamp",123)
success = json.UpdateString("ServerName","string")
success = json.UpdateString("ServiceAccessRoleArn","string")
success = json.UpdateString("SslMode","string")
success = json.UpdateString("SybaseSettings.DatabaseName","string")
success = json.UpdateString("SybaseSettings.Password","string")
success = json.UpdateInt("SybaseSettings.Port",123)
success = json.UpdateString("SybaseSettings.SecretsManagerAccessRoleArn","string")
success = json.UpdateString("SybaseSettings.SecretsManagerSecretId","string")
success = json.UpdateString("SybaseSettings.ServerName","string")
success = json.UpdateString("SybaseSettings.Username","string")
success = json.UpdateString("Tags[0].Key","string")
success = json.UpdateString("Tags[0].ResourceArn","string")
success = json.UpdateString("Tags[0].Value","string")
success = json.UpdateString("Username","string")
// The JSON request body created by the above code:
// {
// "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"
// },
// "EndpointIdentifier": "string",
// "EndpointType": "string",
// "EngineName": "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"
// },
// "Password": "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
// },
// "ResourceIdentifier": "string",
// "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",
// "SybaseSettings": {
// "DatabaseName": "string",
// "Password": "string",
// "Port": number,
// "SecretsManagerAccessRoleArn": "string",
// "SecretsManagerSecretId": "string",
// "ServerName": "string",
// "Username": "string"
// },
// "Tags": [
// {
// "Key": "string",
// "ResourceArn": "string",
// "Value": "string"
// }
// ],
// "Username": "string"
// }
success = rest.AddHeader("Content-Type","application/x-amz-json-1.1")
success = rest.AddHeader("X-Amz-Target","AmazonDMSv20160101.CreateEndpoint")
Dim sbRequestBody As New Chilkat.StringBuilder
success = json.EmitSb(sbRequestBody)
Dim sbResponseBody As New Chilkat.StringBuilder
success = rest.FullRequestSb("POST","/",sbRequestBody,sbResponseBody)
If (success <> True) Then
System.DebugLog(rest.LastErrorText)
Return
End If
Dim respStatusCode As Int32
respStatusCode = rest.ResponseStatusCode
System.DebugLog("response status code = " + Str(respStatusCode))
If (respStatusCode <> 200) Then
System.DebugLog("Response Header:")
System.DebugLog(rest.ResponseHeader)
System.DebugLog("Response Body:")
System.DebugLog(sbResponseBody.GetAsString())
Return
End If
Dim jResp As New Chilkat.JsonObject
success = jResp.LoadSb(sbResponseBody)
// 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
Dim intVal As Int32
Dim CertificateArn As String
CertificateArn = jResp.StringOf("Endpoint.CertificateArn")
Dim DatabaseName As String
DatabaseName = jResp.StringOf("Endpoint.DatabaseName")
Dim BucketName As String
BucketName = jResp.StringOf("Endpoint.DmsTransferSettings.BucketName")
Dim ServiceAccessRoleArn As String
ServiceAccessRoleArn = jResp.StringOf("Endpoint.DmsTransferSettings.ServiceAccessRoleArn")
Dim DocDbSettingsDatabaseName As String
DocDbSettingsDatabaseName = jResp.StringOf("Endpoint.DocDbSettings.DatabaseName")
Dim DocsToInvestigate As Int32
DocsToInvestigate = jResp.IntOf("Endpoint.DocDbSettings.DocsToInvestigate")
Dim ExtractDocId As Int32
ExtractDocId = jResp.IntOf("Endpoint.DocDbSettings.ExtractDocId")
Dim KmsKeyId As String
KmsKeyId = jResp.StringOf("Endpoint.DocDbSettings.KmsKeyId")
Dim NestingLevel As String
NestingLevel = jResp.StringOf("Endpoint.DocDbSettings.NestingLevel")
Dim Password As String
Password = jResp.StringOf("Endpoint.DocDbSettings.Password")
Dim Port As Int32
Port = jResp.IntOf("Endpoint.DocDbSettings.Port")
Dim SecretsManagerAccessRoleArn As String
SecretsManagerAccessRoleArn = jResp.StringOf("Endpoint.DocDbSettings.SecretsManagerAccessRoleArn")
Dim SecretsManagerSecretId As String
SecretsManagerSecretId = jResp.StringOf("Endpoint.DocDbSettings.SecretsManagerSecretId")
Dim ServerName As String
ServerName = jResp.StringOf("Endpoint.DocDbSettings.ServerName")
Dim Username As String
Username = jResp.StringOf("Endpoint.DocDbSettings.Username")
Dim DynamoDbSettingsServiceAccessRoleArn As String
DynamoDbSettingsServiceAccessRoleArn = jResp.StringOf("Endpoint.DynamoDbSettings.ServiceAccessRoleArn")
Dim EndpointUri As String
EndpointUri = jResp.StringOf("Endpoint.ElasticsearchSettings.EndpointUri")
Dim ErrorRetryDuration As Int32
ErrorRetryDuration = jResp.IntOf("Endpoint.ElasticsearchSettings.ErrorRetryDuration")
Dim FullLoadErrorPercentage As Int32
FullLoadErrorPercentage = jResp.IntOf("Endpoint.ElasticsearchSettings.FullLoadErrorPercentage")
Dim ElasticsearchSettingsServiceAccessRoleArn As String
ElasticsearchSettingsServiceAccessRoleArn = jResp.StringOf("Endpoint.ElasticsearchSettings.ServiceAccessRoleArn")
Dim EndpointArn As String
EndpointArn = jResp.StringOf("Endpoint.EndpointArn")
Dim EndpointIdentifier As String
EndpointIdentifier = jResp.StringOf("Endpoint.EndpointIdentifier")
Dim EndpointType As String
EndpointType = jResp.StringOf("Endpoint.EndpointType")
Dim EngineDisplayName As String
EngineDisplayName = jResp.StringOf("Endpoint.EngineDisplayName")
Dim EngineName As String
EngineName = jResp.StringOf("Endpoint.EngineName")
Dim ExternalId As String
ExternalId = jResp.StringOf("Endpoint.ExternalId")
Dim ExternalTableDefinition As String
ExternalTableDefinition = jResp.StringOf("Endpoint.ExternalTableDefinition")
Dim ExtraConnectionAttributes As String
ExtraConnectionAttributes = jResp.StringOf("Endpoint.ExtraConnectionAttributes")
Dim AfterConnectScript As String
AfterConnectScript = jResp.StringOf("Endpoint.GcpMySQLSettings.AfterConnectScript")
Dim CleanSourceMetadataOnMismatch As Int32
CleanSourceMetadataOnMismatch = jResp.IntOf("Endpoint.GcpMySQLSettings.CleanSourceMetadataOnMismatch")
Dim GcpMySQLSettingsDatabaseName As String
GcpMySQLSettingsDatabaseName = jResp.StringOf("Endpoint.GcpMySQLSettings.DatabaseName")
Dim EventsPollInterval As Int32
EventsPollInterval = jResp.IntOf("Endpoint.GcpMySQLSettings.EventsPollInterval")
Dim MaxFileSize As Int32
MaxFileSize = jResp.IntOf("Endpoint.GcpMySQLSettings.MaxFileSize")
Dim ParallelLoadThreads As Int32
ParallelLoadThreads = jResp.IntOf("Endpoint.GcpMySQLSettings.ParallelLoadThreads")
Dim GcpMySQLSettingsPassword As String
GcpMySQLSettingsPassword = jResp.StringOf("Endpoint.GcpMySQLSettings.Password")
Dim GcpMySQLSettingsPort As Int32
GcpMySQLSettingsPort = jResp.IntOf("Endpoint.GcpMySQLSettings.Port")
Dim GcpMySQLSettingsSecretsManagerAccessRoleArn As String
GcpMySQLSettingsSecretsManagerAccessRoleArn = jResp.StringOf("Endpoint.GcpMySQLSettings.SecretsManagerAccessRoleArn")
Dim GcpMySQLSettingsSecretsManagerSecretId As String
GcpMySQLSettingsSecretsManagerSecretId = jResp.StringOf("Endpoint.GcpMySQLSettings.SecretsManagerSecretId")
Dim GcpMySQLSettingsServerName As String
GcpMySQLSettingsServerName = jResp.StringOf("Endpoint.GcpMySQLSettings.ServerName")
Dim ServerTimezone As String
ServerTimezone = jResp.StringOf("Endpoint.GcpMySQLSettings.ServerTimezone")
Dim TargetDbType As String
TargetDbType = jResp.StringOf("Endpoint.GcpMySQLSettings.TargetDbType")
Dim GcpMySQLSettingsUsername As String
GcpMySQLSettingsUsername = jResp.StringOf("Endpoint.GcpMySQLSettings.Username")
Dim CurrentLsn As String
CurrentLsn = jResp.StringOf("Endpoint.IBMDb2Settings.CurrentLsn")
Dim IBMDb2SettingsDatabaseName As String
IBMDb2SettingsDatabaseName = jResp.StringOf("Endpoint.IBMDb2Settings.DatabaseName")
Dim MaxKBytesPerRead As Int32
MaxKBytesPerRead = jResp.IntOf("Endpoint.IBMDb2Settings.MaxKBytesPerRead")
Dim IBMDb2SettingsPassword As String
IBMDb2SettingsPassword = jResp.StringOf("Endpoint.IBMDb2Settings.Password")
Dim IBMDb2SettingsPort As Int32
IBMDb2SettingsPort = jResp.IntOf("Endpoint.IBMDb2Settings.Port")
Dim IBMDb2SettingsSecretsManagerAccessRoleArn As String
IBMDb2SettingsSecretsManagerAccessRoleArn = jResp.StringOf("Endpoint.IBMDb2Settings.SecretsManagerAccessRoleArn")
Dim IBMDb2SettingsSecretsManagerSecretId As String
IBMDb2SettingsSecretsManagerSecretId = jResp.StringOf("Endpoint.IBMDb2Settings.SecretsManagerSecretId")
Dim IBMDb2SettingsServerName As String
IBMDb2SettingsServerName = jResp.StringOf("Endpoint.IBMDb2Settings.ServerName")
Dim SetDataCaptureChanges As Int32
SetDataCaptureChanges = jResp.IntOf("Endpoint.IBMDb2Settings.SetDataCaptureChanges")
Dim IBMDb2SettingsUsername As String
IBMDb2SettingsUsername = jResp.StringOf("Endpoint.IBMDb2Settings.Username")
Dim Broker As String
Broker = jResp.StringOf("Endpoint.KafkaSettings.Broker")
Dim IncludeControlDetails As Int32
IncludeControlDetails = jResp.IntOf("Endpoint.KafkaSettings.IncludeControlDetails")
Dim IncludeNullAndEmpty As Int32
IncludeNullAndEmpty = jResp.IntOf("Endpoint.KafkaSettings.IncludeNullAndEmpty")
Dim IncludePartitionValue As Int32
IncludePartitionValue = jResp.IntOf("Endpoint.KafkaSettings.IncludePartitionValue")
Dim IncludeTableAlterOperations As Int32
IncludeTableAlterOperations = jResp.IntOf("Endpoint.KafkaSettings.IncludeTableAlterOperations")
Dim IncludeTransactionDetails As Int32
IncludeTransactionDetails = jResp.IntOf("Endpoint.KafkaSettings.IncludeTransactionDetails")
Dim MessageFormat As String
MessageFormat = jResp.StringOf("Endpoint.KafkaSettings.MessageFormat")
Dim MessageMaxBytes As Int32
MessageMaxBytes = jResp.IntOf("Endpoint.KafkaSettings.MessageMaxBytes")
Dim NoHexPrefix As Int32
NoHexPrefix = jResp.IntOf("Endpoint.KafkaSettings.NoHexPrefix")
Dim PartitionIncludeSchemaTable As Int32
PartitionIncludeSchemaTable = jResp.IntOf("Endpoint.KafkaSettings.PartitionIncludeSchemaTable")
Dim SaslPassword As String
SaslPassword = jResp.StringOf("Endpoint.KafkaSettings.SaslPassword")
Dim SaslUsername As String
SaslUsername = jResp.StringOf("Endpoint.KafkaSettings.SaslUsername")
Dim SecurityProtocol As String
SecurityProtocol = jResp.StringOf("Endpoint.KafkaSettings.SecurityProtocol")
Dim SslCaCertificateArn As String
SslCaCertificateArn = jResp.StringOf("Endpoint.KafkaSettings.SslCaCertificateArn")
Dim SslClientCertificateArn As String
SslClientCertificateArn = jResp.StringOf("Endpoint.KafkaSettings.SslClientCertificateArn")
Dim SslClientKeyArn As String
SslClientKeyArn = jResp.StringOf("Endpoint.KafkaSettings.SslClientKeyArn")
Dim SslClientKeyPassword As String
SslClientKeyPassword = jResp.StringOf("Endpoint.KafkaSettings.SslClientKeyPassword")
Dim Topic As String
Topic = jResp.StringOf("Endpoint.KafkaSettings.Topic")
Dim KinesisSettingsIncludeControlDetails As Int32
KinesisSettingsIncludeControlDetails = jResp.IntOf("Endpoint.KinesisSettings.IncludeControlDetails")
Dim KinesisSettingsIncludeNullAndEmpty As Int32
KinesisSettingsIncludeNullAndEmpty = jResp.IntOf("Endpoint.KinesisSettings.IncludeNullAndEmpty")
Dim KinesisSettingsIncludePartitionValue As Int32
KinesisSettingsIncludePartitionValue = jResp.IntOf("Endpoint.KinesisSettings.IncludePartitionValue")
Dim KinesisSettingsIncludeTableAlterOperations As Int32
KinesisSettingsIncludeTableAlterOperations = jResp.IntOf("Endpoint.KinesisSettings.IncludeTableAlterOperations")
Dim KinesisSettingsIncludeTransactionDetails As Int32
KinesisSettingsIncludeTransactionDetails = jResp.IntOf("Endpoint.KinesisSettings.IncludeTransactionDetails")
Dim KinesisSettingsMessageFormat As String
KinesisSettingsMessageFormat = jResp.StringOf("Endpoint.KinesisSettings.MessageFormat")
Dim KinesisSettingsNoHexPrefix As Int32
KinesisSettingsNoHexPrefix = jResp.IntOf("Endpoint.KinesisSettings.NoHexPrefix")
Dim KinesisSettingsPartitionIncludeSchemaTable As Int32
KinesisSettingsPartitionIncludeSchemaTable = jResp.IntOf("Endpoint.KinesisSettings.PartitionIncludeSchemaTable")
Dim KinesisSettingsServiceAccessRoleArn As String
KinesisSettingsServiceAccessRoleArn = jResp.StringOf("Endpoint.KinesisSettings.ServiceAccessRoleArn")
Dim StreamArn As String
StreamArn = jResp.StringOf("Endpoint.KinesisSettings.StreamArn")
Dim EndpointKmsKeyId As String
EndpointKmsKeyId = jResp.StringOf("Endpoint.KmsKeyId")
Dim BcpPacketSize As Int32
BcpPacketSize = jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.BcpPacketSize")
Dim ControlTablesFileGroup As String
ControlTablesFileGroup = jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.ControlTablesFileGroup")
Dim MicrosoftSQLServerSettingsDatabaseName As String
MicrosoftSQLServerSettingsDatabaseName = jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.DatabaseName")
Dim MicrosoftSQLServerSettingsPassword As String
MicrosoftSQLServerSettingsPassword = jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.Password")
Dim MicrosoftSQLServerSettingsPort As Int32
MicrosoftSQLServerSettingsPort = jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.Port")
Dim QuerySingleAlwaysOnNode As Int32
QuerySingleAlwaysOnNode = jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.QuerySingleAlwaysOnNode")
Dim ReadBackupOnly As Int32
ReadBackupOnly = jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.ReadBackupOnly")
Dim SafeguardPolicy As String
SafeguardPolicy = jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.SafeguardPolicy")
Dim MicrosoftSQLServerSettingsSecretsManagerAccessRoleArn As String
MicrosoftSQLServerSettingsSecretsManagerAccessRoleArn = jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.SecretsManagerAccessRoleArn")
Dim MicrosoftSQLServerSettingsSecretsManagerSecretId As String
MicrosoftSQLServerSettingsSecretsManagerSecretId = jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.SecretsManagerSecretId")
Dim MicrosoftSQLServerSettingsServerName As String
MicrosoftSQLServerSettingsServerName = jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.ServerName")
Dim UseBcpFullLoad As Int32
UseBcpFullLoad = jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.UseBcpFullLoad")
Dim MicrosoftSQLServerSettingsUsername As String
MicrosoftSQLServerSettingsUsername = jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.Username")
Dim UseThirdPartyBackupDevice As Int32
UseThirdPartyBackupDevice = jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.UseThirdPartyBackupDevice")
Dim AuthMechanism As String
AuthMechanism = jResp.StringOf("Endpoint.MongoDbSettings.AuthMechanism")
Dim AuthSource As String
AuthSource = jResp.StringOf("Endpoint.MongoDbSettings.AuthSource")
Dim AuthType As String
AuthType = jResp.StringOf("Endpoint.MongoDbSettings.AuthType")
Dim MongoDbSettingsDatabaseName As String
MongoDbSettingsDatabaseName = jResp.StringOf("Endpoint.MongoDbSettings.DatabaseName")
Dim MongoDbSettingsDocsToInvestigate As String
MongoDbSettingsDocsToInvestigate = jResp.StringOf("Endpoint.MongoDbSettings.DocsToInvestigate")
Dim MongoDbSettingsExtractDocId As String
MongoDbSettingsExtractDocId = jResp.StringOf("Endpoint.MongoDbSettings.ExtractDocId")
Dim MongoDbSettingsKmsKeyId As String
MongoDbSettingsKmsKeyId = jResp.StringOf("Endpoint.MongoDbSettings.KmsKeyId")
Dim MongoDbSettingsNestingLevel As String
MongoDbSettingsNestingLevel = jResp.StringOf("Endpoint.MongoDbSettings.NestingLevel")
Dim MongoDbSettingsPassword As String
MongoDbSettingsPassword = jResp.StringOf("Endpoint.MongoDbSettings.Password")
Dim MongoDbSettingsPort As Int32
MongoDbSettingsPort = jResp.IntOf("Endpoint.MongoDbSettings.Port")
Dim MongoDbSettingsSecretsManagerAccessRoleArn As String
MongoDbSettingsSecretsManagerAccessRoleArn = jResp.StringOf("Endpoint.MongoDbSettings.SecretsManagerAccessRoleArn")
Dim MongoDbSettingsSecretsManagerSecretId As String
MongoDbSettingsSecretsManagerSecretId = jResp.StringOf("Endpoint.MongoDbSettings.SecretsManagerSecretId")
Dim MongoDbSettingsServerName As String
MongoDbSettingsServerName = jResp.StringOf("Endpoint.MongoDbSettings.ServerName")
Dim MongoDbSettingsUsername As String
MongoDbSettingsUsername = jResp.StringOf("Endpoint.MongoDbSettings.Username")
Dim MySQLSettingsAfterConnectScript As String
MySQLSettingsAfterConnectScript = jResp.StringOf("Endpoint.MySQLSettings.AfterConnectScript")
Dim MySQLSettingsCleanSourceMetadataOnMismatch As Int32
MySQLSettingsCleanSourceMetadataOnMismatch = jResp.IntOf("Endpoint.MySQLSettings.CleanSourceMetadataOnMismatch")
Dim MySQLSettingsDatabaseName As String
MySQLSettingsDatabaseName = jResp.StringOf("Endpoint.MySQLSettings.DatabaseName")
Dim MySQLSettingsEventsPollInterval As Int32
MySQLSettingsEventsPollInterval = jResp.IntOf("Endpoint.MySQLSettings.EventsPollInterval")
Dim MySQLSettingsMaxFileSize As Int32
MySQLSettingsMaxFileSize = jResp.IntOf("Endpoint.MySQLSettings.MaxFileSize")
Dim MySQLSettingsParallelLoadThreads As Int32
MySQLSettingsParallelLoadThreads = jResp.IntOf("Endpoint.MySQLSettings.ParallelLoadThreads")
Dim MySQLSettingsPassword As String
MySQLSettingsPassword = jResp.StringOf("Endpoint.MySQLSettings.Password")
Dim MySQLSettingsPort As Int32
MySQLSettingsPort = jResp.IntOf("Endpoint.MySQLSettings.Port")
Dim MySQLSettingsSecretsManagerAccessRoleArn As String
MySQLSettingsSecretsManagerAccessRoleArn = jResp.StringOf("Endpoint.MySQLSettings.SecretsManagerAccessRoleArn")
Dim MySQLSettingsSecretsManagerSecretId As String
MySQLSettingsSecretsManagerSecretId = jResp.StringOf("Endpoint.MySQLSettings.SecretsManagerSecretId")
Dim MySQLSettingsServerName As String
MySQLSettingsServerName = jResp.StringOf("Endpoint.MySQLSettings.ServerName")
Dim MySQLSettingsServerTimezone As String
MySQLSettingsServerTimezone = jResp.StringOf("Endpoint.MySQLSettings.ServerTimezone")
Dim MySQLSettingsTargetDbType As String
MySQLSettingsTargetDbType = jResp.StringOf("Endpoint.MySQLSettings.TargetDbType")
Dim MySQLSettingsUsername As String
MySQLSettingsUsername = jResp.StringOf("Endpoint.MySQLSettings.Username")
Dim NeptuneSettingsErrorRetryDuration As Int32
NeptuneSettingsErrorRetryDuration = jResp.IntOf("Endpoint.NeptuneSettings.ErrorRetryDuration")
Dim IamAuthEnabled As Int32
IamAuthEnabled = jResp.IntOf("Endpoint.NeptuneSettings.IamAuthEnabled")
Dim NeptuneSettingsMaxFileSize As Int32
NeptuneSettingsMaxFileSize = jResp.IntOf("Endpoint.NeptuneSettings.MaxFileSize")
Dim MaxRetryCount As Int32
MaxRetryCount = jResp.IntOf("Endpoint.NeptuneSettings.MaxRetryCount")
Dim S3BucketFolder As String
S3BucketFolder = jResp.StringOf("Endpoint.NeptuneSettings.S3BucketFolder")
Dim S3BucketName As String
S3BucketName = jResp.StringOf("Endpoint.NeptuneSettings.S3BucketName")
Dim NeptuneSettingsServiceAccessRoleArn As String
NeptuneSettingsServiceAccessRoleArn = jResp.StringOf("Endpoint.NeptuneSettings.ServiceAccessRoleArn")
Dim AccessAlternateDirectly As Int32
AccessAlternateDirectly = jResp.IntOf("Endpoint.OracleSettings.AccessAlternateDirectly")
Dim AdditionalArchivedLogDestId As Int32
AdditionalArchivedLogDestId = jResp.IntOf("Endpoint.OracleSettings.AdditionalArchivedLogDestId")
Dim AddSupplementalLogging As Int32
AddSupplementalLogging = jResp.IntOf("Endpoint.OracleSettings.AddSupplementalLogging")
Dim AllowSelectNestedTables As Int32
AllowSelectNestedTables = jResp.IntOf("Endpoint.OracleSettings.AllowSelectNestedTables")
Dim ArchivedLogDestId As Int32
ArchivedLogDestId = jResp.IntOf("Endpoint.OracleSettings.ArchivedLogDestId")
Dim ArchivedLogsOnly As Int32
ArchivedLogsOnly = jResp.IntOf("Endpoint.OracleSettings.ArchivedLogsOnly")
Dim AsmPassword As String
AsmPassword = jResp.StringOf("Endpoint.OracleSettings.AsmPassword")
Dim AsmServer As String
AsmServer = jResp.StringOf("Endpoint.OracleSettings.AsmServer")
Dim AsmUser As String
AsmUser = jResp.StringOf("Endpoint.OracleSettings.AsmUser")
Dim CharLengthSemantics As String
CharLengthSemantics = jResp.StringOf("Endpoint.OracleSettings.CharLengthSemantics")
Dim OracleSettingsDatabaseName As String
OracleSettingsDatabaseName = jResp.StringOf("Endpoint.OracleSettings.DatabaseName")
Dim DirectPathNoLog As Int32
DirectPathNoLog = jResp.IntOf("Endpoint.OracleSettings.DirectPathNoLog")
Dim DirectPathParallelLoad As Int32
DirectPathParallelLoad = jResp.IntOf("Endpoint.OracleSettings.DirectPathParallelLoad")
Dim EnableHomogenousTablespace As Int32
EnableHomogenousTablespace = jResp.IntOf("Endpoint.OracleSettings.EnableHomogenousTablespace")
Dim FailTasksOnLobTruncation As Int32
FailTasksOnLobTruncation = jResp.IntOf("Endpoint.OracleSettings.FailTasksOnLobTruncation")
Dim NumberDatatypeScale As Int32
NumberDatatypeScale = jResp.IntOf("Endpoint.OracleSettings.NumberDatatypeScale")
Dim OraclePathPrefix As String
OraclePathPrefix = jResp.StringOf("Endpoint.OracleSettings.OraclePathPrefix")
Dim ParallelAsmReadThreads As Int32
ParallelAsmReadThreads = jResp.IntOf("Endpoint.OracleSettings.ParallelAsmReadThreads")
Dim OracleSettingsPassword As String
OracleSettingsPassword = jResp.StringOf("Endpoint.OracleSettings.Password")
Dim OracleSettingsPort As Int32
OracleSettingsPort = jResp.IntOf("Endpoint.OracleSettings.Port")
Dim ReadAheadBlocks As Int32
ReadAheadBlocks = jResp.IntOf("Endpoint.OracleSettings.ReadAheadBlocks")
Dim ReadTableSpaceName As Int32
ReadTableSpaceName = jResp.IntOf("Endpoint.OracleSettings.ReadTableSpaceName")
Dim ReplacePathPrefix As Int32
ReplacePathPrefix = jResp.IntOf("Endpoint.OracleSettings.ReplacePathPrefix")
Dim RetryInterval As Int32
RetryInterval = jResp.IntOf("Endpoint.OracleSettings.RetryInterval")
Dim OracleSettingsSecretsManagerAccessRoleArn As String
OracleSettingsSecretsManagerAccessRoleArn = jResp.StringOf("Endpoint.OracleSettings.SecretsManagerAccessRoleArn")
Dim SecretsManagerOracleAsmAccessRoleArn As String
SecretsManagerOracleAsmAccessRoleArn = jResp.StringOf("Endpoint.OracleSettings.SecretsManagerOracleAsmAccessRoleArn")
Dim SecretsManagerOracleAsmSecretId As String
SecretsManagerOracleAsmSecretId = jResp.StringOf("Endpoint.OracleSettings.SecretsManagerOracleAsmSecretId")
Dim OracleSettingsSecretsManagerSecretId As String
OracleSettingsSecretsManagerSecretId = jResp.StringOf("Endpoint.OracleSettings.SecretsManagerSecretId")
Dim SecurityDbEncryption As String
SecurityDbEncryption = jResp.StringOf("Endpoint.OracleSettings.SecurityDbEncryption")
Dim SecurityDbEncryptionName As String
SecurityDbEncryptionName = jResp.StringOf("Endpoint.OracleSettings.SecurityDbEncryptionName")
Dim OracleSettingsServerName As String
OracleSettingsServerName = jResp.StringOf("Endpoint.OracleSettings.ServerName")
Dim SpatialDataOptionToGeoJsonFunctionName As String
SpatialDataOptionToGeoJsonFunctionName = jResp.StringOf("Endpoint.OracleSettings.SpatialDataOptionToGeoJsonFunctionName")
Dim StandbyDelayTime As Int32
StandbyDelayTime = jResp.IntOf("Endpoint.OracleSettings.StandbyDelayTime")
Dim UseAlternateFolderForOnline As Int32
UseAlternateFolderForOnline = jResp.IntOf("Endpoint.OracleSettings.UseAlternateFolderForOnline")
Dim UseBFile As Int32
UseBFile = jResp.IntOf("Endpoint.OracleSettings.UseBFile")
Dim UseDirectPathFullLoad As Int32
UseDirectPathFullLoad = jResp.IntOf("Endpoint.OracleSettings.UseDirectPathFullLoad")
Dim UseLogminerReader As Int32
UseLogminerReader = jResp.IntOf("Endpoint.OracleSettings.UseLogminerReader")
Dim UsePathPrefix As String
UsePathPrefix = jResp.StringOf("Endpoint.OracleSettings.UsePathPrefix")
Dim OracleSettingsUsername As String
OracleSettingsUsername = jResp.StringOf("Endpoint.OracleSettings.Username")
Dim EndpointPort As Int32
EndpointPort = jResp.IntOf("Endpoint.Port")
Dim PostgreSQLSettingsAfterConnectScript As String
PostgreSQLSettingsAfterConnectScript = jResp.StringOf("Endpoint.PostgreSQLSettings.AfterConnectScript")
Dim CaptureDdls As Int32
CaptureDdls = jResp.IntOf("Endpoint.PostgreSQLSettings.CaptureDdls")
Dim PostgreSQLSettingsDatabaseName As String
PostgreSQLSettingsDatabaseName = jResp.StringOf("Endpoint.PostgreSQLSettings.DatabaseName")
Dim DdlArtifactsSchema As String
DdlArtifactsSchema = jResp.StringOf("Endpoint.PostgreSQLSettings.DdlArtifactsSchema")
Dim ExecuteTimeout As Int32
ExecuteTimeout = jResp.IntOf("Endpoint.PostgreSQLSettings.ExecuteTimeout")
Dim PostgreSQLSettingsFailTasksOnLobTruncation As Int32
PostgreSQLSettingsFailTasksOnLobTruncation = jResp.IntOf("Endpoint.PostgreSQLSettings.FailTasksOnLobTruncation")
Dim HeartbeatEnable As Int32
HeartbeatEnable = jResp.IntOf("Endpoint.PostgreSQLSettings.HeartbeatEnable")
Dim HeartbeatFrequency As Int32
HeartbeatFrequency = jResp.IntOf("Endpoint.PostgreSQLSettings.HeartbeatFrequency")
Dim HeartbeatSchema As String
HeartbeatSchema = jResp.StringOf("Endpoint.PostgreSQLSettings.HeartbeatSchema")
Dim PostgreSQLSettingsMaxFileSize As Int32
PostgreSQLSettingsMaxFileSize = jResp.IntOf("Endpoint.PostgreSQLSettings.MaxFileSize")
Dim PostgreSQLSettingsPassword As String
PostgreSQLSettingsPassword = jResp.StringOf("Endpoint.PostgreSQLSettings.Password")
Dim PluginName As String
PluginName = jResp.StringOf("Endpoint.PostgreSQLSettings.PluginName")
Dim PostgreSQLSettingsPort As Int32
PostgreSQLSettingsPort = jResp.IntOf("Endpoint.PostgreSQLSettings.Port")
Dim PostgreSQLSettingsSecretsManagerAccessRoleArn As String
PostgreSQLSettingsSecretsManagerAccessRoleArn = jResp.StringOf("Endpoint.PostgreSQLSettings.SecretsManagerAccessRoleArn")
Dim PostgreSQLSettingsSecretsManagerSecretId As String
PostgreSQLSettingsSecretsManagerSecretId = jResp.StringOf("Endpoint.PostgreSQLSettings.SecretsManagerSecretId")
Dim PostgreSQLSettingsServerName As String
PostgreSQLSettingsServerName = jResp.StringOf("Endpoint.PostgreSQLSettings.ServerName")
Dim SlotName As String
SlotName = jResp.StringOf("Endpoint.PostgreSQLSettings.SlotName")
Dim PostgreSQLSettingsUsername As String
PostgreSQLSettingsUsername = jResp.StringOf("Endpoint.PostgreSQLSettings.Username")
Dim AuthPassword As String
AuthPassword = jResp.StringOf("Endpoint.RedisSettings.AuthPassword")
Dim RedisSettingsAuthType As String
RedisSettingsAuthType = jResp.StringOf("Endpoint.RedisSettings.AuthType")
Dim AuthUserName As String
AuthUserName = jResp.StringOf("Endpoint.RedisSettings.AuthUserName")
Dim RedisSettingsPort As Int32
RedisSettingsPort = jResp.IntOf("Endpoint.RedisSettings.Port")
Dim RedisSettingsServerName As String
RedisSettingsServerName = jResp.StringOf("Endpoint.RedisSettings.ServerName")
Dim RedisSettingsSslCaCertificateArn As String
RedisSettingsSslCaCertificateArn = jResp.StringOf("Endpoint.RedisSettings.SslCaCertificateArn")
Dim SslSecurityProtocol As String
SslSecurityProtocol = jResp.StringOf("Endpoint.RedisSettings.SslSecurityProtocol")
Dim AcceptAnyDate As Int32
AcceptAnyDate = jResp.IntOf("Endpoint.RedshiftSettings.AcceptAnyDate")
Dim RedshiftSettingsAfterConnectScript As String
RedshiftSettingsAfterConnectScript = jResp.StringOf("Endpoint.RedshiftSettings.AfterConnectScript")
Dim BucketFolder As String
BucketFolder = jResp.StringOf("Endpoint.RedshiftSettings.BucketFolder")
Dim RedshiftSettingsBucketName As String
RedshiftSettingsBucketName = jResp.StringOf("Endpoint.RedshiftSettings.BucketName")
Dim CaseSensitiveNames As Int32
CaseSensitiveNames = jResp.IntOf("Endpoint.RedshiftSettings.CaseSensitiveNames")
Dim CompUpdate As Int32
CompUpdate = jResp.IntOf("Endpoint.RedshiftSettings.CompUpdate")
Dim ConnectionTimeout As Int32
ConnectionTimeout = jResp.IntOf("Endpoint.RedshiftSettings.ConnectionTimeout")
Dim RedshiftSettingsDatabaseName As String
RedshiftSettingsDatabaseName = jResp.StringOf("Endpoint.RedshiftSettings.DatabaseName")
Dim DateFormat As String
DateFormat = jResp.StringOf("Endpoint.RedshiftSettings.DateFormat")
Dim EmptyAsNull As Int32
EmptyAsNull = jResp.IntOf("Endpoint.RedshiftSettings.EmptyAsNull")
Dim EncryptionMode As String
EncryptionMode = jResp.StringOf("Endpoint.RedshiftSettings.EncryptionMode")
Dim ExplicitIds As Int32
ExplicitIds = jResp.IntOf("Endpoint.RedshiftSettings.ExplicitIds")
Dim FileTransferUploadStreams As Int32
FileTransferUploadStreams = jResp.IntOf("Endpoint.RedshiftSettings.FileTransferUploadStreams")
Dim LoadTimeout As Int32
LoadTimeout = jResp.IntOf("Endpoint.RedshiftSettings.LoadTimeout")
Dim RedshiftSettingsMaxFileSize As Int32
RedshiftSettingsMaxFileSize = jResp.IntOf("Endpoint.RedshiftSettings.MaxFileSize")
Dim RedshiftSettingsPassword As String
RedshiftSettingsPassword = jResp.StringOf("Endpoint.RedshiftSettings.Password")
Dim RedshiftSettingsPort As Int32
RedshiftSettingsPort = jResp.IntOf("Endpoint.RedshiftSettings.Port")
Dim RemoveQuotes As Int32
RemoveQuotes = jResp.IntOf("Endpoint.RedshiftSettings.RemoveQuotes")
Dim ReplaceChars As String
ReplaceChars = jResp.StringOf("Endpoint.RedshiftSettings.ReplaceChars")
Dim ReplaceInvalidChars As String
ReplaceInvalidChars = jResp.StringOf("Endpoint.RedshiftSettings.ReplaceInvalidChars")
Dim RedshiftSettingsSecretsManagerAccessRoleArn As String
RedshiftSettingsSecretsManagerAccessRoleArn = jResp.StringOf("Endpoint.RedshiftSettings.SecretsManagerAccessRoleArn")
Dim RedshiftSettingsSecretsManagerSecretId As String
RedshiftSettingsSecretsManagerSecretId = jResp.StringOf("Endpoint.RedshiftSettings.SecretsManagerSecretId")
Dim RedshiftSettingsServerName As String
RedshiftSettingsServerName = jResp.StringOf("Endpoint.RedshiftSettings.ServerName")
Dim ServerSideEncryptionKmsKeyId As String
ServerSideEncryptionKmsKeyId = jResp.StringOf("Endpoint.RedshiftSettings.ServerSideEncryptionKmsKeyId")
Dim RedshiftSettingsServiceAccessRoleArn As String
RedshiftSettingsServiceAccessRoleArn = jResp.StringOf("Endpoint.RedshiftSettings.ServiceAccessRoleArn")
Dim TimeFormat As String
TimeFormat = jResp.StringOf("Endpoint.RedshiftSettings.TimeFormat")
Dim TrimBlanks As Int32
TrimBlanks = jResp.IntOf("Endpoint.RedshiftSettings.TrimBlanks")
Dim TruncateColumns As Int32
TruncateColumns = jResp.IntOf("Endpoint.RedshiftSettings.TruncateColumns")
Dim RedshiftSettingsUsername As String
RedshiftSettingsUsername = jResp.StringOf("Endpoint.RedshiftSettings.Username")
Dim WriteBufferSize As Int32
WriteBufferSize = jResp.IntOf("Endpoint.RedshiftSettings.WriteBufferSize")
Dim AddColumnName As Int32
AddColumnName = jResp.IntOf("Endpoint.S3Settings.AddColumnName")
Dim S3SettingsBucketFolder As String
S3SettingsBucketFolder = jResp.StringOf("Endpoint.S3Settings.BucketFolder")
Dim S3SettingsBucketName As String
S3SettingsBucketName = jResp.StringOf("Endpoint.S3Settings.BucketName")
Dim CannedAclForObjects As String
CannedAclForObjects = jResp.StringOf("Endpoint.S3Settings.CannedAclForObjects")
Dim CdcInsertsAndUpdates As Int32
CdcInsertsAndUpdates = jResp.IntOf("Endpoint.S3Settings.CdcInsertsAndUpdates")
Dim CdcInsertsOnly As Int32
CdcInsertsOnly = jResp.IntOf("Endpoint.S3Settings.CdcInsertsOnly")
Dim CdcMaxBatchInterval As Int32
CdcMaxBatchInterval = jResp.IntOf("Endpoint.S3Settings.CdcMaxBatchInterval")
Dim CdcMinFileSize As Int32
CdcMinFileSize = jResp.IntOf("Endpoint.S3Settings.CdcMinFileSize")
Dim CdcPath As String
CdcPath = jResp.StringOf("Endpoint.S3Settings.CdcPath")
Dim CompressionType As String
CompressionType = jResp.StringOf("Endpoint.S3Settings.CompressionType")
Dim CsvDelimiter As String
CsvDelimiter = jResp.StringOf("Endpoint.S3Settings.CsvDelimiter")
Dim CsvNoSupValue As String
CsvNoSupValue = jResp.StringOf("Endpoint.S3Settings.CsvNoSupValue")
Dim CsvNullValue As String
CsvNullValue = jResp.StringOf("Endpoint.S3Settings.CsvNullValue")
Dim CsvRowDelimiter As String
CsvRowDelimiter = jResp.StringOf("Endpoint.S3Settings.CsvRowDelimiter")
Dim DataFormat As String
DataFormat = jResp.StringOf("Endpoint.S3Settings.DataFormat")
Dim DataPageSize As Int32
DataPageSize = jResp.IntOf("Endpoint.S3Settings.DataPageSize")
Dim DatePartitionDelimiter As String
DatePartitionDelimiter = jResp.StringOf("Endpoint.S3Settings.DatePartitionDelimiter")
Dim DatePartitionEnabled As Int32
DatePartitionEnabled = jResp.IntOf("Endpoint.S3Settings.DatePartitionEnabled")
Dim DatePartitionSequence As String
DatePartitionSequence = jResp.StringOf("Endpoint.S3Settings.DatePartitionSequence")
Dim DatePartitionTimezone As String
DatePartitionTimezone = jResp.StringOf("Endpoint.S3Settings.DatePartitionTimezone")
Dim DictPageSizeLimit As Int32
DictPageSizeLimit = jResp.IntOf("Endpoint.S3Settings.DictPageSizeLimit")
Dim EnableStatistics As Int32
EnableStatistics = jResp.IntOf("Endpoint.S3Settings.EnableStatistics")
Dim EncodingType As String
EncodingType = jResp.StringOf("Endpoint.S3Settings.EncodingType")
Dim S3SettingsEncryptionMode As String
S3SettingsEncryptionMode = jResp.StringOf("Endpoint.S3Settings.EncryptionMode")
Dim S3SettingsExternalTableDefinition As String
S3SettingsExternalTableDefinition = jResp.StringOf("Endpoint.S3Settings.ExternalTableDefinition")
Dim IgnoreHeaderRows As Int32
IgnoreHeaderRows = jResp.IntOf("Endpoint.S3Settings.IgnoreHeaderRows")
Dim IncludeOpForFullLoad As Int32
IncludeOpForFullLoad = jResp.IntOf("Endpoint.S3Settings.IncludeOpForFullLoad")
Dim S3SettingsMaxFileSize As Int32
S3SettingsMaxFileSize = jResp.IntOf("Endpoint.S3Settings.MaxFileSize")
Dim ParquetTimestampInMillisecond As Int32
ParquetTimestampInMillisecond = jResp.IntOf("Endpoint.S3Settings.ParquetTimestampInMillisecond")
Dim ParquetVersion As String
ParquetVersion = jResp.StringOf("Endpoint.S3Settings.ParquetVersion")
Dim PreserveTransactions As Int32
PreserveTransactions = jResp.IntOf("Endpoint.S3Settings.PreserveTransactions")
Dim Rfc4180 As Int32
Rfc4180 = jResp.IntOf("Endpoint.S3Settings.Rfc4180")
Dim RowGroupLength As Int32
RowGroupLength = jResp.IntOf("Endpoint.S3Settings.RowGroupLength")
Dim S3SettingsServerSideEncryptionKmsKeyId As String
S3SettingsServerSideEncryptionKmsKeyId = jResp.StringOf("Endpoint.S3Settings.ServerSideEncryptionKmsKeyId")
Dim S3SettingsServiceAccessRoleArn As String
S3SettingsServiceAccessRoleArn = jResp.StringOf("Endpoint.S3Settings.ServiceAccessRoleArn")
Dim TimestampColumnName As String
TimestampColumnName = jResp.StringOf("Endpoint.S3Settings.TimestampColumnName")
Dim UseCsvNoSupValue As Int32
UseCsvNoSupValue = jResp.IntOf("Endpoint.S3Settings.UseCsvNoSupValue")
Dim UseTaskStartTimeForFullLoadTimestamp As Int32
UseTaskStartTimeForFullLoadTimestamp = jResp.IntOf("Endpoint.S3Settings.UseTaskStartTimeForFullLoadTimestamp")
Dim EndpointServerName As String
EndpointServerName = jResp.StringOf("Endpoint.ServerName")
Dim EndpointServiceAccessRoleArn As String
EndpointServiceAccessRoleArn = jResp.StringOf("Endpoint.ServiceAccessRoleArn")
Dim SslMode As String
SslMode = jResp.StringOf("Endpoint.SslMode")
Dim Status As String
Status = jResp.StringOf("Endpoint.Status")
Dim SybaseSettingsDatabaseName As String
SybaseSettingsDatabaseName = jResp.StringOf("Endpoint.SybaseSettings.DatabaseName")
Dim SybaseSettingsPassword As String
SybaseSettingsPassword = jResp.StringOf("Endpoint.SybaseSettings.Password")
Dim SybaseSettingsPort As Int32
SybaseSettingsPort = jResp.IntOf("Endpoint.SybaseSettings.Port")
Dim SybaseSettingsSecretsManagerAccessRoleArn As String
SybaseSettingsSecretsManagerAccessRoleArn = jResp.StringOf("Endpoint.SybaseSettings.SecretsManagerAccessRoleArn")
Dim SybaseSettingsSecretsManagerSecretId As String
SybaseSettingsSecretsManagerSecretId = jResp.StringOf("Endpoint.SybaseSettings.SecretsManagerSecretId")
Dim SybaseSettingsServerName As String
SybaseSettingsServerName = jResp.StringOf("Endpoint.SybaseSettings.ServerName")
Dim SybaseSettingsUsername As String
SybaseSettingsUsername = jResp.StringOf("Endpoint.SybaseSettings.Username")
Dim EndpointUsername As String
EndpointUsername = jResp.StringOf("Endpoint.Username")
Dim i As Int32
i = 0
Dim count_i As Int32
count_i = jResp.SizeOfArray("Endpoint.OracleSettings.ExtraArchivedLogDestIds")
While i < count_i
jResp.I = i
intVal = jResp.IntOf("Endpoint.OracleSettings.ExtraArchivedLogDestIds[i]")
i = i + 1
Wend
// 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"
// }
// }
