au.com.cybersearch2.classyjpa.entity

Class PersistenceDao<T,ID>

java.lang.Object

au.com.cybersearch2.classyjpa.entity.PersistenceDao<T,ID>

All Implemented Interfaces:

com.j256.ormlite.dao.CloseableIterable<T>, Iterable<T>

public class PersistenceDao<T,ID>
extends Object
implements com.j256.ormlite.dao.CloseableIterable<T>

Adapted com.j256.ormlite.dao.RuntimeExceptionDao to throw javax.persistence.PersistenceException instead. Proxy to a Dao that wraps each Exception and rethrows it as PersistenceException.

 PersistenceDao<Account, String> accountDao = PersistenceDao.createDao(connectionSource, Account.class);
 

Author:

graywatson

Constructor Summary

Constructors

Constructor and Description
PersistenceDao(com.j256.ormlite.dao.Dao<T,ID> dao)

Method Summary

Methods

Modifier and Type	Method and Description
void	assignEmptyForeignCollection(T parent, String fieldName)
<CT> CT	callBatchTasks(Callable<CT> callable)
void	clearObjectCache()
com.j256.ormlite.dao.CloseableIterator<T>	closeableIterator()
void	closeLastIterator()
void	commit(com.j256.ormlite.support.DatabaseConnection connection)
long	countOf()
long	countOf(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery)
int	create(Collection<T> datas)
int	create(T data)
static <T,ID> PersistenceDao<T,ID>	createDao(com.j256.ormlite.support.ConnectionSource connectionSource, Class<T> clazz) Call through to DaoManager.createDao(ConnectionSource, Class) with the returned DAO wrapped in a PersistenceDao.
static <T,ID> PersistenceDao<T,ID>	createDao(com.j256.ormlite.support.ConnectionSource connectionSource, com.j256.ormlite.table.DatabaseTableConfig<T> tableConfig) Call through to DaoManager.createDao(ConnectionSource, DatabaseTableConfig) with the returned DAO wrapped in a PersistenceDao.
T	createIfNotExists(T data)
com.j256.ormlite.dao.Dao.CreateOrUpdateStatus	createOrUpdate(T data)
int	delete(Collection<T> datas)
int	delete(com.j256.ormlite.stmt.PreparedDelete<T> preparedDelete)
int	delete(T data)
com.j256.ormlite.stmt.DeleteBuilder<T,ID>	deleteBuilder()
int	deleteById(ID id)
int	deleteIds(Collection<ID> ids)
void	endThreadConnection(com.j256.ormlite.support.DatabaseConnection connection)
int	executeRaw(String statement, String... arguments)
int	executeRawNoArgs(String statement)
ID	extractId(T data)
com.j256.ormlite.field.FieldType	findForeignFieldType(Class<?> clazz)
com.j256.ormlite.support.ConnectionSource	getConnectionSource()
Class<T>	getDataClass()
<FT> com.j256.ormlite.dao.ForeignCollection<FT>	getEmptyForeignCollection(String fieldName)
com.j256.ormlite.dao.ObjectCache	getObjectCache()
com.j256.ormlite.dao.RawRowMapper<T>	getRawRowMapper()
com.j256.ormlite.stmt.GenericRowMapper<T>	getSelectStarRowMapper()
com.j256.ormlite.dao.CloseableWrappedIterable<T>	getWrappedIterable()
com.j256.ormlite.dao.CloseableWrappedIterable<T>	getWrappedIterable(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery)
boolean	idExists(ID id)
boolean	isAutoCommit() Deprecated.
boolean	isAutoCommit(com.j256.ormlite.support.DatabaseConnection connection)
boolean	isTableExists()
boolean	isUpdatable()
com.j256.ormlite.dao.CloseableIterator<T>	iterator()
com.j256.ormlite.dao.CloseableIterator<T>	iterator(int resultFlags)
com.j256.ormlite.dao.CloseableIterator<T>	iterator(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery)
com.j256.ormlite.dao.CloseableIterator<T>	iterator(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery, int resultFlags)
T	mapSelectStarRow(com.j256.ormlite.support.DatabaseResults results)
void	notifyChanges()
boolean	objectsEqual(T data1, T data2)
String	objectToString(T data)
List<T>	query(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery)
com.j256.ormlite.stmt.QueryBuilder<T,ID>	queryBuilder()
List<T>	queryForAll()
List<T>	queryForEq(String fieldName, Object value)
List<T>	queryForFieldValues(Map<String,Object> fieldValues)
List<T>	queryForFieldValuesArgs(Map<String,Object> fieldValues)
T	queryForFirst(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery)
T	queryForId(ID id)
List<T>	queryForMatching(T matchObj)
List<T>	queryForMatchingArgs(T matchObj)
T	queryForSameId(T data)
<UO> com.j256.ormlite.dao.GenericRawResults<UO>	queryRaw(String query, com.j256.ormlite.dao.DatabaseResultsMapper<UO> mapper, String... arguments)
<UO> com.j256.ormlite.dao.GenericRawResults<UO>	queryRaw(String query, com.j256.ormlite.field.DataType[] columnTypes, com.j256.ormlite.dao.RawRowObjectMapper<UO> mapper, String... arguments)
com.j256.ormlite.dao.GenericRawResults<Object[]>	queryRaw(String query, com.j256.ormlite.field.DataType[] columnTypes, String... arguments)
<UO> com.j256.ormlite.dao.GenericRawResults<UO>	queryRaw(String query, com.j256.ormlite.dao.RawRowMapper<UO> mapper, String... arguments)
com.j256.ormlite.dao.GenericRawResults<String[]>	queryRaw(String query, String... arguments)
long	queryRawValue(String query, String... arguments)
int	refresh(T data)
void	registerObserver(com.j256.ormlite.dao.Dao.DaoObserver observer)
void	rollBack(com.j256.ormlite.support.DatabaseConnection connection)
void	setAutoCommit(boolean autoCommit) Deprecated.
void	setAutoCommit(com.j256.ormlite.support.DatabaseConnection connection, boolean autoCommit)
void	setObjectCache(boolean enabled)
void	setObjectCache(com.j256.ormlite.dao.ObjectCache objectCache)
void	setObjectFactory(com.j256.ormlite.table.ObjectFactory<T> objectFactory)
com.j256.ormlite.support.DatabaseConnection	startThreadConnection()
void	unregisterObserver(com.j256.ormlite.dao.Dao.DaoObserver observer)
int	update(com.j256.ormlite.stmt.PreparedUpdate<T> preparedUpdate)
int	update(T data)
com.j256.ormlite.stmt.UpdateBuilder<T,ID>	updateBuilder()
int	updateId(T data, ID newId)
int	updateRaw(String statement, String... arguments)

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistenceDao

