Class TransactionRepository
- java.lang.Object
-
- fr.gouv.vitam.collect.internal.core.repository.TransactionRepository
-
public class TransactionRepository extends java.lang.Object
repository for collect entities management in mongo.
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
CREATION_DATE
static java.lang.String
ID
static java.lang.String
SET
static java.lang.String
STATUS
static java.lang.String
TENANT_ID
static java.lang.String
TRANSACTION_COLLECTION
-
Constructor Summary
Constructors Constructor Description TransactionRepository(MongoDbAccess mongoDbAccess)
TransactionRepository(MongoDbAccess mongoDbAccess, java.lang.String collectionName)
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description void
createTransaction(TransactionModel transactionModel)
create a transaction modelvoid
deleteTransaction(java.lang.String id)
delete a transaction modeljava.util.Optional<TransactionModel>
findTransaction(java.lang.String id)
return transaction according to idjava.util.Optional<TransactionModel>
findTransactionByQuery(org.bson.conversions.Bson query)
return transaction according to queryjava.util.List<TransactionModel>
findTransactionsByQuery(org.bson.conversions.Bson query)
java.util.List<TransactionModel>
getListTransactionToDeleteByTenant(java.lang.Integer tenantId)
delete Transaction according to tenant and delay and statuscom.mongodb.client.model.UpdateOneModel<org.bson.Document>
getUpdateOneModel(TransactionModel transactionModel)
void
replaceTransaction(TransactionModel transactionModel)
replace a transaction modelvoid
replaceTransactions(java.util.List<TransactionModel> transactionsModel)
Deprecated.: FIXME : Update only if "version = version - 1";
-
-
-
Field Detail
-
TRANSACTION_COLLECTION
public static final java.lang.String TRANSACTION_COLLECTION
- See Also:
- Constant Field Values
-
ID
public static final java.lang.String ID
- See Also:
- Constant Field Values
-
TENANT_ID
public static final java.lang.String TENANT_ID
- See Also:
- Constant Field Values
-
CREATION_DATE
public static final java.lang.String CREATION_DATE
- See Also:
- Constant Field Values
-
SET
public static final java.lang.String SET
- See Also:
- Constant Field Values
-
STATUS
public static final java.lang.String STATUS
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
TransactionRepository
public TransactionRepository(MongoDbAccess mongoDbAccess, java.lang.String collectionName)
-
TransactionRepository
public TransactionRepository(MongoDbAccess mongoDbAccess)
-
-
Method Detail
-
createTransaction
public void createTransaction(TransactionModel transactionModel) throws CollectInternalException
create a transaction model- Parameters:
transactionModel
- transaction model to create- Throws:
CollectInternalException
- exception thrown in case of error
-
replaceTransaction
public void replaceTransaction(TransactionModel transactionModel) throws CollectInternalException
replace a transaction model- Parameters:
transactionModel
- transaction model to replace- Throws:
CollectInternalException
- exception thrown in case of error
-
getUpdateOneModel
public com.mongodb.client.model.UpdateOneModel<org.bson.Document> getUpdateOneModel(TransactionModel transactionModel)
-
replaceTransactions
public void replaceTransactions(java.util.List<TransactionModel> transactionsModel) throws CollectInternalException
Deprecated.: FIXME : Update only if "version = version - 1";replace a transaction model- Parameters:
transactionsModel
- list des transactions model to replace- Throws:
CollectInternalException
- exception thrown in case of error
-
findTransaction
public java.util.Optional<TransactionModel> findTransaction(java.lang.String id) throws CollectInternalException
return transaction according to id- Parameters:
id
- transaction id to find- Returns:
- Optional
- Throws:
CollectInternalException
- exception thrown in case of error
-
findTransactionByQuery
public java.util.Optional<TransactionModel> findTransactionByQuery(org.bson.conversions.Bson query) throws CollectInternalException
return transaction according to query- Parameters:
query
- transaction query to find- Returns:
- Optional
- Throws:
CollectInternalException
- exception thrown in case of error
-
findTransactionsByQuery
public java.util.List<TransactionModel> findTransactionsByQuery(org.bson.conversions.Bson query) throws CollectInternalException
- Throws:
CollectInternalException
-
deleteTransaction
public void deleteTransaction(java.lang.String id)
delete a transaction model- Parameters:
id
- transaction to delete
-
getListTransactionToDeleteByTenant
public java.util.List<TransactionModel> getListTransactionToDeleteByTenant(java.lang.Integer tenantId) throws CollectInternalException
delete Transaction according to tenant and delay and status- Parameters:
tenantId
- tenant id to find- Returns:
- Optional
- Throws:
CollectInternalException
- exception thrown in case of error
-
-