Metacat

import java.sql.Timestamp;

import org.dataone.service.types.Checksum;

import org.dataone.service.types.ChecksumAlgorithm;

import org.dataone.service.types.ObjectFormat;

import org.dataone.service.types.ObjectInfo;

import org.dataone.service.types.ObjectList;

import org.dataone.service.types.Identifier;

import edu.ucsb.nceas.metacat.shared.ServiceException;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

     * return a hash of all of the info that is in the systemmetadata table

     * @param localId

     * @return

     */

    public Hashtable<String, String> getSystemMetadataInfo(String localId)

    throws McdbDocNotFoundException

    {

        try

        {

            AccessionNumber acc = new AccessionNumber(localId, "NONE");

            localId = acc.getDocid();

        }

        catch(Exception e)

        {

            //do nothing. just try the localId as it is

        }

        Hashtable<String, String> h = new Hashtable<String, String>();

        String sql = "select guid, date_uploaded, rights_holder, checksum, checksum_algorithm, " +

          "origin_member_node, authoritative_member_node, date_modified, submitter " +

          "from systemmetadata where docid = ?";

        DBConnection dbConn = null;

        int serialNumber = -1;

        try 

        {

            // Get a database connection from the pool

            dbConn = DBConnectionPool.getDBConnection("IdentifierManager.getDocumentInfo");

            serialNumber = dbConn.getCheckOutSerialNumber();

            // Execute the insert statement

            PreparedStatement stmt = dbConn.prepareStatement(sql);

            stmt.setString(1, localId);

            ResultSet rs = stmt.executeQuery();

            if (rs.next()) 

            {

                String guid = rs.getString(1);

                Timestamp dateUploaded = rs.getTimestamp(2);

                String rightsHolder = rs.getString(3);

                String checksum = rs.getString(4);

                String checksumAlgorithm = rs.getString(5);

                String originMemberNode = rs.getString(6);

                String authoritativeMemberNode = rs.getString(7);

                Timestamp dateModified = rs.getTimestamp(8);

                String submitter = rs.getString(9);

                h.put("guid", guid);

                h.put("date_uploaded", new Long(dateUploaded.getTime()).toString());

                h.put("rights_holder", rightsHolder);

                h.put("checksum", checksum);

                h.put("checksum_algorithm", checksumAlgorithm);

                h.put("origin_member_node", originMemberNode);

                h.put("authoritative_member_node", authoritativeMemberNode);

                h.put("date_modified", new Long(dateModified.getTime()).toString());

                h.put("submitter", submitter);

                stmt.close();

            } 

            else

            {

                stmt.close();

                DBConnectionPool.returnDBConnection(dbConn, serialNumber);

                throw new McdbDocNotFoundException("2Could not find document " + localId);

            }

        } 

        catch (SQLException e) 

        {

            e.printStackTrace();

            logMetacat.error("Error while getting system metadata info for localid " + localId + " : "  

                    + e.getMessage());

        } 

        finally 

        {

            // Return database connection to the pool

            DBConnectionPool.returnDBConnection(dbConn, serialNumber);

        }

        return h;

    }

    /**

     * query the systemmetadata table based on the given parameters

     * @param startTime

     * @param endTime

     * @param objectFormat

     * @param replicaStatus

     * @param start

     * @param count

     * @return ObjectList

     */

    public ObjectList querySystemMetadata(Date startTime, Date endTime, 

            ObjectFormat objectFormat, boolean replicaStatus, int start, int count)

    {

        ObjectList ol = new ObjectList();

        int total = 0;

        try

        {

            String sql = "select guid, date_uploaded, rights_holder, checksum, " +

                "checksum_algorithm, origin_member_node, authoritive_member_node, " +

                "date_modified, submitter, xml_documents.doctype from systemmetadata, " +

                "xml_documents where xml_documents.docid in " +

                "(select docid from identifier where guid = systemmetadata.guid)";

            boolean f1 = false;

            boolean f2 = false;

            boolean f3 = false;

            if(startTime != null)

            {

                sql += " and systemmetadata.date_modified > ?";

                f1 = true;

            }

            if(endTime != null)

            {

                sql += " and systemmetadata.date_modified < ?";

                f2 = true;

            }

            if(objectFormat != null)

            {

                sql += " and xml_documents.doctype = ?";

                f3 = true;

            }

            if(replicaStatus)

            {

                String currentNodeId = PropertyService.getInstance().getProperty("dataone.memberNodeId");

                sql += " and authoritive_member_node != '" + currentNodeId.trim() + "'";

            }

            DBConnection dbConn = DBConnectionPool.getDBConnection("IdentifierManager.createMapping");

            int serialNumber = dbConn.getCheckOutSerialNumber();

            PreparedStatement stmt = dbConn.prepareStatement(sql);

            if(f1 && f2 && f3)

            {

                stmt.setTimestamp(1, new Timestamp(startTime.getTime()));

                stmt.setTimestamp(2, new Timestamp(endTime.getTime()));

                stmt.setString(3, objectFormat.toString());

            }

            else if(f1 && f2 && !f3)

            {

                stmt.setTimestamp(1, new Timestamp(startTime.getTime()));

                stmt.setTimestamp(2, new Timestamp(endTime.getTime()));

            }

            else if(f1 && !f2 && f3)

            {

                stmt.setTimestamp(1, new Timestamp(startTime.getTime()));

                stmt.setString(2, objectFormat.toString());

            }

            else if(f1 && !f2 && !f3)

            {

                stmt.setTimestamp(1, new Timestamp(startTime.getTime()));

            }

            else if(!f1 && f2 && f3)

            {

                stmt.setTimestamp(1, new Timestamp(endTime.getTime()));

                stmt.setString(2, objectFormat.toString());

            }

            else if(!f1 && !f2 && f3)

            {

                stmt.setString(1, objectFormat.toString());

            }

            else if(!f1 && f2 && !f3)

            {

                stmt.setTimestamp(1, new Timestamp(endTime.getTime()));

            }

            //System.out.println("LISTOBJECTS QUERY: " + stmt.toString());

            ResultSet rs = stmt.executeQuery();

            for(int i=0; i<start - 1; i++)

            {

                rs.next();

            }

            int countIndex = 0;

            while(rs.next()) 

            {

                total++;

                if(countIndex >= count)

                {

                    break;

                }

                String guid = rs.getString(1);

                //System.out.println("query found doc with guid " + guid);

                //Timestamp dateUploaded = rs.getTimestamp(2);

                //String rightsHolder = rs.getString(3);

                String checksum = rs.getString(4);

                String checksumAlgorithm = rs.getString(5);

                //String originMemberNode = rs.getString(6);

                String authoritiveMemberNode = rs.getString(7);

                Timestamp dateModified = rs.getTimestamp(8);

                //String submitter = rs.getString(9);

                String format = rs.getString(10);

                ObjectInfo oi = new ObjectInfo();

                Identifier id = new Identifier();

                id.setValue(guid);

                oi.setIdentifier(id);

                oi.setDateSysMetadataModified(new Date(dateModified.getTime()));

                Checksum cs = new Checksum();

                cs.setValue(checksum);

                cs.setAlgorithm(ChecksumAlgorithm.convert(checksumAlgorithm));

                oi.setChecksum(cs);

                ObjectFormat oFormat = ObjectFormat.convert(format);

                if(oFormat != null)

                {

                    oi.setObjectFormat(oFormat);

                }

                ol.addObjectInfo(oi);

                countIndex++;

            }

            while(rs.next())

            { //expend the resultset to get the total count of possible rows

                total++;

            }

        }

        catch(Exception e)

        {

           e.printStackTrace();

           System.out.println("Error querying system metadata: " + e.getMessage());

        }

        System.out.println("listObjects total: " + total);

        ol.setStart(start);

        ol.setCount(count);

        ol.setTotal(total);

        return ol;

    }

    /**