You are viewing a plain text version of this content. The canonical link for it is here.
Posted to ojb-dev@db.apache.org by br...@apache.org on 2003/09/24 15:11:12 UTC
cvs commit: db-ojb/src/test/org/apache/ojb/otm MultipleConnectionsTest.java
brianm 2003/09/24 06:11:12
Added: src/test/org/apache/ojb/otm MultipleConnectionsTest.java
Log:
Tests multiple connections querying in one transaction
Revision Changes Path
1.1 db-ojb/src/test/org/apache/ojb/otm/MultipleConnectionsTest.java
Index: MultipleConnectionsTest.java
===================================================================
package org.apache.ojb.otm;
/* ====================================================================
* The Apache Software License, Version 1.1
*
* Copyright (c) 2001 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The end-user documentation included with the redistribution,
* if any, must include the following acknowledgment:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowledgment may appear in the software itself,
* if and wherever such third-party acknowledgments normally appear.
*
* 4. The names "Apache" and "Apache Software Foundation" and
* "Apache ObjectRelationalBridge" must not be used to endorse or promote products
* derived from this software without prior written permission. For
* written permission, please contact apache@apache.org.
*
* 5. Products derived from this software may not be called "Apache",
* "Apache ObjectRelationalBridge", nor may "Apache" appear in their name, without
* prior written permission of the Apache Software Foundation.
*
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
* ====================================================================
*
* This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation. For more
* information on the Apache Software Foundation, please see
* <http://www.apache.org/>.
*/
import junit.framework.TestCase;
import junit.framework.Assert;
import org.apache.ojb.broker.Article;
import org.apache.ojb.broker.Identity;
import org.apache.ojb.broker.InterfaceArticle;
import org.apache.ojb.broker.PersistenceBrokerFactory;
import org.apache.ojb.broker.query.Criteria;
import org.apache.ojb.broker.query.Query;
import org.apache.ojb.broker.query.QueryFactory;
import org.apache.ojb.odmg.oql.EnhancedOQLQuery;
import org.apache.ojb.otm.core.Transaction;
import java.util.Collection;
import java.util.Iterator;
/**
* Ensure a Transaction can attach multiple connections
*/
public class MultipleConnectionsTest extends TestCase
{
public MultipleConnectionsTest(String name)
{
super(name);
}
private TestKit _kit;
public void setUp()
{
_kit = TestKit.getTestInstance();
}
public void tearDown()
{
}
public void testJustAttachConnections() throws Throwable
{
Transaction tx = null;
Article example;
OTMConnection conn1 = _kit.acquireConnection(PersistenceBrokerFactory.getDefaultKey());
OTMConnection conn2 = _kit.acquireConnection(PersistenceBrokerFactory.getDefaultKey());
try
{
tx = _kit.getTransaction(conn1);
tx.begin();
tx.registerConnection(conn2);
example = (Article) conn1.getObjectByIdentity(
new Identity(Article.class, Article.class,
new Object[]{new Integer(77779)}));
if (example == null)
{
example = Article.createInstance();
example.setArticleId(77779);
}
example.setProductGroupId(7);
example.setStock(333);
example.setArticleName("333");
conn1.makePersistent(example);
EnhancedOQLQuery query = conn2.newOQLQuery();
query.create("select obj from " + Article.class.getName()
+ " where " + "articleId = " + example.getArticleId());
Article same = (Article) conn2.getIteratorByOQLQuery(query).next();
Assert.assertNotNull("Didn't find object in context of transaction", same);
tx.commit();
}
catch (Throwable ex)
{
try
{
if (tx != null && tx.isInProgress())
{
tx.rollback();
}
}
catch (Exception ex2)
{
}
throw ex;
}
finally
{
conn1.close();
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: ojb-dev-unsubscribe@db.apache.org
For additional commands, e-mail: ojb-dev-help@db.apache.org