aws_sdk_databasemigration/protocol_serde/
shape_oracle_settings.rs1pub fn ser_oracle_settings(
3 object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
4 input: &crate::types::OracleSettings,
5) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
6 if let Some(var_1) = &input.add_supplemental_logging {
7 object.key("AddSupplementalLogging").boolean(*var_1);
8 }
9 if let Some(var_2) = &input.archived_log_dest_id {
10 object.key("ArchivedLogDestId").number(
11 #[allow(clippy::useless_conversion)]
12 ::aws_smithy_types::Number::NegInt((*var_2).into()),
13 );
14 }
15 if let Some(var_3) = &input.additional_archived_log_dest_id {
16 object.key("AdditionalArchivedLogDestId").number(
17 #[allow(clippy::useless_conversion)]
18 ::aws_smithy_types::Number::NegInt((*var_3).into()),
19 );
20 }
21 if let Some(var_4) = &input.extra_archived_log_dest_ids {
22 let mut array_5 = object.key("ExtraArchivedLogDestIds").start_array();
23 for item_6 in var_4 {
24 {
25 array_5.value().number(
26 #[allow(clippy::useless_conversion)]
27 ::aws_smithy_types::Number::NegInt((*item_6).into()),
28 );
29 }
30 }
31 array_5.finish();
32 }
33 if let Some(var_7) = &input.allow_select_nested_tables {
34 object.key("AllowSelectNestedTables").boolean(*var_7);
35 }
36 if let Some(var_8) = &input.parallel_asm_read_threads {
37 object.key("ParallelAsmReadThreads").number(
38 #[allow(clippy::useless_conversion)]
39 ::aws_smithy_types::Number::NegInt((*var_8).into()),
40 );
41 }
42 if let Some(var_9) = &input.read_ahead_blocks {
43 object.key("ReadAheadBlocks").number(
44 #[allow(clippy::useless_conversion)]
45 ::aws_smithy_types::Number::NegInt((*var_9).into()),
46 );
47 }
48 if let Some(var_10) = &input.access_alternate_directly {
49 object.key("AccessAlternateDirectly").boolean(*var_10);
50 }
51 if let Some(var_11) = &input.use_alternate_folder_for_online {
52 object.key("UseAlternateFolderForOnline").boolean(*var_11);
53 }
54 if let Some(var_12) = &input.oracle_path_prefix {
55 object.key("OraclePathPrefix").string(var_12.as_str());
56 }
57 if let Some(var_13) = &input.use_path_prefix {
58 object.key("UsePathPrefix").string(var_13.as_str());
59 }
60 if let Some(var_14) = &input.replace_path_prefix {
61 object.key("ReplacePathPrefix").boolean(*var_14);
62 }
63 if let Some(var_15) = &input.enable_homogenous_tablespace {
64 object.key("EnableHomogenousTablespace").boolean(*var_15);
65 }
66 if let Some(var_16) = &input.direct_path_no_log {
67 object.key("DirectPathNoLog").boolean(*var_16);
68 }
69 if let Some(var_17) = &input.archived_logs_only {
70 object.key("ArchivedLogsOnly").boolean(*var_17);
71 }
72 if let Some(var_18) = &input.asm_password {
73 object.key("AsmPassword").string(var_18.as_str());
74 }
75 if let Some(var_19) = &input.asm_server {
76 object.key("AsmServer").string(var_19.as_str());
77 }
78 if let Some(var_20) = &input.asm_user {
79 object.key("AsmUser").string(var_20.as_str());
80 }
81 if let Some(var_21) = &input.char_length_semantics {
82 object.key("CharLengthSemantics").string(var_21.as_str());
83 }
84 if let Some(var_22) = &input.database_name {
85 object.key("DatabaseName").string(var_22.as_str());
86 }
87 if let Some(var_23) = &input.direct_path_parallel_load {
88 object.key("DirectPathParallelLoad").boolean(*var_23);
89 }
90 if let Some(var_24) = &input.fail_tasks_on_lob_truncation {
91 object.key("FailTasksOnLobTruncation").boolean(*var_24);
92 }
93 if let Some(var_25) = &input.number_datatype_scale {
94 object.key("NumberDatatypeScale").number(
95 #[allow(clippy::useless_conversion)]
96 ::aws_smithy_types::Number::NegInt((*var_25).into()),
97 );
98 }
99 if let Some(var_26) = &input.password {
100 object.key("Password").string(var_26.as_str());
101 }
102 if let Some(var_27) = &input.port {
103 object.key("Port").number(
104 #[allow(clippy::useless_conversion)]
105 ::aws_smithy_types::Number::NegInt((*var_27).into()),
106 );
107 }
108 if let Some(var_28) = &input.read_table_space_name {
109 object.key("ReadTableSpaceName").boolean(*var_28);
110 }
111 if let Some(var_29) = &input.retry_interval {
112 object.key("RetryInterval").number(
113 #[allow(clippy::useless_conversion)]
114 ::aws_smithy_types::Number::NegInt((*var_29).into()),
115 );
116 }
117 if let Some(var_30) = &input.security_db_encryption {
118 object.key("SecurityDbEncryption").string(var_30.as_str());
119 }
120 if let Some(var_31) = &input.security_db_encryption_name {
121 object.key("SecurityDbEncryptionName").string(var_31.as_str());
122 }
123 if let Some(var_32) = &input.server_name {
124 object.key("ServerName").string(var_32.as_str());
125 }
126 if let Some(var_33) = &input.spatial_data_option_to_geo_json_function_name {
127 object.key("SpatialDataOptionToGeoJsonFunctionName").string(var_33.as_str());
128 }
129 if let Some(var_34) = &input.standby_delay_time {
130 object.key("StandbyDelayTime").number(
131 #[allow(clippy::useless_conversion)]
132 ::aws_smithy_types::Number::NegInt((*var_34).into()),
133 );
134 }
135 if let Some(var_35) = &input.username {
136 object.key("Username").string(var_35.as_str());
137 }
138 if let Some(var_36) = &input.use_b_file {
139 object.key("UseBFile").boolean(*var_36);
140 }
141 if let Some(var_37) = &input.use_direct_path_full_load {
142 object.key("UseDirectPathFullLoad").boolean(*var_37);
143 }
144 if let Some(var_38) = &input.use_logminer_reader {
145 object.key("UseLogminerReader").boolean(*var_38);
146 }
147 if let Some(var_39) = &input.secrets_manager_access_role_arn {
148 object.key("SecretsManagerAccessRoleArn").string(var_39.as_str());
149 }
150 if let Some(var_40) = &input.secrets_manager_secret_id {
151 object.key("SecretsManagerSecretId").string(var_40.as_str());
152 }
153 if let Some(var_41) = &input.secrets_manager_oracle_asm_access_role_arn {
154 object.key("SecretsManagerOracleAsmAccessRoleArn").string(var_41.as_str());
155 }
156 if let Some(var_42) = &input.secrets_manager_oracle_asm_secret_id {
157 object.key("SecretsManagerOracleAsmSecretId").string(var_42.as_str());
158 }
159 if let Some(var_43) = &input.trim_space_in_char {
160 object.key("TrimSpaceInChar").boolean(*var_43);
161 }
162 if let Some(var_44) = &input.convert_timestamp_with_zone_to_utc {
163 object.key("ConvertTimestampWithZoneToUTC").boolean(*var_44);
164 }
165 if let Some(var_45) = &input.open_transaction_window {
166 object.key("OpenTransactionWindow").number(
167 #[allow(clippy::useless_conversion)]
168 ::aws_smithy_types::Number::NegInt((*var_45).into()),
169 );
170 }
171 if let Some(var_46) = &input.authentication_method {
172 object.key("AuthenticationMethod").string(var_46.as_str());
173 }
174 Ok(())
175}
176
177pub(crate) fn de_oracle_settings<'a, I>(
178 tokens: &mut ::std::iter::Peekable<I>,
179) -> ::std::result::Result<Option<crate::types::OracleSettings>, ::aws_smithy_json::deserialize::error::DeserializeError>
180where
181 I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
182{
183 match tokens.next().transpose()? {
184 Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
185 Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
186 #[allow(unused_mut)]
187 let mut builder = crate::types::builders::OracleSettingsBuilder::default();
188 loop {
189 match tokens.next().transpose()? {
190 Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
191 Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
192 "AddSupplementalLogging" => {
193 builder =
194 builder.set_add_supplemental_logging(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
195 }
196 "ArchivedLogDestId" => {
197 builder = builder.set_archived_log_dest_id(
198 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
199 .map(i32::try_from)
200 .transpose()?,
201 );
202 }
203 "AdditionalArchivedLogDestId" => {
204 builder = builder.set_additional_archived_log_dest_id(
205 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
206 .map(i32::try_from)
207 .transpose()?,
208 );
209 }
210 "ExtraArchivedLogDestIds" => {
211 builder = builder.set_extra_archived_log_dest_ids(crate::protocol_serde::shape_integer_list::de_integer_list(tokens)?);
212 }
213 "AllowSelectNestedTables" => {
214 builder =
215 builder.set_allow_select_nested_tables(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
216 }
217 "ParallelAsmReadThreads" => {
218 builder = builder.set_parallel_asm_read_threads(
219 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
220 .map(i32::try_from)
221 .transpose()?,
222 );
223 }
224 "ReadAheadBlocks" => {
225 builder = builder.set_read_ahead_blocks(
226 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
227 .map(i32::try_from)
228 .transpose()?,
229 );
230 }
231 "AccessAlternateDirectly" => {
232 builder =
233 builder.set_access_alternate_directly(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
234 }
235 "UseAlternateFolderForOnline" => {
236 builder = builder
237 .set_use_alternate_folder_for_online(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
238 }
239 "OraclePathPrefix" => {
240 builder = builder.set_oracle_path_prefix(
241 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
242 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
243 .transpose()?,
244 );
245 }
246 "UsePathPrefix" => {
247 builder = builder.set_use_path_prefix(
248 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
249 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
250 .transpose()?,
251 );
252 }
253 "ReplacePathPrefix" => {
254 builder = builder.set_replace_path_prefix(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
255 }
256 "EnableHomogenousTablespace" => {
257 builder =
258 builder.set_enable_homogenous_tablespace(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
259 }
260 "DirectPathNoLog" => {
261 builder = builder.set_direct_path_no_log(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
262 }
263 "ArchivedLogsOnly" => {
264 builder = builder.set_archived_logs_only(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
265 }
266 "AsmPassword" => {
267 builder = builder.set_asm_password(
268 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
269 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
270 .transpose()?,
271 );
272 }
273 "AsmServer" => {
274 builder = builder.set_asm_server(
275 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
276 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
277 .transpose()?,
278 );
279 }
280 "AsmUser" => {
281 builder = builder.set_asm_user(
282 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
283 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
284 .transpose()?,
285 );
286 }
287 "CharLengthSemantics" => {
288 builder = builder.set_char_length_semantics(
289 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
290 .map(|s| s.to_unescaped().map(|u| crate::types::CharLengthSemantics::from(u.as_ref())))
291 .transpose()?,
292 );
293 }
294 "DatabaseName" => {
295 builder = builder.set_database_name(
296 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
297 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
298 .transpose()?,
299 );
300 }
301 "DirectPathParallelLoad" => {
302 builder =
303 builder.set_direct_path_parallel_load(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
304 }
305 "FailTasksOnLobTruncation" => {
306 builder =
307 builder.set_fail_tasks_on_lob_truncation(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
308 }
309 "NumberDatatypeScale" => {
310 builder = builder.set_number_datatype_scale(
311 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
312 .map(i32::try_from)
313 .transpose()?,
314 );
315 }
316 "Password" => {
317 builder = builder.set_password(
318 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
319 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
320 .transpose()?,
321 );
322 }
323 "Port" => {
324 builder = builder.set_port(
325 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
326 .map(i32::try_from)
327 .transpose()?,
328 );
329 }
330 "ReadTableSpaceName" => {
331 builder = builder.set_read_table_space_name(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
332 }
333 "RetryInterval" => {
334 builder = builder.set_retry_interval(
335 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
336 .map(i32::try_from)
337 .transpose()?,
338 );
339 }
340 "SecurityDbEncryption" => {
341 builder = builder.set_security_db_encryption(
342 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
343 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
344 .transpose()?,
345 );
346 }
347 "SecurityDbEncryptionName" => {
348 builder = builder.set_security_db_encryption_name(
349 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
350 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
351 .transpose()?,
352 );
353 }
354 "ServerName" => {
355 builder = builder.set_server_name(
356 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
357 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
358 .transpose()?,
359 );
360 }
361 "SpatialDataOptionToGeoJsonFunctionName" => {
362 builder = builder.set_spatial_data_option_to_geo_json_function_name(
363 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
364 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
365 .transpose()?,
366 );
367 }
368 "StandbyDelayTime" => {
369 builder = builder.set_standby_delay_time(
370 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
371 .map(i32::try_from)
372 .transpose()?,
373 );
374 }
375 "Username" => {
376 builder = builder.set_username(
377 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
378 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
379 .transpose()?,
380 );
381 }
382 "UseBFile" => {
383 builder = builder.set_use_b_file(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
384 }
385 "UseDirectPathFullLoad" => {
386 builder =
387 builder.set_use_direct_path_full_load(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
388 }
389 "UseLogminerReader" => {
390 builder = builder.set_use_logminer_reader(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
391 }
392 "SecretsManagerAccessRoleArn" => {
393 builder = builder.set_secrets_manager_access_role_arn(
394 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
395 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
396 .transpose()?,
397 );
398 }
399 "SecretsManagerSecretId" => {
400 builder = builder.set_secrets_manager_secret_id(
401 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
402 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
403 .transpose()?,
404 );
405 }
406 "SecretsManagerOracleAsmAccessRoleArn" => {
407 builder = builder.set_secrets_manager_oracle_asm_access_role_arn(
408 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
409 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
410 .transpose()?,
411 );
412 }
413 "SecretsManagerOracleAsmSecretId" => {
414 builder = builder.set_secrets_manager_oracle_asm_secret_id(
415 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
416 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
417 .transpose()?,
418 );
419 }
420 "TrimSpaceInChar" => {
421 builder = builder.set_trim_space_in_char(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
422 }
423 "ConvertTimestampWithZoneToUTC" => {
424 builder = builder
425 .set_convert_timestamp_with_zone_to_utc(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
426 }
427 "OpenTransactionWindow" => {
428 builder = builder.set_open_transaction_window(
429 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
430 .map(i32::try_from)
431 .transpose()?,
432 );
433 }
434 "AuthenticationMethod" => {
435 builder = builder.set_authentication_method(
436 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
437 .map(|s| s.to_unescaped().map(|u| crate::types::OracleAuthenticationMethod::from(u.as_ref())))
438 .transpose()?,
439 );
440 }
441 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
442 },
443 other => {
444 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
445 "expected object key or end object, found: {:?}",
446 other
447 )))
448 }
449 }
450 }
451 Ok(Some(builder.build()))
452 }
453 _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
454 "expected start object or null",
455 )),
456 }
457}