package helper;
import org.apache.log4j.*;
import javax.sql.*;
import javax.naming.*;
import java.util.*;
import java.sql.*;
import java.io.*;

public class DataBaseHelper
{
    Logger log;
    public static final int BUFFER_SIZE = 4096;
    private static final String CONTEXT_PROPERTIES = "context";
    private static final String COMMON_PROPERTIES = "common";
    private static final String DS_JNDI_NAME = "jndi_name";
    private boolean m_isPropertyInit;
    private DataSource m_dataSource;
    private Context m_context;
    private boolean m_isDataSourceUsed;
    private String m_driverName;
    private String m_strURL;
    private String m_strPassword;
    private String m_strLogin;
    private String m_strShema;
    private String m_getallcompany;
    private String m_finecompanybyname;
    private String m_addcompany;
    
    public DataBaseHelper() {
        this.log = Logger.getLogger(DataBaseHelper.class.getName());
        this.m_dataSource = null;
        this.m_context = null;
        this.m_isDataSourceUsed = false;
        this.m_isPropertyInit = false;
        this.m_strURL = null;
        this.m_strPassword = null;
        this.m_strLogin = null;
    }
    
    private DataSource createDataSource() throws NamingException {
        final ResourceBundle contextRes = ResourceBundle.getBundle("common");
        final String strJNDI = contextRes.getString("jndi_name");
        if (this.m_context == null) {
            this.m_context = this.getRootContext();
        }
        return this.m_dataSource = (DataSource)this.m_context.lookup(strJNDI);
    }
    
    private Context getRootContext() throws NamingException {
        final Properties properties = new Properties();
        final ResourceBundle contextRes = ResourceBundle.getBundle("context");
        final Enumeration keys = contextRes.getKeys();
        if (keys != null) {
            while (keys.hasMoreElements()) {
                final String key = keys.nextElement();
                final String value = contextRes.getString(key);
                ((Hashtable<String, String>)properties).put(key, value);
            }
        }
        return this.m_context = new InitialContext(properties);
    }
    
    private DataSource getDataSource() throws NamingException {
        if (this.m_dataSource == null) {
            this.createDataSource();
        }
        return this.m_dataSource;
    }
    
    protected Connection getConnection() throws SQLException, NamingException {
        Connection conn = null;
        if (!this.m_isPropertyInit) {
            this.propertyInit();
        }
        if (!this.m_isDataSourceUsed) {
            try {
                Class.forName(this.m_driverName);
            }
            catch (ClassNotFoundException ex) {
                this.log.error((Object)("getConnection ex = " + ex.getLocalizedMessage()));
                ex.printStackTrace();
            }
        }
        if (this.m_isDataSourceUsed) {
            conn = this.getDataSource().getConnection();
        }
        else {
            conn = this.getConnectionFromURL();
        }
        if (this.m_strShema != null && this.m_strShema.length() > 0) {
            conn.createStatement().executeUpdate("set current schema " + this.m_strShema);
        }
        return conn;
    }
    
    private Connection getConnectionFromURL() throws SQLException {
        final Connection conn = DriverManager.getConnection(this.m_strURL, this.m_strLogin, this.m_strPassword);
        return conn;
    }
    
    protected void closeConnection(Connection conn) {
        if (conn != null) {
            Label_0066: {
                try {
                    if (!conn.isClosed()) {
                        conn.close();
                    }
                }
                catch (SQLException ex) {
                    ex.printStackTrace();
                    this.log.error((Object)("closeConnection SQLException = " + ex.getLocalizedMessage()));
                    break Label_0066;
                }
                finally {
                    conn = null;
                }
                conn = null;
                return;
            }
            conn = null;
        }
    }
    
    protected String converterClobToString(final Clob clob) throws SQLException {
        String result = null;
        if (clob != null) {
            try {
                final Reader clobReader = clob.getCharacterStream();
                final CharArrayWriter writer = new CharArrayWriter();
                final char[] buffer = new char[4096];
                int i = 0;
                while ((i = clobReader.read(buffer)) >= 0) {
                    writer.write(buffer, 0, i);
                }
                writer.flush();
                writer.close();
                result = writer.toString();
            }
            catch (IOException ex) {
                this.log.error((Object)"convertClobToString IOException");
                ex.printStackTrace();
                result = null;
            }
        }
        return result;
    }
    
    public String getSQLaddCompany() {
        return this.m_addcompany;
    }
    
    public String getSQLforAllCompany() {
        return this.m_getallcompany;
    }
    
    public String getSQLfindCompanyByName() {
        return this.m_finecompanybyname;
    }
    
    private void propertyInit() {
        final ResourceBundle contextRes = ResourceBundle.getBundle("common");
        this.m_isDataSourceUsed = new Boolean(contextRes.getString("connection.use_datasource"));
        this.m_driverName = contextRes.getString("connection.driver_class_name");
        this.m_strURL = contextRes.getString("connection.database_url");
        this.m_strLogin = contextRes.getString("connection.database_user");
        this.m_strPassword = contextRes.getString("connection.database_password");
        this.m_strShema = contextRes.getString("connection.schema");
        this.m_isPropertyInit = true;
    }
}