wdscwdmbdao.java

以前做的一个j2ee的项目

   //////////////


   public void updateWdMbNrBlobEmpty(WDSCwdmbDAO wdmb) throws Exception {
       if (wdmb == null) return;
       try {
           this.update("WDSC.updateWdMbNrBlobEmpty", wdmb);
       } catch(Exception e) {
            e.printStackTrace();
            throw new TaxBaseSystemException(e.getMessage());
        }

   }

   public void updateWdMbNrBlobEmpty() throws Exception {
       try {
           this.update("WDSC.updateWdMbNrBlobEmpty", this);
       } catch(Exception e) {
            e.printStackTrace();
            throw new TaxBaseSystemException(e.getMessage());
        }

   }
*/


   /////////////////////////////////////////////////////////////////////////////
   public void deleteWdMb(String mbbm, String swjg) throws Exception {
       this.setMB_DM(mbbm);
       this.setMB_SWJG(swjg);
       Connection conn = null;
       try {
           //删除指标信息 此处没有加入事务完整处理
           conn = JDBCLocator.getInstance().getJDBCConnection();
           sqlMap.setUserConnection(conn);
           WDSCwdmbzbDAO mbzb = new WDSCwdmbzbDAO(this.sqlMap);
           mbzb.deleteWdMbZbWithOutTrans();
           this.deleteE("WDSC.deleteWdMb");
       } catch (Exception e) {
           e.printStackTrace();
           throw new TaxBaseSystemException("YCWDSC21006");//:删除文档模板失败！" + e.getMessage());
       } finally {
           conn.close();
       }
   }
   public void deleteWdMb() throws Exception {
       try {
           this.deleteWdMb(this.m_mbbm, this.MB_SWJG);
       } catch (Exception e) {
           e.printStackTrace();
           throw new TaxBaseSystemException("YCWDSC21006");//:删除文档模板失败！" + e.getMessage());
       }
   }



   private Vector getWdMbZb(WDSCwdmbDAO wdmb) throws Exception {
       WDSCwdmbzbDAO mbzb = new WDSCwdmbzbDAO();
       Vector v = new Vector();
       try {
           mbzb.setMB_DM(wdmb.getMB_DM());
           mbzb.setMB_LB(wdmb.getMB_LB());
           mbzb.setMB_SWJG(wdmb.getMB_SWJG());
           List list = mbzb.getWdMbZb();

           for (int i = 0; i < list.size(); i++) {
               v.add(list.get(i));
           }
           wdmb.setMB_ZB_MSG(v);
       } catch (Exception e) {
           e.printStackTrace();
           throw new TaxBaseSystemException("YCWDSC21007");//:取得文档模板指标失败！" + e.getMessage());
       }
       return v;
   }













    public String getMB_CZY() {
        return MB_CZY;
    }

    public String getMB_DM() {
        return MB_DM;
    }

    public String getMB_ENABLE() {
        return MB_ENABLE;
    }

    public String getMB_LB() {
        return MB_LB;
    }

    public String getMB_MC() {
        return MB_MC;
    }

    public Object getMB_NR() {
        return MB_NR;
    }

    public Vector getMB_ZB_MSG() {
        return MB_ZB_MSG;
    }

    public Date getSCSJ() {
        return SCSJ;
    }

    public void setMB_CZY(String MB_CZY) {
        this.MB_CZY = MB_CZY;
    }

    public void setMB_DM(String MB_DM) {
        this.MB_DM = MB_DM;
    }

    public void setMB_ENABLE(String MB_ENABLE) {
        this.MB_ENABLE = MB_ENABLE;
    }

    public void setMB_LB(String MB_LB) {
        this.MB_LB = MB_LB;
    }

    public void setMB_MC(String MB_MC) {
        this.MB_MC = MB_MC;
    }

    public void setMB_NR(Object MB_NR) {
        this.MB_NR = MB_NR;
    }

    public void setMB_ZB_MSG(Vector MB_ZB_MSG) {
        this.MB_ZB_MSG = MB_ZB_MSG;
    }

    public void setSCSJ(Date SCSJ) {
        this.SCSJ = SCSJ;
    }

    public StringBuffer getMB_NR_BUFFER() {
        return MB_NR_BUFFER;
    }

    public void setMB_NR_BUFFER(StringBuffer MB_NR_BUFFER) {
        if (this.MB_NR_BUFFER == null) {
            this.MB_NR_BUFFER = new StringBuffer();
        } else {
            if (this.MB_NR_BUFFER.length() > 0) {
                this.MB_NR_BUFFER.delete(0, this.MB_NR_BUFFER.length());
            }
        }
        this.MB_NR_BUFFER.append(MB_NR_BUFFER);
    }
