Package lu.kbra.pclib.db.utils

Class BaseDataBaseEntryUtils

java.lang.Object

lu.kbra.pclib.db.utils.BaseDataBaseEntryUtils

All Implemented Interfaces:

DataBaseEntryUtils, DataBaseEntryUtilsOptionsOwner

Direct Known Subclasses:

BaseProxyDataBaseEntryUtils, MySQLDataBaseEntryUtils, PostgreSQLDataBaseEntryUtils, SQLiteDataBaseEntryUtils

public class BaseDataBaseEntryUtils
extends Object
implements DataBaseEntryUtils

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<Class<? extends DataBaseEntry>,Map<Set<String>,ReadOnlyPair<List<ReadOnlyQuadruple<String,ColumnData,Type,Integer>>,ThrowingFunction<Object[],? extends DataBaseEntry,DBException>>>>	argInstanceFactoryCache
protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]>	columnsCache
protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,Map<String,ColumnData>>	columnsNamesCache
protected final List<ColumnTypeFactory>	columnTypeFactories
protected String	dbmsQualifierName
protected final Map<ReadOnlyPair<Class<? extends AbstractDBTable<? extends DataBaseEntry>>,Class<? extends DataBaseEntry>>,String>	deleteSqlCache
protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,String>,Field>	fieldCache
protected final Map<Field,ColumnType>	fieldColumnTypeCache
protected final Map<Field,String>	fieldToColumnNameCache
protected SQLFunctionResolver	functionResolver
protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]>	generatedKeysCache
protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]>	insertColumnsCache
protected final Map<Class<?>,Method>	insertMethodCache
protected final Map<Class<?>,Method>	loadMethodCache
protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]>	nonNullColumnsCache
protected final Map<String,Object>	options
protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]>	primaryKeysCache
protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,String[]>	primaryKeysNamesCache
protected final Map<Class<?>,Map<String,Object>>	queryableHints
protected SQLStructureVisitor	structureVisitor
protected final Map<Class<? extends SQLQueryable<?>>,TableStructure>	tableStructureCache
protected final Map<AnnotatedType,Map<String,Object>>	typeHints
protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]>	updateColumnsCache
protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,String[]>	updateColumnsNamesCache
protected final Map<Class<?>,Method>	updateMethodCache
protected final Map<ReadOnlyPair<Class<? extends AbstractDBTable<? extends DataBaseEntry>>,Class<? extends DataBaseEntry>>,String>	updateSqlCache

Fields inherited from interface lu.kbra.pclib.db.utils.impl.DataBaseEntryUtils

FUNCTION_KEY, MEMBER_KEY, QUALIFIER_KEY, TABLE_NAME_KEY

Fields inherited from interface lu.kbra.pclib.db.utils.impl.DataBaseEntryUtilsOptionsOwner

FAIL_ON_DUPLICATE_FACTORY_METHOD, FAIL_ON_DUPLICATE_FACTORY_METHOD_PROPERTY, FORCE_DEFAULT_VALUE_ON_NON_NULL, FORCE_DEFAULT_VALUE_ON_NON_NULL_PROPERTY, WARN_ON_DUPLICATE_FACTORY_METHOD, WARN_ON_DUPLICATE_FACTORY_METHOD_PROPERTY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseDataBaseEntryUtils()
	BaseDataBaseEntryUtils(String protocolName)
	BaseDataBaseEntryUtils(ColumnTypeRegistry typeRegistry, String protocolName)
	BaseDataBaseEntryUtils(ColumnTypeRegistry typeRegistry, String protocolName, SQLStructureVisitor structureVisitor, SQLFunctionResolver functionResolver)

Method Summary

