1 files changed, 130 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/DatabaseObject.java b/sca-java-1.x/tags/java-stable-20060304/das/rdb/src/main/java/org/apache/tuscany/das/rdb/impl/DatabaseObject.java
new file mode 100644
index 0000000000..d3b00b2e7b
--- /dev/null
+++ b/sca-java-1.x/tags/java-stable-20060304/das/rdb/src/main/java/org/apache/tuscany/das/rdb/impl/DatabaseObject.java
@@ -0,0 +1,130 @@
+/**
+*
+*  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.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+
+import org.apache.tuscany.das.rdb.config.Config;
+import org.apache.tuscany.das.rdb.config.KeyPair;
+import org.apache.tuscany.das.rdb.config.Relationship;
+import org.apache.tuscany.das.rdb.config.wrapper.MappingWrapper;
+import org.apache.tuscany.das.rdb.util.DebugUtil;
+
+import commonj.sdo.DataObject;
+import commonj.sdo.Property;
+
+/**
+ * DatabaseObject wraps DataObject. If a field is an FK field, it will return
+ * the value from the parent.
+ * 
+ * 
+ */
+public class DatabaseObject {
+
+	private final MappingWrapper mappingWrapper;
+
+	private final DataObject dataObject;
+
+	private Property parentReference;
+
+	private static final boolean debug = false;
+
+	private HashMap keyMappings = new HashMap();
+
+	public DatabaseObject(Config model, DataObject changedObject) {
+		this.mappingWrapper = new MappingWrapper(model);
+		this.dataObject = changedObject;
+		initialize();
+	}
+
+	// Initialize Key Mappings
+	private void initialize() {
+		if (mappingWrapper.getConfig() != null) {
+			List relationships = mappingWrapper.getConfig().getRelationship();
+			Iterator i = relationships.iterator();
+			while (i.hasNext()) {
+				Relationship r = (Relationship) i.next();
+				DebugUtil.debugln(getClass(), debug,
+						"Initializing relationship: " + r.getName());
+				if (r.getForeignKeyTable().equals(getTypeName())) {
+					List pairs = r.getKeyPair();
+					Iterator iter = pairs.iterator();
+					while (iter.hasNext()) {
+						KeyPair pair = (KeyPair) iter.next();
+						keyMappings.put(pair.getForeignKeyColumn(), r);
+					}
+				}
+			}
+		}
+	}
+
+	public Object get(String parameter) {
+		Relationship r = (Relationship) keyMappings.get(parameter);
+		if (r == null)
+			return dataObject.get(parameter);
+
+		Property parentRef = getParentReference(r.getPrimaryKeyTable());
+		DataObject parent = dataObject.getDataObject(parentRef);
+		String parentKey = getParentKey(r, parameter);
+		return parent.get(parentKey);
+
+	}
+
+	private String getParentKey(Relationship r, String parameter) {
+		List keyPairs = r.getKeyPair();
+		Iterator i = keyPairs.iterator();
+		while (i.hasNext()) {
+			KeyPair pair = (KeyPair) i.next();
+			if (pair.getForeignKeyColumn().equals(parameter))
+				return pair.getPrimaryKeyColumn();
+		}
+		return null;
+	}
+
+	public Property getParentReference(String parentName) {
+		if (this.parentReference == null) {
+
+			Iterator i = dataObject.getType().getProperties().iterator();							
+			while (i.hasNext()) {
+				Property ref = (Property) i.next();
+				if ((!ref.getType().isDataType()) && 
+						(ref.getType().getName().equals(parentName))) {
+					this.parentReference = ref;
+				}
+			}
+		}
+		return this.parentReference;
+	}
+
+	public String getTableName() {
+		if (mappingWrapper.getConfig() != null)
+			return mappingWrapper.getTableByPropertyName(getTypeName())
+					.getName();
+		else
+			return null;
+	}
+
+	public String getTypeName() {
+		return dataObject.getType().getName();
+	}
+
+	public void setPropagatedID(String propagatedID, int id) {
+		dataObject.setInt(propagatedID, id);
+	}
+}