Web開発mysqlデータベース操作のページング技術

8043 ワード

前にインタフェースにログインした上で、3つのファイルLogin,Verify,Welome.ログインインタフェース操作データベースプロジェクトコード:クリックしてリンクを開く
次にビッグデータ量処理を検証するためにinsert into users(username,passwd,grade)select username,passwd,grade from users  表を自己複製させるには、表の数を10 w以上にしたほうがいいです.
package com.busymonkey;  
  
import java.io.IOException;  
import java.io.PrintWriter;  
  
import javax.servlet.ServletException;  
import javax.servlet.http.HttpServlet;  
import javax.servlet.http.HttpServletRequest;  
import javax.servlet.http.HttpServletResponse;  
  
/** 
 * Servlet implementation class ServletDemo 
 */  
public class Login extends HttpServlet {  
    private static final long serialVersionUID = 1L;  
         
    public Login() {  
        super();  
    }  
  
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {  
        try {  
            PrintWriter pw = response.getWriter();  
            pw.println("<html>");  
            pw.println("<body>");  
            pw.println("<h1>Login</h1>");  
            pw.println("<form action=verify method=post>");  
            pw.println("UserName:<input type=text name=username><br>");  
            pw.println("PassWord:<input type=password name=passwd><br>");  
            pw.println("<input type=submit value=loging><br>");  
            pw.println("</form>");  
            pw.println("</body>");  
            pw.println("</html>");  
        }  
        catch (Exception ex) {  
            ex.printStackTrace();  
        }  
    }  
  
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {  
        this.doGet(request, response);  
    }  
}
package com.busymonkey;

import javax.servlet.ServletException;
import javax.servlet.http.*;
import java.io.*;
import java.sql.*;

public class Verify extends HttpServlet {
    private static final long serialVersionUID = 1L;
       
    public Verify() {
        super();
    }

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    	Connection ct = null;
    	Statement sm = null;
    	ResultSet rs = null;
    	try {
        	String u=request.getParameter("username");
        	String p=request.getParameter("passwd");
        	
        	//     
        	Class.forName("com.mysql.jdbc.Driver");
        	//    
        	ct = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/db_hou", "root", "123456");
        	//  Statement
        	sm = ct.createStatement();
        	rs = sm.executeQuery("select * from users where username='"+u+"' and passwd='"+p+"'");
        	
        	if (rs.next()) {//next           
        		String dbPasswd = rs.getString("passwd");
        		if (dbPasswd.equals(p)) {
	        		HttpSession hs = request.getSession(true);
	        		hs.setMaxInactiveInterval(20);
	        		hs.setAttribute("pass", "ok");
	        		response.sendRedirect("welcome?uname=" + u + "&upass=" + p); 			
        		}
        		else
        		{
        			response.sendRedirect("login");
        		}
        	}
        	else {
        		response.sendRedirect("login");
        	}
        }
        catch (Exception ex) {
        	ex.printStackTrace();
        }finally{
        	try {
        		if (rs!=null) rs.close();
        		if (sm!=null) sm.close();
        		if (ct!=null) ct.close();
        	}
        	catch (Exception ex) {
        		ex.printStackTrace();
        	}
        }
    }

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

}
package com.busymonkey;

import javax.servlet.ServletException;
import javax.servlet.http.*;
import java.io.*;
import java.sql.*;

public class WelCome extends HttpServlet {
    private static final long serialVersionUID = 1L;
       
    public WelCome() {
        super();
    }

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        Connection ct = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        
    	HttpSession hs = request.getSession(true);
        String val = (String) hs.getAttribute("pass");//       
        if ( val == null )
        {
        	try {
        		response.sendRedirect("login");
        	}
        	catch (Exception ex) {
        		ex.printStackTrace();
        	}
        }
    	String u = request.getParameter("uname");
        String p = request.getParameter("upass");
    	try {
    		//    
    		int pageSize = 3;//    
    		int pageCurrent = 1;//    
    		int rowCount = 0;//   
    		int pageCount = 0;//   
    		PrintWriter pw = response.getWriter();
    		//    pageCurrent
    		String sPageCurrent = request.getParameter("pageCurrent");
    		if (sPageCurrent != null) {
    			pageCurrent = Integer.parseInt(sPageCurrent);
    		}

    		//  rowCount
        	Class.forName("com.mysql.jdbc.Driver");
        	ct = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/db_hou", "root", "123456");
        	ps = ct.prepareStatement("select count(*) from users");
        	rs = ps.executeQuery();
        	if (rs.next()) {
        		rowCount = rs.getInt(1);	
        	}
        	//  pageCount
        	if (rowCount%pageSize == 0) {
        		pageCount = rowCount/pageSize;
        	}
        	else {
        		pageCount = rowCount/pageSize + 1;
        	}
        	
        	ps = ct.prepareStatement("select * from users limit ?,?");
        	// ?  
        	ps.setInt(1, pageSize*(pageCurrent-1));
        	ps.setInt(2, pageSize);
        	rs = ps.executeQuery();
        	
        	pw.println("<body><center>");
        	pw.println("<img src=./imgs/1.GIF ><br>");
        	pw.println("Welcome!!!! " + u + " pass=" + p);
        	//     
        	pw.println("<table border=1>");
        	pw.println("<tr><th>ID</th><th>NAME</th><th>PASSWD</th><th>GRADE</th></tr>");
        	while (rs.next()) {
        		pw.println("<tr>");
        		pw.println("<td>"+rs.getInt("userId")+"</td>");
        		pw.println("<td>"+rs.getString("username")+"</td>");
        		pw.println("<td>"+rs.getString("passwd")+"</td>");
        		pw.println("<td>"+rs.getInt("grade")+"</td>");
        		pw.println("</tr>");
        	}
        	pw.println("</table>");
        	
        	//   
        	if (pageCurrent != 1)
        		pw.println("<a href=welcome?pageCurrent="+(pageCurrent-1)+">Prepage</a>");
        	//     
        	for (int i = pageCurrent; i <= pageCurrent+5; i ++) {
        		pw.println("<a href=welcome?pageCurrent="+i+">"+i+"</a>");
        	}
        	//   
        	if (pageCurrent != pageCount)
        		pw.println("<a href=welcome?pageCurrent="+(pageCurrent+1)+">Nextpage</a>");
        	
        	pw.println("</center></body>");
        }
        catch (Exception ex) {
        	ex.printStackTrace();
        }
    }

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

}