facadequerybean.java

资产设备管理系统 第1章 系统登录 1.1 系统登录 （1）双击资产设备管理系统图标

package appgdzc.model;

import javax.ejb.SessionBean;
import javax.ejb.SessionContext;
import javax.ejb.CreateException;
import java.util.Collection;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import javax.naming.Context;
import appgdzc.tools.InitContext;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import javax.swing.table.DefaultTableModel;
public class facadeQueryBean implements SessionBean {
    SessionContext sessionContext;
    Context context = null;
    InitContext initContext = new InitContext();
    DataSource ds = null;
    Connection con = null;
    ResultSet rs = null;
    PreparedStatement psmt = null;
    ResultSetMetaData rsmd = null;

    public void ejbCreate() throws CreateException {
       context = initContext.getinitialContext();
        try{
            ds = (DataSource) context.lookup("DB_GDZCPool");
            con = ds.getConnection();
        }catch(javax.naming.NamingException name){
            name.printStackTrace();
        }catch(java.sql.SQLException sql){
            sql.printStackTrace();
        }
    }

    public void ejbRemove() {
    }

    public void ejbActivate() {
        context = initContext.getinitialContext();
        try{
            ds = (DataSource) context.lookup("DB_GDZCPool");
            con = ds.getConnection();
        }catch(javax.naming.NamingException name){
            name.printStackTrace();
        }catch(java.sql.SQLException sql){
            sql.printStackTrace();
        }
    }

    public void ejbPassivate() {
    }

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



    public boolean modifyuser(String sqlStr) {
        try{
            con = ds.getConnection();
            psmt = con.prepareStatement(sqlStr);
            psmt.execute();
            return true;
        }catch(java.sql.SQLException sql){
            sql.printStackTrace();
        }finally{
            try{
                con.close();
            }catch(java.sql.SQLException sql){
                System.out.println("关闭数据库连接失败:" + sql.getMessage());
            }
        }
        return false;

    }

    public Collection getQueryObject(String strSql) {
        java.util.Collection resultCollection = new java.util.Vector();
        try{
           con = ds.getConnection();
           psmt = con.prepareStatement(strSql);
           psmt.execute();
           rs = psmt.getResultSet();
           rsmd = rs.getMetaData();

           while(rs.next()){
               java.util.Vector vData = new java.util.Vector();
               for(int i = 1 ; i <= rsmd.getColumnCount() ; i++){
                   Object obj = null;
                   if (rsmd.getColumnTypeName(i).equals("datetime")){
                       obj = rs.getDate(i);
                       vData.addElement(obj);
                   }else{
                       obj = rs.getObject(i);
                       vData.addElement(String.valueOf(obj).trim());
                   }
               }
               resultCollection.add(vData);
               System.out.println("resultCollection = " + resultCollection);
           }
       }catch(java.sql.SQLException sql){
           sql.printStackTrace();
           return null;
       }finally{
           try{
               con.close();
           }catch(java.sql.SQLException sql){
               System.out.println("关闭数据库连接失败:" + sql.getMessage());
           }
       }

        return resultCollection;
    }
}