|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.midao.jdbc.core.AsyncQueryRunner
public class AsyncQueryRunner
Base AsyncQueryRunnerService
implementation
Constructor Summary | |
---|---|
AsyncQueryRunner(QueryRunnerService runner,
java.util.concurrent.ExecutorService executorService)
Creates new AsyncQueryRunner instance |
Method Summary | ||
---|---|---|
java.util.concurrent.Future<int[]> |
batch(InputHandler[] inputHandlers)
|
|
java.util.concurrent.Future<int[]> |
batch(java.lang.String sql,
java.lang.Object[][] params)
|
|
|
call(AbstractNamedInputHandler<T> inputHandler)
|
|
|
call(AbstractNamedInputHandler<T> inputHandler,
java.lang.String catalog,
java.lang.String schema,
boolean useCache)
|
|
java.util.concurrent.Future<QueryParameters> |
call(AbstractQueryInputHandler inputHandler)
|
|
|
call(InputHandler<T> inputHandler,
OutputHandler<S> outputHandler)
|
|
|
call(InputHandler<T> inputHandler,
OutputHandler<S> outputHandler,
java.lang.String catalog,
java.lang.String schema,
boolean useCache)
|
|
void |
commit()
|
|
java.lang.Integer |
getTransactionIsolationLevel()
|
|
boolean |
isTransactionManualMode()
|
|
AsyncQueryRunnerService |
override(java.lang.String operation,
java.lang.Object value)
|
|
AsyncQueryRunnerService |
overrideOnce(java.lang.String operation,
java.lang.Object value)
|
|
|
query(InputHandler inputHandler,
OutputHandler<T> outputHandler)
|
|
|
query(java.lang.String sql,
OutputHandler<T> outputHandler)
|
|
|
query(java.lang.String sql,
OutputHandler<T> outputHandler,
java.lang.Object... params)
|
|
void |
releaseSavepoint(java.sql.Savepoint savepoint)
|
|
AsyncQueryRunnerService |
removeOverride(java.lang.String operation)
|
|
void |
rollback()
|
|
void |
rollback(java.sql.Savepoint savepoint)
|
|
java.sql.Savepoint |
setSavepoint()
|
|
java.sql.Savepoint |
setSavepoint(java.lang.String name)
|
|
void |
setTransactionIsolationLevel(java.lang.Integer level)
|
|
void |
setTransactionManualMode(boolean manualMode)
|
|
java.util.concurrent.Future<java.lang.Integer> |
update(InputHandler inputHandler)
|
|
|
update(InputHandler inputHandler,
OutputHandler<T> outputHandler)
|
|
java.util.concurrent.Future<java.lang.Integer> |
update(java.lang.String sql)
|
|
java.util.concurrent.Future<java.lang.Integer> |
update(java.lang.String sql,
java.lang.Object... params)
|
|
java.util.concurrent.Future<java.lang.Integer> |
update(java.lang.String sql,
java.lang.Object param)
|
|
|
update(java.lang.String sql,
OutputHandler<T> outputHandler,
java.lang.Object... params)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AsyncQueryRunner(QueryRunnerService runner, java.util.concurrent.ExecutorService executorService)
runner
- QueryRunnerService
implementationexecutorService
- ExecutorService
implementationMethod Detail |
---|
public java.util.concurrent.Future<int[]> batch(java.lang.String sql, java.lang.Object[][] params) throws java.sql.SQLException
batch
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.batch(String, Object[][])
public java.util.concurrent.Future<int[]> batch(InputHandler[] inputHandlers) throws java.sql.SQLException
batch
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.batch(org.midao.jdbc.core.handlers.input.InputHandler[])
public <T> java.util.concurrent.Future<T> query(java.lang.String sql, OutputHandler<T> outputHandler, java.lang.Object... params) throws java.sql.SQLException
query
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.query(String, org.midao.jdbc.core.handlers.output.OutputHandler, Object...)
public <T> java.util.concurrent.Future<T> query(InputHandler inputHandler, OutputHandler<T> outputHandler) throws java.sql.SQLException
query
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.query(org.midao.jdbc.core.handlers.input.InputHandler, org.midao.jdbc.core.handlers.output.OutputHandler)
public <T> java.util.concurrent.Future<T> query(java.lang.String sql, OutputHandler<T> outputHandler) throws java.sql.SQLException
query
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.query(String, org.midao.jdbc.core.handlers.output.OutputHandler)
public java.util.concurrent.Future<java.lang.Integer> update(java.lang.String sql) throws java.sql.SQLException
update
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.update(String)
public java.util.concurrent.Future<java.lang.Integer> update(java.lang.String sql, java.lang.Object param) throws java.sql.SQLException
update
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.update(String, Object)
public java.util.concurrent.Future<java.lang.Integer> update(java.lang.String sql, java.lang.Object... params) throws java.sql.SQLException
update
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.update(String, Object...)
public java.util.concurrent.Future<java.lang.Integer> update(InputHandler inputHandler) throws java.sql.SQLException
update
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.update(org.midao.jdbc.core.handlers.input.InputHandler)
public <T> java.util.concurrent.Future<T> update(InputHandler inputHandler, OutputHandler<T> outputHandler) throws java.sql.SQLException
update
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.update(org.midao.jdbc.core.handlers.input.InputHandler, org.midao.jdbc.core.handlers.output.OutputHandler)
public <T> java.util.concurrent.Future<T> update(java.lang.String sql, OutputHandler<T> outputHandler, java.lang.Object... params) throws java.sql.SQLException
update
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.update(String, org.midao.jdbc.core.handlers.output.OutputHandler, Object...)
public java.util.concurrent.Future<QueryParameters> call(AbstractQueryInputHandler inputHandler) throws java.sql.SQLException
call
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.query.AbstractQueryInputHandler)
public <T> java.util.concurrent.Future<T> call(AbstractNamedInputHandler<T> inputHandler, java.lang.String catalog, java.lang.String schema, boolean useCache) throws java.sql.SQLException
call
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.named.AbstractNamedInputHandler, String, String, boolean)
public <T> java.util.concurrent.Future<T> call(AbstractNamedInputHandler<T> inputHandler) throws java.sql.SQLException
call
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.named.AbstractNamedInputHandler)
public <T,S> java.util.concurrent.Future<CallResults<T,S>> call(InputHandler<T> inputHandler, OutputHandler<S> outputHandler) throws java.sql.SQLException
call
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.InputHandler, org.midao.jdbc.core.handlers.output.OutputHandler)
public <T,S> java.util.concurrent.Future<CallResults<T,S>> call(InputHandler<T> inputHandler, OutputHandler<S> outputHandler, java.lang.String catalog, java.lang.String schema, boolean useCache) throws java.sql.SQLException
call
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.InputHandler, org.midao.jdbc.core.handlers.output.OutputHandler, String, String, boolean)
public void setTransactionManualMode(boolean manualMode)
setTransactionManualMode
in interface AsyncQueryRunnerService
QueryRunnerService.setTransactionManualMode(boolean)
public boolean isTransactionManualMode()
isTransactionManualMode
in interface AsyncQueryRunnerService
QueryRunnerService.isTransactionManualMode()
public void setTransactionIsolationLevel(java.lang.Integer level)
setTransactionIsolationLevel
in interface AsyncQueryRunnerService
QueryRunnerService.setTransactionIsolationLevel(Integer)
public java.lang.Integer getTransactionIsolationLevel()
getTransactionIsolationLevel
in interface AsyncQueryRunnerService
QueryRunnerService.getTransactionIsolationLevel()
public void commit() throws java.sql.SQLException
commit
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.commit()
public void rollback() throws java.sql.SQLException
rollback
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.rollback()
public java.sql.Savepoint setSavepoint() throws java.sql.SQLException
setSavepoint
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.setSavepoint()
public java.sql.Savepoint setSavepoint(java.lang.String name) throws java.sql.SQLException
setSavepoint
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.setSavepoint(String)
public void rollback(java.sql.Savepoint savepoint) throws java.sql.SQLException
rollback
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.rollback(java.sql.Savepoint)
public void releaseSavepoint(java.sql.Savepoint savepoint) throws java.sql.SQLException
releaseSavepoint
in interface AsyncQueryRunnerService
java.sql.SQLException
QueryRunnerService.releaseSavepoint(java.sql.Savepoint)
public AsyncQueryRunnerService overrideOnce(java.lang.String operation, java.lang.Object value)
overrideOnce
in interface AsyncQueryRunnerService
QueryRunnerService.overrideOnce(String, Object)
public AsyncQueryRunnerService override(java.lang.String operation, java.lang.Object value)
override
in interface AsyncQueryRunnerService
QueryRunnerService.override(String, Object)
public AsyncQueryRunnerService removeOverride(java.lang.String operation)
removeOverride
in interface AsyncQueryRunnerService
QueryRunnerService.removeOverride(String)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |