booktermbean.java

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

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

public class BookTermBean extends BookTermDao{
  public static BookTermModel newTerm(String userMdn,String termName,String termAttr,int regType)throws SysException,UpdateException,AppException{
    BookTermModel bookterm = new BookTermModel();
    bookterm.setId(getSequenceNextValue());
    bookterm.setTermName(termName);
    bookterm.setUserMdn(userMdn);
    bookterm.setTermAttr(termAttr);
    bookterm.setRegDate(new Timestamp(System.currentTimeMillis()));
    bookterm.setRegType(regType);
    return insert(bookterm);
  }
  public static Collection getTermByUserMdn(String userMdn)throws SysException{
    String sql = "SELECT * FROM WAP_BOOK_TERM WHERE USER_MDN = '" +userMdn + "' ORDER BY ID DESC";
    return queryBySql(sql);
  }
  public static boolean deleteTerm(int id,String userMdn)throws SysException{
 boolean flag = false;
 Connection conn = null;
 try {
 conn = Database.getConnection();
 conn.setAutoCommit(false);
 String sql = "UPDATE WAP_BOOK_TERM_USER SET TERM_ID = (SELECT ID FROM WAP_BOOK_TERM WHERE USER_MDN = '" + userMdn + "' AND TERM_ATTR = 0) WHERE TERM_ID =" + id;
 updateBySql(sql);
 sql = "DELETE FROM WAP_BOOK_TERM WHERE ID = " + id;
 updateBySql(sql);
 conn.commit();
 flag = true;
 }catch (SysException e) {
 e.printStackTrace();
 try {conn.rollback();} catch (Exception ex) {}
 } catch (SQLException e) {
 e.printStackTrace();
 try {conn.rollback();} catch (Exception ex) {}
 throw new SysException("SQLException while execute subscribe");
 } finally {
 try {conn.setAutoCommit(true);} catch (Exception ex) {}
 try {conn.close();} catch (Exception ex) {}
 }
  return flag;
 }
}