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

public class AccessionNumber  {

    String globalName;

    String localId;

    String accNumber;

    Connection conn;

    /** Split the accession number in 2 parts by ":" character */

    public AccessionNumber (Connection conn, String accNumber) {

        this.conn = conn;

        this.globalName = getGlobalName(accNumber);

        this.localId = getLocalId(accNumber);

        this.accNumber = put();

    }    

    /** check for existance of Accesssion Number */

    public boolean check (String globalName, String localId) {

        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) {

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

        }    

        return hasAccNumber;

    }    

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

    public int get (String globalName) {

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

            if (hasLocalId)

                return rs.getInt(1);

            pstmt.close();

        } catch (SQLException e) {

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

        }    

        return -1;

    }

    //** register next unique number for a local ID by a given global name */

    public String put () {

        if (!check(globalName, localId)) {

            put(globalName, localId);

            return globalName + ":" + localId;

        } else {

            // get max local Id, put next Id

            int l = get(globalName);

            System.out.println(l);

            if ( l == -1 ) l = 1;

            else l += 1;

            put (globalName, (new Integer(l)).toString());

            return globalName + ":" + l;

        }    

    }

    private void put (String globalName, String localId) {

        try {

            PreparedStatement pstmt;

            pstmt = conn.prepareStatement("INSERT INTO xml_acc_numbers (global_name, local_id) " + 

                                          "VALUES (?, ?)");

            pstmt.setString(1,globalName);

            pstmt.setString(2,localId);

            pstmt.execute();

        } catch (SQLException e) {

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

        }    

    }

    // get the global part of the accession number

    private String getGlobalName (String accNumber) 

        throws StringIndexOutOfBoundsException {

        return accNumber.substring(0, accNumber.lastIndexOf(":"));

    }    

    // get the local part of the accession number

    private String getLocalId (String accNumber)

        throws StringIndexOutOfBoundsException {

        return accNumber.substring(accNumber.lastIndexOf(":")+1);

    }    

    static public void main(String[] args) {

        String 	defaultDB = "jdbc:oracle:thin:@penelope.nceas.ucsb.edu:1526:DEV8";

        if (args.length < 4)

        {

            System.err.println("Wrong number of arguments!!!");

            System.err.println("USAGE: java AccessionNumber " +

                               "<userID> <accessionNumber> <user> <password> [dbstring]");

            return;

        } else {

            try {

                String userID   = args[0];

                String accNum   = args[1];

                String user     = args[2];

                String password = args[3];

                String dbstring = null;

                if (args.length <= 4)

                    dbstring = defaultDB;

                else

                    dbstring = args[4];

                // Open a connection to the database

                // Load the Oracle JDBC driver

                Class.forName ("oracle.jdbc.driver.OracleDriver");

                // Connect to the database

                Connection conn = DriverManager.getConnection( dbstring, user, password);

                AccessionNumber an = new AccessionNumber(conn, accNum);

                System.out.println("Accession Number registration finished for: " + an.accNumber);

            } catch (Exception e) {

                System.err.println(e.getMessage());

            }

        }

    }    

}