com.ibatis.sqlmap.engine.impl
Class SqlMapExecutorDelegate

java.lang.Object
  extended bycom.ibatis.sqlmap.engine.impl.SqlMapExecutorDelegate

public class SqlMapExecutorDelegate
extends java.lang.Object


Field Summary
private  java.util.HashMap cacheModels
           
private  boolean cacheModelsEnabled
           
private  DataExchangeFactory dataExchangeFactory
           
static int DEFAULT_MAX_REQUESTS
           
static int DEFAULT_MAX_SESSIONS
           
static int DEFAULT_MAX_TRANSACTIONS
           
private  boolean enhancementEnabled
           
private  boolean lazyLoadingEnabled
           
private  java.util.HashMap mappedStatements
           
private  int maxRequests
           
private  int maxSessions
           
private  int maxTransactions
           
private  java.util.HashMap parameterMaps
           
private static Probe PROBE
           
private  ThrottledPool requestPool
           
private  java.util.HashMap resultMaps
           
private  ThrottledPool sessionPool
           
private  SqlExecutor sqlExecutor
           
private  TransactionManager txManager
           
private  TypeHandlerFactory typeHandlerFactory
           
 
Constructor Summary
SqlMapExecutorDelegate()
           
 
Method Summary
 void addCacheModel(CacheModel model)
           
 void addMappedStatement(MappedStatement ms)
           
 void addParameterMap(ParameterMap map)
           
 void addResultMap(ResultMap map)
           
private  void autoCommitTransaction(SessionScope session, boolean autoStart)
           
private  void autoEndTransaction(SessionScope session, boolean autoStart)
           
private  Transaction autoStartTransaction(SessionScope session, boolean autoStart, Transaction trans)
           
 void commitTransaction(SessionScope session)
           
 int delete(SessionScope session, java.lang.String id, java.lang.Object param)
           
 void endTransaction(SessionScope session)
           
 boolean equals(java.lang.Object obj)
           
 int executeBatch(SessionScope session)
           
private  java.lang.Object executeSelectKey(SessionScope session, Transaction trans, MappedStatement ms, java.lang.Object param)
           
 void flushDataCache()
           
 void flushDataCache(java.lang.String id)
           
 CacheModel getCacheModel(java.lang.String id)
           
 java.util.Iterator getCacheModelNames()
           
 DataExchangeFactory getDataExchangeFactory()
           
 javax.sql.DataSource getDataSource()
           
 MappedStatement getMappedStatement(java.lang.String id)
           
 java.util.Iterator getMappedStatementNames()
           
 int getMaxRequests()
           
 int getMaxSessions()
           
 int getMaxTransactions()
           
 ParameterMap getParameterMap(java.lang.String id)
           
 java.util.Iterator getParameterMapNames()
           
 ResultMap getResultMap(java.lang.String id)
           
 java.util.Iterator getResultMapNames()
           
 SqlExecutor getSqlExecutor()
           
 Transaction getTransaction(SessionScope session)
           
 TransactionManager getTxManager()
           
 TypeHandlerFactory getTypeHandlerFactory()
           
 int hashCode()
           
 java.lang.Object insert(SessionScope session, java.lang.String id, java.lang.Object param)
           
 boolean isCacheModelsEnabled()
           
 boolean isEnhancementEnabled()
           
 boolean isLazyLoadingEnabled()
           
protected  RequestScope popRequest(SessionScope session, MappedStatement mappedStatement)
           
protected  SessionScope popSession()
           
protected  void pushRequest(RequestScope request)
           
protected  void pushSession(SessionScope session)
           
 java.util.List queryForList(SessionScope session, java.lang.String id, java.lang.Object paramObject)
           
 java.util.List queryForList(SessionScope session, java.lang.String id, java.lang.Object paramObject, int skip, int max)
           
 java.util.Map queryForMap(SessionScope session, java.lang.String id, java.lang.Object paramObject, java.lang.String keyProp)
           
 java.util.Map queryForMap(SessionScope session, java.lang.String id, java.lang.Object paramObject, java.lang.String keyProp, java.lang.String valueProp)
           
 java.lang.Object queryForObject(SessionScope session, java.lang.String id, java.lang.Object paramObject)
           
 java.lang.Object queryForObject(SessionScope session, java.lang.String id, java.lang.Object paramObject, java.lang.Object resultObject)
           
 PaginatedList queryForPaginatedList(SessionScope session, java.lang.String id, java.lang.Object paramObject, int pageSize)
           
 void queryWithRowHandler(SessionScope session, java.lang.String id, java.lang.Object paramObject, RowHandler rowHandler)
           
 void setCacheModelsEnabled(boolean cacheModelsEnabled)
           
 void setEnhancementEnabled(boolean enhancementEnabled)
           
 void setLazyLoadingEnabled(boolean lazyLoadingEnabled)
           
 void setMaxRequests(int maxRequests)
           
 void setMaxSessions(int maxSessions)
           
 void setMaxTransactions(int maxTransactions)
           
 void setTxManager(TransactionManager txManager)
           
 void setUserProvidedTransaction(SessionScope session, java.sql.Connection userConnection)
           
 void startBatch(SessionScope session)
           
 void startTransaction(SessionScope session)
           
 int update(SessionScope session, java.lang.String id, java.lang.Object param)
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

