Package fr.gouv.vitam.collect.internal.core.repository

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

Modifier and Type	Method	Description
void	createTransaction(TransactionModel transactionModel)	create a transaction model
void	deleteTransaction(java.lang.String id)	delete a transaction model
java.util.Optional<TransactionModel>	findTransaction(java.lang.String id)	return transaction according to id
java.util.Optional<TransactionModel>	findTransactionByQuery(org.bson.conversions.Bson query)	return transaction according to query
java.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 status
com.mongodb.client.model.UpdateOneModel<org.bson.Document>	getUpdateOneModel(TransactionModel transactionModel)
void	replaceTransaction(TransactionModel transactionModel)	replace a transaction model
void	replaceTransactions(java.util.List<TransactionModel> transactionsModel)	Deprecated. : FIXME : Update only if "version = version - 1";

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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