1 files changed, 138 insertions, 0 deletions
diff --git a/projects/net.wotonomy.persistence/src/main/java/net/wotonomy/access/EODatabaseChannel.java b/projects/net.wotonomy.persistence/src/main/java/net/wotonomy/access/EODatabaseChannel.java
new file mode 100644
index 0000000..10424e9
--- /dev/null
+++ b/projects/net.wotonomy.persistence/src/main/java/net/wotonomy/access/EODatabaseChannel.java
@@ -0,0 +1,138 @@
+/*
+ Wotonomy: OpenStep design patterns for pure Java applications.
+ Copyright (C) 2001 Michael Powers
+
+ This library is free software; you can redistribute it and/or
+ modify it under the terms of the GNU Lesser General Public
+ License as published by the Free Software Foundation; either
+ version 2.1 of the License, or (at your option) any later version.
+
+ This library 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
+ Lesser General Public License for more details.
+
+ You should have received a copy of the GNU Lesser General Public
+ License along with this library; if not, see http://www.gnu.org
+ */
+package net.wotonomy.access;
+
+import net.wotonomy.control.EOClassDescription;
+import net.wotonomy.control.EOEditingContext;
+import net.wotonomy.control.EOFetchSpecification;
+import net.wotonomy.control.EOGlobalID;
+import net.wotonomy.control.EOKeyValueCodingAdditions;
+import net.wotonomy.foundation.NSArray;
+import net.wotonomy.foundation.NSDictionary;
+import net.wotonomy.foundation.NSMutableArray;
+
+/**
+*
+* @author ezamudio@nasoft.com
+* @author $Author: cgruber $
+* @version $Revision: 894 $
+*/
+public class EODatabaseChannel {
+
+	protected EODatabaseContext _context;
+	protected EOAdaptorChannel _channel;
+	protected EOEntity _currEntity;
+	protected EOEditingContext _currEC;
+	protected NSArray _attributes;
+	protected boolean _locking;
+	protected boolean _refreshing;
+
+	public EODatabaseChannel(EODatabaseContext context) {
+		super();
+		_context = context;
+		_channel = _context.adaptorContext().createAdaptorChannel();
+	}
+
+	public EOAdaptorChannel adaptorChannel() {
+		return _channel;
+	}
+
+	public EODatabaseContext databaseContext() {
+		return _context;
+	}
+
+	public void cancelFetch() {
+		_channel.cancelFetch();
+	}
+
+	public Object fetchObject() {
+		NSDictionary r = _channel.fetchRow();
+		EOGlobalID gid = _currEntity.globalIDForRow(r);
+		Object eo = _currEC.objectForGlobalID(gid);
+		if (eo == null) {
+			eo = EOClassDescription.classDescriptionForEntityName(_currEntity.name()).createInstanceWithEditingContext(_currEC, gid);
+			if (eo instanceof EOKeyValueCodingAdditions)
+				((EOKeyValueCodingAdditions)eo).takeValuesFromDictionary(r);
+			else
+				EOKeyValueCodingAdditions.DefaultImplementation.takeValuesFromDictionary(eo, r);
+		} else {
+			if (isRefreshingObjects()) {
+				//TODO: refresh object (how?)
+			}
+		}
+		return eo;
+	}
+
+	public boolean isFetchInProgress() {
+		return _channel.isFetchInProgress();
+	}
+
+	public void setIsLocking(boolean flag) {
+		_locking = flag;
+	}
+
+	public boolean isLocking() {
+		return _locking;
+	}
+
+	public void setIsRefreshingObjects(boolean flag) {
+		_refreshing = flag;
+	}
+
+	public boolean isRefreshingObjects() {
+		return _refreshing;
+	}
+
+	public void selectObjectsWithFetchSpecification(EOFetchSpecification fspec, EOEditingContext ec) {
+		setIsLocking(fspec.locksObjects());
+		setIsRefreshingObjects(fspec.refreshesRefetchedObjects());
+		setCurrentEditingContext(ec);
+		setCurrentEntity(databaseContext().database().entityNamed(fspec.entityName()));
+		NSMutableArray atts = new NSMutableArray();
+		atts.addObjectsFromArray(_currEntity.attributes());
+		adaptorChannel().selectAttributes(atts, fspec, isLocking(), _currEntity);
+		adaptorChannel().setAttributesToFetch(atts);
+		_attributes = atts;
+	}
+
+	public void setCurrentEditingContext(EOEditingContext ec) {
+		_currEC = ec;
+	}
+
+	public void setCurrentEntity(EOEntity entity) {
+		_currEntity = entity;
+	}
+
+}
+/*
+ * $Log$
+ * Revision 1.2  2006/02/16 16:47:14  cgruber
+ * Move some classes in to "internal" packages and re-work imports, etc.
+ *
+ * Also use UnsupportedOperationExceptions where appropriate, instead of WotonomyExceptions.
+ *
+ * Revision 1.1  2006/02/16 13:19:57  cgruber
+ * Check in all sources in eclipse-friendly maven-enabled packages.
+ *
+ * Revision 1.2  2003/08/29 21:15:46  chochos
+ * use EOEntity's globalIDForRow method.
+ *
+ * Revision 1.1  2003/08/19 01:54:43  chochos
+ * The EODatabase layer still needs a lot of work, but it's on its way...
+ *
+ */
+\ No newline at end of file