1 files changed, 176 insertions, 0 deletions
diff --git a/sca-java-1.x/tags/java-stable-20060304/das/rdb/src/main/java/org/apache/tuscany/das/rdb/impl/ApplyChangesCommandImpl.java b/sca-java-1.x/tags/java-stable-20060304/das/rdb/src/main/java/org/apache/tuscany/das/rdb/impl/ApplyChangesCommandImpl.java
new file mode 100644
index 0000000000..6e92a5e6a2
--- /dev/null
+++ b/sca-java-1.x/tags/java-stable-20060304/das/rdb/src/main/java/org/apache/tuscany/das/rdb/impl/ApplyChangesCommandImpl.java
@@ -0,0 +1,176 @@
+/**
+ *
+ *  Copyright 2005 The Apache Software Foundation or its licensors, as applicable.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+package org.apache.tuscany.das.rdb.impl;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.sql.Connection;
+import java.sql.DriverManager;
+
+import org.apache.tuscany.das.rdb.ApplyChangesCommand;
+import org.apache.tuscany.das.rdb.Command;
+import org.apache.tuscany.das.rdb.Key;
+import org.apache.tuscany.das.rdb.config.Config;
+import org.apache.tuscany.das.rdb.config.ConnectionProperties;
+import org.apache.tuscany.das.rdb.config.impl.ConfigPackageImpl;
+import org.apache.tuscany.das.rdb.util.DebugUtil;
+
+import commonj.sdo.DataObject;
+import commonj.sdo.Type;
+import commonj.sdo.helper.XMLDocument;
+import commonj.sdo.helper.XMLHelper;
+
+/**
+ * 
+ */
+public class ApplyChangesCommandImpl implements ApplyChangesCommand {
+
+    private ConnectionImpl dasConnection;
+
+    private static final boolean debug = false;
+
+    private ChangeSummarizer summarizer = new ChangeSummarizer();
+
+    public ApplyChangesCommandImpl() {
+        // Empty Constructor
+    }
+
+    // IOException is recoverable, needs to be thrown
+    public ApplyChangesCommandImpl(InputStream mappingModel) throws IOException {
+        setMapping(mappingModel);
+    }
+
+    public ApplyChangesCommandImpl(Config mappingModel){
+        summarizer.setMapping(mappingModel);
+//TODO - Really need to refactor the Command framework.  ReadCommand and ApplychangesCommand should
+// be using the same approach to set connection and should probably share the same initialization.
+//        if (mappingModel.getConnectionProperties() != null)
+//            setConnection(mappingModel.getConnectionProperties());
+    }
+
+    public void setConnection(Connection connection) {
+        setConnection(new ConnectionImpl(connection));
+    }
+
+    public void setConnection(Connection connection, boolean manageTransaction) {
+        ConnectionImpl c = new ConnectionImpl(connection);
+        c.setManageTransactions(manageTransaction);
+        setConnection(c);
+    }
+
+    public void setConnection(ConnectionImpl connection) {
+        dasConnection = connection;
+        summarizer.setConnection(connection);
+    }
+
+    public void setConnection(ConnectionProperties c) {
+        try {
+            Connection connection = null;
+            Class.forName(c.getDriverClassName());
+            if (c.getDriverUserName() == null)
+                connection = DriverManager.getConnection(c.getDriverURL());
+            else
+                connection = DriverManager.getConnection(c.getDriverURL(), c.getDriverUserName(), c.getDriverPassword());
+            connection.setAutoCommit(false);
+            setConnection(connection);
+        } catch (Exception ex) {
+            throw new RuntimeException(ex);
+        }
+    }
+
+    public void addCreateCommand(Type type, Command cmd) {
+        summarizer.addCreateCommand(type, cmd);
+        ((CommandImpl) cmd).setConnection(dasConnection);
+    }
+
+    public void addUpdateCommand(Type type, Command cmd) {
+        // DebugUtil.debugln(getClass(), debug, "Adding update command for type
+        // " + type.getName());
+        summarizer.addUpdateCommand(type, cmd);
+        ((CommandImpl) cmd).setConnection(dasConnection);
+    }
+
+    public void addDeleteCommand(Type type, Command cmd) {
+        summarizer.addDeleteCommand(type, cmd);
+        ((CommandImpl) cmd).setConnection(dasConnection);
+    }
+
+    public void execute(DataObject root) {
+        DebugUtil.debugln(getClass(), debug, "Executing ApplyChangesCmd");
+
+        if (dasConnection == null)
+            throw new RuntimeException("A connection must be provided");
+
+        if (!root.equals(root.getDataGraph().getRootObject()))
+            throw new RuntimeException("'root' argument must be the root of the datagraph");
+        
+        Changes changes = summarizer.loadChanges(root);
+
+        boolean success = false;
+        try {
+            changes.execute();
+            success = true;
+        } finally {
+            if (success)
+                dasConnection.cleanUp();
+            else
+                dasConnection.errorCleanUp();
+        }
+    }
+
+    public void setMapping(InputStream stream) throws IOException {
+    	XMLHelper helper = XMLHelper.INSTANCE;
+   
+        ConfigPackageImpl impl = ConfigPackageImpl.eINSTANCE;
+    	XMLDocument doc = helper.load(stream);
+    	Config mapping = (Config) doc.getRootObject();
+
+        summarizer.setMapping(mapping);
+        if (mapping.getConnectionProperties() != null)
+            setConnection(mapping.getConnectionProperties());
+
+    }
+
+    public void addRelationship(String parent, String child) {
+        summarizer.addRelationship(parent, child);
+    }
+
+    public void addPrimaryKey(String columnName) {
+        summarizer.addPrimaryKey(columnName);
+    }
+
+    public void addCollisionColumn(String columnName) {
+        summarizer.addCollisionColumn(columnName);
+    }
+
+    public void addRelationship(Key parentKey, Key childKey) {
+        throw new RuntimeException("Not Implemented");
+    }
+
+    public void addPrimaryKey(Key key) {
+        summarizer.addPrimarykey(key);
+    }
+
+    public void addGeneratedPrimaryKey(String columnName) {
+        summarizer.addGeneratedPrimaryKey(columnName);
+    }
+
+    public void addConverter(String name, String converterName) {
+        summarizer.addConverter(name, converterName);
+    }
+
+}