pagedefinedaoimpl.java

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

/**
 * QueryDAOImpl.java       08/08/2002,
 * Author:
 *
 * Copyright (c) 2002 Censoft Corp.
 * Beijing China
 * All rights reserved.
 *
 * Modifier:
 * Time:
 ***/
package com.gs.pageBuilder.dao;

import java.util.*;
import java.sql.*;
import com.gs.util.*;
import com.gs.util.PubFunc;
import com.gs.pageBuilder.model.*;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.CallableStatement;
import java.io.Writer;
import java.io.File;
import java.io.FileInputStream;
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.FileNotFoundException;
import oracle.sql.CLOB;
import java.io.BufferedReader;
import java.io.*;


public class PageDefineDAOImpl
    implements PageDefineDAO {

  private Connection conn;
  private Statement stmt;
  private ResultSet resu, rs;
  private PreparedStatement pstmt;
  public PageDefineDAOImpl() {
    super();
  }

  /**
   * 获得打印参数
   * 应用:获得打印参数
   */
  public ArrayList getPagePrintSetup(String BM) throws
      AppException {
    ArrayList pagePrintSetupList = new ArrayList();
    String sql = null;
    try {

      conn = Common.getConnection();
    //  conn.setAutoCommit(false);
      stmt = conn.createStatement();
      try {

        //是否正常数据
        if (BM == null) {
          Debug.println(
              "[PageDefineDAOImpl]getPagePrintSetup----->BM is null!");
          return pagePrintSetupList;
        }

        sql = "select * from "
            + TableNameUtil.UNIVERSAL_PRINTSET
            + " where code='"
            + BM
            + "'";

        Debug.println("[PageDefineDAOImpl]getPagePrintSetup--->>>sql:" + sql);
        rs = stmt.executeQuery(sql);

        if (rs.next()) {
          pagePrintSetupList.add(0, rs.getString("POSITION_LEFT"));
          pagePrintSetupList.add(1, rs.getString("POSITION_TOP"));
        }
        else {
          pagePrintSetupList.add(0, "0");
          pagePrintSetupList.add(1, "0");
        }

      }
      catch (SQLException sqle) {
        Debug.println("[PageDefineDAOImpl]getPagePrintSetup--->>>Exception:" +
                      sqle.getMessage());
      }
      Debug.println("ok");
   //   conn.commit();

    }
    catch (Exception e) {
      try {
        conn.rollback();
      }
      catch (Exception er) {}
      e.printStackTrace();
      Debug.println("[PageDefineDAOImpl--->getPagePrintSetup]Exception is : " +
                    e.getMessage());
      throw new AppException("在DAO中捕获到一个错误: " + e.getMessage());
    }
    finally {
      try {
        this.closePreparedStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeResultSet();
      }
      catch (Exception e) {
      }
      try {
        this.closeStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeConnection();
      }
      catch (Exception e) {
      }
    }

    return pagePrintSetupList;
  }

  /**
   * 保存页面定义数据
   * 应用:单逻辑，组逻辑，层逻辑
   */
  public boolean saveDateDefine(ArrayList saveDateList) throws
      AppException {
    boolean flag = false;
    String sql = null;
    String code = "";
    PreparedStatement stmtPar = null;

    try {

      conn = Common.getConnection();
   //   conn.setAutoCommit(false);
      stmt = conn.createStatement();

      try {

        //是否正常数据
        if (saveDateList == null) {
          Debug.println(
              "[PageDefineDAOImpl]saveDateDefine----->saveDateList is null!");
          return flag;
        }

        Debug.println("[PageDefineDAOImpl]saveDateDefine--->>>sql:" +
                      (String) saveDateList.get(0));
        stmt.executeUpdate( (String) saveDateList.get(0));

        //获得code编号
        sql = "select code from "
            + TableNameUtil.UNIVERSAL_PAGEELEMENT_DEFINE
            + " order by code desc"
            ;

        Debug.println("[PageDefineDAOImpl]saveDateDefine--->>>sql:" + sql);
        rs = stmt.executeQuery(sql);

        if (rs.next()) {
          code = (String) rs.getString("code");
        }
        else {
          code = "100000000";
        }
        rs.close();
        //插入定义数据
        for (int i = 1; i < saveDateList.size(); i++) {
          long longtemp = Long.parseLong(code) + 1;
          code = "" + longtemp;
          Debug.println("[PageDefineSaveDataHandler]ProcessEvent------->code:" +
                        code + " , sql:" + saveDateList.get(i));
          stmtPar = conn.prepareStatement( (String) saveDateList.get(i));
          stmtPar.setString(1, code); //set code

          stmtPar.executeUpdate();
        }

        flag = true;
      }
      catch (SQLException sqle) {
        Debug.println("[PageDefineDAOImpl]saveDateDefine--->>>Exception:" +
                      sqle.getMessage());
      }
      Debug.println("ok");
   //   conn.commit();

    }
    catch (Exception e) {
      try {
        conn.rollback();
      }
      catch (Exception er) {}
      e.printStackTrace();
      Debug.println("[PageDefineDAOImpl--->saveDateDefine]Exception is : " +
                    e.getMessage());
      throw new AppException("在DAO中捕获到一个错误: " + e.getMessage());
    }
    finally {
      try {
        stmtPar.close();
      }
      catch (Exception e) {
      }

      try {
        this.closePreparedStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeResultSet();
      }
      catch (Exception e) {
      }
      try {
        this.closeStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeConnection();
      }
      catch (Exception e) {
      }

    }

    return flag;
  }

  /**
   * 添加定义页面
   * 应用:添加定义页面
   */
  public String addPageDefine(PageDefineModel pageDefineModel) throws
      AppException {
    boolean flag = false;
    String sql = null;
    String code = "";
    try {
      conn = Common.getConnection();
     // conn.setAutoCommit(false);
      stmt = conn.createStatement();

      //是否正常数据
      if (pageDefineModel == null) {
        Debug.println(
            "[PageDefineDAOImpl]addPageDefine----->pageDefineModel is null!");
        code = PubFunc.toSql(pageDefineModel.getCode(), 0);
        return code;
      }
      code = PubFunc.toSql(pageDefineModel.getCode(), 0);

      /*
        CODE VARCHAR2(12) NOT NULL PRIMARY KEY,	//页面编号query001
        EXPLAIN VARCHAR2(200) NULL,		//说明
        ROWCOLSIGN VARCHAR2(8) NULL,		//页面生成行列分类
        CLASS1 VARCHAR2(8) NULL,		//
        CLASS2 VARCHAR2(8) NULL,		//
        CLASS3 VARCHAR2(8) NULL,		//业务类型
        CONTENT CLOB NULL,			//页面生成结果
        PAGE_WIDTH VARCHAR2(8) NULL,		//页面宽度
        PAGE_STYLE VARCHAR2(200) NULL,		//页面样式
        BUILD_DATE VARCHAR2(30) NULL,		//生成日期
        ORDERID VARCHAR2(8) NULL		//排列顺序号
       */

      sql = "select * from "
          + TableNameUtil.UNIVERSAL_PAGE_DEFINE
          + " where code='"
          + PubFunc.toSql(pageDefineModel.getCode(), 0)
          + "'"
          ;
      rs = stmt.executeQuery(sql);
      if (rs.next()) {
        Debug.println("[PageDefineDAOImpl]addPageDefine--->>>code:" +
                      PubFunc.toSql(pageDefineModel.getCode(), 0) +
                      " is exist!");
        return "";
      }
      rs.close();

      sql = "insert into "
          + TableNameUtil.UNIVERSAL_PAGE_DEFINE
          + " (code,explain,rowcolsign,class1,class2,class3,page_width,page_style,build_date,orderid)values('"
          + PubFunc.toSql(pageDefineModel.getCode(), 0)
          + "','"
          + PubFunc.toSql(pageDefineModel.getExplain(), 0)
          + "','"
          + PubFunc.toSql(pageDefineModel.getRowcolSign(), 0)
          + "','"
          + PubFunc.toSql(pageDefineModel.getClass1(), 0)
          + "','"
          + PubFunc.toSql(pageDefineModel.getClass2(), 0)
          + "','"
          + PubFunc.toSql(pageDefineModel.getClass3(), 0)
          + "','"
          + PubFunc.toSql(pageDefineModel.getPageWidth(), 0)
          + "','"
          + PubFunc.toSql(pageDefineModel.getPageStyle(), 0)
          + "','"
          + PubFunc.toSql(pageDefineModel.getBuildDate(), 0)
          + "','"
          + PubFunc.toSql(pageDefineModel.getOrderID(), 0)
          + "')"
          ;

      Debug.println("[PageDefineDAOImpl]addPageDefine--->>>sql:" + sql);
      stmt.executeUpdate(sql);
   //   conn.commit();
    }
    catch (SQLException sqle) {
      Debug.println("[PageDefineDAOImpl]addPageDefine--->>>Exception:" +
                    sqle.getMessage());
    }

    finally {
      try {
        this.closePreparedStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeResultSet();
      }
      catch (Exception e) {
      }
      try {
        this.closeStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeConnection();
      }
      catch (Exception e) {
      }
    }

    return code;
  }

  /**
   * 删除定义页面
   * 应用:删除定义页面
   */
  public boolean dellPageDefine(String code) throws
      AppException {
    String sql = null;
    boolean flag = false;
    try {
      conn = Common.getConnection();
    //  conn.setAutoCommit(false);
      stmt = conn.createStatement();

      //是否正常数据
      if (code == null || "".equals(code)) {
        Debug.println(
            "[PageDefineDAOImpl]dellPageDefine----->code is null!");
        return flag;
      }

      sql = "delete from  "
          + TableNameUtil.UNIVERSAL_PAGE_DEFINE
          + " where code='"
          + PubFunc.toSql(code, 0)
          + "'"
          ;

      Debug.println("[PageDefineDAOImpl]dellPageDefine--->>>sql:" + sql);
      stmt.executeUpdate(sql);
    //  conn.commit();
    }
    catch (SQLException sqle) {
      Debug.println("[PageDefineDAOImpl]dellPageDefine--->>>Exception:" +
                    sqle.getMessage());
    }

    finally {
      try {
        this.closePreparedStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeResultSet();
      }
      catch (Exception e) {
      }
      try {
        this.closeStatement();