systemparamdao.java

WAP PUSH后台源码,WAP PUSH后台源码

package com.sxit.wap.systemparam;
import java.sql.*;
import java.util.*;
import com.sxit.wap.common.*;
import com.sxit.wap.exception.*;

public class SystemParamDao {
  public static String tableName = "WAP_SYSTEM_PARAM";
  public static SystemParamModel insert(SystemParamModel model) throws SysException,UpdateException,AppException {
    if (!SystemParamBean.isValidData(model)) {
      Debug.println(model.toString() + "\n" + "Illegal data values for insert");
      throw new AppException("Illegal data values for insert");
    }
    String sql = getInsertSQL(model);
    Connection dbConnection = null;
    Statement stmt = null;
    try {
      dbConnection = getDBConnection();
      stmt = dbConnection.createStatement();
      int resultCount = stmt.executeUpdate(sql);
      if ( resultCount != 1 ) {
        Debug.println(sql + "\n" + "ERROR in INSERT !! resultCount = " + resultCount);
        throw new UpdateException("ERROR in INSERT !! resultCount = " + resultCount);
      }
      return model;
    } catch(SQLException e) {
        Debug.println(sql + "\n" + "SQLException while execute insert method :\n" + e);
        throw new SysException("SQLException while execute insert method :\n" + e);
    } finally {
      closeStatement(stmt);
      closeConnection(dbConnection);
    }
  }
  public static SystemParamModel insert(SystemParamModel model, Connection dbConnection) throws SysException,UpdateException,AppException {
    if (!SystemParamBean.isValidData(model)) {
      Debug.println(model.toString() + "\n" + "Illegal data values for insert");
      throw new AppException("Illegal data values for insert");
    }
    String sql = getInsertSQL(model);
    Statement stmt = null;
    try {
      stmt = dbConnection.createStatement();
      int resultCount = stmt.executeUpdate(sql);
      if ( resultCount != 1 ) {
        Debug.println(sql + "\n" + "ERROR in INSERT !! resultCount = " + resultCount);
        throw new UpdateException("ERROR in INSERT !! resultCount = " + resultCount);
      }
      return model;
    } catch(SQLException e) {
        Debug.println(sql + "\n" + "SQLException while execute insert method :\n" + e);
        throw new SysException("SQLException while execute insert method :\n" + e);
    } finally {
      closeStatement(stmt);
    }
  }
  public static SystemParamModel update(SystemParamModel model) throws SysException,UpdateException,AppException {
    if (!SystemParamBean.isValidData(model)) {
      Debug.println(model.toString() + "\n" + "Illegal data values for update");
      throw new AppException("Illegal data values for update");
    }
    String sql = getUpdateSQL(model);
    Connection dbConnection = null;
    Statement stmt = null;
    try {
      dbConnection = getDBConnection();
      stmt = dbConnection.createStatement();
      int resultCount = stmt.executeUpdate(sql);
      if ( resultCount != 1 ) {
        Debug.println(sql + "\n" + "ERROR in UPDATE !! resultCount = " + resultCount);
        throw new UpdateException("ERROR in UPDATE !! resultCount = " + resultCount);
      }
      return model;
    } catch(SQLException e) {
      Debug.println(sql + "\n" + "SQLException while execute update mothod :\n" + e);
      throw new SysException("SQLException while execute update mothod :\n" + e);
    } finally {
      closeStatement(stmt);
      closeConnection(dbConnection);
    }
  }
  public static SystemParamModel update(SystemParamModel model, Connection dbConnection) throws SysException,UpdateException,AppException {
    if (!SystemParamBean.isValidData(model)) {
      Debug.println(model.toString() + "\n" + "Illegal data values for update");
      throw new AppException("Illegal data values for update");
    }
    String sql = getUpdateSQL(model);
    Statement stmt = null;
    try {
      stmt = dbConnection.createStatement();
      int resultCount = stmt.executeUpdate(sql);
      if ( resultCount != 1 ) {
        Debug.println(sql + "\n" + "ERROR in UPDATE !! resultCount = " + resultCount);
        throw new UpdateException("ERROR in UPDATE !! resultCount = " + resultCount);
      }
      return model;
    } catch(SQLException e) {
      Debug.println(sql + "\n" + "SQLException while execute update mothod :\n" + e);
      throw new SysException("SQLException while execute update mothod :\n" + e);
    } finally {
      closeStatement(stmt);
    }
  }
  public static void delete(int id) throws SysException,UpdateException,AppException {
    String sql = getDeleteSQL(id);
    Connection dbConnection = null;
    Statement stmt = null;
    try {
      dbConnection = getDBConnection();
      stmt = dbConnection.createStatement();
      int resultCount = stmt.executeUpdate(sql);
      if ( resultCount != 1 ) {
        Debug.println(sql + "\n" + "ERROR in DELETE !! resultCount = " + resultCount);
        throw new UpdateException("ERROR in DELETE !! resultCount = " + resultCount);
      }
    } catch(SQLException e) {
        Debug.println(sql + "\n" + "SQLException while execute delete mothod :\n" + e);
        throw new SysException("SQLException while execute delete mothod :\n" + e);
    } finally {
      closeStatement(stmt);
      closeConnection(dbConnection);
    }
  }
  public static void delete(int id, Connection dbConnection) throws SysException,UpdateException,AppException {
    String sql = getDeleteSQL(id);
    Statement stmt = null;
    try {
      stmt = dbConnection.createStatement();
      int resultCount = stmt.executeUpdate(sql);
      if ( resultCount != 1 ) {
        Debug.println(sql + "\n" + "ERROR in DELETE !! resultCount = " + resultCount);
        throw new UpdateException("ERROR in DELETE !! resultCount = " + resultCount);
      }
    } catch(SQLException e) {
        Debug.println(sql + "\n" + "SQLException while execute delete mothod :\n" + e);
        throw new SysException("SQLException while execute delete mothod :\n" + e);
    } finally {
      closeStatement(stmt);
    }
  }
  public static void delete(int[] ids) throws SysException,UpdateException,AppException {
    String sql = getDeleteSQL(ids);
    Connection dbConnection = null;
    Statement stmt = null;
    try {
      dbConnection = getDBConnection();
      stmt = dbConnection.createStatement();
      int resultCount = stmt.executeUpdate(sql);
      if ( resultCount != ids.length ) {
        Debug.println(sql + "\n" + "ERROR in DELETE !! resultCount = " + resultCount);
        throw new UpdateException("ERROR in DELETE !! resultCount = " + resultCount);
      }
    } catch(SQLException e) {
        Debug.println(sql + "\n" + "SQLException while execute delete mothod :\n" + e);
        throw new SysException("SQLException while execute delete mothod :\n" + e);
    } finally {
      closeStatement(stmt);
      closeConnection(dbConnection);
    }
  }
  public static void delete(int[] ids, Connection dbConnection) throws SysException,UpdateException,AppException {
    String sql = getDeleteSQL(ids);
    Statement stmt = null;
    try {
      stmt = dbConnection.createStatement();
      int resultCount = stmt.executeUpdate(sql);
      if ( resultCount != ids.length ) {
        Debug.println(sql + "\n" + "ERROR in DELETE !! resultCount = " + resultCount);
        throw new UpdateException("ERROR in DELETE !! resultCount = " + resultCount);
      }
    } catch(SQLException e) {
        Debug.println(sql + "\n" + "SQLException while execute delete mothod :\n" + e);
        throw new SysException("SQLException while execute delete mothod :\n" + e);
    } finally {
      closeStatement(stmt);
    }
  }
  public static SystemParamModel findByPK(int id) throws SysException,FinderException {
    String sql = getFindByPKSQL(id);
    Connection dbConnection = null;
    Statement stmt = null;
    ResultSet rs = null;
    try {
      dbConnection = getDBConnection();
      stmt = dbConnection.createStatement();
      rs = stmt.executeQuery(sql);
      if ( !rs.next() ) {
        Debug.println(sql + "\n" + "No record for primary key " + id);
        throw new FinderException("No record for primary key " + id);
      }
      SystemParamModel model = new SystemParamModel();
      model.setId(rs.getInt("ID"));
      model.setSystemName(Function.readDBEncode(rs.getString("SYSTEM_NAME")));
      model.setManageMainPageUri(Function.readDBEncode(rs.getString("MANAGE_MAIN_PAGE_URI")));
      model.setManageIndexPageUri(Function.readDBEncode(rs.getString("MANAGE_INDEX_PAGE_URI")));
      model.setUserMainPageUri(Function.readDBEncode(rs.getString("USER_MAIN_PAGE_URI")));
      model.setUserIndexPageUri(Function.readDBEncode(rs.getString("USER_INDEX_PAGE_URI")));
      model.setCpIndexPageUri(Function.readDBEncode(rs.getString("CP_INDEX_PAGE_URI")));
      model.setCpMainPageUri(Function.readDBEncode(rs.getString("CP_MAIN_PAGE_URI")));
      model.setGroupIndexPageUri(Function.readDBEncode(rs.getString("GROUP_INDEX_PAGE_URI")));
      model.setGroupMainPageUri(Function.readDBEncode(rs.getString("GROUP_MAIN_PAGE_URI")));
      model.setInitPageRow(rs.getInt("INIT_PAGE_ROW"));
      model.setImgLocation(Function.readDBEncode(rs.getString("IMG_LOCATION")));
      model.setClearSubType(rs.getInt("CLEAR_SUB_TYPE"));
      model.setSystemIntro(Function.readDBEncode(rs.getString("SYSTEM_INTRO")));
      model.setExcelPath(Function.readDBEncode(rs.getString("EXCEL_PATH")));
      model.setStatPicturePath(Function.readDBEncode(rs.getString("STAT_PICTURE_PATH")));
      model.setSmallPicturePath(Function.readDBEncode(rs.getString("SMALL_PICTURE_PATH")));
      model.setSystemCode(Function.readDBEncode(rs.getString("SYSTEM_CODE")));
      model.setSystemState(Function.readDBEncode(rs.getString("SYSTEM_STATE")));
      return model;
    } catch(SQLException e) {
      Debug.println(sql + "\n" + "SQLException while execute findByPK mothod :\n" + e);
      throw new SysException("SQLException while execute findByPK mothod :\n" + e);
    } finally {
      closeResultSet(rs);
      closeStatement(stmt);
      closeConnection(dbConnection);
    }
  }
  public static int updateBySql(String sql) throws SysException {
    Connection dbConnection = null;
    Statement stmt = null;
    try {
      dbConnection = getDBConnection();
      stmt = dbConnection.createStatement();
      return stmt.executeUpdate(sql);
    } catch(SQLException e) {
      Debug.println(sql + "\n" + "SQLException while execute updateBySql mothod :\n" + e);
      throw new SysException("SQLException while execute updateBySql mothod :\n" + e);
    } finally {
      closeStatement(stmt);
      closeConnection(dbConnection);
    }
  }
  public static int updateBySql(String sql, Connection dbConnection) throws SysException {
    Statement stmt = null;
    try {
      stmt = dbConnection.createStatement();
      return stmt.executeUpdate(sql);
    } catch(SQLException e) {
      Debug.println(sql + "\nSQLException while execute updateBySql mothod :\n" + e);
      throw new SysException("SQLException while execute updateBySql mothod :\n" + e);
    } finally {
      closeStatement(stmt);
    }