Metacat

      // Get the document indicated

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

      }

      StringReader dtd = null;

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

        try {

          if ( !dtdtext[0].equals("") ) {

        }

        try {

            }

        } finally {

          util.returnConnection(conn);

        }    

   private String   docid = null;

   private String   user = null;

   private String   group = null;

   private Thread   xmlIndex;

   private boolean endDocument = false;

   private int serverCode = 1;

     }

   }

   /** Construct an instance of the handler class 

    *

    * @param conn the JDBC connection to which information is written

    * @param action - "INSERT" or "UPDATE"

    * @param docid to be inserted or updated into JDBC connection

    */

   {

     this(conn);

     this.action = action;

     this.docid = docid;

     this.user = user;

     this.group = group;

     this.xmlIndex = new Thread(this);

   }

   /** SAX Handler that receives notification of beginning of the document */

   public void startDocument() throws SAXException {

       rootNode.writeNodename(docname);

       try {

         currentDocument = new DocumentImpl(conn, rootNode.getNodeID(), 

       } catch (Exception ane) {

         throw (new SAXException("Error in DBSaxHandler.startElement " + 

                                 action, ane));

   *                  following the PUBLIC keyword in DOCTYPE declaration or

   *                  the docname if no Public ID provided or

   *                  null if no DOCTYPE declaration provided

   *

   */

  public DocumentImpl(Connection conn, long rootnodeid, String docname, 

                      String doctype, String docid, String action, String user,

                      throws SQLException, Exception

  {

    this.conn = conn;

    this.docname = docname;

    this.doctype = doctype;

    this.docid = docid;

  }

  /**

   * get the document name

  private void writeDocumentToDB(String action, String user)

               throws SQLException, Exception

  {

  }

 /** creates SQL code and inserts new document into DB connection */

               throws SQLException, Exception {

    try {

      PreparedStatement pstmt = null;

        //this.docid = ac.generate(docid, "INSERT");

        pstmt = conn.prepareStatement(

            "INSERT INTO xml_documents " +

        //note that the server_location is set to 1. 

        //this means that "localhost" in the xml_replication table must

        //always be the first entry!!!!!

        pstmt.setString(4, doctype);

        pstmt.setString(5, user);

        pstmt.setString(6, user);

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

        // Save the old document entry in a backup table

            "UPDATE xml_documents " +

            "SET rootnodeid = ?, docname = ?, doctype = ?, " +

            "user_updated = ?, date_updated = sysdate, " +

        // Bind the values to the query

        pstmt.setLong(1, rootnodeid);

        pstmt.setString(2, docname);

        pstmt.setString(4, user);

        pstmt.setInt(5, serverCode);

        pstmt.setInt(6, thisrev);

      } else {

        System.err.println("Action not supported: " + action);

   *

   * @param conn the JDBC connection to the database

   * @param filename the filename to be loaded into the database

   * @param action the action to be performed (INSERT OR UPDATE)

   * @param docid the docid to use for the INSERT OR UPDATE

   */

  public static String write(Connection conn,String filename,

                             String action, String docid, String user,

                             String group )

                throws Exception {

    Reader dtd = null;

    if ( dtdfilename != null ) {

      dtd = new FileReader(new File(dtdfilename).toString());

    }

    return write ( conn, new FileReader(new File(filename).toString()),

  }

                             String action, String docid, String user,

                             String group )

                throws Exception {

  }

                             String action, String docid, String user,

                             String group )

                throws Exception {

     //originally inserted document.

      DocumentImpl doc = new DocumentImpl(conn, docid);

      int servercode = doc.getServerlocation();

    }

    else

    {//if the file is being inserted then the servercode is always 1

    }

  }

    return write(conn,xml,null,action,docid,user,group,serverCode);

  }

                              String action, String docid, String user,

                              String group, int serverCode) 

                throws Exception

  {

  }

                              String action, String docid, String user,

                              String group, int serverCode, boolean override)

                throws Exception

  {

  }

  /**

   *

   * @param conn the JDBC connection to the database

   * @param xml the xml stream to be loaded into the database

   * @param action the action to be performed (INSERT OR UPDATE)

   * @param docid the docid to use for the INSERT OR UPDATE

   * @param user the user that owns the document

   *        update will be locked and version checked.

   */

                              String action, String docid, String user,

                              String group, int serverCode, boolean override)

                throws Exception

          MetacatReplication.replLog("lock granted for " + docid + " from " +

                                      server);

          XMLReader parser = initializeParser(conn, action, newdocid, 

          conn.setAutoCommit(false);

          parser.parse(new InputSource(xml));

          conn.commit();

    try 

    { 

      XMLReader parser = initializeParser(conn, action, newdocid, 

      conn.setAutoCommit(false);

      parser.parse(new InputSource(xml));

      conn.commit();

   */

  private static XMLReader initializeParser(Connection conn, String action,

                                   String docid, String user, String group,

                           throws Exception 

  {

    XMLReader parser = null;

    //

    try {

      ContentHandler chandler = new DBSAXHandler(conn, action, docid,

      EntityResolver eresolver= new DBEntityResolver(conn,

                                                 (DBSAXHandler)chandler, dtd);

      DTDHandler dtdhandler   = new DBDTDHandler(conn);

    try {

      String filename    = null;

      String dtdfilename = null;

      String action      = null;

      String docid       = null;

      for ( int i=0 ; i < args.length; ++i ) {

        if ( args[i].equals( "-f" ) ) {

          filename =  args[++i];

        } else if ( args[i].equals( "-r" ) ) {

          dtdfilename =  args[++i];

        } else if ( args[i].equals( "-a" ) ) {

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

        System.err.println(

          "USAGE: java DocumentImpl [-t] <-a INSERT> [-d docid] <-f filename> "+

        System.err.println(

          "   OR: java DocumentImpl [-t] <-a UPDATE -d docid -f filename> " +

        System.err.println(

          "   OR: java DocumentImpl [-t] <-a DELETE -d docid>");

        System.err.println(

        DocumentImpl.delete(dbconn, docid, null, null);

        System.out.println("Document deleted: " + docid);

      } else {

                                             dtdfilename, action, docid,

                                             null, null);

        if ((docid != null) && (!docid.equals(newdocid))) {