modifyenterprisedaoimpl.java

一套完整的工商12315的源程序jsp部分在12315里,后台JAVA部分在gs12315src里,没有打包数据库.

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: </p>
 * @author glt
 * @version 1.0
 */
package com.gs.component.enterprise.dao;

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

import com.gs.component.enterprise.model.*;
import com.gs.pageBuilder.model.*;
import com.gs.util.*;

/**
 * 数据库访问对象继承DAO接口
 * 主要实现企业表单的数据库修改功能
 */
public class ModifyEnterpriseDAOImpl implements ModifyEnterpriseDAO{
    Connection conn = null;
    Statement stmt = null;
    ResultSet rs = null;
    String sql = null;
    SQLExecProxy sqlExecProxy = null;

    public ModifyEnterpriseDAOImpl(){
        sqlExecProxy = new SQLExecProxy();
    }

    /**
     *执行SQL语句（delete或insert或update语句）
     * @param	SN,BID,tableList
     * @return   none
     * @exception Exception
     */
    public void saveModifyInfo(String SN,String BID,String updateSql) throws
        AppException{
        ArrayList alreturn = null;
        try{
            conn = Common.getConnection();
         //   conn.setAutoCommit(false);
            stmt = conn.createStatement();
            Debug.println("[ModifyEnterpriseDAOImpl--->updateTable]Connection Database is ok!");
            Debug.println("[ModifyEnterpriseDAOImpl--->updateTable]sql =" + updateSql);
            stmt.executeUpdate(updateSql);
        //    conn.commit();
        } catch(Exception e){
            try{
                conn.rollback();
            } catch(Exception er){
            }
            Debug.println("[ModifyEnterpriseDAOImpl--->getTreeMenu]Exception is : " + e.getMessage());
            throw new AppException("EnterpriseDAO.selectApproveInfo: Exception " + e.getMessage());
        } finally{
            cleanup(rs,stmt,conn);
        }
    }

    /**
     *执行SQL语句组（delete或insert或update语句）
     * @param	sqls 所要执行的SQL语句群
     * @return   none
     * @exception Exception
     */
    public void executeSQLS(ArrayList sqls) throws
        AppException{
        ArrayList alreturn = null;
        try{
            conn = Common.getConnection();
          //  conn.setAutoCommit(false);
            stmt = conn.createStatement();
            Debug.println("[ModifyEnterpriseDAOImpl--->executeSQLS]Connection Database is ok!");
            int i=0;
            for( i = 0;i < sqls.size();i++){
                String updateSql = (String) sqls.get(i);
                Debug.println("[ModifyEnterpriseDAOImpl--->executeSQLS]sql =" + updateSql);
                stmt.executeUpdate(updateSql);
            }
            if(i > 0){
         //       conn.commit();
            }
        } catch(Exception e){
            try{
                conn.rollback();
            } catch(Exception er){
            }
            Debug.println("[ModifyEnterpriseDAOImpl--->getTreeMenu]Exception is : " + e.getMessage());
            throw new AppException("EnterpriseDAO.selectApproveInfo: Exception " + e.getMessage());
        } finally{
            cleanup(rs,stmt,conn);
        }
    }

    /**
     *得到要修改的页面的page_code
     * @param	SN,BID,
     * @return   ArrayList
     * @exception SQLException
     */
    public QueryPageDefine getQueryPageDefine(String code) throws
        AppException{
        boolean flag = false;
        String sql = null;
        QueryPageDefine queryPageDefine = new QueryPageDefine();
        try{
            conn = Common.getConnection();
            stmt = conn.createStatement();
            //是否正常数据
            if(code == null || "".equals(code)){
                Debug.println(
                    "[ModifyEnterpriseDAOImpl]getQueryPageDefine----->code is null!");
                return queryPageDefine;
            }
            sql = "select * from  "
                + TableNameUtil.UNIVERSAL_QUERY_PAGEDEFINE
                + " where code='" + code + "'";

            Debug.println("[ModifyEnterpriseDAOImpl]getQueryPageDefine--->>>sql:" + sql);

            rs = stmt.executeQuery(sql);

            if(rs.next()){
                queryPageDefine.setCode(rs.getString("code"));
                queryPageDefine.setPageCode(rs.getString("page_code"));
                queryPageDefine.setExplain(rs.getString("explain"));
                queryPageDefine.setOrderId(rs.getString("order_id"));
                queryPageDefine.setBID(rs.getString("bid"));
                queryPageDefine.setDJJG(rs.getString("djjg"));
                queryPageDefine.setGXDW(rs.getString("gxdw"));
                queryPageDefine.setPageType(rs.getString("page_type"));
                queryPageDefine.setCATEGORY1(rs.getString("category1"));
                queryPageDefine.setCATEGORY2(rs.getString("category2"));
                queryPageDefine.setCATEGORY3(rs.getString("category3"));
            }
        } catch(SQLException sqle){
            Debug.println("[ModifyEnterpriseDAOImpl]getQueryPageDefine--->>>Exception:" +
                          sqle.getMessage());
        }

        finally{
            cleanup(rs,stmt,conn);
        }
        return queryPageDefine;
    }

