Module com.appslandia.common

Package com.appslandia.common.record

Class DbContext

java.lang.Object

com.appslandia.common.record.DbContext

All Implemented Interfaces:

AutoCloseable

public class DbContext
extends Object
implements AutoCloseable

Author:

Loc Ha

Constructor Summary

Constructors

Constructor	Description
DbContext()
DbContext(DataSource dataSource)

Method Summary

Modifier and Type	Method	Description
protected void	assertNotClosed()
protected void	assertTransactional()
void	close()
void	commit()
int	delete(Record key, Table table)
protected int	delete(Record key, Table table, boolean addBatch)
void	deleteBatch(Record key, Table table)
void	executeBatch()
boolean	executeExists(String sql)
boolean	executeExists(String pSql, Object... params)
boolean	executeExists(String pSql, Map<String,Object> params)
List<Record>	executeList(String sql)
<T> List<T>	executeList(String sql, ResultSetMapper<T> mapper)
<T> List<T>	executeList(String sql, ResultSetMapper<T> mapper, List<T> list)
<T> List<Record>	executeList(String pSql, Object... params)
<T> List<T>	executeList(String pSql, Object[] params, ResultSetMapper<T> mapper)
<T> List<T>	executeList(String pSql, Object[] params, ResultSetMapper<T> mapper, List<T> list)
<T> List<Record>	executeList(String pSql, Map<String,Object> params)
<T> List<T>	executeList(String pSql, Map<String,Object> params, ResultSetMapper<T> mapper)
<T> List<T>	executeList(String pSql, Map<String,Object> params, ResultSetMapper<T> mapper, List<T> list)
<K,V> Map<K,V>	executeMap(String sql, ResultSetMapper<K> keyMapper, ResultSetMapper<V> valueMapper)
<K,V> Map<K,V>	executeMap(String sql, ResultSetMapper<K> keyMapper, ResultSetMapper<V> valueMapper, Map<K,V> map)
<K,V> Map<K,V>	executeMap(String pSql, Object[] params, ResultSetMapper<K> keyMapper, ResultSetMapper<V> valueMapper)
<K,V> Map<K,V>	executeMap(String pSql, Object[] params, ResultSetMapper<K> keyMapper, ResultSetMapper<V> valueMapper, Map<K,V> map)
<K,V> Map<K,V>	executeMap(String pSql, Object[] params, String keyColumn, String valueColumn)
<K,V> Map<K,V>	executeMap(String pSql, Object[] params, String keyColumn, String valueColumn, Map<K,V> map)
<K,V> Map<K,V>	executeMap(String sql, String keyColumn, String valueColumn)
<K,V> Map<K,V>	executeMap(String sql, String keyColumn, String valueColumn, Map<K,V> map)
<K,V> Map<K,V>	executeMap(String pSql, Map<String,Object> params, ResultSetMapper<K> keyMapper, ResultSetMapper<V> valueMapper)
<K,V> Map<K,V>	executeMap(String pSql, Map<String,Object> params, ResultSetMapper<K> keyMapper, ResultSetMapper<V> valueMapper, Map<K,V> map)
<K,V> Map<K,V>	executeMap(String pSql, Map<String,Object> params, String keyColumn, String valueColumn)
<K,V> Map<K,V>	executeMap(String pSql, Map<String,Object> params, String keyColumn, String valueColumn, Map<K,V> map)
void	executeQuery(String sql, ResultSetHandler handler)
void	executeQuery(String pSql, Object[] params, ResultSetHandler handler)
void	executeQuery(String pSql, Map<String,Object> params, ResultSetHandler handler)
<T> T	executeScalar(String sql)
<T> T	executeScalar(String pSql, Object... params)
<T> T	executeScalar(String pSql, Map<String,Object> params)
Record	executeSingle(String sql)
<T> T	executeSingle(String sql, ResultSetMapper<T> mapper)
Record	executeSingle(String pSql, Object... params)
<T> T	executeSingle(String pSql, Object[] params, ResultSetMapper<T> mapper)
Record	executeSingle(String pSql, Map<String,Object> params)
<T> T	executeSingle(String pSql, Map<String,Object> params, ResultSetMapper<T> mapper)
int	executeUpdate(String sql)
int	executeUpdate(String pSql, Object... params)
int	executeUpdate(String pSql, Map<String,Object> params)
boolean	exists(Record key, Table table)
Connection	getConnection()
static DataSource	getDataSource()
Record	getRecord(Record key, Table table)
Object	insert(Record record, Table table)
protected Object	insert(Record record, Table table, boolean addBatch)
void	insertBatch(Record record, Table table)
boolean	isTransactional()
void	rollback()
static void	setDataSource(DataSource ds)
protected void	setParameter(StatementImpl stat, String parameterName, Object val, int sqlType)
void	setTransactional()
int	update(Record record, Table table)
protected int	update(Record record, Table table, boolean addBatch)
void	updateBatch(Record record, Table table)

