Package lu.kbra.pclib.db.table

Class DataBaseTable<T extends DataBaseEntry>

java.lang.Object

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

All Implemented Interfaces:

SQLHookable, SQLQueryable<T>, AbstractDBTable<T>

Direct Known Subclasses:

DBTableProxy, DeferredDataBaseTable

public class DataBaseTable<T extends DataBaseEntry>
extends Object
implements AbstractDBTable<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected DataBase	database
protected DataBaseEntryUtils	dataBaseEntryUtils
protected Class<? extends AbstractDBTable<T>>	tableClass
protected TableStructure	tableStructure

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DataBaseTable()
	DataBaseTable(DataBase dataBase)
	DataBaseTable(DataBase dataBase, DataBaseEntryUtils dbEntryUtils)
	DataBaseTable(DataBase dataBase, DataBaseEntryUtils dbEntryUtils, Class<? extends AbstractDBTable<T>> tableClass)

Method Summary

Modifier and Type	Method	Description
int	clear()
protected int	clear(Connection c)
int	count()
protected int	count(Connection c)
protected int	countNotNull(Connection c, T data)
int	countNotNull(T data)
protected int	countUniques(Connection c, T data)
int	countUniques(T data)
DataBaseTableStatus<T,? extends DataBaseTable<T>>	create()
protected DataBaseTableStatus<T,? extends DataBaseTable<T>>	create(Connection c)
DataBaseTable<T>	createProxy(Connection connection)
protected T	delete(Connection c, T data)
T	delete(T data)
protected Optional<T>	deleteIfExists(Connection c, T data)
Optional<T>	deleteIfExists(T data)
protected Optional<T>	deleteUnique(Connection c, T data)
Optional<T>	deleteUnique(T data)
protected List<T>	deleteUniques(Connection c, T data)
List<T>	deleteUniques(T data)
protected String	doubleQuoteEscapeIdentifier(String identifier)
DataBaseTable<T>	drop()
protected DataBaseTable<T>	drop(Connection c)
boolean	exists()
protected boolean	exists(Connection c)
protected boolean	exists(Connection c, T data)
boolean	exists(T data)
protected boolean	existsUnique(Connection c, T data)
boolean	existsUnique(T data)
protected boolean	existsUniques(Connection c, T data)
boolean	existsUniques(T data)
protected void	gen()
DataBaseConnector	getConnector()
String[]	getCreateSQL()
String[]	getPrimaryKeysNames()
protected DataBaseTable<T>	getQueryable()
Class<? extends SQLQueryable<T>>	getTargetClass()
protected T	insert(Connection c, T data)
T	insert(T data)
protected T	insertAndReload(Connection c, T data)
T	insertAndReload(T data)
protected T	load(Connection c, T data)
T	load(T data)
protected List<T>	loadByUnique(Connection c, T data)
List<T>	loadByUnique(T data)	Returns a list of all the possible entries matching with the unique values of the input.
protected Optional<T>	loadIfExists(Connection c, T data)
Optional<T>	loadIfExists(T data)
protected T	loadIfExistsElseInsert(Connection c, T data)
T	loadIfExistsElseInsert(T data)	Loads the first pk result, returns a the newly inserted instance if none is found
protected T	loadUnique(Connection c, T data)
T	loadUnique(T data)	Loads the first unique result, or throws an exception if none is found.
protected Optional<T>	loadUniqueIfExists(Connection c, T data)
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.
protected T	loadUniqueIfExistsElseInsert(Connection c, T data)
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.
protected <B> B	query(Connection c, SQLQuery<T,B> query)
<B> B	query(SQLQuery<T,B> query)
void	requestHook(SQLRequestType type, Object query)
void	setDbEntryUtils(DataBaseEntryUtils dbEntryUtils)
int	truncate()
protected int	truncate(Connection c)
protected T	update(Connection c, T data)
T	update(T data)
protected T	updateAndReload(Connection c, T data)
T	updateAndReload(T data)
protected AbstractConnection	use()

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

