channeldao.java

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

    String sql = "";
    if (Database.dbType == DBType.ORACLE) {
      sql = "INSERT INTO WAP_CHANNEL (ID, CP_ID, CHANNEL_NAME, CHANNEL_DESCRIBE, CHANNEL_URL, CHANNEL_ACCESS, CHANNEL_SUBSCRIBE, CHANNEL_STATUS, CHANNEL_REGDATE, CHANNEL_TYPE, CHANNEL_APPEAR, CHANNEL_TRADE, CHANNEL_FREE, CHANNEL_TEST, CHANNEL_CODE, SEND_MOBILE, CHANNEL_REMARK) VALUES ("
          + model.getId() + ", "
          + model.getCpId() + ", '"
          + Function.writeDBEncode(model.getChannelName()) + "', '"
          + Function.writeDBEncode(model.getChannelDescribe()) + "', '"
          + Function.writeDBEncode(model.getChannelUrl()) + "', "
          + model.getChannelAccess() + ", "
          + model.getChannelSubscribe() + ", "
          + model.getChannelStatus() + ", TO_DATE('"
          + Function.DateToString(model.getChannelRegdate()) + "', 'YYYY/MM/DD HH24:MI:SS'), "
          + model.getChannelType() + ", "
          + model.getChannelAppear() + ", "
          + model.getChannelTrade() + ", "
          + model.getChannelFree() + ", "
          + model.getChannelTest() + ", '"
          + Function.writeDBEncode(model.getChannelCode()) + "', "
          + model.getSendMobile() + ", '"
          + Function.writeDBEncode(model.getChannelRemark()) + "')";
    } else if (Database.dbType == DBType.SQLSERVER) {
      sql = "INSERT INTO WAP_CHANNEL (ID, CP_ID, CHANNEL_NAME, CHANNEL_DESCRIBE, CHANNEL_URL, CHANNEL_ACCESS, CHANNEL_SUBSCRIBE, CHANNEL_STATUS, CHANNEL_REGDATE, CHANNEL_TYPE, CHANNEL_APPEAR, CHANNEL_TRADE, CHANNEL_FREE, CHANNEL_TEST, CHANNEL_CODE, SEND_MOBILE, CHANNEL_REMARK) VALUES ("
          + model.getId() + ", "
          + model.getCpId() + ", '"
          + Function.writeDBEncode(model.getChannelName()) + "', '"
          + Function.writeDBEncode(model.getChannelDescribe()) + "', '"
          + Function.writeDBEncode(model.getChannelUrl()) + "', "
          + model.getChannelAccess() + ", "
          + model.getChannelSubscribe() + ", "
          + model.getChannelStatus() + ", '"
          + Function.DateToString(model.getChannelRegdate()) + "', "
          + model.getChannelType() + ", "
          + model.getChannelAppear() + ", "
          + model.getChannelTrade() + ", "
          + model.getChannelFree() + ", "
          + model.getChannelTest() + ", '"
          + Function.writeDBEncode(model.getChannelCode()) + "', "
          + model.getSendMobile() + ", '"
          + Function.writeDBEncode(model.getChannelRemark()) + "')";
    } else if (Database.dbType == DBType.MYSQL) {
      sql = "INSERT INTO WAP_CHANNEL (ID, CP_ID, CHANNEL_NAME, CHANNEL_DESCRIBE, CHANNEL_URL, CHANNEL_ACCESS, CHANNEL_SUBSCRIBE, CHANNEL_STATUS, CHANNEL_REGDATE, CHANNEL_TYPE, CHANNEL_APPEAR, CHANNEL_TRADE, CHANNEL_FREE, CHANNEL_TEST, CHANNEL_CODE, SEND_MOBILE, CHANNEL_REMARK) VALUES ("
          + model.getId() + ", "
          + model.getCpId() + ", '"
          + Function.writeDBEncode(model.getChannelName()) + "', '"
          + Function.writeDBEncode(model.getChannelDescribe()) + "', '"
          + Function.writeDBEncode(model.getChannelUrl()) + "', "
          + model.getChannelAccess() + ", "
          + model.getChannelSubscribe() + ", "
          + model.getChannelStatus() + ", '"
          + Function.DateToString(model.getChannelRegdate()) + "', "
          + model.getChannelType() + ", "
          + model.getChannelAppear() + ", "
          + model.getChannelTrade() + ", "
          + model.getChannelFree() + ", "
          + model.getChannelTest() + ", '"
          + Function.writeDBEncode(model.getChannelCode()) + "', "
          + model.getSendMobile() + ", '"
          + Function.writeDBEncode(model.getChannelRemark()) + "')";
    }
    return sql;
  }
  protected static String getUpdateSQL(ChannelModel model) {
    String sql = "";
    if (Database.dbType == DBType.ORACLE) {
      sql = "UPDATE WAP_CHANNEL SET CP_ID = "
          + model.getCpId() + ", CHANNEL_NAME = '"
          + Function.writeDBEncode(model.getChannelName()) + "', CHANNEL_DESCRIBE = '"
          + Function.writeDBEncode(model.getChannelDescribe()) + "', CHANNEL_URL = '"
          + Function.writeDBEncode(model.getChannelUrl()) + "', CHANNEL_ACCESS = "
          + model.getChannelAccess() + ", CHANNEL_SUBSCRIBE = "
          + model.getChannelSubscribe() + ", CHANNEL_STATUS = "
          + model.getChannelStatus() + ", CHANNEL_REGDATE = TO_DATE('"
          + Function.DateToString(model.getChannelRegdate()) + "', 'YYYY-MM-DD HH24:MI:SS'), CHANNEL_TYPE = "
          + model.getChannelType() + ", CHANNEL_APPEAR = "
          + model.getChannelAppear() + ", CHANNEL_TRADE = "
          + model.getChannelTrade() + ", CHANNEL_FREE = "
          + model.getChannelFree() + ", CHANNEL_TEST = "
          + model.getChannelTest() + ", CHANNEL_CODE = '"
          + Function.writeDBEncode(model.getChannelCode()) + "', SEND_MOBILE = "
          + model.getSendMobile() + ", CHANNEL_REMARK = '"
          + Function.writeDBEncode(model.getChannelRemark()) + "' WHERE ID = " + model.getId();
    } else if (Database.dbType == DBType.SQLSERVER) {
      sql = "UPDATE WAP_CHANNEL SET CP_ID = "
          + model.getCpId() + ", CHANNEL_NAME = '"
          + Function.writeDBEncode(model.getChannelName()) + "', CHANNEL_DESCRIBE = '"
          + Function.writeDBEncode(model.getChannelDescribe()) + "', CHANNEL_URL = '"
          + Function.writeDBEncode(model.getChannelUrl()) + "', CHANNEL_ACCESS = "
          + model.getChannelAccess() + ", CHANNEL_SUBSCRIBE = "
          + model.getChannelSubscribe() + ", CHANNEL_STATUS = "
          + model.getChannelStatus() + ", CHANNEL_REGDATE = '"
          + Function.DateToString(model.getChannelRegdate()) + "', CHANNEL_TYPE = "
          + model.getChannelType() + ", CHANNEL_APPEAR = "
          + model.getChannelAppear() + ", CHANNEL_TRADE = "
          + model.getChannelTrade() + ", CHANNEL_FREE = "
          + model.getChannelFree() + ", CHANNEL_TEST = "
          + model.getChannelTest() + ", CHANNEL_CODE = '"
          + Function.writeDBEncode(model.getChannelCode()) + "', SEND_MOBILE = "
          + model.getSendMobile() + ", CHANNEL_REMARK = '"
          + Function.writeDBEncode(model.getChannelRemark()) + "' WHERE ID = " + model.getId();
    } else if (Database.dbType == DBType.MYSQL) {
      sql = "UPDATE WAP_CHANNEL SET CP_ID = "
          + model.getCpId() + ", CHANNEL_NAME = '"
          + Function.writeDBEncode(model.getChannelName()) + "', CHANNEL_DESCRIBE = '"
          + Function.writeDBEncode(model.getChannelDescribe()) + "', CHANNEL_URL = '"
          + Function.writeDBEncode(model.getChannelUrl()) + "', CHANNEL_ACCESS = "
          + model.getChannelAccess() + ", CHANNEL_SUBSCRIBE = "
          + model.getChannelSubscribe() + ", CHANNEL_STATUS = "
          + model.getChannelStatus() + ", CHANNEL_REGDATE = '"
          + Function.DateToString(model.getChannelRegdate()) + "', CHANNEL_TYPE = "
          + model.getChannelType() + ", CHANNEL_APPEAR = "
          + model.getChannelAppear() + ", CHANNEL_TRADE = "
          + model.getChannelTrade() + ", CHANNEL_FREE = "
          + model.getChannelFree() + ", CHANNEL_TEST = "
          + model.getChannelTest() + ", CHANNEL_CODE = '"
          + Function.writeDBEncode(model.getChannelCode()) + "', SEND_MOBILE = "
          + model.getSendMobile() + ", CHANNEL_REMARK = '"
          + Function.writeDBEncode(model.getChannelRemark()) + "' WHERE ID = " + model.getId();
    }
    return sql;
  }
  protected static String getDeleteSQL(int id) {
    String sql = "";
    if (Database.dbType == DBType.ORACLE) {
      sql = "DELETE FROM WAP_CHANNEL WHERE ID = " + id;
    } else if (Database.dbType == DBType.SQLSERVER) {
      sql = "DELETE FROM WAP_CHANNEL WHERE ID = " + id;
    } else if (Database.dbType == DBType.MYSQL) {
      sql = "DELETE FROM WAP_CHANNEL WHERE ID = " + id;
    }
    return sql;
  }
  protected static String getDeleteSQL(int[] ids) {
    String sql = "";
    if (Database.dbType == DBType.ORACLE) {
      sql = "DELETE FROM WAP_CHANNEL WHERE 1 = 2";
      for ( int i = 0; i < ids.length; i++ ) {
        sql += " OR ID = " + ids[i];
      }
    } else if (Database.dbType == DBType.SQLSERVER) {
      sql = "DELETE FROM WAP_CHANNEL WHERE 1 = 2";
      for ( int i = 0; i < ids.length; i++ ) {
        sql += " OR ID = " + ids[i];
      }
    } else if (Database.dbType == DBType.MYSQL) {
      sql = "DELETE FROM WAP_CHANNEL WHERE 1 = 2";
      for ( int i = 0; i < ids.length; i++ ) {
        sql += " OR ID = " + ids[i];
      }
    }
    return sql;
  }
  protected static String getFindByPKSQL(int id) {
    String sql = "";
    if (Database.dbType == DBType.ORACLE) {
      sql = "SELECT * FROM WAP_CHANNEL WHERE ID = " + id;
    } else if (Database.dbType == DBType.SQLSERVER) {
      sql = "SELECT * FROM WAP_CHANNEL WHERE ID = " + id;
    } else if (Database.dbType == DBType.MYSQL) {
      sql = "SELECT * FROM WAP_CHANNEL WHERE ID = " + id;
    }
    return sql;
  }
  protected static boolean isValidData(ChannelModel 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)) {
      ChannelModel model=new ChannelModel();
      model.setId(ChannelBean.getSequenceNextValue());
      model.setCpId(1);
      model.setChannelName("abc");
      model.setChannelDescribe("abc");
      model.setChannelUrl("abc");
      model.setChannelAccess(1);
      model.setChannelSubscribe(1);
      model.setChannelStatus(1);
      model.setChannelRegdate(Function.getCurrTime());
      model.setChannelType(1);
      model.setChannelAppear(1);
      model.setChannelTrade(1);
      model.setChannelFree(1);
      model.setChannelTest(1);
      model.setChannelCode("abc");
      model.setSendMobile(1);
      model.setChannelRemark("abc");
      ChannelModel channelModel = ChannelBean.insert(model);
    }else if ("update".equalsIgnoreCase(action)){
      ChannelModel channelModel = ChannelBean.findByPK(1);
      int id = channelModel.getId();
      int cpId = channelModel.getCpId();
      String channelName = channelModel.getChannelName();
      String channelDescribe = channelModel.getChannelDescribe();
      String channelUrl = channelModel.getChannelUrl();
      int channelAccess = channelModel.getChannelAccess();
      int channelSubscribe = channelModel.getChannelSubscribe();
      int channelStatus = channelModel.getChannelStatus();
      Timestamp channelRegdate = channelModel.getChannelRegdate();