relationdetailbo.java

bs_客户关系管理系统 每个例子文件夹都附有数据库表、程序源文件和一个war包（或者jar包）。如果是cs结构的

package bo;

import java.util.List;
import java.util.ArrayList;
import myjdbc.DatabaseOperation;
import vo.WbRelationDetail;
import java.util.*;
import struts.actionform.RelationListForm;
import java.io.UnsupportedEncodingException;

public class RelationDetailBo {
  private static RelationDetailBo rbo = null;
  private static DatabaseOperation db = null;
  private RelationDetailBo() {
    db = DatabaseOperation.getInstance();
  }
  public static RelationDetailBo getInstance()
  {
    if (rbo == null)
      rbo = new RelationDetailBo();
    return rbo;
  }
  public void getPageableRelationDetailList(RelationListForm form)
  {
    List result = new ArrayList();
    String sql = "select relation_sn,name,status,relation_time,link_man from Wb_RelationDetail";
    List rs = db.executeSQLSeperatePage(sql,null,form.getPageSize(),form.getCurr());
    //只有第一次时，才需要设置totalPage。以后是在各个页面传递totalPage的值
    if (form.getTotalPage() == -1)
     {
       int totalPage = db.getTotalPage(sql,null,form.getPageSize());
       form.setTotalPage(totalPage);
     }
    for (Iterator iter = rs.iterator(); iter.hasNext(); ) {
      Object[]  obs = (Object[]) iter.next();
      WbRelationDetail temp = new WbRelationDetail();
      temp.setRelationSn((String)obs[0]);
      temp.setName((String)obs[1]);
      temp.setStatus((String)obs[2]);
      temp.setRelationTime(((java.util.Date)obs[3]).toString());
      temp.setLinkMan((String)obs[4]);
      result.add(temp);
    }
//    prt(result);
    form.setRelationDetailCol(result);
  }
  public String saveNewRelation(RelationListForm form)
  {
    try {
      WbRelationDetail temp = form.getWbRelationDetail();
      StringBuffer sql = new StringBuffer();
      sql.append("INSERT INTO Wb_RelationDetail (relation_sn, name, type, status, relation_time, link_address, link_man, telephone,zip_code, email, hobby, note) ");
      sql.append("VALUES('").append(temp.getRelationSn()).append("', ");
      sql.append("'").append(convertEncoding(temp.getName())).append("', ");
      sql.append("'").append(convertEncoding(temp.getType())).append("', ");
      sql.append("'").append(convertEncoding(temp.getStatus())).append("', ");
      sql.append("'").append(convertEncoding(temp.getRelationTime())).append("', ");
      sql.append("'").append(convertEncoding(temp.getLinkAddress())).append("', ");
      sql.append("'").append(convertEncoding(temp.getLinkMan())).append("', ");
      sql.append("'").append(temp.getTelephone()).append("', ");
      sql.append("'").append(temp.getZipCode()).append("', ");
      sql.append("'").append(temp.getEmail()).append("', ");
      sql.append("'").append(convertEncoding(temp.getHobby())).append("', ");
      sql.append("'").append(convertEncoding(temp.getNote())).append("' ");
      sql.append(")");
      System.out.println("sql = " + sql.toString());
      db.executeSQL(sql.toString());
      return "保存成功！";
    }catch(Exception e) {
      e.printStackTrace();
      return "保存失败！";
    }

  }

  public String saveModifyRelation(RelationListForm form) {
    try {
    WbRelationDetail temp = form.getWbRelationDetail();
    String sn = temp.getRelationSn();
    StringBuffer sql = new StringBuffer();
    sql.append("UPDATE Wb_RelationDetail ");
    sql.append("SET name = ").append("'").append(convertEncoding(temp.getName())).append("', ");
    sql.append("type = ").append("'").append(convertEncoding(temp.getType())).append("', ");
    sql.append("status = ").append("'").append(convertEncoding(temp.getStatus())).append("', ");
    sql.append("relation_time = ").append("'").append(convertEncoding(temp.getRelationTime())).append("', ");
    sql.append("link_address = ").append("'").append(convertEncoding(temp.getLinkAddress())).append("', ");
    sql.append("link_man = ").append("'").append(convertEncoding(temp.getLinkMan())).append("', ");
    sql.append("telephone = ").append("'").append(convertEncoding(temp.getTelephone())).append("', ");
    sql.append("zip_code = ").append("'").append(temp.getZipCode()).append("', ");
    sql.append("email = ").append("'").append(temp.getEmail()).append("', ");
    sql.append("hobby = ").append("'").append(convertEncoding(temp.getHobby())).append("', ");
    sql.append("note = ").append("'").append(convertEncoding(temp.getNote())).append("' ");
    sql.append("WHERE relation_sn = '").append(sn).append("' ");
    db.executeSQL(sql.toString());
    return "修改成功！";
    }catch(Exception e){
      e.printStackTrace();
      return "修改失败！";
    }

  }
  public void getRelationBySn(RelationListForm form) throws Exception{
    String sn = form.getRelationSn();
    String sql = "select * from Wb_RelationDetail where relation_sn ='"+sn+"' ";
    System.out.println("sn = " + sn +",and sql = " + sql);
    List rs = db.executeSQL(sql);
    if (rs.size()> 1)
      throw new Exception("主键重复，请检查数据库表Wb_RelationDetail中已有的记录！");
    form.setWbRelationDetail((WbRelationDetail)rs.get(0));
  }
  public String deleteRelationBySn(RelationListForm form)
  {
    try {
      String sn = form.getRelationSn();
      String sql = "delete from Wb_RelationDetail where relation_sn = '" + sn +
          "' ";
      db.executeSQL(sql);
      return "删除成功！";
    }catch(Exception e) {
      e.printStackTrace();
      return "删除失败！";
    }
  }

//  private void prt(List list)
//  {
//    for (Iterator iter = list.iterator(); iter.hasNext(); ) {
//      WbRelationDetail item = (WbRelationDetail) iter.next();
//      System.out.println("relation sn = " + item.getRelationSn() +" , and relation name = "+ item.getName());
//    }
//  }

  private static String convertEncoding(String old)
 {
   try
   {
     return new String(old.getBytes("ISO8859-1"));
   }catch(UnsupportedEncodingException e)
   {
     e.printStackTrace();
     return "编码转化出错！";
   }
 }

}