dmgldictdao.java

以前做的一个j2ee的项目

package gov.gdlt.ssgly.taxcore.taxdao.dmgl;

import java.sql.*;
import java.util.*;

import gov.gdlt.ssgly.taxcore.comm.dao.*;
import gov.gdlt.ssgly.taxcore.comm.util.*;
import gov.gdlt.ssgly.taxcore.taxevent.dmgl.*;

/**
 * <p>Title: 税收管理员平台</p>
 *
 * <p>Description: 税收管理员平台</p>
 *
 * <p>Copyright: Copyright (c) 2005</p>
 *
 * <p>Company: 广州</p>
 *
 * @author 颜颖滨
 * @version 1.0
 */

public class DMGLDictDAO extends BaseDataAccessObject{

    private String table_name;
    private int zdbXh;
    private String zdValue;
    private String zdDescript;
    private int qzbXh;

    public DMGLDictDAO() {
      try {
        jbInit();
      } catch (Exception ex) {
        ex.printStackTrace();
      }
    }


    public Connection getCurrConnection() throws Exception{
      return this.getSqlMapClient().openSession().getDataSource().getConnection();
    }

    /**
     * 功能:查询某个表的所有/某个字段的属性和定义,返回列表
     * 参数:table_name 表名
     * 参数:column_name 字段名
     */
    public List getFieldList(String table_name,String column_name) throws Exception {
      DMGLDictFieldVO fd=new DMGLDictFieldVO();
      fd.setTable_name(table_name);
      fd.setColumn_name(column_name);
      return this.selectAll("T_DM_DICT.getfdVOList", fd);
    }

    /**
     * 功能:根据字典表序号查询取值表,返回列表
     * 参数:table_name 表名
     * 参数:column_name 字段名
     */
    public List getQZBList(int zdbXh) throws Exception {
      DMGLDictFieldValueVO fdValueVO=new DMGLDictFieldValueVO();
      fdValueVO.setZdbXh(zdbXh);
      return this.selectAll("T_DM_DICT.getQZBList", fdValueVO);
    }

    /**
     * 功能:导入目标表数据至取值表中
     */
    public int importQZB(DMGLDictFieldVO zdbVO) throws Exception {
        Connection conn = this.getCurrConnection();
        Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                                              ResultSet.CONCUR_UPDATABLE);
        String sql,sql1 = "";

        String zdbXh=zdbVO.getZdbXh();
        String wjBm=zdbVO.getWjBm();
        String wjZdm=zdbVO.getWjZdm();
        String wjMszd=zdbVO.getWjMszd();
        String wjGltj=zdbVO.getWjGltj();
        wjGltj=(wjGltj==null)?"":wjGltj.trim();

        if(wjBm.equals("")||wjZdm.equals(""))return -1;

        sql1="DELETE FROM t_dm_dict_qzb WHERE ZDB_XH='"+zdbXh+"'";

        if(!wjMszd.equals("")){
          sql="INSERT INTO t_dm_dict_qzb(QZB_XH,ZDB_XH,ZD_VALUE,ZD_DESCRIPT) SELECT SQ_DM_DICT_QZB_XH.nextval,"+zdbXh+","+wjZdm+","+wjMszd+" FROM "+wjBm;
        }else{
          sql="INSERT INTO t_dm_dict_qzb(QZB_XH,ZDB_XH,ZD_VALUE,ZD_DESCRIPT) SELECT SQ_DM_DICT_QZB_XH.nextval,"+zdbXh+","+wjZdm+","+wjZdm+" FROM "+wjBm;
        }

        if ((!wjGltj.equals(""))&&(wjGltj.length()>=5)) {
            String s = wjGltj.substring(0, 5).toUpperCase();
            if (s.equals("WHERE")) {
                wjGltj = wjGltj.substring(5, wjGltj.length());
            }
            sql += " WHERE " + wjGltj;
        }

        System.out.println(sql1);
        System.out.println(sql);

        int rows=-1;
        //try {
        stmt.execute(sql1);
        rows = stmt.executeUpdate(sql);
        //} catch (SQLException ex) {
        //    ex.printStackTrace();
        //}
        stmt.close();
        conn.close();