Modifier and Type	Method	Description
void	appendTypes(ColumnTypeRegistry addColumnTypeRegistry)
protected <B extends SQLQueryable<T>, T extends DataBaseEntry> Map<String,ColumnData>	computeColumnNames(Class<B> tableClazz, Class<T> entryClazz)
protected <B extends SQLQueryable<T>, T extends DataBaseEntry> ColumnData[]	computeColumnsFor(Class<T> entryClazz, Class<B> tableClazz)
<B extends SQLQueryable<T>, T extends DataBaseEntry> String	computeDefaultValue(Class<B> tableClazz, Field field)
protected Method	computeFactoryMethod(Class<?> clazz)
protected String	computeFieldToColumnName(Field field)
protected <B extends SQLQueryable<T>, T extends DataBaseEntry> ColumnData[]	computeGeneratedKeys(Class<T> entryClazz, Class<B> tableClazz)
protected <B extends SQLQueryable<T>, T extends DataBaseEntry> Map<Set<String>,ReadOnlyPair<List<ReadOnlyQuadruple<String,ColumnData,Type,Integer>>,ThrowingFunction<Object[],? extends DataBaseEntry,DBException>>>	computeInstanceFactories(Class<T> entryClazz, Class<B> tableClazz)
protected <B extends SQLQueryable<T>, T extends DataBaseEntry> ColumnData[]	computeNonNullColumns(Class<T> entryClazz, Class<B> tableClazz)
protected <B extends AbstractDBTable<T>, T extends DataBaseEntry> String	computePreparedDeleteSql(B table, Class<T> entryClazz)
protected <B extends AbstractDBTable<T>, T extends DataBaseEntry> String	computePreparedUpdateSQL(B table, Class<T> entryClazz)
protected <B extends SQLQueryable<T>, T extends DataBaseEntry> String[]	computePrimaryKeyNames(Class<T> entryClazz, Class<B> tableClazz)
protected <B extends SQLQueryable<T>, T extends DataBaseEntry> ColumnData[]	computePrimaryKeys(Class<T> entryClazz, Class<B> tableClazz)
protected Map<String,Object>	computeQueryableHints(Class<?> tableClazz)
Stream<ColumnTypeFactory>	computeType(Class<?> rawType, Map<String,Object> typeHints)
protected Map<String,Object>	computeTypeHints(AnnotatedType annotatedType)
protected <B extends SQLQueryable<T>, T extends DataBaseEntry> String[]	computeUpdateColumnsNames(Class<T> entryClazz, Class<B> tableClazz)
String	fieldToColumnName(Field field)
String	fieldToColumnName(String name)
<B extends SQLQueryable<T>, T extends DataBaseEntry> void	fillInsert(B table, T data, ResultSet rs)	Only reload generated keys
<B extends SQLQueryable<T>, T extends DataBaseEntry> void	fillLoad(B table, T data, ResultSet rs)	Full reload
protected <T extends DataBaseEntry> T	fillLoad(Class<T> entryClazz, ResultSet rs, List<ReadOnlyQuadruple<String,ColumnData,Type,Integer>> mapping, ThrowingFunction<Object[],? extends DataBaseEntry,DBException> factory)
<B extends SQLQueryable<T>, T extends DataBaseEntry> void	fillLoadAll(B table, Class<T> entryClazz, ResultSet rs, Consumer<T> listExporter)
<B extends SQLQueryable<T>, T extends DataBaseEntry> void	fillUpdate(B table, T data, ResultSet rs)
protected Field	findField(Class<?> type, String name)
protected Field[]	getAllFields(Class<?> type)
<B extends SQLQueryable<T>, T extends DataBaseEntry> ColumnData	getColumnFor(Class<T> entryClazz, Class<B> tableClazz, String name)
<B extends SQLQueryable<T>, T extends DataBaseEntry> ColumnData[]	getColumnsFor(Class<T> entryClazz, Class<B> tableClazz)
<T extends DataBaseEntry> Class<T>	getEntryType(Class<? extends SQLQueryable<?>> tableClass)
<T extends DataBaseEntry> Field	getFieldFor(Class<T> entryClazz, String sqlName)
<T extends DataBaseEntry> Field	getFieldFor(Class<T> entryClazz, ColumnData columnData)
<B extends SQLQueryable<T>, T extends DataBaseEntry> ColumnData[]	getGeneratedKeys(Class<T> entryClazz, Class<B> tableClazz)
protected <B extends SQLQueryable<T>, T extends DataBaseEntry> ColumnData[]	getInsertColumns(Class<T> entryClazz, Class<B> tableClazz)
<T extends DataBaseEntry> Method	getInsertMethod(Class<T> dataClazz)
<T extends DataBaseEntry> Method	getLoadMethod(Class<T> dataClazz)
protected <B extends SQLQueryable<T>, T extends DataBaseEntry> ColumnData[]	getNonNullColumns(Class<T> entryClazz, Class<B> tableClazz)	NOT OnUpdate, NOT PK, NOT Generated
<B extends SQLQueryable<T>, T extends DataBaseEntry> String[]	getNonNullKeys(B instance, T data)	returns the names of the columns that aren't null. ignored primary keys, generated and OnUpdate columns.
<B extends SQLQueryable<T>, T extends DataBaseEntry> Map<String,Object>	getNonNullValues(B instance, T data)
Map<String,Object>	getOptions()
<B extends AbstractDBTable<T>, T extends DataBaseEntry> String	getPreparedDeleteSQL(B table, T data)
<B extends AbstractDBTable<T>, T extends DataBaseEntry> String	getPreparedInsertSQL(B table, T data)
<B extends SQLQueryable<T>, T extends DataBaseEntry> String	getPreparedSelectCountNotNullSQL(B instance, String[] notNullKeys, T data)
<B extends SQLQueryable<T>, T extends DataBaseEntry> String	getPreparedSelectCountUniqueSQL(B instance, String[][] uniqueKeys, T data)
<B extends SQLQueryable<T>, T extends DataBaseEntry> String	getPreparedSelectSQL(B table, T data)
<B extends SQLQueryable<T>, T extends DataBaseEntry> String	getPreparedSelectUniqueSQL(B instance, String[][] uniqueKeys, T data)
<B extends AbstractDBTable<T>, T extends DataBaseEntry> String	getPreparedUpdateSQL(B table, T data)
<B extends SQLQueryable<T>, T extends DataBaseEntry> ColumnData[]	getPrimaryKeys(Class<T> entryClazz, Class<B> tableClazz)
<B extends SQLQueryable<T>, T extends DataBaseEntry> String[]	getPrimaryKeysNames(Class<T> entryClazz, Class<B> tableClazz)
Map<String,Object>	getQueryableHints(Class<?> tableClazz)
<V extends SQLQueryable<T>, T extends DataBaseEntry> String	getQueryableName(Class<V> tableClass)
String	getReferencedColumnName(ForeignKey fk)
ColumnType	getTypeFor(Class<?> clazz, Optional<AnnotatedType> type, Map<String,Object> typeHints)
ColumnType	getTypeFor(AnnotatedType annotatedType)
ColumnType	getTypeFor(AnnotatedType annotatedType, Map<String,Object> typeHints)
ColumnType	getTypeFor(Field field)
Map<String,Object>	getTypeHints(AnnotatedType annotatedType)
<T extends DataBaseEntry> String[][]	getUniqueKeys(ConstraintData[] allConstraints, T data)
<T extends DataBaseEntry> Map<String,Object>[]	getUniqueValues(ConstraintData[] allConstraints, T data)
protected <B extends SQLQueryable<T>, T extends DataBaseEntry> ColumnData[]	getUpdateColumns(Class<T> entryClazz, Class<B> tableClazz)
<B extends SQLQueryable<T>, T extends DataBaseEntry> String[]	getUpdateColumnsNames(Class<T> entryClazz, Class<B> tableClazz)
<T extends DataBaseEntry> Method	getUpdateMethod(Class<T> dataClazz)
<T extends DataBaseEntry> Method	getUpdateMethod(T data)
protected final String	globToRegex(String trim)
<B extends SQLQueryable<T>, T extends DataBaseEntry> T	instance(Class<T> entryClazz, Class<B> tableClazz)
protected boolean	isListType(Type type)
DataBaseEntryUtils	loadTypes(ColumnTypeRegistry registry)
protected boolean	matchesDbmsQualifier(String dbms)
protected String	parameterToColumnName(Parameter p)
<B extends AbstractDBTable<T>, T extends DataBaseEntry> void	prepareDeleteSQL(PreparedStatement stmt, B instance, T data)
<B extends AbstractDBTable<T>, T extends DataBaseEntry> void	prepareInsertSQL(PreparedStatement stmt, B instance, T data)
<B extends SQLQueryable<T>, T extends DataBaseEntry> void	prepareSelectCountNotNullSQL(PreparedStatement stmt, B instance, String[] notNullKeys, T data)
<B extends SQLQueryable<T>, T extends DataBaseEntry> void	prepareSelectCountUniqueSQL(PreparedStatement stmt, B instance, String[][] uniqueKeys, T data)
<B extends SQLQueryable<T>, T extends DataBaseEntry> void	prepareSelectSQL(PreparedStatement stmt, B instance, T data)
<B extends SQLQueryable<T>, T extends DataBaseEntry> void	prepareSelectUniqueSQL(PreparedStatement stmt, B instance, String[][] uniqueKeys, T data)
<B extends AbstractDBTable<T>, T extends DataBaseEntry> void	prepareUpdateSQL(PreparedStatement stmt, B instance, T data)
<V extends SQLQueryable<T>, T extends DataBaseEntry> String	qualifiedName(Class<V> typeName)
<B extends SQLQueryable<T>, T extends DataBaseEntry> String	replaceSQLQualifiers(Class<B> tableClazz, String input)
DataBaseStructure	scanDataBase(DataBase dataBase, Map<String,Object> baseHints)
<B extends AbstractDBTable<T>, T extends DataBaseEntry> TableStructure	scanEntry(Class<B> tableClazz, Class<T> entryClazz)
<T extends DataBaseEntry> TableStructure	scanTable(Class<? extends AbstractDBTable<T>> tableClazz)
List<Field>	sortFields(Field[] fields)

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.utils.impl.DataBaseEntryUtils

