CreateDataSource C Example
#include <C_CkRest.h>
#include <C_CkAuthAws.h>
#include <C_CkJsonObject.h>
#include <C_CkStringBuilder.h>
void ChilkatSample(void)
{
HCkRest rest;
BOOL success;
HCkAuthAws authAws;
HCkJsonObject json;
HCkStringBuilder sbRequestBody;
HCkStringBuilder sbResponseBody;
int respStatusCode;
HCkJsonObject jResp;
const char *DataSourceArn;
const char *Description;
const char *AwsRegion;
int BaseTableTTL;
const char *DeltaSyncTableName;
int DeltaSyncTableTTL;
const char *TableName;
int UseCallerCredentials;
int Versioned;
const char *ElasticsearchConfigAwsRegion;
const char *Endpoint;
const char *AuthorizationType;
const char *SigningRegion;
const char *SigningServiceName;
const char *HttpConfigEndpoint;
const char *LambdaFunctionArn;
const char *Name;
const char *OpenSearchServiceConfigAwsRegion;
const char *OpenSearchServiceConfigEndpoint;
const char *RdsHttpEndpointConfigAwsRegion;
const char *AwsSecretStoreArn;
const char *DatabaseName;
const char *DbClusterIdentifier;
const char *Schema;
const char *RelationalDatabaseSourceType;
const char *ServiceRoleArn;
const char *v_Type;
// This example requires the Chilkat API to have been previously unlocked.
// See Global Unlock Sample for sample code.
rest = CkRest_Create();
authAws = CkAuthAws_Create();
CkAuthAws_putAccessKey(authAws,"AWS_ACCESS_KEY");
CkAuthAws_putSecretKey(authAws,"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.)
CkAuthAws_putRegion(authAws,"us-west-2");
CkAuthAws_putServiceName(authAws,"appsync");
// SetAuthAws causes Chilkat to automatically add the following headers: Authorization, X-Amz-Date
CkRest_SetAuthAws(rest,authAws);
// URL: https://appsync.us-west-2.amazonaws.com/
// Use the same region as specified above.
success = CkRest_Connect(rest,"appsync.us-west-2.amazonaws.com",443,TRUE,TRUE);
if (success != TRUE) {
printf("ConnectFailReason: %d\n",CkRest_getConnectFailReason(rest));
printf("%s\n",CkRest_lastErrorText(rest));
CkRest_Dispose(rest);
CkAuthAws_Dispose(authAws);
return;
}
// 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
json = CkJsonObject_Create();
CkJsonObject_UpdateString(json,"description","string");
CkJsonObject_UpdateString(json,"dynamodbConfig.awsRegion","string");
CkJsonObject_UpdateInt(json,"dynamodbConfig.deltaSyncConfig.baseTableTTL",123);
CkJsonObject_UpdateString(json,"dynamodbConfig.deltaSyncConfig.deltaSyncTableName","string");
CkJsonObject_UpdateInt(json,"dynamodbConfig.deltaSyncConfig.deltaSyncTableTTL",123);
CkJsonObject_UpdateString(json,"dynamodbConfig.tableName","string");
CkJsonObject_UpdateInt(json,"dynamodbConfig.useCallerCredentials",123);
CkJsonObject_UpdateInt(json,"dynamodbConfig.versioned",123);
CkJsonObject_UpdateString(json,"elasticsearchConfig.awsRegion","string");
CkJsonObject_UpdateString(json,"elasticsearchConfig.endpoint","string");
CkJsonObject_UpdateString(json,"httpConfig.authorizationConfig.authorizationType","string");
CkJsonObject_UpdateString(json,"httpConfig.authorizationConfig.awsIamConfig.signingRegion","string");
CkJsonObject_UpdateString(json,"httpConfig.authorizationConfig.awsIamConfig.signingServiceName","string");
CkJsonObject_UpdateString(json,"httpConfig.endpoint","string");
CkJsonObject_UpdateString(json,"lambdaConfig.lambdaFunctionArn","string");
CkJsonObject_UpdateString(json,"name","string");
CkJsonObject_UpdateString(json,"openSearchServiceConfig.awsRegion","string");
CkJsonObject_UpdateString(json,"openSearchServiceConfig.endpoint","string");
CkJsonObject_UpdateString(json,"relationalDatabaseConfig.rdsHttpEndpointConfig.awsRegion","string");
CkJsonObject_UpdateString(json,"relationalDatabaseConfig.rdsHttpEndpointConfig.awsSecretStoreArn","string");
CkJsonObject_UpdateString(json,"relationalDatabaseConfig.rdsHttpEndpointConfig.databaseName","string");
CkJsonObject_UpdateString(json,"relationalDatabaseConfig.rdsHttpEndpointConfig.dbClusterIdentifier","string");
CkJsonObject_UpdateString(json,"relationalDatabaseConfig.rdsHttpEndpointConfig.schema","string");
CkJsonObject_UpdateString(json,"relationalDatabaseConfig.relationalDatabaseSourceType","string");
CkJsonObject_UpdateString(json,"serviceRoleArn","string");
CkJsonObject_UpdateString(json,"type","string");
// The JSON request body created by the above code:
// {
// "description": "string",
// "dynamodbConfig": {
// "awsRegion": "string",
// "deltaSyncConfig": {
// "baseTableTTL": number,
// "deltaSyncTableName": "string",
// "deltaSyncTableTTL": number
// },
// "tableName": "string",
// "useCallerCredentials": boolean,
// "versioned": boolean
// },
// "elasticsearchConfig": {
// "awsRegion": "string",
// "endpoint": "string"
// },
// "httpConfig": {
// "authorizationConfig": {
// "authorizationType": "string",
// "awsIamConfig": {
// "signingRegion": "string",
// "signingServiceName": "string"
// }
// },
// "endpoint": "string"
// },
// "lambdaConfig": {
// "lambdaFunctionArn": "string"
// },
// "name": "string",
// "openSearchServiceConfig": {
// "awsRegion": "string",
// "endpoint": "string"
// },
// "relationalDatabaseConfig": {
// "rdsHttpEndpointConfig": {
// "awsRegion": "string",
// "awsSecretStoreArn": "string",
// "databaseName": "string",
// "dbClusterIdentifier": "string",
// "schema": "string"
// },
// "relationalDatabaseSourceType": "string"
// },
// "serviceRoleArn": "string",
// "type": "string"
// }
CkRest_AddHeader(rest,"Content-Type","application/x-amz-json-1.1");
CkRest_AddHeader(rest,"X-Amz-Target","CreateDataSource");
sbRequestBody = CkStringBuilder_Create();
CkJsonObject_EmitSb(json,sbRequestBody);
sbResponseBody = CkStringBuilder_Create();
success = CkRest_FullRequestSb(rest,"POST","/v1/apis/{apiId}/datasources",sbRequestBody,sbResponseBody);
if (success != TRUE) {
printf("%s\n",CkRest_lastErrorText(rest));
CkRest_Dispose(rest);
CkAuthAws_Dispose(authAws);
CkJsonObject_Dispose(json);
CkStringBuilder_Dispose(sbRequestBody);
CkStringBuilder_Dispose(sbResponseBody);
return;
}
respStatusCode = CkRest_getResponseStatusCode(rest);
printf("response status code = %d\n",respStatusCode);
if (respStatusCode != 200) {
printf("Response Header:\n");
printf("%s\n",CkRest_responseHeader(rest));
printf("Response Body:\n");
printf("%s\n",CkStringBuilder_getAsString(sbResponseBody));
CkRest_Dispose(rest);
CkAuthAws_Dispose(authAws);
CkJsonObject_Dispose(json);
CkStringBuilder_Dispose(sbRequestBody);
CkStringBuilder_Dispose(sbResponseBody);
return;
}
jResp = CkJsonObject_Create();
CkJsonObject_LoadSb(jResp,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
// Chilkat functions returning "const char *" return a pointer to temporary internal memory owned and managed by Chilkat.
// See this example explaining how this memory should be used: const char * functions.
DataSourceArn = CkJsonObject_stringOf(jResp,"dataSource.dataSourceArn");
Description = CkJsonObject_stringOf(jResp,"dataSource.description");
AwsRegion = CkJsonObject_stringOf(jResp,"dataSource.dynamodbConfig.awsRegion");
BaseTableTTL = CkJsonObject_IntOf(jResp,"dataSource.dynamodbConfig.deltaSyncConfig.baseTableTTL");
DeltaSyncTableName = CkJsonObject_stringOf(jResp,"dataSource.dynamodbConfig.deltaSyncConfig.deltaSyncTableName");
DeltaSyncTableTTL = CkJsonObject_IntOf(jResp,"dataSource.dynamodbConfig.deltaSyncConfig.deltaSyncTableTTL");
TableName = CkJsonObject_stringOf(jResp,"dataSource.dynamodbConfig.tableName");
UseCallerCredentials = CkJsonObject_IntOf(jResp,"dataSource.dynamodbConfig.useCallerCredentials");
Versioned = CkJsonObject_IntOf(jResp,"dataSource.dynamodbConfig.versioned");
ElasticsearchConfigAwsRegion = CkJsonObject_stringOf(jResp,"dataSource.elasticsearchConfig.awsRegion");
Endpoint = CkJsonObject_stringOf(jResp,"dataSource.elasticsearchConfig.endpoint");
AuthorizationType = CkJsonObject_stringOf(jResp,"dataSource.httpConfig.authorizationConfig.authorizationType");
SigningRegion = CkJsonObject_stringOf(jResp,"dataSource.httpConfig.authorizationConfig.awsIamConfig.signingRegion");
SigningServiceName = CkJsonObject_stringOf(jResp,"dataSource.httpConfig.authorizationConfig.awsIamConfig.signingServiceName");
HttpConfigEndpoint = CkJsonObject_stringOf(jResp,"dataSource.httpConfig.endpoint");
LambdaFunctionArn = CkJsonObject_stringOf(jResp,"dataSource.lambdaConfig.lambdaFunctionArn");
Name = CkJsonObject_stringOf(jResp,"dataSource.name");
OpenSearchServiceConfigAwsRegion = CkJsonObject_stringOf(jResp,"dataSource.openSearchServiceConfig.awsRegion");
OpenSearchServiceConfigEndpoint = CkJsonObject_stringOf(jResp,"dataSource.openSearchServiceConfig.endpoint");
RdsHttpEndpointConfigAwsRegion = CkJsonObject_stringOf(jResp,"dataSource.relationalDatabaseConfig.rdsHttpEndpointConfig.awsRegion");
AwsSecretStoreArn = CkJsonObject_stringOf(jResp,"dataSource.relationalDatabaseConfig.rdsHttpEndpointConfig.awsSecretStoreArn");
DatabaseName = CkJsonObject_stringOf(jResp,"dataSource.relationalDatabaseConfig.rdsHttpEndpointConfig.databaseName");
DbClusterIdentifier = CkJsonObject_stringOf(jResp,"dataSource.relationalDatabaseConfig.rdsHttpEndpointConfig.dbClusterIdentifier");
Schema = CkJsonObject_stringOf(jResp,"dataSource.relationalDatabaseConfig.rdsHttpEndpointConfig.schema");
RelationalDatabaseSourceType = CkJsonObject_stringOf(jResp,"dataSource.relationalDatabaseConfig.relationalDatabaseSourceType");
ServiceRoleArn = CkJsonObject_stringOf(jResp,"dataSource.serviceRoleArn");
v_Type = CkJsonObject_stringOf(jResp,"dataSource.type");
// A sample JSON response body parsed by the above code:
// {
// "dataSource": {
// "dataSourceArn": "string",
// "description": "string",
// "dynamodbConfig": {
// "awsRegion": "string",
// "deltaSyncConfig": {
// "baseTableTTL": number,
// "deltaSyncTableName": "string",
// "deltaSyncTableTTL": number
// },
// "tableName": "string",
// "useCallerCredentials": boolean,
// "versioned": boolean
// },
// "elasticsearchConfig": {
// "awsRegion": "string",
// "endpoint": "string"
// },
// "httpConfig": {
// "authorizationConfig": {
// "authorizationType": "string",
// "awsIamConfig": {
// "signingRegion": "string",
// "signingServiceName": "string"
// }
// },
// "endpoint": "string"
// },
// "lambdaConfig": {
// "lambdaFunctionArn": "string"
// },
// "name": "string",
// "openSearchServiceConfig": {
// "awsRegion": "string",
// "endpoint": "string"
// },
// "relationalDatabaseConfig": {
// "rdsHttpEndpointConfig": {
// "awsRegion": "string",
// "awsSecretStoreArn": "string",
// "databaseName": "string",
// "dbClusterIdentifier": "string",
// "schema": "string"
// },
// "relationalDatabaseSourceType": "string"
// },
// "serviceRoleArn": "string",
// "type": "string"
// }
// }
CkRest_Dispose(rest);
CkAuthAws_Dispose(authAws);
CkJsonObject_Dispose(json);
CkStringBuilder_Dispose(sbRequestBody);
CkStringBuilder_Dispose(sbResponseBody);
CkJsonObject_Dispose(jResp);
}
