0.8.1-rc1/filemgr/src/main/java/org/apache/oodt/cas/filemgr/repository/DataSourceRepositoryManager.java - oodt - Git at Google

 /*
  * Licensed to the Apache Software Foundation (ASF) under one or more
  * contributor license agreements.  See the NOTICE file distributed with
  * this work for additional information regarding copyright ownership.
  * The ASF licenses this file to You under the Apache License, Version 2.0
  * (the "License"); you may not use this file except in compliance with
  * the License.  You may obtain a copy of the License at
  *
  *     http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */

 package org.apache.oodt.cas.filemgr.repository;

 //OODT imports
 import org.apache.oodt.cas.filemgr.structs.ProductType;
 import org.apache.oodt.cas.filemgr.structs.exceptions.RepositoryManagerException;
 import org.apache.oodt.cas.filemgr.util.DbStructFactory;

 //JDK imports
 import java.sql.Connection;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
 import java.util.List;
 import java.util.Vector;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 import javax.sql.DataSource;

 /**
  * @author mattmann
  * @author bfoster
  * @version $Revision$
  *
  * <p>
  * An implementation of the {@link RepositoryManager} interface that is backed
  * by a {@link DataSource} for storing and retreiving {@link Product} policy in
  * the form of {@link ProductType}s.
  * </p>
  *
  */
 public class DataSourceRepositoryManager implements RepositoryManager {

     /* our sql data source */
     private DataSource dataSource = null;

     /* our log stream */
     private static final Logger LOG = Logger.getLogger(DataSourceRepositoryManager.class
             .getName());

     /**
      *
      * <p>
      * Default Constructor
      * </p>.
      *
      * @param ds
      *            The DataSource to initialize this repository manager with.
      */
     public DataSourceRepositoryManager(DataSource ds) {
         this.dataSource = ds;
     }

     /*
      * (non-Javadoc)
      *
      * @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#addProductType(org.apache.oodt.cas.filemgr.structs.ProductType)
      */
     public synchronized void addProductType(ProductType productType)
             throws RepositoryManagerException {
         Connection conn = null;
         Statement statement = null;
         ResultSet rs = null;

         try {
             conn = dataSource.getConnection();
             conn.setAutoCommit(false);
             statement = conn.createStatement();

             String addProductTypeSql = "INSERT INTO product_types (product_type_name, product_type_description, product_type_repository_path, product_type_versioner_class) "
                     + "VALUES ('"
                     + productType.getName()
                     + "', '"
                     + productType.getDescription()
                     + "', '"
                     + productType.getProductRepositoryPath()
                     + "', '"
                     + productType.getVersioner() + "')";

             LOG.log(Level.FINE, "addProductType: Executing: "
                     + addProductTypeSql);
             statement.execute(addProductTypeSql);

             String productTypeId = new String();
             String getProductTypeIdSql = "SELECT MAX(product_type_id) AS max_id FROM product_types";

             rs = statement.executeQuery(getProductTypeIdSql);

             while (rs.next()) {
                 productTypeId = String.valueOf(rs.getInt("max_id"));
             }

             productType.setProductTypeId(productTypeId);

             // create the references table
             String createRefSql = "CREATE TABLE product_reference_"
                     + productTypeId
                     + " (product_id int NOT NULL, product_orig_reference varchar(255), product_datastore_reference varchar(255))";
             LOG.log(Level.FINE, "addProductType: Executing: " + createRefSql);
             statement.execute(createRefSql);

             // create the metadata table
             String createMetaSql = "CREATE TABLE product_metadata_"
                     + productTypeId
                     + " (product_id int NOT NULL, element_id int NOT NULL, metadata_value varchar(2000) NOT NULL)";
             LOG.log(Level.FINE, "addProductType: Executing: " + createMetaSql);
             statement.execute(createMetaSql);
             conn.commit();

         } catch (Exception e) {
             e.printStackTrace();
             LOG.log(Level.WARNING, "Exception adding product type. Message: "
                     + e.getMessage());
             try {
                 conn.rollback();
             } catch (SQLException e2) {
                 LOG.log(Level.SEVERE,
                         "Unable to rollback addProductType transaction. Message: "
                                 + e2.getMessage());
             }
             throw new RepositoryManagerException(e.getMessage());
         } finally {

             if (rs != null) {
                 try {
                     rs.close();
                 } catch (SQLException ignore) {
                 }

                 rs = null;
             }

             if (statement != null) {
                 try {
                     statement.close();
                 } catch (SQLException ignore) {
                 }

                 statement = null;
             }

             if (conn != null) {
                 try {
                     conn.close();

                 } catch (SQLException ignore) {
                 }

                 conn = null;
             }
         }

     }

     /*
      * (non-Javadoc)
      *
      * @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#modifyProductType(org.apache.oodt.cas.filemgr.structs.ProductType)
      */
     public synchronized void modifyProductType(ProductType productType)
             throws RepositoryManagerException {
         Connection conn = null;
         Statement statement = null;

         try {
             conn = dataSource.getConnection();
             conn.setAutoCommit(false);
             statement = conn.createStatement();

             String modifyProductTypeSql = "UPDATE product_types SET product_type_name='"
                     + productType.getName()
                     + "', product_type_description='"
                     + productType.getDescription()
                     + "', "
                     + "product_type_versioner_class='"
                     + productType.getVersioner()
                     + "', product_type_repository_path='"
                     + productType.getProductRepositoryPath()
                     + "' "
                     + "WHERE product_type_id = "
                     + productType.getProductTypeId();

             LOG.log(Level.FINE, "modifyProductType: Executing: "
                     + modifyProductTypeSql);
             statement.execute(modifyProductTypeSql);
             conn.commit();

         } catch (Exception e) {
             e.printStackTrace();
             LOG.log(Level.WARNING,
                     "Exception modifying product type. Message: "
                             + e.getMessage());
             try {
                 conn.rollback();
             } catch (SQLException e2) {
                 LOG.log(Level.SEVERE,
                         "Unable to rollback modifyProductType transaction. Message: "
                                 + e2.getMessage());
             }
             throw new RepositoryManagerException(e.getMessage());
         } finally {

             if (statement != null) {
                 try {
                     statement.close();
                 } catch (SQLException ignore) {
                 }

                 statement = null;
             }

             if (conn != null) {
                 try {
                     conn.close();

                 } catch (SQLException ignore) {
                 }

                 conn = null;
             }
         }

     }

     /*
      * (non-Javadoc)
      *
      * @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#removeProductType(org.apache.oodt.cas.filemgr.structs.ProductType)
      */
     public void removeProductType(ProductType productType)
             throws RepositoryManagerException {
         Connection conn = null;
         Statement statement = null;

         try {
             conn = dataSource.getConnection();
             conn.setAutoCommit(false);
             statement = conn.createStatement();

             String deleteProductTypeSql = "DELETE FROM product_types WHERE product_type_id = "
                     + productType.getProductTypeId();

             LOG.log(Level.FINE, "removeProductType: Executing: "
                     + deleteProductTypeSql);
             statement.execute(deleteProductTypeSql);

             // TODO: Decide if it makes sense to delete the references table
             // and the metadata table here. For now, we won't because maybe
             // they'll just want to remove the ability to deal with this product
             // type
             // rather than remove all of the metdata and references for the
             // products with it
             conn.commit();

         } catch (Exception e) {
             e.printStackTrace();
             LOG.log(Level.WARNING, "Exception removing product type. Message: "
                     + e.getMessage());
             try {
                 conn.rollback();
             } catch (SQLException e2) {
                 LOG.log(Level.SEVERE,
                         "Unable to rollback removeProductType transaction. Message: "
                                 + e2.getMessage());
             }
             throw new RepositoryManagerException(e.getMessage());
         } finally {
             if (statement != null) {
                 try {
                     statement.close();
                 } catch (SQLException ignore) {
                 }

                 statement = null;
             }

             if (conn != null) {
                 try {
                     conn.close();

                 } catch (SQLException ignore) {
                 }

                 conn = null;
             }
         }

     }

     /*
      * (non-Javadoc)
      *
      * @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#getProductTypeById(java.lang.String)
      */
     public ProductType getProductTypeById(String productTypeId)
             throws RepositoryManagerException {
         Connection conn = null;
         Statement statement = null;
         ResultSet rs = null;

         ProductType productType = null;

         try {
             conn = dataSource.getConnection();
             statement = conn.createStatement();

             String getProductTypeSql = "SELECT * from product_types WHERE product_type_id = "
                     + productTypeId;

             LOG.log(Level.FINE, "getProductTypeById: Executing: "
                     + getProductTypeSql);
             rs = statement.executeQuery(getProductTypeSql);

             while (rs.next()) {
                 productType = DbStructFactory.getProductType(rs);
             }

         } catch (Exception e) {
             e.printStackTrace();
             LOG.log(Level.WARNING, "Exception getting product type. Message: "
                     + e.getMessage());
             try {
                 conn.rollback();
             } catch (SQLException e2) {
                 LOG.log(Level.SEVERE,
                         "Unable to rollback getProductTypeById transaction. Message: "
                                 + e2.getMessage());
             }
             throw new RepositoryManagerException(e.getMessage());
         } finally {

             if (rs != null) {
                 try {
                     rs.close();
                 } catch (SQLException ignore) {
                 }

                 rs = null;
             }

             if (statement != null) {
                 try {
                     statement.close();
                 } catch (SQLException ignore) {
                 }

                 statement = null;
             }

             if (conn != null) {
                 try {
                     conn.close();

                 } catch (SQLException ignore) {
                 }

                 conn = null;
             }
         }

         return productType;
     }

     /*
      * (non-Javadoc)
      *
      * @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#getProductTypeByName(java.lang.String)
      */
     public ProductType getProductTypeByName(String productTypeName)
             throws RepositoryManagerException {
         Connection conn = null;
         Statement statement = null;
         ResultSet rs = null;

         ProductType productType = null;

         try {
             conn = dataSource.getConnection();
             statement = conn.createStatement();

             String getProductTypeSql = "SELECT * from product_types WHERE product_type_name = '"
                     + productTypeName + "'";

             LOG.log(Level.FINE, "getProductTypeByName: Executing: "
                     + getProductTypeSql);
             rs = statement.executeQuery(getProductTypeSql);

             while (rs.next()) {
                 productType = DbStructFactory.getProductType(rs);
             }

         } catch (Exception e) {
             e.printStackTrace();
             LOG.log(Level.WARNING, "Exception getting product type. Message: "
                     + e.getMessage());
             try {
                 conn.rollback();
             } catch (SQLException e2) {
                 LOG.log(Level.SEVERE,
                         "Unable to rollback getProductTypeByName transaction. Message: "
                                 + e2.getMessage());
             }
             throw new RepositoryManagerException(e.getMessage());
         } finally {

             if (rs != null) {
                 try {
                     rs.close();
                 } catch (SQLException ignore) {
                 }

                 rs = null;
             }

             if (statement != null) {
                 try {
                     statement.close();
                 } catch (SQLException ignore) {
                 }

                 statement = null;
             }

             if (conn != null) {
                 try {
                     conn.close();

                 } catch (SQLException ignore) {
                 }

                 conn = null;
             }
         }

         return productType;
     }

     /*
      * (non-Javadoc)
      *
      * @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#getProductTypes()
      */
     public List<ProductType> getProductTypes() throws RepositoryManagerException {
         Connection conn = null;
         Statement statement = null;
         ResultSet rs = null;

         List<ProductType> productTypes = null;

         try {
             conn = dataSource.getConnection();
             statement = conn.createStatement();

             String getProductTypeSql = "SELECT * from product_types";

             LOG.log(Level.FINE, "getProductTypes: Executing: "
                     + getProductTypeSql);
             rs = statement.executeQuery(getProductTypeSql);

             productTypes = new Vector<ProductType>();
             while (rs.next()) {
                 ProductType productType = DbStructFactory.getProductType(rs);
                 productTypes.add(productType);
             }

             if (productTypes.size() == 0) {
                 productTypes = null;
             }

         } catch (Exception e) {
             e.printStackTrace();
             LOG.log(Level.WARNING, "Exception getting product types. Message: "
                     + e.getMessage());
             try {
                 conn.rollback();
             } catch (SQLException e2) {
                 LOG.log(Level.SEVERE,
                         "Unable to rollback getProductTypes transaction. Message: "
                                 + e2.getMessage());
             }
             throw new RepositoryManagerException(e.getMessage());
         } finally {

             if (rs != null) {
                 try {
                     rs.close();
                 } catch (SQLException ignore) {
                 }

                 rs = null;
             }

             if (statement != null) {
                 try {
                     statement.close();
                 } catch (SQLException ignore) {
                 }

                 statement = null;
             }

             if (conn != null) {
                 try {
                     conn.close();

                 } catch (SQLException ignore) {
                 }

                 conn = null;
             }
         }

         return productTypes;
     }

 }
	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF licenses this file to You under the Apache License, Version 2.0
	* (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	package org.apache.oodt.cas.filemgr.repository;

	//OODT imports
	import org.apache.oodt.cas.filemgr.structs.ProductType;
	import org.apache.oodt.cas.filemgr.structs.exceptions.RepositoryManagerException;
	import org.apache.oodt.cas.filemgr.util.DbStructFactory;

	//JDK imports
	import java.sql.Connection;
	import java.sql.ResultSet;
	import java.sql.SQLException;
	import java.sql.Statement;
	import java.util.List;
	import java.util.Vector;
	import java.util.logging.Level;
	import java.util.logging.Logger;
	import javax.sql.DataSource;

	/**
	* @author mattmann
	* @author bfoster
	* @version $Revision$
	*
	* <p>
	* An implementation of the {@link RepositoryManager} interface that is backed
	* by a {@link DataSource} for storing and retreiving {@link Product} policy in
	* the form of {@link ProductType}s.
	* </p>
	*
	*/
	public class DataSourceRepositoryManager implements RepositoryManager {

	/* our sql data source */
	private DataSource dataSource = null;

	/* our log stream */
	private static final Logger LOG = Logger.getLogger(DataSourceRepositoryManager.class
	.getName());

	/**
	*
	* <p>
	* Default Constructor
	* </p>.
	*
	* @param ds
	* The DataSource to initialize this repository manager with.
	*/
	public DataSourceRepositoryManager(DataSource ds) {
	this.dataSource = ds;
	}

	/*
	* (non-Javadoc)
	*
	* @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#addProductType(org.apache.oodt.cas.filemgr.structs.ProductType)
	*/
	public synchronized void addProductType(ProductType productType)
	throws RepositoryManagerException {
	Connection conn = null;
	Statement statement = null;
	ResultSet rs = null;

	try {
	conn = dataSource.getConnection();
	conn.setAutoCommit(false);
	statement = conn.createStatement();

	String addProductTypeSql = "INSERT INTO product_types (product_type_name, product_type_description, product_type_repository_path, product_type_versioner_class) "
	+ "VALUES ('"
	+ productType.getName()
	+ "', '"
	+ productType.getDescription()
	+ "', '"
	+ productType.getProductRepositoryPath()
	+ "', '"
	+ productType.getVersioner() + "')";

	LOG.log(Level.FINE, "addProductType: Executing: "
	+ addProductTypeSql);
	statement.execute(addProductTypeSql);

	String productTypeId = new String();
	String getProductTypeIdSql = "SELECT MAX(product_type_id) AS max_id FROM product_types";

	rs = statement.executeQuery(getProductTypeIdSql);

	while (rs.next()) {
	productTypeId = String.valueOf(rs.getInt("max_id"));
	}

	productType.setProductTypeId(productTypeId);

	// create the references table
	String createRefSql = "CREATE TABLE product_reference_"
	+ productTypeId
	+ " (product_id int NOT NULL, product_orig_reference varchar(255), product_datastore_reference varchar(255))";
	LOG.log(Level.FINE, "addProductType: Executing: " + createRefSql);
	statement.execute(createRefSql);

	// create the metadata table
	String createMetaSql = "CREATE TABLE product_metadata_"
	+ productTypeId
	+ " (product_id int NOT NULL, element_id int NOT NULL, metadata_value varchar(2000) NOT NULL)";
	LOG.log(Level.FINE, "addProductType: Executing: " + createMetaSql);
	statement.execute(createMetaSql);
	conn.commit();

	} catch (Exception e) {
	e.printStackTrace();
	LOG.log(Level.WARNING, "Exception adding product type. Message: "
	+ e.getMessage());
	try {
	conn.rollback();
	} catch (SQLException e2) {
	LOG.log(Level.SEVERE,
	"Unable to rollback addProductType transaction. Message: "
	+ e2.getMessage());
	}
	throw new RepositoryManagerException(e.getMessage());
	} finally {

	if (rs != null) {
	try {
	rs.close();
	} catch (SQLException ignore) {
	}

	rs = null;
	}

	if (statement != null) {
	try {
	statement.close();
	} catch (SQLException ignore) {
	}

	statement = null;
	}

	if (conn != null) {
	try {
	conn.close();

	} catch (SQLException ignore) {
	}

	conn = null;
	}
	}

	}

	/*
	* (non-Javadoc)
	*
	* @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#modifyProductType(org.apache.oodt.cas.filemgr.structs.ProductType)
	*/
	public synchronized void modifyProductType(ProductType productType)
	throws RepositoryManagerException {
	Connection conn = null;
	Statement statement = null;

	try {
	conn = dataSource.getConnection();
	conn.setAutoCommit(false);
	statement = conn.createStatement();

	String modifyProductTypeSql = "UPDATE product_types SET product_type_name='"
	+ productType.getName()
	+ "', product_type_description='"
	+ productType.getDescription()
	+ "', "
	+ "product_type_versioner_class='"
	+ productType.getVersioner()
	+ "', product_type_repository_path='"
	+ productType.getProductRepositoryPath()
	+ "' "
	+ "WHERE product_type_id = "
	+ productType.getProductTypeId();

	LOG.log(Level.FINE, "modifyProductType: Executing: "
	+ modifyProductTypeSql);
	statement.execute(modifyProductTypeSql);
	conn.commit();

	} catch (Exception e) {
	e.printStackTrace();
	LOG.log(Level.WARNING,
	"Exception modifying product type. Message: "
	+ e.getMessage());
	try {
	conn.rollback();
	} catch (SQLException e2) {
	LOG.log(Level.SEVERE,
	"Unable to rollback modifyProductType transaction. Message: "
	+ e2.getMessage());
	}
	throw new RepositoryManagerException(e.getMessage());
	} finally {

	if (statement != null) {
	try {
	statement.close();
	} catch (SQLException ignore) {
	}

	statement = null;
	}

	if (conn != null) {
	try {
	conn.close();

	} catch (SQLException ignore) {
	}

	conn = null;
	}
	}

	}

	/*
	* (non-Javadoc)
	*
	* @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#removeProductType(org.apache.oodt.cas.filemgr.structs.ProductType)
	*/
	public void removeProductType(ProductType productType)
	throws RepositoryManagerException {
	Connection conn = null;
	Statement statement = null;

	try {
	conn = dataSource.getConnection();
	conn.setAutoCommit(false);
	statement = conn.createStatement();

	String deleteProductTypeSql = "DELETE FROM product_types WHERE product_type_id = "
	+ productType.getProductTypeId();

	LOG.log(Level.FINE, "removeProductType: Executing: "
	+ deleteProductTypeSql);
	statement.execute(deleteProductTypeSql);

	// TODO: Decide if it makes sense to delete the references table
	// and the metadata table here. For now, we won't because maybe
	// they'll just want to remove the ability to deal with this product
	// type
	// rather than remove all of the metdata and references for the
	// products with it
	conn.commit();

	} catch (Exception e) {
	e.printStackTrace();
	LOG.log(Level.WARNING, "Exception removing product type. Message: "
	+ e.getMessage());
	try {
	conn.rollback();
	} catch (SQLException e2) {
	LOG.log(Level.SEVERE,
	"Unable to rollback removeProductType transaction. Message: "
	+ e2.getMessage());
	}
	throw new RepositoryManagerException(e.getMessage());
	} finally {
	if (statement != null) {
	try {
	statement.close();
	} catch (SQLException ignore) {
	}

	statement = null;
	}

	if (conn != null) {
	try {
	conn.close();

	} catch (SQLException ignore) {
	}

	conn = null;
	}
	}

	}

	/*
	* (non-Javadoc)
	*
	* @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#getProductTypeById(java.lang.String)
	*/
	public ProductType getProductTypeById(String productTypeId)
	throws RepositoryManagerException {
	Connection conn = null;
	Statement statement = null;
	ResultSet rs = null;

	ProductType productType = null;

	try {
	conn = dataSource.getConnection();
	statement = conn.createStatement();

	String getProductTypeSql = "SELECT * from product_types WHERE product_type_id = "
	+ productTypeId;

	LOG.log(Level.FINE, "getProductTypeById: Executing: "
	+ getProductTypeSql);
	rs = statement.executeQuery(getProductTypeSql);

	while (rs.next()) {
	productType = DbStructFactory.getProductType(rs);
	}

	} catch (Exception e) {
	e.printStackTrace();
	LOG.log(Level.WARNING, "Exception getting product type. Message: "
	+ e.getMessage());
	try {
	conn.rollback();
	} catch (SQLException e2) {
	LOG.log(Level.SEVERE,
	"Unable to rollback getProductTypeById transaction. Message: "
	+ e2.getMessage());
	}
	throw new RepositoryManagerException(e.getMessage());
	} finally {

	if (rs != null) {
	try {
	rs.close();
	} catch (SQLException ignore) {
	}

	rs = null;
	}

	if (statement != null) {
	try {
	statement.close();
	} catch (SQLException ignore) {
	}

	statement = null;
	}

	if (conn != null) {
	try {
	conn.close();

	} catch (SQLException ignore) {
	}

	conn = null;
	}
	}

	return productType;
	}

	/*
	* (non-Javadoc)
	*
	* @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#getProductTypeByName(java.lang.String)
	*/
	public ProductType getProductTypeByName(String productTypeName)
	throws RepositoryManagerException {
	Connection conn = null;
	Statement statement = null;
	ResultSet rs = null;

	ProductType productType = null;

	try {
	conn = dataSource.getConnection();
	statement = conn.createStatement();

	String getProductTypeSql = "SELECT * from product_types WHERE product_type_name = '"
	+ productTypeName + "'";

	LOG.log(Level.FINE, "getProductTypeByName: Executing: "
	+ getProductTypeSql);
	rs = statement.executeQuery(getProductTypeSql);

	while (rs.next()) {
	productType = DbStructFactory.getProductType(rs);
	}

	} catch (Exception e) {
	e.printStackTrace();
	LOG.log(Level.WARNING, "Exception getting product type. Message: "
	+ e.getMessage());
	try {
	conn.rollback();
	} catch (SQLException e2) {
	LOG.log(Level.SEVERE,
	"Unable to rollback getProductTypeByName transaction. Message: "
	+ e2.getMessage());
	}
	throw new RepositoryManagerException(e.getMessage());
	} finally {

	if (rs != null) {
	try {
	rs.close();
	} catch (SQLException ignore) {
	}

	rs = null;
	}

	if (statement != null) {
	try {
	statement.close();
	} catch (SQLException ignore) {
	}

	statement = null;
	}

	if (conn != null) {
	try {
	conn.close();

	} catch (SQLException ignore) {
	}

	conn = null;
	}
	}

	return productType;
	}

	/*
	* (non-Javadoc)
	*
	* @see org.apache.oodt.cas.filemgr.repository.RepositoryManager#getProductTypes()
	*/
	public List<ProductType> getProductTypes() throws RepositoryManagerException {
	Connection conn = null;
	Statement statement = null;
	ResultSet rs = null;

	List<ProductType> productTypes = null;

	try {
	conn = dataSource.getConnection();
	statement = conn.createStatement();

	String getProductTypeSql = "SELECT * from product_types";

	LOG.log(Level.FINE, "getProductTypes: Executing: "
	+ getProductTypeSql);
	rs = statement.executeQuery(getProductTypeSql);

	productTypes = new Vector<ProductType>();
	while (rs.next()) {
	ProductType productType = DbStructFactory.getProductType(rs);
	productTypes.add(productType);
	}

	if (productTypes.size() == 0) {
	productTypes = null;
	}

	} catch (Exception e) {
	e.printStackTrace();
	LOG.log(Level.WARNING, "Exception getting product types. Message: "
	+ e.getMessage());
	try {
	conn.rollback();
	} catch (SQLException e2) {
	LOG.log(Level.SEVERE,
	"Unable to rollback getProductTypes transaction. Message: "
	+ e2.getMessage());
	}
	throw new RepositoryManagerException(e.getMessage());
	} finally {

	if (rs != null) {
	try {
	rs.close();
	} catch (SQLException ignore) {
	}

	rs = null;
	}

	if (statement != null) {
	try {
	statement.close();
	} catch (SQLException ignore) {
	}

	statement = null;
	}

	if (conn != null) {
	try {
	conn.close();

	} catch (SQLException ignore) {
	}

	conn = null;
	}
	}

	return productTypes;
	}

	}