Metacat

public class MetaCatServlet extends HttpServlet

{

    private static Hashtable sessionHash = new Hashtable();

    private Timer timer = null;

    // Constants -- these should be final in a servlet

                MetaCatUtil.printMessage("Options configured: "

                        + options.getOption("configured"));

            } catch (IOException ioe) {

                logMetacat.error("Error in loading options: "

                        + ioe.getMessage());

            }

        } catch (ServletException ex) {

            throw ex;

        } catch (SQLException e) {

            logMetacat.error("Error in MetacatServlet.init: "

                    + e.getMessage());

        }

    /**

     * Index the paths specified in the metacat.properties

     */

        MetaCatUtil.pathsForIndexing

            = MetaCatUtil.getOptionList(MetaCatUtil.getOption("indexed_paths"));

            ResultSet rs = null;

            for (int i = 0; i < MetaCatUtil.pathsForIndexing.size(); i++) {

                           + (String) MetaCatUtil.pathsForIndexing.elementAt(i)

                           + "' is indexed.... ");

                    rs = pstmt.getResultSet();

                    if (!rs.next()) {

                        rs.close();

                        pstmt.close();

                        conn.increaseUsageCount(1);

                        pstmt.close();

                        conn.increaseUsageCount(1);

                                + " records from xml_nodes for '"

                                + (String) MetaCatUtil.pathsForIndexing.elementAt(i)

                                + "'");

                    } else {

                    }

                    rs.close();

            HttpServletResponse response) throws ServletException, IOException

    {

        MetaCatUtil util = new MetaCatUtil();

        /*

         * +connPool.getSizeOfDBConnectionPool(),10);

         */

        //If all DBConnection in the pool are free and DBConnection pool

        //size is greater than initial value, shrink the connection pool

            }

            String action = ((String[]) params.get("action"))[0];

            // This block handles session management for the servlet

            // by looking up the current session information for all actions

                HttpSession sess = request.getSession(true);

                if (sess.isNew() && !params.containsKey("sessionid")) {

                    // session expired or has not been stored b/w user requests

                            "The session is new or no sessionid is assigned. The user is public");

                    username = "public";

                    sess.setAttribute("username", username);

                } else {

                            + "has sessionid parameter");

                    try {

                        if (params.containsKey("sessionid")) {

                if (username == null || (username.trim().equals(""))) {

                    username = "public";

                }

            }

            // Now that we know the session is valid, we can delegate the

            // request

    private void handleLoginAction(PrintWriter out, Hashtable params,

            HttpServletRequest request, HttpServletResponse response)

    {

        AuthSession sess = null;

        if(params.get("username") == null){

        }

        String un = ((String[]) params.get("username"))[0];

        String pw = ((String[]) params.get("password"))[0];

        String qformat = "xml";

    private void handleLogoutAction(PrintWriter out, Hashtable params,

            HttpServletRequest request, HttpServletResponse response)

    {

        String qformat = "xml";

        if(params.get("qformat") != null){

            qformat = ((String[]) params.get("qformat"))[0];

        if (sess != null) {

            logMetacat.info("The session id " + sess.getId()

                    + " will be invalidate in logout action");

                    + sess.getAttribute("username")

                    + " will be invalidate in logout action");

            sess.invalidate();

        DBQuery queryobj = new DBQuery();

        queryobj.findDocuments(response, out, params, user, groups, sessionid);

        double outPutTime = System.currentTimeMillis() / 1000;

                + (outPutTime - startTime));

    }

    /**

        DBQuery queryobj = new DBQuery();

        queryobj.findDocuments(response, out, params, user, groups, sessionid);

        double outPutTime = System.currentTimeMillis() / 1000;

                + (outPutTime - startTime));

        //handleSQuery(out, params, response,user, groups, sessionid);

            HttpServletResponse response,

            String user, String[] groups, String passWord)

    {

        // Output stream

        ServletOutputStream out = null;

        // Zip output stream

            HttpServletRequest request, HttpServletResponse response,

            String user, String passWord, String[] groups)

    {

        String[] docs = new String[10];

        String inlineDataId = null;

        String docId = "";

    private long getInlineDataNodeId(String inLineDataId, String docId)

            throws SQLException

    {

        long nodeId = 0;

        String INLINE = "inline";

        boolean hasRow;

                DBConnectionPool.returnDBConnection(conn, serialNumber);

            }

        }

                + " is: " + nodeId);

        return nodeId;

    }

            HttpServletResponse response, String user, String passWord,

            String[] groups)

    {

        ServletOutputStream out = null;

        ZipOutputStream zout = null;

        PrintWriter pw = null;

            throws ClassNotFoundException, IOException, SQLException,

            McdbException, Exception

    {

        try {

            // here is hack for handle docid=john.10(in order to tell mike.jim.10.1

                    ContentTypeProvider provider = new ContentTypeProvider(

                            docid);

                    contentType = provider.getContentType();

                            + contentType);

                }

            HttpServletResponse response, PrintWriter out, Hashtable params,

            String user, String[] groups)

    {

        DBConnection dbConn = null;

        int serialNumber = -1;

                    // write the document to the database

                    try {

                        String accNumber = docid[0];

                                + accNumber + "...");

                        if (accNumber.equals("")) {

                            accNumber = null;

    private static boolean needDTDValidation(StringReader xmlreader)

            throws IOException

    {

        StringBuffer cbuff = new StringBuffer();

        java.util.Stack st = new java.util.Stack();

        boolean validate = false;

            }

        }

        return validate;

    }

    /* check if the xml string contains key words to specify schema loocation */

    private String findNamespace(StringReader xml) throws IOException

    {

        String namespace = null;

        String eml2_0_0NameSpace = DocumentImpl.EML2_0_0NAMESPACE;

        String eml2_1_0NameSpace = DocumentImpl.EML2_1_0NAMESPACE;

        if (xml == null) {

                    + namespace);

            return namespace;

        }

        		String namespaceWithPrefix = NAMESPACEKEYWORD 

        					+ ":" + prefix;

        		startIndex = targetLine.indexOf(namespaceWithPrefix);

        	} else {

        		// if prefix not found then look for xmlns

        		// attribute to find the ns 

        		startIndex = targetLine.indexOf(NAMESPACEKEYWORD);

        	}

            int start = 1;

            } 

            // else: xmlns not found. namespace = null will be returned

         	logMetacat.debug("start is " + end);

         	logMetacat.debug("end is " + end);

            if(start < end){

            	namespaceString = targetLine.substring(start + 1, end);

            }

                    + namespaceString);

            if(namespaceString != null){

            	if (namespaceString.indexOf(eml2_0_0NameSpace) != -1) {

            }

        }

        return namespace;

    private String getSchemaLine(StringReader xml) throws IOException

    {

        // find the line

        String secondLine = null;

        int count = 0;

            tmp = xml.read();

        }

        secondLine = buffer.toString();

        xml.reset();

        return secondLine;

    private String getPrefix(String schemaLine)

    {

    	String prefix = null;

    	String rootElement = schemaLine.substring(0, schemaLine.indexOf(" "));

        if(rootElement.indexOf(":") > 0){

        	prefix = rootElement.substring(rootElement.indexOf(":") + 1,

            HttpServletRequest request, HttpServletResponse response,

            String user, String[] groups)

    {

        String[] docid = (String[]) params.get("docid");

        if(docid == null){

                    out.println("<success>");

                    out.println("Document deleted.");

                    out.println("</success>");

                }

                catch (AccessionNumberException ane) {

                    response.setContentType("text/xml");

    private void handleGetLogAction(Hashtable params, HttpServletRequest request,

            HttpServletResponse response, String username, String[] groups)

    {

        try {

            response.setContentType("text/xml");

            PrintWriter out = response.getWriter();

            HttpServletRequest request, HttpServletResponse response,

            String username, String[] groups)

    {

        // Get all of the parameters in the correct formats

        String[] docid = (String[])params.get("docid");

    private void handleMultipartForm(HttpServletRequest request,

            HttpServletResponse response)

    {

        PrintWriter out = null;

        String action = null;

        int sizeLimit = (new Integer(MetaCatUtil.getOption("datafilesizelimit")))

                .intValue();

        logMetacat.info(

        try {

            MultipartParser mp = new MultipartParser(request,

                    sizeLimit * 1024 * 1024);

            Part part;

            PrintWriter out, Hashtable params, Hashtable fileList,

            String username, String[] groupnames)

    {

        //PrintWriter out = null;

        //Connection conn = null;

        String action = null;

        // Make sure we have a docid and datafile

        if (docid != null && fileList.containsKey("datafile")) {

            // Get a reference to the file part of the form

            FilePart filePart = (FilePart) fileList.get("datafile");

            String fileName = filePart.getFileName();

            // Check if the right file existed in the uploaded data

            if (fileName != null) {

    private void handleSetAccessAction(PrintWriter out, Hashtable params,

            String username)

    {

        String[] docList = null;

        String[] principalList = null;

        String[] permissionList = null;

        //debug

        if (packageSet != null) {

            for (int i = 0; i < packageSet.size(); i++) {

                        + (String) packageSet.elementAt(i));

            }

        }

    private String getFieldValueForDoc(String accessionNumber, String fieldName)

            throws Exception

    {

        if (accessionNumber == null || accessionNumber.equals("")

                || fieldName == null || fieldName.equals("")) { throw new Exception(

                "Docid or field name was not specified"); }

     */

    private Vector getDocumentList() throws SQLException

    {

        Vector docList = new Vector();

        PreparedStatement pstmt = null;

        ResultSet rs = null;

     */

    private static String appendRev(String docid) throws Exception

    {

        String newAccNum = null;

        String separator = MetaCatUtil.getOption("accNumSeparator");

        int firstIndex = docid.indexOf(separator);

            // in other suituation we don't change the docid

            newAccNum = docid;

        }

        return newAccNum;

    }

}