Metacat

/**

 *    '$RCSfile: ConfigurableEcogridEndPoint.java,v $'

 *

 *     '$Author: leinfelder $'

 *       '$Date: 2008/06/20 17:47:12 $'

 *   '$Revision: 1.1 $'

 *

 *  For Details: http://ecoinformatics.org

 *

 * Copyright (c) 2007 The Regents of the University of California.

 * All rights reserved.

 * 

 * Permission is hereby granted, without written agreement and without

 * license or royalty fees, to use, copy, modify, and distribute this

 * software and its documentation for any purpose, provided that the

 * above copyright notice and the following two paragraphs appear in

 * all copies of this software.

 * 

 * IN NO EVENT SHALL THE UNIVERSITY OF CALIFORNIA BE LIABLE TO ANY PARTY

 * FOR DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES

 * ARISING OUT OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN

 * IF THE UNIVERSITY OF CALIFORNIA HAS BEEN ADVISED OF THE POSSIBILITY

 * OF SUCH DAMAGE.

 * 

 * THE UNIVERSITY OF CALIFORNIA SPECIFICALLY DISCLAIMS ANY WARRANTIES,

 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF

 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. THE SOFTWARE

 * PROVIDED HEREUNDER IS ON AN "AS IS" BASIS, AND THE UNIVERSITY

 * OF CALIFORNIA HAS NO OBLIGATION TO PROVIDE MAINTENANCE, SUPPORT,

 * UPDATES, ENHANCEMENTS, OR MODIFICATIONS.

 */

package edu.ucsb.nceas.metacat.dataquery;

import org.ecoinformatics.datamanager.download.EcogridEndPointInterface;

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

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

/**

 * This class implements EcogridEndPointInterface and is configurable using a properties file.

 * Should be useful for switching to remote endpoints etc.

 * 

 * @author leinfelder

 *

 */

public class ConfigurableEcogridEndPoint implements EcogridEndPointInterface 

{  

	private String metacatEcogridEndPoint = null;

	private String metacatEcogridAuthEndPoint = null;

	private String metacatEcogridPutEndPoint = null;

	private String metacatEcogridIdentifierEndPoint = null;

	private String srbEcogridEndPoint = null;

	private String srbMachineName = null;

	protected String baseURL = null;

	public ConfigurableEcogridEndPoint() {

		if (!loadProperties()) {

			try {

				//use values from server where deployed

				baseURL = 

					"http://"

					+ PropertyService.getProperty("server.name")

					+ ":"

					+ PropertyService.getProperty("server.httpPort")

					+ "/"

					+ PropertyService.getProperty("application.context")

					+ "/services/";

				metacatEcogridEndPoint = baseURL + "QueryService";

				metacatEcogridAuthEndPoint = baseURL + "AuthenticationService";

				metacatEcogridPutEndPoint = baseURL + "PutService";

				metacatEcogridIdentifierEndPoint = baseURL + "IdentificationService";

			} catch (PropertyNotFoundException e) {

				//we are SOL now

				e.printStackTrace();

			}

		}	

	}

	private boolean loadProperties() {

		try {

			metacatEcogridEndPoint 				= PropertyService.getProperty("datamanager.endpoint.query");

			metacatEcogridAuthEndPoint 			= PropertyService.getProperty("datamanager.endpoint.authentication");

			metacatEcogridPutEndPoint 			= PropertyService.getProperty("datamanager.endpoint.put");

			metacatEcogridIdentifierEndPoint 	= PropertyService.getProperty("datamanager.endpoint.identifier");

			srbEcogridEndPoint 					= PropertyService.getProperty("datamanager.srb.endpoint");

			srbMachineName 						= PropertyService.getProperty("datamanager.srb.machinename");

		} catch (PropertyNotFoundException e) {

			//e.printStackTrace();

			return false;

		}

		if (metacatEcogridEndPoint == null || metacatEcogridEndPoint.length() == 0) {

			return false;

		}

		return true;

	}

	 /**

	    * Gets the end point which Metacat implements ecogrid interface.

	    * This end point will be used to handle ecogrid protocol

        * 

	    * @return end point url string

	    */