getDbmsQualifierName, getFunctionResolver, getStructureVisitor, getTypeFor

Methods inherited from interface lu.kbra.pclib.db.utils.impl.DataBaseEntryUtilsOptionsOwner

getOption, getOptionOrDefault, getOptionOrDefault, hasOption, isFailOnDuplicateFactoryMethod, isForceDefaultValueOnNonNull, isWarnOnDuplicateFactoryMethod, setOption

Field Details

columnTypeFactories

protected final List<ColumnTypeFactory> columnTypeFactories

dbmsQualifierName

protected String dbmsQualifierName

structureVisitor

protected SQLStructureVisitor structureVisitor

functionResolver

protected SQLFunctionResolver functionResolver

fieldColumnTypeCache

protected final Map<Field,ColumnType> fieldColumnTypeCache

columnsCache

protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]> columnsCache

primaryKeysCache

protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]> primaryKeysCache

primaryKeysNamesCache

protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,String[]> primaryKeysNamesCache

generatedKeysCache

protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]> generatedKeysCache

updateColumnsNamesCache

protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,String[]> updateColumnsNamesCache

nonNullColumnsCache

protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]> nonNullColumnsCache

insertColumnsCache

protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]> insertColumnsCache

updateColumnsCache

protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,ColumnData[]> updateColumnsCache

