Chilkat Online Tools

GetQueryExecution Objective-C Example

Athena

#import <CkoRest.h>
#import <CkoAuthAws.h>
#import <CkoJsonObject.h>
#import <CkoStringBuilder.h>
#import <NSString.h>

// This example requires the Chilkat API to have been previously unlocked.
// See Global Unlock Sample for sample code.

CkoRest *rest = [[CkoRest alloc] init];
BOOL success;

CkoAuthAws *authAws = [[CkoAuthAws alloc] init];
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 = @"athena";
// SetAuthAws causes Chilkat to automatically add the following headers: Authorization, X-Amz-Date
[rest SetAuthAws: authAws];

// URL: https://athena.us-west-2.amazonaws.com/
// Use the same region as specified above.
success = [rest Connect: @"athena.us-west-2.amazonaws.com" port: [NSNumber numberWithInt: 443] tls: YES autoReconnect: YES];
if (success != YES) {
    NSLog(@"%@%d",@"ConnectFailReason: ",[rest.ConnectFailReason intValue]);
    NSLog(@"%@",rest.LastErrorText);
    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

CkoJsonObject *json = [[CkoJsonObject alloc] init];
[json UpdateString: @"QueryExecutionId" value: @"string"];

// The JSON request body created by the above code:

// {
//   "QueryExecutionId": "string"
// }

[rest AddHeader: @"Content-Type" value: @"application/x-amz-json-1.1"];
[rest AddHeader: @"X-Amz-Target" value: @"AmazonAthena.GetQueryExecution"];

CkoStringBuilder *sbRequestBody = [[CkoStringBuilder alloc] init];
[json EmitSb: sbRequestBody];
CkoStringBuilder *sbResponseBody = [[CkoStringBuilder alloc] init];
success = [rest FullRequestSb: @"POST" uriPath: @"/" requestBody: sbRequestBody responseBody: sbResponseBody];
if (success != YES) {
    NSLog(@"%@",rest.LastErrorText);
    return;
}

int respStatusCode = [rest.ResponseStatusCode intValue];
NSLog(@"%@%d",@"response status code = ",respStatusCode);
if (respStatusCode != 200) {
    NSLog(@"%@",@"Response Header:");
    NSLog(@"%@",rest.ResponseHeader);
    NSLog(@"%@",@"Response Body:");
    NSLog(@"%@",[sbResponseBody GetAsString]);
    return;
}

CkoJsonObject *jResp = [[CkoJsonObject alloc] init];
[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

NSString *EffectiveEngineVersion = [jResp StringOf: @"QueryExecution.EngineVersion.EffectiveEngineVersion"];
NSString *SelectedEngineVersion = [jResp StringOf: @"QueryExecution.EngineVersion.SelectedEngineVersion"];
NSString *Query = [jResp StringOf: @"QueryExecution.Query"];
NSString *Catalog = [jResp StringOf: @"QueryExecution.QueryExecutionContext.Catalog"];
NSString *Database = [jResp StringOf: @"QueryExecution.QueryExecutionContext.Database"];
NSString *QueryExecutionId = [jResp StringOf: @"QueryExecution.QueryExecutionId"];
NSString *S3AclOption = [jResp StringOf: @"QueryExecution.ResultConfiguration.AclConfiguration.S3AclOption"];
NSString *EncryptionOption = [jResp StringOf: @"QueryExecution.ResultConfiguration.EncryptionConfiguration.EncryptionOption"];
NSString *KmsKey = [jResp StringOf: @"QueryExecution.ResultConfiguration.EncryptionConfiguration.KmsKey"];
NSString *ExpectedBucketOwner = [jResp StringOf: @"QueryExecution.ResultConfiguration.ExpectedBucketOwner"];
NSString *OutputLocation = [jResp StringOf: @"QueryExecution.ResultConfiguration.OutputLocation"];
NSString *StatementType = [jResp StringOf: @"QueryExecution.StatementType"];
NSString *DataManifestLocation = [jResp StringOf: @"QueryExecution.Statistics.DataManifestLocation"];
int DataScannedInBytes = [[jResp IntOf: @"QueryExecution.Statistics.DataScannedInBytes"] intValue];
int EngineExecutionTimeInMillis = [[jResp IntOf: @"QueryExecution.Statistics.EngineExecutionTimeInMillis"] intValue];
int QueryPlanningTimeInMillis = [[jResp IntOf: @"QueryExecution.Statistics.QueryPlanningTimeInMillis"] intValue];
int QueryQueueTimeInMillis = [[jResp IntOf: @"QueryExecution.Statistics.QueryQueueTimeInMillis"] intValue];
int ServiceProcessingTimeInMillis = [[jResp IntOf: @"QueryExecution.Statistics.ServiceProcessingTimeInMillis"] intValue];
int TotalExecutionTimeInMillis = [[jResp IntOf: @"QueryExecution.Statistics.TotalExecutionTimeInMillis"] intValue];
int ErrorCategory = [[jResp IntOf: @"QueryExecution.Status.AthenaError.ErrorCategory"] intValue];
NSString *ErrorMessage = [jResp StringOf: @"QueryExecution.Status.AthenaError.ErrorMessage"];
int ErrorType = [[jResp IntOf: @"QueryExecution.Status.AthenaError.ErrorType"] intValue];
int Retryable = [[jResp IntOf: @"QueryExecution.Status.AthenaError.Retryable"] intValue];
int CompletionDateTime = [[jResp IntOf: @"QueryExecution.Status.CompletionDateTime"] intValue];
NSString *State = [jResp StringOf: @"QueryExecution.Status.State"];
NSString *StateChangeReason = [jResp StringOf: @"QueryExecution.Status.StateChangeReason"];
int SubmissionDateTime = [[jResp IntOf: @"QueryExecution.Status.SubmissionDateTime"] intValue];
NSString *WorkGroup = [jResp StringOf: @"QueryExecution.WorkGroup"];

// A sample JSON response body parsed by the above code:

// {
//   "QueryExecution": {
//     "EngineVersion": {
//       "EffectiveEngineVersion": "string",
//       "SelectedEngineVersion": "string"
//     },
//     "Query": "string",
//     "QueryExecutionContext": {
//       "Catalog": "string",
//       "Database": "string"
//     },
//     "QueryExecutionId": "string",
//     "ResultConfiguration": {
//       "AclConfiguration": {
//         "S3AclOption": "string"
//       },
//       "EncryptionConfiguration": {
//         "EncryptionOption": "string",
//         "KmsKey": "string"
//       },
//       "ExpectedBucketOwner": "string",
//       "OutputLocation": "string"
//     },
//     "StatementType": "string",
//     "Statistics": {
//       "DataManifestLocation": "string",
//       "DataScannedInBytes": number,
//       "EngineExecutionTimeInMillis": number,
//       "QueryPlanningTimeInMillis": number,
//       "QueryQueueTimeInMillis": number,
//       "ServiceProcessingTimeInMillis": number,
//       "TotalExecutionTimeInMillis": number
//     },
//     "Status": {
//       "AthenaError": {
//         "ErrorCategory": number,
//         "ErrorMessage": "string",
//         "ErrorType": number,
//         "Retryable": boolean
//       },
//       "CompletionDateTime": number,
//       "State": "string",
//       "StateChangeReason": "string",
//       "SubmissionDateTime": number
//     },
//     "WorkGroup": "string"
//   }
// }