Metacat

package edu.ucsb.nceas.metacat.admin.upgrade;

/**

 *  '$RCSfile$'

 *    Purpose: A Class for upgrading the database to version 1.5

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

 *             National Center for Ecological Analysis and Synthesis

 *    Authors: Saurabh Garg

 *

 *   '$Author$'

 *     '$Date$'

 * '$Revision$'

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 */

import java.sql.Connection;

import java.sql.Driver;

import java.sql.ResultSet;

import java.sql.PreparedStatement;

import java.sql.Statement;

import java.sql.DriverManager;

import java.sql.Timestamp;

import edu.ucsb.nceas.metacat.properties.PropertyService;

import edu.ucsb.nceas.utilities.SortedProperties;

public class Upgrade1_10_0 implements UpgradeUtilityInterface {

    private String driver = null;

    private String url = null;

    private String user = null;

    private String password = null;

    public boolean upgrade() throws AdminException {

    	try {

    		// get the properties

    		driver = PropertyService.getProperty("database.driver");

    	    url = PropertyService.getProperty("database.connectionURI");

    	    user = PropertyService.getProperty("database.user");

    	    password = PropertyService.getProperty("database.password");

	        // Create a JDBC connection to the database

	    	Connection sqlca = null;

	        Driver d = (Driver) Class.forName(driver).newInstance();

	        DriverManager.registerDriver(d);

	        sqlca = DriverManager.getConnection(url, user, password);

	        // three tables need to be updated here

	        String[] tablesToUpdate = {"xml_nodes", "xml_nodes_revisions", "xml_path_index"};

	        for (String tableName: tablesToUpdate) {

		        Statement sqlStatement = null;

		        PreparedStatement pstmt = null;

		        ResultSet rset = null;

		        sqlStatement = sqlca.createStatement();

		        rset = sqlStatement.executeQuery(

		            "SELECT DISTINCT NODEID, NODEDATA "

		            + "FROM " + tableName + " WHERE "

		            + "nodedata IS NOT NULL AND "

		            + "UPPER(nodedata) = LOWER(nodedata)");

		        int count = 0;

		        while (rset.next()) {

		            String nodeid = rset.getString(1);

		            String nodedata = rset.getString(2);

		            try {

		                if (!nodedata.trim().equals("")) {

		                	System.out.println(nodedata);

		            		Calendar dataDateValue = DatatypeConverter.parseDateTime(nodedata);

		                    Timestamp dataTimestamp = new Timestamp(dataDateValue.getTimeInMillis());

		                    pstmt = sqlca.prepareStatement(

		                        "update " + tableName +

		                        " set nodedatadate = ?" +

		                        " where nodeid = " + nodeid);

		                    pstmt.setTimestamp(1, dataTimestamp);

		                    pstmt.execute();

		                    pstmt.close();

		                    count++;

		                    if (count%5 == 0) {

		                        System.out.println(count + "...");

		                    }

		            	// do nothing, was not a valid date

		            	e.printStackTrace();

		        }

		        System.out.println("Table: " + tableName + " complete. " + count + " values converted.");

		        rset.close();

		        sqlStatement.close();

	        }

	        sqlca.close();

    	} catch (Exception e) {

    		e.printStackTrace();

            throw new AdminException("Error upgrading system to 1.10.0: " + e.getMessage());

        }

    	return true;

    }

    public static void main(String [] ags){

        try {

        	// set up the properties based on the test/deployed configuration of the workspace

        	SortedProperties testProperties =

				new SortedProperties("test/test.properties");

			testProperties.load();

			String metacatContextDir = testProperties.getProperty("metacat.contextDir");

			PropertyService.getInstance(metacatContextDir + "/WEB-INF");

			// now run it

            Upgrade1_10_0 upgrader = new Upgrade1_10_0();

            upgrader.upgrade();

            Calendar date = DatatypeConverter.parseDate("2011-03-17");

            System.out.println("date:" + DatatypeConverter.printDate(date));

            System.out.println("Exception:" + ex.getMessage());

            ex.printStackTrace();

        }

    }

}