DatabaseProperties.java

/*
 * GovWay - A customizable API Gateway 
 * https://govway.org
 * 
 * Copyright (c) 2005-2025 Link.it srl (https://link.it).
 * 
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 3, as published by
 * the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 */
package org.openspcoop2.generic_project.utils;

import org.openspcoop2.generic_project.exception.ServiceException;
import java.util.Properties;

import org.openspcoop2.utils.TipiDatabase;
import org.openspcoop2.utils.UtilsException;


/**
 * DatabaseProperties
 * 
 * @author Poli Andrea (apoli@link.it)
 * @author $Author$
 * @version $Rev$, $Date$
 */
public class DatabaseProperties {

    
    /** Copia Statica */
    private static DatabaseProperties databaseProperties = null;

    public static synchronized void initialize(String propertiesLocalPath, String propertiesName, String nomeFileProperties,org.slf4j.Logger log) throws ServiceException{

        if(DatabaseProperties.databaseProperties==null)
            DatabaseProperties.databaseProperties = new DatabaseProperties(propertiesLocalPath,propertiesName,nomeFileProperties,log);  

    }

    public static DatabaseProperties getInstance(org.slf4j.Logger log) throws ServiceException{
        if(log!=null) {
            // unused
        }
        // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
        if(DatabaseProperties.databaseProperties==null){
            synchronized (DatabaseProperties.class) {
                if(DatabaseProperties.databaseProperties==null){
                    throw new ServiceException("DatabaseProperties not initialized, use initialize method");
                }
            }
        }
        return DatabaseProperties.databaseProperties;
    }
    
    
    
    
    
    /* ********  F I E L D S  P R I V A T I  ******** */

    /** Reader delle proprieta' impostate nel file 'database.properties' */
    private DatabaseInstanceProperties reader;





    /* ********  C O S T R U T T O R E  ******** */

    /**
     * Viene chiamato in causa per istanziare il properties reader
     *
     * 
     */
    private DatabaseProperties(String propertiesLocalPath, String propertiesName, String nomeFileProperties,org.slf4j.Logger log) throws ServiceException{

        /* ---- Lettura del cammino del file di configurazione ---- */

        Properties propertiesReader = new Properties();
        java.io.InputStream properties = null;
        try{  
            properties = DatabaseProperties.class.getResourceAsStream("/"+nomeFileProperties);
            if(properties==null){
                throw new ServiceException("Properties "+nomeFileProperties+" not found");
            }
            propertiesReader.load(properties);
            properties.close();
        }catch(Exception e) {
            doError(log, nomeFileProperties, properties, e);
        }   
    
        try{
            this.reader = new DatabaseInstanceProperties(propertiesLocalPath,propertiesName,propertiesReader, log);
        }catch(Exception e){
            throw new ServiceException(e.getMessage(),e);
        }
    }
    private void doError(org.slf4j.Logger log, String nomeFileProperties, java.io.InputStream properties, Exception e) throws ServiceException {
        String msg = "Riscontrato errore durante la lettura del file '"+nomeFileProperties+"': "+e.getMessage();
        log.error(msg,e);
        try{
            if(properties!=null)
                properties.close();
        }catch(Exception er){
            // close
        }
        throw new ServiceException(e.getMessage(),e);
    }

    
    
    
    
    /* ********  P R O P E R T I E S  ******** */


    private String getProperty(String name,boolean required, boolean convertEnvProperty) throws UtilsException{
        String tmp = null;
        if(convertEnvProperty){
            tmp = this.reader.getValueConvertEnvProperties(name);
        }else{
            tmp = this.reader.getValue(name);
        }
        if(tmp==null &&
            required){
            throw new UtilsException("Property ["+name+"] not found");
        }
        if(tmp!=null){
            return tmp.trim();
        }else{
            return null;
        }
    }
    

    

    // DB

    
    private static final String PROP_TIPO_DATABASE = "db.tipoDatabase";
    public String getTipoDatabase() throws UtilsException {
        return this.getProperty(DatabaseProperties.PROP_TIPO_DATABASE, true, false);
    }
    public TipiDatabase getTipoDatabaseEnum() throws UtilsException {
        return TipiDatabase.toEnumConstant(this.getTipoDatabase());
    }
    
    private static final String PROP_SHOW_SQL = "db.showSql";
    public boolean isShowSql() throws UtilsException {
        return Boolean.parseBoolean(this.getProperty(DatabaseProperties.PROP_SHOW_SQL, true, false));
    }
    
    private static final String PROP_GENERATE_DDL = "db.generateDDL";
    public boolean isGenerateDDL() throws UtilsException {
        return Boolean.parseBoolean(this.getProperty(DatabaseProperties.PROP_GENERATE_DDL, true, false));
    }
    