insertMethodCache

protected final Map<Class<?>,Method> insertMethodCache

updateMethodCache

protected final Map<Class<?>,Method> updateMethodCache

loadMethodCache

protected final Map<Class<?>,Method> loadMethodCache

tableStructureCache

protected final Map<Class<? extends SQLQueryable<?>>,TableStructure> tableStructureCache

fieldToColumnNameCache

protected final Map<Field,String> fieldToColumnNameCache

fieldCache

protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,String>,Field> fieldCache

updateSqlCache

protected final Map<ReadOnlyPair<Class<? extends AbstractDBTable<? extends DataBaseEntry>>,Class<? extends DataBaseEntry>>,String> updateSqlCache

deleteSqlCache

protected final Map<ReadOnlyPair<Class<? extends AbstractDBTable<? extends DataBaseEntry>>,Class<? extends DataBaseEntry>>,String> deleteSqlCache

typeHints

protected final Map<AnnotatedType,Map<String,Object>> typeHints

queryableHints

protected final Map<Class<?>,Map<String,Object>> queryableHints

options

protected final Map<String,Object> options

argInstanceFactoryCache

protected final Map<Class<? extends DataBaseEntry>,Map<Set<String>,ReadOnlyPair<List<ReadOnlyQuadruple<String,ColumnData,Type,Integer>>,ThrowingFunction<Object[],? extends DataBaseEntry,DBException>>>> argInstanceFactoryCache

