/*
* 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.util;
//JDK imports
import java.util.logging.Level;
import java.util.logging.Logger;
//OODT imports
import org.apache.oodt.cas.filemgr.datatransfer.DataTransfer;
import org.apache.oodt.cas.filemgr.datatransfer.DataTransferFactory;
import org.apache.oodt.cas.filemgr.ingest.Cache;
import org.apache.oodt.cas.filemgr.ingest.CacheFactory;
import org.apache.oodt.cas.filemgr.metadata.extractors.FilemgrMetExtractor;
import org.apache.oodt.cas.filemgr.repository.RepositoryManager;
import org.apache.oodt.cas.filemgr.repository.RepositoryManagerFactory;
import org.apache.oodt.cas.filemgr.structs.query.conv.VersionConverter;
import org.apache.oodt.cas.filemgr.structs.query.filter.FilterAlgor;
import org.apache.oodt.cas.filemgr.structs.type.TypeHandler;
import org.apache.oodt.cas.filemgr.catalog.Catalog;
import org.apache.oodt.cas.filemgr.catalog.CatalogFactory;
import org.apache.oodt.cas.filemgr.validation.ValidationLayer;
import org.apache.oodt.cas.filemgr.validation.ValidationLayerFactory;
import org.apache.oodt.cas.filemgr.versioning.Versioner;
/**
* @author mattmann
* @author bfoster
* @version $Revision$
*
* <p>
* Generic object creation utilities for FileManager objects from their
* interface class names.
* </p>
*
*/
public final class GenericFileManagerObjectFactory {
/* our log stream */
private static Logger LOG = Logger
.getLogger(GenericFileManagerObjectFactory.class.getName());
private GenericFileManagerObjectFactory() throws InstantiationException {
throw new InstantiationException(
"Don't construct final factory classes!");
}
/**
* <p>
* Constructs a new {@link DataTransfer} from the specified
* <code>serviceFactory</code>.
* </p>
*
* @param serviceFactory
* The Service Factory class name that will be instantiated to
* provide DataTransfer objects.
* @return A newly instantiated {@link DataTransfer} object.
*/
public static DataTransfer getDataTransferServiceFromFactory(
String serviceFactory) {
DataTransferFactory dataTransferFactory = null;
Class<DataTransferFactory> dataTransferFactoryClass = null;
try {
dataTransferFactoryClass = (Class<DataTransferFactory>) Class.forName(serviceFactory);
dataTransferFactory = dataTransferFactoryClass.newInstance();
return dataTransferFactory.createDataTransfer();
} catch (ClassNotFoundException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"ClassNotFoundException when loading data transfer factory class "
+ serviceFactory + " Message: " + e.getMessage());
} catch (InstantiationException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"InstantiationException when loading data transfer factory class "
+ serviceFactory + " Message: " + e.getMessage());
} catch (IllegalAccessException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"IllegalAccessException when loading data transfer factory class "
+ serviceFactory + " Message: " + e.getMessage());
}
return null;
}
/**
* <p>
* Constructs a new {@link RepositoryManager} from the specified
* <code>serviceFactory</code>.
* </p>
*
* @param serviceFactory
* The class name of the service factory used to create new
* RepositoryManager objects.
* @return A newly constructed {@link RepositoryManager} object.
*/
public static RepositoryManager getRepositoryManagerServiceFromFactory(
String serviceFactory) {
RepositoryManagerFactory factory = null;
Class<RepositoryManagerFactory> clazz = null;
try {
clazz = (Class<RepositoryManagerFactory>) Class.forName(serviceFactory);
factory = clazz.newInstance();
return factory.createRepositoryManager();
} catch (ClassNotFoundException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"ClassNotFoundException when loading data store factory class "
+ serviceFactory + " Message: " + e.getMessage());
} catch (InstantiationException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"InstantiationException when loading data store factory class "
+ serviceFactory + " Message: " + e.getMessage());
} catch (IllegalAccessException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"IllegalAccessException when loading data store factory class "
+ serviceFactory + " Message: " + e.getMessage());
}
return null;
}
/**
* <p>
* Constructs a new {@link Catalog} from the specified
* <code>serviceFactory</code>.
* </p>
*
* @param serviceFactory
* The class name of the service factory used to create new
* Catalog objects.
* @return A newly constructed {@link Catalog} object.
*/
public static Catalog getCatalogServiceFromFactory(String serviceFactory) {
CatalogFactory factory = null;
Class<CatalogFactory> clazz = null;
try {
clazz = (Class<CatalogFactory>) Class.forName(serviceFactory);
factory = clazz.newInstance();
return factory.createCatalog();
} catch (ClassNotFoundException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"ClassNotFoundException when loading metadata store factory class "
+ serviceFactory + " Message: " + e.getMessage());
} catch (InstantiationException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"InstantiationException when loading metadata store factory class "
+ serviceFactory + " Message: " + e.getMessage());
} catch (IllegalAccessException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"IllegalAccessException when loading metadata store factory class "
+ serviceFactory + " Message: " + e.getMessage());
}
return null;
}
/**
* <p>
* Creates a {@link ValidationLayer} from the specified
* <code>serviceFactory</code>.
* </p>
*
* @param serviceFactory
* The classname of the ValidationLayerFactory to use to create
* the ValidationLayer.
* @return A new {@link ValidationLayer}, created from the specified
* ValidationLayerFactory.
*/
public static ValidationLayer getValidationLayerFromFactory(
String serviceFactory) {
ValidationLayerFactory factory = null;
Class<ValidationLayerFactory> clazz = null;
try {
clazz = (Class<ValidationLayerFactory>) Class.forName(serviceFactory);
factory = clazz.newInstance();
return factory.createValidationLayer();
} catch (ClassNotFoundException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"ClassNotFoundException when loading validation layer factory class "
+ serviceFactory + " Message: " + e.getMessage());
} catch (InstantiationException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"InstantiationException when loading validation layer factory class "
+ serviceFactory + " Message: " + e.getMessage());
} catch (IllegalAccessException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"IllegalAccessException when loading validation layer factory class "
+ serviceFactory + " Message: " + e.getMessage());
}
return null;
}
public static Cache getCacheFromFactory(String serviceFactory){
CacheFactory factory = null;
Class<CacheFactory> clazz = null;
try {
clazz = (Class<CacheFactory>) Class.forName(serviceFactory);
factory = clazz.newInstance();
return factory.createCache();
} catch (ClassNotFoundException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"ClassNotFoundException when loading cache factory class "
+ serviceFactory + " Message: " + e.getMessage());
} catch (InstantiationException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"InstantiationException when loading cache factory class "
+ serviceFactory + " Message: " + e.getMessage());
} catch (IllegalAccessException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"IllegalAccessException when loading cache factory class "
+ serviceFactory + " Message: " + e.getMessage());
}
return null;
}
/**
* <p>
* Constructs a new {@link Versioner} from the specified
* <code>className</code>.
* </p>
*
* @param className
* The class name of the Versioner object to create.
* @return A newly constructed {@link Versioner} object.
*/
public static Versioner getVersionerFromClassName(String className) {
try {
Class<Versioner> versionerClass = (Class<Versioner>) Class.forName(className);
return versionerClass.newInstance();
} catch (ClassNotFoundException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"ClassNotFoundException when loading versioner class "
+ className + " Message: " + e.getMessage());
} catch (InstantiationException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"InstantiationException when loading versioner class "
+ className + " Message: " + e.getMessage());
} catch (IllegalAccessException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"IllegalAccessException when loading versioner class "
+ className + " Message: " + e.getMessage());
}
return null;
}
public static FilemgrMetExtractor getExtractorFromClassName(String className) {
try {
Class<FilemgrMetExtractor> extractorClass = (Class<FilemgrMetExtractor>) Class.forName(className);
return extractorClass.newInstance();
} catch (ClassNotFoundException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"ClassNotFoundException when loading extractor class "
+ className + " Message: " + e.getMessage());
} catch (InstantiationException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"InstantiationException when loading extractor class "
+ className + " Message: " + e.getMessage());
} catch (IllegalAccessException e) {
e.printStackTrace();
LOG.log(Level.WARNING,
"IllegalAccessException when loading extractor class "
+ className + " Message: " + e.getMessage());
}
return null;
}
public static TypeHandler getTypeHandlerFromClassName(String className) {
try {
return (TypeHandler) Class.forName(className).newInstance();
}catch (Exception e) {
e.printStackTrace();
LOG.log(Level.WARNING, "Failed to load TypeHandler class '" + className + "' : " + e.getMessage());
}
return null;
}
public static FilterAlgor getFilterAlgorFromClassName(String className) {
try {
return (FilterAlgor) Class.forName(className).newInstance();
}catch (Exception e) {
e.printStackTrace();
LOG.log(Level.WARNING, "Failed to load TypeHandler class '" + className + "' : " + e.getMessage());
}
return null;
}
public static VersionConverter getVersionConverterFromClassName(String className) {
try {
return (VersionConverter) Class.forName(className).newInstance();
}catch (Exception e) {
e.printStackTrace();
LOG.log(Level.WARNING, "Failed to load TypeHandler class '" + className + "' : " + e.getMessage());
}
return null;
}
}