Metacat

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.PreparedStatement;

import java.sql.Statement;

import java.sql.SQLException;

import java.sql.DriverManager;

    static String database = "@database@";

    static String url = "@jdbc-connect@";

    static String user = "@user@";

    static String password = "@password@";

    public static void upgrade_xml_nodes(Connection sqlca) throws SQLException{

        // Delete old nodedatanumerical column from xml_nodes if one exsists

        try {

            System.out.println(

                "Deleting old nodedatanumerical column from xml_nodes...");

            pstmt = sqlca.prepareStatement(

                "ALTER TABLE xml_nodes DROP COLUMN nodedatanumerical");

            pstmt.execute();

            pstmt.close();

            System.out.println("Done.");

        } catch (Exception e) {

            System.out.println(" column not found.");

        }

        // Create nodedatanumerical column in xml_nodes

        System.out.println(

            "Creating new nodedatanumerical column in xml_nodes...");

        if (database.equals("oracle")) {

            pstmt = sqlca.prepareStatement(

                "ALTER TABLE xml_nodes ADD nodedatanumerical NUMBER");

        }

        else {

            pstmt = sqlca.prepareStatement(

                "ALTER TABLE xml_nodes ADD nodedatanumerical FLOAT8");

        }

        pstmt.execute();

        pstmt.close();

        System.out.println("Done.");

        // Copy numerical values from nodedata to

        // nodedatanumerical column in xml_nodes

        System.out.println(

            "Copy numerical values from nodedata to nodedatanumerical "

            + "in xml_nodes...");

        sqlStatement = sqlca.createStatement();

        rset = sqlStatement.executeQuery(

            "SELECT DISTINCT NODEID, NODEDATA "

            + "FROM xml_nodes 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);

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

                    double s = Double.parseDouble(nodedata);

                    pstmt = sqlca.prepareStatement(

                        "update xml_nodes set nodedatanumerical = " + s +

                        " where nodeid=" + nodeid);

                    pstmt.execute();

                    pstmt.close();

                    count++;

                }

            } catch (NumberFormatException nfe) {

            } catch (Exception e) {

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

        }

        System.out.println("Done. " + count + " values copied.");

        rset.close();

        sqlStatement.close();

    }

    public static void upgrade_xml_index(Connection sqlca) throws SQLException{

        Statement sqlStatement, sqlStatement1 = null;

        PreparedStatement pstmt = null;

        ResultSet rset, rset1 = null;

        // Delete old nodedata column from xml_index if one exsists

        try {

                "Deleting old nodedata column from xml_index...");

            pstmt = sqlca.prepareStatement(

                "ALTER TABLE xml_index DROP COLUMN nodedata");

        } catch (Exception e) {

            System.out.println(" column not found.");

        }

        // Create nodedata column in xml_index

        System.out.println(

            "Creating new nodedata column in xml_index...");

        if (database.equals("oracle")) {

            pstmt = sqlca.prepareStatement(

                "ALTER TABLE xml_index ADD nodedata VARCHAR2(4000)");

        } else {

            pstmt = sqlca.prepareStatement(

                "ALTER TABLE xml_index ADD nodedata VARCHAR(4000)");

        }

        pstmt.execute();

        pstmt.close();

        System.out.println("Done.");

        // Copy numerical values from nodedata to

        // nodedatanumerical column in xml_index

        System.out.println(

            "Copy nodedata from xml_nodes to nodedata in xml_index...");

        sqlStatement = sqlca.createStatement();

        rset = sqlStatement.executeQuery(

            "select docid, nodeid, path from xml_index");

        int j = 0;

        while (rset.next()) {

            String docid = rset.getString(1);

            String nodeid = rset.getString(2);

            String path = rset.getString(3);

            sqlStatement1 = sqlca.createStatement();

            rset1 = sqlStatement1.executeQuery(

                "select nodedata from xml_nodes where parentnodeid = " + nodeid

		+ " and docid = '" + docid

                + "' and nodetype = 'TEXT'");

            while (rset1.next()) {

                String nodedata = rset1.getString(1);

                if (nodedata != null && !nodedata.trim().equals("")) {

                    j++;

                    if (j % 100 == 0) {

                        System.out.println("Number of records modified:" + j);

                    pstmt = sqlca.prepareStatement(

                        "update xml_index set nodedata = ? where nodeid = " +

                        nodeid + " and path = ? and docid = ? and nodedata is null");

                    pstmt.setString(1, nodedata);

                    pstmt.setString(2, path);

                    pstmt.setString(3, docid);

                    pstmt.execute();

                    pstmt.close();

                    continue;

            rset1.close();

            sqlStatement1.close();

        }

        rset.close();

        sqlStatement.close();

        // Create index on xml_index.docid

        System.out.println("Creating index on docid column in xml_index...");

        pstmt = sqlca.prepareStatement(

            "CREATE INDEX xml_index_idx2 ON xml_index (docid)");

        pstmt.execute();

        pstmt.close();

    }

    public static void main(String [] ags){

        try {

            Connection sqlca = null;

            // Create a JDBC connection to the database

            DriverManager.registerDriver(new @dbDriver@());

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

            // Upgrade the xml_nodes table

            upgrade_xml_nodes(sqlca);

            // Upgrade the xml_index table

            upgrade_xml_index(sqlca);

            // Close the connection...

        } catch (SQLException ex) {