summaryrefslogtreecommitdiff
path: root/projects/net.wotonomy.persistence/src/main/java/net/wotonomy/access/EOAdaptorContext.java
blob: 35a1468c997a45adf2b51415de71c0911e39c1eb (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
/*
 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.foundation.NSArray;
import net.wotonomy.foundation.NSMutableArray;
import net.wotonomy.foundation.NSNotificationCenter;

/**
 *
 * @author ezamudio@nasoft.com
 * @author $Author: cgruber $
 * @version $Revision: 894 $
 */

public abstract class EOAdaptorContext {

	public static final String AdaptorContextBeginTransactionNotification = "AdaptorContextBeginTransaction";
	public static final String AdaptorContextCommitTransactionNotification = "AdaptorContextCommitTransaction";
	public static final String AdaptorContextRollbackTransactionNotification = "AdaptorContextRollbackTransaction";

	protected EOAdaptor _adaptor;
	protected NSMutableArray _channels = new NSMutableArray();
	protected boolean _hasOpenTransaction;

	public EOAdaptorContext(EOAdaptor adaptor) {
		super();
		_adaptor = adaptor;
	}

	public EOAdaptor adaptor() {
		return _adaptor;
	}

	public abstract void beginTransaction();

	public abstract void commitTransaction();

	public abstract void rollbackTransaction();

	public abstract EOAdaptorChannel createAdaptorChannel();

	public abstract void handleDroppedConnection();

	public NSArray channels() {
		return new NSArray(_channels);
	}

	public boolean hasBusyChannels() {
		for (int i = 0; i < _channels.count(); i++) {
			EOAdaptorChannel chan = (EOAdaptorChannel) _channels.objectAtIndex(i);
			if (chan.isFetchInProgress())
				return true;
		}
		return false;
	}

	public boolean hasOpenChannels() {
		for (int i = 0; i < _channels.count(); i++) {
			EOAdaptorChannel chan = (EOAdaptorChannel) _channels.objectAtIndex(i);
			if (chan.isOpen())
				return true;
		}
		return false;
	}

	public boolean hasOpenTransaction() {
		return _hasOpenTransaction;
	}

	public void transactionDidBegin() {
		_hasOpenTransaction = true;
		NSNotificationCenter.defaultCenter().postNotification(AdaptorContextBeginTransactionNotification, this);
	}

	public void transactionDidCommit() {
		_hasOpenTransaction = false;
		NSNotificationCenter.defaultCenter().postNotification(AdaptorContextCommitTransactionNotification, this);
	}

	public void transactionDidRollback() {
		_hasOpenTransaction = false;
		NSNotificationCenter.defaultCenter().postNotification(AdaptorContextRollbackTransactionNotification, this);
	}

}
/*
 * $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.1 2003/08/13 00:37:45 chochos an almost complete implementation of
 * the abstract adaptor-layer classes
 *
 */