Methods inherited from class java.lang.Object

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

Constructor Detail

DbContext

public DbContext()
          throws SQLException

Throws:

SQLException

DbContext

public DbContext(DataSource dataSource)
          throws SQLException

Throws:

SQLException

Method Detail

getConnection

public Connection getConnection()
                         throws SQLException

Throws:

SQLException

setParameter

protected void setParameter(StatementImpl stat,
                            String parameterName,
                            Object val,
                            int sqlType)
                     throws SQLException

Throws:

SQLException

insert

public Object insert(Record record,
                     Table table)
              throws SQLException

Throws:

SQLException

insertBatch

public void insertBatch(Record record,
                        Table table)
                 throws SQLException

Throws:

SQLException

insert

protected Object insert(Record record,
                        Table table,
                        boolean addBatch)
                 throws SQLException

Throws:

SQLException

update

public int update(Record record,
                  Table table)
           throws SQLException

Throws:

SQLException

updateBatch

public void updateBatch(Record record,
                        Table table)
                 throws SQLException

Throws:

SQLException

update

protected int update(Record record,
                     Table table,
                     boolean addBatch)
              throws SQLException

Throws:

SQLException

delete

public int delete(Record key,
                  Table table)
           throws SQLException

Throws:

SQLException

deleteBatch

public void deleteBatch(Record key,
                        Table table)
                 throws SQLException

Throws:

SQLException

delete

protected int delete(Record key,
                     Table table,
                     boolean addBatch)
              throws SQLException

Throws:

SQLException

getRecord

public Record getRecord(Record key,
                        Table table)
                 throws SQLException

Throws:

SQLException

exists

public boolean exists(Record key,
                      Table table)
               throws SQLException

Throws:

SQLException

executeList

public List<Record> executeList(String sql)
                         throws SQLException

Throws:

SQLException

executeList

public <T> List<Record> executeList(String pSql,
                                    Object... params)
                             throws SQLException

Throws:

SQLException

executeList

public <T> List<Record> executeList(String pSql,
                                    Map<String,Object> params)
                             throws SQLException

Throws:

SQLException

executeSingle

public Record executeSingle(String sql)
                     throws SQLException

Throws:

SQLException

executeSingle

public Record executeSingle(String pSql,
                            Object... params)
                     throws SQLException

Throws:

SQLException

executeSingle

public Record executeSingle(String pSql,
                            Map<String,Object> params)
                     throws SQLException

Throws:

SQLException

executeUpdate

public int executeUpdate(String sql)
                  throws SQLException

Throws:

SQLException

executeUpdate

public int executeUpdate(String pSql,
                         Object... params)
                  throws SQLException

Throws:

SQLException

executeUpdate

public int executeUpdate(String pSql,
                         Map<String,Object> params)
                  throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String sql,
                                             ResultSetMapper<K> keyMapper,
                                             ResultSetMapper<V> valueMapper)
                                      throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String sql,
                                             ResultSetMapper<K> keyMapper,
                                             ResultSetMapper<V> valueMapper,
                                             Map<K,V> map)
                                      throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String pSql,
                                             Object[] params,
                                             ResultSetMapper<K> keyMapper,
                                             ResultSetMapper<V> valueMapper)
                                      throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String pSql,
                                             Map<String,Object> params,
                                             ResultSetMapper<K> keyMapper,
                                             ResultSetMapper<V> valueMapper)
                                      throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String pSql,
                                             Object[] params,
                                             ResultSetMapper<K> keyMapper,
                                             ResultSetMapper<V> valueMapper,
                                             Map<K,V> map)
                                      throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String pSql,
                                             Map<String,Object> params,
                                             ResultSetMapper<K> keyMapper,
                                             ResultSetMapper<V> valueMapper,
                                             Map<K,V> map)
                                      throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String sql,
                                             String keyColumn,
                                             String valueColumn)
                                      throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String sql,
                                             String keyColumn,
                                             String valueColumn,
                                             Map<K,V> map)
                                      throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String pSql,
                                             Object[] params,
                                             String keyColumn,
                                             String valueColumn)
                                      throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String pSql,
                                             Map<String,Object> params,
                                             String keyColumn,
                                             String valueColumn)
                                      throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String pSql,
                                             Object[] params,
                                             String keyColumn,
                                             String valueColumn,
                                             Map<K,V> map)
                                      throws SQLException

