sessionstatefulbean.java

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

// Decompiled by DJ v3.7.7.81 Copyright 2004 Atanas Neshkov  Date: 2009-2-24 15:56:43
// Home Page : http://members.fortunecity.com/neshkov/dj.html  - Check often for new version!
// Decompiler options: packimports(3) 
// Source File Name:   SessionStatefulBean.java

package com.volcano.eruption.tsas.applet.obj.collect.sessionbeantest;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.Map;

import javax.ejb.CreateException;
import javax.ejb.SessionBean;
import javax.ejb.SessionContext;
import javax.naming.InitialContext;
import javax.sql.DataSource;

import com.volcano.eruption.tsas.applet.obj.FormulaMark_VO;
import com.volcano.eruption.tsas.applet.obj.RoleEachDayCount_VO;
import com.volcano.eruption.tsas.applet.obj.Role_VO;
import com.volcano.eruption.tsas.applet.obj.collect.Mapping_VO;
import com.volcano.eruption.tsas.applet.obj.collect.RationDate;
import com.volcano.eruption.tsas.applet.obj.collect.SubUsage;
import com.volcano.eruption.tsas.metadata.FormulaMarkEntity_VO;

public class SessionStatefulBean
    implements SessionBean
{

    public SessionStatefulBean()
    {
    }

    public void ejbCreate()
        throws CreateException
    {
        try
        {
            if(con == null || con.isClosed())
            {
                InitialContext ctx = new InitialContext();
                DataSource ds = (DataSource)ctx.lookup("yyzy_db2");
                con = ds.getConnection();
                System.out.println("connection in EJB:" + con);
            }
        }
        catch(Exception ex)
        {
            System.err.println("EJB\u4E2D\u83B7\u5F97JNDI yyzy_db2 \u5931\u8D25 Initial failed. " + ex);
        }
    }

    public void ejbRemove()
    {
        try
        {
            if(con != null || !con.isClosed())
            {
                con.close();
                System.out.println("Close connection");
            }
        }
        catch(Exception ex)
        {
            System.err.println("\u5173\u95EDconnection\u5931\u8D25. " + ex);
        }
        con = null;
    }

    public void ejbActivate()
    {
        try
        {
            if(con == null || con.isClosed())
            {
                InitialContext ctx = new InitialContext();
                DataSource ds = (DataSource)ctx.lookup("yyzy_db2");
                con = ds.getConnection();
                System.out.println("connection in EJB:" + con);
            }
        }
        catch(Exception ex)
        {
            System.err.println("EJB\u4E2D\u83B7\u5F97JNDI yyzy_db2 \u5931\u8D25 Initial failed. " + ex);
        }
    }

    public void ejbPassivate()
    {
        try
        {
            if(con != null || !con.isClosed())
            {
                con.close();
                System.out.println("Close connection");
            }
        }
        catch(Exception ex)
        {
            System.err.println("\u5173\u95EDconnection\u5931\u8D25. " + ex);
        }
        con = null;
    }

    public void setSessionContext(SessionContext sessionContext)
    {
        this.sessionContext = sessionContext;
    }

    public Mapping_VO getMapping_VO()
    {
        Mapping_VO returnVal = new Mapping_VO();
        Hashtable phdm2phmc = new Hashtable();
        Hashtable phmc2phdm = new Hashtable();
        Hashtable yydm2yymc = new Hashtable();
        Hashtable yymc2yydm = new Hashtable();
        Statement stmt = null;
        ResultSet rs = null;
        try
        {
            stmt = con.createStatement();
            long start_time = System.currentTimeMillis();
            rs = stmt.executeQuery("select pfphdm,pfphmc from DIM.T_DIM_YYZY_PFPH where current date > ksrq and current date < jsrq");
            long time = System.currentTimeMillis() - start_time;
            System.out.println("\u724C\u53F7\u4EE3\u7801\u548C\u724C\u53F7\u540D\u79F0\u8F6C\u6362\u6267\u884CSQL\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            int count;
            for(count = 0; rs.next(); count++)
            {
                int s1 = Integer.parseInt(rs.getObject(1).toString());
                String s2 = rs.getObject(2).toString().trim();
                phdm2phmc.put(new Integer(s1), s2);
                phmc2phdm.put(s2, new Integer(s1));
            }

            if(count == 0)
                System.out.println("DIM.T_DIM_YYZY_PFPH\u8868\u6CA1\u6709\u6570\u636E,\u65E0\u6CD5\u5EFA\u7ACB\u724C\u53F7\u4EE3\u7801\u548C\u724C\u53F7\u540D\u79F0\u8F6C\u6362Mapping");
            start_time = System.currentTimeMillis();
            rs = stmt.executeQuery("select YYDM,YYMC from DIM.T_DIM_YYZY_YYZDB where current date > ksrq and current date < jsrq");
            time = System.currentTimeMillis() - start_time;
            System.out.println("\u70DF\u53F6\u4EE3\u7801\u548C\u70DF\u53F6\u540D\u79F0\u8F6C\u6362\u6267\u884CSQL\u8017\u65F6\uFF1A" + (1.0D * (double)time) / 1000D);
            for(count = 0; rs.next(); count++)
            {
                int s1 = Integer.parseInt(rs.getObject(1).toString());
                String s2 = rs.getObject(2).toString().trim();
                yydm2yymc.put(new Integer(s1), s2);
                yymc2yydm.put(s2, new Integer(s1));
            }

            if(count == 0)
                System.out.println("DIM.T_DIM_YYZY_YYZDB\u8868\u6CA1\u6709\u6570\u636E,\u65E0\u6CD5\u5EFA\u7ACB\u70DF\u53F6\u4EE3\u7801\u548C\u70DF\u53F6\u540D\u79F0\u8F6C\u6362Mapping");
            rs.close();
            stmt.close();
        }
        catch(SQLException ex)
        {
            ex.printStackTrace();
        }
        returnVal.setPhdm2phmc(phdm2phmc);
        returnVal.setPhmc2phdm(phmc2phdm);
        returnVal.setYydm2yymc(yydm2yymc);
        returnVal.setYymc2yydm(yymc2yydm);
        return returnVal;
    }

    public ArrayList getSubUsageOfYanyeByPaihao(String sql, String start, String end)
    {
        ArrayList list = new ArrayList();
        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);
            int count = 0;
            start_time = System.currentTimeMillis();
            SubUsage su;
            for(; rs.next(); list.add(su))
            {
                int phdm = rs.getInt("PFPHDM");
                int yydm = rs.getInt("yydm");
                int yydcddm = rs.getInt("dcddm");
                long qauntity = rs.getLong("XHYZL");
                java.sql.Date date = rs.getDate("PFRQ");
                int yynf = rs.getInt("yynf");
                int zxpfjsdm = rs.getInt("ZXPFJSDM");
                su = new SubUsage(phdm, yydm, yydcddm, qauntity, date, yynf, zxpfjsdm, start, end);
            }

            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 getRationDate(String sql)
    {
        ArrayList list = new ArrayList();
        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);
            int count = 0;
            start_time = System.currentTimeMillis();
            RationDate rd;
            for(; rs.next(); list.add(rd))
            {
                int phdm = rs.getInt("pfphdm");
                java.sql.Date date = rs.getDate("pfrq");
                rd = new RationDate(phdm, 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 int getWorkDay(String sql)