org.midao.jdbc.core
Class AsyncQueryRunner

java.lang.Object
  extended by org.midao.jdbc.core.AsyncQueryRunner
All Implemented Interfaces:
AsyncQueryRunnerService

public class AsyncQueryRunner
extends java.lang.Object
implements AsyncQueryRunnerService

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)
          
<T> java.util.concurrent.Future<T>
call(AbstractNamedInputHandler<T> inputHandler)
          
<T> java.util.concurrent.Future<T>
call(AbstractNamedInputHandler<T> inputHandler, java.lang.String catalog, java.lang.String schema, boolean useCache)
          
 java.util.concurrent.Future<QueryParameters> call(AbstractQueryInputHandler inputHandler)
          
<T,S> java.util.concurrent.Future<CallResults<T,S>>
call(InputHandler<T> inputHandler, OutputHandler<S> outputHandler)
          
<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)
          
 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)
          
<T> java.util.concurrent.Future<T>
query(InputHandler inputHandler, OutputHandler<T> outputHandler)
          
<T> java.util.concurrent.Future<T>
query(java.lang.String sql, OutputHandler<T> outputHandler)
          
<T> java.util.concurrent.Future<T>
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)
          
<T> java.util.concurrent.Future<T>
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)
          
<T> java.util.concurrent.Future<T>
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

AsyncQueryRunner

public AsyncQueryRunner(QueryRunnerService runner,
                        java.util.concurrent.ExecutorService executorService)
Creates new AsyncQueryRunner instance

Parameters:
runner - QueryRunnerService implementation
executorService - ExecutorService implementation
Method Detail

batch

public java.util.concurrent.Future<int[]> batch(java.lang.String sql,
                                                java.lang.Object[][] params)
                                         throws java.sql.SQLException

Specified by:
batch in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.batch(String, Object[][])

batch

public java.util.concurrent.Future<int[]> batch(InputHandler[] inputHandlers)
                                         throws java.sql.SQLException

Specified by:
batch in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.batch(org.midao.jdbc.core.handlers.input.InputHandler[])

query

public <T> java.util.concurrent.Future<T> query(java.lang.String sql,
                                                OutputHandler<T> outputHandler,
                                                java.lang.Object... params)
                                     throws java.sql.SQLException

Specified by:
query in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.query(String, org.midao.jdbc.core.handlers.output.OutputHandler, Object...)

query

public <T> java.util.concurrent.Future<T> query(InputHandler inputHandler,
                                                OutputHandler<T> outputHandler)
                                     throws java.sql.SQLException

Specified by:
query in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.query(org.midao.jdbc.core.handlers.input.InputHandler, org.midao.jdbc.core.handlers.output.OutputHandler)

query

public <T> java.util.concurrent.Future<T> query(java.lang.String sql,
                                                OutputHandler<T> outputHandler)
                                     throws java.sql.SQLException

Specified by:
query in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.query(String, org.midao.jdbc.core.handlers.output.OutputHandler)

update

public java.util.concurrent.Future<java.lang.Integer> update(java.lang.String sql)
                                                      throws java.sql.SQLException

Specified by:
update in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(String)

update

public java.util.concurrent.Future<java.lang.Integer> update(java.lang.String sql,
                                                             java.lang.Object param)
                                                      throws java.sql.SQLException

Specified by:
update in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(String, Object)

update

public java.util.concurrent.Future<java.lang.Integer> update(java.lang.String sql,
                                                             java.lang.Object... params)
                                                      throws java.sql.SQLException

Specified by:
update in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(String, Object...)

update

public java.util.concurrent.Future<java.lang.Integer> update(InputHandler inputHandler)
                                                      throws java.sql.SQLException

Specified by:
update in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(org.midao.jdbc.core.handlers.input.InputHandler)

update

public <T> java.util.concurrent.Future<T> update(InputHandler inputHandler,
                                                 OutputHandler<T> outputHandler)
                                      throws java.sql.SQLException