PROBE

private static final Probe PROBE

DEFAULT_MAX_REQUESTS

public static final int DEFAULT_MAX_REQUESTS
See Also:
Constant Field Values

DEFAULT_MAX_SESSIONS

public static final int DEFAULT_MAX_SESSIONS
See Also:
Constant Field Values

DEFAULT_MAX_TRANSACTIONS

public static final int DEFAULT_MAX_TRANSACTIONS
See Also:
Constant Field Values

lazyLoadingEnabled

private boolean lazyLoadingEnabled

cacheModelsEnabled

private boolean cacheModelsEnabled

enhancementEnabled

private boolean enhancementEnabled

maxRequests

private int maxRequests

maxSessions

private int maxSessions

maxTransactions

private int maxTransactions

txManager

private TransactionManager txManager

mappedStatements

private java.util.HashMap mappedStatements

cacheModels

private java.util.HashMap cacheModels

resultMaps

private java.util.HashMap resultMaps

parameterMaps

private java.util.HashMap parameterMaps

requestPool

private ThrottledPool requestPool

sessionPool

private ThrottledPool sessionPool

sqlExecutor

private SqlExecutor sqlExecutor

typeHandlerFactory

private TypeHandlerFactory typeHandlerFactory

dataExchangeFactory

private DataExchangeFactory dataExchangeFactory
Constructor Detail

SqlMapExecutorDelegate

public SqlMapExecutorDelegate()
Method Detail

getDataExchangeFactory

public DataExchangeFactory getDataExchangeFactory()

getTypeHandlerFactory

public TypeHandlerFactory getTypeHandlerFactory()

isLazyLoadingEnabled

public boolean isLazyLoadingEnabled()

setLazyLoadingEnabled

public void setLazyLoadingEnabled(boolean lazyLoadingEnabled)

isCacheModelsEnabled

public boolean isCacheModelsEnabled()

setCacheModelsEnabled

public void setCacheModelsEnabled(boolean cacheModelsEnabled)

isEnhancementEnabled

public boolean isEnhancementEnabled()

setEnhancementEnabled

public void setEnhancementEnabled(boolean enhancementEnabled)

getMaxRequests

public int getMaxRequests()

setMaxRequests

public void setMaxRequests(int maxRequests)

getMaxSessions

public int getMaxSessions()

setMaxSessions

public void setMaxSessions(int maxSessions)

getMaxTransactions

public int getMaxTransactions()

setMaxTransactions

public void setMaxTransactions(int maxTransactions)

getTxManager

public TransactionManager getTxManager()

setTxManager

public void setTxManager(TransactionManager txManager)

addMappedStatement

public void addMappedStatement(MappedStatement ms)

getMappedStatementNames

public java.util.Iterator getMappedStatementNames()

getMappedStatement

public MappedStatement getMappedStatement(java.lang.String id)

addCacheModel

public void addCacheModel(CacheModel model)

getCacheModelNames

public java.util.Iterator getCacheModelNames()

getCacheModel

public CacheModel getCacheModel(java.lang.String id)

addResultMap

public void addResultMap(ResultMap map)

getResultMapNames

public java.util.Iterator getResultMapNames()

getResultMap

public ResultMap getResultMap(java.lang.String id)

addParameterMap

public void addParameterMap(ParameterMap map)

getParameterMapNames

public java.util.Iterator getParameterMapNames()

getParameterMap

public ParameterMap getParameterMap(java.lang.String id)

flushDataCache

public void flushDataCache()

flushDataCache

public void flushDataCache(java.lang.String id)

insert

public java.lang.Object insert(SessionScope session,
                               java.lang.String id,
                               java.lang.Object param)
                        throws java.sql.SQLException
Throws:
java.sql.SQLException

executeSelectKey

private java.lang.Object executeSelectKey(SessionScope session,
                                          Transaction trans,
                                          MappedStatement ms,
                                          java.lang.Object param)
                                   throws java.sql.SQLException
Throws:
java.sql.SQLException

update

public int update(SessionScope session,
                  java.lang.String id,
                  java.lang.Object param)
           throws java.sql.SQLException
Throws:
java.sql.SQLException

delete

public int delete(SessionScope session,
                  java.lang.String id,
                  java.lang.Object param)
           throws java.sql.SQLException
Throws:
java.sql.SQLException

queryForObject

public java.lang.Object queryForObject(SessionScope session,
                                       java.lang.String id,
                                       java.lang.Object paramObject)
                                throws java.sql.SQLException
Throws:
java.sql.SQLException

queryForObject

public java.lang.Object queryForObject(SessionScope session,
                                       java.lang.String id,
                                       java.lang.Object paramObject,
                                       java.lang.Object resultObject)
                                throws java.sql.SQLException
Throws:
java.sql.SQLException

queryForList

public java.util.List queryForList(SessionScope session,
                                   java.lang.String id,
                                   java.lang.Object paramObject)
                            throws java.sql.SQLException
Throws:
java.sql.SQLException

queryForList

public java.util.List queryForList(SessionScope session,
                                   java.lang.String id,
                                   java.lang.Object paramObject,
                                   int skip,
                                   int max)
                            throws java.sql.SQLException
Throws:
java.sql.SQLException

queryWithRowHandler

public void queryWithRowHandler(SessionScope session,
                                java.lang.String id,
                                java.lang.Object paramObject,
                                RowHandler rowHandler)
                         throws java.sql.SQLException
Throws:
java.sql.SQLException

queryForPaginatedList

public PaginatedList queryForPaginatedList(SessionScope session,
                                           java.lang.String id,
                                           java.lang.Object paramObject,
                                           int pageSize)
                                    throws java.sql.SQLException
Throws:
java.sql.SQLException

queryForMap

public java.util.Map queryForMap(SessionScope session,
                                 java.lang.String id,
                                 java.lang.Object paramObject,
                                 java.lang.String keyProp)
                          throws java.sql.SQLException
Throws:
java.sql.SQLException

queryForMap

public java.util.Map queryForMap(SessionScope session,
                                 java.lang.String id,
                                 java.lang.Object paramObject,
                                 java.lang.String keyProp,
                                 java.lang.String valueProp)
                          throws java.sql.SQLException
Throws:
java.sql.SQLException

startTransaction

public void startTransaction(SessionScope session)
                      throws java.sql.SQLException
Throws:
java.sql.SQLException

commitTransaction

public void commitTransaction(SessionScope session)
                       throws java.sql.SQLException
Throws:
java.sql.SQLException

endTransaction

public void endTransaction(SessionScope session)
                    throws java.sql.SQLException
Throws:
java.sql.SQLException

startBatch

public void startBatch(SessionScope session)
                throws java.sql.SQLException
Throws:
java.sql.SQLException

executeBatch

public int executeBatch(SessionScope session)
                 throws java.sql.SQLException
Throws:
java.sql.SQLException

setUserProvidedTransaction

public void setUserProvidedTransaction(SessionScope session,
                                       java.sql.Connection userConnection)

getDataSource

public javax.sql.DataSource getDataSource()

getSqlExecutor

public SqlExecutor getSqlExecutor()

getTransaction

public Transaction getTransaction(SessionScope session)

autoEndTransaction

private void autoEndTransaction(SessionScope session,
                                boolean autoStart)
                         throws java.sql.SQLException
Throws:
java.sql.SQLException

autoCommitTransaction

private void autoCommitTransaction(SessionScope session,
                                   boolean autoStart)
                            throws java.sql.SQLException
Throws:
java.sql.SQLException

autoStartTransaction

private Transaction autoStartTransaction(SessionScope session,
                                         boolean autoStart,
                                         Transaction trans)
                                  throws java.sql.SQLException
Throws:
java.sql.SQLException

equals

public boolean equals(java.lang.Object obj)

hashCode

public int hashCode()

popRequest

protected RequestScope popRequest(SessionScope session,
                                  MappedStatement mappedStatement)

pushRequest

protected void pushRequest(RequestScope request)

popSession

protected SessionScope popSession()

pushSession

protected void pushSession(SessionScope session)