checkdao.java

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

      sql = "UPDATE USER_CHECK SET OLD_MDN = '"
          + Function.writeDBEncode(model.getOldMdn()) + "', SUBSTATUS = '"
          + Function.writeDBEncode(model.getSubstatus()) + "', OLD_SUBSTATUS = '"
          + Function.writeDBEncode(model.getOldSubstatus()) + "', STATUS = "
          + model.getStatus() + ", SERIALNO = '"
          + Function.writeDBEncode(model.getSerialno()) + "', OPDATE = '"
          + Function.DateToString(model.getOpdate()) + "', OPRAREAID = '"
          + Function.writeDBEncode(model.getOprareaid()) + "', POINT = '"
          + Function.writeDBEncode(model.getPoint()) + "' WHERE MDN = '" + model.getMdn() + "'";
    }
    return sql;
  }
  protected static String getDeleteSQL(String mdn) {
    String sql = "";
    if (Database.dbType == DBType.ORACLE) {
      sql = "DELETE FROM USER_CHECK WHERE MDN = '" + mdn + "'";
    } else if (Database.dbType == DBType.SQLSERVER) {
      sql = "DELETE FROM USER_CHECK WHERE MDN = '" + mdn + "'";
    } else if (Database.dbType == DBType.MYSQL) {
      sql = "DELETE FROM USER_CHECK WHERE MDN = '" + mdn + "'";
    }
    return sql;
  }
  protected static String getDeleteSQL(String[] ids) {
    String sql = "";
    if (Database.dbType == DBType.ORACLE) {
      sql = "DELETE FROM USER_CHECK WHERE 1 = 2";
      for ( int i = 0; i < ids.length; i++ ) {
        sql += " OR MDN = '" + ids[i] + "'";
      }
    } else if (Database.dbType == DBType.SQLSERVER) {
      sql = "DELETE FROM USER_CHECK WHERE 1 = 2";
      for ( int i = 0; i < ids.length; i++ ) {
        sql += " OR MDN = '" + ids[i] + "'";
      }
    } else if (Database.dbType == DBType.MYSQL) {
      sql = "DELETE FROM USER_CHECK WHERE 1 = 2";
      for ( int i = 0; i < ids.length; i++ ) {
        sql += " OR MDN = '" + ids[i] + "'";
      }
    }
    return sql;
  }
  protected static String getFindByPKSQL(String mdn) {
    String sql = "";
    if (Database.dbType == DBType.ORACLE) {
      sql = "SELECT * FROM USER_CHECK WHERE MDN = '" + mdn + "'";
    } else if (Database.dbType == DBType.SQLSERVER) {
      sql = "SELECT * FROM USER_CHECK WHERE MDN = '" + mdn + "'";
    } else if (Database.dbType == DBType.MYSQL) {
      sql = "SELECT * FROM USER_CHECK WHERE MDN = '" + mdn + "'";
    }
    return sql;
  }
  protected static boolean isValidData(CheckModel model) {
    return true;
  }
  private static Connection getDBConnection() throws SysException {
    return Database.getConnection();
  }
  private static void closeConnection(Connection dbConnection) throws SysException {
    try {
      if (dbConnection != null && !dbConnection.isClosed()) {
        dbConnection.close();
        dbConnection = null;
      }
    } catch (SQLException se) {
      //throw new SysException("SQL Exception while closing DB connection : \n" + se);
    }
  }
  private static void closeResultSet(ResultSet result) throws SysException {
    try {
      if (result != null) {
        result.close();
      }
    } catch (SQLException se) {
      //throw new SysException("SQL Exception while closing Result Set : \n" + se);
    }
  }
  private static void closeStatement(Statement stmt) throws SysException {
    try {
      if (stmt != null) {
        stmt.close();
      }
    } catch (SQLException se) {
      //throw new SysException("SQL Exception while closing Statement : \n" + se);
    }
  }
  public static void main(String[] args) throws Exception{
    String action = "";
    if (args.length == 1) {
      action = args[0];
    }
    if (action == null || "".equals(action)) {

    } else if ("insert".equalsIgnoreCase(action)) {
      CheckModel model=new CheckModel();
      model.setMdn("abc");
      model.setOldMdn("abc");
      model.setSubstatus("abc");
      model.setOldSubstatus("abc");
      model.setStatus(1);
      model.setSerialno("abc");
      model.setOpdate(Function.getCurrTime());
      model.setOprareaid("abc");
      model.setPoint("abc");
      CheckModel checkModel = CheckBean.insert(model);
    }else if ("update".equalsIgnoreCase(action)){
      CheckModel checkModel = CheckBean.findByPK("1");
      String mdn = checkModel.getMdn();
      String oldMdn = checkModel.getOldMdn();
      String substatus = checkModel.getSubstatus();
      String oldSubstatus = checkModel.getOldSubstatus();
      int status = checkModel.getStatus();
      String serialno = checkModel.getSerialno();
      Timestamp opdate = checkModel.getOpdate();
      String oprareaid = checkModel.getOprareaid();
      String point = checkModel.getPoint();
      checkModel.setOldMdn(oldMdn);
      checkModel.setSubstatus(substatus);
      checkModel.setOldSubstatus(oldSubstatus);
      checkModel.setStatus(status);
      checkModel.setSerialno(serialno);
      checkModel.setOpdate(opdate);
      checkModel.setOprareaid(oprareaid);
      checkModel.setPoint(point);
      update(checkModel);
    }else if ("delete".equalsIgnoreCase(action)){
      String[] ids = new String[3];
      ids[0] = "1";
      ids[1] = "2";
      ids[2] = "3";
      CheckBean.delete(ids);
    }else if ("findByPK".equalsIgnoreCase(action)){
      CheckModel checkModel = CheckBean.findByPK("1");
      String mdn = checkModel.getMdn();
      String oldMdn = checkModel.getOldMdn();
      String substatus = checkModel.getSubstatus();
      String oldSubstatus = checkModel.getOldSubstatus();
      int status = checkModel.getStatus();
      String serialno = checkModel.getSerialno();
      Timestamp opdate = checkModel.getOpdate();
      String oprareaid = checkModel.getOprareaid();
      String point = checkModel.getPoint();
      System.out.println("mdn = " + mdn);
      System.out.println("oldMdn = " + oldMdn);
      System.out.println("substatus = " + substatus);
      System.out.println("oldSubstatus = " + oldSubstatus);
      System.out.println("status = " + status);
      System.out.println("serialno = " + serialno);
      System.out.println("opdate = " + Function.getYYYYMMDDHHMISS(opdate));
      System.out.println("oprareaid = " + oprareaid);
      System.out.println("point = " + point);
    }else if ("queryBySql".equalsIgnoreCase(action)){
      Collection coll = CheckBean.queryBySql("SELECT * FROM USER_CHECK");
    }else if ("getRowCountBySql".equalsIgnoreCase(action)){
      int rowCount = CheckBean.getRowCountBySql("SELECT COUNT(*) FROM USER_CHECK");
      System.out.println("rowCount = " + rowCount);
    }else if ("queryAll".equalsIgnoreCase(action)){
      Collection coll = CheckBean.queryAll();
      Iterator it = coll.iterator();
      while ( it.hasNext() ) {
        Hashtable element = (Hashtable)it.next();
        String mdn = (String)element.get("mdn");
        String oldMdn = (String)element.get("oldMdn");
        String substatus = (String)element.get("substatus");
        String oldSubstatus = (String)element.get("oldSubstatus");
        String status = (String)element.get("status");
        String serialno = (String)element.get("serialno");
        String opdate = Function.getYYYYMMDDHHMISS((Timestamp)element.get("opdate"));
        String oprareaid = (String)element.get("oprareaid");
        String point = (String)element.get("point");
        System.out.print("mdn = " + mdn + ",\t");
        System.out.print("oldMdn = " + oldMdn + ",\t");
        System.out.print("substatus = " + substatus + ",\t");
        System.out.print("oldSubstatus = " + oldSubstatus + ",\t");
        System.out.print("status = " + status + ",\t");
        System.out.print("serialno = " + serialno + ",\t");
        System.out.print("opdate = " + opdate + ",\t");
        System.out.print("oprareaid = " + oprareaid + ",\t");
        System.out.print("point = " + point + "\n");
      }
    }else if ("getRowCountOfAll".equalsIgnoreCase(action)){
      int rowCount = CheckBean.getRowCountOfAll();
      System.out.println("rowCount = " + rowCount);
    }else if ("getSequenceNextValue".equalsIgnoreCase(action)){
      int sequenceValue = CheckBean.getSequenceNextValue();
      System.out.println("sequenceValue = " + sequenceValue);
    }
  }
}
/*
String mdn = (model==null?"":model.getMdn());
String oldMdn = (model==null?"":model.getOldMdn());
String substatus = (model==null?"":model.getSubstatus());
String oldSubstatus = (model==null?"":model.getOldSubstatus());
int status = (model==null?0:model.getStatus());
String serialno = (model==null?"":model.getSerialno());
Timestamp opdate = (model==null?null:model.getOpdate());
String oprareaid = (model==null?"":model.getOprareaid());
String point = (model==null?"":model.getPoint());
String mdn = PageUtil.parseStringField(request.getParameter("mdn"), "mdn", false, 20);
String oldMdn = PageUtil.parseStringField(request.getParameter("oldMdn"), "oldMdn", false, 20);
String substatus = PageUtil.parseStringField(request.getParameter("substatus"), "substatus", false, 4);
String oldSubstatus = PageUtil.parseStringField(request.getParameter("oldSubstatus"), "oldSubstatus", false, 4);
int status = PageUtil.parseIntField(request.getParameter("status"), "status", false, 0, 4);
String serialno = PageUtil.parseStringField(request.getParameter("serialno"), "serialno", false, 19);
String oprareaid = PageUtil.parseStringField(request.getParameter("oprareaid"), "oprareaid", false, 19);
String point = PageUtil.parseStringField(request.getParameter("point"), "point", false, 19);


String mdn = PageUtil.parseStringField(request.getParameter("mdn"), "mdn", false, 21);
String oldMdn = PageUtil.parseStringField(request.getParameter("oldMdn"), "oldMdn", true, 21);
String substatus = PageUtil.parseStringField(request.getParameter("substatus"), "substatus", false, 5);
String oldSubstatus = PageUtil.parseStringField(request.getParameter("oldSubstatus"), "oldSubstatus", true, 5);
int status = PageUtil.parseIntField(request.getParameter("status"), "status", false, 0, 9);
String serialno = PageUtil.parseStringField(request.getParameter("serialno"), "serialno", false, 20);
Timestamp opdate = PageUtil.parseDateField(request.getParameter("opdate"), "opdate", false);
String oprareaid = PageUtil.parseStringField(request.getParameter("oprareaid"), "oprareaid", true, 20);
String point = PageUtil.parseStringField(request.getParameter("point"), "point", true, 20);
String mdn = (model==null?"":""+model.getMdn());
String oldMdn = (model==null?"":""+model.getOldMdn());
String substatus = (model==null?"":""+model.getSubstatus());
String oldSubstatus = (model==null?"":""+model.getOldSubstatus());
String status = (model==null?"0":""+model.getStatus());
String serialno = (model==null?"":""+model.getSerialno());
Timestamp opdate = (model==null?null:model.getOpdate());
String oprareaid = (model==null?"":""+model.getOprareaid());
String point = (model==null?"":""+model.getPoint());

Collection coll = CheckBean.queryAll((pageNum-1) * pageRow + 1, pageNum * pageRow);
Iterator it = coll.iterator();
while ( it.hasNext() ) {
    Hashtable element = (Hashtable)it.next();
    CheckModel checkModel = CheckBean.toModel(element);
    String mdn = checkModel.getMdn();
    String oldMdn = checkModel.getOldMdn();
    String substatus = checkModel.getSubstatus();
    String oldSubstatus = checkModel.getOldSubstatus();
    int status = checkModel.getStatus();
    String serialno = checkModel.getSerialno();
    Timestamp opdate = checkModel.getOpdate();
    String oprareaid = checkModel.getOprareaid();
    String point = checkModel.getPoint();

        excel.setCellData(new ExcelCell(ExcelUtil.STRING_CELL_TYTE, currRow, currCol++), mdn+"");
        excel.setCellData(new ExcelCell(ExcelUtil.STRING_CELL_TYTE, currRow, currCol++), oldMdn+"");
        excel.setCellData(new ExcelCell(ExcelUtil.STRING_CELL_TYTE, currRow, currCol++), substatus+"");
        excel.setCellData(new ExcelCell(ExcelUtil.STRING_CELL_TYTE, currRow, currCol++), oldSubstatus+"");
        excel.setCellData(new ExcelCell(ExcelUtil.INT_CELL_TYTE,    currRow, currCol++), status+"");
        excel.setCellData(new ExcelCell(ExcelUtil.STRING_CELL_TYTE, currRow, currCol++), serialno+"");
        excel.setCellData(new ExcelCell(ExcelUtil.DATE_CELL_TYTE,   currRow, currCol++), opdate);
        excel.setCellData(new ExcelCell(ExcelUtil.STRING_CELL_TYTE, currRow, currCol++), oprareaid+"");
        excel.setCellData(new ExcelCell(ExcelUtil.STRING_CELL_TYTE, currRow, currCol++), point+"");
*/