Specified by:
update in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(org.midao.jdbc.core.handlers.input.InputHandler, org.midao.jdbc.core.handlers.output.OutputHandler)

update

public <T> java.util.concurrent.Future<T> update(java.lang.String sql,
                                                 OutputHandler<T> outputHandler,
                                                 java.lang.Object... params)
                                      throws java.sql.SQLException

Specified by:
update in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(String, org.midao.jdbc.core.handlers.output.OutputHandler, Object...)

call

public java.util.concurrent.Future<QueryParameters> call(AbstractQueryInputHandler inputHandler)
                                                  throws java.sql.SQLException

Specified by:
call in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.query.AbstractQueryInputHandler)

call

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

Specified by:
call in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.named.AbstractNamedInputHandler, String, String, boolean)

call

public <T> java.util.concurrent.Future<T> call(AbstractNamedInputHandler<T> inputHandler)
                                    throws java.sql.SQLException

Specified by:
call in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.named.AbstractNamedInputHandler)

call

public <T,S> java.util.concurrent.Future<CallResults<T,S>> call(InputHandler<T> inputHandler,
                                                                OutputHandler<S> outputHandler)
                                                   throws java.sql.SQLException

Specified by:
call in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.InputHandler, org.midao.jdbc.core.handlers.output.OutputHandler)

call

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

Specified by:
call in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.InputHandler, org.midao.jdbc.core.handlers.output.OutputHandler, String, String, boolean)

setTransactionManualMode

public void setTransactionManualMode(boolean manualMode)

Specified by:
setTransactionManualMode in interface AsyncQueryRunnerService
See Also:
QueryRunnerService.setTransactionManualMode(boolean)

isTransactionManualMode

public boolean isTransactionManualMode()

Specified by:
isTransactionManualMode in interface AsyncQueryRunnerService
See Also:
QueryRunnerService.isTransactionManualMode()

setTransactionIsolationLevel

public void setTransactionIsolationLevel(java.lang.Integer level)

Specified by:
setTransactionIsolationLevel in interface AsyncQueryRunnerService
See Also:
QueryRunnerService.setTransactionIsolationLevel(Integer)

getTransactionIsolationLevel

public java.lang.Integer getTransactionIsolationLevel()

Specified by:
getTransactionIsolationLevel in interface AsyncQueryRunnerService
See Also:
QueryRunnerService.getTransactionIsolationLevel()

commit

public void commit()
            throws java.sql.SQLException

Specified by:
commit in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.commit()

rollback

public void rollback()
              throws java.sql.SQLException

Specified by:
rollback in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.rollback()

setSavepoint

public java.sql.Savepoint setSavepoint()
                                throws java.sql.SQLException

Specified by:
setSavepoint in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.setSavepoint()

setSavepoint

public java.sql.Savepoint setSavepoint(java.lang.String name)
                                throws java.sql.SQLException

Specified by:
setSavepoint in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.setSavepoint(String)

rollback

public void rollback(java.sql.Savepoint savepoint)
              throws java.sql.SQLException

Specified by:
rollback in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.rollback(java.sql.Savepoint)

releaseSavepoint

public void releaseSavepoint(java.sql.Savepoint savepoint)
                      throws java.sql.SQLException

Specified by:
releaseSavepoint in interface AsyncQueryRunnerService
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.releaseSavepoint(java.sql.Savepoint)

overrideOnce

public AsyncQueryRunnerService overrideOnce(java.lang.String operation,
                                            java.lang.Object value)

Specified by:
overrideOnce in interface AsyncQueryRunnerService
See Also:
QueryRunnerService.overrideOnce(String, Object)

override

public AsyncQueryRunnerService override(java.lang.String operation,
                                        java.lang.Object value)

Specified by:
override in interface AsyncQueryRunnerService
See Also:
QueryRunnerService.override(String, Object)

removeOverride

public AsyncQueryRunnerService removeOverride(java.lang.String operation)

Specified by:
removeOverride in interface AsyncQueryRunnerService
See Also:
QueryRunnerService.removeOverride(String)


Copyright © 2013. All Rights Reserved.