# WARNING: DO NOT EDIT, AUTO-GENERATED CODE!
# See https://github.com/aws-beam/aws-codegen for more details.
defmodule AWS.RDSData do
@moduledoc """
RDS Data API
Amazon RDS provides an HTTP endpoint to run SQL statements on an Amazon Aurora
DB cluster.
To run these statements, you use the RDS Data API (Data API).
Data API is available with the following types of Aurora databases:
* Aurora PostgreSQL - Serverless v2, provisioned, and Serverless v1
* Aurora MySQL - Serverless v2, provisioned, and Serverless v1
For more information about the Data API, see [Using RDS Data API](https://docs.aws.amazon.com/AmazonRDS/latest/AuroraUserGuide/data-api.html)
in the *Amazon Aurora User Guide*.
"""
alias AWS.Client
alias AWS.Request
@typedoc """
## Example:
rollback_transaction_request() :: %{
"resourceArn" => String.t() | atom(),
"secretArn" => String.t() | atom(),
"transactionId" => String.t() | atom()
}
"""
@type rollback_transaction_request() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
database_unavailable_exception() :: %{}
"""
@type database_unavailable_exception() :: %{}
@typedoc """
## Example:
access_denied_exception() :: %{
"message" => String.t() | atom()
}
"""
@type access_denied_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
invalid_resource_state_exception() :: %{
"message" => String.t() | atom()
}
"""
@type invalid_resource_state_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
execute_sql_response() :: %{
"sqlStatementResults" => list(sql_statement_result())
}
"""
@type execute_sql_response() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
service_unavailable_error() :: %{}
"""
@type service_unavailable_error() :: %{}
@typedoc """
## Example:
result_set_options() :: %{
"decimalReturnType" => list(any()),
"longReturnType" => list(any())
}
"""
@type result_set_options() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
column_metadata() :: %{
"arrayBaseColumnType" => integer(),
"isAutoIncrement" => boolean(),
"isCaseSensitive" => boolean(),
"isCurrency" => boolean(),
"isSigned" => boolean(),
"label" => String.t() | atom(),
"name" => String.t() | atom(),
"nullable" => integer(),
"precision" => integer(),
"scale" => integer(),
"schemaName" => String.t() | atom(),
"tableName" => String.t() | atom(),
"type" => integer(),
"typeName" => String.t() | atom()
}
"""
@type column_metadata() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
begin_transaction_request() :: %{
"database" => String.t() | atom(),
"resourceArn" => String.t() | atom(),
"schema" => String.t() | atom(),
"secretArn" => String.t() | atom()
}
"""
@type begin_transaction_request() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
begin_transaction_response() :: %{
"transactionId" => String.t() | atom()
}
"""
@type begin_transaction_response() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
execute_statement_response() :: %{
"columnMetadata" => list(column_metadata()),
"formattedRecords" => String.t() | atom(),
"generatedFields" => list(list()),
"numberOfRecordsUpdated" => float(),
"records" => list(list(list())())
}
"""
@type execute_statement_response() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
database_error_exception() :: %{
"message" => String.t() | atom()
}
"""
@type database_error_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
sql_statement_result() :: %{
"numberOfRecordsUpdated" => float(),
"resultFrame" => result_frame()
}
"""
@type sql_statement_result() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
commit_transaction_response() :: %{
"transactionStatus" => String.t() | atom()
}
"""
@type commit_transaction_response() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
batch_execute_statement_request() :: %{
"database" => String.t() | atom(),
"parameterSets" => list(list(sql_parameter())()),
"resourceArn" => String.t() | atom(),
"schema" => String.t() | atom(),
"secretArn" => String.t() | atom(),
"sql" => String.t() | atom(),
"transactionId" => String.t() | atom()
}
"""
@type batch_execute_statement_request() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
batch_execute_statement_response() :: %{
"updateResults" => list(update_result())
}
"""
@type batch_execute_statement_response() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
result_set_metadata() :: %{
"columnCount" => float(),
"columnMetadata" => list(column_metadata())
}
"""
@type result_set_metadata() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
internal_server_error_exception() :: %{}
"""
@type internal_server_error_exception() :: %{}
@typedoc """
## Example:
http_endpoint_not_enabled_exception() :: %{
"message" => String.t() | atom()
}
"""
@type http_endpoint_not_enabled_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
struct_value() :: %{
"attributes" => list(list())
}
"""
@type struct_value() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
not_found_exception() :: %{
"message" => String.t() | atom()
}
"""
@type not_found_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
execute_sql_request() :: %{
"awsSecretStoreArn" => String.t() | atom(),
"database" => String.t() | atom(),
"dbClusterOrInstanceArn" => String.t() | atom(),
"schema" => String.t() | atom(),
"sqlStatements" => String.t() | atom()
}
"""
@type execute_sql_request() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
unsupported_result_exception() :: %{
"message" => String.t() | atom()
}
"""
@type unsupported_result_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
invalid_secret_exception() :: %{
"message" => String.t() | atom()
}
"""
@type invalid_secret_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
database_resuming_exception() :: %{
"message" => String.t() | atom()
}
"""
@type database_resuming_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
update_result() :: %{
"generatedFields" => list(list())
}
"""
@type update_result() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
rdsdata_record() :: %{
"values" => list(list())
}
"""
@type rdsdata_record() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
statement_timeout_exception() :: %{
"dbConnectionId" => float(),
"message" => String.t() | atom()
}
"""
@type statement_timeout_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
secrets_error_exception() :: %{
"message" => String.t() | atom()
}
"""
@type secrets_error_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
result_frame() :: %{
"records" => list(record()),
"resultSetMetadata" => result_set_metadata()
}
"""
@type result_frame() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
sql_parameter() :: %{
"name" => String.t() | atom(),
"typeHint" => list(any()),
"value" => list()
}
"""
@type sql_parameter() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
forbidden_exception() :: %{
"message" => String.t() | atom()
}
"""
@type forbidden_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
bad_request_exception() :: %{
"message" => String.t() | atom()
}
"""
@type bad_request_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
transaction_not_found_exception() :: %{
"message" => String.t() | atom()
}
"""
@type transaction_not_found_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
rollback_transaction_response() :: %{
"transactionStatus" => String.t() | atom()
}
"""
@type rollback_transaction_response() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
database_not_found_exception() :: %{
"message" => String.t() | atom()
}
"""
@type database_not_found_exception() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
commit_transaction_request() :: %{
"resourceArn" => String.t() | atom(),
"secretArn" => String.t() | atom(),
"transactionId" => String.t() | atom()
}
"""
@type commit_transaction_request() :: %{(String.t() | atom()) => any()}
@typedoc """
## Example:
execute_statement_request() :: %{
"continueAfterTimeout" => boolean(),
"database" => String.t() | atom(),
"formatRecordsAs" => list(any()),
"includeResultMetadata" => boolean(),
"parameters" => list(sql_parameter()),
"resourceArn" => String.t() | atom(),
"resultSetOptions" => result_set_options(),
"schema" => String.t() | atom(),
"secretArn" => String.t() | atom(),
"sql" => String.t() | atom(),
"transactionId" => String.t() | atom()
}
"""
@type execute_statement_request() :: %{(String.t() | atom()) => any()}
@type batch_execute_statement_errors() ::
database_not_found_exception()
| transaction_not_found_exception()
| bad_request_exception()
| forbidden_exception()
| secrets_error_exception()
| statement_timeout_exception()
| database_resuming_exception()
| invalid_secret_exception()
| http_endpoint_not_enabled_exception()
| internal_server_error_exception()
| database_error_exception()
| service_unavailable_error()
| invalid_resource_state_exception()
| access_denied_exception()
| database_unavailable_exception()
@type begin_transaction_errors() ::
database_not_found_exception()
| transaction_not_found_exception()
| bad_request_exception()
| forbidden_exception()
| secrets_error_exception()
| statement_timeout_exception()
| database_resuming_exception()
| invalid_secret_exception()
| http_endpoint_not_enabled_exception()
| internal_server_error_exception()
| database_error_exception()
| service_unavailable_error()
| invalid_resource_state_exception()
| access_denied_exception()
| database_unavailable_exception()
@type commit_transaction_errors() ::
database_not_found_exception()
| transaction_not_found_exception()
| bad_request_exception()
| forbidden_exception()
| secrets_error_exception()
| statement_timeout_exception()
| invalid_secret_exception()
| not_found_exception()
| http_endpoint_not_enabled_exception()
| internal_server_error_exception()
| database_error_exception()
| service_unavailable_error()
| invalid_resource_state_exception()
| access_denied_exception()
| database_unavailable_exception()
@type execute_sql_errors() ::
bad_request_exception()
| forbidden_exception()
| internal_server_error_exception()
| service_unavailable_error()
| access_denied_exception()
@type execute_statement_errors() ::
database_not_found_exception()
| transaction_not_found_exception()
| bad_request_exception()
| forbidden_exception()
| secrets_error_exception()
| statement_timeout_exception()
| database_resuming_exception()
| invalid_secret_exception()
| unsupported_result_exception()
| http_endpoint_not_enabled_exception()
| internal_server_error_exception()
| database_error_exception()
| service_unavailable_error()
| invalid_resource_state_exception()
| access_denied_exception()
| database_unavailable_exception()
@type rollback_transaction_errors() ::
database_not_found_exception()
| transaction_not_found_exception()
| bad_request_exception()
| forbidden_exception()
| secrets_error_exception()
| statement_timeout_exception()
| invalid_secret_exception()
| not_found_exception()
| http_endpoint_not_enabled_exception()
| internal_server_error_exception()
| database_error_exception()
| service_unavailable_error()
| invalid_resource_state_exception()
| access_denied_exception()
| database_unavailable_exception()
def metadata do
%{
api_version: "2018-08-01",
content_type: "application/x-amz-json-1.1",
credential_scope: nil,
endpoint_prefix: "rds-data",
global?: false,
hostname: nil,
protocol: "rest-json",
service_id: "RDS Data",
signature_version: "v4",
signing_name: "rds-data",
target_prefix: nil
}
end
@doc """
Runs a batch SQL statement over an array of data.
You can run bulk update and insert operations for multiple records using a DML
statement with different parameter sets. Bulk operations can provide a
significant performance improvement over individual insert and update
operations.
If a call isn't part of a transaction because it doesn't include the
`transactionID` parameter, changes that result from the call are committed
automatically.
There isn't a fixed upper limit on the number of parameter sets. However, the
maximum size of the HTTP request submitted through the Data API is 4 MiB. If the
request exceeds this limit, the Data API returns an error and doesn't process
the request. This 4-MiB limit includes the size of the HTTP headers and the JSON
notation in the request. Thus, the number of parameter sets that you can include
depends on a combination of factors, such as the size of the SQL statement and
the size of each parameter set.
The response size limit is 1 MiB. If the call returns more than 1 MiB of
response data, the call is terminated.
"""
@spec batch_execute_statement(map(), batch_execute_statement_request(), list()) ::
{:ok, batch_execute_statement_response(), any()}
| {:error, {:unexpected_response, any()}}
| {:error, term()}
| {:error, batch_execute_statement_errors()}
def batch_execute_statement(%Client{} = client, input, options \\ []) do
url_path = "/BatchExecute"
headers = []
custom_headers = []
query_params = []
meta = metadata()
Request.request_rest(
client,
meta,
:post,
url_path,
query_params,
custom_headers ++ headers,
input,
options,
200
)
end
@doc """
Starts a SQL transaction.
A transaction can run for a maximum of 24 hours. A transaction is terminated and
rolled back automatically after 24 hours.
A transaction times out if no calls use its transaction ID in three minutes. If
a transaction times out before it's committed, it's rolled back automatically.
For Aurora MySQL, DDL statements inside a transaction cause an implicit commit.
We recommend that you run each MySQL DDL statement in a separate
`ExecuteStatement` call with `continueAfterTimeout` enabled.
"""
@spec begin_transaction(map(), begin_transaction_request(), list()) ::
{:ok, begin_transaction_response(), any()}
| {:error, {:unexpected_response, any()}}
| {:error, term()}
| {:error, begin_transaction_errors()}
def begin_transaction(%Client{} = client, input, options \\ []) do
url_path = "/BeginTransaction"
headers = []
custom_headers = []
query_params = []
meta = metadata()
Request.request_rest(
client,
meta,
:post,
url_path,
query_params,
custom_headers ++ headers,
input,
options,
200
)
end
@doc """
Ends a SQL transaction started with the `BeginTransaction` operation and commits
the changes.
"""
@spec commit_transaction(map(), commit_transaction_request(), list()) ::
{:ok, commit_transaction_response(), any()}
| {:error, {:unexpected_response, any()}}
| {:error, term()}
| {:error, commit_transaction_errors()}
def commit_transaction(%Client{} = client, input, options \\ []) do
url_path = "/CommitTransaction"
headers = []
custom_headers = []
query_params = []
meta = metadata()
Request.request_rest(
client,
meta,
:post,
url_path,
query_params,
custom_headers ++ headers,
input,
options,
200
)
end
@doc """
Runs one or more SQL statements.
This operation isn't supported for Aurora Serverless v2 and provisioned DB
clusters. For Aurora Serverless v1 DB clusters, the operation is deprecated. Use
the `BatchExecuteStatement` or `ExecuteStatement` operation.
"""
@spec execute_sql(map(), execute_sql_request(), list()) ::
{:ok, execute_sql_response(), any()}
| {:error, {:unexpected_response, any()}}
| {:error, term()}
| {:error, execute_sql_errors()}
def execute_sql(%Client{} = client, input, options \\ []) do
url_path = "/ExecuteSql"
headers = []
custom_headers = []
query_params = []
meta = metadata()
Request.request_rest(
client,
meta,
:post,
url_path,
query_params,
custom_headers ++ headers,
input,
options,
200
)
end
@doc """
Runs a SQL statement against a database.
If a call isn't part of a transaction because it doesn't include the
`transactionID` parameter, changes that result from the call are committed
automatically.
If the binary response data from the database is more than 1 MB, the call is
terminated.
"""
@spec execute_statement(map(), execute_statement_request(), list()) ::
{:ok, execute_statement_response(), any()}
| {:error, {:unexpected_response, any()}}
| {:error, term()}
| {:error, execute_statement_errors()}
def execute_statement(%Client{} = client, input, options \\ []) do
url_path = "/Execute"
headers = []
custom_headers = []
query_params = []
meta = metadata()
Request.request_rest(
client,
meta,
:post,
url_path,
query_params,
custom_headers ++ headers,
input,
options,
200
)
end
@doc """
Performs a rollback of a transaction.
Rolling back a transaction cancels its changes.
"""
@spec rollback_transaction(map(), rollback_transaction_request(), list()) ::
{:ok, rollback_transaction_response(), any()}
| {:error, {:unexpected_response, any()}}
| {:error, term()}
| {:error, rollback_transaction_errors()}
def rollback_transaction(%Client{} = client, input, options \\ []) do
url_path = "/RollbackTransaction"
headers = []
custom_headers = []
query_params = []
meta = metadata()
Request.request_rest(
client,
meta,
:post,
url_path,
query_params,
custom_headers ++ headers,
input,
options,
200
)
end
end