Metacat

/**

 *        Name: DBSAXDocument.java

 *     Purpose: A Class that writes an XML document main data

 *   Copyright: 2000 Regents of the University of California and the

 *              National Center for Ecological Analysis and Synthesis

 *     Authors: Jivka Bojilova

 *

 *     Version: '$Id$'

 */

import java.sql.*;

import java.io.IOException;

import java.util.Hashtable;

import java.util.Enumeration;

/**

 * A Class that writes an XML document main data to a database connection

 */

public class DBSAXDocument {

    private Connection		conn;

    private long            rootnodeid;

    private String          docname;

    private String          doctype;

    /**

     * Construct a new document instance

     *

     * @param conn the JDBC Connection to which all information is written

     * @param rootnodeid - sequence id of the root node in the document

     * @param docname - the name of DTD, i.e. the name immediately following the DOCTYPE keyword - should be the root element name.

     * (Oracle's and IBM parsers are not aware if it is not the root element name)

     * @param doctype - Public ID of the DTD, i.e. the name immediately following the PUBLIC keyword in DOCTYPE declaration.

     *

     */

    public DBSAXDocument (Connection conn, long rootnodeid, String docname, String doctype)

    {

      this.conn = conn;

      this.rootnodeid = rootnodeid;

      this.docname = docname;

      this.doctype = doctype;

      writeDocumentToDB();

      System.out.println("DBSAXDocument.writeDocumentToDB");

    }

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

    private void writeDocumentToDB() {

        try {

          conn.setAutoCommit(false);

          PreparedStatement pstmt;

          pstmt = conn.prepareStatement(

                "INSERT INTO xml_documents (docid, rootnodeid, docname, doctype) " +

                "VALUES (null, ?, ?, ?)");

          // Bind the values to the query

          pstmt.setLong(1, rootnodeid);

          pstmt.setString(2, docname);

          pstmt.setString(3, doctype);

          // Do the insertion

          pstmt.execute();

          pstmt.close();

          conn.commit();

          conn.setAutoCommit(true);

        } catch (SQLException e) {

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

        }

    }

}