columnsNamesCache

protected final Map<ReadOnlyPair<Class<? extends DataBaseEntry>,Class<? extends SQLQueryable<? extends DataBaseEntry>>>,Map<String,ColumnData>> columnsNamesCache

Constructor Details

BaseDataBaseEntryUtils

public BaseDataBaseEntryUtils(ColumnTypeRegistry typeRegistry,
 String protocolName)

BaseDataBaseEntryUtils

public BaseDataBaseEntryUtils(ColumnTypeRegistry typeRegistry,
 String protocolName,
 SQLStructureVisitor structureVisitor,
 SQLFunctionResolver functionResolver)

BaseDataBaseEntryUtils

public BaseDataBaseEntryUtils(String protocolName)

BaseDataBaseEntryUtils

protected BaseDataBaseEntryUtils()

Method Details

appendTypes

public void appendTypes(ColumnTypeRegistry addColumnTypeRegistry)

computeType

public Stream<ColumnTypeFactory> computeType(Class<?> rawType,
 Map<String,Object> typeHints)

Specified by:

computeType in interface DataBaseEntryUtils

fieldToColumnName

public String fieldToColumnName(Field field)

Specified by:

fieldToColumnName in interface DataBaseEntryUtils

fieldToColumnName

public String fieldToColumnName(String name)

Specified by:

fieldToColumnName in interface DataBaseEntryUtils

fillInsert

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
void fillInsert(B table,
 T data,
 ResultSet rs)
         throws SQLException

Description copied from interface: DataBaseEntryUtils

Only reload generated keys

Specified by:

fillInsert in interface DataBaseEntryUtils

Throws:

SQLException

fillLoad

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
void fillLoad(B table,
 T data,
 ResultSet rs)
       throws SQLException

Description copied from interface: DataBaseEntryUtils

Full reload

Specified by:

fillLoad in interface DataBaseEntryUtils

Throws:

SQLException

fillLoadAll

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
void fillLoadAll(B table,
 Class<T> entryClazz,
 ResultSet rs,
 Consumer<T> listExporter)
          throws SQLException

Specified by:

fillLoadAll in interface DataBaseEntryUtils

Throws:

SQLException

fillUpdate

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
void fillUpdate(B table,
 T data,
 ResultSet rs)
         throws SQLException

Specified by:

fillUpdate in interface DataBaseEntryUtils

Throws:

SQLException

getColumnFor

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
ColumnData getColumnFor(Class<T> entryClazz,
 Class<B> tableClazz,
 String name)

getColumnsFor

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
ColumnData[] getColumnsFor(Class<T> entryClazz,
 Class<B> tableClazz)

getEntryType

public <T extends DataBaseEntry> Class<T> getEntryType(Class<? extends SQLQueryable<?>> tableClass)

Specified by:

getEntryType in interface DataBaseEntryUtils

getFieldFor

public <T extends DataBaseEntry> Field getFieldFor(Class<T> entryClazz,
 ColumnData columnData)

getFieldFor

public <T extends DataBaseEntry> Field getFieldFor(Class<T> entryClazz,
 String sqlName)

Specified by:

getFieldFor in interface DataBaseEntryUtils

getGeneratedKeys

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
ColumnData[] getGeneratedKeys(Class<T> entryClazz,
 Class<B> tableClazz)

Specified by:

getGeneratedKeys in interface DataBaseEntryUtils

getInsertMethod

public <T extends DataBaseEntry> Method getInsertMethod(Class<T> dataClazz)

Specified by:

getInsertMethod in interface DataBaseEntryUtils

getLoadMethod

public <T extends DataBaseEntry> Method getLoadMethod(Class<T> dataClazz)

Specified by:

getLoadMethod in interface DataBaseEntryUtils

getNonNullKeys

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
String[] getNonNullKeys(B instance,
 T data)

Description copied from interface: DataBaseEntryUtils

returns the names of the columns that aren't null. ignored primary keys, generated and OnUpdate columns.

Specified by:

getNonNullKeys in interface DataBaseEntryUtils

