createtopicservlet.java

简易的BBS,可以进行排行榜的查询,发布意见,建立一个新的主题

package com.bbs.servlets;

import javax.servlet.*;
import javax.servlet.http.*;
import java.io.*;
import java.util.*;
import org.springframework.jdbc.core.JdbcTemplate;
import com.bbs.connect.DatabaseConnect;
import javax.sql.DataSource;
import com.bbs.po.BBSCritiqueBean;
import java.text.SimpleDateFormat;

public class CreateTopicServlet
    extends HttpServlet {
  private static final String CONTENT_TYPE = "text/html; charset=GBK";
  org.apache.commons.logging.Log log = org.apache.commons.logging.LogFactory.getLog(this.getClass());
  public int curPage = 0; //当前的页值。
  public int maxPage=0; //最大的页数。
  public int maxRowCount=0; //最大的行数。
  public static int rowsPerPage = 20; //控制分页的行数。
  public List list = null;
  public List TaxisResult = null;
  //Initialize global variables
  public void init() throws ServletException {
  }

  //Process the HTTP Get request
  public void doGet(HttpServletRequest request, HttpServletResponse response) throws
      ServletException, IOException {
    response.setContentType(CONTENT_TYPE);
    doPost(request,response);
  }

  //Process the HTTP Post request
  public void doPost(HttpServletRequest request, HttpServletResponse response) throws
      ServletException, IOException {
    //request.setCharacterEncoding(CONTENT_TYPE);
    response.setContentType(CONTENT_TYPE);
    //request.setCharacterEncoding("GBK");
    try
    {

      String topicname =new String(request.getParameter("topname").getBytes("ISO8859-1"),"GBK");//request.getParameter("topname");
      String username =request.getParameter("accounts");
      request.getSession(true).setAttribute("accounts", username);
      String sql = "";
      DatabaseConnect dbc = new DatabaseConnect();
      Date datetime = new Date();
      SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      String issuancetime = sdf.format(datetime);
      sql = "select topicName from dbo.topic where topicName='"+topicname+"'";
      DataSource ds2 = dbc.DatabaseConnect();
      JdbcTemplate jt2 = new JdbcTemplate(ds2);
      List judge=jt2.queryForList(sql);
      sql="";
      if (judge.size()<=0)
      {
        sql =
            "insert into dbo.topic (topicName,topicAuthor,issuanceTime)values('"
            + topicname + "','" + username + "','" + issuancetime + "')";
        DataSource ds1 = dbc.DatabaseConnect();
        JdbcTemplate jt1 = new JdbcTemplate(ds1);
        jt1.execute(sql);
      }else
      {
        request.getRequestDispatcher("/BBSAlert.jsp?accounts="+request.getParameter("accounts")).forward(request, response);
        return;
      }
      /*
      sql="";
      sql = "select a.topicName,count(distinct b.critiquePerson) Number "
          +"from  topic a left join  bbstable b  on  a.topicname =b.topicname  "
          + "group by a.topicName order by Number";

      DataSource ds = dbc.DatabaseConnect();
      JdbcTemplate jt = new JdbcTemplate(ds);
      List list = jt.queryForList(sql);
      //System.out.println("creagte:^^^^"+list.size());
      sql="";
      //初始化maxRowCount、maxPage
      if (list == null) list = new ArrayList();
      maxRowCount = list.size();
      if (maxRowCount % rowsPerPage == 0) {
        maxPage = maxRowCount / rowsPerPage;
      }
      else {
        maxPage = maxRowCount / rowsPerPage + 1;
      }
      List taxisdatalist = new ArrayList(); //排序后的数据集
      List backresult = new ArrayList(); //返回页面数据
      List backmaxpage = new ArrayList(); //返回页面数据
      List backcurpage = new ArrayList(); //返回当前页
      request.getSession(true).setAttribute("maxPage", maxPage);
      taxisdatalist = list;

      if (request.getParameter("px") != null) {
        if (request.getParameter("px").equals("fee_income")) {
          Comparator comp = new Mycomparator();
          Collections.sort(taxisdatalist, comp);
        }
        if (request.getParameter("px").equals("fee_income_rate")) {
          Comparator comp = new FeeIncomeRate();
          Collections.sort(taxisdatalist, comp);
        }
        if (request.getParameter("px").equals("into_ratio")) {
          Comparator comp = new IntoRatio();
          Collections.sort(taxisdatalist, comp);
        }
      }
      if (request.getParameter("page") != null) {
        curPage = Integer.parseInt(request.getParameter("page"));
      }
      if ((curPage == 0||curPage==1) && taxisdatalist != null) {
        for (int i = 0; i < rowsPerPage; i++) {
          if (taxisdatalist.size()==(i+1)||taxisdatalist.size()==0)
          break;
          if (taxisdatalist.get(i) != null)
          backresult.add(taxisdatalist.get(i));
        }
        curPage = 1;
        backcurpage.add(String.valueOf(curPage));
        request.getSession(true).setAttribute("curpage", curPage);
      }
      if (curPage > 1 && taxisdatalist != null) {
        for (int i = 0; i < rowsPerPage; i++) {
          if (taxisdatalist.size()==((curPage-1) * rowsPerPage + i))
          break;
            if (taxisdatalist.get((curPage-1) * rowsPerPage + i) != null)
            backresult.add(taxisdatalist.get((curPage-1) * rowsPerPage + i));
        }
        if (request.getParameter("page")!=null)
        {
          curPage = Integer.parseInt(request.getParameter("page"));
        }
        request.getSession(true).setAttribute("curpage", curPage);

      }

      if (backresult!=null)
      {
        List pagecontent = new ArrayList();
        pagecontent= backresult;
        request.getSession(true).setAttribute("backresult",backresult);
        request.setAttribute("backresult", backresult);
      }*/
      request.getRequestDispatcher("/topicshow.jsp?accounts="+request.getParameter("accounts")).forward(request, response);
    }catch(Exception e)
    {
      e.printStackTrace();
    }

  }

  //Clean up resources
  public void destroy() {
  }
}