Metacat

/**

 *  '$RCSfile$'

 *    Purpose: A class to test how many sql command one connection can execute

 *  Copyright: 2000 Regents of the University of California and the

 *             National Center for Ecological Analysis and Synthesis

 *    Authors: Jing Tao

 *

 *   '$Author: leinfelder $'

 *     '$Date: 2011-11-02 20:40:12 -0700 (Wed, 02 Nov 2011) $'

 * '$Revision: 6595 $'

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 */

import java.io.*;

import java.util.Vector;

import java.lang.*;

import java.sql.*;

import edu.ucsb.nceas.metacat.*;

import edu.ucsb.nceas.metacat.database.*;

/**

 * A class to test when mamimum dbconnection number reached

 */

public class MaxmumDBConnection implements Runnable

{

  /**

   * Usage: java -cp metacat.jar   < -t times>

   *

   */

  public static void main(String [] args) throws Exception

  {

    // defaul loop value is 10

    int loop = 10;

    Thread runner = null;

    DBConnectionPool pool = DBConnectionPool.getInstance();

    // get loop number from argument

    for ( int i=0 ; i < args.length; ++i ) 

    {

      if ( args[i].equals( "-t" ) ) 

      {

          loop =  Integer.parseInt(args[++i]);

      }//if 

      else 

      {

          System.err.println("   args[" +i+ "] '" +args[i]+ "' ignored." );

      }//else

    }//for

    System.out.println("loop: "+loop);

    //ran the number of thread.

    for (int i= 0; i<loop; i++)

    {

          runner = new Thread( new MaxmumDBConnection());

          runner.start();

    }//for

    System.out.println("End");

  }//main

  /**

   * Method to run a sal insert command

   * @param conn, the connection will be used

   * @param i, part of docid

   */

  private static void insert(long i) throws SQLException

  {

    int serialNumber = 0;

    DBConnection conn = null;

    PreparedStatement pStmt = null;

    String sql = "insert into xml_documents (docid) values (?)";

    String docid = "jing."+i;

    try 

    {

      conn = DBConnectionPool.getDBConnection("insert");

      serialNumber = conn.getCheckOutSerialNumber();

      System.out.println("serialNumber: "+serialNumber);

      pStmt = conn.prepareStatement(sql);

      pStmt.setString(1, docid);

      pStmt.execute();

      System.out.println("Inserted successfully: "+i);

     }

     finally

     {

       try

       {

          pStmt.close();

       }

       finally

       {

          DBConnectionPool.returnDBConnection(conn, serialNumber);

          System.out.println("return inert conn!");

          System.out.println("the return insert connection's status: "

                                                 +conn.getStatus());

       }

     }

  }//insert

  /**

   * Method to run a sql select commnad

   * @param conn, connection will be used

   */

  private static void select() throws SQLException

  {

    int serialNumber = 0;

    DBConnection conn = null;

    PreparedStatement pStmt = null;

    ResultSet rs = null;

    String sql = "select docid from xml_documents where docid like ?";

    try

    {

      conn = DBConnectionPool.getDBConnection("select");

      serialNumber = conn.getCheckOutSerialNumber();

      System.out.println("serialNumber: "+serialNumber);

      pStmt = conn.prepareStatement(sql);

      pStmt.setString(1, "%jing%");

      pStmt.execute();

      rs = pStmt.getResultSet();

      if (rs.next())

      {

        String str = rs.getString(1);

        System.out.println("Select docid: "+str);

      }//if

    }//try

    finally

    {

      try

      {

        pStmt.close();

      }//try

      finally

      {

        DBConnectionPool.returnDBConnection(conn,serialNumber);

        System.out.println("return select conn!");

        System.out.println("the return insert connection's status: "

                                                        +conn.getStatus());

      }//finally

    }//fianlly

  }//select

  public void run()

  {

     long index = (new Double (Math.random()*100000)).longValue();

     try

     {

       insert(index);

       select();

     }//try

     catch (SQLException e)

     {

       System.out.println("error is run: "+e.getMessage());

     }

  }

}//DBConnectionPoolTester