10 files changed, 774 insertions, 0 deletions
diff --git a/src/main/src/conf/ConfigConnectionBean.java b/src/main/src/conf/ConfigConnectionBean.java
new file mode 100644
index 0000000..b43b56f
--- /dev/null
+++ b/src/main/src/conf/ConfigConnectionBean.java
@@ -0,0 +1,111 @@
+/*
+ * SSSync, a Simple and Stupid Synchronizer for data with multi-valued attributes
+ * Copyright (C) 2014  Ludovic Pouzenc <ludovic@pouzenc.fr>
+ *  
+ * This file is part of SSSync.
+ *
+ *  SSSync is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  SSSync is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with SSSync.  If not, see <http://www.gnu.org/licenses/>
+ */
+
+package conf;
+
+import data.io.sql.SQLConnectionWrapper.DBMSType;
+
+/**
+ * Generated Configuration Bean
+ */
+public class ConfigConnectionBean {
+	
+	public enum ConnectionType { jdbc, ldap }
+	
+	private String id;
+	private ConnectionType type;
+	private DBMSType dbms;
+	private String ress;
+	private String host;
+	private int port;
+	private String user;
+	private String bind;
+	private String pass;
+	private String db;
+	
+	public String getId() {
+		return id;
+	}
+	public void setId(String id) {
+		this.id = id;
+	}
+	public ConnectionType getType() {
+		return type;
+	}
+	public void setType(ConnectionType type) {
+		this.type = type;
+	}
+	public DBMSType getDbms() {
+		return dbms;
+	}
+	public void setDbms(DBMSType dbms) {
+		this.dbms = dbms;
+	}
+	public String getRess() {
+		return ress;
+	}
+	public void setRess(String ress) {
+		this.ress = ress;
+	}
+	public String getHost() {
+		return host;
+	}
+	public void setHost(String host) {
+		this.host = host;
+	}
+	public int getPort() {
+		return port;
+	}
+	public void setPort(int port) {
+		this.port = port;
+	}
+	public String getUser() {
+		return user;
+	}
+	public void setUser(String user) {
+		this.user = user;
+	}
+	public String getBind() {
+		return bind;
+	}
+	public void setBind(String bind) {
+		this.bind = bind;
+	}
+	public String getPass() {
+		return pass;
+	}
+	public void setPass(String pass) {
+		this.pass = pass;
+	}
+	public String getDb() {
+		return db;
+	}	
+	public void setDb(String db) {
+		this.db = db;
+	}
+	
+	@Override
+	public String toString() {
+		return "ConfigConnectionBean [id=" + id + ", type=" + type + ", dbms=" + dbms
+				+ ", ress=" + ress + ", host=" + host + ", port=" + port
+				+ ", user=" + user + ", bind=" + bind + ", pass=(obfuscated)]";
+	}
+	
+}
diff --git a/src/main/src/conf/ConfigConnectionsBean.java b/src/main/src/conf/ConfigConnectionsBean.java
new file mode 100644
index 0000000..9fb034b
--- /dev/null
+++ b/src/main/src/conf/ConfigConnectionsBean.java
@@ -0,0 +1,45 @@
+/*
+ * SSSync, a Simple and Stupid Synchronizer for data with multi-valued attributes
+ * Copyright (C) 2014  Ludovic Pouzenc <ludovic@pouzenc.fr>
+ *  
+ * This file is part of SSSync.
+ *
+ *  SSSync is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  SSSync is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with SSSync.  If not, see <http://www.gnu.org/licenses/>
+ */
+
+package conf;
+
+import java.util.List;
+
+/**
+ * Generated Configuration Bean
+ */
+public class ConfigConnectionsBean {
+	
+	private List<ConfigConnectionBean> connections;
+
+		public List<ConfigConnectionBean> getConnections() {
+		return connections;
+	}
+
+	public void setConnections(List<ConfigConnectionBean> connections) {
+		this.connections = connections;
+	}
+
+	@Override
+	public String toString() {
+		return "ConfigConnectionsBean [connections=" + ConfigRootBean.listDump(connections,1) + "]";
+	}
+
+}
diff --git a/src/main/src/conf/ConfigGlobalsBean.java b/src/main/src/conf/ConfigGlobalsBean.java
new file mode 100644
index 0000000..256acee
--- /dev/null
+++ b/src/main/src/conf/ConfigGlobalsBean.java
@@ -0,0 +1,41 @@
+/*
+ * SSSync, a Simple and Stupid Synchronizer for data with multi-valued attributes
+ * Copyright (C) 2014  Ludovic Pouzenc <ludovic@pouzenc.fr>
+ *  
+ * This file is part of SSSync.
+ *
+ *  SSSync is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  SSSync is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with SSSync.  If not, see <http://www.gnu.org/licenses/>
+ */
+
+package conf;
+
+/**
+ * Generated Configuration Bean
+ */
+public class ConfigGlobalsBean {
+	private int maxExecTime;
+	
+	public int getMaxExecTime() {
+		return maxExecTime;
+	}
+
+	public void setMaxExecTime(int maxExecTime) {
+		this.maxExecTime = maxExecTime;
+	}
+
+	@Override
+	public String toString() {
+		return "ConfigGlobalsBean [maxExecTime=" + maxExecTime + "]";
+	}
+}
diff --git a/src/main/src/conf/ConfigOpLimitsBean.java b/src/main/src/conf/ConfigOpLimitsBean.java
new file mode 100644
index 0000000..8f68e8c
--- /dev/null
+++ b/src/main/src/conf/ConfigOpLimitsBean.java
@@ -0,0 +1,55 @@
+/*
+ * SSSync, a Simple and Stupid Synchronizer for data with multi-valued attributes
+ * Copyright (C) 2014  Ludovic Pouzenc <ludovic@pouzenc.fr>
+ *  
+ * This file is part of SSSync.
+ *
+ *  SSSync is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  SSSync is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with SSSync.  If not, see <http://www.gnu.org/licenses/>
+ */
+
+package conf;
+
+/**
+ * Generated Configuration Bean
+ */
+public class ConfigOpLimitsBean {
+	private int insert;
+	private int update;
+	private int delete;
+	
+	public int getInsert() {
+		return insert;
+	}
+	public void setInsert(int insert) {
+		this.insert = insert;
+	}
+	public int getUpdate() {
+		return update;
+	}
+	public void setUpdate(int update) {
+		this.update = update;
+	}
+	public int getDelete() {
+		return delete;
+	}
+	public void setDelete(int delete) {
+		this.delete = delete;
+	}
+	
+	@Override
+	public String toString() {
+		return "ConfigOpLimitsBean [insert=" + insert + ", update=" + update
+				+ ", delete=" + delete + "]";
+	}
+}
diff --git a/src/main/src/conf/ConfigRootBean.java b/src/main/src/conf/ConfigRootBean.java
new file mode 100644
index 0000000..acbbd49
--- /dev/null
+++ b/src/main/src/conf/ConfigRootBean.java
@@ -0,0 +1,73 @@
+/*
+ * SSSync, a Simple and Stupid Synchronizer for data with multi-valued attributes
+ * Copyright (C) 2014  Ludovic Pouzenc <ludovic@pouzenc.fr>
+ *  
+ * This file is part of SSSync.
+ *
+ *  SSSync is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  SSSync is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with SSSync.  If not, see <http://www.gnu.org/licenses/>
+ */
+
+package conf;
+
+import java.util.List;
+
+/**
+ * Generated Configuration Bean
+ */
+public class ConfigRootBean {
+	
+	private ConfigGlobalsBean globals;
+	private List<ConfigTaskBean> tasks;
+	
+	public ConfigGlobalsBean getGlobals() {
+		return globals;
+	}
+	public void setGlobals(ConfigGlobalsBean globals) {
+		this.globals = globals;
+	}
+
+	public List<ConfigTaskBean> getTasks() {
+		return tasks;
+	}
+	public void setTasks(List<ConfigTaskBean> tasks) {
+		this.tasks = tasks;
+	}
+
+	@Override
+	public String toString() {
+		return "ConfigRootBean [globals=" + globals + ", tasks=" + listDump(tasks, 1) + "]";
+	}
+	
+
+	public static <T> String listDump(List<T> list, int ident) {
+		StringBuffer buf = new StringBuffer();
+		buf.append('{');
+		for (T item : list) {
+			buf.append('\n');
+			for (int i = 0; i < ident; i++) {
+				buf.append('\t');
+			}
+			buf.append(item.toString());
+			buf.append(',');
+		}
+		buf.append('\n');
+		for (int i = 0; i < ident-1; i++) {
+			buf.append('\t');
+		}
+		buf.append('}');
+		return buf.toString();
+	}
+
+	
+}
diff --git a/src/main/src/conf/ConfigSrcOrDestBean.java b/src/main/src/conf/ConfigSrcOrDestBean.java
new file mode 100644
index 0000000..5be1674
--- /dev/null
+++ b/src/main/src/conf/ConfigSrcOrDestBean.java
@@ -0,0 +1,96 @@
+/*
+ * SSSync, a Simple and Stupid Synchronizer for data with multi-valued attributes
+ * Copyright (C) 2014  Ludovic Pouzenc <ludovic@pouzenc.fr>
+ *  
+ * This file is part of SSSync.
+ *
+ *  SSSync is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  SSSync is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with SSSync.  If not, see <http://www.gnu.org/licenses/>
+ */
+
+package conf;
+
+import data.filters.MVDataCombiner;
+
+/**
+ * Generated Configuration Bean
+ */
+public class ConfigSrcOrDestBean {
+
+	public enum SourceKind { csv, ldap, sorted_csv, sql };
+	
+	private String name;
+	private SourceKind kind;
+	private String conn;
+	private MVDataCombiner.MVDataCombineMode mode;
+	private String query;
+	private String path;
+	private String attr;
+	private String base;
+
+	public String getName() {
+		return name;
+	}
+	public void setName(String name) {
+		this.name = name;
+	}
+	public SourceKind getKind() {
+		return kind;
+	}
+	public void setKind(SourceKind kind) {
+		this.kind = kind;
+	}
+	public String getConn() {
+		return conn;
+	}
+	public void setConn(String conn) {
+		this.conn = conn;
+	}
+	public MVDataCombiner.MVDataCombineMode getMode() {
+		return mode;
+	}
+	public void setMode(MVDataCombiner.MVDataCombineMode mode) {
+		this.mode = mode;
+	}
+	public String getQuery() {
+		return query;
+	}
+	public void setQuery(String query) {
+		this.query = query;
+	}
+	public String getPath() {
+		return path;
+	}
+	public void setPath(String path) {
+		this.path = path;
+	}
+	public String getAttr() {
+		return attr;
+	}
+	public void setAttr(String attr) {
+		this.attr = attr;
+	}
+	public String getBase() {
+		return base;
+	}
+	public void setBase(String base) {
+		this.base = base;
+	}
+	
+	@Override
+	public String toString() {
+		return "ConfigSrcOrDestBean [name=" + name + ", kind=" + kind
+				+ ", conn=" + conn + ", mode=" + mode + ", query=" + query
+				+ ", path=" + path + ", attr=" + attr + ", base=" + base + "]";
+	}
+}
diff --git a/src/main/src/conf/ConfigTaskBean.java b/src/main/src/conf/ConfigTaskBean.java
new file mode 100644
index 0000000..ed34eee
--- /dev/null
+++ b/src/main/src/conf/ConfigTaskBean.java
@@ -0,0 +1,80 @@
+/*
+ * SSSync, a Simple and Stupid Synchronizer for data with multi-valued attributes
+ * Copyright (C) 2014  Ludovic Pouzenc <ludovic@pouzenc.fr>
+ *  
+ * This file is part of SSSync.
+ *
+ *  SSSync is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  SSSync is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with SSSync.  If not, see <http://www.gnu.org/licenses/>
+ */
+
+package conf;
+
+import java.util.List;
+
+/**
+ * Generated Configuration Bean
+ */
+public class ConfigTaskBean {
+
+	private String name;
+	private ConfigOpLimitsBean opLimits;
+	private List<ConfigSrcOrDestBean> sources;
+	private	ConfigSrcOrDestBean destination;
+	private boolean skipReadErrors;
+	private boolean skipEntryDelete;
+	
+	public String getName() {
+		return name;
+	}
+	public void setName(String name) {
+		this.name = name;
+	}
+	public ConfigOpLimitsBean getOpLimits() {
+		return opLimits;
+	}
+	public void setOpLimits(ConfigOpLimitsBean opLimits) {
+		this.opLimits = opLimits;
+	}
+	public List<ConfigSrcOrDestBean> getSources() {
+		return sources;
+	}
+	public void setSources(List<ConfigSrcOrDestBean> sources) {
+		this.sources = sources;
+	}
+	public ConfigSrcOrDestBean getDestination() {
+		return destination;
+	}
+	public void setDestination(ConfigSrcOrDestBean destination) {
+		this.destination = destination;
+	}
+	public boolean isSkipReadErrors() {
+		return skipReadErrors;
+	}
+	public void setSkipReadErrors(boolean skipReadErrors) {
+		this.skipReadErrors = skipReadErrors;
+	}
+	public boolean isSkipEntryDelete() {
+		return skipEntryDelete;
+	}
+	public void setSkipEntryDelete(boolean skipDelete) {
+		this.skipEntryDelete = skipDelete;
+	}
+	@Override
+	public String toString() {
+		return "ConfigTaskBean [name=" + name + ", opLimits=" + opLimits
+				+ ", sources=" + sources + ", destination=" + destination
+				+ ", skipReadErrors=" + skipReadErrors + ", skipEntryDelete="
+				+ skipEntryDelete + "]";
+	}
+}
diff --git a/src/main/src/conf/SSSyncConfParser.java b/src/main/src/conf/SSSyncConfParser.java
new file mode 100644
index 0000000..42dc760
--- /dev/null
+++ b/src/main/src/conf/SSSyncConfParser.java
@@ -0,0 +1,65 @@
+/*
+ * SSSync, a Simple and Stupid Synchronizer for data with multi-valued attributes
+ * Copyright (C) 2014  Ludovic Pouzenc <ludovic@pouzenc.fr>
+ *  
+ * This file is part of SSSync.
+ *
+ *  SSSync is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  SSSync is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with SSSync.  If not, see <http://www.gnu.org/licenses/>
+ */
+
+package conf;
+
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.text.ParseException;
+
+import org.yaml.snakeyaml.Yaml;
+import org.yaml.snakeyaml.constructor.Constructor;
+
+/**
+ * TODO javadoc
+ * 
+ * @author lpouzenc
+ */
+public class SSSyncConfParser {
+	
+	public static ConfigRootBean loadMainConfig(String mainConfigFile) throws FileNotFoundException, ParseException {
+		Yaml yamlMain = new Yaml(new Constructor(ConfigRootBean.class));
+
+		//TODO : try to prevent weird exceptions when config is not respecting the implicit grammar of the bean tree
+		
+		ConfigRootBean confMain = (ConfigRootBean) yamlMain.load(new FileInputStream(mainConfigFile));
+		
+		if ( confMain == null || confMain.getGlobals() == null ) {
+			throw new ParseException("Config parser has returned a null item", 0);
+		}
+		
+		// TODO : check config sanity and completeness
+		
+		return confMain;
+	}
+	
+	public static ConfigConnectionsBean loadConnConfig(String connConfigFile) throws FileNotFoundException, ParseException {
+		Yaml yamlConn = new Yaml(new Constructor(ConfigConnectionsBean.class));
+
+		ConfigConnectionsBean confConn = (ConfigConnectionsBean) yamlConn.load(new FileInputStream(connConfigFile));
+		
+		if ( confConn == null ) {
+			throw new ParseException("Config parser has return a null item", 0);
+		}
+		
+		return confConn;
+	}
+
+}
diff --git a/src/main/src/conf/SSSyncConnectionsFactory.java b/src/main/src/conf/SSSyncConnectionsFactory.java
new file mode 100644
index 0000000..e747258
--- /dev/null
+++ b/src/main/src/conf/SSSyncConnectionsFactory.java
@@ -0,0 +1,61 @@
+/*
+ * SSSync, a Simple and Stupid Synchronizer for data with multi-valued attributes
+ * Copyright (C) 2014  Ludovic Pouzenc <ludovic@pouzenc.fr>
+ *  
+ * This file is part of SSSync.
+ *
+ *  SSSync is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  SSSync is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with SSSync.  If not, see <http://www.gnu.org/licenses/>
+ */
+
+package conf;
+
+import data.io.ConnectionsHolder;
+import data.io.ldap.LDAPConnectionWrapper;
+import data.io.sql.SQLConnectionWrapper;
+
+/**
+ * TODO javadoc
+ * 
+ * @author lpouzenc
+ */
+public class SSSyncConnectionsFactory {
+
+	/**
+	 * Setup all connections described in config
+	 * @return 
+	 * @throws Exception
+	 */
+	public static ConnectionsHolder setupConnections(ConfigConnectionsBean confConn) throws Exception {  
+		ConnectionsHolder connections = new ConnectionsHolder();
+		
+		for ( ConfigConnectionBean conn : confConn.getConnections() ) {
+			switch (conn.getType()) {
+			case jdbc:
+				SQLConnectionWrapper connSQL = new SQLConnectionWrapper(conn.getDbms(), conn.getHost(), conn.getPort(), conn.getRess(), conn.getUser(), conn.getPass(), conn.getDb());
+				connections.putConnSQL(conn.getId(), connSQL);
+				break;
+			case ldap:
+				LDAPConnectionWrapper connLDAP = new LDAPConnectionWrapper(conn.getHost(), conn.getPort(), conn.getBind(), conn.getPass());
+				connections.putConnLDAP(conn.getId(), connLDAP);
+				break;
+			default:
+				//XXX : find better Exception type
+				throw new Exception("Bad config : conn '" + conn.getId() + "' unsupported type");
+			}
+		}
+		
+		return connections;
+	}
+	
+}
diff --git a/src/main/src/conf/SSSyncTasksFactory.java b/src/main/src/conf/SSSyncTasksFactory.java
new file mode 100644
index 0000000..de3e8f6
--- /dev/null
+++ b/src/main/src/conf/SSSyncTasksFactory.java
@@ -0,0 +1,147 @@
+/*
+ * SSSync, a Simple and Stupid Synchronizer for data with multi-valued attributes
+ * Copyright (C) 2014  Ludovic Pouzenc <ludovic@pouzenc.fr>
+ *  
+ * This file is part of SSSync.
+ *
+ *  SSSync is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  SSSync is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with SSSync.  If not, see <http://www.gnu.org/licenses/>
+ */
+
+package conf;
+
+import java.io.File;
+import java.io.FileReader;
+import java.util.ArrayList;
+import java.util.List;
+
+import sync.BasicSyncTask;
+import data.filters.MVDataCombiner;
+import data.filters.MVDataCombiner.MVDataCombineMode;
+import data.io.ConnectionsHolder;
+import data.io.MVDataReader;
+import data.io.MVDataWriter;
+import data.io.SafeDataReader;
+import data.io.csv.CSVDataReader;
+import data.io.ldap.LDAPConnectionWrapper;
+import data.io.sql.SQLConnectionWrapper;
+
+/**
+ * TODO javadoc
+ * 
+ * @author lpouzenc
+ */
+public class SSSyncTasksFactory {
+
+	/**
+	 * Build tasks objects with all needed resources from a config beans tree
+	 * @param conf
+	 * @return
+	 * @throws Exception
+	 */
+	public static List<BasicSyncTask> setupTasks(ConnectionsHolder connections, ConfigRootBean confMain) throws Exception {
+		List<BasicSyncTask> tasks = new ArrayList<BasicSyncTask>();
+		
+		// For each task...
+		for ( ConfigTaskBean confTask: confMain.getTasks() ) {
+			MVDataReader srcReader=null;
+			
+			// Building all sources
+			
+			List<ConfigSrcOrDestBean> confSources = confTask.getSources();
+			// See if we are in multiple source situation (then MVDataCombiner) or not (then simple MVDataReader)
+			if ( confSources.size() == 0 ) {
+				throw new Exception("Bad config : task '" + confTask.getName() + "' has no defined sources");
+			} else if ( confSources.size() == 1 ) {
+				srcReader = new SafeDataReader(_makeReader(connections, confSources.get(0), confTask.getName()), confTask.isSkipReadErrors());
+			} else {
+				List<MVDataReader> readers = new ArrayList<MVDataReader>();
+				List<MVDataCombineMode> mergeModes = new ArrayList<MVDataCombineMode>();
+				
+				// For each source of the future MVDataCombiner...
+				for ( ConfigSrcOrDestBean confSource: confSources ) {
+					// Create and add the reader and his parameters
+					readers.add(new SafeDataReader(_makeReader(connections, confSource, confTask.getName()), confTask.isSkipReadErrors()));
+					mergeModes.add(confSource.getMode());
+				}				
+				
+				srcReader = new MVDataCombiner("srcCombiner", readers.toArray(new MVDataReader[0]), mergeModes.toArray(new MVDataCombineMode[0]));
+			}
+			
+			// Building destination 
+			
+			MVDataReader dstReader=null;
+			MVDataWriter dstWriter=null;
+			
+			ConfigSrcOrDestBean confDestination = confTask.getDestination();
+			switch ( confDestination.getKind() ) {
+			case ldap:
+				LDAPConnectionWrapper builder = connections.getLDAPConnectionBuilder(confDestination.getConn());
+				// TODO : configurable lookAhead
+				MVDataReader tmpReader = builder.newFlatReader(confDestination.getName()+"_reader", confDestination.getBase(), confDestination.getAttr(), 128);
+				dstReader = new SafeDataReader(tmpReader, false);
+				dstWriter = builder.newFlatWriter(confDestination.getBase(), confDestination.getAttr());
+				break;
+			default:
+				throw new Exception("Bad config : task '" + confTask.getName() + "' unsupported destination kind");
+			}
+			
+			// Then building the sync task and add it to the task list
+			int maxInserts = confTask.getOpLimits().getInsert();
+			int maxUpdates = confTask.getOpLimits().getUpdate();
+			int maxDeletes = confTask.getOpLimits().getDelete();
+			
+			BasicSyncTask task = new BasicSyncTask(confTask.getName(), false, srcReader, dstReader, dstWriter);
+			task.setOperationLimits(maxInserts, maxUpdates, maxDeletes);
+			task.setSkipEntryDelete(confTask.isSkipEntryDelete());
+			tasks.add(task);
+		}
+		
+		return tasks;
+	}
+
+	/**
+	 * Helper function to make a new reader from an existing connection
+	 * @param confSource
+	 * @param taskName
+	 * @return
+	 * @throws Exception
+	 */
+	private static MVDataReader _makeReader(ConnectionsHolder connections, ConfigSrcOrDestBean confSource, String taskName) throws Exception {
+		MVDataReader reader=null;
+		switch (confSource.getKind()) {
+		case csv:
+			reader = new CSVDataReader(confSource.getName(), new FileReader(confSource.getPath()), false);
+			break;
+		case ldap:
+			LDAPConnectionWrapper ldapConnBuilder = connections.getLDAPConnectionBuilder(confSource.getConn());
+			//FIXME : if conf error, get...ConnectionBuilder could return null
+			//TODO : configurable lookAhead
+			reader = ldapConnBuilder.newFlatReader(confSource.getName(), confSource.getBase(), confSource.getAttr(), 128); 
+			break;
+		case sorted_csv:
+			reader = new CSVDataReader(confSource.getName(), new FileReader(confSource.getPath()), true);
+			break;
+		case sql:
+			SQLConnectionWrapper sqlConnBuilder = connections.getSQLConnectionBuilder(confSource.getConn());
+			//TODO We assume the query config item is a filepath. It isn't checked anywhere.  
+			reader = sqlConnBuilder.newReader(confSource.getName(), new File(confSource.getQuery()));
+			break;
+		default:
+			throw new Exception("Bad config : task '" + taskName + "' unsupported source kind");
+		}
+
+		return reader;
+	}
+	
+}