public PersistenceDao(com.j256.ormlite.dao.Dao<T,ID> dao)

Method Detail

createDao

public static <T,ID> PersistenceDao<T,ID> createDao(com.j256.ormlite.support.ConnectionSource connectionSource,
                                    Class<T> clazz)
                                      throws SQLException

Call through to DaoManager.createDao(ConnectionSource, Class) with the returned DAO wrapped in a PersistenceDao.

Throws:

SQLException

createDao

public static <T,ID> PersistenceDao<T,ID> createDao(com.j256.ormlite.support.ConnectionSource connectionSource,
                                    com.j256.ormlite.table.DatabaseTableConfig<T> tableConfig)
                                      throws SQLException

Call through to DaoManager.createDao(ConnectionSource, DatabaseTableConfig) with the returned DAO wrapped in a PersistenceDao.

Throws:

SQLException

queryForId

public T queryForId(ID id)

See Also:

Dao.queryForId(Object)

queryForFirst

public T queryForFirst(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery)

See Also:

Dao.queryForFirst(PreparedQuery)

queryForAll

public List<T> queryForAll()

See Also:

Dao.queryForAll()

queryForEq

public List<T> queryForEq(String fieldName,
                 Object value)

See Also:

Dao.queryForEq(String, Object)

queryForMatching

public List<T> queryForMatching(T matchObj)

See Also:

Dao.queryForMatching(Object)

queryForMatchingArgs

public List<T> queryForMatchingArgs(T matchObj)

See Also:

Dao.queryForMatchingArgs(Object)

queryForFieldValues

public List<T> queryForFieldValues(Map<String,Object> fieldValues)

See Also:

Dao.queryForFieldValues(Map)

queryForFieldValuesArgs

public List<T> queryForFieldValuesArgs(Map<String,Object> fieldValues)

See Also:

Dao.queryForFieldValuesArgs(Map)

queryForSameId

public T queryForSameId(T data)

See Also:

Dao.queryForSameId(Object)

queryBuilder

public com.j256.ormlite.stmt.QueryBuilder<T,ID> queryBuilder()

See Also:

Dao.queryBuilder()

updateBuilder

public com.j256.ormlite.stmt.UpdateBuilder<T,ID> updateBuilder()

See Also:

Dao.updateBuilder()

deleteBuilder

public com.j256.ormlite.stmt.DeleteBuilder<T,ID> deleteBuilder()

