Package io.clonecloudstore.common.database.postgre

Class ExtendedPanacheRepositoryBase<F,E extends F>

java.lang.Object

io.clonecloudstore.common.database.postgre.ExtendedPanacheRepositoryBase<F,E>

Type Parameters:

E - the type for the DTO to use

All Implemented Interfaces:

RepositoryBaseInterface<F>, io.quarkus.hibernate.orm.panache.PanacheRepositoryBase<E,String>

public abstract class ExtendedPanacheRepositoryBase<F,E extends F>
extends Object
implements io.quarkus.hibernate.orm.panache.PanacheRepositoryBase<E,String>, RepositoryBaseInterface<F>

The base Postgre implementation of the RepositoryBaseInterface

Field Summary

Fields

Modifier and Type	Field	Description
protected final PostgreBulkHelper	helper
protected final PostgreStreamHelper<F,E>	streamHelper

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

ID, ID_PG

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ExtendedPanacheRepositoryBase(E forClass)

Method Summary

Modifier and Type	Method	Description
ExtendedPanacheRepositoryBase<F,E>	addToInsertBulk(F so)	SHall be in an enclosing Transactional to enforce bulk effects
ExtendedPanacheRepositoryBase<F,E>	addToUpdateBulk(F so)	SHall be in an enclosing Transactional to enforce bulk effects
protected void	changeBulkSize(int bulkSize)
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)
F	findOne(DbQuery query)
org.hibernate.query.Query<E>	findQuery(DbQuery query)	Build the SELECT Hibernate Query from the DbQuery
Stream<F>	findStream(DbQuery query)
F	findWithPk(String pk)
void	flushAll()	Force flush of all remaining bulk items, and if supported other items
protected int	getBulkSize()
org.hibernate.query.Query<E>	getSelectQuery(DbQuery dbQuery)	Build the SELECT Hibernate Query from the DbQuery
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.hibernate.orm.panache.PanacheRepositoryBase

count, count, count, count, delete, delete, delete, delete, deleteAll, deleteById, find, find, find, find, find, find, findAll, findAll, findById, findById, findByIdOptional, findByIdOptional, flush, getEntityManager, isPersistent, list, list, list, list, list, list, listAll, listAll, persist, persist, persist, persist, persistAndFlush, stream, stream, stream, stream, stream, stream, streamAll, streamAll, update, update, update

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

createEmptyItem, getPkName, getTable

Field Details

streamHelper

protected final PostgreStreamHelper<F,E extends F> streamHelper

helper

protected final PostgreBulkHelper helper

Constructor Details

ExtendedPanacheRepositoryBase

protected ExtendedPanacheRepositoryBase(E forClass)

Method Details

isSqlRepository

public boolean isSqlRepository()

Specified by:

isSqlRepository in interface RepositoryBaseInterface<F>

Returns:

True if SQL based repository, else False (NoSQL)

changeBulkSize

protected void changeBulkSize(int bulkSize)

getBulkSize

protected int getBulkSize()

addToInsertBulk

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

SHall be in an enclosing Transactional to enforce bulk effects

Specified by:

addToInsertBulk in interface RepositoryBaseInterface<F>

Parameters:

so - the item to bulk (insert/update)

Returns:

this

Throws:

CcsDbException

addToUpdateBulk

public ExtendedPanacheRepositoryBase<F,E> addToUpdateBulk(F so)
                                                   throws CcsDbException

SHall be in an enclosing Transactional to enforce bulk effects

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

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

findQuery

public org.hibernate.query.Query<E> findQuery(DbQuery query)
                                       throws CcsDbException

Build the SELECT Hibernate Query from the DbQuery

Throws:

CcsDbException

getSelectQuery

public org.hibernate.query.Query<E> getSelectQuery(DbQuery dbQuery)
                                            throws CcsDbException

Build the SELECT Hibernate Query from the DbQuery

Throws:

CcsDbException