Metacat

/**

 *        Name: AccessionNumber.java

 *     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

 *

 *     Version: '$Id$'

 */

package edu.ucsb.nceas.metacat;

import java.net.*;

import java.sql.*;

 * A class that gets Accession Number, check for uniqueness and register it

 * into db connection

 */

        throws ClassNotFoundException, StringIndexOutOfBoundsException, SQLException

    {

        String localId = null;

        PropertyResourceBundle options = null;

        options = (PropertyResourceBundle)PropertyResourceBundle.getBundle("metacat");

        String dbDriver = (String)options.handleGetObject("dbDriver");

        String defaultDB = (String)options.handleGetObject("defaultDB");

        String user = (String)options.handleGetObject("user");

        String password = (String)options.handleGetObject("password");

        String defaultGlobalName = (String)options.handleGetObject("defaultGlobalName");

        String sep = (String)options.handleGetObject("accNumberSeparator");

        try {

            // Open a new connection to the database

            Connection conn = MetaCatUtil.openDBConnection(dbDriver, defaultDB, user, password);

            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 == "INSERT" )

                if ( accNumber == null )

                    return put(conn, defaultGlobalName, null, sep);

                else

                    return put(conn, globalName, localId, sep);

        } catch (SQLException e) {

            System.out.println("Error on AccessionNumber.genAccessionNumber(): " + e.getMessage());

            throw e;

        }

        return null;

    private static String put (Connection conn, String globalName, String localId, String sep)

                throws SQLException

    {

        Integer l = null;

        try {

            if ( localId == null )

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

            else if ( !unique(conn, globalName, localId) )

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

            else

                l = new Integer(localId);

            // insert globalName & l

            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();

        } catch (SQLException e) {

            System.out.println("Error on AccessionNumber.put(conn, globalName, localId): " + e.getMessage());

            throw e;

        }

        return globalName + sep + l;

    }

                throws SQLException

    {

        boolean hasAccNumber = false;

        try {

            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();

        } catch (SQLException e) {

            throw e;

        return hasAccNumber;

    }

    //** get the last in order local ID by a given global name */

                throws SQLException

    {

            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();

            if (hasLocalId)

                return rs.getInt(1);

            pstmt.close();

        } catch (SQLException e) {

            System.out.println("Error on AccessionNumber.get(): " + e.getMessage());

    // get the global part of the accession number

    // get the local part of the accession number

}