3.0 data loader development. still need to make sure unit tests pass.

JumpMind · Dec 22, 2011 · e5aec5f · e5aec5f
1 parent c2aa2ec
commit e5aec5f
Show file tree

Hide file tree

Showing 143 changed files with 1,556 additions and 7,419 deletions.
diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java
diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/ISymmetricEngine.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/ISymmetricEngine.java
@@ -50,10 +50,10 @@
 import org.jumpmind.symmetric.service.IRouterService;
 import org.jumpmind.symmetric.service.ISecurityService;
 import org.jumpmind.symmetric.service.IStatisticService;
+import org.jumpmind.symmetric.service.ITransformService;
 import org.jumpmind.symmetric.service.ITriggerRouterService;
 import org.jumpmind.symmetric.service.IUpgradeService;
 import org.jumpmind.symmetric.statistic.IStatisticManager;
-import org.jumpmind.symmetric.transform.ITransformService;
 import org.springframework.context.ApplicationContext;
 
 public interface ISymmetricEngine {

diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java
@@ -113,6 +113,7 @@ private ParameterConstants() {
     public final static String DATA_LOADER_ENABLE_FALLBACK_INSERT = "dataloader.enable.fallback.insert";
     public final static String DATA_LOADER_ALLOW_MISSING_DELETE = "dataloader.allow.missing.delete";
     public final static String DATA_LOADER_MAX_ROWS_BEFORE_COMMIT = "dataloader.max.rows.before.commit";
+    public final static String DATA_LOADER_TREAT_DATETIME_AS_VARCHAR = "db.treat.date.time.as.varchar.enabled";
 
     public final static String DATA_RELOAD_IS_BATCH_INSERT_TRANSACTIONAL = "datareload.batch.insert.transactional";
 
@@ -186,8 +187,6 @@ private ParameterConstants() {
 
     public final static String DB_MASTER_COLLATION = "db.master.collation";
 
-    public final static String DB_TREAT_DATE_TIME_AS_VARCHAR = "db.treat.date.time.as.varchar.enabled";
-
     public static Map<String, ParameterMetaData> getParameterMetaData() {
         return parameterMetaData;
     }

diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/config/INodeIdGenerator.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/config/INodeIdGenerator.java
@@ -20,7 +20,7 @@
 
 package org.jumpmind.symmetric.config;
 
-import org.jumpmind.symmetric.ext.IExtensionPoint;
+import org.jumpmind.extension.IExtensionPoint;
 import org.jumpmind.symmetric.model.Node;
 import org.jumpmind.symmetric.service.INodeService;
 import org.jumpmind.symmetric.util.DefaultNodeIdGenerator;

diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/config/IParameterFilter.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/config/IParameterFilter.java
@@ -19,7 +19,7 @@
  * under the License.  */
 package org.jumpmind.symmetric.config;
 
-import org.jumpmind.symmetric.ext.IExtensionPoint;
+import org.jumpmind.extension.IExtensionPoint;
 
 public interface IParameterFilter extends IExtensionPoint {
 

diff --git a/.../symmetric-core/src/main/java/org/jumpmind/symmetric/config/ITriggerCreationListener.java b/.../symmetric-core/src/main/java/org/jumpmind/symmetric/config/ITriggerCreationListener.java
@@ -20,7 +20,7 @@
 
 package org.jumpmind.symmetric.config;
 
-import org.jumpmind.symmetric.ext.IExtensionPoint;
+import org.jumpmind.extension.IExtensionPoint;
 import org.jumpmind.symmetric.model.Trigger;
 import org.jumpmind.symmetric.model.TriggerHistory;