org.apache.shardingsphere.infra.executor.sql.federate.execute

Class FederateJDBCExecutor

java.lang.Object

org.apache.shardingsphere.infra.executor.sql.federate.execute.FederateJDBCExecutor

All Implemented Interfaces:

FederateExecutor

public final class FederateJDBCExecutor
extends Object
implements FederateExecutor

Federate JDBC executor.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONNECTION_URL
static String	DRIVER_NAME

Constructor Summary

Constructors

Constructor and Description
FederateJDBCExecutor(String schema, OptimizeContextFactory factory, ConfigurationProperties props, JDBCExecutor jdbcExecutor)

Method Summary

Modifier and Type	Method and Description
void	close() Close.
List<QueryResult>	executeQuery(ExecutionContext executionContext, JDBCExecutorCallback<? extends ExecuteResult> callback, DriverExecutionPrepareEngine<JDBCExecutionUnit,Connection> prepareEngine) Execute query.
ResultSet	getResultSet() Get result set.

Methods inherited from class java.lang.Object

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

Field Detail

CONNECTION_URL

public static final String CONNECTION_URL

See Also:

Constant Field Values

DRIVER_NAME

public static final String DRIVER_NAME

See Also:

Constant Field Values

Constructor Detail

FederateJDBCExecutor

public FederateJDBCExecutor(String schema,
                            OptimizeContextFactory factory,
                            ConfigurationProperties props,
                            JDBCExecutor jdbcExecutor)

Method Detail

executeQuery

public List<QueryResult> executeQuery(ExecutionContext executionContext,
                                      JDBCExecutorCallback<? extends ExecuteResult> callback,
                                      DriverExecutionPrepareEngine<JDBCExecutionUnit,Connection> prepareEngine)
                               throws SQLException

Description copied from interface: FederateExecutor

Execute query.

Specified by:

executeQuery in interface FederateExecutor

Parameters:

executionContext - execution context

callback - callback

prepareEngine - prepare engine

Returns:

execute result

Throws:

SQLException - SQL exception

close

public void close()
           throws SQLException

Description copied from interface: FederateExecutor

Close.

Specified by:

close in interface FederateExecutor

Throws:

SQLException - SQL exception

getResultSet

public ResultSet getResultSet()
                       throws SQLException

Description copied from interface: FederateExecutor

Get result set.

Specified by:

getResultSet in interface FederateExecutor

Returns:

result set

Throws:

SQLException - sql exception