@Test(expected = IllegalArgumentException.class) public void testGetQueryNoTable() throws Exception { processor.getQuery(dbAdapter, null, null, null, null, null); }
protected String getQuery(DatabaseAdapter dbAdapter, String tableName, String columnNames, List<String> maxValColumnNames, String customWhereClause, Map<String, String> stateMap) { return getQuery(dbAdapter, tableName, null, columnNames, maxValColumnNames, customWhereClause, stateMap); }
QueryDatabaseTable extends AbstractDatabaseFetchProcessor { protected String getQuery(DatabaseAdapter dbAdapter, String tableName, String columnNames, List<String> maxValColumnNames, String customWhereClause, Map<String, String> stateMap) { return getQuery(dbAdapter, tableName, null, columnNames, maxValColumnNames, customWhereClause, stateMap); } }
QueryDatabaseTable extends AbstractDatabaseFetchProcessor { protected String getQuery(DatabaseAdapter dbAdapter, String tableName, String columnNames, List<String> maxValColumnNames, String customWhereClause, Map<String, String> stateMap) { return getQuery(dbAdapter, tableName, null, columnNames, maxValColumnNames, customWhereClause, stateMap); } QueryDatabaseTable(); }
QueryDatabaseTable extends AbstractDatabaseFetchProcessor { protected String getQuery(DatabaseAdapter dbAdapter, String tableName, String columnNames, List<String> maxValColumnNames, String customWhereClause, Map<String, String> stateMap) { return getQuery(dbAdapter, tableName, null, columnNames, maxValColumnNames, customWhereClause, stateMap); } QueryDatabaseTable(); @Override Set<Relationship> getRelationships(); @OnScheduled void setup(final ProcessContext context); @OnStopped void stop(); @Override void onTrigger(final ProcessContext context, final ProcessSessionFactory sessionFactory); }
QueryDatabaseTable extends AbstractDatabaseFetchProcessor { protected String getQuery(DatabaseAdapter dbAdapter, String tableName, String columnNames, List<String> maxValColumnNames, String customWhereClause, Map<String, String> stateMap) { return getQuery(dbAdapter, tableName, null, columnNames, maxValColumnNames, customWhereClause, stateMap); } QueryDatabaseTable(); @Override Set<Relationship> getRelationships(); @OnScheduled void setup(final ProcessContext context); @OnStopped void stop(); @Override void onTrigger(final ProcessContext context, final ProcessSessionFactory sessionFactory); static final String RESULT_TABLENAME; static final String RESULT_ROW_COUNT; static final PropertyDescriptor FETCH_SIZE; static final PropertyDescriptor MAX_ROWS_PER_FLOW_FILE; static final PropertyDescriptor OUTPUT_BATCH_SIZE; static final PropertyDescriptor MAX_FRAGMENTS; }