package org.askalon.provenance.gpdatabase.impl;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import org.apache.log4j.Logger;


public class DatabaseManager
{

    private ResultSet rs1, rs2, rs3, rs4;
    private Statement st1, st2, st3, st4;
    private static final Logger logger = Logger.getLogger(DatabaseManager.class);
    private static Connection connection = null;

    // ======= SINGLETON DEFS START HERE===========//
    private static DatabaseManager instance = null;

    private static final Logger LOGGER = Logger.getLogger(DatabaseManager.class);

    public DatabaseManager()
    {
    }

    public static DatabaseManager getInstance()
    {
        if (instance == null)
        {

            create();
        }

        return instance;
    }

    private static DatabaseManager create()
    {
        instance = new DatabaseManager();
        return instance;
    }
    // ==============SINGLETON DEFS END HERE===============//

    public static Connection getConnection()
    {
        if (connection == null)
            connection = createConnection();
        return connection;
    }

    private static Connection createConnection()
    {
        try
        {
            logger.debug("Now trying to Connect to DB");
            connection = DriverManager.getConnection("jdbc:postgresql://" + (InetAddress.getLocalHost().getHostName().equals("junaid-desktop") ? "127.0.0.1" : "192.168.64.183") + "/" + "GPP",
                    "USER", "PASS");

        }
        catch (SQLException se)
        {
            logger.error("Connectivity Failed");
            logger.error(se.getMessage());
        }
        catch (UnknownHostException e)
        {
            e.printStackTrace();
        }
        return connection;
    }

    public void closeConnection()
    {
        if (connection != null)
        {
            try
            {
                DatabaseManager.connection.close();
                LOGGER.debug("Connection Closed");
            }
            catch (SQLException e)
            {
                LOGGER.error("Can not close the database connection");
            }
        }
    }

    public Statement createStatement()
    {
        Statement stmt = null;
        try
        {
            stmt = connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
        }
        catch (SQLException se)
        {
            LOGGER.error("Couldn't create statement.");
            LOGGER.error(se.getStackTrace());
        }
        return (stmt);
    }


    public boolean PerformDatabaseAction(String ActionCommand)
    {
        System.out.println("Storage ITEM is "+ ActionCommand);
        return (ActionCommand.length()>10?true:false);
    }
}


//public boolean PerformDatabaseAction(String ActionCommand)
//{
//  String SQL=makeStatement(ActionCommand);
//
//  st1 = createStatement();
//  try
//  {
//      rs1=st1.executeQuery(SQL);
//
//  }
//  catch (SQLException e)
//  {
//      e.printStackTrace();
//  }
//  return false;
//}
//
//private String makeStatement(String actionCommand)
//{
//  return null;
//}