Metacat

/**

 *        Name: DBWriter.java

 *     Purpose: A Class that reads in an XML text document and

 *              write its contents to a database connection

 * Institution: National Center for Ecological Analysis and Synthesis

 *   Copyright: 1998 

 *     Authors: Matt Jones

 *     

 *     Version: '$Id: DBWriter.java 8 1999-09-13 07:23:05Z jones $'

 */

//package edu.ucsb.nceas.dbwriter;

import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStream;

import java.net.URL;

import java.util.Properties;

import java.sql.*;

import org.xml.sax.ErrorHandler;

import org.xml.sax.InputSource;

import org.xml.sax.SAXException;

import org.xml.sax.SAXParseException;

import org.w3c.dom.Element;

import org.w3c.dom.Node;

import org.w3c.dom.NodeList;

import com.sun.xml.tree.XmlDocument;

import com.sun.xml.tree.XmlDocumentBuilder;

import com.sun.xml.tree.SimpleElementFactory;

import com.sun.xml.parser.Resolver;

import com.sun.xml.parser.ValidatingParser;

public class DBWriter

{

    private XmlDocument			doc;

    private Connection			conn = null;

    // Constructer to init the class

    public DBWriter(String argv[]) 

	throws SAXException, SQLException, IOException, ClassNotFoundException {

        // Open a connection to the database

        conn = openDBConnection(

		"oracle.jdbc.driver.OracleDriver",

		"jdbc:oracle:thin:@penelope.nceas.ucsb.edu:1526:DEV",

		"jones", "kinkaj0u");

	// THIS IS TEMPORARY 

        // Prepare a statement to cleanup the emp table

/*

        Statement stmt = conn.createStatement ();

        try {

            	stmt.execute ("delete from xml_elements where nodeid = 1500");

        } catch (SQLException e) {

        	// Ignore an error here

        }

*/       

	// THIS IS TEMPORARY 

        // Prepare to insert new names in the Elements table

/*

        PreparedStatement pstmt = conn.prepareStatement(

	        "insert into xml_elements (nodeid, nodename) values (?, ?)");

        // Add an element as element number 1500

        pstmt.setInt (1, 1500);	// The first ? is for NODEID

        pstmt.setString (2, "eml-variable");// The second ? is for NODENAME

        // Do the insertion

        pstmt.execute ();

*/

	//

	// Load the document, using the appropriate custom

	// DOM elements.

	//

	XmlDocument	doc = createDocument (

		Resolver.createInputSource (new File (argv [1])),

		new FileInputStream (argv [0]),

		new ErrorPrinter ()

	);

	DBElement		root;

    	root = (DBElement)doc.getDocumentElement();

	root.normalize();

        root.writeXmlToDB(conn);

    }

    //

    // usage:  main someprops.props someplay.xml 

    //

    public static void main (String argv [])

    {

	try {

	    if (argv.length != 2) {

		System.err.println ("usage: java project.DBWriter "

		    + "someprops.props someplay.xml");

		System.exit (1);

	    }

            new DBWriter(argv);

	} catch (Throwable t) {

            t.printStackTrace (System.out);

	}

    }

    static private XmlDocument createDocument (

	InputSource	input,

	InputStream	propsStream,

	ErrorHandler	errorHandler

    ) throws SAXException, IOException

    {

	try {

	    XmlDocumentBuilder		builder = new XmlDocumentBuilder ();

	    ValidatingParser		parser = new ValidatingParser ();

	    //

	    // Configure the builder to create the right elements.

	    //

	    {

		Properties		props;

		SimpleElementFactory	factory;

		props = new Properties ();

		props.load (propsStream);

		factory = new SimpleElementFactory ();

		factory.addMapping (props, DBWriter.class.getClassLoader ());

		builder.setElementFactory (factory);

	    }

	    //

	    // Configure the parser

	    //

	    parser.setErrorHandler (errorHandler);

	    parser.setEntityResolver (new Resolver ());

	    parser.setDocumentHandler (builder);

	    parser.parse (input);

	    // Look at how the different versions print themselvs...

	    if (false) {

		builder.getDocument ().write (System.out);

		System.exit (0);

	    }

	    return builder.getDocument ();

	} catch (SAXParseException e) {

	    // already reported

	    throw e;

	} catch (SAXException e) {

	    e.printStackTrace (System.out);

	    throw e;

	} catch (IOException e) {

	    e.printStackTrace (System.out);

	    throw e;

	}

    }

    private Connection openDBConnection(String dbDriver, String connection, 

		String user, String password) 

		throws SQLException, ClassNotFoundException {

      // Load the Oracle JDBC driver

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

      // Connect to the database

      // You can put a database name after the @ sign in the connection URL.

      Connection conn = DriverManager.getConnection(

	"jdbc:oracle:thin:@penelope.nceas.ucsb.edu:1526:DEV", 

	"jones", "kinkaj0u");

      return conn;

    }

    static class ErrorPrinter implements ErrorHandler

    {

	private void message (String level, SAXParseException e)

	{

	    System.out.print ("** ");

	    System.out.println (level);

	    System.out.print ("   URI = ");

	    System.out.print (e.getSystemId ());

	    System.out.print (" Line = ");

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

	    System.out.print ("   Message = ");

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

	    /*

	    if (e.getException () != null)

		e.getException ().printStackTrace (System.out);

	    else

		e.printStackTrace (System.out);

	    */

	}

	public void error (SAXParseException e)

	{

	    // normally a validity error

	    message ("Error (recoverable)", e);

	}

	public void warning (SAXParseException e)

	{

	    message ("Warning", e);

	}

	public void fatalError (SAXParseException e)

	{

	    message ("FATAL ERROR", e);

	}

    }

}