getNonNullValues

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
Map<String,Object> getNonNullValues(B instance,
 T data)

Specified by:

getNonNullValues in interface DataBaseEntryUtils

getOptions

public Map<String,Object> getOptions()

Specified by:

getOptions in interface DataBaseEntryUtilsOptionsOwner

getPreparedDeleteSQL

public <B extends AbstractDBTable<T>,
T extends DataBaseEntry>
String getPreparedDeleteSQL(B table,
 T data)

Specified by:

getPreparedDeleteSQL in interface DataBaseEntryUtils

getPreparedInsertSQL

public <B extends AbstractDBTable<T>,
T extends DataBaseEntry>
String getPreparedInsertSQL(B table,
 T data)

Specified by:

getPreparedInsertSQL in interface DataBaseEntryUtils

getPreparedSelectCountNotNullSQL

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
String getPreparedSelectCountNotNullSQL(B instance,
 String[] notNullKeys,
 T data)

Specified by:

getPreparedSelectCountNotNullSQL in interface DataBaseEntryUtils

getPreparedSelectCountUniqueSQL

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
String getPreparedSelectCountUniqueSQL(B instance,
 String[][] uniqueKeys,
 T data)

Specified by:

getPreparedSelectCountUniqueSQL in interface DataBaseEntryUtils

getPreparedSelectSQL

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
String getPreparedSelectSQL(B table,
 T data)

Specified by:

getPreparedSelectSQL in interface DataBaseEntryUtils

getPreparedSelectUniqueSQL

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
String getPreparedSelectUniqueSQL(B instance,
 String[][] uniqueKeys,
 T data)

Specified by:

getPreparedSelectUniqueSQL in interface DataBaseEntryUtils

getPreparedUpdateSQL

public <B extends AbstractDBTable<T>,
T extends DataBaseEntry>
String getPreparedUpdateSQL(B table,
 T data)

Specified by:

getPreparedUpdateSQL in interface DataBaseEntryUtils

getPrimaryKeys

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
ColumnData[] getPrimaryKeys(Class<T> entryClazz,
 Class<B> tableClazz)

Specified by:

getPrimaryKeys in interface DataBaseEntryUtils

getPrimaryKeysNames

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
String[] getPrimaryKeysNames(Class<T> entryClazz,
 Class<B> tableClazz)

Specified by:

getPrimaryKeysNames in interface DataBaseEntryUtils

getQueryableHints

public Map<String,Object> getQueryableHints(Class<?> tableClazz)

Specified by:

getQueryableHints in interface DataBaseEntryUtils

getQueryableName

public <V extends SQLQueryable<T>,
T extends DataBaseEntry>
String getQueryableName(Class<V> tableClass)

Specified by:

getQueryableName in interface DataBaseEntryUtils

getReferencedColumnName

public String getReferencedColumnName(ForeignKey fk)

Specified by:

getReferencedColumnName in interface DataBaseEntryUtils

getTypeFor

public ColumnType getTypeFor(AnnotatedType annotatedType)

Specified by:

getTypeFor in interface DataBaseEntryUtils

getTypeFor

public ColumnType getTypeFor(AnnotatedType annotatedType,
 Map<String,Object> typeHints)

Specified by:

getTypeFor in interface DataBaseEntryUtils

getTypeFor

public ColumnType getTypeFor(Class<?> clazz,
 Optional<AnnotatedType> type,
 Map<String,Object> typeHints)

Specified by:

getTypeFor in interface DataBaseEntryUtils

getTypeFor

public ColumnType getTypeFor(Field field)

Specified by:

getTypeFor in interface DataBaseEntryUtils

getTypeHints

public Map<String,Object> getTypeHints(AnnotatedType annotatedType)

Specified by:

getTypeHints in interface DataBaseEntryUtils

getUniqueKeys

public <T extends DataBaseEntry> String[][] getUniqueKeys(ConstraintData[] allConstraints,
 T data)

Specified by:

getUniqueKeys in interface DataBaseEntryUtils

getUniqueValues

public <T extends DataBaseEntry>
Map<String,Object>[] getUniqueValues(ConstraintData[] allConstraints,
 T data)

Specified by:

getUniqueValues in interface DataBaseEntryUtils

