Metacat

import java.util.Map;

import java.util.TreeMap;

    private Connection getConnection() throws AdminException {

    	Connection conn = null;

	    	// get the properties

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

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

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

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

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

    	} catch (Exception e) {

			String msg = "Could not get connection: " + e.getMessage();

			log.error(msg);

			AdminException ae = new AdminException(msg);

			ae.initCause(e);

			throw ae;

		} 

    	return conn;

    }

    private Map<String, Timestamp> getDataValues(String tableName) throws AdminException {

		Map<String, Timestamp> dataValues = new TreeMap<String, Timestamp>();

    	try {

        	Connection conn = getConnection();

			// select the nodes that are not numeric and not null

	        sqlStatement = conn .createStatement();

	        rset = sqlStatement.executeQuery(

	            "SELECT DISTINCT NODEID, NODEDATA "

	            + "FROM " + tableName + " WHERE "

	            + "nodedata IS NOT NULL "

	            //+ "AND nodedatanumerical IS NULL"

	            );

	        count = 0;

	        while (rset.next()) {

	            nodeid = rset.getString(1);

	            nodedata = rset.getString(2);

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

	            	try {

	            		Calendar dataDateValue = DatatypeConverter.parseDateTime(nodedata);

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

	                    dataValues.put(nodeid, dataTimestamp);

	            	} catch (Exception e) {

						// probably not a valid date

					}

	            }

                log.debug("parsed: " + nodedata);

                count++;

                if (count%5 == 0) {

                    log.debug(count + "...");

                }		               

	        }

	        log.warn("Table: " + tableName + " complete. " + count + " values converted.");

	        rset.close();

	        sqlStatement.close();

	        conn.close();

    	} catch (Exception e) {

    		String msg = "Error parsing date time node data: " + e.getMessage();

    		log.error(msg, e);

            throw new AdminException(msg);

        }

    	return dataValues;

    }

    private boolean upgradeSingleTable(String tableName) throws AdminException {

    	Map<String, Timestamp> dataValues = getDataValues(tableName);

    	Connection conn = getConnection();

    	for (String nodeid: dataValues.keySet()) {

    		Timestamp dataTimestamp = dataValues.get(nodeid);

			upgradeSingleValue(tableName, nodeid, dataTimestamp , conn);

    	}

    	if (conn != null) {

    		try {

				conn.close();

			} catch (SQLException e) {

				throw new AdminException("Error closing connection: " + e.getMessage());

			}

    	}

    	return true;

    }

    private boolean upgradeSingleValue(String tableName, String nodeid, Timestamp dataTimestamp, Connection conn) throws AdminException {

    	try {

	        PreparedStatement pstmt = null;

            try {

                    pstmt = conn.prepareStatement(

                        "update " + tableName +

                        " set nodedatadate = ? " +

                        " where nodeid = ? ");

                    pstmt.setTimestamp(1, dataTimestamp);

                    pstmt.setString(2, nodeid);

                    pstmt.execute();

                    log.debug("processed nodedata: " + dataTimestamp);

            } catch (Exception e) { 

            	// do nothing, was not a valid date

            	//e.printStackTrace();

            } finally {

            	if (pstmt != null) {

            		pstmt.close();

            	}

            }