See Also:

Dao.deleteBuilder()

query

public List<T> query(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery)

See Also:

Dao.query(PreparedQuery)

create

public int create(T data)

See Also:

Dao.create(Object)

create

public int create(Collection<T> datas)

createIfNotExists

public T createIfNotExists(T data)

See Also:

Dao.createIfNotExists(Object)

createOrUpdate

public com.j256.ormlite.dao.Dao.CreateOrUpdateStatus createOrUpdate(T data)

See Also:

Dao.createOrUpdate(Object)

update

public int update(T data)

See Also:

Dao.update(Object)

updateId

public int updateId(T data,
           ID newId)

See Also:

Dao.updateId(Object, Object)

update

public int update(com.j256.ormlite.stmt.PreparedUpdate<T> preparedUpdate)

See Also:

Dao.update(PreparedUpdate)

refresh

public int refresh(T data)

See Also:

Dao.refresh(Object)

delete

public int delete(T data)

See Also:

Dao.delete(Object)

deleteById

public int deleteById(ID id)

See Also:

Dao.deleteById(Object)

delete

public int delete(Collection<T> datas)

See Also:

Dao.delete(Collection)

deleteIds

public int deleteIds(Collection<ID> ids)

See Also:

Dao.deleteIds(Collection)

delete

public int delete(com.j256.ormlite.stmt.PreparedDelete<T> preparedDelete)

See Also:

Dao.delete(PreparedDelete)

iterator

public com.j256.ormlite.dao.CloseableIterator<T> iterator()

Specified by:

iterator in interface Iterable<T>

See Also:

Dao.iterator()

closeableIterator

public com.j256.ormlite.dao.CloseableIterator<T> closeableIterator()

Specified by:

closeableIterator in interface com.j256.ormlite.dao.CloseableIterable<T>

iterator

public com.j256.ormlite.dao.CloseableIterator<T> iterator(int resultFlags)

See Also:

Dao.iterator(int)

getWrappedIterable

public com.j256.ormlite.dao.CloseableWrappedIterable<T> getWrappedIterable()

See Also:

Dao.getWrappedIterable()

getWrappedIterable

public com.j256.ormlite.dao.CloseableWrappedIterable<T> getWrappedIterable(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery)

See Also:

Dao.getWrappedIterable(PreparedQuery)

closeLastIterator

public void closeLastIterator()

See Also:

Dao.closeLastIterator()

iterator

public com.j256.ormlite.dao.CloseableIterator<T> iterator(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery)

See Also:

Dao.iterator(PreparedQuery)

iterator

public com.j256.ormlite.dao.CloseableIterator<T> iterator(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery,
                                                 int resultFlags)

See Also:

Dao.iterator(PreparedQuery, int)

queryRaw

public com.j256.ormlite.dao.GenericRawResults<String[]> queryRaw(String query,
                                                        String... arguments)

See Also:

Dao.queryRaw(String, String...)

queryRaw

public <UO> com.j256.ormlite.dao.GenericRawResults<UO> queryRaw(String query,
                                                       com.j256.ormlite.dao.DatabaseResultsMapper<UO> mapper,
                                                       String... arguments)

See Also:

Dao.queryRaw(String, DatabaseResultsMapper, String...)

queryRawValue

public long queryRawValue(String query,
                 String... arguments)

See Also:

Dao.queryRawValue(String, String...)

queryRaw

public <UO> com.j256.ormlite.dao.GenericRawResults<UO> queryRaw(String query,
                                                       com.j256.ormlite.dao.RawRowMapper<UO> mapper,
                                                       String... arguments)

See Also:

Dao.queryRaw(String, RawRowMapper, String...)

queryRaw

public <UO> com.j256.ormlite.dao.GenericRawResults<UO> queryRaw(String query,
                                                       com.j256.ormlite.field.DataType[] columnTypes,
                                                       com.j256.ormlite.dao.RawRowObjectMapper<UO> mapper,
                                                       String... arguments)

See Also:

Dao.queryRaw(String, DataType[], RawRowObjectMapper, String...)

queryRaw

public com.j256.ormlite.dao.GenericRawResults<Object[]> queryRaw(String query,
                                                        com.j256.ormlite.field.DataType[] columnTypes,
                                                        String... arguments)

See Also:

Dao.queryRaw(String, DataType[], String...)

executeRaw

public int executeRaw(String statement,
             String... arguments)

See Also:

Dao.executeRaw(String, String...)

executeRawNoArgs

public int executeRawNoArgs(String statement)

See Also:

Dao.executeRawNoArgs(String)

