handledatabase.java

jsp+javabean实现的会员管理系统

package myservlet.control;

import java.io.IOException;
import java.sql.*;

import javax.servlet.RequestDispatcher;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.*;

import mybean.data.Login;
import mybean.data.MemberInform;
import mybean.data.ShowByPage;

import com.sun.rowset.*;

public class HandleDatabase extends HttpServlet {

	CachedRowSetImpl rowSet = null;

	public void init(ServletConfig config) throws ServletException {
		super.init(config);
		try {
			Class.forName("com.mysql.jdbc.Driver");
		} catch (Exception e) {
		}
	}

	protected void doPost(HttpServletRequest request,
			HttpServletResponse response) throws ServletException, IOException {
		HttpSession session = request.getSession(true);
		Login login = (Login) session.getAttribute("login");
		boolean ok = true;
		if (login == null) {
			ok = false;
			response.sendRedirect("login.jsp");
		}
		if (ok == true) {
			continueDoPost(request, response);
		}
	}

	private void continueDoPost(HttpServletRequest request,
			HttpServletResponse response) throws ServletException, IOException {
		HttpSession session = request.getSession(true);
		Connection con = null;
		StringBuffer presentPageResult = new StringBuffer();
		ShowByPage showBean = null;
		try {
			showBean = (ShowByPage) session.getAttribute("show");
			if (showBean == null) {
				showBean = new ShowByPage();
				session.setAttribute("show", showBean);
			}
		} catch (Exception exp) {
			showBean = new ShowByPage();
			session.setAttribute("show", showBean);
		}
		showBean.setPageSize(3);
		int showPage = Integer.parseInt(request.getParameter("showPage"));
		if (showPage > showBean.getPageAllCount()) {
			showPage = 1;
		}
		if (showPage <= 0) {
			showPage = showBean.getPageAllCount();
		}
		showBean.setShowPage(showPage);
		int pageSize = showBean.getPageSize();
		String uri = "jdbc:mysql://localhost:3306/ComeHere";
		try {
			con = DriverManager.getConnection(uri, "root", "wsy5201314");
			Statement sql = con
					.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
							ResultSet.CONCUR_READ_ONLY);
			ResultSet rs = sql.executeQuery("SELECT * FROM member");
			rowSet = new CachedRowSetImpl();
			rowSet.populate(rs);
			con.close();
			showBean.setRowSet(rowSet);
			rowSet.last();
			int m = rowSet.getRow();
			int n = pageSize;
			int pageAllCount = ((m % n) == 0) ? (m / n) : (m / n + 1);
			showBean.setPageAllCount(pageAllCount);
			presentPageResult = show(showPage, pageSize, rowSet);
			showBean.setPresentPageResult(presentPageResult);
		} catch (SQLException exp) {
		}
		RequestDispatcher dispatcher = request
				.getRequestDispatcher("/showAllMember.jsp");
		dispatcher.forward(request, response);
	}

	public StringBuffer show(int page, int pageSize, CachedRowSetImpl rowSet) {
		StringBuffer str = new StringBuffer();
		try {
			rowSet.absolute((page - 1) * pageSize + 1);
			for (int i = 1; i <= pageSize; i++) {
				str.append("<tr>");
				str.append("<td>" + rowSet.getString(1) + "</td>");
				str.append("<td>" + rowSet.getString(3) + "</td>");
				str.append("<td>" + rowSet.getString(4) + "</td>");
				str.append("<td>" + rowSet.getString(5) + "</td>");
				str.append("<td>" + rowSet.getString(6) + "</td>");
				str.append("<td>" + rowSet.getString(7) + "</td>");
				String s = "<img src=image/" + rowSet.getString(8)
						+ " width=100 height=100/>";
				str.append("<td>" + s + "</td>");
				str.append("</tr>");
				rowSet.next();
			}
		} catch (SQLException exp) {
		}
		return str;
	}

	public void doGet(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {
		HttpSession session = request.getSession(true);
		Login login = (Login) session.getAttribute("login"); // 获取用户登录时的Javabean
		boolean ok = true;
		if (login == null) {
			ok = false;
			response.sendRedirect("login.jsp"); // 重定向到登录页面
		}
		if (ok == true) {
			continueDoGet(request, response);
		}
	}

	public void continueDoGet(HttpServletRequest request,
			HttpServletResponse response) throws ServletException, IOException {
		MemberInform inform = new MemberInform();
		request.setAttribute("inform", inform);
		String logname = request.getParameter("logname");
		Connection con = null;
		String uri = "jdbc:mysql://localhost:3306/ComeHere";
		try {
			con = DriverManager.getConnection(uri, "root", "wsy5201314");
			Statement sql = con.createStatement();
			ResultSet rs = sql
					.executeQuery("SELECT * FROM member where logname = '"
							+ logname + "'");
			if (rs.next()) {
				inform.setLogname(rs.getString(1));
				inform.setSex(rs.getString(3));
				inform.setAge(rs.getString(4));
				inform.setPhone(rs.getString(5));
				inform.setEmail(rs.getString(6));
				inform.setMessage(rs.getString(7));
				inform.setPic(rs.getString(8));
				inform.setBackNews("查询到的会员信息：");
			}
			con.close();
			RequestDispatcher dispatcher = request
					.getRequestDispatcher("/showLookedMember.jsp");
			dispatcher.forward(request, response);
		} catch (SQLException exp) {
			inform.setBackNews("" + exp);
			System.out.println("ok1" + exp);
		}
	}

}