Package io.clonecloudstore.common.database.mongo

Class ExtendedPanacheMongoRepositoryBase<F,E extends F>

java.lang.Object

io.clonecloudstore.common.database.mongo.ExtendedPanacheMongoRepositoryBase<F,E>

Type Parameters:

E - the type for the DTO to use

All Implemented Interfaces:

RepositoryBaseInterface<F>, io.quarkus.mongodb.panache.PanacheMongoRepositoryBase<E,String>

Direct Known Subclasses:

MgDaoAccessorBucketRepository, MgDaoAccessorObjectRepository, MgDaoNativeListingRepository, MgDaoOwnershipRepository, MgDaoRequestRepository, MgDaoSitesActionRepository, MgDaoSitesListingRepository, MgDaoTopologyRepository

public abstract class ExtendedPanacheMongoRepositoryBase<F,E extends F>
extends Object
implements io.quarkus.mongodb.panache.PanacheMongoRepositoryBase<E,String>, RepositoryBaseInterface<F>

The base Mongo implementation of the RepositoryBaseInterface

Field Summary

Fields

Modifier and Type	Field	Description
protected final MongoBulkInsertHelper<F,E>	helper
static final String	ISSUE_WITH_SERIALIZATION
protected final MongoStreamHelper<F,E>	streamHelper

Fields inherited from interface io.clonecloudstore.common.database.utils.RepositoryBaseInterface

ID, ID_PG

Constructor Summary

Constructors

Constructor	Description
ExtendedPanacheMongoRepositoryBase()

Method Summary

Modifier and Type	Method	Description
ExtendedPanacheMongoRepositoryBase<F,E>	addToInsertBulk(F so)	Add one element to an insert bulk operation
ExtendedPanacheMongoRepositoryBase<F,E>	addToUpdateBulk(org.bson.Document find, org.bson.Document update)
ExtendedPanacheMongoRepositoryBase<F,E>	addToUpsertBulk(org.bson.Document find, F update)
long	count(DbQuery query)
long	countAll()
long	delete(DbQuery query)
long	deleteAllDb()
void	deleteWithPk(String pk)	Delete the item according to the Primary Key
ClosingIterator<F>	findIterator(DbQuery query)
ClosingIterator<F>	findIterator(org.bson.Document query)
F	findOne(DbQuery query)
Stream<F>	findStream(DbQuery query)
F	findWithPk(String pk)
void	flushAll()	Force flush of all remaining bulk items, and if supported other items
void	insert(F item)
boolean	isSqlRepository()
long	update(DbQuery query, DbUpdate update)
boolean	updateFull(F item)	Update fully this E

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.quarkus.mongodb.panache.PanacheMongoRepositoryBase

count, count, count, count, count, delete, delete, delete, delete, delete, deleteAll, deleteById, find, find, find, find, find, find, find, find, findAll, findAll, findById, findByIdOptional, list, list, list, list, list, list, list, list, listAll, listAll, mongoCollection, mongoDatabase, persist, persist, persist, persist, persistOrUpdate, persistOrUpdate, persistOrUpdate, persistOrUpdate, stream, stream, stream, stream, stream, stream, stream, stream, streamAll, streamAll, update, update, update, update, update, update, update, update

Methods inherited from interface io.clonecloudstore.common.database.utils.RepositoryBaseInterface

createEmptyItem, getPkName, getTable

Field Details

ISSUE_WITH_SERIALIZATION

public static final String ISSUE_WITH_SERIALIZATION

See Also:

• Constant Field Values

helper

protected final MongoBulkInsertHelper<F,E extends F> helper

streamHelper

protected final MongoStreamHelper<F,E extends F> streamHelper

Constructor Details

ExtendedPanacheMongoRepositoryBase

public ExtendedPanacheMongoRepositoryBase()

Method Details

isSqlRepository

public boolean isSqlRepository()

Specified by:

isSqlRepository in interface RepositoryBaseInterface<F>

Returns:

True if SQL based repository, else False (NoSQL)

addToInsertBulk

public ExtendedPanacheMongoRepositoryBase<F,E> addToInsertBulk(F so)
                                                        throws CcsDbException