    private static final String PROP_AUTO_COMMIT = "db.autoCommit";
    public boolean isAutoCommit() throws UtilsException {
        return Boolean.parseBoolean(this.getProperty(DatabaseProperties.PROP_AUTO_COMMIT, true, false));
    }
    
    private static final String PROP_SECONDS_TO_REFRESH_CONNECTION = "db.secondsToRefreshConnection";
    public int getSecondsToRefreshConnection() throws UtilsException {
        return Integer.parseInt(this.getProperty(DatabaseProperties.PROP_SECONDS_TO_REFRESH_CONNECTION, true, false));
    }
    
    public ServiceManagerProperties getServiceManagerProperties() throws UtilsException{
        ServiceManagerProperties sm = new ServiceManagerProperties();
        sm.setDatabaseType(this.getTipoDatabase());
        sm.setShowSql(this.isShowSql());
        sm.setGenerateDdl(this.isGenerateDDL());
        sm.setAutomaticTransactionManagement(this.isAutoCommit());
        sm.setSecondsToRefreshConnection(this.getSecondsToRefreshConnection());
        return sm;
    }
    
    private static final String PROP_TIPO = "db.tipo";
    private static final String PROP_TIPO_VALUE_DATASOURCE = "datasource";
    private static final String PROP_TIPO_VALUE_CONNECTION = "connection";
    private String getTipoAccessoDatabase() throws UtilsException {
        String v = this.getProperty(DatabaseProperties.PROP_TIPO, true, true);
        if(!DatabaseProperties.PROP_TIPO_VALUE_DATASOURCE.equals(v) && !DatabaseProperties.PROP_TIPO_VALUE_CONNECTION.equals(v)){
            throw new UtilsException("Tipo di accesso al database fornito ["+v+"] non valido (supportati "+DatabaseProperties.PROP_TIPO_VALUE_DATASOURCE+","+DatabaseProperties.PROP_TIPO_VALUE_CONNECTION+")");
        }
        return v;
    }
    public boolean isTipoAccessoTramiteDatasource() throws UtilsException{
        return DatabaseProperties.PROP_TIPO_VALUE_DATASOURCE.equals(this.getTipoAccessoDatabase());
    }
    public boolean isTipoAccessoTramiteConnection() throws UtilsException{
        return DatabaseProperties.PROP_TIPO_VALUE_CONNECTION.equals(this.getTipoAccessoDatabase());
    }
    
    private static final String PROP_DATASOURCE_JNDI_NAME = "db.datasource.jndiName";
    public String getDatasourceJNDIName() throws UtilsException {
        return this.getProperty(DatabaseProperties.PROP_DATASOURCE_JNDI_NAME, DatabaseProperties.PROP_TIPO_VALUE_DATASOURCE.equals(this.getTipoAccessoDatabase()), true);
    }
    private static final String PROP_DATASOURCE_JNDI_CONTEXT = "db.datasource.jndiContext";
    public Properties getDatasourceJNDIContext() throws UtilsException {
        return this.reader.readPropertiesConvertEnvProperties(DatabaseProperties.PROP_DATASOURCE_JNDI_CONTEXT);
    }
    
    private static final String PROP_CONNECTION_URL = "db.connection.url";
    public String getConnectionUrl() throws UtilsException {
        return this.getProperty(DatabaseProperties.PROP_CONNECTION_URL, DatabaseProperties.PROP_TIPO_VALUE_CONNECTION.equals(this.getTipoAccessoDatabase()), true);
    }
    private static final String PROP_CONNECTION_DRIVER = "db.connection.driver";
    public String getConnectionDriverJDBC() throws UtilsException {
        return this.getProperty(DatabaseProperties.PROP_CONNECTION_DRIVER, DatabaseProperties.PROP_TIPO_VALUE_CONNECTION.equals(this.getTipoAccessoDatabase()), true);
    }
    private static final String PROP_CONNECTION_AUTH_USER = "db.connection.user";
    public String getConnectionAuthUsername() throws UtilsException {
        /**return this.getProperty(PROP_CONNECTION_AUTH_USER, PROP_TIPO_VALUE_CONNECTION.equals(this.getTipoAccessoDatabase()), true);*/
        return this.getProperty(DatabaseProperties.PROP_CONNECTION_AUTH_USER, false, true);
    }
    private static final String PROP_CONNECTION_AUTH_PASSWORD = "db.connection.password";
    public String getConnectionAuthPassword() throws UtilsException {
        /**return this.getProperty(PROP_CONNECTION_AUTH_PASSWORD, PROP_TIPO_VALUE_CONNECTION.equals(this.getTipoAccessoDatabase()), true);*/
        return this.getProperty(DatabaseProperties.PROP_CONNECTION_AUTH_PASSWORD, false, true);
    }
    
}