public void tearDown() {
executor.close();
}
public void testQuery() throws Exception {
MutableContext context = new MutableMapContext();
context.setString(
GenericJdbcConnectorConstants.CONNECTOR_JDBC_DRIVER,
GenericJdbcTestConstants.DRIVER);
context.setString(
GenericJdbcConnectorConstants.CONNECTOR_JDBC_URL,
GenericJdbcTestConstants.URL);
context.setString(GenericJdbcConnectorConstants.CONNECTOR_JDBC_DATA_SQL,
"SELECT * FROM " + executor.delimitIdentifier(tableName)
+ " WHERE ${CONDITIONS}");
ConnectionConfiguration connConf = new ConnectionConfiguration();
ImportJobConfiguration jobConf = new ImportJobConfiguration();