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$'

 * 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

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 String rev = null;

   * Construct an AccessionNumber

   */

         //throws SQLException, ClassNotFoundException

  //{

  //}

  /**

   * Construct an AccessionNumber

   *

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

   */

    this.sep = MetaCatUtil.getOption("accNumSeparator");

   * Construct an AccessionNumber

   *

   * @param conn the db connection to read Accession number from

   * @param accnum the accession number to be checked for validness

   */

 {

    this.rev = null;

    this.docid = accnum;

    if ( accnum != null ) {

      int firstIndex = accnum.indexOf(this.sep);

      int lastIndex = accnum.lastIndexOf(this.sep);

      if ( firstIndex != lastIndex ) {

        //this docid contains a revision number

        this.rev = accnum.substring(lastIndex + 1);

        this.docid = accnum.substring(0, lastIndex);

      }

    }

    // INSERT

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

      // check accession number for validness

      if ( docid == null ) {

        throw new AccessionNumberException("Accession number is required.");

      // rev is not provided; throw an exception to prevent the insertion

      } else if ( rev == null ) {

        throw new AccessionNumberException

                  ("Revision number is required and must be 1.");

      // docid is used; throw an exception to prevent the insertion

      } else if ( accNumberUsed(docid) ) {

        throw new AccessionNumberException

                  ("Accession number " + docid + " is already in use.");

      // rev is <> 1; throw an exception to prevent the insertion

    // UPDATE or DELETE

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

      String l_rev = "";

      // Accession# is not provided; throw an exception to prevent the action

      if ( docid == null ) {

        throw new AccessionNumberException("Accession number is required.");

      // rev is not provided; throw an exception to prevent the action

      } else if ( rev == null ) {

        throw new AccessionNumberException

                  ("Revision number is required.");

      // Accession# is not current (not in xml_documents); throw an exception

      } else if ( !accNumberIsCurrent(docid) ) {

        throw new AccessionNumberException

                  ("Document not found for Accession number " + docid);

                                              + getLastRevisionNumber(docid));

      // Revision number is not the recent one; throw an exception

      } else if ( action.equals("DELETE") &&

                  !rev.equals(l_rev = getLastRevision(docid)) ) {

        throw new AccessionNumberException

                  ("Last revision number is "+ l_rev);

      }

    }

  }

   * where <revisionid> is always 1.

   *

   * @param docid <sitecode>.<uniqueid> part of Accession Number

   * @param action INSERT, UPDATE or DELETE action

                throws AccessionNumberException, SQLException

  {

    return generate(docid, "1", action);

  }

  /**

   * Generate an Accession Number of form <sidecode>.<uniqueid>.<revisionid>

   *

   * @param docid <sitecode>.<uniqueid> part of Accession Number

   * @param rev <revisionid> of Accession Number

   * @param action INSERT, UPDATE or DELETE action

   */

  {

    try {

      // INSERT

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

        if ( docid == null ) {

        } else if ( accNumberUsed(docid) ) {

          throw new AccessionNumberException

                    ("Accession number " + docid + " is already in use.");

        // rev is <> 1; throw an exception to prevent the insertion

        } else if ( !rev.equals("1") ) {

          throw new AccessionNumberException

                    ("Revision number must be 1.");

        // docid is not used and rev=1; return it

      // UPDATE or DELETE

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

        // Accession# is not provided; throw an exception to prevent the action

        // Accession# is not current (not in xml_documents); throw an exception

        } else if ( !rev.equals(getLastRevision(docid)) ) {

          throw new AccessionNumberException

          ("Revision number must be the recent.");

        } else {

      }

    } catch (SQLException e) {

      throw new SQLException

    // never comes here

    throw new

    AccessionNumberException("Fatal Error in accession number generation.");

  }

  private String getSitecode()

    int serialNumber = -1;

      //check out DBConnection

      conn=DBConnectionPool.getDBConnection("AccessionNumber.getUniqueID");

      serialNumber=conn.getCheckOutSerialNumber();

               "VALUES (?, " + sysdate + ")");

      pstmt.setString(1, sitecode);

      pstmt.close();

                                                          "accession_number");

      //because we only count the connection usage one when it check in

      //but it use twice. So we need to increase one

      conn.increaseUsageCount(1);

      throw new

    {

      DBConnectionPool.returnDBConnection(conn, serialNumber);

    }

    int serialNumber = -1;

      //check out DBConnection

      conn=DBConnectionPool.getDBConnection("AccessionNumber.accNumberUsed");

      serialNumber=conn.getCheckOutSerialNumber();

                "SELECT 'x' FROM xml_revisions " +

      pstmt.setString(2,accNumber);

      ResultSet rs = pstmt.getResultSet();

      hasAccNumber = rs.next();

      pstmt.close();

      ("Error on AccessionNumber.accNumberUsed(accNumber): " + e.getMessage());

    finally

    {

      DBConnectionPool.returnDBConnection(conn, serialNumber);

    }

  }

    int serialNumber = -1;

      //check out DBConnection

      conn=DBConnectionPool.getDBConnection("AccessionNumber.accNumberIsCurre");

      serialNumber=conn.getCheckOutSerialNumber();

      pstmt.execute();

      ResultSet rs = pstmt.getResultSet();

      hasCurrentAccNumber = rs.next();

      pstmt.close();

      throw new SQLException(

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

          e.getMessage());

    finally

    {

      DBConnectionPool.returnDBConnection(conn, serialNumber);

    }

    return hasCurrentAccNumber;

  }

  private String getLastRevision(String docid) throws SQLException

  {

    String rev = "";

    int serialNumber = -1;

    try {

      //check out DBConnection

      conn=DBConnectionPool.getDBConnection("AccessionNumber.getLastRevision");

      serialNumber=conn.getCheckOutSerialNumber();

              ("SELECT rev FROM xml_documents WHERE docid='" + docid + "'");

      pstmt.execute();

      ResultSet rs = pstmt.getResultSet();

      boolean hasRow = rs.next();

      rev = rs.getString(1);

      pstmt.close();

    } catch (SQLException e) {

      throw new SQLException(

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

    }

    {

      DBConnectionPool.returnDBConnection(conn,serialNumber);

    }

    return rev;

  }

  /**

    * Get last revision number from database for a docid

    * The return value is integer because we want compare it to there new one

    * @param docid <sitecode>.<uniqueid> part of Accession Number

    */

  private int getLastRevisionNumber(String docId) throws SQLException

  {

    int rev = 1;

    int serialNumber = -1;

    try {

      //check out DBConnection

      conn=DBConnectionPool.getDBConnection("AccessionNumber.getLastRevisionN");

      serialNumber=conn.getCheckOutSerialNumber();

              ("SELECT rev FROM xml_documents WHERE docid='" + docId + "'");

      pStmt.execute();

      boolean hasRow = rs.next();

      rev = rs.getInt(1);

      pStmt.close();

    } catch (SQLException e) {

      throw new SQLException(

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

    }

    {

      DBConnectionPool.returnDBConnection(conn,serialNumber);

    }

  }

  private String getNextRevision(String docid) throws SQLException

  {

    String rev = "";

    int serialNumber = -1;

      //check out DBConnection

      conn=DBConnectionPool.getDBConnection("AccessionNumber.getNextRevision");

      serialNumber=conn.getCheckOutSerialNumber();

              ("SELECT rev+1 FROM xml_documents WHERE docid='" + docid + "'");

      pstmt.execute();

      ResultSet rs = pstmt.getResultSet();

      boolean hasRow = rs.next();

      rev = rs.getString(1);

      pstmt.close();

    } catch (SQLException e) {

      throw new SQLException(

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

    }

    {

      DBConnectionPool.returnDBConnection(conn, serialNumber);

    }

    return rev;

  }

  /**

   * returns the docid encoded in this accession number

   */

  public String getDocid() {

    return this.docid;

  }

  /**

   * returns the revision number encoded in this accession number

   */

  public String getRev()

  {

    return this.rev;

  }