servlet中如何操作数据库

先下载 mysql-connector-java-5.1.38-bin.jar ，然后把 mysql-connector-java-5.1.38-bin.jar 放到 tomcat 的 lib 目录下，再进行以下操作：

1.  加载驱动程序

Class.forName("com.mysql.jdbc.Driver");

2.  创建数据库url

String url = "jdbc:mysql://localhost:3307/spdb?useSSL=false";

String user = "root";

password = "root";

3.  建立连接

con = DriverManager.getConnection(url,user,password);

4.  创建statement

sta = con.createStatement();

5.  创建查询语句

rs = sta.executeQuery("select passwd from users where username='"+username+"'limit 1");

注意SQL的注入漏洞！

---

案例代码：

//接收用户名和密码
String username;
String password;
Connection con = null;
Statement sta = null;
ResultSet rs = null;
        
try {
    username = request.getParameter("username");
    String passwd = request.getParameter("password");
        
    //加载驱动程序
    Class.forName("com.mysql.jdbc.Driver");
            
    //创建数据库url
    String url = "jdbc:mysql://localhost:3307/spdb?useSSL=false";
    String user = "root";
    password = "root";
            
    //建立连接
    con = DriverManager.getConnection(url,user,password);
            
    //创建statement
    sta = con.createStatement();
            
    rs = sta.executeQuery("select passwd from users where username='"+username+"'limit 1");
            
    if(rs.next()){
        //说明用户存在
        String dbPasswd = rs.getString(1);
        if(dbPasswd.equals(passwd)){
            //合法
            //将用户信息存入session
            HttpSession hs = request.getSession(true);
            hs.setMaxInactiveInterval(60);
            hs.setAttribute("name", username);
                    
            //跳到下一个页面【servlet提供了两种：sendredirect转向，forward转发】
            //sendredirect 的 url 应该这样：/web应用名/servlet url
            response.sendRedirect("/UsersManager/MainFrame?username=" + username + "&password=" + password);
        }else{
            //跳回登录页面
            response.sendRedirect("/UsersManager/LoginServlet");
        }
    }else{
        //跳回登录页面
        response.sendRedirect("/UsersManager/LoginServlet");
    }
            
} catch (ClassNotFoundException e) {
    e.printStackTrace();
} catch (SQLException e) {
    e.printStackTrace();
} finally{
    try {
        if(null != rs){
            rs.close();
        }
        if(null != sta){
            sta.close();
        }
        if(null != con){
            con.close();
        }
    } catch (SQLException e) {
        e.printStackTrace();
            }
}