org.midao.jdbc.core.service
Interface AsyncQueryRunnerService

All Known Implementing Classes:
AsyncQueryRunner

public interface AsyncQueryRunnerService

Core Service of Midao. Asynchronously executes all type of Queries.


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)
           
 

Method Detail

batch

java.util.concurrent.Future<int[]> batch(java.lang.String sql,
                                         java.lang.Object[][] params)
                                         throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.batch(String, Object[][])

batch

java.util.concurrent.Future<int[]> batch(InputHandler[] inputHandlers)
                                         throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.batch(org.midao.jdbc.core.handlers.input.InputHandler[])

query

<T> java.util.concurrent.Future<T> query(java.lang.String sql,
                                         OutputHandler<T> outputHandler,
                                         java.lang.Object... params)
                                     throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.query(String, org.midao.jdbc.core.handlers.output.OutputHandler, Object...)

query

<T> java.util.concurrent.Future<T> query(InputHandler inputHandler,
                                         OutputHandler<T> outputHandler)
                                     throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.query(org.midao.jdbc.core.handlers.input.InputHandler, org.midao.jdbc.core.handlers.output.OutputHandler)

query

<T> java.util.concurrent.Future<T> query(java.lang.String sql,
                                         OutputHandler<T> outputHandler)
                                     throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.query(String, org.midao.jdbc.core.handlers.output.OutputHandler)

update

java.util.concurrent.Future<java.lang.Integer> update(java.lang.String sql)
                                                      throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(String)

update

java.util.concurrent.Future<java.lang.Integer> update(java.lang.String sql,
                                                      java.lang.Object param)
                                                      throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(String, Object)

update

java.util.concurrent.Future<java.lang.Integer> update(java.lang.String sql,
                                                      java.lang.Object... params)
                                                      throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(String, Object...)

update

java.util.concurrent.Future<java.lang.Integer> update(InputHandler inputHandler)
                                                      throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(org.midao.jdbc.core.handlers.input.InputHandler)

update

<T> java.util.concurrent.Future<T> update(InputHandler inputHandler,
                                          OutputHandler<T> outputHandler)
                                      throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(org.midao.jdbc.core.handlers.input.InputHandler, org.midao.jdbc.core.handlers.output.OutputHandler)

update

<T> java.util.concurrent.Future<T> update(java.lang.String sql,
                                          OutputHandler<T> outputHandler,
                                          java.lang.Object... params)
                                      throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.update(String, org.midao.jdbc.core.handlers.output.OutputHandler, Object...)

call

java.util.concurrent.Future<QueryParameters> call(AbstractQueryInputHandler inputHandler)
                                                  throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.query.AbstractQueryInputHandler)

call

<T> java.util.concurrent.Future<T> call(AbstractNamedInputHandler<T> inputHandler)
                                    throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.named.AbstractNamedInputHandler)

call

<T> java.util.concurrent.Future<T> call(AbstractNamedInputHandler<T> inputHandler,
                                        java.lang.String catalog,
                                        java.lang.String schema,
                                        boolean useCache)
                                    throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.named.AbstractNamedInputHandler, String, String, boolean)

call

<T,S> java.util.concurrent.Future<CallResults<T,S>> call(InputHandler<T> inputHandler,
                                                         OutputHandler<S> outputHandler)
                                                   throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.call(org.midao.jdbc.core.handlers.input.InputHandler, org.midao.jdbc.core.handlers.output.OutputHandler)

call

<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
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)

overrideOnce

AsyncQueryRunnerService overrideOnce(java.lang.String operation,
                                     java.lang.Object value)
See Also:
QueryRunnerService.overrideOnce(String, Object)

override

AsyncQueryRunnerService override(java.lang.String operation,
                                 java.lang.Object value)
See Also:
QueryRunnerService.override(String, Object)

removeOverride

AsyncQueryRunnerService removeOverride(java.lang.String operation)
See Also:
QueryRunnerService.removeOverride(String)

setTransactionManualMode

void setTransactionManualMode(boolean manualMode)
See Also:
QueryRunnerService.setTransactionManualMode(boolean)

isTransactionManualMode

boolean isTransactionManualMode()
See Also:
QueryRunnerService.isTransactionManualMode()

setTransactionIsolationLevel

void setTransactionIsolationLevel(java.lang.Integer level)
See Also:
QueryRunnerService.setTransactionIsolationLevel(Integer)

getTransactionIsolationLevel

java.lang.Integer getTransactionIsolationLevel()
See Also:
QueryRunnerService.getTransactionIsolationLevel()

commit

void commit()
            throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.commit()

rollback

void rollback()
              throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.rollback()

setSavepoint

java.sql.Savepoint setSavepoint()
                                throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.setSavepoint()

setSavepoint

java.sql.Savepoint setSavepoint(java.lang.String name)
                                throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.setSavepoint(String)

rollback

void rollback(java.sql.Savepoint savepoint)
              throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.rollback(java.sql.Savepoint)

releaseSavepoint

void releaseSavepoint(java.sql.Savepoint savepoint)
                      throws java.sql.SQLException
Throws:
java.sql.SQLException
See Also:
QueryRunnerService.releaseSavepoint(java.sql.Savepoint)


Copyright © 2013. All Rights Reserved.