cvs commit: db-ojb/src/test/org/apache/ojb/compare PerformanceBaseTest.java

[arminw]

arminw      2005/12/30 10:23:57

  Modified:    src/test/org/apache/ojb/compare Tag: OJB_1_0_RELEASE
                        PerformanceBaseTest.java
  Log:
  fix test, add hsql shutdown call
  
  Revision  Changes    Path
  No                   revision
  No                   revision
  1.1.2.2   +44 -0     
db-ojb/src/test/org/apache/ojb/compare/PerformanceBaseTest.java
  
  Index: PerformanceBaseTest.java
  ===================================================================
  RCS file: 
/home/cvs/db-ojb/src/test/org/apache/ojb/compare/PerformanceBaseTest.java,v
  retrieving revision 1.1.2.1
  retrieving revision 1.1.2.2
  diff -u -r1.1.2.1 -r1.1.2.2
  --- PerformanceBaseTest.java  26 Apr 2005 22:03:16 -0000      1.1.2.1
  +++ PerformanceBaseTest.java  30 Dec 2005 18:23:57 -0000      1.1.2.2
  @@ -2,10 +2,17 @@
   
   import java.sql.Connection;
   import java.sql.PreparedStatement;
  +import java.sql.Statement;
  +import java.sql.SQLException;
   
   import org.apache.ojb.broker.metadata.ClassDescriptor;
   import org.apache.ojb.broker.util.logging.Logger;
   import org.apache.ojb.broker.util.logging.LoggerFactory;
  +import org.apache.ojb.broker.platforms.PlatformHsqldbImpl;
  +import org.apache.ojb.broker.platforms.Platform;
  +import org.apache.ojb.broker.query.Query;
  +import org.apache.ojb.broker.query.QueryFactory;
  +import org.apache.ojb.broker.HsqldbShutdown;
   import org.apache.ojb.junit.PBTestCase;
   
   /**
  @@ -79,6 +86,7 @@
           try
           {
               clearTable();
  +            shutdown();
               super.tearDown();
           }
           catch(Exception e)
  @@ -225,4 +233,40 @@
               throw e;
           }
       }
  +
  +    public void shutdown()
  +    {
  +        Platform platform = 
broker.serviceConnectionManager().getSupportedPlatform();
  +
  +        if(platform instanceof PlatformHsqldbImpl)
  +        {
  +            Connection con = null;
  +            Statement stmt = null;
  +
  +            try
  +            {
  +                con = broker.serviceConnectionManager().getConnection();
  +                stmt = con.createStatement();
  +                stmt.execute("shutdown");
  +            }
  +            catch (Exception e)
  +            {
  +                e.printStackTrace();
  +            }
  +            finally
  +            {
  +                try
  +                {
  +                    if(con != null) con.close();
  +                    if(stmt != null) stmt.close();
  +
  +                }
  +                catch (SQLException e1)
  +                {
  +                    e1.printStackTrace();
  +                }
  +            }
  +        }
  +
  +    }
   }
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]