/*
* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License").
* You may not use this file except in compliance with the License.
* A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file. This file is distributed
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
* express or implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
/*
* Do not modify this file. This file is generated from the redshift-data-2019-12-20.normal.json service model.
*/
using System;
using System.Collections.Generic;
using System.Globalization;
using System.IO;
using System.Net;
using System.Text;
using System.Xml.Serialization;
using Amazon.RedshiftDataAPIService.Model;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Transform;
using Amazon.Runtime.Internal.Util;
using ThirdParty.Json.LitJson;
namespace Amazon.RedshiftDataAPIService.Model.Internal.MarshallTransformations
{
///
/// Response Unmarshaller for DescribeStatement operation
///
public class DescribeStatementResponseUnmarshaller : JsonResponseUnmarshaller
{
///
/// Unmarshaller the response from the service to the response class.
///
///
///
public override AmazonWebServiceResponse Unmarshall(JsonUnmarshallerContext context)
{
DescribeStatementResponse response = new DescribeStatementResponse();
context.Read();
int targetDepth = context.CurrentDepth;
while (context.ReadAtDepth(targetDepth))
{
if (context.TestExpression("ClusterIdentifier", targetDepth))
{
var unmarshaller = StringUnmarshaller.Instance;
response.ClusterIdentifier = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("CreatedAt", targetDepth))
{
var unmarshaller = DateTimeUnmarshaller.Instance;
response.CreatedAt = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("Database", targetDepth))
{
var unmarshaller = StringUnmarshaller.Instance;
response.Database = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("DbUser", targetDepth))
{
var unmarshaller = StringUnmarshaller.Instance;
response.DbUser = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("Duration", targetDepth))
{
var unmarshaller = LongUnmarshaller.Instance;
response.Duration = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("Error", targetDepth))
{
var unmarshaller = StringUnmarshaller.Instance;
response.Error = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("HasResultSet", targetDepth))
{
var unmarshaller = BoolUnmarshaller.Instance;
response.HasResultSet = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("Id", targetDepth))
{
var unmarshaller = StringUnmarshaller.Instance;
response.Id = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("QueryParameters", targetDepth))
{
var unmarshaller = new ListUnmarshaller(SqlParameterUnmarshaller.Instance);
response.QueryParameters = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("QueryString", targetDepth))
{
var unmarshaller = StringUnmarshaller.Instance;
response.QueryString = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("RedshiftPid", targetDepth))
{
var unmarshaller = LongUnmarshaller.Instance;
response.RedshiftPid = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("RedshiftQueryId", targetDepth))
{
var unmarshaller = LongUnmarshaller.Instance;
response.RedshiftQueryId = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("ResultRows", targetDepth))
{
var unmarshaller = LongUnmarshaller.Instance;
response.ResultRows = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("ResultSize", targetDepth))
{
var unmarshaller = LongUnmarshaller.Instance;
response.ResultSize = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("SecretArn", targetDepth))
{
var unmarshaller = StringUnmarshaller.Instance;
response.SecretArn = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("Status", targetDepth))
{
var unmarshaller = StringUnmarshaller.Instance;
response.Status = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("SubStatements", targetDepth))
{
var unmarshaller = new ListUnmarshaller(SubStatementDataUnmarshaller.Instance);
response.SubStatements = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("UpdatedAt", targetDepth))
{
var unmarshaller = DateTimeUnmarshaller.Instance;
response.UpdatedAt = unmarshaller.Unmarshall(context);
continue;
}
if (context.TestExpression("WorkgroupName", targetDepth))
{
var unmarshaller = StringUnmarshaller.Instance;
response.WorkgroupName = unmarshaller.Unmarshall(context);
continue;
}
}
return response;
}
///
/// Unmarshaller error response to exception.
///
///
///
///
///
public override AmazonServiceException UnmarshallException(JsonUnmarshallerContext context, Exception innerException, HttpStatusCode statusCode)
{
var errorResponse = JsonErrorResponseUnmarshaller.GetInstance().Unmarshall(context);
errorResponse.InnerException = innerException;
errorResponse.StatusCode = statusCode;
var responseBodyBytes = context.GetResponseBodyBytes();
using (var streamCopy = new MemoryStream(responseBodyBytes))
using (var contextCopy = new JsonUnmarshallerContext(streamCopy, false, null))
{
if (errorResponse.Code != null && errorResponse.Code.Equals("InternalServerException"))
{
return InternalServerExceptionUnmarshaller.Instance.Unmarshall(contextCopy, errorResponse);
}
if (errorResponse.Code != null && errorResponse.Code.Equals("ResourceNotFoundException"))
{
return ResourceNotFoundExceptionUnmarshaller.Instance.Unmarshall(contextCopy, errorResponse);
}
if (errorResponse.Code != null && errorResponse.Code.Equals("ValidationException"))
{
return ValidationExceptionUnmarshaller.Instance.Unmarshall(contextCopy, errorResponse);
}
}
return new AmazonRedshiftDataAPIServiceException(errorResponse.Message, errorResponse.InnerException, errorResponse.Type, errorResponse.Code, errorResponse.RequestId, errorResponse.StatusCode);
}
private static DescribeStatementResponseUnmarshaller _instance = new DescribeStatementResponseUnmarshaller();
internal static DescribeStatementResponseUnmarshaller GetInstance()
{
return _instance;
}
///
/// Gets the singleton.
///
public static DescribeStatementResponseUnmarshaller Instance
{
get
{
return _instance;
}
}
}
}