Package lu.kbra.pclib.db.table

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

java.lang.Object

lu.kbra.pclib.db.table.DatabaseTable<T>

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 DatabaseTable<T>

Field Summary

Fields

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

Fields inherited from class lu.kbra.pclib.db.table.DatabaseTable

customHints, database, databaseEntryUtils, queryableHookManager, structure

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)
DatabaseTableStatus	create()	Deprecated.
DatabaseTable<T>	createProxy(Supplier<AbstractConnection> connection)	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 first unique result, or throws an exception if none is found.
Optional<T>	loadUniqueIfExists(T data)	Loads the first 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	setDbEntryUtils(DatabaseEntryUtils dbEntryUtils)	Deprecated.
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 AbstractConnection	use()
protected final <R, T extends RuntimeException> R	useWithTry(ThrowingFunction<AbstractConnection,R,T> supplier)

Methods inherited from class lu.kbra.pclib.db.table.DatabaseTable

clear, count, countNotNull, countUniques, create, delete, deleteAll, deleteIfExists, deleteIfExists, deleteUnique, deleteUniques, doubleQuoteEscapeIdentifier, drop, exists, exists, existsUnique, existsUniques, filterExists, filterExistsByUnique, filterExistsUnique, getEntryClass, getName, getQualifiedName, getQueryable, getTargetClass, insert, insertAll, insertAndReload, insertAndReloadAll, load, loadAll, loadAllByUnique, loadAllUnique, loadByUnique, loadIfExists, loadIfExists, loadIfExistsElseInsert, loadUnique, loadUniqueIfExists, loadUniqueIfExistsElseInsert, loadUniqueIfExistsElseInsertAndReload, loadUniqueInternal, query, toString, truncate, update, updateAll, updateAndReload, updateAndReloadAll, updateAndReloadIfExists, updateAndReloadIfExistsElseInsert, updateAndReloadIfExistsElseInsertAndReload, updateIfExists, updateIfExistsElseInsert, updateIfExistsElseInsertAndReload, validateStructure, validateWrite

Methods inherited from class java.lang.Object

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

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>>

Overrides:

clear in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

count

public int count()
          throws DBException

Specified by:

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

Overrides:

count in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

countNotNull

public int countNotNull(T data)
                 throws DBException

Specified by:

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

Overrides:

countNotNull in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

countUniques

public int countUniques(T data)
                 throws DBException

Specified by:

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

Overrides:

countUniques in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

create

@Deprecated
public DatabaseTableStatus create()
                           throws DBException

Deprecated.

Specified by:

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

Overrides:

create in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

createProxy

@Deprecated
public DatabaseTable<T> createProxy(Supplier<AbstractConnection> connection)

Deprecated.

Overrides:

createProxy in class DatabaseTable<T extends DatabaseEntry>

delete

public T delete(T data)
         throws DBException

Specified by:

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

Overrides:

delete in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

deleteAll

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

Specified by:

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

Overrides:

deleteAll in class DatabaseTable<T extends DatabaseEntry>

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>>

Overrides:

deleteAllIfExists in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

deleteIfExists

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

Specified by:

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

Overrides:

deleteIfExists in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

deleteUnique

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

Specified by:

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

Overrides:

deleteUnique in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

deleteUniques

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

Specified by:

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

Overrides:

deleteUniques in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

drop

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

Deprecated.

Specified by:

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

Overrides:

drop in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

exists

@Deprecated
public boolean exists()
               throws DBException

Deprecated.

Specified by:

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

Overrides:

exists in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

exists

public boolean exists(T data)
               throws DBException

Specified by:

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

Overrides:

exists in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

existsUnique

public boolean existsUnique(T data)
                     throws DBException

Specified by:

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

Overrides:

existsUnique in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

existsUniques

public boolean existsUniques(T data)
                      throws DBException

Specified by:

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

Overrides:

existsUniques in class DatabaseTable<T extends DatabaseEntry>

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>>

Overrides:

filterExists in class DatabaseTable<T extends DatabaseEntry>

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>>

Overrides:

filterExistsUnique in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

getConnector

public DatabaseConnector getConnector()

Specified by:

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

Overrides:

getConnector in class DatabaseTable<T extends DatabaseEntry>

getCreateSQL

@Deprecated
public String[] getCreateSQL()

Deprecated.

Specified by:

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

Overrides:

getCreateSQL in class DatabaseTable<T extends DatabaseEntry>

getCustomHints

public Map<String,Object> getCustomHints()

getDatabase

public Database getDatabase()

getDatabaseEntryUtils

public DatabaseEntryUtils getDatabaseEntryUtils()

getQueryableHookManager

public SQLQueryableHookManager getQueryableHookManager()

getStatementAsSQL

public String getStatementAsSQL(Statement stmt)

getStructure

public TableStructure getStructure()