	   public String getMetacatEcogridEndPoint()

	   {

		   return metacatEcogridEndPoint;

	   }

	   public String getMetacatEcogridAuthEndPoint()

	   {

		   return metacatEcogridAuthEndPoint;

	   }

	   public String getMetacatEcogridPutEndPoint()

	   {

		   return metacatEcogridPutEndPoint;

	   }

	   public String getMetacatEcogridIdentifierEndPoint() 

	   {

			return metacatEcogridIdentifierEndPoint;

		}

	   /**

	    * Gets the end point which SRB implements ecogrid interface.

	    * This end point will be used to handle srb protocol.

        * 

	    * @return end point url string

	    */

	   public String getSRBEcogridEndPoint()

	   {

		   return srbEcogridEndPoint;

	   }

	   /**

	    * Gets the machine name which srb protocol will be used.

	    * The default value for this class is "srb-mcat.sdsc.edu".

        * 

	    * @return the machine name of srb server

	    */

	   public String getSRBMachineName()

	   {

		   return srbMachineName;

	   }

}

/**

 *    '$RCSfile: ConfigurableEcogridEndPoint.java,v $'

 *

 *     '$Author: leinfelder $'

 *       '$Date: 2008/06/20 17:47:12 $'

 *   '$Revision: 1.1 $'

 *

 *  For Details: http://ecoinformatics.org

 *

 * Copyright (c) 2007 The Regents of the University of California.

 * All rights reserved.

 * 

 * Permission is hereby granted, without written agreement and without

 * license or royalty fees, to use, copy, modify, and distribute this

 * software and its documentation for any purpose, provided that the

 * above copyright notice and the following two paragraphs appear in

 * all copies of this software.

 * 

 * IN NO EVENT SHALL THE UNIVERSITY OF CALIFORNIA BE LIABLE TO ANY PARTY

 * FOR DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES

 * ARISING OUT OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN

 * IF THE UNIVERSITY OF CALIFORNIA HAS BEEN ADVISED OF THE POSSIBILITY

 * OF SUCH DAMAGE.

 * 

 * THE UNIVERSITY OF CALIFORNIA SPECIFICALLY DISCLAIMS ANY WARRANTIES,

 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF

 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. THE SOFTWARE

 * PROVIDED HEREUNDER IS ON AN "AS IS" BASIS, AND THE UNIVERSITY

 * OF CALIFORNIA HAS NO OBLIGATION TO PROVIDE MAINTENANCE, SUPPORT,

 * UPDATES, ENHANCEMENTS, OR MODIFICATIONS.

 */

package edu.ucsb.nceas.metacat.dataquery;

import org.ecoinformatics.datamanager.download.AuthenticatedEcogridEndPointInterface;

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

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

/**

 * This class implements AuthenticatedEcogridEndPointInterface 

 * and is configurable using the properties file.

 * Useful for switching to remote endpoints etc.

 * 

 * @author leinfelder

 *

 */

public class ConfigurableAuthenticatedEcogridEndPoint 

	extends ConfigurableEcogridEndPoint implements AuthenticatedEcogridEndPointInterface  {  

	private String metacatAuthenticatedEcogridEndPoint = null;

	private String sessionId = null;

	public ConfigurableAuthenticatedEcogridEndPoint() {

		super();

		if (!loadProperties()) {

			metacatAuthenticatedEcogridEndPoint = baseURL + "AuthenticatedQueryService";

		}

	}

	public ConfigurableAuthenticatedEcogridEndPoint(String sessionId) {

		this();

		this.sessionId = sessionId;

	}

	private boolean loadProperties() {

		try {

			metacatAuthenticatedEcogridEndPoint = PropertyService.getProperty("datamanager.endpoint.authenticatedquery");

		} catch (PropertyNotFoundException e) {

			//e.printStackTrace();

			return false;

		}

		if (metacatAuthenticatedEcogridEndPoint == null || metacatAuthenticatedEcogridEndPoint.length() == 0) {

			return false;

		}

		return true;

	}

	 /**

	    * Gets the end point which Metacat implements authenticated ecogrid interface.

	    * This end point will be used to handle ecogrid protocol

        * 

	    * @return end point url string

	    */

	   public String getMetacatAuthenticatedEcogridEndPoint()

	   {

		   return metacatAuthenticatedEcogridEndPoint;

	   }

	   public String getSessionId()

	   {

		   return sessionId;

	   }

	   public void setSessionId(String id) {

		   sessionId = id;

	   }

}

