Package lu.kbra.pclib.db.table

Class DBTableProxy<V extends DatabaseTable<T>,T extends DatabaseEntry>

java.lang.Object

lu.kbra.pclib.db.table.DBTableProxy<V,T>

All Implemented Interfaces:

SQLQueryable<T>, AbstractDBTable<T>

public class DBTableProxy<V extends DatabaseTable<T>,T extends DatabaseEntry>
extends Object
implements AbstractDBTable<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected final V	delegate
protected final Supplier<AbstractConnection>	useMethod

Constructor Summary

Constructors

Constructor	Description
DBTableProxy(V delegate, Supplier<AbstractConnection> useMethod)

Method Summary

Modifier and Type	Method	Description
int	clear()
int	count()
int	countNotNull(T data)
int	countUniques(T data)
boolean	create()	Deprecated.
T	delete(T data)
<C extends Collection<T>> C	deleteAll(C datas)
<C extends Collection<T>, D extends Collection<T>> D	deleteAllIfExists(C datas, Supplier<D> supplier)
Optional<T>	deleteIfExists(T data)
Optional<T>	deleteUnique(T data)
List<T>	deleteUniques(T data)
AbstractDBTable<T>	drop()	Deprecated.
boolean	exists()	Deprecated.
boolean	exists(T data)
boolean	existsUnique(T data)
boolean	existsUniques(T data)
<C extends Collection<T>, D extends Collection<T>> D	filterExists(C datas, Supplier<D> supplier)
<C extends Collection<T>, D extends Collection<T>> D	filterExistsByUnique(C datas, Supplier<D> supplier)
<C extends Collection<T>, D extends Collection<T>> D	filterExistsUnique(C datas, Supplier<D> supplier)
DatabaseConnector	getConnector()
String[]	getCreateSQL()	Deprecated.
Map<String,Object>	getCustomHints()
Database	getDatabase()
DatabaseEntryUtils	getDatabaseEntryUtils()
SQLQueryableHookManager	getQueryableHookManager()
String	getStatementAsSQL(Statement stmt)
TableStructure	getStructure()
T	insert(T data)
<C extends Collection<T>> C	insertAll(C data)
T	insertAndReload(T data)
<C extends Collection<T>> C	insertAndReloadAll(C datas)
T	load(T data)
<C extends Collection<T>> C	loadAll(C datas)
<C extends Collection<T>, D extends Collection<T>> D	loadAllByUnique(C datas, Supplier<D> supplier)
<C extends Collection<T>, D extends Collection<T>> D	loadAllIfExists(C datas, Supplier<D> supplier)
<C extends Collection<T>> C	loadAllUnique(C datas)
List<T>	loadByUnique(T data)	Returns a list of all the possible entries matching with the unique values of the input.
Optional<T>	loadIfExists(T data)
T	loadIfExistsElseInsert(T data)	Loads the first pk result, returns a the newly inserted instance if none is found
T	loadUnique(T data)	Loads the only unique result, or throws an exception if none is found.
Optional<T>	loadUniqueIfExists(T data)	Loads the only unique result, returns null if none is found and throws an exception if too many are available.
T	loadUniqueIfExistsElseInsert(T data)	Loads the first unique result, returns a the newly inserted instance if none is found and throws an exception if too many are available.
T	loadUniqueIfExistsElseInsertAndReload(T data)	Loads the first unique result, returns null if none is found and throws an exception if too many are available.
<B> B	query(SQLQuery<T,B> query)
void	setQueryableHookManager(SQLQueryableHookManager queryableHookManager)	Deprecated.
void	setTableStructure(TableStructure tableStructure)	Deprecated.
int	truncate()	Deprecated.
T	update(T data)
<C extends Collection<T>> C	updateAll(C datas)
T	updateAndReload(T data)
<C extends Collection<T>> C	updateAndReloadAll(C datas)
Optional<T>	updateAndReloadIfExists(T data)
T	updateAndReloadIfExistsElseInsert(T data)
T	updateAndReloadIfExistsElseInsertAndReload(T data)
Optional<T>	updateIfExists(T data)
T	updateIfExistsElseInsert(T data)
T	updateIfExistsElseInsertAndReload(T data)
protected final <R, T extends RuntimeException> R	useWithTry(ThrowingFunction<AbstractConnection,R,T> supplier)

Methods inherited from class java.lang.Object

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

Methods inherited from interface lu.kbra.pclib.db.table.AbstractDBTable

getTableId

Methods inherited from interface lu.kbra.pclib.db.impl.SQLQueryable

getEntryClass, getName, getQualifiedName, getTargetClass

Field Details

delegate

protected final V extends DatabaseTable<T> delegate

useMethod

protected final Supplier<AbstractConnection> useMethod

Constructor Details

DBTableProxy

public DBTableProxy(V delegate,
 Supplier<AbstractConnection> useMethod)

Method Details

clear

public int clear()
          throws DBException

Specified by:

clear in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

count

public int count()
          throws DBException

Specified by:

count in interface SQLQueryable<V extends DatabaseTable<T>>