insert

public T insert(T data)
         throws DBException

Specified by:

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

Overrides:

insert in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

insertAll

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

Specified by:

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

Overrides:

insertAll in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

insertAndReload

public T insertAndReload(T data)
                  throws DBException

Specified by:

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

Overrides:

insertAndReload in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

insertAndReloadAll

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

Specified by:

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

Overrides:

insertAndReloadAll in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

load

public T load(T data)
       throws DBException

Specified by:

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

Overrides:

load in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

loadAll

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

Specified by:

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

Overrides:

loadAll in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

loadByUnique

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

Description copied from class: DatabaseTable

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>>

Overrides:

loadByUnique in class DatabaseTable<T extends DatabaseEntry>

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>>

Overrides:

loadAllIfExists in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

loadIfExists

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

Specified by:

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

Overrides:

loadIfExists in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

loadIfExistsElseInsert

public T loadIfExistsElseInsert(T data)
                         throws DBException

Description copied from class: DatabaseTable

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

Overrides:

loadIfExistsElseInsert in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

loadUnique

public T loadUnique(T data)
             throws DBException

Description copied from class: DatabaseTable

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

Specified by:

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

Overrides:

loadUnique in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

loadUniqueIfExists

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

Description copied from class: DatabaseTable

Loads the first 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>>

Overrides:

loadUniqueIfExists in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

loadUniqueIfExistsElseInsert

public T loadUniqueIfExistsElseInsert(T data)
                               throws DBException

Description copied from class: DatabaseTable

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>>

Overrides:

loadUniqueIfExistsElseInsert in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

query

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

Specified by:

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

Overrides:

query in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

setDbEntryUtils

@Deprecated
public void setDbEntryUtils(DatabaseEntryUtils dbEntryUtils)

Deprecated.

Overrides:

setDbEntryUtils in class DatabaseTable<T extends DatabaseEntry>

setQueryableHookManager

@Deprecated
public void setQueryableHookManager(SQLQueryableHookManager queryableHookManager)

Deprecated.

setTableStructure

@Deprecated
public void setTableStructure(TableStructure tableStructure)

Deprecated.

Specified by:

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

Overrides:

setTableStructure in class DatabaseTable<T extends DatabaseEntry>

truncate

@Deprecated
public int truncate()
             throws DBException

Deprecated.

Specified by:

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

Overrides:

truncate in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

update

public T update(T data)
         throws DBException

Specified by:

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

Overrides:

update in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

updateAll

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

Specified by:

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

Overrides:

updateAll in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

updateAndReload

public T updateAndReload(T data)
                  throws DBException

Specified by:

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

Overrides:

updateAndReload in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

updateAndReloadAll

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

Specified by:

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

Overrides:

updateAndReloadAll in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

use

protected final AbstractConnection use()
                                throws DBException

Overrides:

use in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

useWithTry

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

updateAndReloadIfExists

public Optional<T> updateAndReloadIfExists(T data)

Specified by:

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

Overrides:

updateAndReloadIfExists in class DatabaseTable<T extends DatabaseEntry>

updateAndReloadIfExistsElseInsert

public T updateAndReloadIfExistsElseInsert(T data)

Specified by:

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

Overrides:

updateAndReloadIfExistsElseInsert in class DatabaseTable<T extends DatabaseEntry>

updateAndReloadIfExistsElseInsertAndReload

public T updateAndReloadIfExistsElseInsertAndReload(T data)

Specified by:

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

Overrides:

updateAndReloadIfExistsElseInsertAndReload in class DatabaseTable<T extends DatabaseEntry>

updateIfExists

public Optional<T> updateIfExists(T data)

Specified by:

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

Overrides:

updateIfExists in class DatabaseTable<T extends DatabaseEntry>

updateIfExistsElseInsert

public T updateIfExistsElseInsert(T data)

Specified by:

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

Overrides:

updateIfExistsElseInsert in class DatabaseTable<T extends DatabaseEntry>

updateIfExistsElseInsertAndReload

public T updateIfExistsElseInsertAndReload(T data)

Specified by:

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

Overrides:

updateIfExistsElseInsertAndReload in class DatabaseTable<T extends DatabaseEntry>

loadUniqueIfExistsElseInsertAndReload

public T loadUniqueIfExistsElseInsertAndReload(T data)
                                        throws DBException

Description copied from class: DatabaseTable

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>>

Overrides:

loadUniqueIfExistsElseInsertAndReload in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException

loadAllUnique

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

Specified by:

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

Overrides:

loadAllUnique in class DatabaseTable<T extends DatabaseEntry>

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>>

Overrides:

loadAllByUnique in class DatabaseTable<T extends DatabaseEntry>

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>>

Overrides:

filterExistsByUnique in class DatabaseTable<T extends DatabaseEntry>

Throws:

DBException