Description copied from interface: RepositoryBaseInterface

Add one element to an insert bulk operation

Specified by:

addToInsertBulk in interface RepositoryBaseInterface<F>

Parameters:

so - the item to bulk (insert/update)

Returns:

this

Throws:

CcsDbException

addToUpsertBulk

public ExtendedPanacheMongoRepositoryBase<F,E> addToUpsertBulk(org.bson.Document find,
 F update)
                                                        throws CcsDbException

Throws:

CcsDbException

addToUpdateBulk

public ExtendedPanacheMongoRepositoryBase<F,E> addToUpdateBulk(org.bson.Document find,
 org.bson.Document update)
                                                        throws CcsDbException

Throws:

CcsDbException

flushAll

public void flushAll()
              throws CcsDbException

Description copied from interface: RepositoryBaseInterface

Force flush of all remaining bulk items, and if supported other items

Specified by:

flushAll in interface RepositoryBaseInterface<F>

Throws:

CcsDbException

findOne

public F findOne(DbQuery query)
          throws CcsDbException

Specified by:

findOne in interface RepositoryBaseInterface<F>

Parameters:

query - the where condition

Returns:

the item according to the query

Throws:

CcsDbException

findWithPk

public F findWithPk(String pk)
             throws CcsDbException

Specified by:

findWithPk in interface RepositoryBaseInterface<F>

Parameters:

pk - the Primary Key as String

Returns:

the item according to the Primary Key

Throws:

CcsDbException

deleteWithPk

public void deleteWithPk(String pk)
                  throws CcsDbException

Description copied from interface: RepositoryBaseInterface

Delete the item according to the Primary Key

Specified by:

deleteWithPk in interface RepositoryBaseInterface<F>

Parameters:

pk - the Primary Key as String

Throws:

CcsDbException

findStream

public Stream<F> findStream(DbQuery query)
                     throws CcsDbException

Specified by:

findStream in interface RepositoryBaseInterface<F>

Parameters:

query - the where condition

Returns:

the Stream (real one) based on Query (where condition)

Throws:

CcsDbException

findIterator

public ClosingIterator<F> findIterator(DbQuery query)
                                throws CcsDbException

Specified by:

findIterator in interface RepositoryBaseInterface<F>

Parameters:

query - the where condition

Returns:

the iterator based on Query (where condition)

Throws:

CcsDbException

findIterator

public ClosingIterator<F> findIterator(org.bson.Document query)
                                throws CcsDbException

Throws:

CcsDbException

count

public long count(DbQuery query)
           throws CcsDbException

Specified by:

count in interface RepositoryBaseInterface<F>

Parameters:

query - the where condition

Returns:

the count based on Query (where condition)

Throws:

CcsDbException

countAll

public long countAll()
              throws CcsDbException

Specified by:

countAll in interface RepositoryBaseInterface<F>

Returns:

the total number of rows

Throws:

CcsDbException

deleteAllDb

public long deleteAllDb()
                 throws CcsDbException

Specified by:

deleteAllDb in interface RepositoryBaseInterface<F>

Returns:

the total number of deleted rows

Throws:

CcsDbException

delete

public long delete(DbQuery query)
            throws CcsDbException

Specified by:

delete in interface RepositoryBaseInterface<F>

Parameters:

query - the where condition

Returns:

the count of deleted items based on Query (where condition)

Throws:

CcsDbException

update

public long update(DbQuery query,
 DbUpdate update)
            throws CcsDbException

Specified by:

update in interface RepositoryBaseInterface<F>

Parameters:

query - the where condition

update - the update part

Returns:

the count of updated items based on Query (where condition) and the Update

Throws:

CcsDbException

updateFull

public boolean updateFull(F item)
                   throws CcsDbException

Description copied from interface: RepositoryBaseInterface

Update fully this E

Specified by:

updateFull in interface RepositoryBaseInterface<F>

Returns:

True if ok

Throws:

CcsDbException

insert

public void insert(F item)
            throws CcsDbException

Specified by:

insert in interface RepositoryBaseInterface<F>

Parameters:

item - the item to insert

Throws:

CcsDbException