Throws:

DBException

countNotNull

public int countNotNull(T data)
                 throws DBException

Specified by:

countNotNull in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

countUniques

public int countUniques(T data)
                 throws DBException

Specified by:

countUniques in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

create

@Deprecated
public boolean create()
               throws DBException

Deprecated.

Specified by:

create in interface AbstractDBTable<V extends DatabaseTable<T>>

Specified by:

create in interface SQLQueryable<V extends DatabaseTable<T>>

Returns:

true if it was created

Throws:

DBException

delete

public T delete(T data)
         throws DBException

Specified by:

delete in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

deleteAll

public <C extends Collection<T>> C deleteAll(C datas)
                                      throws DBException

Specified by:

deleteAll in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

deleteAllIfExists

public <C extends Collection<T>,
D extends Collection<T>>
D deleteAllIfExists(C datas,
 Supplier<D> supplier)
             throws DBException

Specified by:

deleteAllIfExists in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

deleteIfExists

public Optional<T> deleteIfExists(T data)
                           throws DBException

Specified by:

deleteIfExists in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

deleteUnique

public Optional<T> deleteUnique(T data)
                         throws DBException

Specified by:

deleteUnique in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

deleteUniques

public List<T> deleteUniques(T data)
                      throws DBException

Specified by:

deleteUniques in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

drop

@Deprecated
public AbstractDBTable<T> drop()
                        throws DBException

Deprecated.

Specified by:

drop in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

exists

@Deprecated
public boolean exists()
               throws DBException

Deprecated.

Specified by:

exists in interface AbstractDBTable<V extends DatabaseTable<T>>

Specified by:

exists in interface SQLQueryable<V extends DatabaseTable<T>>

Throws:

DBException

exists

public boolean exists(T data)
               throws DBException

Specified by:

exists in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

existsUnique

public boolean existsUnique(T data)
                     throws DBException

Specified by:

existsUnique in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

existsUniques

public boolean existsUniques(T data)
                      throws DBException

Specified by:

existsUniques in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

filterExists

public <C extends Collection<T>,
D extends Collection<T>>
D filterExists(C datas,
 Supplier<D> supplier)
        throws DBException

Specified by:

filterExists in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

filterExistsUnique

public <C extends Collection<T>,
D extends Collection<T>>
D filterExistsUnique(C datas,
 Supplier<D> supplier)
              throws DBException

Specified by:

filterExistsUnique in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

TooManyMatchingRowsException - if a row matches > 0 unique rows

DBException

getConnector

public DatabaseConnector getConnector()

Specified by:

getConnector in interface SQLQueryable<V extends DatabaseTable<T>>

getCreateSQL

@Deprecated
public String[] getCreateSQL()

Deprecated.

Specified by:

getCreateSQL in interface AbstractDBTable<V extends DatabaseTable<T>>

getCustomHints

public Map<String,Object> getCustomHints()

Specified by:

getCustomHints in interface AbstractDBTable<V extends DatabaseTable<T>>

Specified by:

getCustomHints in interface SQLQueryable<V extends DatabaseTable<T>>

getDatabase

public Database getDatabase()

Specified by:

getDatabase in interface AbstractDBTable<V extends DatabaseTable<T>>

Specified by:

getDatabase in interface SQLQueryable<V extends DatabaseTable<T>>

getDatabaseEntryUtils

public DatabaseEntryUtils getDatabaseEntryUtils()

Specified by:

getDatabaseEntryUtils in interface SQLQueryable<V extends DatabaseTable<T>>

getQueryableHookManager

public SQLQueryableHookManager getQueryableHookManager()

Specified by:

getQueryableHookManager in interface AbstractDBTable<V extends DatabaseTable<T>>

Specified by:

getQueryableHookManager in interface SQLQueryable<V extends DatabaseTable<T>>

getStatementAsSQL

public String getStatementAsSQL(Statement stmt)

Specified by:

getStatementAsSQL in interface SQLQueryable<V extends DatabaseTable<T>>

getStructure

public TableStructure getStructure()

Specified by:

getStructure in interface AbstractDBTable<V extends DatabaseTable<T>>

Specified by:

getStructure in interface SQLQueryable<V extends DatabaseTable<T>>

insert

public T insert(T data)
         throws DBException

Specified by:

insert in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

insertAll

public <C extends Collection<T>> C insertAll(C data)
                                      throws DBException

Specified by:

insertAll in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

insertAndReload

public T insertAndReload(T data)
                  throws DBException

Specified by:

insertAndReload in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

insertAndReloadAll

public <C extends Collection<T>> C insertAndReloadAll(C datas)
                                               throws DBException

Specified by:

insertAndReloadAll in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

load

public T load(T data)
       throws DBException

Specified by:

load in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

loadAll

public <C extends Collection<T>> C loadAll(C datas)
                                    throws DBException

Specified by:

loadAll in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

loadByUnique

public List<T> loadByUnique(T data)
                     throws DBException

Description copied from interface: AbstractDBTable

Returns a list of all the possible entries matching with the unique values of the input.

Specified by:

loadByUnique in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

