usersubhisdao.java

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

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

public class UserSubHisDao {
  public static String tableName = "WAP_USER_SUB_HIS";
  public static UserSubHisModel insert(UserSubHisModel model) throws SysException,UpdateException,AppException {
    if (!UserSubHisBean.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 UserSubHisModel insert(UserSubHisModel model, Connection dbConnection) throws SysException,UpdateException,AppException {
    if (!UserSubHisBean.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 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);
    }
  }
  public static Collection queryBySql(String sql) throws SysException {
    Connection dbConnection = null;
    Statement stmt = null;
    ResultSet rs = null;
    ArrayList list = new ArrayList();
    try {
      dbConnection = getDBConnection();
      stmt = dbConnection.createStatement();
      rs = stmt.executeQuery(sql);
      ResultSetMetaData rsmd = rs.getMetaData();
      while ( rs.next() ) {
        Hashtable element = new Hashtable();
        for (int i = 1; i <= rsmd.getColumnCount(); i++) {
          String columnName = rsmd.getColumnName(i);
          String fieldName = Function.format(columnName);
          String fieldType = ColumnType.getFieldType(Database.dbType, rsmd, i);
          if (fieldType == null) continue;
          if ("Timestamp".equals(fieldType)) {
            element.put(fieldName, rs.getTimestamp(columnName));
          } else if ("String".equals(fieldType)) {
            String value = Function.readDBEncode(rs.getString(columnName));
            if (value == null) value = "";
            element.put(fieldName, value);
          } else if ("int".equals(fieldType)) {
            element.put(fieldName, String.valueOf(rs.getInt(columnName)));
          } else if ("long".equals(fieldType)) {
            element.put(fieldName, String.valueOf(rs.getLong(columnName)));
          } else if ("float".equals(fieldType)) {
            element.put(fieldName, String.valueOf(rs.getFloat(columnName)));
          }
        }
        list.add(element);
      }
      return list;
    } catch(SQLException e) {
      Debug.println(sql + "\n" + "SQLException while execute queryBySql mothod :\n" + e);
      throw new SysException("SQLException while execute queryBySql mothod :\n" + e);
    } finally {
      closeResultSet(rs);
      closeStatement(stmt);
      closeConnection(dbConnection);
    }
  }
  public static Collection queryBySql(String sql, int beginRow, int endRow) throws SysException {
    Connection dbConnection = null;
    Statement stmt = null;
    ResultSet rs = null;
    ArrayList list = new ArrayList();
    try {
      dbConnection = getDBConnection();
      stmt = dbConnection.createStatement();
      rs = stmt.executeQuery(sql);
      ResultSetMetaData rsmd = rs.getMetaData();
      int row = 0;
      while ( rs.next() ) {
        if (++row < beginRow) continue;
        if (row > endRow) break;
        Hashtable element = new Hashtable();
        for (int i = 1; i <= rsmd.getColumnCount(); i++) {
          String columnName = rsmd.getColumnName(i);
          String fieldName = Function.format(columnName);
          String fieldType = ColumnType.getFieldType(Database.dbType, rsmd, i);
          if (fieldType == null) continue;
          if ("Timestamp".equals(fieldType)) {
            element.put(fieldName, rs.getTimestamp(columnName));
          } else if ("String".equals(fieldType)) {
            String value = Function.readDBEncode(rs.getString(columnName));
            if (value == null) value = "";
            element.put(fieldName, value);
          } else if ("int".equals(fieldType)) {
            element.put(fieldName, String.valueOf(rs.getInt(columnName)));
          } else if ("long".equals(fieldType)) {
            element.put(fieldName, String.valueOf(rs.getLong(columnName)));
          } else if ("float".equals(fieldType)) {
            element.put(fieldName, String.valueOf(rs.getFloat(columnName)));
          }
        }
        list.add(element);
      }
      return list;
    } catch(SQLException e) {
      Debug.println(sql + "\n" + "SQLException while execute queryBySql mothod :\n" + e);
      throw new SysException("SQLException while execute queryBySql mothod :\n" + e);
    } finally {
      closeResultSet(rs);
      closeStatement(stmt);
      closeConnection(dbConnection);
    }
  }
  public static int getRowCountBySql(String sql) throws SysException {
    Connection dbConnection = null;
    Statement stmt = null;
    ResultSet rs = null;
    int rowCount = 0;
    try {
      dbConnection = getDBConnection();
      stmt = dbConnection.createStatement();
      rs = stmt.executeQuery(sql);
      if ( rs.next() ) {
        rowCount = rs.getInt(1);
      }else{
        Debug.println(sql + "\n" + "ERROR in get row count!!");
        throw new SysException("ERROR in get row count!!");
      }
      return rowCount;
    } catch(SQLException e) {
      Debug.println(sql + "\n" + "SQLException while execute getRowCountBySql mothod :\n" + e);
      throw new SysException("SQLException while execute getRowCountBySql mothod :\n" + e);
    } finally {
      closeResultSet(rs);
      closeStatement(stmt);
      closeConnection(dbConnection);
    }
  }
  public static Collection queryAll() throws SysException {
    String sql = "SELECT USER_MDN, CHANNEL_ID, SUB_DATE, FEE_TYPE, FEE_CODE FROM WAP_USER_SUB_HIS";
    return queryBySql(sql);
  }
  public static Collection queryAll(int beginRow, int endRow) throws SysException {
    String sql = "SELECT USER_MDN, CHANNEL_ID, SUB_DATE, FEE_TYPE, FEE_CODE FROM WAP_USER_SUB_HIS";
    return queryBySql(sql, beginRow, endRow);
  }
  public static int getRowCountOfAll() throws SysException {
    String sql = "SELECT COUNT(*) FROM WAP_USER_SUB_HIS";
    return getRowCountBySql(sql);
  }
  public static UserSubHisModel toModel(Hashtable element) {
    UserSubHisModel model = new UserSubHisModel();
    model.setUserMdn((String)element.get("userMdn"));
    model.setChannelId(Integer.parseInt((String)element.get("channelId")));
    model.setSubDate((Timestamp)element.get("subDate"));
    model.setFeeType(Integer.parseInt((String)element.get("feeType")));
    model.setFeeCode(Integer.parseInt((String)element.get("feeCode")));
    return model;
  }
  public static Collection allToModel(Collection coll) {