updateRaw

public int updateRaw(String statement,
            String... arguments)

See Also:

Dao.updateRaw(String, String...)

callBatchTasks

public <CT> CT callBatchTasks(Callable<CT> callable)

See Also:

Dao.callBatchTasks(Callable)

objectToString

public String objectToString(T data)

See Also:

Dao.objectToString(Object)

objectsEqual

public boolean objectsEqual(T data1,
                   T data2)

See Also:

Dao.objectsEqual(Object, Object)

extractId

public ID extractId(T data)

See Also:

Dao.extractId(Object)

getDataClass

public Class<T> getDataClass()

See Also:

Dao.getDataClass()

findForeignFieldType

public com.j256.ormlite.field.FieldType findForeignFieldType(Class<?> clazz)

See Also:

Dao.findForeignFieldType(Class)

isUpdatable

public boolean isUpdatable()

See Also:

Dao.isUpdatable()

isTableExists

public boolean isTableExists()

See Also:

Dao.isTableExists()

countOf

public long countOf()

See Also:

Dao.countOf()

countOf

public long countOf(com.j256.ormlite.stmt.PreparedQuery<T> preparedQuery)

See Also:

Dao.countOf(PreparedQuery)

assignEmptyForeignCollection

public void assignEmptyForeignCollection(T parent,
                                String fieldName)

See Also:

Dao.assignEmptyForeignCollection(Object, String)

getEmptyForeignCollection

public <FT> com.j256.ormlite.dao.ForeignCollection<FT> getEmptyForeignCollection(String fieldName)

See Also:

Dao.getEmptyForeignCollection(String)

setObjectCache

public void setObjectCache(boolean enabled)

See Also:

Dao.setObjectCache(boolean)

getObjectCache

public com.j256.ormlite.dao.ObjectCache getObjectCache()

See Also:

Dao.getObjectCache()

setObjectCache

public void setObjectCache(com.j256.ormlite.dao.ObjectCache objectCache)

See Also:

Dao.setObjectCache(ObjectCache)

clearObjectCache

public void clearObjectCache()

See Also:

Dao.clearObjectCache()

mapSelectStarRow

public T mapSelectStarRow(com.j256.ormlite.support.DatabaseResults results)

See Also:

Dao.mapSelectStarRow(DatabaseResults)

getSelectStarRowMapper

public com.j256.ormlite.stmt.GenericRowMapper<T> getSelectStarRowMapper()

See Also:

Dao.getSelectStarRowMapper()

idExists

public boolean idExists(ID id)

See Also:

Dao.idExists(Object)

startThreadConnection

public com.j256.ormlite.support.DatabaseConnection startThreadConnection()

See Also:

Dao.startThreadConnection()

endThreadConnection

public void endThreadConnection(com.j256.ormlite.support.DatabaseConnection connection)

See Also:

Dao.endThreadConnection(DatabaseConnection)

setAutoCommit

@Deprecated
public void setAutoCommit(boolean autoCommit)

Deprecated.

See Also:

Dao.setAutoCommit(boolean)

setAutoCommit

public void setAutoCommit(com.j256.ormlite.support.DatabaseConnection connection,
                 boolean autoCommit)

See Also:

Dao.setAutoCommit(DatabaseConnection, boolean)

isAutoCommit

@Deprecated
public boolean isAutoCommit()

Deprecated.

See Also:

Dao.isAutoCommit()

isAutoCommit

public boolean isAutoCommit(com.j256.ormlite.support.DatabaseConnection connection)

See Also:

Dao.isAutoCommit(DatabaseConnection)

commit

public void commit(com.j256.ormlite.support.DatabaseConnection connection)

See Also:

Dao.commit(DatabaseConnection)

rollBack

public void rollBack(com.j256.ormlite.support.DatabaseConnection connection)

See Also:

Dao.rollBack(DatabaseConnection)

setObjectFactory

public void setObjectFactory(com.j256.ormlite.table.ObjectFactory<T> objectFactory)

See Also:

Dao.setObjectFactory(ObjectFactory)

getRawRowMapper

public com.j256.ormlite.dao.RawRowMapper<T> getRawRowMapper()

See Also:

Dao.getRawRowMapper()

getConnectionSource

public com.j256.ormlite.support.ConnectionSource getConnectionSource()

See Also:

Dao.getConnectionSource()

registerObserver

public void registerObserver(com.j256.ormlite.dao.Dao.DaoObserver observer)

unregisterObserver

public void unregisterObserver(com.j256.ormlite.dao.Dao.DaoObserver observer)

notifyChanges

public void notifyChanges()