Metacat

/**

 *    Purpose: A class that gets Accession Number, check for uniqueness

 *             and register it into db

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

 *             National Center for Ecological Analysis and Synthesis

 *    Authors: Jivka Bojilova, Matt Jones

 *     '$Date$'

 * '$Revision$'

package edu.ucsb.nceas.metacat;

import java.net.*;

import java.sql.*;

 * Generates a unique Accession Number or if provided check it

 * for uniqueness and register it into the db connection

 * (on update or delete of XML document)

 * Check for existance of provided Accession Number

 *

  private Connection conn = null;

  private String defaultGlobalName = null;

  private String sep = null;

   * Construct an AccessionNumber

   */

  public AccessionNumber ()

         throws SQLException, ClassNotFoundException  {

    this.defaultGlobalName = util.getOption("defaultGlobalName");

    this.sep = util.getOption("accNumberSeparator");

    // Open a connection to the database

    this.conn = util.openDBConnection();

  }

  /**

   * Construct an AccessionNumber

   *

   * @param conn the db connection to read from and write Accession# to

   */

  public AccessionNumber (Connection conn) {

    this.sep = util.getOption("accNumberSeparator");

    this.conn = conn;

   * Get an Accession Number, check it for uniqueness and

   * register it into db connection. If no Accession Number is

   * provided, generate one from the database and return it.

   *

   * @param accNumber - Accession # if provided or null if not

   * @param action - INSERT, UPDATE or DELETE.

   * When "INSERT" and accession # provided is not unique, get new one.

   * If it is unique, use it.

   * When "INSERT" and accession # is null, get a new one.

   * When "UPDATE", accession # is required and it is checked for existance.

   * When "DELETE", accession # is required and it is checked for existance.

   */

  public String generate (String accNumber, String action)

         throws AccessionNumberException, SQLException   {

    String globalName = null;

    String localId = null;

      conn.setAutoCommit(true);

      // split the acc # in 2 parts - global name & local id

      if ( accNumber != null ) {

        globalName = getGlobalName(accNumber, sep);

        localId = getLocalId(accNumber, sep);

      }

      // register unique acc #

      if ( action.equals("INSERT")) {

        if ( accNumber == null )

          return put(defaultGlobalName, null, sep);

        else

          return put(globalName, localId, sep);

      } else if ( action.equals("UPDATE") || action.equals("DELETE")) {

        if ( accNumber == null ) {

          throw (new AccessionNumberException("Accession number is " +

          "required."));

        } else if (!accNumberIsCurrent(accNumber)) {

          throw (new AccessionNumberException("Document " +

          "not found for accession #: " + accNumber));

        } else {

          return (globalName + sep + localId);

        }

      }

      MetaCatUtil.debugMessage(

                 "Error on AccessionNumber.generate(): " +

                  siobe.getMessage());

      throw (new AccessionNumberException("Accession number invalid, " +

                 "expecting character \'" + sep + "'."));

    } catch (SQLException e) {

      throw new SQLException(

                 "Error on AccessionNumber.generate(accNumber, action): " +

                  e.getMessage());

    }

           "accession number generation: "));

  }

  private String put (String globalName, String localId, String sep)

    try {

      if ( localId == null )

         l = new Integer(get(globalName) + 1);

      else if ( accNumberUsed(globalName, localId) )

         l = new Integer(get(globalName) + 1);

      else

         l = new Integer(localId);

     PreparedStatement pstmt;

     pstmt = conn.prepareStatement(

             "INSERT INTO xml_acc_numbers (global_name, local_id) " +

             "VALUES (?, ?)");

     pstmt.setString(1,globalName);

     pstmt.setString(2,l.toString());

     pstmt.execute();

      throw new SQLException(

            "Error on AccessionNumber.put(globalName, localId, sep): "

            + e.getMessage());

    }

  }

  /** check for existence of Accesssion Number xml_acc_numbers table */

  private boolean accNumberUsed(String globalName, String localId)

                      throws SQLException {

      PreparedStatement pstmt;

      pstmt = conn.prepareStatement(

                "WHERE global_name LIKE ? AND local_id = ?");

      pstmt.setString(2,localId);

      pstmt.execute();

      ResultSet rs = pstmt.getResultSet();

      hasAccNumber = rs.next();

      pstmt.close();

      throw new SQLException(

                "Error on AccessionNumber.accNumberUsed(globalName, " +

                  "localId): " + e.getMessage());

    }

  }

  private boolean accNumberIsCurrent(String accNumber) throws SQLException {

      PreparedStatement pstmt;

      pstmt = conn.prepareStatement(

                "WHERE docid LIKE ?");

      pstmt.execute();

      ResultSet rs = pstmt.getResultSet();

      hasCurrentAccNumber = rs.next();

      pstmt.close();

      throw new SQLException(

          "Error on AccessionNumber.accNumberIsCurrent(String accNumber): " +

          e.getMessage());

    return hasCurrentAccNumber;

  }

  private int get (String globalName) throws SQLException  {

    try {

      PreparedStatement pstmt;

      pstmt = conn.prepareStatement(

              "SELECT max(local_id) FROM xml_acc_numbers " +

              "WHERE global_name LIKE ?");

      pstmt.setString(1,globalName);

      pstmt.execute();

      ResultSet rs = pstmt.getResultSet();

      boolean hasLocalId = rs.next();

        return rs.getInt(1);

      }

    } catch (SQLException e) {

      throw new SQLException(

            "Error on AccessionNumber.get(globalName): " + e.getMessage());

    }

  }

  private String getGlobalName (String accNumber, String sep)

          throws StringIndexOutOfBoundsException {

  }

  private String getLocalId (String accNumber, String sep)

          throws StringIndexOutOfBoundsException {

  }

 * '$Log$

 * 'cleared static methods in AccessionNumber classes for fixing bug found

 * 'when multiple requests to the servlet at a time.

 * '

 * 'Added "release" keyword to all metacat source files so that the release

 * 'number will be evident in software distributions.

 * '

 * 'Fixed bugs associated with the new UPDATE and DELETE functions of

 * 'DBWriter.  There were problematic interactions between some static

 * 'variables used in DBEntityResolver and the way in which the

 * 'Servlet objects are re-used across multiple client invocations.

 * '

 * 'Generally cleaned up error reporting.  Now all errors and success

 * 'results are reported as XML documents from MetaCatServlet.  Need

 * 'to make the command line tools do the same.

 * '

 * 'Merged in substantial changes to DBWriter and associated classes and to

 * 'the MetaCatServlet in order to accomodate the new UPDATE and DELETE

 * 'functions.  The command line tools and the parameters for the

 * 'servlet have changed substantially.

 * '

 * 'Added DELETE feature to DBWriter.  Now takes an action "DELETE" and a

 * 'docid and will move the record from the xml_documents table to the

 * 'xml_revisions table.

 * 'Modified option parsing to support option symbols on command line.

 * '

 * 'Revision 1.8.2.4  2000/06/25 23:11:40  jones

 * 'Documentation update

 * '

 * 'Revision 1.8.2.3  2000/06/25 23:08:31  jones

 * 'Minor change to excpetion handling

 * ''

 */