Throws:

SQLException

executeMap

public <K,V> Map<K,V> executeMap(String pSql,
                                             Map<String,Object> params,
                                             String keyColumn,
                                             String valueColumn,
                                             Map<K,V> map)
                                      throws SQLException

Throws:

SQLException

executeList

public <T> List<T> executeList(String sql,
                               ResultSetMapper<T> mapper)
                        throws SQLException

Throws:

SQLException

executeList

public <T> List<T> executeList(String sql,
                               ResultSetMapper<T> mapper,
                               List<T> list)
                        throws SQLException

Throws:

SQLException

executeList

public <T> List<T> executeList(String pSql,
                               Object[] params,
                               ResultSetMapper<T> mapper)
                        throws SQLException

Throws:

SQLException

executeList

public <T> List<T> executeList(String pSql,
                               Map<String,Object> params,
                               ResultSetMapper<T> mapper)
                        throws SQLException

Throws:

SQLException

executeList

public <T> List<T> executeList(String pSql,
                               Object[] params,
                               ResultSetMapper<T> mapper,
                               List<T> list)
                        throws SQLException

Throws:

SQLException

executeList

public <T> List<T> executeList(String pSql,
                               Map<String,Object> params,
                               ResultSetMapper<T> mapper,
                               List<T> list)
                        throws SQLException

Throws:

SQLException

executeSingle

public <T> T executeSingle(String sql,
                           ResultSetMapper<T> mapper)
                    throws SQLException

Throws:

SQLException

executeSingle

public <T> T executeSingle(String pSql,
                           Object[] params,
                           ResultSetMapper<T> mapper)
                    throws SQLException

Throws:

SQLException

executeSingle

public <T> T executeSingle(String pSql,
                           Map<String,Object> params,
                           ResultSetMapper<T> mapper)
                    throws SQLException

Throws:

SQLException

executeScalar

public <T> T executeScalar(String sql)
                    throws SQLException

Throws:

SQLException

executeScalar

public <T> T executeScalar(String pSql,
                           Object... params)
                    throws SQLException

Throws:

SQLException

executeScalar

public <T> T executeScalar(String pSql,
                           Map<String,Object> params)
                    throws SQLException

Throws:

SQLException

executeExists

public boolean executeExists(String sql)
                      throws SQLException

Throws:

SQLException

executeExists

public boolean executeExists(String pSql,
                             Object... params)
                      throws SQLException

Throws:

SQLException

executeExists

public boolean executeExists(String pSql,
                             Map<String,Object> params)
                      throws SQLException

Throws:

SQLException

executeQuery

public void executeQuery(String sql,
                         ResultSetHandler handler)
                  throws Exception

Throws:

Exception

executeQuery

public void executeQuery(String pSql,
                         Object[] params,
                         ResultSetHandler handler)
                  throws Exception

Throws:

Exception

executeQuery

public void executeQuery(String pSql,
                         Map<String,Object> params,
                         ResultSetHandler handler)
                  throws Exception

Throws:

Exception

executeBatch

public void executeBatch()
                  throws SQLException

Throws:

SQLException

setTransactional

public void setTransactional()
                      throws SQLException

Throws:

SQLException

isTransactional

public boolean isTransactional()
                        throws SQLException

Throws:

SQLException

commit

public void commit()
            throws SQLException

Throws:

SQLException

rollback

public void rollback()
              throws SQLException

Throws:

SQLException

assertTransactional

protected void assertTransactional()
                            throws SQLException

Throws:

SQLException

assertNotClosed

protected void assertNotClosed()
                        throws SQLException

Throws:

SQLException

close

public void close()
           throws SQLException

Specified by:

close in interface AutoCloseable

Throws:

SQLException

getDataSource

public static DataSource getDataSource()
                                throws IllegalStateException

Throws:

IllegalStateException

setDataSource

public static void setDataSource(DataSource ds)