getDatabase, getEntryClass, getTableClass, getTableStructure

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

getDataBaseEntryUtils, getName, getQualifiedName

Field Details

database

protected DataBase database

dataBaseEntryUtils

protected DataBaseEntryUtils dataBaseEntryUtils

tableStructure

protected TableStructure tableStructure

tableClass

protected Class<? extends AbstractDBTable<T extends DataBaseEntry>> tableClass

Constructor Details

DataBaseTable

public DataBaseTable(DataBase dataBase)

DataBaseTable

public DataBaseTable(DataBase dataBase,
 DataBaseEntryUtils dbEntryUtils)

DataBaseTable

public DataBaseTable(DataBase dataBase,
 DataBaseEntryUtils dbEntryUtils,
 Class<? extends AbstractDBTable<T>> tableClass)

DataBaseTable

protected DataBaseTable()

Method Details

clear

public int clear()
          throws DBException

Specified by:

clear in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

count

public int count()
          throws DBException

Specified by:

count in interface SQLQueryable<T extends DataBaseEntry>

Throws:

DBException

countNotNull

public int countNotNull(T data)
                 throws DBException

Specified by:

countNotNull in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

countUniques

public int countUniques(T data)
                 throws DBException

Specified by:

countUniques in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

create

public DataBaseTableStatus<T,? extends DataBaseTable<T>> create()
                                                         throws DBException

Specified by:

create in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

createProxy

public DataBaseTable<T> createProxy(Connection connection)

delete

public T delete(T data)
         throws DBException

Specified by:

delete in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

deleteIfExists

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

Specified by:

deleteIfExists in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

deleteUnique

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

Specified by:

deleteUnique in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

deleteUniques

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

Specified by:

deleteUniques in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

drop

public DataBaseTable<T> drop()
                      throws DBException

Specified by:

drop in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

exists

public boolean exists()
               throws DBException

Specified by:

exists in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

exists

public boolean exists(T data)
               throws DBException

Specified by:

exists in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

existsUnique

public boolean existsUnique(T data)
                     throws DBException

Specified by:

existsUnique in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

existsUniques

public boolean existsUniques(T data)
                      throws DBException

Specified by:

existsUniques in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

getConnector

public DataBaseConnector getConnector()

Specified by:

getConnector in interface SQLQueryable<T extends DataBaseEntry>

getCreateSQL

public String[] getCreateSQL()

Specified by:

getCreateSQL in interface AbstractDBTable<T extends DataBaseEntry>

getPrimaryKeysNames

public String[] getPrimaryKeysNames()

Specified by:

getPrimaryKeysNames in interface AbstractDBTable<T extends DataBaseEntry>

getTargetClass

public Class<? extends SQLQueryable<T>> getTargetClass()

Specified by:

getTargetClass in interface SQLQueryable<T extends DataBaseEntry>

insert

public T insert(T data)
         throws DBException

Specified by:

insert in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

insertAndReload

public T insertAndReload(T data)
                  throws DBException

Specified by:

insertAndReload in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

load

public T load(T data)
       throws DBException

Specified by:

load in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

loadByUnique

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

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

Specified by:

loadByUnique in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

loadIfExists

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

Throws:

DBException

loadIfExistsElseInsert

public T loadIfExistsElseInsert(T data)
                         throws DBException

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

Throws:

DBException

loadUnique

public T loadUnique(T data)
             throws DBException

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

Specified by:

loadUnique in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

loadUniqueIfExists

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

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<T extends DataBaseEntry>

Throws:

DBException

loadUniqueIfExistsElseInsert

public T loadUniqueIfExistsElseInsert(T data)
                               throws DBException

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<T extends DataBaseEntry>

Throws:

DBException

query

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

Specified by:

query in interface SQLQueryable<T extends DataBaseEntry>