/*
    //为保证事物完整性,特修改此方法
    protected Object saveE(String id) throws TaxBaseSystemException {
        Object generatedKey = null;
        try {
            //sqlMap = this.getSqlMapClient(); //用父类方法获取SqlMap对象
            try {
                try {
                    //sqlMap.startTransaction();
                    generatedKey = sqlMap.insert(id, this);
                    //sqlMap.commitTransaction();
                } finally {
                    //sqlMap.endTransaction();
                }
            } catch (SQLException ex) {
                ex.printStackTrace();
                return new Integer(ApplicationContext.RET_FAIL);
            }
        } catch(Exception e) {
            e.printStackTrace();
            throw new TaxBaseSystemException(e.getMessage());
        }

        return generatedKey;
    }
*/
    /**
     * 提供通用的删除记录的方法（另一个版本，使用本DAO的数据作为传入参数）
     * @param id：String SqlMap配置文件的SQL语句ID值
     * @return int <br>
     *     >=0 被删除的记录数<br>
     *     RET_FAIL 执行失败
     */

    protected int deleteE(String id) throws TaxBaseSystemException {
        int rows = 0;
        try {
            try {
                //执行delete操作
                try {
                    rows = sqlMap.delete(id, this);
                } finally {
                }
            } catch (SQLException ex) {
                ex.printStackTrace();
                return ApplicationContext.RET_FAIL;
            }
        }  catch(Exception e) {
            e.printStackTrace();
            throw new TaxBaseSystemException("YCWDSC21008");//:删除文档模板指标失败！" + e.getMessage());
        }
        return rows;
    }


    public SqlMapClient getSqlMapClient() {
          sqlMap = super.getSqlMapClient();
          return sqlMap;
    }

  public SqlMapClient getSqlMap() {
    return sqlMap;
  }

  public void setSqlMap(SqlMapClient sqlMap) {
    this.sqlMap = sqlMap;
  }

    public String getMB_SWJG() {
        return MB_SWJG;
    }

    public void setMB_SWJG(String MB_SWJG) {
        this.MB_SWJG = MB_SWJG;
    }




    public int getIS_EXIST() {
        return IS_EXIST;
    }

    public void setIS_EXIST(int IS_EXIST) {
        this.IS_EXIST = IS_EXIST;
    }

    private void jbInit() throws Exception {
    }




    public boolean getMbDmIsExist (String dm, String swjg) throws
            TaxBaseSystemException {
        this.setMB_DM(dm);
        this.setMB_SWJG(swjg);
        try {
            this.select("WDSC.getMbDmIsExist", this);
        } catch(Exception e) {
            e.printStackTrace();
            throw new TaxBaseSystemException("YCWDSC21009");//:得到指定代码和税务机关的模板是否存在失败！！" + e.getMessage());
        }

        int i = this.getIS_EXIST();
        return (i>0)?true:false;
    }
    public boolean getMbDmIsExist () throws TaxBaseSystemException {
        try {
            this.select("WDSC.getMbDmIsExist", this);
        } catch(Exception e) {
            e.printStackTrace();
            throw new TaxBaseSystemException("YCWDSC21009");//:得到指定代码和税务机关的模板是否存在失败！！" + e.getMessage());
        }
        int i = this.getIS_EXIST();
        return (i>0)?true:false;
    }

    public void updateWdMbWithOutMbNr () throws Exception {
        Connection conn = null;
        try {
            conn = JDBCLocator.getInstance().getJDBCConnection();

            Statement stmt = conn.createStatement();

            String sql = " UPDATE T_WDSC_WDMB " +
                " SET MB_DM= '" + this.getNEW_MB_DM()+"', MB_MC='" + this.getMB_MC() + "', MB_LB='"+ this.getNEW_MB_LB()+"', MB_ENABLE='" +
                this.getMB_ENABLE()+"', SCSJ=sysdate, MB_CZY='" +this.getMB_CZY()+"', MB_SWJG='"+this.getMB_SWJG()+"' " +
                " WHERE MB_DM='"+this.getMB_DM()+"' AND MB_LB = '" + this.getMB_LB() + "' AND MB_SWJG like '" + this.getMB_SWJG() + "' ";
            stmt.executeQuery(sql);

            if (!this.getMB_DM().equals(this.getNEW_MB_DM()) ||
                   !this.getMB_SWJG().equals(this.getNEW_MB_SWJG()) ||
                      !this.getMB_LB().equals(this.getNEW_MB_LB()) ){
                WDSCwdmbzbDAO mbzb = new WDSCwdmbzbDAO(this.getSqlMap());
                mbzb.setMB_DM(this.getMB_DM());
                mbzb.setMB_LB(this.getMB_LB());
                mbzb.setMB_SWJG(this.getMB_SWJG());
                mbzb.setXG_CZY_DM("000000");
                mbzb.setXG_SJ(new Date());

                mbzb.setNEW_MB_DM(this.getNEW_MB_DM());
                mbzb.setNEW_MB_SWJG(this.getNEW_MB_SWJG());
                mbzb.setNEW_MB_LB(this.getNEW_MB_LB());


                sql = " UPDATE T_WDSC_WDMBZB SET " +
                " MB_DM = '" + mbzb.getNEW_MB_DM() + "', " +
                " MB_LB = '" + mbzb.getNEW_MB_LB() + "', " +
                " XG_SJ = sysdate, " +
                " XG_CZY_DM = '" + mbzb.getXG_CZY_DM() + "', " +
                " MB_SWJG = '" + mbzb.getNEW_MB_SWJG() + "' " +
                " WHERE MB_DM = '" + mbzb.getMB_DM() + "' " +
                "    AND MB_LB = '" + mbzb.getMB_LB() + "' " +
                "    AND MB_SWJG like '" + mbzb.getMB_SWJG() + "' ";
                stmt.executeUpdate(sql);
            }
            stmt.close();
            conn.commit();
        } catch(Exception e) {
            e.printStackTrace();
            throw new TaxBaseSystemException("YCWDSC21010");//:更新模板内容失败！" + e.getMessage());
        } finally {
            if (conn != null) conn.close();
        }
    }


    //删除多个模板，
    //delCondition:删除条件, delete t_wdsc_wdmb where delCondition
    //
    public void delSomeWdMb(String delCondition) throws Exception {
        String sql = null;
        Connection conn = null;
        Statement stmt = null;

        try {
            conn = JDBCLocator.getInstance().getJDBCConnection();
            stmt = conn.createStatement();

            sql = " DELETE T_WDSC_WDMB WHERE " + delCondition;
            stmt.execute(sql);

            sql = " DELETE T_WDSC_WDMBZB WHERE " + delCondition;
            stmt.execute(sql);
            stmt.close();
            conn.commit();
        } catch(Exception e) {
            if (conn != null) conn.rollback();
            e.printStackTrace();
            throw new Exception("YCWDSC21011");//:删除多个模板失败！" + e.getMessage());
        } finally {
            if (conn != null) conn.close();
        }
    }

    public String getNEW_MB_DM() {
        return NEW_MB_DM;
    }

    public String getNEW_MB_SWJG() {
        return NEW_MB_SWJG;
    }

    public void setNEW_MB_DM(String NEW_MB_DM) {
        this.NEW_MB_DM = NEW_MB_DM;
    }

    public void setNEW_MB_SWJG(String NEW_MB_SWJG) {
        this.NEW_MB_SWJG = NEW_MB_SWJG;
    }

    public String getNEW_MB_LB() {
        return NEW_MB_LB;
    }

    public void setNEW_MB_LB(String NEW_MB_LB) {
        this.NEW_MB_LB = NEW_MB_LB;
    }

}