diff options
Diffstat (limited to 'src/main/src/sync/SSSyncTasksFactory.java')
-rw-r--r-- | src/main/src/sync/SSSyncTasksFactory.java | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/main/src/sync/SSSyncTasksFactory.java b/src/main/src/sync/SSSyncTasksFactory.java index a91b3fa..4f7cfd6 100644 --- a/src/main/src/sync/SSSyncTasksFactory.java +++ b/src/main/src/sync/SSSyncTasksFactory.java @@ -118,18 +118,18 @@ public class SSSyncTasksFactory { private static MVDataReader _makeSrcReader(ConnectionsHolder connections, ConfigSourceBean confSource, String taskName) throws Exception { MVDataReader reader=null; switch (confSource.getKind()) { - case csv: + case FIXED_CSV: reader = new CSVDataReader(confSource.getName(), new FileReader(confSource.getPath()), false); break; - case ldap: + case FIXED_CSV_SORTED: + reader = new CSVDataReader(confSource.getName(), new FileReader(confSource.getPath()), true); + break; + case LDAP: LDAPConnectionWrapper ldapConnBuilder = connections.getLDAPConnectionBuilder(confSource.getConn()); //FIXME if conf error, getLDAPConnectionBuilder could return null reader = ldapConnBuilder.newFlatReader(confSource.getName(), confSource.getBase(), confSource.getAttr(), confSource.getLookahead()); break; - case sorted_csv: - reader = new CSVDataReader(confSource.getName(), new FileReader(confSource.getPath()), true); - break; - case sql: + case SQL: SQLConnectionWrapper sqlConnBuilder = connections.getSQLConnectionBuilder(confSource.getConn()); //FIXME if conf error, getSQLConnectionBuilder could return null //TODO We assume the query config item is a filepath. It isn't checked anywhere. @@ -156,7 +156,7 @@ public class SSSyncTasksFactory { MVDataWriter writer = null; switch ( confDest.getKind() ) { - case ldap: + case LDAP: LDAPConnectionWrapper builder = connections.getLDAPConnectionBuilder(confDest.getConn()); reader = builder.newFlatReader(confDest.getName()+"_reader", confDest.getBase(), confDest.getAttr(), confDest.getLookahead()); writer = builder.newFlatWriter(confDest.getBase(), confDest.getAttr()); |