perftest.java.version_2

Expert Oracle Database Architecture 9i and 10g sql源码

import java.sql.*;
import oracle.jdbc.OracleDriver;
import java.util.Date;
public class perftest
{
  public static void main (String arr[]) throws Exception
  {
    DriverManager.registerDriver(new oracle.jdbc.OracleDriver());
    Connection con = DriverManager.getConnection
          ("jdbc:oracle:thin:@localhost.localdomain:1521:ora10g",
            "scott", "tiger");

    Integer iters = new Integer(arr[0]);
    Integer commitCnt = new Integer(arr[1]);

    con.setAutoCommit(false);
    doInserts( con, 1, 1 );

    Statement stmt = con.createStatement ();
    stmt.execute
    ( "begin dbms_monitor.session_trace_enable(waits=>TRUE); end;" );

    doInserts( con, iters.intValue(), commitCnt.intValue() );
    doInserts( con, iters.intValue(), iters.intValue() );
    con.commit();
    con.close();
  }
  static void doInserts(Connection con, int count, int commitCount )
  throws Exception
  {
    PreparedStatement ps =
       con.prepareStatement
       ("insert into test " +
        "(id, code, descr, insert_user, insert_date)"
        + " values (?,?,?, user, sysdate)");

    PreparedStatement commit =
       con.prepareStatement
       ("begin /* commit size = " + commitCount + " */ commit; end;" );

    int  rowcnt = 0;
    int  committed = 0;
    long start = new Date().getTime();
    for (int i = 0; i < count; i++ )
    {
      ps.setInt(1,i);
      ps.setString(2,"PS - code" + i);
      ps.setString(3,"PS - desc" + i);
      ps.executeUpdate();
      rowcnt++;
      if ( rowcnt == commitCount )
      {
        commit.executeUpdate();
        rowcnt = 0;
        committed++;
      }
    }
    con.commit();
    long end = new Date().getTime();
    System.out.println
    ("pstatement " + count + " times in " + 
     (end - start) + " milli seconds committed = "+committed);
  }
}