[JBoss-dev] CVS update: jbosstest/src/main/org/jboss/test/xa/bean XATestBean.java

[Scott M Stark]

  User: starksm 
  Date: 01/07/08 18:06:07

  Modified:    src/main/org/jboss/test/xa/bean Tag: Branch_2_4
                        XATestBean.java
  Log:
  Merge latest changes from main to the 2.4 branch
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.2.2.1   +49 -1     jbosstest/src/main/org/jboss/test/xa/bean/XATestBean.java
  
  Index: XATestBean.java
  ===================================================================
  RCS file: /cvsroot/jboss/jbosstest/src/main/org/jboss/test/xa/bean/XATestBean.java,v
  retrieving revision 1.2
  retrieving revision 1.2.2.1
  diff -u -r1.2 -r1.2.2.1
  --- XATestBean.java   2001/01/07 23:14:43     1.2
  +++ XATestBean.java   2001/07/09 01:06:07     1.2.2.1
  @@ -14,7 +14,15 @@
   import javax.sql.DataSource;
   import org.jboss.test.xa.interfaces.CantSeeDataException;
   
  -public class XATestBean implements SessionBean {
  +public class XATestBean
  +    implements SessionBean
  +{
  +    public final static String DROP_TABLE =
  +        "DROP TABLE XA_TEST";
  +
  +    public final static String CREATE_TABLE =
  +        "CREATE TABLE XA_TEST(ID INTEGER NOT NULL PRIMARY KEY, DATA INTEGER NOT 
NULL)";
  +
       public final static String DB_1_NAME = "java:comp/env/jdbc/DBConnection1";
       public final static String DB_2_NAME = "java:comp/env/jdbc/DBConnection2";
   
  @@ -36,6 +44,46 @@
       public void setSessionContext(SessionContext parm1) throws EJBException {
       }
   
  +    protected void execute(DataSource ds, String sql) throws SQLException {
  +        Connection con = ds.getConnection();
  +        try {
  +            Statement s = con.createStatement();
  +            s.execute(sql);
  +            s.close();
  +        }
  +        finally {
  +            con.close();
  +        }
  +    }
  +
  +    protected void execute(Connection con, String sql) throws SQLException {
  +        Statement s = con.createStatement();
  +        s.execute(sql);
  +        s.close();
  +    }
  +    
  +    public void createTables() throws NamingException, SQLException {
  +        Context ctx = new InitialContext();
  +        try {
  +            DataSource ds1 = (DataSource)ctx.lookup(DB_1_NAME);
  +            try {
  +                execute(ds1, DROP_TABLE);
  +            }
  +            catch (Exception ignore) {}
  +            execute(ds1, CREATE_TABLE);
  +
  +            DataSource ds2 = (DataSource)ctx.lookup(DB_2_NAME);
  +            try {
  +                execute(ds2, DROP_TABLE);
  +            }
  +            catch (Exception ignore) {}
  +            execute(ds2, CREATE_TABLE);
  +        }
  +        finally {
  +            ctx.close();
  +        }
  +    }
  +    
       public void clearData() {
           try {
               Context ctx = new InitialContext();
  
  
  

_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development