        return rows;
    }


    /**
     * 功能:查询某个表的所有/某个字段的属性和定义,返回字段对象
     * 参数:table_name 表名
     * 参数:column_name 字段名
     */
    public DMGLDictFieldVO getFieldObject(String table_name,String column_name) throws Exception {
        List l=getFieldList(table_name, column_name);
        DMGLDictFieldVO ret=new DMGLDictFieldVO();
        ret=(DMGLDictFieldVO) l.get(0);
        return ret;
    }

    /**
     * 功能:功能:取回某个分类所有的代码表列表
     * 参数:dmb_fl 代码表分类
     */
    public ArrayList getZdbList(String tableCategory) throws Exception {
        Connection conn=this.getCurrConnection();
        Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                                              ResultSet.CONCUR_UPDATABLE);
        String sql1="";
        if(tableCategory!=null){sql1=" WHERE dmb_fl='"+tableCategory+"' ";}
        String sql = "SELECT z.table_name,z.comments as tab_comments from all_tab_comments z where z.table_name in (SELECT DISTINCT dmb_mc FROM t_dm_dict"
                     +sql1+") ORDER BY z.table_name";

        ResultSet rs = stmt.executeQuery(sql);

        ArrayList retList=new ArrayList();

        while(rs.next()){
          String[] s=new String[2];
          s[0]=rs.getString(1);
          s[1]=rs.getString(2);
          retList.add(s);
        }

        rs.close();
        stmt.close();
        conn.close();
        return retList;
      //return this.selectAll("T_DM_DICT.selectDMBList",table_category);
    }


    /**
     * 功能:功能:取回所有的可用代码表列表
     * 参数:T_DM_...的为代码表
     */
    public ArrayList getValidZdbList() throws Exception {
        Connection conn=this.getCurrConnection();
        Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                                              ResultSet.CONCUR_UPDATABLE);
        String sql =" SELECT a.table_name,b.comments as tab_comments "
                   +" FROM all_tables a,all_tab_comments b "
                    +" where a.owner = b.owner "
                    +" and a.table_name = b.table_name "
                    +" and a.table_name like 'T_DM_%' and a.owner='DB_SSGLY' and a.table_name<>'T_DM_DICT' and a.table_name<>'T_DM_DICT_QZB'  ORDER BY a.table_name";

        ResultSet rs = stmt.executeQuery(sql);

        ArrayList retList=new ArrayList();

        while(rs.next()){
          String[] s=new String[2];
          s[0]=rs.getString(1);
          s[1]=rs.getString(2);
          retList.add(s);
        }

        rs.close();
        stmt.close();
        conn.close();
        return retList;
    }

    /**
     * 功能:修改字典表
     */
     public int updateZDB(DMGLDictFieldVO zdbvo) throws Exception {
         return this.update("T_DM_DICT.updateZDB",zdbvo);
     }

    /**
     * 功能:向字典表添加,代码表有而字典表中没有的字段
     * @param ATableName String
     * @return boolean
     */
    public int addZdb(String table_name) throws Exception  {
      this.settable_name(table_name);
      Object obj=this.save("T_DM_DICT.addZdb");
      int ret=(obj==null?1:((Integer) obj).intValue());
      return ret;
    }

    /**
     * 功能:删除字典表中某个代码表
     */
    public int delZDB(DMGLDictFieldVO zdbvo) throws Exception {
        return this.delete("T_DM_DICT.delZDB",zdbvo);
     }

    /**
     * 功能:添加取值表记录
     */
    public int addQZB(DMGLDictFieldValueVO zdqzVO) throws Exception{
      this.setZdbXh(zdqzVO.getZdbXh());
      this.setZdValue(zdqzVO.getZdValue());
      this.setZdDescript(zdqzVO.getZdDescript());
      Object obj=this.save("T_DM_DICT.addQZB");
      int ret=(obj==null?1:((Integer) obj).intValue());

      return ret;
    }

    /**
     * 功能:删除取值表记录
     */
    public int delQZB(DMGLDictFieldValueVO zdqzvo) throws Exception{
      return this.delete("T_DM_DICT.delQZB",zdqzvo);
    }

    /**
     * 功能:修改取值表记录
     */
    public int updQZB(DMGLDictFieldValueVO zdqzVO) throws Exception{
        this.setQzbXh(zdqzVO.getQzbXh());
        this.setZdbXh(zdqzVO.getZdbXh());
        this.setZdValue(zdqzVO.getZdValue());
        this.setZdDescript(zdqzVO.getZdDescript());
        Object obj=this.save("T_DM_DICT.updQZB");
        int ret=(obj==null?1:((Integer) obj).intValue());
        return ret;
    }

    /**
     * 功能:返回一个table的数据列表
     *
     */
    public ArrayList getTableData(List fdList) throws Exception{

        if(fdList==null)return null;

        DMGLDictFieldVO dfvo=(DMGLDictFieldVO) fdList.get(0);
        String tableName=dfvo.getTable_name();