001: /*
002: * ====================================================================
003: * JAFFA - Java Application Framework For All
004: *
005: * Copyright (C) 2002 JAFFA Development Group
006: *
007: * This library is free software; you can redistribute it and/or
008: * modify it under the terms of the GNU Lesser General Public
009: * License as published by the Free Software Foundation; either
010: * version 2.1 of the License, or (at your option) any later version.
011: *
012: * This library is distributed in the hope that it will be useful,
013: * but WITHOUT ANY WARRANTY; without even the implied warranty of
014: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
015: * Lesser General Public License for more details.
016: *
017: * You should have received a copy of the GNU Lesser General Public
018: * License along with this library; if not, write to the Free Software
019: * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
020: *
021: * Redistribution and use of this software and associated documentation ("Software"),
022: * with or without modification, are permitted provided that the following conditions are met:
023: * 1. Redistributions of source code must retain copyright statements and notices.
024: * Redistributions must also contain a copy of this document.
025: * 2. Redistributions in binary form must reproduce the above copyright notice,
026: * this list of conditions and the following disclaimer in the documentation
027: * and/or other materials provided with the distribution.
028: * 3. The name "JAFFA" must not be used to endorse or promote products derived from
029: * this Software without prior written permission. For written permission,
030: * please contact mail to: jaffagroup@yahoo.com.
031: * 4. Products derived from this Software may not be called "JAFFA" nor may "JAFFA"
032: * appear in their names without prior written permission.
033: * 5. Due credit should be given to the JAFFA Project (http://jaffa.sourceforge.net).
034: *
035: * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED
036: * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
037: * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
038: * DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
039: * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
040: * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
041: * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
042: * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
043: * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
044: * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
045: * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
046: * SUCH DAMAGE.
047: * ====================================================================
048: */
049:
050: package org.jaffa.persistence.blackboxtests;
051:
052: import junit.framework.TestCase;
053: import org.jaffa.persistence.UOW;
054: import org.jaffa.persistence.exceptions.UOWException;
055:
056: /**
057: * This has connection pool related tests
058: * @author GautamJ
059: * @version
060: */
061: public class ConnectionPoolTest extends TestCase {
062:
063: /** Creates new QueryTest */
064: public ConnectionPoolTest(String name) {
065: super (name);
066: }
067:
068: /** This test will create the 'maximumConnections as defined in init.xml' number of UOW objects. It will then try to create one more UOW, which is expected to throw an exception.
069: */
070: public void testConnectionsExhausted() {
071: UOW[] uows = null;
072: UOW oneMoreUow = null;
073: try {
074: // obtain the maximum number of connections from the pool
075: int maximumConnections = Integer
076: .parseInt((String) Wrapper.getDatabaseInfo().get(
077: Wrapper.MAXIMUM_CONNECTIONS));
078: uows = new UOW[maximumConnections];
079: for (int i = 0; i < uows.length; i++)
080: uows[i] = new UOW();
081:
082: // now create an additional UOW, which is expected to throw an exception
083: try {
084: oneMoreUow = new UOW();
085: fail("Able to create an UOW even after maximum number of connections were obtained !!");
086: } catch (UOWException e) {
087: // This is expected.. do nothing
088: }
089:
090: } catch (Exception e) {
091: e.printStackTrace();
092: fail();
093:
094: } finally {
095: try {
096: if (oneMoreUow != null)
097: oneMoreUow.rollback();
098:
099: if (uows != null) {
100: for (int i = 0; i < uows.length; i++) {
101: if (uows[i] != null) {
102: uows[i].rollback();
103: uows[i] = null;
104: }
105: }
106: }
107: } catch (Exception e) {
108: e.printStackTrace();
109: fail();
110: }
111: }
112: }
113:
114: /** This test will obtain the maximumConnections and relase them. The process will be repeated 100 times.
115: */
116: public void testConnectionPoolRobustness() {
117: UOW[] uows = null;
118: try {
119: int maximumConnections = Integer
120: .parseInt((String) Wrapper.getDatabaseInfo().get(
121: Wrapper.MAXIMUM_CONNECTIONS));
122: for (int iteration = 0; iteration < 100; iteration++) {
123: // obtain the maximum number of connections from the pool
124: uows = new UOW[maximumConnections];
125: for (int i = 0; i < uows.length; i++)
126: uows[i] = new UOW();
127:
128: // Now release the connections
129: for (int i = 0; i < uows.length; i++) {
130: uows[i].rollback();
131: uows[i] = null;
132: }
133: uows = null;
134: }
135:
136: } catch (Exception e) {
137: e.printStackTrace();
138: fail();
139:
140: } finally {
141: try {
142: if (uows != null) {
143: for (int i = 0; i < uows.length; i++) {
144: if (uows[i] != null) {
145: uows[i].rollback();
146: uows[i] = null;
147: }
148: }
149: }
150: } catch (Exception e) {
151: e.printStackTrace();
152: fail();
153: }
154: }
155: }
156:
157: }
|