如何用JSP servlet完成一个简单的登录页面连接mysql数

第四步：success.jsp

Java code

<%@ page language="java" contentType="text/html; charset=ISO-8859-1"
    pageEncoding="ISO-8859-1"%>







    ${address }

    ${port }

     

第五步：loginServlet.java

Java code

package com.servlet;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.sql.SQLException;
 
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 com.dao.Dao;
 
public class loginServlet extends HttpServlet {
    public void destroy() {
        super.destroy(); // Just puts "destroy" string in log
 
        // Put your code here
 
    }
 
    public void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        request.setCharacterEncoding("utf-8");
        response.setContentType("text/html");
        PrintWriter out = response.getWriter();
        String name = new String(request.getParameter("user").getBytes(
                "ISO8859_1"), "GBK");
        String pwd = new String(request.getParameter("pwd").getBytes(
                "ISO8859_1"), "UTF-8");
        User user = new User();
        user.setUser(name);
        user.setPwd(pwd);
        Dao dao = new Dao();
        boolean isLogin;
        try {
            isLogin = dao.logoin(user);
 
            if (isLogin) {
                InetAddress inetAddress = InetAddress.getLocalHost();
                String m = inetAddress.getHostAddress();
                int n = request.getRemotePort();
                System.out.println(m+"*********"+ n);
                HttpSession session = request.getSession(); 
                session.setAttribute("address", m);
                session.setAttribute("port", n);
                response.sendRedirect("success.jsp");
            } else {
                response.sendRedirect("index.jsp");
            }
 
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
 
    public void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        doPost(request, response);
    }
 
    public void init() throws ServletException {
    }
 
}

Java code

package com.servlet;
 
public class User {
    private String user;
    private String pwd;
    private String name;
 
    private int age;
 
    public String getUser() {
        return user;
    }
 
    public void setUser(String user) {
        this.user = user;
    }
 
    public String getPwd() {
        return pwd;
    }
 
    public void setPwd(String pwd) {
        this.pwd = pwd;
    }
 
    public String getName() {
        return name;
    }
 
    public void setName(String name) {
        this.name = name;
    }
 
    public int getAge() {
        return age;
    }
 
    public void setAge(int age) {
        this.age = age;
    }
}

Java code?

package com.util;
 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
 
public class GetConnection {
    //通过静态方法注册驱动，获得连接
 
    public static Connection getConnection(){
       String driver = "com.mysql.jdbc.Driver";
       String url = "jdbc:mysql://localhost/student";
       Connection con = null;
       try {
        Class.forName(driver);
        try {
         con = DriverManager.getConnection(url,"root","123456");
        } catch (SQLException e) {
         e.printStackTrace();
        }
       } catch (ClassNotFoundException e) {
        e.printStackTrace();
       }
       System.out.println("已获得数据库的连接");
       return con;
    }
    /*public static void main(String args[]){
       getConnection();
    }*/
    }

Java code?

package com.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
 
import com.servlet.User;
import com.util.GetConnection;
 
public class Dao {
    private Connection conn;
    private PreparedStatement pstat;
    String sql = "";
 
    /**
     *
     * 用户登录
     */
    public boolean logoin(User user) throws SQLException {
        conn = GetConnection.getConnection();
        boolean i = false;
        sql = "select * from user where user=? and pwd=?";
 
        pstat = conn.prepareStatement(sql);
 
        pstat.setString(1, user.getUser());
        pstat.setString(2, user.getPwd());
 
        ResultSet rs1 = (ResultSet) pstat.executeQuery();
        if (rs1.next()) {
            i = true;
            rs1.close();
            pstat.close();
        } else {
            i = false;
            rs1.close();
            pstat.close();
        }
        conn.close();
        return i;
    }
 
    /**
     * 用户注册
     */
    public void addUser(User user) {
        conn = GetConnection.getConnection();
        sql = "insert into user values(?,?,?,?)";
        try {
            pstat = conn.prepareStatement(sql);
            pstat.setString(1, user.getUser());
            pstat.setString(2, user.getPwd());
            pstat.setString(3, user.getName());
 
            pstat.setInt(5, user.getAge());
            pstat.executeUpdate();
            pstat.close();
            conn.close();
 
        } catch (SQLException e) {
            e.printStackTrace();
        }
 
    }
}

注意事项：1.数据库用户密码；2.访问地址。