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

 *    Release: @release@

 *

 *   '$Author: jones $'

 *     '$Date: 2004-03-26 17:40:45 -0800 (Fri, 26 Mar 2004) $'

 * '$Revision: 2068 $'

 *

 * 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.*;

/**

 * A class to test DBConnectionPool class

 */

public class JDBCTest

{

  /**

   * the main routine used to test how many sql command one connection can 

   * execute   

   * Usage: java -cp metacat.jar JDBC-diver-file  <-Driver driverName -t times>

   *

   * @param drivername, the jdbc dirver name for database

   * @param times, how many queries  will be run

   */

  public static void main(String [] args)

  {

    //instaniate a DBConnectionPool object

    //Becuase it is singleton, we should use getInstance method

    int loop = 10;

    String driverName = null;

    Connection conn = null;

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

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

    try

    {

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

      {

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

        {

          driverName=args[++i];

        }//if

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

        {

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

        }//else if 

        else 

        {

          System.err.println

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

        }//else

      }//for

      System.out.println("Driver name: "+driverName);

      //open and get one connection

      conn = getConnection(driverName);

      //use this connection excecute sql command

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

      {

        if (conn == null || conn.isClosed())

        {

          System.out.println("db conncetion is bad");

          break;

        }

        //System.out.println("metadata: "+conn.getMetaData());

        //System.out.println("warning: "+conn.getWarnings());

        insert(conn, index);

        select(conn);

        index++;

      }//for

      System.out.println("End");

    }//try

    catch (SQLException e)

    {

      System.out.println("error in sql: "+e.getMessage());

    }//catch

    catch (Exception ee)

    {

      System.out.println("error in other: "+ee.getMessage());

    }

    finally

    {

       try

       {

         conn.close();

       }

       catch (SQLException eee)

       {

         System.out.println("error in close connection: "+eee.getMessage());

       }

    }//finally

  }//main

  /**

   * Method to open a connection to database

   */

  private static Connection getConnection(String nameOfDriver) 

                                    throws SQLException, ClassNotFoundException

  {

    String url = null;

    String user = null;

    String password = null;

    url = MetaCatUtil.getOption("defaultDB");

    //System.out.println("url: "+url);

    user = MetaCatUtil.getOption("user");

    //System.out.println("user: "+user);

    password = MetaCatUtil.getOption("password");

    //System.out.println("password: "+password);

    //load Oracle dbDriver

    Class.forName(nameOfDriver);

    //System.out.println("after load dbDriver");

    //open and return connection

    return DriverManager.getConnection(url, user, password);

  }

  /**

   * Method to run a sal insert command

   * @param conn, the connection will be used

   * @param i, part of docid

   */

  private static void insert(Connection conn, long i) throws SQLException

  {

    int serialNumber = 0;

    //Connection conn = null;

    PreparedStatement pStmt = null;

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

    String docid = "jing."+i;

    try

    {

      pStmt = conn.prepareStatement(sql);

      pStmt.setString(1, docid);

      pStmt.execute();

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

     }

     finally

     {

       pStmt.close();

     }

  }//insert

  /**

   * Method to run a sql select commnad

   * @param conn, connection will be used

   */

  private static void select(Connection conn) throws SQLException

  {

    int serialNumber = 0;

    PreparedStatement pStmt = null;

    ResultSet rs = null;

    String sql = "select docid from xml_documents where docid like'%jing%'";

    try

    {

      pStmt = conn.prepareStatement(sql);

      pStmt.execute();

      rs = pStmt.getResultSet();

      if (rs.next())

      {

        String str = rs.getString(1);

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

      }

    }

    finally

    {

      pStmt.close();

    }

  }//select

}//DBConnectionPoolTester