selectservlet.java

用Servlet做的一个小项目。用Servlet做的一个小项目。用Servlet做的一个小项目。用Servlet做的一个小项目。用Servlet做的一个小项目。

package controller;

import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import model.AddressBookBean;
import model.UserBean;
import model.dao.BaseDao;

/**
 * 分类查找联系人
 */
public class SelectServlet extends HttpServlet {

	// 定义连接对象
	Connection con = null;
	// 定义预处理对象
	PreparedStatement pstmt = null;
	// 定义结果集对象
	ResultSet rs = null;
	// 定义AddressBookBean实体类对象
	AddressBookBean bookBean = null;
	// 定义List接口对象并实例化List接口的实现类ArrayList()
	List list = new ArrayList();

	public void doGet(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {
		// 定义session对象
		HttpSession session = request.getSession(false);
		// 取出user中的数据赋给实体类对象
		UserBean user = (UserBean) session.getAttribute("user");
		// 接收页面传参
		String relation = request.getParameter("relation");

		// 定义SQL语句
		String sql = "select * from BOOK where userId=? and relation=?";
		try {
			// 得到连接
			con = BaseDao.getCon();
			// 预处理SQL语句
			pstmt = con.prepareStatement(sql);
			// 给占位符赋值
			pstmt.setInt(1, user.getUserId());
			pstmt.setString(2, relation);
			// 执行命令
			rs = pstmt.executeQuery();
			// 存在的话循环赋值并添加到list
			while (rs.next()) {
				bookBean = new AddressBookBean();
				bookBean.setId(rs.getInt("id"));
				bookBean.setName(rs.getString("name"));
				bookBean.setSex(rs.getString("sex"));
				bookBean.setPhone(rs.getString("phone"));
				bookBean.setMobilePhone(rs.getString("mobilePhone"));
				list.add(bookBean);
			}
			// 存入session
			session.setAttribute("list", list);
			// 重定向到show.jsp
			response.sendRedirect("show.jsp");
		} catch (SQLException ex) {
			// 异常处理
			ex.printStackTrace();
		} finally {
			// 关闭连接
			BaseDao.CloseAll(con, pstmt, rs);
		}
	}

	public void doPost(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {
		this.doGet(request, response);
	}

}