KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > objectweb > cjdbc > scenario > raidb1 > pool > VariablePoolScenario


1 /**
2  * C-JDBC: Clustered JDBC.
3  * Copyright (C) 2002-2004 French National Institute For Research In Computer
4  * Science And Control (INRIA).
5  * Contact: c-jdbc@objectweb.org
6  *
7  * This library is free software; you can redistribute it and/or modify it
8  * under the terms of the GNU Lesser General Public License as published by the
9  * Free Software Foundation; either version 2.1 of the License, or any later
10  * version.
11  *
12  * This library is distributed in the hope that it will be useful, but WITHOUT
13  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
14  * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License
15  * for more details.
16  *
17  * You should have received a copy of the GNU Lesser General Public License
18  * along with this library; if not, write to the Free Software Foundation,
19  * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
20  *
21  * Initial developer(s): Nicolas Modrzyk.
22  * Contributor(s): ______________________.
23  */
24
25 package org.objectweb.cjdbc.scenario.raidb1.pool;
26
27 import java.sql.Connection JavaDoc;
28 import java.sql.PreparedStatement JavaDoc;
29 import java.sql.SQLException JavaDoc;
30 import java.sql.Statement JavaDoc;
31
32 import org.objectweb.cjdbc.scenario.templates.SimpleRaidb1Template;
33
34 /**
35  * Having problems with the variable pool
36  *
37  * @author <a HREF="mailto:Nicolas.Modrzyk@inrialpes.fr">Nicolas Modrzyk </a>
38  * @version 1.0
39  */
40 public class VariablePoolScenario extends SimpleRaidb1Template
41 {
42   /**
43    * @see junit.framework.TestCase#setUp()
44    */
45   protected void setUp()
46   {
47     super.setUp();
48     try
49     {
50       cm.loadVirtualDatabases(controller, "myDB", "hsqldb-thinks-oracle.xml");
51       mainVdb = controller.getVirtualDatabase("myDB");
52       mainVdb.enableAllBackends();
53     }
54     catch (Exception JavaDoc e)
55     {
56       e.printStackTrace();
57     }
58   }
59   
60   /**
61    * Test proposed by Marc
62    *
63    * @throws Exception if fails
64    */
65   public void testGetManyConnection() throws Exception JavaDoc
66   {
67     Connection JavaDoc aConnection = getCJDBCConnection();
68     aConnection.setAutoCommit(false);
69     Statement JavaDoc stmt = aConnection.createStatement();
70     try
71     {
72       stmt.executeUpdate("drop table test2");
73     }
74     catch (SQLException JavaDoc ignore)
75     {
76       // table unknown ?
77 }
78     stmt
79         .executeUpdate("create table test2 (id int, CONSTRAINT test_PK PRIMARY KEY(id))");
80     PreparedStatement JavaDoc insert = aConnection
81         .prepareStatement("insert into test2 (id) values (?)");
82     insert.setInt(1, 1);
83     insert.executeUpdate();
84     aConnection.commit();
85     aConnection.setAutoCommit(true);
86     aConnection.setAutoCommit(false);
87     insert = aConnection.prepareStatement("insert into test2 (id) values (?)");
88     insert.setInt(1, 2);
89     insert.executeUpdate();
90     aConnection.commit();
91     aConnection.setAutoCommit(true);
92     aConnection.close();
93   }
94 }
Popular Tags