public class CompTivBeanFactory extends DataBaseHelper
{
    Logger log;
    private static final String GET_ALL_COMPUTERS = "select * from COMPUTER";
    private static final String GET_NUM_RECORDS = "select count(*) from COMPUTER";
    private static final String GET_COMP_BY_CSID = "select * from COMPUTER where COMPUTER_SYS_ID=?";
    private static final String GET_COMP_BY_OID = "select * from COMPUTER where TME_OBJECT_ID=?";
    private static final String GET_COMP_BY_HOST = "SELECT distinct * from computer where (upper(computer_alias) = upper(?) or upper(tme_object_label)=upper(?)) and (RECORD_TIME in (SELECT max(record_time) as record_time from computer where (upper(computer_alias) = upper(?) or upper(tme_object_label)=upper(?))))";
    private static CompTivBeanFactory m_factory;
    
    static {
        CompTivBeanFactory.m_factory = null;
    }
    
    private CompTivBeanFactory() throws NullPointerException {
        this.log = Logger.getLogger(CompTivBeanFactory.class.getName());
    }
    
    public static CompTivBeanFactory getFactory() throws NullPointerException {
        if (CompTivBeanFactory.m_factory == null) {
            CompTivBeanFactory.m_factory = new CompTivBeanFactory();
        }
        return CompTivBeanFactory.m_factory;
    }
    
    public CompTivBean getCompByOID(String oid) {
        CompTivBean bean = null;
        Connection con = null;
        Label_0157: {
            try {
                con = this.getConnection();
                PreparedStatement ps = null;
                ps = con.prepareStatement("select * from COMPUTER where TME_OBJECT_ID=?");
                oid = String.valueOf(oid) + "+#TMF_Endpoint::Endpoint#";
                ps.setString(1, oid);
                this.log.debug((Object)("Ищем компьютер с oid=" + oid));
                final ResultSet rs = ps.executeQuery();
                if (rs.next()) {
                    bean = this.convertResultSetToItem(rs);
                }
                else {
                    this.log.error((Object)("can't read computer info by oid=" + oid));
                }
            }
            catch (Exception e) {
                e.printStackTrace();
                break Label_0157;
            }
            finally {
                this.closeConnection(con);
            }
            this.closeConnection(con);
            return bean;
        }
        this.closeConnection(con);
        return bean;
    }
    
    public CompTivBean getCompByHost(final String hostn) {
        CompTivBean bean = null;
        Connection con = null;
        Label_0164: {
            try {
                con = this.getConnection();
                PreparedStatement ps = null;
                ps = con.prepareStatement("SELECT distinct * from computer where (upper(computer_alias) = upper(?) or upper(tme_object_label)=upper(?)) and (RECORD_TIME in (SELECT max(record_time) as record_time from computer where (upper(computer_alias) = upper(?) or upper(tme_object_label)=upper(?))))");
                ps.setString(1, hostn);
                ps.setString(2, hostn);
                ps.setString(3, hostn);
                ps.setString(4, hostn);
                this.log.debug((Object)("Ищем компьютер с COMPUTER_ALIAS=" + hostn));
                final ResultSet rs = ps.executeQuery();
                if (rs.next()) {
                    bean = this.convertResultSetToItem(rs);
                }
                else {
                    this.log.error((Object)("can't read computer info by name=" + hostn));
                }
            }
            catch (Exception e) {
                e.printStackTrace();
                break Label_0164;
            }
            finally {
                this.closeConnection(con);
            }
            this.closeConnection(con);
            return bean;
        }
        this.closeConnection(con);
        return bean;
    }
    
    public CompTivBean getCompByCSID(final String csid) {
        CompTivBean bean = null;
        Connection con = null;
        Label_0100: {
            try {
                con = this.getConnection();
                PreparedStatement ps = null;
                ps = con.prepareStatement("select * from COMPUTER where COMPUTER_SYS_ID=?");
                ps.setString(1, csid);
                final ResultSet rs = ps.executeQuery();
                if (rs.next()) {
                    bean = this.convertResultSetToItem(rs);
                }
                else {
                    this.log.error((Object)"can't read department info");
                }
            }
            catch (Exception e) {
                e.printStackTrace();
                break Label_0100;
            }
            finally {
                this.closeConnection(con);
            }
            this.closeConnection(con);
            return bean;
        }
        this.closeConnection(con);
        return bean;
    }
    
    public int getNumRecords() {
        Connection con = null;
        int result = 0;
        Label_0074: {
            try {
                con = this.getConnection();
                PreparedStatement ps = null;
                ps = con.prepareStatement("select count(*) from COMPUTER");
                final ResultSet rs = ps.executeQuery();
                rs.next();
                result = rs.getInt(1);
            }
            catch (Exception e) {
                e.printStackTrace();
                break Label_0074;
            }
            finally {
                this.closeConnection(con);
            }
            this.closeConnection(con);
            return result;
        }
        this.closeConnection(con);
        return result;
    }
    