getUpdateColumnsNames

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
String[] getUpdateColumnsNames(Class<T> entryClazz,
 Class<B> tableClazz)

Specified by:

getUpdateColumnsNames in interface DataBaseEntryUtils

getUpdateMethod

public <T extends DataBaseEntry> Method getUpdateMethod(Class<T> dataClazz)

Specified by:

getUpdateMethod in interface DataBaseEntryUtils

getUpdateMethod

public <T extends DataBaseEntry> Method getUpdateMethod(T data)

Specified by:

getUpdateMethod in interface DataBaseEntryUtils

instance

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
T instance(Class<T> entryClazz,
 Class<B> tableClazz)

Specified by:

instance in interface DataBaseEntryUtils

loadTypes

public DataBaseEntryUtils loadTypes(ColumnTypeRegistry registry)

prepareDeleteSQL

public <B extends AbstractDBTable<T>,
T extends DataBaseEntry>
void prepareDeleteSQL(PreparedStatement stmt,
 B instance,
 T data)
               throws SQLException

Specified by:

prepareDeleteSQL in interface DataBaseEntryUtils

Throws:

SQLException

prepareInsertSQL

public <B extends AbstractDBTable<T>,
T extends DataBaseEntry>
void prepareInsertSQL(PreparedStatement stmt,
 B instance,
 T data)
               throws SQLException

Specified by:

prepareInsertSQL in interface DataBaseEntryUtils

Throws:

SQLException

prepareSelectCountNotNullSQL

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
void prepareSelectCountNotNullSQL(PreparedStatement stmt,
 B instance,
 String[] notNullKeys,
 T data)
                           throws SQLException

Specified by:

prepareSelectCountNotNullSQL in interface DataBaseEntryUtils

Throws:

SQLException

prepareSelectCountUniqueSQL

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
void prepareSelectCountUniqueSQL(PreparedStatement stmt,
 B instance,
 String[][] uniqueKeys,
 T data)
                          throws SQLException

Specified by:

prepareSelectCountUniqueSQL in interface DataBaseEntryUtils

Throws:

SQLException

prepareSelectSQL

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
void prepareSelectSQL(PreparedStatement stmt,
 B instance,
 T data)
               throws SQLException

Specified by:

prepareSelectSQL in interface DataBaseEntryUtils

Throws:

SQLException

prepareSelectUniqueSQL

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
void prepareSelectUniqueSQL(PreparedStatement stmt,
 B instance,
 String[][] uniqueKeys,
 T data)
                     throws SQLException

Specified by:

prepareSelectUniqueSQL in interface DataBaseEntryUtils

Throws:

SQLException

prepareUpdateSQL

public <B extends AbstractDBTable<T>,
T extends DataBaseEntry>
void prepareUpdateSQL(PreparedStatement stmt,
 B instance,
 T data)
               throws SQLException

Specified by:

prepareUpdateSQL in interface DataBaseEntryUtils

Throws:

SQLException

qualifiedName

public <V extends SQLQueryable<T>,
T extends DataBaseEntry>
String qualifiedName(Class<V> typeName)

Specified by:

qualifiedName in interface DataBaseEntryUtils

replaceSQLQualifiers

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
String replaceSQLQualifiers(Class<B> tableClazz,
 String input)

Specified by:

replaceSQLQualifiers in interface DataBaseEntryUtils

scanDataBase

public DataBaseStructure scanDataBase(DataBase dataBase,
 Map<String,Object> baseHints)

Specified by:

scanDataBase in interface DataBaseEntryUtils

scanEntry

public <B extends AbstractDBTable<T>,
T extends DataBaseEntry>
TableStructure scanEntry(Class<B> tableClazz,
 Class<T> entryClazz)

Specified by:

scanEntry in interface DataBaseEntryUtils

scanTable

public <T extends DataBaseEntry> TableStructure scanTable(Class<? extends AbstractDBTable<T>> tableClazz)

Specified by:

scanTable in interface DataBaseEntryUtils

sortFields

public List<Field> sortFields(Field[] fields)

computeColumnNames

protected <B extends SQLQueryable<T>,
T extends DataBaseEntry>
Map<String,ColumnData> computeColumnNames(Class<B> tableClazz,
 Class<T> entryClazz)

