import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
import oracle.jdbc.OracleCallableStatement;
import oracle.jdbc.OracleConnection;
import oracle.jdbc.OracleDriver;
import oracle.jdbc.pool.OracleConnectionCacheManager;
import oracle.jdbc.pool.OracleDataSource;



public final class ODS
{
  private static final String CACHE_NAME = "ODS@" + Project.rootPath;
  
  private static final String FILE_NAME = "WEB-INF/Connection.properties";
  private static final long SYS_LOGIN_ID = -1;
  private static OracleDataSource ods = null;
  private static OracleConnectionCacheManager occm = null;
  
  private static Properties prop;
  
  public static final CoreException authException = new CoreException("Сеанс не авторизован", true);
  
  static
  {
    try {
      DriverManager.registerDriver(new OracleDriver());
    }
    catch (SQLException e) {
      e.printStackTrace(System.err);
    }
  }
  
  public ODS() {}
  
  public static synchronized void init() throws Exception { if (ods == null) {
      prop = loadParams();
      
      ods = new OracleDataSource();
      ods.setDriverType("thin");
      setProperties(prop);
      
      ods.setConnectionCachingEnabled(true);
      ods.setConnectionCacheName(CACHE_NAME);
      
      occm = OracleConnectionCacheManager.getConnectionCacheManagerInstance();
      if (occm.existsCache(CACHE_NAME))
        occm.removeCache(CACHE_NAME, 0);
      occm.createCache(CACHE_NAME, ods, prop);
    }
  }
  
  public static synchronized void done() throws Exception
  {
    if (ods != null) {
      ods.close();
      ods = null;
    }
  }
  
  public static void reinit(Properties prop) throws Exception
  {
    done();
    init();
  }
  
  public static void clearSessions() throws Exception
  {
    OracleConnection conn = getConnection();
    


    conn.close();
  }
  
  private static void setProperties(Properties prop)
    throws Exception
  {
    ods.setServerName(prop.getProperty("HostName"));
    ods.setPortNumber(Integer.parseInt(prop.getProperty("Port")));
    ods.setDatabaseName(prop.getProperty("SID"));
    ods.setUser(prop.getProperty("UserName"));
    ods.setPassword(prop.getProperty("Password"));
  }
  
  private static void initConnection(OracleConnection conn, long loginId) throws Exception
  {
    try (OracleCallableStatement cs = (OracleCallableStatement)conn.prepareCall("Begin Core_Global.Init_Connection(?); End;")) {
      cs.setLong(1, loginId);
      cs.execute();
    }
  }
  



  public static OracleConnection getConnection(long loginId)
    throws Exception
  {
    OracleConnection conn = null;
    
    if (loginId == 0) {
      throw authException;
    }
    
    for (int try_count = 0; try_count < 3; try_count++) {
      conn = (OracleConnection) ods.getConnection();
      if (conn != null) break;
      Thread.sleep(300);
    }
    if (conn == null) {
      if (occm.getNumberOfAvailableConnections(CACHE_NAME) == 0) {
        throw new Exception("Количество связей с БД превысило максимум");
      }
      reinit(prop);
      
      for (int try_count = 0; try_count < 3; try_count++) {
        conn = (OracleConnection)ods.getConnection();
        if (conn != null) break;
        Thread.sleep(300);
      }
      if (conn == null) {
        throw new Exception("Соединение с БД потеряно");
      }
    }
    conn.setAutoCommit(false);
    initConnection(conn, loginId);
    return conn;
  }
  



  public static OracleConnection getConnection()
    throws Exception
  {
    return getConnection(-1);
  }
  

  public static OracleConnection createConnection()
    throws Exception
  {
    Properties prop1 = loadParams();
    OracleConnection conn = (OracleConnection)DriverManager.getConnection(
      "jdbc:oracle:thin:@" + prop1.getProperty("HostName") + ":" + 
      prop1.getProperty("Port") + ":" + prop1.getProperty("SID"), 
      prop1.getProperty("UserName"), prop1.getProperty("Password"));
    
    conn.setAutoCommit(false);
    initConnection(conn, -1);
    return conn;
  }
  




  public static void putConnection(OracleConnection conn)
  {
    if (conn != null) {
      try {
        conn.rollback();
      } catch (SQLException localException) {}
      try {
        conn.close();
      }
      catch (SQLException localException1) {}
    }
  }
  


  public static Properties loadParams()
    throws Exception
  {
    Properties prop2 = new Properties();
    try (FileInputStream f = new FileInputStream(Project.rootPath + "WEB-INF/Connection.properties")) {
      prop2.load(f);
    }
    return prop2;
  }
  



  public static void storeParams(Properties prop)
    throws Exception
  {
    try (FileOutputStream f = new FileOutputStream(Project.rootPath + "WEB-INF/Connection.properties")) {
      prop.store(f, null);
    }
  }
}