001: /*--
002:
003: Copyright (C) 2002-2005 Adrian Price.
004: All rights reserved.
005:
006: Redistribution and use in source and binary forms, with or without
007: modification, are permitted provided that the following conditions
008: are met:
009:
010: 1. Redistributions of source code must retain the above copyright
011: notice, this list of conditions, and the following disclaimer.
012:
013: 2. Redistributions in binary form must reproduce the above copyright
014: notice, this list of conditions, and the disclaimer that follows
015: these conditions in the documentation and/or other materials
016: provided with the distribution.
017:
018: 3. The names "OBE" and "Open Business Engine" must not be used to
019: endorse or promote products derived from this software without prior
020: written permission. For written permission, please contact
021: adrianprice@sourceforge.net.
022:
023: 4. Products derived from this software may not be called "OBE" or
024: "Open Business Engine", nor may "OBE" or "Open Business Engine"
025: appear in their name, without prior written permission from
026: Adrian Price (adrianprice@users.sourceforge.net).
027:
028: THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
029: WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
030: OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
031: DISCLAIMED. IN NO EVENT SHALL THE AUTHOR(S) BE LIABLE FOR ANY DIRECT,
032: INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
033: (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
034: SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
035: HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
036: STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
037: IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
038: POSSIBILITY OF SUCH DAMAGE.
039:
040: For more information on OBE, please see
041: <http://obe.sourceforge.net/>.
042:
043: */
044:
045: package org.obe.test;
046:
047: import org.obe.client.api.repository.RepositoryException;
048: import org.obe.spi.service.InstanceRepository;
049: import org.obe.spi.service.ProcessRepository;
050: import org.obe.spi.service.ServiceManager;
051: import org.obe.xpdl.model.misc.AbstractWFElement;
052:
053: import java.io.IOException;
054: import java.util.Date;
055: import java.util.Properties;
056:
057: /**
058: * An abstract base class for repository tests.
059: *
060: * @author Adrian Price
061: */
062: public abstract class AbstractRepositoryTest extends OBETestCase {
063: private static final int MILLIS_PER_SEC = 1000;
064: protected static ServiceManager _svcMgr;
065: protected static ProcessRepository _processRepository;
066: protected static InstanceRepository _instanceRepository;
067: private Properties _svcMgrProps;
068:
069: protected AbstractRepositoryTest(String name, Properties svcMgrProps) {
070: super (name);
071: _svcMgrProps = svcMgrProps;
072: }
073:
074: protected void checkCount(String hint, int expected,
075: Object[] elements) {
076: assertEquals(hint + " count is wrong;", expected,
077: elements.length);
078: for (int i = 0; i < elements.length; i++) {
079: assertNull(hint + " count returned an entity;", elements[i]);
080: }
081: }
082:
083: protected void checkIds(String hint, String[] expected,
084: AbstractWFElement[] elements) {
085:
086: String[] actualIds = new String[elements.length];
087: for (int i = 0; i < elements.length; i++)
088: actualIds[i] = elements[i].getId();
089: checkIds(hint, expected, actualIds);
090: }
091:
092: protected void checkIds(String hint, String[] expected,
093: String[] actual) {
094: assertEquals(hint + " count is wrong;", expected.length,
095: actual.length);
096: boolean[] found = new boolean[expected.length];
097: for (int i = 0; i < actual.length; i++) {
098: String id = actual[i];
099: for (int j = 0; j < expected.length; j++) {
100: if (id.equals(expected[j])) {
101: found[j] = true;
102: break;
103: }
104: }
105: }
106: for (int i = 0; i < found.length; i++) {
107: if (!found[i])
108: fail(hint + " query failed to find ID = " + expected[i]);
109: }
110: }
111:
112: // This method returns a date from which the milliseconds component has
113: // been removed. This is because some databases only support a date/time
114: // resolution of one second.
115: protected static Date ignoreMillis(Date date) {
116: if (date != null) {
117: long millis = date.getTime();
118: if (millis % MILLIS_PER_SEC != 0)
119: date = new Date(millis - millis % MILLIS_PER_SEC);
120: }
121: return date;
122: }
123:
124: protected void initializeRepositories() throws IOException,
125: RepositoryException {
126:
127: // If the subclass constructor passed service manager properties, use
128: // them; otherwise, use the system properties and configuration file.
129: _svcMgr = _svcMgrProps == null ? new ServiceManager()
130: : new ServiceManager(_svcMgrProps);
131: _svcMgr.init();
132: _processRepository = _svcMgr.getProcessRepository();
133: _instanceRepository = _svcMgr.getInstanceRepository();
134: _instanceRepository.purge();
135: _processRepository.purge();
136: getLogger().info("Repositories initialized");
137: }
138:
139: protected void uninitializeRepositories() throws IOException,
140: RepositoryException {
141:
142: _svcMgr.exit();
143: _svcMgr = null;
144: _processRepository = null;
145: _instanceRepository = null;
146: getLogger().info("Repositories uninitialized");
147: }
148: }
|