/*-
 * ================================================================================
 * ECOMP Portal SDK
 * ================================================================================
 * Copyright (C) 2017 AT&T Intellectual Property
 * ================================================================================
 * Licensed 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.openecomp.portalsdk.analytics.system.fusion.adapter;

import java.sql.*;
import java.util.*;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.servlet.*;

import com.mchange.v2.c3p0.ComboPooledDataSource;

import org.hibernate.SessionFactory;
import org.hibernate.engine.jdbc.connections.spi.ConnectionProvider;
import org.hibernate.engine.spi.SessionFactoryImplementor;
import org.hibernate.engine.spi.SessionImplementor;
import org.openecomp.portalsdk.core.FusionObject;
import org.openecomp.portalsdk.core.service.DataAccessService;
import org.openecomp.portalsdk.core.util.SystemProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;

public class FusionAdapter implements FusionObject {

    public static final String LOCAL_SESSION_FACTORY_KEY = "local";


    private ComboPooledDataSource dataSource;
    private Map<String,ComboPooledDataSource> dataSourceMap;
    
    //private 		SessionFactory sessionFactory;
    private        ServletContext     servletContext;    

    public FusionAdapter() {
    }


    public ServletContext getServletContext() {
        return servletContext;
    }

    public void setServletContext(ServletContext servletContext) {
        this.servletContext = servletContext;
    }

    /** Gets connection to the database **/
    public  Connection getConnection() {
    	Connection connection = null;
    	try {
    	   connection = getDataSource().getConnection();
    	} catch(Exception ex) {
    		ex.printStackTrace();
    	}
       return connection;
    }


    /** Gets connection to the database indicated via the session factory key **/
    public synchronized Connection getConnection(String schemaId) {
		Connection connection = null;
		try {
			connection = getDataSourceMap().get(schemaId).getConnection();
		} catch (Exception e) {
			e.printStackTrace();
		}
	
		return connection;
    }


    /** Releases connection to the database **/
    public void releaseConnection(Connection conn) {
        try {
          conn.close();
        }
        catch (Exception e) {
          e.printStackTrace();
        }
    }


	public ComboPooledDataSource getDataSource() {
		return dataSource;
	}


	@Autowired
	public void setDataSource(ComboPooledDataSource dataSource) {
		this.dataSource = dataSource;
	}

	public Map<String,ComboPooledDataSource> getDataSourceMap() {
		if(dataSourceMap==null)
			dataSourceMap = (Map<String,ComboPooledDataSource>)SpringContext.getApplicationContext().getBean("dataSourceMap");

		return dataSourceMap;
	}

	public void setdataSourceMap(Map<String,ComboPooledDataSource> dataSourceMap) {
		this.dataSourceMap = dataSourceMap;
	}

}