sessionstatefulbean.java

jboss4 + Mysql +ejb3.0 EJB3 简单例子

    {
        int returnValue = -1;
        System.out.println(sql);
        Statement stmt = null;
        ResultSet rs = null;
        try
        {
            stmt = con.createStatement();
            long start_time = System.currentTimeMillis();
            rs = stmt.executeQuery(sql);
            long time = System.currentTimeMillis() - start_time;
            System.out.println("\u6267\u884CSQL\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            if(rs.next())
                returnValue = rs.getInt(1);
            rs.close();
            stmt.close();
        }
        catch(SQLException ex)
        {
            ex.printStackTrace();
        }
        return returnValue;
    }

    public String getString(String sql, String colname)
    {
        String returnVal = "";
        Statement stmt = null;
        ResultSet rs = null;
        try
        {
            stmt = con.createStatement();
            long start_time = System.currentTimeMillis();
            rs = stmt.executeQuery(sql);
            long time = System.currentTimeMillis() - start_time;
            System.out.println("\u6267\u884CSQL\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            int count = 0;
            start_time = System.currentTimeMillis();
            if(rs.next())
                returnVal = rs.getObject(colname).toString().trim();
            time = System.currentTimeMillis() - start_time;
            System.out.println("\u8F6C\u6362\u5BF9\u8C61\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            rs.close();
            stmt.close();
        }
        catch(SQLException ex)
        {
            ex.printStackTrace();
        }
        return returnVal;
    }

    public int getInt(String sql, String colname)
    {
        int returnVal = 0;
        Statement stmt = null;
        ResultSet rs = null;
        try
        {
            stmt = con.createStatement();
            long start_time = System.currentTimeMillis();
            rs = stmt.executeQuery(sql);
            long time = System.currentTimeMillis() - start_time;
            System.out.println("\u6267\u884CSQL\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            int count = 0;
            start_time = System.currentTimeMillis();
            if(rs.next())
                returnVal = rs.getInt(colname);
            time = System.currentTimeMillis() - start_time;
            System.out.println("\u8F6C\u6362\u5BF9\u8C61\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            rs.close();
            stmt.close();
        }
        catch(SQLException ex)
        {
            ex.printStackTrace();
        }
        return returnVal;
    }

    public ArrayList getFormulaMarkEntity_VO(String sql)
    {
        ArrayList list = new ArrayList();
        Statement stmt = null;
        ResultSet rs = null;
        try
        {
            stmt = con.createStatement();
            long start_time = System.currentTimeMillis();
            rs = stmt.executeQuery(sql);
            long time = System.currentTimeMillis() - start_time;
            System.out.println("\u6267\u884CSQL\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            int count = 0;
            start_time = System.currentTimeMillis();
            FormulaMarkEntity_VO obj;
            for(; rs.next(); list.add(obj))
            {
                long s1 = rs.getLong("DIM_T_DIM_YYZY_PFPH_LSBH");
                String s2 = rs.getString("DIM_T_DIM_YYZY_PFPH_PFPHBS");
                String s3 = rs.getString("DIM_T_DIM_YYZY_PFPH_PFPHDM");
                String s4 = rs.getString("DIM_T_DIM_YYZY_PFPH_PFPHMC");
                String s5 = rs.getString("DIM_T_DIM_YYZY_PFPH_YHBS");
                String s6 = rs.getString("DIM_T_DIM_YYZY_PFPH_SCCJDM");
                java.sql.Date s7 = rs.getDate("DIM_T_DIM_YYZY_PFPH_KSRQ");
                java.sql.Date s8 = rs.getDate("DIM_T_DIM_YYZY_PFPH_JSRQ");
                obj = new FormulaMarkEntity_VO(s1, s2, s3, s4, s5, s6, s7, s8);
            }

            time = System.currentTimeMillis() - start_time;
            System.out.println("\u8F6C\u6362\u5BF9\u8C61\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            System.out.println("\u5BF9\u8C61\u4E2A\u6570\uFF1A" + list.size());
            rs.close();
            stmt.close();
        }
        catch(SQLException ex)
        {
            ex.printStackTrace();
        }
        return list;
    }

    public ArrayList getRoleEachDayCount_VO(String sql)
    {
        ArrayList list = new ArrayList();
        Statement stmt = null;
        ResultSet rs = null;
        try
        {
            stmt = con.createStatement();
            long start_time = System.currentTimeMillis();
            rs = stmt.executeQuery(sql);
            long time = System.currentTimeMillis() - start_time;
            System.out.println("\u6267\u884CSQL\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            int count = 0;
            start_time = System.currentTimeMillis();
            RoleEachDayCount_VO redc_obj;
            for(; rs.next(); list.add(redc_obj))
            {
                Integer pfphdm = new Integer(rs.getInt("PFPHDM"));
                String pfphmc = rs.getString("PFPHMC") == null ? "" : rs.getString("PFPHMC");
                String date = rs.getString("PFRQ") == null ? "" : rs.getString("PFRQ");
                Integer zxpfjsdm = new Integer(rs.getInt("ZXPFJSDM"));
                String zxpfjsmc = zxpfjsdm.toString();
                Integer bigdecimal_xhyzl = new Integer(rs.getInt("ZXHYL"));
                FormulaMark_VO formulamark = new FormulaMark_VO();
                formulamark.setFormulaMarkCode(pfphdm.toString());
                formulamark.setFormulaMarkName(pfphmc.trim());
                Role_VO role = new Role_VO();
                role.setFormulaMark(formulamark);
                role.setRoleCode(zxpfjsdm.toString());
                role.setRoleName(zxpfjsmc.trim());
                redc_obj = new RoleEachDayCount_VO();
                redc_obj.setRole(role);
                redc_obj.setPlanningOfUse(bigdecimal_xhyzl);
                redc_obj.setWorkdayOfDate(date);
            }

            time = System.currentTimeMillis() - start_time;
            System.out.println("\u8F6C\u6362\u5BF9\u8C61\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            System.out.println("\u5BF9\u8C61\u4E2A\u6570\uFF1A" + list.size());
            rs.close();
            stmt.close();
        }
        catch(SQLException ex)
        {
            ex.printStackTrace();
        }
        return list;
    }

    public ArrayList queryExecuteLeaf(String sql)
    {
        ArrayList list = new ArrayList();
        Statement stmt = null;
        ResultSet rs = null;
        try
        {
            stmt = con.createStatement();
            long start_time = System.currentTimeMillis();
            rs = stmt.executeQuery(sql);
            long time = System.currentTimeMillis() - start_time;
            System.out.println("\u6267\u884CSQL\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            start_time = System.currentTimeMillis();
            Map map = new HashMap();
            for(; rs.next(); list.add(map))
            {
                map = new HashMap();
                map.put("ZXPFDM", rs.getString("ZXPFDM"));
                map.put("PFPHDM", rs.getString("PFPHDM"));
                map.put("PFPHMC", rs.getString("PFPHMC"));
                map.put("ZXPFJSDM", rs.getString("ZXPFJSDM"));
                map.put("ZXPFJSMC", rs.getString("ZXPFJSMC"));
                map.put("NPFZBDM", rs.getString("NPFZBDM"));
                map.put("YYDM", rs.getString("YYDM"));
                map.put("YYMC", rs.getString("YYMC"));
                map.put("YYNF", rs.getString("YYNF"));
                map.put("YYBZ", rs.getString("YYBZ"));
                map.put("SFTDYYBJ", rs.getString("SFTDYYBJ"));
                map.put("DPXS", rs.getString("DPXS"));
                map.put("XHYZL", rs.getString("XHYZL"));
                map.put("DPBFB", rs.getString("DPBFB"));
                map.put("BFBHYZL", rs.getString("BFBHYZL"));
                map.put("PFRQ", rs.getString("PFRQ"));
                map.put("GZRXH", rs.getString("GZRXH"));
                map.put("BBH", rs.getString("BBH"));
                map.put("XBBH", rs.getString("XBBH"));
                map.put("YYCDMC", rs.getString("YYCDMC"));
                map.put("YYDJMC", rs.getString("YYDJMC"));
                map.put("YYKBMC", rs.getString("YYKBMC"));
                map.put("YYLBMC", rs.getString("YYLBMC"));
            }

            time = System.currentTimeMillis() - start_time;
            System.out.println("\u8F6C\u6362\u5BF9\u8C61\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            System.out.println("\u5BF9\u8C61\u4E2A\u6570\uFF1A" + list.size());
            rs.close();
            stmt.close();
        }
        catch(SQLException ex)
        {
            ex.printStackTrace();
        }
        return list;
    }

    public int callProcedure(int yydm, int year, int qauntity, String date)
    {
        CallableStatement proc = null;
        try
        {
            proc = con.prepareCall("{ call APP_YYB.SP_YYZY_TEST(?,?,?,?) }");
            proc.setInt(1, yydm);
            proc.setInt(2, year);
            proc.setInt(3, qauntity);
            proc.setString(4, date);
            proc.execute();
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        return 0;
    }

    private static final long serialVersionUID = 0xc61e93e6385cd222L;
    SessionContext sessionContext;
    Connection con;
}