public final class FederateJDBCExecutor extends Object implements FederateExecutor
| Modifier and Type | Field and Description |
|---|---|
static String |
CONNECTION_URL |
static String |
DRIVER_NAME |
| Constructor and Description |
|---|
FederateJDBCExecutor(String schema,
OptimizeContextFactory factory,
ConfigurationProperties props,
JDBCExecutor jdbcExecutor) |
| 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.
|
public static final String CONNECTION_URL
public static final String DRIVER_NAME
public FederateJDBCExecutor(String schema, OptimizeContextFactory factory, ConfigurationProperties props, JDBCExecutor jdbcExecutor)
public List<QueryResult> executeQuery(ExecutionContext executionContext, JDBCExecutorCallback<? extends ExecuteResult> callback, DriverExecutionPrepareEngine<JDBCExecutionUnit,Connection> prepareEngine) throws SQLException
FederateExecutorexecuteQuery in interface FederateExecutorexecutionContext - execution contextcallback - callbackprepareEngine - prepare engineSQLException - SQL exceptionpublic void close()
throws SQLException
FederateExecutorclose in interface FederateExecutorSQLException - SQL exceptionpublic ResultSet getResultSet() throws SQLException
FederateExecutorgetResultSet in interface FederateExecutorSQLException - sql exceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.