    /**
     *得到要修改的字段
     * @param	SN,BID,
     * @return   ArrayList
     * @exception SQLException
     */
    public ArrayList getModifyFieldList(String SN,String BID,String code) throws
        AppException{
        //boolean flag = false;
        String tableName = TableNameUtil.GSGSJIN_BASIS02;
        String page_code = null;
        QueryPageDefine queryPageDefine = new QueryPageDefine();
        ArrayList queryFieldList = new ArrayList();

        int fieldCountNum = 0;
        Connection queryCONN = null;
        ResultSet queryRS = null;
        Statement querySTMT = null;
        try{
            queryCONN = Common.getConnection();
            querySTMT = queryCONN.createStatement();
            queryPageDefine = getQueryPageDefine(code);
            page_code = queryPageDefine.getPageCode();
            Debug.print("[ModifyEnterpriseDAOImpl]getModifyFieldList--->page_code" + page_code);

            String sqlQuery = "select b.code ,b.explain,b.format_type from "
                + TableNameUtil.UNIVERSAL_QUERY_DATA
                + " a,"
                + TableNameUtil.UNIVERSAL_QUERY_FIELD_DEFINE
                + " b where a.page_code='"
                + page_code
                + "' and a.field_name=b.code order by a.order_id";

            /*
                         String sqlQuery = "SELECT b.CODE ,b.EXPLAIN,b.FORMAT_TYPE from "
                + TableNameUtil.UNIVERSAL_QUERY_DATA
                + " a,"
                + TableNameUtil.UNIVERSAL_QUERY_FIELD_DEFINE
                + " b where a.PAGE_CODE='"
                + page_code
                + "' and a.FIELD_NAME=b.CODE";
             */
            //sqlQuery = "select FIELD_NAME,CODE FROM UNIVERSAL_QUERY_DATA WHERE PAGE_CODE='" + page_code + "'";
            Debug.println("[ModifyEnterpriseDAOImpl]getModifyFieldList--->>>sqlQuery:" + sqlQuery);
            queryRS = querySTMT.executeQuery(sqlQuery);

            for(fieldCountNum = 0;queryRS.next();fieldCountNum++){
                QueryPageFieldDefine queryPageFieldDefine = new QueryPageFieldDefine();
                //去掉00
                String tempstr = queryRS.getString("code");
                if(tempstr != null && tempstr.length() > 2){
                    tempstr = tempstr.substring(0,tempstr.length() - 2);
                }

                queryPageFieldDefine.setFieldName(tempstr);
                queryPageFieldDefine.setExplain(queryRS.getString("EXPLAIN"));
                queryPageFieldDefine.setFieldValue("");
                queryPageFieldDefine.setFormatType(queryRS.getString("FORMAT_TYPE"));
                queryFieldList.add(queryPageFieldDefine);
                Debug.println("[ModifyEnterpriseDAOImpl]字段取值:" + fieldCountNum + "   " + queryRS.getString("CODE"));
            }
        } catch(SQLException sqle){
            Debug.println("[ModifyEnterpriseDAOImpl]getModifyFieldList--->>>Exception:" +
                          sqle.getMessage());
        } catch(Exception e){
            Debug.println("[ModifyEnterpriseDAOImpl]getModifyFieldList--->>>Exception:" + e.getMessage());
        } finally{
            cleanup(queryRS,querySTMT,queryCONN);
        }
        return queryFieldList;
    }

    /**
     * <p>Descript:获取子表的最大记录号（包括变更时删除的记录）</p>
     * @param BID
     * @param InnerCode
     * @param SubTableName
     * @return sMaxRecordNum
     * @throws java.lang.Exception
     */
    public String getSubMaxRecordNumber(String BID,String InnerCode,String SubTableName) throws Exception{

        String sql = null;
        String sMaxRecordNum = null;
        try{
            String newBID = null;
            if(BID.startsWith("01")){
                newBID = BID;
            }else{
                newBID = "02"+BID.substring(2);
            }
            //查询表
            sql = "select max(field003) as maxRecordNum from (";
            sql += " select field003 from " + TableNameUtil.IN_SUB_INSDEL + " where field004 = '" + InnerCode + "' and field002 = '" + SubTableName +
                "'";
            sql += " union all ";
            sql += " select field003 from " + TableNameUtil.GSGSJIN_SUB02;
            sql += " where field002 = 'sub02" + SubTableName.substring(5) + "' ";
            sql += " and field001 in (select field001 from " + TableNameUtil.GSGSJIN_BASIS02;
            sql += " where field002  = '" + newBID + "'  ";
            sql += " and field003 ='" + InnerCode + "')";
            sql += " ) a";
            Debug.println("[ChangeBusinessDAOImpl-->getSubMaxRecordNumber]sql:" + sql);
            //调用frl的
            sqlExecProxy.openProxy();
            sqlExecProxy.executeQuery(sql);
            if(sqlExecProxy.nextRow()){
                sMaxRecordNum = (String) sqlExecProxy.getFieldString("maxRecordNum");
            }
        } catch(Exception e){
            throw new Exception("[ChangeBusinessDAOImpl-->getSubMaxRecordNumber]exception:" + e.toString());
        } finally{
            try{
                sqlExecProxy.closeProxy();
            } catch(Exception e){
                Debug.println("[ChangeBusinessDAOImpl-->>getSubMaxRecordNumber]exception:" + e.toString());
            }
        }
        Debug.println("[ChangeBusinessDAOImpl-->getSubMaxRecordNumber]sMaxRecordNum:" + sMaxRecordNum);
        return sMaxRecordNum;
    } //getSubMaxRecordNumber()


    /**
     * 释放资源
     * @param none
     * @return   none
     * @exception SQLException
     */
    protected void cleanup(ResultSet rs,Statement stmt,Connection conn) throws
        AppException{
        Common.clearUp(rs,stmt,conn);
    }

}