computeColumnsFor

protected <B extends SQLQueryable<T>,
T extends DataBaseEntry>
ColumnData[] computeColumnsFor(Class<T> entryClazz,
 Class<B> tableClazz)

computeDefaultValue

public <B extends SQLQueryable<T>,
T extends DataBaseEntry>
String computeDefaultValue(Class<B> tableClazz,
 Field field)

Specified by:

computeDefaultValue in interface DataBaseEntryUtils

computeFactoryMethod

protected Method computeFactoryMethod(Class<?> clazz)

computeFieldToColumnName

protected String computeFieldToColumnName(Field field)

computeGeneratedKeys

protected <B extends SQLQueryable<T>,
T extends DataBaseEntry>
ColumnData[] computeGeneratedKeys(Class<T> entryClazz,
 Class<B> tableClazz)

computeInstanceFactories

protected <B extends SQLQueryable<T>,
T extends DataBaseEntry>
Map<Set<String>,ReadOnlyPair<List<ReadOnlyQuadruple<String,ColumnData,Type,Integer>>,ThrowingFunction<Object[],? extends DataBaseEntry,DBException>>> computeInstanceFactories(Class<T> entryClazz,
 Class<B> tableClazz)

computeNonNullColumns

protected <B extends SQLQueryable<T>,
T extends DataBaseEntry>
ColumnData[] computeNonNullColumns(Class<T> entryClazz,
 Class<B> tableClazz)

computePreparedDeleteSql

protected <B extends AbstractDBTable<T>,
T extends DataBaseEntry>
String computePreparedDeleteSql(B table,
 Class<T> entryClazz)

computePreparedUpdateSQL

protected <B extends AbstractDBTable<T>,
T extends DataBaseEntry>
String computePreparedUpdateSQL(B table,
 Class<T> entryClazz)

computePrimaryKeyNames

protected <B extends SQLQueryable<T>,
T extends DataBaseEntry>
String[] computePrimaryKeyNames(Class<T> entryClazz,
 Class<B> tableClazz)

computePrimaryKeys

protected <B extends SQLQueryable<T>,
T extends DataBaseEntry>
ColumnData[] computePrimaryKeys(Class<T> entryClazz,
 Class<B> tableClazz)

computeQueryableHints

protected Map<String,Object> computeQueryableHints(Class<?> tableClazz)

computeTypeHints

protected Map<String,Object> computeTypeHints(AnnotatedType annotatedType)

computeUpdateColumnsNames

protected <B extends SQLQueryable<T>,
T extends DataBaseEntry>
String[] computeUpdateColumnsNames(Class<T> entryClazz,
 Class<B> tableClazz)

fillLoad

protected <T extends DataBaseEntry> T fillLoad(Class<T> entryClazz,
 ResultSet rs,
 List<ReadOnlyQuadruple<String,ColumnData,Type,Integer>> mapping,
 ThrowingFunction<Object[],? extends DataBaseEntry,DBException> factory)
                                        throws SQLException

Throws:

SQLException

findField

protected Field findField(Class<?> type,
 String name)
                   throws NoSuchFieldException

Throws:

NoSuchFieldException

getAllFields

protected Field[] getAllFields(Class<?> type)

getInsertColumns

protected <B extends SQLQueryable<T>,
T extends DataBaseEntry>
ColumnData[] getInsertColumns(Class<T> entryClazz,
 Class<B> tableClazz)

getNonNullColumns

protected <B extends SQLQueryable<T>,
T extends DataBaseEntry>
ColumnData[] getNonNullColumns(Class<T> entryClazz,
 Class<B> tableClazz)

NOT OnUpdate, NOT PK, NOT Generated

getUpdateColumns

protected <B extends SQLQueryable<T>,
T extends DataBaseEntry>
ColumnData[] getUpdateColumns(Class<T> entryClazz,
 Class<B> tableClazz)

globToRegex

protected final String globToRegex(String trim)

isListType

protected boolean isListType(Type type)

matchesDbmsQualifier

protected boolean matchesDbmsQualifier(String dbms)

parameterToColumnName

protected String parameterToColumnName(Parameter p)