    public Collection getAllComputers() {
        Connection con = null;
        final Collection result = new ArrayList();
        Label_0089: {
            try {
                con = this.getConnection();
                PreparedStatement ps = null;
                ps = con.prepareStatement("select * from COMPUTER");
                final ResultSet rs = ps.executeQuery();
                while (rs.next()) {
                    result.add(this.convertResultSetToItem(rs));
                }
            }
            catch (Exception e) {
                e.printStackTrace();
                break Label_0089;
            }
            finally {
                this.closeConnection(con);
            }
            this.closeConnection(con);
            return result;
        }
        this.closeConnection(con);
        return result;
    }
    
    private CompTivBean convertResultSetToItem(final ResultSet rs) throws SQLException {
        final CompTivBean bean = new CompTivBean();
        final String csid = rs.getString("COMPUTER_SYS_ID");
        final Date computer_scantime = rs.getDate("COMPUTER_SCANTIME");
        final String tme_object_id = rs.getString("TME_OBJECT_ID");
        final String tme_object_label = rs.getString("TME_OBJECT_LABEL");
        final String computer_model = rs.getString("COMPUTER_MODEL");
        final Date computer_boot_time = rs.getDate("COMPUTER_BOOT_TIME");
        final String computer_alias = rs.getString("COMPUTER_ALIAS");
        final String sys_ser_num = rs.getString("COMPUTER_ALIAS");
        final String os_name = rs.getString("OS_NAME");
        final String os_type = rs.getString("OS_TYPE");
        final long os_major_vers = rs.getLong("OS_MAJOR_VERS");
        final long os_minor_vers = rs.getLong("OS_MINOR_VERS");
        final String os_sub_vers = rs.getString("OS_SUB_VERS");
        final String os_inst_date = rs.getString("OS_INST_DATE");
        final String registered_owner = rs.getString("REGISTERED_OWNER");
        final String registered_org = rs.getString("REGISTERED_ORG");
        final String keybord_type = rs.getString("KEYBOARD_TYPE");
        final long funktion_keys = rs.getLong("FUNCTION_KEYS");
        final String tz_locale = rs.getString("TZ_LOCALE");
        final String tz_name = rs.getString("TZ_NAME");
        final String tz_daylight_name = rs.getString("TZ_DAYLIGHT_NAME");
        final String on_savings_time = rs.getString("ON_SAVINGS_TIME");
        final long tz_seconds = rs.getLong("TZ_SECONDS");
        final String time_direction = rs.getString("TIME_DIRECTION");
        final Date record_time = rs.getDate("RECORD_TIME");
        final String os_kernel_mode = rs.getString("OS_KERNEL_MODE");
        final String os_lang_vers = rs.getString("OS_LANG_VERS");
        final String os_lcid = rs.getString("OS_LCID");
        final String current_lcid = rs.getString("CURRENT_LCID");
        final String os_arch = rs.getString("CURRENT_LCID");
        bean.setCsid(csid);
        bean.setComputer_scantime(computer_scantime);
        bean.setTme_object_id(tme_object_id);
        bean.setTme_object_label(tme_object_label);
        bean.setComputer_model(computer_model);
        bean.setComputer_boot_time(computer_boot_time);
        bean.setComputer_alias(computer_alias);
        bean.setSys_ser_num(sys_ser_num);
        bean.setOs_name(os_name);
        bean.setOs_type(os_type);
        bean.setOs_major_vers(os_major_vers);
        bean.setOs_minor_vers(os_minor_vers);
        bean.setOs_sub_vers(os_sub_vers);
        bean.setOs_inst_date(os_inst_date);
        bean.setRegistered_owner(registered_owner);
        bean.setRegistered_org(registered_org);
        bean.setKeybord_type(keybord_type);
        bean.setFunktion_keys(funktion_keys);
        bean.setTz_locale(tz_locale);
        bean.setTz_name(tz_name);
        bean.setTz_daylight_name(tz_daylight_name);
        bean.setOn_savings_time(on_savings_time);
        bean.setTz_seconds(tz_seconds);
        bean.setTime_direction(time_direction);
        bean.setRecord_time(record_time);
        bean.setOs_kernel_mode(os_kernel_mode);
        bean.setOs_lang_vers(os_lang_vers);
        bean.setOs_lcid(os_lcid);
        bean.setCurrent_lcid(current_lcid);
        bean.setOs_arch(os_arch);
        return bean;
    }
}

private static CompTivBeanFactory m_factory;
public static CompTivBeanFactory getFactory() throws NullPointerException {
        if (CompTivBeanFactory.m_factory == null) {
            CompTivBeanFactory.m_factory = new CompTivBeanFactory();
        }
        return CompTivBeanFactory.m_factory;
    }

public class DataBaseHelper
{
    Logger log;
    public static final int BUFFER_SIZE = 4096;
    private static final String CONTEXT_PROPERTIES = "com.hetnet.common.context";
    private static final String COMMON_PROPERTIES = "com.hetnet.common.common";
    private static final String DS_JNDI_NAME = "hetnet.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("com.hetnet.common.common");
        final String strJNDI = contextRes.getString("connection.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("com.hetnet.common.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("com.hetnet.common.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_getallcompany = contextRes.getString("sql.tivoli.inventory.company.all");
        this.m_finecompanybyname = contextRes.getString("sql.tivoli.inventory.company.find.by.name");
        this.m_addcompany = contextRes.getString("sql.tivoli.inventory.company.add");
        this.m_isPropertyInit = true;
    }
}