Class DynamoDbMethods
- java.lang.Object
-
- io.toro.martini.DynamoDbMethods
-
public final class DynamoDbMethods extends Object
Dynamodb methods used to communicate in the dynamodb connection and manipulate the data
-
-
Field Summary
Fields Modifier and Type Field Description static String
REQUEST_ITEMS
-
Constructor Summary
Constructors Constructor Description DynamoDbMethods(io.toro.martini.database.DataSourceManager manager)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static GloopModel
batchGetItems(@NotNull String databaseConnectionName, String returnConsumedCapacity, List<GloopModel> requestItems)
The BatchGetItem operation returns the attributes of one or more items from one or more tables and return BatchGetItemResponse as GloopModelstatic GloopModel
batchGetItems(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, String returnConsumedCapacity, List<GloopModel> requestItems)
The BatchGetItem operation returns the attributes of one or more items from one or more tables and return BatchGetItemResponse as GloopModelstatic GloopModel
batchPartiQl(@NotNull String databaseConnectionName, List<GloopModel> statementRequests)
This operation allows you to perform batch reads or writes on data stored in DynamoDB, using PartiQL and return BatchExecuteStatementResponse as GloopModelstatic GloopModel
batchPartiQl(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, List<GloopModel> statementRequests)
This operation allows you to perform batch reads or writes on data stored in DynamoDB, using PartiQL and return BatchExecuteStatementResponse as GloopModelstatic GloopModel
batchWriteItems(@NotNull String databaseConnectionName, List<GloopModel> models, String returnConsumedCapacity, String returnItemCollectionMetrics)
The BatchWriteItem operation puts or deletes multiple items in one or more tables and return BatchWriteItemResponse as GloopModelstatic GloopModel
batchWriteItems(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, List<GloopModel> models, String returnConsumedCapacity, String returnItemCollectionMetrics)
The BatchWriteItem operation puts or deletes multiple items in one or more tables and return BatchWriteItemResponse as GloopModelstatic io.toro.martini.database.DynamoDbDataSource
connection(@NotNull String connectionName)
Return dynamodb datasource objectstatic GloopModel
createGlobalTable(@NotNull String databaseConnectionName, @NotNull String globalTableName, List<String> regionNames)
Creates a global table from an existing table and return CreateGlobalTableResponse as GloopModel.static GloopModel
createGlobalTable(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String globalTableName, List<String> regionNames)
Creates a global table from an existing table and return CreateGlobalTableResponse as GloopModelstatic GloopModel
createTable(@NotNull String databaseConnectionName, GloopModel createTableRequest)
The CreateTable operation adds a new table to your account and return CreateTableResponse as GloopModelstatic GloopModel
createTable(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, GloopModel createTableRequest)
The CreateTable operation adds a new table to your account and return CreateTableResponse as GloopModelstatic GloopModel
deleteItem(@NotNull String databaseConnectionName, @NotNull String tableName, List<GloopModel> keyModels, String returnValues, String returnConsumedCapacity, String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, List<GloopModel> expressionAttributeValueModels)
Deletes a single item in a table by primary key and return DeleteItemResponse as GloopModelstatic GloopModel
deleteItem(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String tableName, List<GloopModel> keyModels, String returnValues, String returnConsumedCapacity, String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, List<GloopModel> expressionAttributeValueModels)
Deletes a single item in a table by primary key and return DeleteItemResponse as GloopModelstatic GloopModel
deleteTable(@NotNull String databaseConnectionName, @NotNull String tableName)
The DeleteTable operation deletes a table and all of its items and return table description response as GloopModelstatic GloopModel
deleteTable(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String tableName)
The DeleteTable operation deletes a table and all of its items and return table description response as GloopModelstatic GloopModel
describeGlobalTable(@NotNull String databaseConnectionName, @NotNull String globalTableName)
Returns information about the specified global table and return DescribeGlobalTableResponse as GloopModelstatic GloopModel
describeGlobalTable(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String globalTableName)
Returns information about the specified global table and return DescribeGlobalTableResponse as GloopModelstatic GloopModel
describeTable(@NotNull String databaseConnectionName, @NotNull String tableName)
Describe the table and return information of the table as GloopModelstatic GloopModel
describeTable(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String tableName)
Describe the table and return information of the table as GloopModelstatic GloopModel
executeTransaction(@NotNull String databaseConnectionName, String clientRequestToken, List<GloopModel> models)
This operation allows you to perform transactional reads or writes on data stored in DynamoDB, using PartiQL and return ExecuteTransactionResponse as GloopModelstatic GloopModel
executeTransaction(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, String clientRequestToken, List<GloopModel> models)
This operation allows you to perform transactional reads or writes on data stored in DynamoDB, using PartiQL and return ExecuteTransactionResponse as GloopModelsoftware.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient
getAsyncClient(@NotNull String connectionName)
Return dynamoDb Async Clientstatic software.amazon.awssdk.services.dynamodb.DynamoDbClient
getDynamoDbClient(String connectionName)
Returns a DynamoDbClient object from the DynamoDbDatabaseSource objectsoftware.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedAsyncClient
getEnhancedAsyncClient(@NotNull String connectionName)
Return DynamoDb Enhanced Async Clientsoftware.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClient
getEnhancedClient(@NotNull String connectionName)
Return dynamoDb Enhanced Clientstatic GloopModel
getItem(@NotNull String databaseConnectionName, @NotNull String tableName, List<GloopModel> keyModels, Boolean consistentRead, String returnConsumedCapacity, String projectionExpression, Map<String,String> expressionAttributeNames)
The GetItem operation returns a set of attributes for the item with the given primary key and return GetItemResponse as GloopModelstatic GloopModel
getItem(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String tableName, List<GloopModel> keyModels, Boolean consistentRead, String returnConsumedCapacity, String projectionExpression, Map<String,String> expressionAttributeNames)
The GetItem operation returns a set of attributes for the item with the given primary key and return GetItemResponse as GloopModelstatic GloopModel
listGlobalTables(@NotNull String databaseConnectionName, int limit, String exclusiveStartTableName, String region)
Lists all global tables that have a replica in the specified Regionstatic GloopModel
listGlobalTables(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, Integer limit, String exclusiveStartTableName, String region)
Lists all global tables that have a replica in the specified Regionstatic GloopModel
listTables(@NotNull String databaseConnectionName, int limit, String exclusiveStartTableName)
Return list of table names associated with the current account and endpointstatic GloopModel
listTables(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, Integer limit, String exclusiveStartTableName)
Return list of table names associated with the current account and endpointstatic GloopModel
partiQL(@NotNull String databaseConnectionName, Boolean consistentRead, String nextToken, String statement, List<GloopModel> parameters)
This operation allows you to perform reads and singleton writes on data stored in DynamoDB, using PartiQL and return ExecuteStatementResponse as GloopModelstatic GloopModel
partiQL(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, Boolean consistentRead, String nextToken, String statement, List<GloopModel> parameters)
This operation allows you to perform reads and singleton writes on data stored in DynamoDB, using PartiQL and return ExecuteStatementResponse as GloopModelstatic GloopModel
putItem(@NotNull String databaseConnectionName, @NotNull String tableName, List<GloopModel> items, String returnValues, String returnConsumedCapacity, String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, List<GloopModel> expressionAttributeValues)
Creates a new item, or replaces an old item with a new item and convert the PutItemResponse into gloop modelstatic GloopModel
putItem(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String tableName, List<GloopModel> items, String returnValues, String returnConsumedCapacity, String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, List<GloopModel> expressionAttributeValues)
Creates a new item, or replaces an old item with a new item and convert the PutItemResponse into gloop modelstatic GloopModel
query(@NotNull String databaseConnectionName, @NotNull String tableName, String indexName, String select, Integer limit, Boolean consistentRead, Boolean scanIndexForward, List<GloopModel> exclusiveStartKeyModels, String returnConsumedCapacity, String projectionExpression, String filterExpression, String keyConditionExpression, Map<String,String> expressionAttributeNames, List<GloopModel> expressionAttributeValueModels)
The Query operation finds items based on primary key values and return QueryResponse as GloopModelstatic GloopModel
query(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String tableName, String indexName, String select, Integer limit, Boolean consistentRead, Boolean scanIndexForward, List<GloopModel> exclusiveStartKeyModels, String returnConsumedCapacity, String projectionExpression, String filterExpression, String keyConditionExpression, Map<String,String> expressionAttributeNames, List<GloopModel> expressionAttributeValueModels)
The Query operation finds items based on primary key values and return QueryResponse as GloopModelstatic GloopModel
scanTable(@NotNull String databaseConnectionName, @NotNull String tableName, String indexName, Integer limit, String select, Boolean consistentRead, List<GloopModel> exclusiveStartKeyModels, String returnConsumedCapacity, String projectionExpression, String filterExpression, Map<String,String> expressionAttributeNames, List<GloopModel> expressionAttributeValueModels, Integer segment, Integer totalSegments)
Scan operation returns one or more items and item attributes by accessing every item in a table or a secondary index and return ScanResponse as GloopModelstatic GloopModel
scanTable(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String tableName, String indexName, Integer limit, String select, Boolean consistentRead, List<GloopModel> exclusiveStartKeyModels, String returnConsumedCapacity, String projectionExpression, String filterExpression, Map<String,String> expressionAttributeNames, List<GloopModel> expressionAttributeValueModels, Integer segment, Integer totalSegments)
Scan operation returns one or more items and item attributes by accessing every item in a table or a secondary index and return ScanResponse as GloopModel(package private) static void
setDataSourceManager(io.toro.martini.database.DataSourceManager manager)
static GloopModel
transactGetItems(@NotNull String databaseConnectionName, String returnConsumedCapacity, List<GloopModel> transactGetItemsRequest)
TransactGetItems is a synchronous operation that atomically retrieves multiple items from one or more tables in a single account and Region and return TransactGetItemResponse as GloopModelstatic GloopModel
transactGetItems(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, String returnConsumedCapacity, List<GloopModel> transactGetItemsRequest)
TransactGetItems is a synchronous operation that atomically retrieves multiple items from one or more tables in a single account and Region and return TransactGetItemResponse as GloopModelstatic GloopModel
transactWriteItems(@NotNull String databaseConnectionName, String returnConsumedCapacity, String returnItemCollectionMetrics, String clientRequestToken, List<GloopModel> transactWriteItemsRequest)
TransactWriteItems is a synchronous write operation that groups up to 100 action requests and return TransactWriteItems as GloopModelstatic GloopModel
transactWriteItems(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, String returnConsumedCapacity, String returnItemCollectionMetrics, String clientRequestToken, List<GloopModel> transactWriteItemsRequest)
TransactWriteItems is a synchronous write operation that groups up to 100 action requests and return TransactWriteItems as GloopModelstatic GloopModel
updateGlobalTable(@NotNull String databaseConnectionName, String globalTableName, List<GloopModel> models)
Adds or removes replicas in the specified global table and return UpdateGlobalTableResponse as GloopModelstatic GloopModel
updateGlobalTable(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, String globalTableName, List<GloopModel> models)
Adds or removes replicas in the specified global table and return UpdateGlobalTableResponse as GloopModelstatic GloopModel
updateItem(@NotNull String databaseConnectionName, @NotNull String tableName, List<GloopModel> keyModels, String returnValues, String returnConsumedCapacity, String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, List<GloopModel> expressionAttributeValueModels, String updateExpression)
Edits an existing item's attributes, or adds a new item to the table if it does not already exist and return UpdateItemResponse as Gloop Modelstatic GloopModel
updateItem(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String tableName, List<GloopModel> keyModels, String returnValues, String returnConsumedCapacity, String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, List<GloopModel> expressionAttributeValueModels, String updateExpression)
Edits an existing item's attributes, or adds a new item to the table if it does not already exist and return UpdateItemResponse as Gloop Modelstatic GloopModel
updateTable(@NotNull String databaseConnectionName, GloopModel model)
Modifies the provisioned throughput settings, global secondary indexes, or DynamoDB Streams settings for a given table and return table description response as GloopModelstatic GloopModel
updateTable(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, GloopModel model)
Modifies the provisioned throughput settings, global secondary indexes, or DynamoDB Streams settings for a given table and return table description response as GloopModel
-
-
-
Field Detail
-
REQUEST_ITEMS
public static final String REQUEST_ITEMS
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
DynamoDbMethods
@Autowired public DynamoDbMethods(io.toro.martini.database.DataSourceManager manager)
-
-
Method Detail
-
setDataSourceManager
static void setDataSourceManager(io.toro.martini.database.DataSourceManager manager)
-
getDynamoDbClient
public static software.amazon.awssdk.services.dynamodb.DynamoDbClient getDynamoDbClient(String connectionName)
Returns a DynamoDbClient object from the DynamoDbDatabaseSource object- Parameters:
connectionName
- the name of the mongo db connection registered in Martini Runtime- Returns:
- DynamoDbClient
-
putItem
@GloopObjectParameter("output{\ndynamodbOutput#io.toro.martini.dynamodb.DynamoDbResponse{\n}\n}") public static GloopModel putItem(@NotNull @NotNull String databaseConnectionName, @NotNull @NotNull String tableName, @GloopObjectParameter("items#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> items, @GloopParameter(defaultValue="",choices={"NONE","ALL_OLD"}) String returnValues, @GloopParameter(defaultValue="",choices={"TOTAL","INDEXES","NONE"}) String returnConsumedCapacity, @GloopParameter(defaultValue="",choices={"NONE","SIZE"}) String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, @GloopObjectParameter("expressionAttributeValues#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> expressionAttributeValues)
Creates a new item, or replaces an old item with a new item and convert the PutItemResponse into gloop model- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimetableName
- the name of the tableitems
- a map of attribute name/value pairs, one for each attribute as GloopModelreturnValues
- to get the item attributes as they appeared before they were updatedreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsereturnItemCollectionMetrics
- determine whether item collection metrics are returnedconditionExpression
- a condition that must be satisfied in order for a conditional PutItem operation to succeedexpressionAttributeNames
- one or more substitution tokens for attribute names in an expressionexpressionAttributeValues
- one or more values that can be substituted in an expression as GloopModel- Returns:
- GloopModel
-
putItem
@GloopObjectParameter("output{\ndynamodbOutput#io.toro.martini.dynamodb.DynamoDbResponse{\n}\n}") public static GloopModel putItem(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull @NotNull String tableName, @GloopObjectParameter("items#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> items, @GloopParameter(defaultValue="",choices={"NONE","ALL_OLD"}) String returnValues, @GloopParameter(defaultValue="",choices={"TOTAL","INDEXES","NONE"}) String returnConsumedCapacity, @GloopParameter(defaultValue="",choices={"NONE","SIZE"}) String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, @GloopObjectParameter("expressionAttributeValues#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> expressionAttributeValues)
Creates a new item, or replaces an old item with a new item and convert the PutItemResponse into gloop model- Parameters:
client
- dynamodb client to perform the put item requesttableName
- the name of the tableitems
- a map of attribute name/value pairs, one for each attribute as GloopModelreturnValues
- to get the item attributes as they appeared before they were updatedreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsereturnItemCollectionMetrics
- determine whether item collection metrics are returnedconditionExpression
- a condition that must be satisfied in order for a conditional PutItem operation to succeedexpressionAttributeNames
- one or more substitution tokens for attribute names in an expressionexpressionAttributeValues
- one or more values that can be substituted in an expression as GloopModel- Returns:
- GloopModel
-
updateItem
@GloopObjectParameter("output{\ndynamodbOutput#io.toro.martini.dynamodb.DynamoDbResponse{\n}\n}") public static GloopModel updateItem(@NotNull @NotNull String databaseConnectionName, @NotNull @NotNull String tableName, @GloopObjectParameter("keys#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> keyModels, @GloopParameter(defaultValue="",choices={"NONE","ALL_OLD","ALL_NEW","UPDATED_OLD","UPDATED_NEW"}) String returnValues, @GloopParameter(defaultValue="",choices={"TOTAL","INDEXES","NONE"}) String returnConsumedCapacity, @GloopParameter(defaultValue="",choices={"NONE","SIZE"}) String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, @GloopObjectParameter("expressionAttributeValues#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> expressionAttributeValueModels, String updateExpression)
Edits an existing item's attributes, or adds a new item to the table if it does not already exist and return UpdateItemResponse as Gloop Model- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimetableName
- the name of the tablekeyModels
- the primary key of the item to be updated as GloopModelreturnValues
- to get the item attributes as they appeared before they were updatedreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsereturnItemCollectionMetrics
- determine whether item collection metrics are returnedconditionExpression
- a condition that must be satisfied in order for a conditional update to succeedexpressionAttributeNames
- one or more substitution tokens for attribute names in an expressionexpressionAttributeValueModels
- one or more values that can be substituted in an expression as GloopModelupdateExpression
- an expression that defines one or more attributes to be updated- Returns:
- GloopModel
-
updateItem
@GloopObjectParameter("output{\ndynamodbOutput#io.toro.martini.dynamodb.DynamoDbResponse{\n}\n}") public static GloopModel updateItem(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull @NotNull String tableName, @GloopObjectParameter("keys#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> keyModels, @GloopParameter(defaultValue="",choices={"NONE","ALL_OLD","ALL_NEW","UPDATED_OLD","UPDATED_NEW"}) String returnValues, @GloopParameter(defaultValue="",choices={"TOTAL","INDEXES","NONE"}) String returnConsumedCapacity, @GloopParameter(defaultValue="",choices={"NONE","SIZE"}) String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, @GloopObjectParameter("expressionAttributeValues#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> expressionAttributeValueModels, String updateExpression)
Edits an existing item's attributes, or adds a new item to the table if it does not already exist and return UpdateItemResponse as Gloop Model- Parameters:
client
- dynamodb client to perform the update item requesttableName
- the name of the tablekeyModels
- the primary key of the item to be updated as GloopModelreturnValues
- to get the item attributes as they appeared before they were updatedreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsereturnItemCollectionMetrics
- determine whether item collection metrics are returnedconditionExpression
- a condition that must be satisfied in order for a conditional update to succeedexpressionAttributeNames
- one or more substitution tokens for attribute names in an expressionexpressionAttributeValueModels
- one or more values that can be substituted in an expression as GloopModelupdateExpression
- an expression that defines one or more attributes to be updated- Returns:
- GloopModel
-
deleteItem
@GloopObjectParameter("output{\ndynamodbOutput#io.toro.martini.dynamodb.DynamoDbResponse{\n}\n}") public static GloopModel deleteItem(@NotNull @NotNull String databaseConnectionName, @NotNull @NotNull String tableName, @GloopObjectParameter("keys#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> keyModels, @GloopParameter(defaultValue="",choices={"NONE","ALL_OLD"}) String returnValues, @GloopParameter(defaultValue="",choices={"TOTAL","INDEXES","NONE"}) String returnConsumedCapacity, @GloopParameter(defaultValue="",choices={"NONE","SIZE"}) String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, @GloopObjectParameter("expressionAttributeValues#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> expressionAttributeValueModels)
Deletes a single item in a table by primary key and return DeleteItemResponse as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimetableName
- the name of the tablekeyModels
- a map of attribute names to AttributeValue objects, representing the primary key of the item to delete as GloopModelreturnValues
- to get the item attributes as they appeared before they were updatedreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsereturnItemCollectionMetrics
- determine whether item collection metrics are returnedconditionExpression
- a condition that must be satisfied in order for a conditional DeleteItem to succeedexpressionAttributeNames
- one or more substitution tokens for attribute names in an expressionexpressionAttributeValueModels
- one or more values that can be substituted in an expression as GloopModel- Returns:
- GloopModel
-
deleteItem
@GloopObjectParameter("output{\ndynamodbOutput#io.toro.martini.dynamodb.DynamoDbResponse{\n}\n}") public static GloopModel deleteItem(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull @NotNull String tableName, @GloopObjectParameter("keys#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> keyModels, @GloopParameter(defaultValue="",choices={"NONE","ALL_OLD"}) String returnValues, @GloopParameter(defaultValue="",choices={"TOTAL","INDEXES","NONE"}) String returnConsumedCapacity, @GloopParameter(defaultValue="",choices={"NONE","SIZE"}) String returnItemCollectionMetrics, String conditionExpression, Map<String,String> expressionAttributeNames, @GloopObjectParameter("expressionAttributeValues#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> expressionAttributeValueModels)
Deletes a single item in a table by primary key and return DeleteItemResponse as GloopModel- Parameters:
client
- dynamodb client to perform the delete item requesttableName
- the name of the tablekeyModels
- a map of attribute names to AttributeValue objects, representing the primary key of the item to delete as GloopModelreturnValues
- to get the item attributes as they appeared before they were updatedreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsereturnItemCollectionMetrics
- determine whether item collection metrics are returnedconditionExpression
- a condition that must be satisfied in order for a conditional DeleteItem to succeedexpressionAttributeNames
- one or more substitution tokens for attribute names in an expressionexpressionAttributeValueModels
- one or more values that can be substituted in an expression as GloopModel- Returns:
- GloopModel
-
getItem
@GloopObjectParameter("output{\ndynamodbOutput#io.toro.martini.dynamodb.DynamoDbResponse{\n}\n}") public static GloopModel getItem(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull @NotNull String tableName, @GloopObjectParameter("keys#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> keyModels, Boolean consistentRead, @GloopParameter(defaultValue="",choices={"NONE","TOTAL","INDEXES"}) String returnConsumedCapacity, String projectionExpression, Map<String,String> expressionAttributeNames)
The GetItem operation returns a set of attributes for the item with the given primary key and return GetItemResponse as GloopModel- Parameters:
client
- dynamodb client to perform the get item requesttableName
- the name of the tablekeyModels
- a map of attribute names representing the primary key of the item to retrieve as GloopModelconsistentRead
- determines the read consistency modelreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responseprojectionExpression
- a string that identifies one or more attributes to retrieve from the tableexpressionAttributeNames
- one or more substitution tokens for attribute names in an expression- Returns:
- GloopModel
-
getItem
@GloopObjectParameter("output{\ndynamodbOutput#io.toro.martini.dynamodb.DynamoDbResponse{\n}\n}") public static GloopModel getItem(@NotNull @NotNull String databaseConnectionName, @NotNull @NotNull String tableName, @GloopObjectParameter("keys#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> keyModels, Boolean consistentRead, @GloopParameter(defaultValue="",choices={"NONE","TOTAL","INDEXES"}) String returnConsumedCapacity, String projectionExpression, Map<String,String> expressionAttributeNames)
The GetItem operation returns a set of attributes for the item with the given primary key and return GetItemResponse as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimetableName
- the name of the tablekeyModels
- a map of attribute names representing the primary key of the item to retrieve as GloopModelconsistentRead
- determines the read consistency modelreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responseprojectionExpression
- a string that identifies one or more attributes to retrieve from the tableexpressionAttributeNames
- one or more substitution tokens for attribute names in an expression- Returns:
- GloopModel
-
query
@GloopObjectParameter("output{\ndynamoDbQueryResponse#io.toro.martini.dynamodb.DynamoDbQueryResponse{\n}\n}") public static GloopModel query(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull @NotNull String tableName, String indexName, String select, Integer limit, Boolean consistentRead, Boolean scanIndexForward, @GloopObjectParameter("exclusiveStartKey#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> exclusiveStartKeyModels, @GloopParameter(defaultValue="",choices={"NONE","INDEXES","TOTAL"}) String returnConsumedCapacity, String projectionExpression, String filterExpression, String keyConditionExpression, Map<String,String> expressionAttributeNames, @GloopObjectParameter("expressionAttributeValues#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> expressionAttributeValueModels)
The Query operation finds items based on primary key values and return QueryResponse as GloopModel- Parameters:
client
- dynamodb client to perform the query table requesttableName
- the name of the tableindexName
- the name of an index to queryselect
- the attributes to be returned in the resultlimit
- the maximum number of items to evaluateconsistentRead
- determines the read consistency modelscanIndexForward
- determines the read consistency modelexclusiveStartKeyModels
- the primary key of the first item that this operation will evaluatereturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responseprojectionExpression
- a string that identifies one or more attributes to retrieve from the tablefilterExpression
- a string that contains conditions that DynamoDB applies after the Query operationkeyConditionExpression
- the condition that specifies the key values for items to be retrieved by the Query actionexpressionAttributeNames
- one or more substitution tokens for attribute names in an expressionexpressionAttributeValueModels
- one or more values that can be substituted in an expression as GloopModel- Returns:
- GloopModel
-
query
@GloopObjectParameter("output{\ndynamoDbQueryResponse#io.toro.martini.dynamodb.DynamoDbQueryResponse{\n}\n}") public static GloopModel query(@NotNull @NotNull String databaseConnectionName, @NotNull @NotNull String tableName, String indexName, String select, Integer limit, Boolean consistentRead, Boolean scanIndexForward, @GloopObjectParameter("exclusiveStartKey#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> exclusiveStartKeyModels, @GloopParameter(defaultValue="",choices={"NONE","INDEXES","TOTAL"}) String returnConsumedCapacity, String projectionExpression, String filterExpression, String keyConditionExpression, Map<String,String> expressionAttributeNames, @GloopObjectParameter("expressionAttributeValues#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> expressionAttributeValueModels)
The Query operation finds items based on primary key values and return QueryResponse as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimetableName
- the name of the tableindexName
- the name of an index to queryselect
- the attributes to be returned in the resultlimit
- the maximum number of items to evaluateconsistentRead
- determines the read consistency modelscanIndexForward
- determines the read consistency modelexclusiveStartKeyModels
- the primary key of the first item that this operation will evaluatereturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responseprojectionExpression
- a string that identifies one or more attributes to retrieve from the tablefilterExpression
- a string that contains conditions that DynamoDB applies after the Query operationkeyConditionExpression
- the condition that specifies the key values for items to be retrieved by the Query actionexpressionAttributeNames
- one or more substitution tokens for attribute names in an expressionexpressionAttributeValueModels
- one or more values that can be substituted in an expression as GloopModel- Returns:
- GloopModel
-
scanTable
@GloopObjectParameter("output{\ndynamodbScanResponse#io.toro.martini.dynamodb.DynamoDbQueryResponse{\n}\n}") public static GloopModel scanTable(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull @NotNull String tableName, String indexName, Integer limit, String select, Boolean consistentRead, @GloopObjectParameter("exclusiveStartKey#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> exclusiveStartKeyModels, @GloopParameter(defaultValue="",choices={"NONE","INDEXES","TOTAL"}) String returnConsumedCapacity, String projectionExpression, String filterExpression, Map<String,String> expressionAttributeNames, @GloopObjectParameter("expressionAttributeValues#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> expressionAttributeValueModels, Integer segment, Integer totalSegments)
Scan operation returns one or more items and item attributes by accessing every item in a table or a secondary index and return ScanResponse as GloopModel- Parameters:
client
- dynamodb client to perform the scan table requesttableName
- the name of the tableindexName
- the name of a secondary index to scanselect
- the attributes to be returned in the resultlimit
- the maximum number of items to evaluateconsistentRead
- determines the read consistency model during scanexclusiveStartKeyModels
- the primary key of the first item that this operation will evaluatereturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responseprojectionExpression
- a string that identifies one or more attributes to retrieve from the tablefilterExpression
- a string that contains conditions that DynamoDB applies after the Scan operationexpressionAttributeNames
- one or more substitution tokens for attribute names in an expressionexpressionAttributeValueModels
- one or more values that can be substituted in an expression as GloopModelsegment
- identifies an individual segment to be scanned by an application workertotalSegments
- represents the total number of segments into which the Scan operation will be divided- Returns:
- GloopModel
-
scanTable
@GloopObjectParameter("output{\ndynamodbScanResponse#io.toro.martini.dynamodb.DynamoDbQueryResponse{\n}\n}") public static GloopModel scanTable(@NotNull @NotNull String databaseConnectionName, @NotNull @NotNull String tableName, String indexName, Integer limit, String select, Boolean consistentRead, @GloopObjectParameter("exclusiveStartKey#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> exclusiveStartKeyModels, @GloopParameter(defaultValue="",choices={"NONE","INDEXES","TOTAL"}) String returnConsumedCapacity, String projectionExpression, String filterExpression, Map<String,String> expressionAttributeNames, @GloopObjectParameter("expressionAttributeValues#io.toro.martini.dynamodb.MapAttributeValue[]{\n}") List<GloopModel> expressionAttributeValueModels, Integer segment, Integer totalSegments)
Scan operation returns one or more items and item attributes by accessing every item in a table or a secondary index and return ScanResponse as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimetableName
- the name of the tableindexName
- the name of a secondary index to scanselect
- the attributes to be returned in the resultlimit
- the maximum number of items to evaluateconsistentRead
- determines the read consistency model during scanexclusiveStartKeyModels
- the primary key of the first item that this operation will evaluatereturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responseprojectionExpression
- a string that identifies one or more attributes to retrieve from the tablefilterExpression
- a string that contains conditions that DynamoDB applies after the Scan operationexpressionAttributeNames
- one or more substitution tokens for attribute names in an expressionexpressionAttributeValueModels
- one or more values that can be substituted in an expression as GloopModelsegment
- identifies an individual segment to be scanned by an application workertotalSegments
- represents the total number of segments into which the Scan operation will be divided- Returns:
- GloopModel
-
batchGetItems
@GloopObjectParameter("output{\nbatchGetItemResponse#io.toro.martini.dynamodb.BatchGetItemResponse{\n}\n}") public static GloopModel batchGetItems(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @GloopParameter(defaultValue="",choices={"TOTAL","INDEXES","NONE"}) String returnConsumedCapacity, @GloopObjectParameter("batchGetItemRequest#io.toro.martini.dynamodb.BatchGetItemRequest[]{\n}") List<GloopModel> requestItems)
The BatchGetItem operation returns the attributes of one or more items from one or more tables and return BatchGetItemResponse as GloopModel- Parameters:
client
- dynamodb client to perform the scan table requestreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responserequestItems
- a map of one or more table names and, for each table, a map that describes one or more items to retrieve from that table as GloopModel- Returns:
- GloopModel
-
batchGetItems
@GloopObjectParameter("output{\nbatchGetItemResponse#io.toro.martini.dynamodb.BatchGetItemResponse{\n}\n}") public static GloopModel batchGetItems(@NotNull @NotNull String databaseConnectionName, @GloopParameter(defaultValue="",choices={"TOTAL","INDEXES","NONE"}) String returnConsumedCapacity, @GloopObjectParameter("batchGetItemRequest#io.toro.martini.dynamodb.BatchGetItemRequest[]{\n}") List<GloopModel> requestItems)
The BatchGetItem operation returns the attributes of one or more items from one or more tables and return BatchGetItemResponse as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimereturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responserequestItems
- a map of one or more table names and, for each table, a map that describes one or more items to retrieve from that table as GloopModel- Returns:
- GloopModel
-
partiQL
@GloopObjectParameter("output{\npartiQLResponse#io.toro.martini.dynamodb.PartiQLResponse{\n}\n}") public static GloopModel partiQL(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, Boolean consistentRead, String nextToken, @GloopParameter(allowNull=false) String statement, @GloopObjectParameter("parameters#io.toro.martini.dynamodb.AttributeValue[]{\n}") List<GloopModel> parameters)
This operation allows you to perform reads and singleton writes on data stored in DynamoDB, using PartiQL and return ExecuteStatementResponse as GloopModel- Parameters:
client
- dynamodb client to perform the partiQl requestconsistentRead
- the consistency of a read operationnextToken
- set this value to get remaining resultsstatement
- the PartiQL statement representing the operation to runparameters
- the parameters for the PartiQL statement- Returns:
- GloopModel
-
partiQL
@GloopObjectParameter("output{\npartiQLResponse#io.toro.martini.dynamodb.PartiQLResponse{\n}\n}") public static GloopModel partiQL(@NotNull @NotNull String databaseConnectionName, Boolean consistentRead, String nextToken, String statement, @GloopObjectParameter("parameters#io.toro.martini.dynamodb.AttributeValue[]{\n}") List<GloopModel> parameters)
This operation allows you to perform reads and singleton writes on data stored in DynamoDB, using PartiQL and return ExecuteStatementResponse as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimeconsistentRead
- the consistency of a read operationnextToken
- set this value to get remaining resultsstatement
- the PartiQL statement representing the operation to runparameters
- the parameters for the PartiQL statement as GloopModel- Returns:
- GloopModel
-
batchPartiQl
@GloopObjectParameter("output{\nstatementResponse#io.toro.martini.dynamodb.StatementResponse[]{\n}\n}") public static GloopModel batchPartiQl(@NotNull @NotNull String databaseConnectionName, @GloopObjectParameter("batchStatementRequest#io.toro.martini.dynamodb.StatementRequest[]{\n}") List<GloopModel> statementRequests)
This operation allows you to perform batch reads or writes on data stored in DynamoDB, using PartiQL and return BatchExecuteStatementResponse as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimestatementRequests
- The list of PartiQL statements representing the batch to run as GloopModel- Returns:
- GloopModel
-
batchPartiQl
@GloopObjectParameter("output{\nstatementResponse#io.toro.martini.dynamodb.StatementResponse[]{\n}\n}") public static GloopModel batchPartiQl(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @GloopObjectParameter("batchStatementRequest#io.toro.martini.dynamodb.StatementRequest[]{\n}") List<GloopModel> statementRequests)
This operation allows you to perform batch reads or writes on data stored in DynamoDB, using PartiQL and return BatchExecuteStatementResponse as GloopModel- Parameters:
client
- dynamodb client to perform the batch partiQl requeststatementRequests
- The list of PartiQL statements representing the batch to run as GloopModel- Returns:
- GloopModel
-
createTable
@GloopObjectParameter("output{\n createTableResponse#io.toro.martini.dynamodb.TableDescription{\n}\n}") public static GloopModel createTable(@NotNull @NotNull String databaseConnectionName, @GloopObjectParameter("createTableRequest#io.toro.martini.dynamodb.CreateTableRequest{\n}") GloopModel createTableRequest)
The CreateTable operation adds a new table to your account and return CreateTableResponse as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimecreateTableRequest
- describe the input parameter to be able to create table- Returns:
- GloopModel
-
createTable
@GloopObjectParameter("output{\n createTableResponse#io.toro.martini.dynamodb.TableDescription{\n}\n}") public static GloopModel createTable(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @GloopObjectParameter("createTableRequest#io.toro.martini.dynamodb.CreateTableRequest{\n}") GloopModel createTableRequest)
The CreateTable operation adds a new table to your account and return CreateTableResponse as GloopModel- Parameters:
client
- dynamodb client to perform the create table requestcreateTableRequest
- describe the input parameter to be able to create table- Returns:
- GloopModel
-
deleteTable
@GloopObjectParameter("output{\ntableDescriptionResponse#io.toro.martini.dynamodb.TableDescription{\n}\n}") public static GloopModel deleteTable(@NotNull @NotNull String databaseConnectionName, @NotNull @NotNull String tableName)
The DeleteTable operation deletes a table and all of its items and return table description response as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimetableName
- the name of the table to delete- Returns:
- GloopModel
-
deleteTable
@GloopObjectParameter("output{\ntableDescriptionResponse#io.toro.martini.dynamodb.TableDescription{\n}\n}") public static GloopModel deleteTable(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull @NotNull String tableName)
The DeleteTable operation deletes a table and all of its items and return table description response as GloopModel- Parameters:
client
- dynamodb client to perform delete table requesttableName
- the name of the table to delete- Returns:
- GloopModel
-
updateTable
@GloopObjectParameter("output{\ntableDescriptionResponse#io.toro.martini.dynamodb.TableDescription{\n}\n}") public static GloopModel updateTable(@NotNull @NotNull String databaseConnectionName, @GloopObjectParameter("updateTableRequest#io.toro.martini.dynamodb.UpdateTableRequest{\n}") GloopModel model)
Modifies the provisioned throughput settings, global secondary indexes, or DynamoDB Streams settings for a given table and return table description response as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini Runtimemodel
- describe the input parameter to update the table- Returns:
- GloopModel
-
updateTable
@GloopObjectParameter("output{\ntableDescriptionResponse#io.toro.martini.dynamodb.TableDescription{\n}\n}") public static GloopModel updateTable(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @GloopObjectParameter("updateTableRequest#io.toro.martini.dynamodb.UpdateTableRequest{\n}") GloopModel model)
Modifies the provisioned throughput settings, global secondary indexes, or DynamoDB Streams settings for a given table and return table description response as GloopModel- Parameters:
client
- dynamodb client to perform update table requestmodel
- describe the input parameter to update the table- Returns:
- GloopModel
-
describeTable
@GloopObjectParameter("output{\ntableDescriptionResponse#io.toro.martini.dynamodb.TableDescription{\n}\n}") public static GloopModel describeTable(@NotNull @NotNull String databaseConnectionName, @NotNull @NotNull String tableName)
Describe the table and return information of the table as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimetableName
- the name of the table to describe- Returns:
- GloopModel
-
describeTable
@GloopObjectParameter("output{\ntableDescriptionResponse#io.toro.martini.dynamodb.TableDescription{\n}\n}") public static GloopModel describeTable(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull @NotNull String tableName)
Describe the table and return information of the table as GloopModel- Parameters:
client
- dynamodb client to perform the describe table requesttableName
- the name of the table to describe- Returns:
- GloopModel
-
listTables
@GloopObjectParameter("output{\nlistTablesResponse#io.toro.martini.dynamodb.ListTablesResponse{\n}\n}") public static GloopModel listTables(@NotNull @NotNull String databaseConnectionName, @GloopParameter(defaultValue="1") int limit, String exclusiveStartTableName)
Return list of table names associated with the current account and endpoint- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini Runtimelimit
- a maximum number of table names to returnexclusiveStartTableName
- the first table name that this operation will evaluate- Returns:
- GloopModel
-
listTables
@GloopObjectParameter("output{\nlistTablesResponse#io.toro.martini.dynamodb.ListTablesResponse{\n}\n}") public static GloopModel listTables(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, Integer limit, String exclusiveStartTableName)
Return list of table names associated with the current account and endpoint- Parameters:
client
- dynamodb client to perform the list table requestlimit
- a maximum number of table names to returnexclusiveStartTableName
- the first table name that this operation will evaluate- Returns:
- GloopModel
-
listGlobalTables
@GloopObjectParameter("output{\nlistGlobalTablesResponse#io.toro.martini.dynamodb.ListGlobalTablesResponse{\n}\n}") public static GloopModel listGlobalTables(@NotNull @NotNull String databaseConnectionName, @GloopParameter(defaultValue="1") int limit, String exclusiveStartTableName, String region)
Lists all global tables that have a replica in the specified RegionNote: This operation only applies to Version 2017.11.29 (Legacy) of global tables. We recommend using Version 2019.11.21 (Current) when creating new global tables.
- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini Runtimelimit
- a maximum number of table names to returnexclusiveStartTableName
- the first table name that this operation will evaluateregion
- lists the global tables in a specific Region- Returns:
- GloopModel
-
listGlobalTables
@GloopObjectParameter("output{\nlistGlobalTablesResponse#io.toro.martini.dynamodb.ListGlobalTablesResponse{\n}\n}") public static GloopModel listGlobalTables(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, Integer limit, String exclusiveStartTableName, String region)
Lists all global tables that have a replica in the specified RegionNote: This operation only applies to Version 2017.11.29 (Legacy) of global tables. We recommend using Version 2019.11.21 (Current) when creating new global tables.
- Parameters:
client
- dynamodb client to perform the list global table requestlimit
- a maximum number of table names to returnexclusiveStartTableName
- the first table name that this operation will evaluateregion
- lists the global tables in a specific Region- Returns:
- GloopModel
-
updateGlobalTable
@GloopObjectParameter("output{\nupdateGlobalTableResponse#io.toro.martini.dynamodb.GlobalTableDescription{\n}\n}") public static GloopModel updateGlobalTable(@NotNull @NotNull String databaseConnectionName, String globalTableName, @GloopObjectParameter("replicaUpdate#io.toro.martini.dynamodb.ReplicaUpdate[]{\n}") List<GloopModel> models)
Adds or removes replicas in the specified global table and return UpdateGlobalTableResponse as GloopModelNote: This operation only applies to Version 2017.11.29 (Legacy) of global tables. We recommend using Version 2019.11.21 (Current) when creating new global tables.
- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimeglobalTableName
- the global table namemodels
- describe the input parameters to update table- Returns:
- GloopModel
-
updateGlobalTable
@GloopObjectParameter("output{\nupdateGlobalTableResponse#io.toro.martini.dynamodb.GlobalTableDescription{\n}\n}") public static GloopModel updateGlobalTable(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, String globalTableName, @GloopObjectParameter("replicaUpdate#io.toro.martini.dynamodb.ReplicaUpdate[]{\n}") List<GloopModel> models)
Adds or removes replicas in the specified global table and return UpdateGlobalTableResponse as GloopModelNote: This operation only applies to Version 2017.11.29 (Legacy) of global tables. We recommend using Version 2019.11.21 (Current) when creating new global tables.
- Parameters:
client
- dynamodb client to perform the update global table requestglobalTableName
- the global table namemodels
- describe the input parameters to update table- Returns:
- GloopModel
-
createGlobalTable
@GloopObjectParameter("output{\ncreateGlobalTableResponse#io.toro.martini.dynamodb.GlobalTableDescription{\n}\n}") public static GloopModel createGlobalTable(@NotNull @NotNull String databaseConnectionName, @NotNull @NotNull String globalTableName, List<String> regionNames)
Creates a global table from an existing table and return CreateGlobalTableResponse as GloopModel.Note: This operation only applies to Version 2017.11.29 (Legacy) of global tables. We recommend using Version 2019.11.21 (Current) when creating new global tables.
- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimeglobalTableName
- the global table nameregionNames
- the Regions where the global table needs to be created- Returns:
- GloopModel
-
createGlobalTable
@GloopObjectParameter("output{\ncreateGlobalTableResponse#io.toro.martini.dynamodb.GlobalTableDescription{\n}\n}") public static GloopModel createGlobalTable(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull @NotNull String globalTableName, List<String> regionNames)
Creates a global table from an existing table and return CreateGlobalTableResponse as GloopModelNote: This operation only applies to Version 2017.11.29 (Legacy) of global tables. We recommend using Version 2019.11.21 (Current) when creating new global tables.
- Parameters:
client
- dynamodb client to perform the create global table requestglobalTableName
- the global table nameregionNames
- the Regions where the global table needs to be created- Returns:
- GloopModel
-
describeGlobalTable
@GloopObjectParameter("output{\ndescribeGlobalTableResponse#io.toro.martini.dynamodb.GlobalTableDescription{\n}\n}") public static GloopModel describeGlobalTable(@NotNull @NotNull String databaseConnectionName, @NotNull @NotNull String globalTableName)
Returns information about the specified global table and return DescribeGlobalTableResponse as GloopModelNote: This operation only applies to Version 2017.11.29 (Legacy) of global tables. We recommend using Version 2019.11.21 (Current) when creating new global tables.
- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimeglobalTableName
- the name of the global table- Returns:
- GloopModel
-
describeGlobalTable
@GloopObjectParameter("output{\ndescribeGlobalTableResponse#io.toro.martini.dynamodb.GlobalTableDescription{\n}\n}") public static GloopModel describeGlobalTable(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull @NotNull String globalTableName)
Returns information about the specified global table and return DescribeGlobalTableResponse as GloopModelNote: This operation only applies to Version 2017.11.29 (Legacy) of global tables. We recommend using Version 2019.11.21 (Current) when creating new global tables.
- Parameters:
client
- dynamodb client to perform the describe global table requestglobalTableName
- the name of the global table- Returns:
- GloopModel
-
batchWriteItems
@GloopObjectParameter("output{\nbatchWriteItemResponse#io.toro.martini.dynamodb.BatchWriteItemResponse{\n}\n}") public static GloopModel batchWriteItems(@NotNull @NotNull String databaseConnectionName, @GloopObjectParameter("requestItems#io.toro.martini.dynamodb.RequestItem[]{\n}") List<GloopModel> models, @GloopParameter(defaultValue="",choices={"INDEXES","TOTAL","NONE"}) String returnConsumedCapacity, @GloopParameter(defaultValue="",choices={"SIZE","NONE"}) String returnItemCollectionMetrics)
The BatchWriteItem operation puts or deletes multiple items in one or more tables and return BatchWriteItemResponse as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini Runtimemodels
- describe the request itemsreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsereturnItemCollectionMetrics
- determines whether item collection metrics are returned- Returns:
- GloopModel
-
batchWriteItems
@GloopObjectParameter("output{\nbatchWriteItemResponse#io.toro.martini.dynamodb.BatchWriteItemResponse{\n}\n}") public static GloopModel batchWriteItems(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @GloopObjectParameter("requestItems#io.toro.martini.dynamodb.RequestItem[]{\n}") List<GloopModel> models, @GloopParameter(defaultValue="",choices={"INDEXES","TOTAL","NONE"}) String returnConsumedCapacity, @GloopParameter(defaultValue="",choices={"SIZE","NONE"}) String returnItemCollectionMetrics)
The BatchWriteItem operation puts or deletes multiple items in one or more tables and return BatchWriteItemResponse as GloopModel- Parameters:
client
- dynamodb client to perform the batch write item requestmodels
- describe the request items to batch write itemsreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsereturnItemCollectionMetrics
- determines whether item collection metrics are returned- Returns:
- GloopModel
-
executeTransaction
@GloopObjectParameter("output{\nexecuteTransactionResponse#io.toro.martini.dynamodb.ExecuteTransactionResponse{\n}\n}") public static GloopModel executeTransaction(@NotNull @NotNull String databaseConnectionName, String clientRequestToken, @GloopObjectParameter("transactStatements#io.toro.martini.dynamodb.ParameterizedStatement[]{\n}") List<GloopModel> models)
This operation allows you to perform transactional reads or writes on data stored in DynamoDB, using PartiQL and return ExecuteTransactionResponse as GloopModel- Parameters:
databaseConnectionName
- the name of the dynamodb connection registered in Martini RuntimeclientRequestToken
- set this value to get remaining resultsmodels
- describe the parameterized statement to perform execute transaction- Returns:
- GloopModel
-
executeTransaction
@GloopObjectParameter("output{\nexecuteTransactionResponse#io.toro.martini.dynamodb.ExecuteTransactionResponse{\n}\n}") public static GloopModel executeTransaction(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, String clientRequestToken, @GloopObjectParameter("transactStatements#io.toro.martini.dynamodb.ParameterizedStatement[]{\n}") List<GloopModel> models)
This operation allows you to perform transactional reads or writes on data stored in DynamoDB, using PartiQL and return ExecuteTransactionResponse as GloopModel- Parameters:
client
- dynamodb client to perform the execute transaction requestclientRequestToken
- set this value to get remaining resultsmodels
- describe the parameterized statement to perform execute transaction- Returns:
- GloopModel
-
transactGetItems
@GloopObjectParameter("output{\ntransactGetItemResponse#io.toro.martini.dynamodb.TransactGetItemResponse{\n}\n}") public static GloopModel transactGetItems(@NotNull @NotNull String databaseConnectionName, @GloopParameter(defaultValue="",choices={"INDEXES","TOTAL","NONE"}) String returnConsumedCapacity, @GloopObjectParameter("transactGetItemsRequest#io.toro.martini.dynamodb.Get[]{\n}") List<GloopModel> transactGetItemsRequest)
TransactGetItems is a synchronous operation that atomically retrieves multiple items from one or more tables in a single account and Region and return TransactGetItemResponse as GloopModel- Parameters:
databaseConnectionName
- databaseConnectionName the name of the dynamodb connection registered in Martini RuntimereturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsetransactGetItemsRequest
- describe TransactGetItem object as GloopModel to perform the TransactGetItems- Returns:
- GloopModel
-
transactGetItems
@GloopObjectParameter("output{\ntransactGetItemResponse#io.toro.martini.dynamodb.TransactGetItemResponse{\n}\n}") public static GloopModel transactGetItems(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @GloopParameter(defaultValue="",choices={"INDEXES","TOTAL","NONE"}) String returnConsumedCapacity, @GloopObjectParameter("transactGetItemsRequest#io.toro.martini.dynamodb.Get[]{\n}") List<GloopModel> transactGetItemsRequest)
TransactGetItems is a synchronous operation that atomically retrieves multiple items from one or more tables in a single account and Region and return TransactGetItemResponse as GloopModel- Parameters:
client
- dynamodb client to perform the transact get items requestreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsetransactGetItemsRequest
- describe TransactGetItem object as GloopModel to perform the TransactGetItems- Returns:
- GloopModel
-
transactWriteItems
@GloopObjectParameter("output{\ntransactWriteItemResponses#io.toro.martini.dynamodb.TransactWriteItemResponses{\n}\n}") public static GloopModel transactWriteItems(@NotNull @NotNull String databaseConnectionName, @GloopParameter(defaultValue="",choices={"INDEXES","TOTAL","NONE"}) String returnConsumedCapacity, @GloopParameter(defaultValue="",choices={"SIZE","NONE"}) String returnItemCollectionMetrics, String clientRequestToken, @GloopObjectParameter("transactWriteItemsRequest#io.toro.martini.dynamodb.TransactWriteItem[]{\n}") List<GloopModel> transactWriteItemsRequest)
TransactWriteItems is a synchronous write operation that groups up to 100 action requests and return TransactWriteItems as GloopModel- Parameters:
databaseConnectionName
- databaseConnectionName the name of the dynamodb connection registered in Martini RuntimereturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsereturnItemCollectionMetrics
- determines whether item collection metrics are returnedclientRequestToken
- providing a ClientRequestToken makes the call to TransactWriteItems idempotenttransactWriteItemsRequest
- describe the TransactItems object as GloopModel- Returns:
- GloopModel
-
transactWriteItems
@GloopObjectParameter("output{\ntransactWriteItemResponses#io.toro.martini.dynamodb.TransactWriteItemResponses{\n}\n}") public static GloopModel transactWriteItems(@NotNull @NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @GloopParameter(defaultValue="",choices={"INDEXES","TOTAL","NONE"}) String returnConsumedCapacity, @GloopParameter(defaultValue="",choices={"SIZE","NONE"}) String returnItemCollectionMetrics, String clientRequestToken, @GloopObjectParameter("transactWriteItemsRequest#io.toro.martini.dynamodb.TransactWriteItem[]{\n}") List<GloopModel> transactWriteItemsRequest)
TransactWriteItems is a synchronous write operation that groups up to 100 action requests and return TransactWriteItems as GloopModel- Parameters:
client
- dynamodb client to perform the transact write items requestreturnConsumedCapacity
- level of detail about the throughput consumption that is returned in the responsereturnItemCollectionMetrics
- determines whether item collection metrics are returnedclientRequestToken
- providing a ClientRequestToken makes the call to TransactWriteItems idempotenttransactWriteItemsRequest
- describe the TransactItems object as GloopModel- Returns:
- GloopModel
-
connection
public static io.toro.martini.database.DynamoDbDataSource connection(@NotNull @NotNull String connectionName)
Return dynamodb datasource object- Parameters:
connectionName
- the name of the saved database connection in Martini- Returns:
- datasource
-
getAsyncClient
public software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient getAsyncClient(@NotNull @NotNull String connectionName)
Return dynamoDb Async Client- Parameters:
connectionName
- the name of the saved database connection in Martini- Returns:
- dynamoDbAsyncClient
-
getEnhancedAsyncClient
public software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedAsyncClient getEnhancedAsyncClient(@NotNull @NotNull String connectionName)
Return DynamoDb Enhanced Async Client- Parameters:
connectionName
- the name of the saved database connection in Martini- Returns:
- dynamoDbEnhancedAsyncClient
-
-