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 StringREQUEST_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 GloopModelbatchGetItems(@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 GloopModelbatchGetItems(@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 GloopModelbatchPartiQl(@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 GloopModelbatchPartiQl(@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 GloopModelbatchWriteItems(@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 GloopModelbatchWriteItems(@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.DynamoDbDataSourceconnection(@NotNull String connectionName)Return dynamodb datasource objectstatic GloopModelcreateGlobalTable(@NotNull String databaseConnectionName, @NotNull String globalTableName, List<String> regionNames)Creates a global table from an existing table and return CreateGlobalTableResponse as GloopModel.static GloopModelcreateGlobalTable(@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 GloopModelcreateTable(@NotNull String databaseConnectionName, GloopModel createTableRequest)The CreateTable operation adds a new table to your account and return CreateTableResponse as GloopModelstatic GloopModelcreateTable(@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 GloopModeldeleteItem(@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 GloopModeldeleteItem(@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 GloopModeldeleteTable(@NotNull String databaseConnectionName, @NotNull String tableName)The DeleteTable operation deletes a table and all of its items and return table description response as GloopModelstatic GloopModeldeleteTable(@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 GloopModeldescribeGlobalTable(@NotNull String databaseConnectionName, @NotNull String globalTableName)Returns information about the specified global table and return DescribeGlobalTableResponse as GloopModelstatic GloopModeldescribeGlobalTable(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String globalTableName)Returns information about the specified global table and return DescribeGlobalTableResponse as GloopModelstatic GloopModeldescribeTable(@NotNull String databaseConnectionName, @NotNull String tableName)Describe the table and return information of the table as GloopModelstatic GloopModeldescribeTable(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, @NotNull String tableName)Describe the table and return information of the table as GloopModelstatic GloopModelexecuteTransaction(@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 GloopModelexecuteTransaction(@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.DynamoDbAsyncClientgetAsyncClient(@NotNull String connectionName)Return dynamoDb Async Clientstatic software.amazon.awssdk.services.dynamodb.DynamoDbClientgetDynamoDbClient(String connectionName)Returns a DynamoDbClient object from the DynamoDbDatabaseSource objectsoftware.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedAsyncClientgetEnhancedAsyncClient(@NotNull String connectionName)Return DynamoDb Enhanced Async Clientsoftware.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientgetEnhancedClient(@NotNull String connectionName)Return dynamoDb Enhanced Clientstatic GloopModelgetItem(@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 GloopModelgetItem(@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 GloopModellistGlobalTables(@NotNull String databaseConnectionName, int limit, String exclusiveStartTableName, String region)Lists all global tables that have a replica in the specified Regionstatic GloopModellistGlobalTables(@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 GloopModellistTables(@NotNull String databaseConnectionName, int limit, String exclusiveStartTableName)Return list of table names associated with the current account and endpointstatic GloopModellistTables(@NotNull software.amazon.awssdk.services.dynamodb.DynamoDbClient client, Integer limit, String exclusiveStartTableName)Return list of table names associated with the current account and endpointstatic GloopModelpartiQL(@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 GloopModelpartiQL(@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 GloopModelputItem(@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 GloopModelputItem(@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 GloopModelquery(@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 GloopModelquery(@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 GloopModelscanTable(@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 GloopModelscanTable(@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 voidsetDataSourceManager(io.toro.martini.database.DataSourceManager manager)static GloopModeltransactGetItems(@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 GloopModeltransactGetItems(@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 GloopModeltransactWriteItems(@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 GloopModeltransactWriteItems(@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 GloopModelupdateGlobalTable(@NotNull String databaseConnectionName, String globalTableName, List<GloopModel> models)Adds or removes replicas in the specified global table and return UpdateGlobalTableResponse as GloopModelstatic GloopModelupdateGlobalTable(@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 GloopModelupdateItem(@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 GloopModelupdateItem(@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 GloopModelupdateTable(@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 GloopModelupdateTable(@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
-
-