aws_sdk_dynamodb/operation/
execute_statement.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `ExecuteStatement`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct ExecuteStatement;
6impl ExecuteStatement {
7    /// Creates a new `ExecuteStatement`
8    pub fn new() -> Self {
9        Self
10    }
11    pub(crate) async fn orchestrate(
12        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
13        input: crate::operation::execute_statement::ExecuteStatementInput,
14    ) -> ::std::result::Result<
15        crate::operation::execute_statement::ExecuteStatementOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::execute_statement::ExecuteStatementError,
18            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
19        >,
20    > {
21        let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
22            ::aws_smithy_runtime_api::client::interceptors::context::Error,
23            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
24        >| {
25            err.map_service_error(|err| {
26                err.downcast::<crate::operation::execute_statement::ExecuteStatementError>()
27                    .expect("correct error type")
28            })
29        };
30        let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
31            .await
32            .map_err(map_err)?;
33        let output = context.finalize().map_err(map_err)?;
34        ::std::result::Result::Ok(
35            output
36                .downcast::<crate::operation::execute_statement::ExecuteStatementOutput>()
37                .expect("correct output type"),
38        )
39    }
40
41    pub(crate) async fn orchestrate_with_stop_point(
42        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
43        input: crate::operation::execute_statement::ExecuteStatementInput,
44        stop_point: ::aws_smithy_runtime::client::orchestrator::StopPoint,
45    ) -> ::std::result::Result<
46        ::aws_smithy_runtime_api::client::interceptors::context::InterceptorContext,
47        ::aws_smithy_runtime_api::client::result::SdkError<
48            ::aws_smithy_runtime_api::client::interceptors::context::Error,
49            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
50        >,
51    > {
52        let input = ::aws_smithy_runtime_api::client::interceptors::context::Input::erase(input);
53        use ::tracing::Instrument;
54        ::aws_smithy_runtime::client::orchestrator::invoke_with_stop_point("DynamoDB", "ExecuteStatement", input, runtime_plugins, stop_point)
55            // Create a parent span for the entire operation. Includes a random, internal-only,
56            // seven-digit ID for the operation orchestration so that it can be correlated in the logs.
57            .instrument(::tracing::debug_span!(
58                "DynamoDB.ExecuteStatement",
59                "rpc.service" = "DynamoDB",
60                "rpc.method" = "ExecuteStatement",
61                "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
62                "rpc.system" = "aws-api",
63            ))
64            .await
65    }
66
67    pub(crate) fn operation_runtime_plugins(
68        client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
69        client_config: &crate::config::Config,
70        config_override: ::std::option::Option<crate::config::Builder>,
71    ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
72        let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
73
74        if let ::std::option::Option::Some(config_override) = config_override {
75            for plugin in config_override.runtime_plugins.iter().cloned() {
76                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
77            }
78            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
79                config_override,
80                client_config.config.clone(),
81                &client_config.runtime_components,
82            ));
83        }
84        runtime_plugins
85    }
86}
87impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ExecuteStatement {
88    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
89        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("ExecuteStatement");
90
91        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
92            ExecuteStatementRequestSerializer,
93        ));
94        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
95            ExecuteStatementResponseDeserializer,
96        ));
97
98        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
99            crate::config::auth::Params::builder()
100                .operation_name("ExecuteStatement")
101                .build()
102                .expect("required fields set"),
103        ));
104
105        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
106            "ExecuteStatement",
107            "DynamoDB",
108        ));
109        let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
110        signing_options.double_uri_encode = true;
111        signing_options.content_sha256_header = false;
112        signing_options.normalize_uri_path = true;
113        signing_options.payload_override = None;
114
115        cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
116            signing_options,
117            ..::std::default::Default::default()
118        });
119
120        ::std::option::Option::Some(cfg.freeze())
121    }
122
123    fn runtime_components(
124        &self,
125        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
126    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
127        #[allow(unused_mut)]
128        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ExecuteStatement")
129            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
130                ExecuteStatementTelemetryInputCaptureInterceptor,
131            ))
132            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
133                ::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default(),
134            ))
135            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
136                ExecuteStatementEndpointParamsInterceptor,
137            ))
138            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
139                crate::operation::execute_statement::ExecuteStatementError,
140            >::new())
141            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
142                crate::operation::execute_statement::ExecuteStatementError,
143            >::new())
144            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
145                crate::operation::execute_statement::ExecuteStatementError,
146            >::new());
147
148        ::std::borrow::Cow::Owned(rcb)
149    }
150}
151
152#[derive(Debug)]
153struct ExecuteStatementTelemetryInputCaptureInterceptor;
154
155#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
156impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ExecuteStatementTelemetryInputCaptureInterceptor {
157    fn name(&self) -> &'static str {
158        "ExecuteStatementTelemetryInputCaptureInterceptor"
159    }
160
161    fn read_before_execution(
162        &self,
163        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
164            '_,
165            ::aws_smithy_runtime_api::client::interceptors::context::Input,
166            ::aws_smithy_runtime_api::client::interceptors::context::Output,
167            ::aws_smithy_runtime_api::client::interceptors::context::Error,
168        >,
169        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
170    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
171        // Nothing to do unless the customer opted in by naming members to record.
172        let ::std::option::Option::Some(requested) = cfg
173            .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
174            .filter(|r| !r.is_empty())
175        else {
176            return ::std::result::Result::Ok(());
177        };
178
179        let ::std::option::Option::Some(input) = context.input().downcast_ref::<ExecuteStatementInput>() else {
180            // A mismatched input is not this interceptor's concern; skip quietly.
181            return ::std::result::Result::Ok(());
182        };
183
184        let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
185        if requested.should_capture("Statement") {
186            if let ::std::option::Option::Some(value) = input.statement.as_deref() {
187                captured.insert("Statement", value);
188            }
189        }
190        if requested.should_capture("NextToken") {
191            if let ::std::option::Option::Some(value) = input.next_token.as_deref() {
192                captured.insert("NextToken", value);
193            }
194        }
195
196        cfg.interceptor_state().store_put(captured);
197        ::std::result::Result::Ok(())
198    }
199}
200#[derive(Debug)]
201struct ExecuteStatementResponseDeserializer;
202impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for ExecuteStatementResponseDeserializer {
203    fn deserialize_nonstreaming_with_config(
204        &self,
205        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
206        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
207    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
208        let (success, status) = (response.status().is_success(), response.status().as_u16());
209        let headers = response.headers();
210        let body = response.body().bytes().expect("body loaded");
211        #[allow(unused_mut)]
212        let mut force_error = false;
213        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
214        let parse_result = if !success && status != 200 || force_error {
215            crate::protocol_serde::shape_execute_statement::de_execute_statement_http_error(status, headers, body)
216        } else {
217            crate::protocol_serde::shape_execute_statement::de_execute_statement_http_response(status, headers, body)
218        };
219        crate::protocol_serde::type_erase_result(parse_result)
220    }
221}
222#[derive(Debug)]
223struct ExecuteStatementRequestSerializer;
224impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for ExecuteStatementRequestSerializer {
225    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
226    fn serialize_input(
227        &self,
228        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
229        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
230    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
231        let input = input
232            .downcast::<crate::operation::execute_statement::ExecuteStatementInput>()
233            .expect("correct type");
234        let _header_serialization_settings = _cfg
235            .load::<crate::serialization_settings::HeaderSerializationSettings>()
236            .cloned()
237            .unwrap_or_default();
238        let mut request_builder = {
239            #[allow(clippy::uninlined_format_args)]
240            fn uri_base(
241                _input: &crate::operation::execute_statement::ExecuteStatementInput,
242                output: &mut ::std::string::String,
243            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
244                use ::std::fmt::Write as _;
245                ::std::write!(output, "/").expect("formatting should succeed");
246                ::std::result::Result::Ok(())
247            }
248            #[allow(clippy::unnecessary_wraps)]
249            fn update_http_builder(
250                input: &crate::operation::execute_statement::ExecuteStatementInput,
251                builder: ::http_1x::request::Builder,
252            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
253                let mut uri = ::std::string::String::new();
254                uri_base(input, &mut uri)?;
255                ::std::result::Result::Ok(builder.method("POST").uri(uri))
256            }
257            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
258            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/x-amz-json-1.0");
259            builder = _header_serialization_settings.set_default_header(
260                builder,
261                ::http_1x::header::HeaderName::from_static("x-amz-target"),
262                "DynamoDB_20120810.ExecuteStatement",
263            );
264            builder
265        };
266        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_execute_statement::ser_execute_statement_input(&input)?);
267        if let Some(content_length) = body.content_length() {
268            let content_length = content_length.to_string();
269            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
270        }
271        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
272    }
273}
274#[derive(Debug)]
275struct ExecuteStatementEndpointParamsInterceptor;
276
277#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
278impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ExecuteStatementEndpointParamsInterceptor {
279    fn name(&self) -> &'static str {
280        "ExecuteStatementEndpointParamsInterceptor"
281    }
282
283    fn read_before_execution(
284        &self,
285        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
286            '_,
287            ::aws_smithy_runtime_api::client::interceptors::context::Input,
288            ::aws_smithy_runtime_api::client::interceptors::context::Output,
289            ::aws_smithy_runtime_api::client::interceptors::context::Error,
290        >,
291        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
292    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
293        let _input = context
294            .input()
295            .downcast_ref::<ExecuteStatementInput>()
296            .ok_or("failed to downcast to ExecuteStatementInput")?;
297
298        let params = crate::config::endpoint::Params::builder()
299            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
300            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
301            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
302            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
303            .set_account_id_endpoint_mode(::std::option::Option::Some(
304                cfg.load::<::aws_types::endpoint_config::AccountIdEndpointMode>()
305                    .cloned()
306                    .unwrap_or_default()
307                    .to_string(),
308            ))
309            .build()
310            .map_err(|err| {
311                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
312            })?;
313        cfg.interceptor_state()
314            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
315        ::std::result::Result::Ok(())
316    }
317}
318
319// The get_* functions below are generated from JMESPath expressions in the
320// operationContextParams trait. They target the operation's input shape.
321
322/// Error type for the `ExecuteStatementError` operation.
323#[non_exhaustive]
324#[derive(::std::fmt::Debug)]
325pub enum ExecuteStatementError {
326    /// <p>A condition specified in the operation failed to be evaluated.</p>
327    ConditionalCheckFailedException(crate::types::error::ConditionalCheckFailedException),
328    /// <p>There was an attempt to insert an item with the same primary key as an item that already exists in the DynamoDB table.</p>
329    DuplicateItemException(crate::types::error::DuplicateItemException),
330    /// <p>An error occurred on the server side.</p>
331    InternalServerError(crate::types::error::InternalServerError),
332    /// <p>An item collection is too large. This exception is only returned for tables that have one or more local secondary indexes.</p>
333    ItemCollectionSizeLimitExceededException(crate::types::error::ItemCollectionSizeLimitExceededException),
334    /// <p>The request was denied due to request throttling. For detailed information about why the request was throttled and the ARN of the impacted resource, find the <a href="https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_ThrottlingReason.html">ThrottlingReason</a> field in the returned exception. The Amazon Web Services SDKs for DynamoDB automatically retry requests that receive this exception. Your request is eventually successful, unless your retry queue is too large to finish. Reduce the frequency of requests and use exponential backoff. For more information, go to <a href="https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Programming.Errors.html#Programming.Errors.RetryAndBackoff">Error Retries and Exponential Backoff</a> in the <i>Amazon DynamoDB Developer Guide</i>.</p>
335    ProvisionedThroughputExceededException(crate::types::error::ProvisionedThroughputExceededException),
336    /// <p>Throughput exceeds the current throughput quota for your account. For detailed information about why the request was throttled and the ARN of the impacted resource, find the <a href="https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_ThrottlingReason.html">ThrottlingReason</a> field in the returned exception. Contact <a href="https://aws.amazon.com/support">Amazon Web Services Support</a> to request a quota increase.</p>
337    RequestLimitExceeded(crate::types::error::RequestLimitExceeded),
338    /// <p>The operation tried to access a nonexistent table or index. The resource might not be specified correctly, or its status might not be <code>ACTIVE</code>.</p>
339    ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
340    /// <p>The request was denied due to request throttling. For detailed information about why the request was throttled and the ARN of the impacted resource, find the <a href="https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_ThrottlingReason.html">ThrottlingReason</a> field in the returned exception.</p>
341    ThrottlingException(crate::types::error::ThrottlingException),
342    /// <p>Operation was rejected because there is an ongoing transaction for the item.</p>
343    TransactionConflictException(crate::types::error::TransactionConflictException),
344    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
345    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
346    variable wildcard pattern and check `.code()`:
347     \
348    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
349     \
350    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-ExecuteStatementError) for what information is available for the error.")]
351    Unhandled(crate::error::sealed_unhandled::Unhandled),
352}
353impl ExecuteStatementError {
354    /// Creates the `ExecuteStatementError::Unhandled` variant from any error type.
355    pub fn unhandled(
356        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
357    ) -> Self {
358        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
359            source: err.into(),
360            meta: ::std::default::Default::default(),
361        })
362    }
363
364    /// Creates the `ExecuteStatementError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
365    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
366        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
367            source: err.clone().into(),
368            meta: err,
369        })
370    }
371    ///
372    /// Returns error metadata, which includes the error code, message,
373    /// request ID, and potentially additional information.
374    ///
375    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
376        match self {
377            Self::ConditionalCheckFailedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
378            Self::DuplicateItemException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
379            Self::InternalServerError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
380            Self::ItemCollectionSizeLimitExceededException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
381            Self::ProvisionedThroughputExceededException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
382            Self::RequestLimitExceeded(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
383            Self::ResourceNotFoundException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
384            Self::ThrottlingException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
385            Self::TransactionConflictException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
386            Self::Unhandled(e) => &e.meta,
387        }
388    }
389    /// Returns `true` if the error kind is `ExecuteStatementError::ConditionalCheckFailedException`.
390    pub fn is_conditional_check_failed_exception(&self) -> bool {
391        matches!(self, Self::ConditionalCheckFailedException(_))
392    }
393    /// Returns `true` if the error kind is `ExecuteStatementError::DuplicateItemException`.
394    pub fn is_duplicate_item_exception(&self) -> bool {
395        matches!(self, Self::DuplicateItemException(_))
396    }
397    /// Returns `true` if the error kind is `ExecuteStatementError::InternalServerError`.
398    pub fn is_internal_server_error(&self) -> bool {
399        matches!(self, Self::InternalServerError(_))
400    }
401    /// Returns `true` if the error kind is `ExecuteStatementError::ItemCollectionSizeLimitExceededException`.
402    pub fn is_item_collection_size_limit_exceeded_exception(&self) -> bool {
403        matches!(self, Self::ItemCollectionSizeLimitExceededException(_))
404    }
405    /// Returns `true` if the error kind is `ExecuteStatementError::ProvisionedThroughputExceededException`.
406    pub fn is_provisioned_throughput_exceeded_exception(&self) -> bool {
407        matches!(self, Self::ProvisionedThroughputExceededException(_))
408    }
409    /// Returns `true` if the error kind is `ExecuteStatementError::RequestLimitExceeded`.
410    pub fn is_request_limit_exceeded(&self) -> bool {
411        matches!(self, Self::RequestLimitExceeded(_))
412    }
413    /// Returns `true` if the error kind is `ExecuteStatementError::ResourceNotFoundException`.
414    pub fn is_resource_not_found_exception(&self) -> bool {
415        matches!(self, Self::ResourceNotFoundException(_))
416    }
417    /// Returns `true` if the error kind is `ExecuteStatementError::ThrottlingException`.
418    pub fn is_throttling_exception(&self) -> bool {
419        matches!(self, Self::ThrottlingException(_))
420    }
421    /// Returns `true` if the error kind is `ExecuteStatementError::TransactionConflictException`.
422    pub fn is_transaction_conflict_exception(&self) -> bool {
423        matches!(self, Self::TransactionConflictException(_))
424    }
425}
426impl ::std::error::Error for ExecuteStatementError {
427    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
428        match self {
429            Self::ConditionalCheckFailedException(_inner) => ::std::option::Option::Some(_inner),
430            Self::DuplicateItemException(_inner) => ::std::option::Option::Some(_inner),
431            Self::InternalServerError(_inner) => ::std::option::Option::Some(_inner),
432            Self::ItemCollectionSizeLimitExceededException(_inner) => ::std::option::Option::Some(_inner),
433            Self::ProvisionedThroughputExceededException(_inner) => ::std::option::Option::Some(_inner),
434            Self::RequestLimitExceeded(_inner) => ::std::option::Option::Some(_inner),
435            Self::ResourceNotFoundException(_inner) => ::std::option::Option::Some(_inner),
436            Self::ThrottlingException(_inner) => ::std::option::Option::Some(_inner),
437            Self::TransactionConflictException(_inner) => ::std::option::Option::Some(_inner),
438            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
439        }
440    }
441}
442impl ::std::fmt::Display for ExecuteStatementError {
443    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
444        match self {
445            Self::ConditionalCheckFailedException(_inner) => _inner.fmt(f),
446            Self::DuplicateItemException(_inner) => _inner.fmt(f),
447            Self::InternalServerError(_inner) => _inner.fmt(f),
448            Self::ItemCollectionSizeLimitExceededException(_inner) => _inner.fmt(f),
449            Self::ProvisionedThroughputExceededException(_inner) => _inner.fmt(f),
450            Self::RequestLimitExceeded(_inner) => _inner.fmt(f),
451            Self::ResourceNotFoundException(_inner) => _inner.fmt(f),
452            Self::ThrottlingException(_inner) => _inner.fmt(f),
453            Self::TransactionConflictException(_inner) => _inner.fmt(f),
454            Self::Unhandled(_inner) => {
455                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
456                    write!(f, "unhandled error ({code})")
457                } else {
458                    f.write_str("unhandled error")
459                }
460            }
461        }
462    }
463}
464impl ::aws_smithy_types::retry::ProvideErrorKind for ExecuteStatementError {
465    fn code(&self) -> ::std::option::Option<&str> {
466        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
467    }
468    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
469        ::std::option::Option::None
470    }
471}
472impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for ExecuteStatementError {
473    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
474        match self {
475            Self::ConditionalCheckFailedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
476            Self::DuplicateItemException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
477            Self::InternalServerError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
478            Self::ItemCollectionSizeLimitExceededException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
479            Self::ProvisionedThroughputExceededException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
480            Self::RequestLimitExceeded(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
481            Self::ResourceNotFoundException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
482            Self::ThrottlingException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
483            Self::TransactionConflictException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
484            Self::Unhandled(_inner) => &_inner.meta,
485        }
486    }
487}
488impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for ExecuteStatementError {
489    fn create_unhandled_error(
490        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
491        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
492    ) -> Self {
493        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
494            source,
495            meta: meta.unwrap_or_default(),
496        })
497    }
498}
499impl ::aws_types::request_id::RequestId for crate::operation::execute_statement::ExecuteStatementError {
500    fn request_id(&self) -> Option<&str> {
501        self.meta().request_id()
502    }
503}
504
505pub use crate::operation::execute_statement::_execute_statement_input::ExecuteStatementInput;
506
507pub use crate::operation::execute_statement::_execute_statement_output::ExecuteStatementOutput;
508
509mod _execute_statement_input;
510
511mod _execute_statement_output;
512
513/// Builders
514pub mod builders;
aws_sdk_dynamodb/operation/execute_statement.rs

aws_sdk_dynamodb/operation/
execute_statement.rs