loadAllIfExists

public <C extends Collection<T>,
D extends Collection<T>>
D loadAllIfExists(C datas,
 Supplier<D> supplier)
           throws DBException

Specified by:

loadAllIfExists in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

loadIfExists

public Optional<T> loadIfExists(T data)
                         throws DBException

Specified by:

loadIfExists in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

loadIfExistsElseInsert

public T loadIfExistsElseInsert(T data)
                         throws DBException

Description copied from interface: AbstractDBTable

Loads the first pk result, returns a the newly inserted instance if none is found

Specified by:

loadIfExistsElseInsert in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

loadUnique

public T loadUnique(T data)
             throws DBException

Description copied from interface: AbstractDBTable

Loads the only unique result, or throws an exception if none is found.

Specified by:

loadUnique in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

loadUniqueIfExists

public Optional<T> loadUniqueIfExists(T data)
                               throws DBException

Description copied from interface: AbstractDBTable

Loads the only unique result, returns null if none is found and throws an exception if too many are available.

Specified by:

loadUniqueIfExists in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

loadUniqueIfExistsElseInsert

public T loadUniqueIfExistsElseInsert(T data)
                               throws DBException

Description copied from interface: AbstractDBTable

Loads the first unique result, returns a the newly inserted instance if none is found and throws an exception if too many are available.

Specified by:

loadUniqueIfExistsElseInsert in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

query

public <B> B query(SQLQuery<T,B> query)
            throws DBException

Specified by:

query in interface SQLQueryable<V extends DatabaseTable<T>>

Throws:

DBException

setQueryableHookManager

@Deprecated
public void setQueryableHookManager(SQLQueryableHookManager queryableHookManager)

Deprecated.

Specified by:

setQueryableHookManager in interface AbstractDBTable<V extends DatabaseTable<T>>

setTableStructure

@Deprecated
public void setTableStructure(TableStructure tableStructure)

Deprecated.

Specified by:

setTableStructure in interface AbstractDBTable<V extends DatabaseTable<T>>

truncate

@Deprecated
public int truncate()
             throws DBException

Deprecated.

Specified by:

truncate in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

update

public T update(T data)
         throws DBException

Specified by:

update in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

updateAll

public <C extends Collection<T>> C updateAll(C datas)
                                      throws DBException

Specified by:

updateAll in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

updateAndReload

public T updateAndReload(T data)
                  throws DBException

Specified by:

updateAndReload in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

updateAndReloadAll

public <C extends Collection<T>> C updateAndReloadAll(C datas)
                                               throws DBException

Specified by:

updateAndReloadAll in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

useWithTry

protected final <R,
T extends RuntimeException> R useWithTry(ThrowingFunction<AbstractConnection,R,T> supplier)
                                                     throws T

Throws:

T extends RuntimeException

updateAndReloadIfExists

public Optional<T> updateAndReloadIfExists(T data)

Specified by:

updateAndReloadIfExists in interface AbstractDBTable<V extends DatabaseTable<T>>

updateAndReloadIfExistsElseInsert

public T updateAndReloadIfExistsElseInsert(T data)

Specified by:

updateAndReloadIfExistsElseInsert in interface AbstractDBTable<V extends DatabaseTable<T>>

updateAndReloadIfExistsElseInsertAndReload

public T updateAndReloadIfExistsElseInsertAndReload(T data)

Specified by:

updateAndReloadIfExistsElseInsertAndReload in interface AbstractDBTable<V extends DatabaseTable<T>>

updateIfExists

public Optional<T> updateIfExists(T data)

Specified by:

updateIfExists in interface AbstractDBTable<V extends DatabaseTable<T>>

updateIfExistsElseInsert

public T updateIfExistsElseInsert(T data)

Specified by:

updateIfExistsElseInsert in interface AbstractDBTable<V extends DatabaseTable<T>>

updateIfExistsElseInsertAndReload

public T updateIfExistsElseInsertAndReload(T data)

Specified by:

updateIfExistsElseInsertAndReload in interface AbstractDBTable<V extends DatabaseTable<T>>

loadUniqueIfExistsElseInsertAndReload

public T loadUniqueIfExistsElseInsertAndReload(T data)
                                        throws DBException

Description copied from interface: AbstractDBTable

Loads the first unique result, returns null if none is found and throws an exception if too many are available.

Specified by:

loadUniqueIfExistsElseInsertAndReload in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

loadAllUnique

public <C extends Collection<T>> C loadAllUnique(C datas)
                                          throws DBException

Specified by:

loadAllUnique in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

loadAllByUnique

public <C extends Collection<T>,
D extends Collection<T>>
D loadAllByUnique(C datas,
 Supplier<D> supplier)
           throws DBException

Specified by:

loadAllByUnique in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException

filterExistsByUnique

public <C extends Collection<T>,
D extends Collection<T>>
D filterExistsByUnique(C datas,
 Supplier<D> supplier)
                throws DBException

Specified by:

filterExistsByUnique in interface AbstractDBTable<V extends DatabaseTable<T>>

Throws:

DBException