BMPBEANBean.java~5~
上传用户:dinglihq
上传日期:2013-02-04
资源大小:99958k
文件大小:4k
源码类别:

Java编程

开发平台:

Java

  1. package com.cwj.userjmssesenbdb;
  2. import javax.ejb.*;
  3. import java.sql.*;
  4. import javax.naming.*;
  5. public class BMPBEANBean implements EntityBean {
  6.   EntityContext entityContext;
  7.   java.lang.String shancbz;
  8.   java.lang.String xiwbz;
  9.   Context ctx;
  10.   public BMPBEANPK ejbCreate(java.lang.String shancbz, java.lang.String xiwbz) throws CreateException {
  11.     /**@todo Complete this method*/
  12.     PreparedStatement pstmt = null;
  13.     Connection conn = null;
  14.     setShancbz(shancbz);
  15.     setXiwbz(xiwbz);
  16.     try {
  17.       System.out.println("ejbCreate() called.");
  18.       this.shancbz = shancbz;
  19.       this.xiwbz = xiwbz;
  20.       conn = getConnection();
  21.       pstmt = conn.prepareStatement(
  22.           "insert into aa11 (shancbz, xiwbz) values (?, ?)");
  23.       pstmt.setString(1, shancbz);
  24.       pstmt.setString(2, xiwbz);
  25.       pstmt.executeUpdate();
  26.       return new BMPBEANPK(shancbz);
  27.     }catch (Exception e) {
  28.       throw new CreateException(e.toString());
  29.     }
  30.     finally {
  31.        try {
  32.          if (pstmt != null) {
  33.            pstmt.close();
  34.          }
  35.        }
  36.        catch (Exception e) {}
  37.         try {
  38.               if (conn != null) {
  39.                 conn.close();
  40.               }
  41.         }
  42.         catch (Exception e) {}
  43.       }
  44.   }
  45.   public void ejbPostCreate(java.lang.String shancbz, java.lang.String xiwbz) throws CreateException {
  46.     /**@todo Complete this method*/
  47.   }
  48.   public void ejbRemove() throws RemoveException {
  49.     /**@todo Complete this method*/
  50.   }
  51.   public void ejbLoad() {
  52.     /**@todo Complete this method*/
  53.   }
  54.   public void ejbStore() {
  55.     /**@todo Complete this method*/
  56.   }
  57.   public void ejbActivate() {
  58.     /**@todo Complete this method*/
  59.   }
  60.   public void ejbPassivate() {
  61.     /**@todo Complete this method*/
  62.   }
  63.   public void unsetEntityContext() {
  64.     this.entityContext = null;
  65.   }
  66.   public void setEntityContext(EntityContext entityContext) {
  67.     this.entityContext = entityContext;
  68.   }
  69.   public void setShancbz(java.lang.String shancbz) {
  70.     this.shancbz = shancbz;
  71.   }
  72.   public void setXiwbz(java.lang.String xiwbz) {
  73.     this.xiwbz = xiwbz;
  74.   }
  75.   public java.lang.String getShancbz() {
  76.     return shancbz;
  77.   }
  78.   public java.lang.String getXiwbz() {
  79.     return xiwbz;
  80.   }
  81.   public java.lang.String ejbFindByPrimaryKey(java.lang.String untitledField1) throws FinderException {
  82.     /**@todo Complete this method*/
  83.     return null;
  84.   }
  85.   public BMPBEANPK ejbFindByPrimaryKey(BMPBEANPK pk) throws FinderException {
  86.     /**@todo Complete this method*/
  87.     return null;
  88.   }
  89.   public java.sql.Connection getConnection() throws Exception {
  90.     try {
  91.       ctx = new InitialContext();
  92.       javax.sql.DataSource ds = (javax.sql.DataSource) ctx.lookup(
  93.           "TestDataSource");
  94.       return ds.getConnection();
  95.     }
  96.     catch (Exception ex) {
  97.       System.err.println("Could not locate datasource! Reason:");
  98.       ex.printStackTrace();
  99.       throw ex;
  100.     }
  101.   }
  102.   public BMPBEANPK ejbHomeEjbInsertAa11(String shancbz, String xiwbz) throws CreateException {
  103.     PreparedStatement pstmt=null;
  104.     Connection conn=null;
  105.     try{
  106.       System.out.println("ejbHomeEjbInsertAa11() called");
  107.       this.shancbz=shancbz;
  108.       this.xiwbz=xiwbz;
  109.       conn=getConnection();
  110.       pstmt=conn.prepareStatement("insert into Aa11(shancbz,xiwbz)values(?,?)");
  111.       pstmt.setString(1,shancbz);
  112.       pstmt.setString(2,xiwbz);
  113.       pstmt.executeUpdate();
  114.       return new BMPBEANPK(shancbz);
  115.     }
  116.     catch(Exception e){
  117.       throw new CreateException(e.toString());
  118.     }
  119.     finally {
  120.        try {
  121.          if (pstmt != null) {
  122.            pstmt.close();
  123.          }
  124.        }
  125.        catch (Exception e) {}
  126.         try {
  127.               if (conn != null) {
  128.                 conn.close();
  129.               }
  130.         }
  131.         catch (Exception e) {}
  132.       }
  133.   }
  134.   public BMPBEANPK ejbHomeEjbdeleteAa11(String shancbz) {
  135.     /**@todo Complete this method*/
  136.     return null;
  137.   }
  138. }