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

 * accession number for uniqueness and register it into the db connection

     * and register it into new db connection. If no accession number is

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

     *

     * @param action - INSERT, UPDATE or DELETE.

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

     * If it is unique, use it.

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

     * When "UPDATE", accession # is required.

     * When "DELETE", accession # is required.

     */

        String localId = null;

        MetaCatUtil   util = new MetaCatUtil();

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

        try {

            // Open a new connection to the database

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

            if ( accNumber != null ) {

                globalName = getGlobalName(accNumber, sep);

                localId = getLocalId(accNumber, sep);

            }

            // register unique acc #

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

                if ( accNumber == null ) {

                  throw (new AccessionNumberException("Accession number is " +

                         "required."));

                } else if (!accNumberIsCurrent(conn, 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 + "'."));

                       e.getMessage());

        }

               "accession number generation: "));

    {

        Integer l = null;

        try {

            if ( localId == null )

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

            else

                l = new Integer(localId);

            // insert globalName & l

            PreparedStatement pstmt;

                    "INSERT INTO xml_acc_numbers (global_name, local_id) " +

                    "VALUES (?, ?)");

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

            pstmt.execute();

                   + e.getMessage());

        }

        return globalName + sep + l;

    }

        PreparedStatement pstmt;

        pstmt = conn.prepareStatement(

                "SELECT 'x' FROM xml_acc_numbers " +

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

        pstmt.setString(1,globalName);

        pstmt.setString(2,localId);

        pstmt.execute();

        ResultSet rs = pstmt.getResultSet();

        hasAccNumber = rs.next();

        pstmt.close();

        throw e;

      }

      boolean hasCurrentAccNumber = false;

      try {

        PreparedStatement pstmt;

        pstmt = conn.prepareStatement(

                "SELECT 'x' FROM xml_documents " +

                "WHERE docid LIKE ?");

        pstmt.setString(1, accNumber);

        pstmt.execute();

        ResultSet rs = pstmt.getResultSet();

        hasCurrentAccNumber = rs.next();

        pstmt.close();

      } catch (SQLException e) {

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

        throw e;

      }

      return hasCurrentAccNumber;

    }

    {

            PreparedStatement pstmt;

                    "SELECT max(local_id) FROM xml_acc_numbers " +

                    "WHERE global_name LIKE ?");

            pstmt.execute();

            ResultSet rs = pstmt.getResultSet();

            boolean hasLocalId = rs.next();

            if (hasLocalId)

                return rs.getInt(1);

            pstmt.close();

        } catch (SQLException e) {

    // get the global part of the accession number

    // get the local part of the accession number

 * '$Log$

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

 * ''

 */