/**

 *    '$RCSfile: DatabaseConnectionPoolFactory.java,v $'

 *

 *     '$Author: leinfelder $'

 *       '$Date: 2007/10/05 21:10:17 $'

 *   '$Revision: 1.1 $'

 *

 *  For Details: http://kepler.ecoinformatics.org

 *

 * Copyright (c) 2003 The Regents of the University of California.

 * All rights reserved.

 * 

 * Permission is hereby granted, without written agreement and without

 * license or royalty fees, to use, copy, modify, and distribute this

 * software and its documentation for any purpose, provided that the

 * above copyright notice and the following two paragraphs appear in

 * all copies of this software.

 * 

 * IN NO EVENT SHALL THE UNIVERSITY OF CALIFORNIA BE LIABLE TO ANY PARTY

 * FOR DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES

 * ARISING OUT OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN

 * IF THE UNIVERSITY OF CALIFORNIA HAS BEEN ADVISED OF THE POSSIBILITY

 * OF SUCH DAMAGE.

 * 

 * THE UNIVERSITY OF CALIFORNIA SPECIFICALLY DISCLAIMS ANY WARRANTIES,

 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF

 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. THE SOFTWARE

 * PROVIDED HEREUNDER IS ON AN "AS IS" BASIS, AND THE UNIVERSITY

 * OF CALIFORNIA HAS NO OBLIGATION TO PROVIDE MAINTENANCE, SUPPORT,

 * UPDATES, ENHANCEMENTS, OR MODIFICATIONS.

 */

package edu.ucsb.nceas.metacat.dataquery;

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

import java.sql.Connection;

import java.sql.SQLException;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.ecoinformatics.datamanager.database.ConnectionNotAvailableException;

import org.ecoinformatics.datamanager.database.DatabaseConnectionPoolInterface;

/**

 * This class provides an implementation of DataConnetionPoolInterface 

 * Implementation and database information for this class will be read from property file.

 * 

 * @author leinfelder

 * 

 */

public class DatabaseConnectionPoolFactory {

	public static Log log = LogFactory.getLog(DatabaseConnectionPoolFactory.class);

	private static String implementationClass = null;

	static {

		loadOptions();

	}

	/**

	 * Constructor. Loading database parameter from property file

	 * 

	 */

	public DatabaseConnectionPoolFactory() {

	}

	/**

	 * Loads Data Manager options from a configuration file.

	 */

	private static void loadOptions() {

		try {

			implementationClass = PropertyService.getProperty("datamanager.implementation");

		} 

		catch (Exception e) {

			log.error("Error in loading options: " + e.getMessage());

		}

	}

	public static DatabaseConnectionPoolInterface getDatabaseConnectionPoolInterface() {

		DatabaseConnectionPoolInterface instance = null;

		try {

			instance = 

				(DatabaseConnectionPoolInterface) Class.forName(implementationClass).newInstance();

		} catch (Exception e) {

			log.error(e.getMessage() 

					+ ": could not create DatabaseConnectionPoolInterface implementation: " 

					+ implementationClass);

			e.printStackTrace();

		} 

		return instance;

	}

	public static void main(String arg[]) {

		Connection conn = null;

		try {

			conn = DatabaseConnectionPoolFactory.getDatabaseConnectionPoolInterface().getConnection();

			log.debug("conn=" + conn);

		} catch (SQLException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		} catch (ConnectionNotAvailableException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}

		finally {

			try {

				conn.close();

			} catch (SQLException e) {

				// TODO Auto-generated catch block

				e.printStackTrace();

			}

		}

	}

}

		endPointInfo = new ConfigurableEcogridEndPoint();

		endPointInfo = new ConfigurableAuthenticatedEcogridEndPoint(sessionId);

		connectionPool = DatabaseConnectionPoolFactory.getDatabaseConnectionPoolInterface();