Throws:

DBException

requestHook

public void requestHook(SQLRequestType type,
 Object query)

Specified by:

requestHook in interface SQLHookable

setDbEntryUtils

public void setDbEntryUtils(DataBaseEntryUtils dbEntryUtils)

truncate

public int truncate()
             throws DBException

Specified by:

truncate in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

update

public T update(T data)
         throws DBException

Specified by:

update in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

updateAndReload

public T updateAndReload(T data)
                  throws DBException

Specified by:

updateAndReload in interface AbstractDBTable<T extends DataBaseEntry>

Throws:

DBException

clear

protected int clear(Connection c)
             throws DBException

Throws:

DBException

count

protected int count(Connection c)
             throws DBException

Throws:

DBException

countNotNull

protected int countNotNull(Connection c,
 T data)
                    throws DBException

Throws:

DBException

countUniques

protected int countUniques(Connection c,
 T data)
                    throws DBException

Throws:

DBException

create

protected DataBaseTableStatus<T,? extends DataBaseTable<T>> create(Connection c)
                                                            throws DBException

Throws:

DBException

delete

protected T delete(Connection c,
 T data)
            throws DBException

Throws:

DBException

deleteIfExists

protected Optional<T> deleteIfExists(Connection c,
 T data)
                              throws DBException

Throws:

DBException

deleteUnique

protected Optional<T> deleteUnique(Connection c,
 T data)
                            throws DBException

Throws:

DBException

deleteUniques

protected List<T> deleteUniques(Connection c,
 T data)
                         throws DBException

Throws:

DBException

doubleQuoteEscapeIdentifier

protected String doubleQuoteEscapeIdentifier(String identifier)

drop

protected DataBaseTable<T> drop(Connection c)
                         throws DBException

Throws:

DBException

exists

protected boolean exists(Connection c)
                  throws DBException

Throws:

DBException

exists

protected boolean exists(Connection c,
 T data)
                  throws DBException

Throws:

DBException

existsUnique

protected boolean existsUnique(Connection c,
 T data)
                        throws DBException

Throws:

DBException

existsUniques

protected boolean existsUniques(Connection c,
 T data)
                         throws DBException

Throws:

DBException

gen

protected void gen()

getQueryable

protected DataBaseTable<T> getQueryable()

insert

protected T insert(Connection c,
 T data)
            throws DBException

Throws:

DBException

insertAndReload

protected T insertAndReload(Connection c,
 T data)
                     throws DBException

Throws:

DBException

load

protected T load(Connection c,
 T data)
          throws DBException

Throws:

DBException

loadByUnique

protected List<T> loadByUnique(Connection c,
 T data)
                        throws DBException

Throws:

DBException

loadIfExists

protected Optional<T> loadIfExists(Connection c,
 T data)
                            throws DBException

Throws:

DBException

loadIfExistsElseInsert

protected T loadIfExistsElseInsert(Connection c,
 T data)
                            throws DBException

Throws:

DBException

loadUnique

protected T loadUnique(Connection c,
 T data)
                throws DBException

Throws:

DBException

loadUniqueIfExists

protected Optional<T> loadUniqueIfExists(Connection c,
 T data)
                                  throws DBException

Throws:

DBException

loadUniqueIfExistsElseInsert

protected T loadUniqueIfExistsElseInsert(Connection c,
 T data)
                                  throws DBException

Throws:

DBException

query

protected <B> B query(Connection c,
 SQLQuery<T,B> query)
               throws DBException

Throws:

DBException

truncate

protected int truncate(Connection c)
                throws DBException

Throws:

DBException

update

protected T update(Connection c,
 T data)
            throws DBException

Throws:

DBException

updateAndReload

protected T updateAndReload(Connection c,
 T data)
                     throws DBException

Throws:

DBException

use

protected AbstractConnection use()
                          throws DBException

Throws:

DBException