编程语言
首页 > 编程语言> > JavaWeb网上书城项目

JavaWeb网上书城项目

作者:互联网

一、需求分析

用JSP/Servlet技术开发一个网上书店,主要完成以下功能:

用户:注册与登录,用户信息的修改

图书:图书显示,图书的购买,购物车的管理。图书的添加,删除,查询

二、系统设计

1)创建相关的数据库表;

2)使用MVC架构或者JSP+JavaBean,至少一个功能模块使用MVC;

3)在JSP中综合使用EL 表达式,JSTL标记库,JavaBean ;

4)使用过滤器完成请求参数编码的设置或登录权限的控制;

5)正确完成Servlet和过滤器的配置

6)使用数据库连接池进行数据库连

三、程序流程图

四、各功能实现代码

4.1管理员功能实现

4.1.1管理员类

4.1.2管理员类dao接口

4.1.3管理员类dao接口的实现方法(操作数据库)

package bean;

import utils.JDBCUtil;

import java.sql.*;

public  class adminDaoImpl implements adminDao{

    public void addadmin(admin a) {
        //连接数据库
        Connection conn = null;
        PreparedStatement psql=null;
        ResultSet rs=null;
        try {
            conn = JDBCUtil.getConnection();
            String sql = "insert into admin value (?,?)";
            conn = JDBCUtil.getConnection();
            psql=conn.prepareStatement(sql);
            psql.setString(1,a.getName());
            psql.setString(2,a.getPassword());
            int i = psql.executeUpdate();
            if(i>0){
                System.out.println("插入成功!");
            }else {
                System.out.println("插入失败!");
            }
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(psql, conn);
        }
    }

    public admin queryadmin(String username) {

        //连接数据库
        Connection conn = null;
        Statement statement=null;
        ResultSet rs=null;
        admin a=new admin();

        try {
            conn = JDBCUtil.getConnection();
            statement = conn.createStatement();
            String sql = "select * from admin where name ='" + username + "'";
            rs=statement.executeQuery(sql);
            while(rs.next()){

                a.setName(rs.getString("name"));
                a.setPassword(rs.getString("password"));
            }
            rs.close();
            conn.close();
            return a;
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(statement, conn);
        }
        return a;
    }
}

4.1.4管理员登录页面

4.1.5管理员注册页面

4.1.5管理员登录的service方法

import bean.UserDaoImpl;
import bean.adminDao;
import bean.adminDaoImpl;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import java.io.IOException;
import java.io.PrintWriter;

@WebServlet(name = "adminLoginServlet",urlPatterns = "/adminLoginServlet")
public class adminLoginServlet extends HttpServlet {
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

        //设置编码和响应类型
        response.setContentType("text/html");
        response.setCharacterEncoding("utf-8");
        request.setCharacterEncoding("utf-8");
        HttpSession session =request.getSession(true);
        //         1.获得用户名和密码
        //       2.验证用户名和密码是否正确 "zhou" "123456"
        String adminname=request.getParameter("adminName");
        String password=request.getParameter("adminPasswd");
        //获得响应的输出流
        PrintWriter pw=response.getWriter();
        adminDao dao = new adminDaoImpl();
        String name=dao.queryadmin(adminname).getName();
        String passwd=dao.queryadmin(adminname).getPassword();
        if(adminname.equals(name)&&password.equals(passwd)){
            session.setAttribute("admin",name);
            request.getRequestDispatcher("/adminnavcation.jsp").forward(request,response);
        }else {
            //验证失败
            pw.println("<font color='green'><h2>登录失败</h2></font>");
        }
    }

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

管理员注册的方法

import utils.JDBCUtil;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

@WebServlet(name = "adminRegistServlet",urlPatterns = "/adminRegistServlet")
public class adminRegistServlet extends HttpServlet {
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        request.setCharacterEncoding("utf-8");
        response.setContentType("html/text;charset=utf-8");
        //1.获取数据
        String name = request.getParameter("name");
        String password = request.getParameter("password");
        //2.判断用户名不能为空
        if (name==null||"".equals(name)){
            System.out.println("用户名不能为空!");
            String s = "用户名不能为空";
            response.getWriter().write(s);
        }
        //连接数据库,插入数据
        Connection conn = null;
        PreparedStatement psta = null;
        String sql = "insert into admin value (?,?)";

        try {
            conn = JDBCUtil.getConnection();
            psta = conn.prepareStatement(sql);
            psta.setString(1,name);
            psta.setString(2,password);
            psta.execute();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(psta,conn);
        }
        response.sendRedirect("adminlogin.html");
    }

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

4.1.6管理员登陆后的显示的主界面

4.1.7管理员添加商品的方法

import utils.JDBCUtil;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

@WebServlet(name = "adminaddbooksServlet",urlPatterns = "/adminaddbooksServlet")
public class adminaddbooksServlet extends HttpServlet {
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        request.setCharacterEncoding("utf-8");
        response.setContentType("html/text;charset=utf-8");
        //1.获取数据
        String name = request.getParameter("name");
        String writer = request.getParameter("writer");
        String type=request.getParameter("type");
        String id=request.getParameter("id");
        int number= Integer.parseInt(request.getParameter("number"));
        int price= Integer.parseInt(request.getParameter("price"));
        //2.判断用户名不能为空
        /*if (name==null||"".equals(name)&&writer==null||"".equals(writer)&&type==null||"".equals(type)&&id==null||"".equals(id)&&number==0||"".equals(price)&&writer==null||"".equals(price)){
            String s = "书籍信息要写完整";
            response.getWriter().write(s);
            response.sendRedirect("addbooks.html");
        }*/
        //连接数据库,插入数据
        Connection conn = null;
        PreparedStatement psta = null;
        String sql = "insert into book value (?,?,?,?,?,?)";

        try {
            conn = JDBCUtil.getConnection();
            psta = conn.prepareStatement(sql);
            psta.setString(1,name);
            psta.setString(2,writer);
            psta.setString(3,type);
            psta.setString(4,id);
            psta.setInt(5,number);
            psta.setInt(6,price);
            psta.execute();
            /*int i = psta.executeUpdate(sql);
            if(i>0){
                //request.getRequestDispatcher("adminlogin.html").forward(request,response);
                response.sendRedirect("adminnavcation.jsp");
            }else {
                System.out.println("插入失败!");
            }*/
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(psta,conn);
        }
        response.sendRedirect("adminnavcation.jsp");
    }

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

4.1.7 管理员删除商品的方法

<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<%@taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
<%@page isELIgnored="false"  %>
<%@ page import="java.util.List" %>
<%@ page import="bean.*" %>
<%@ page import="java.io.PrintWriter" %>
<html>
<head>
    <title>管理员删除图书页面</title>
</head>
<body>
<%
    //获取得到传递过来的id
    String id = request.getParameter("bid");
    BookDao dao=new BookDao();
    dao.deletebook(id);
    response.sendRedirect("adminnavcation.jsp");
%>
</body>
</html>

4.1.8管理员修改图书单价的方法

<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<%@taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
<%@page isELIgnored="false"  %>
<%@ page import="java.util.List" %>
<%@ page import="bean.*" %>
<%@ page import="java.io.PrintWriter" %>
<html>
<head>
    <title>修改图书单价页面</title>

</head>
<body>
<%
    request.setCharacterEncoding("utf-8");
    response.setCharacterEncoding("utf-8");
    //获取得到传递过来的id
    String bookname=request.getParameter("name");
    int price= Integer.parseInt(request.getParameter("price"));
    BookDao dao=new BookDao();
    dao.updateprice(bookname,price);
    response.sendRedirect("adminnavcation.jsp");
%>
</body>
</html>

4.1.9管理员修改图书库存的方法

<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<%@taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
<%@page isELIgnored="false"  %>
<%@ page import="java.util.List" %>
<%@ page import="bean.*" %>
<%@ page import="java.io.PrintWriter" %>
<html>
<head>
    <title>修改图书数量页面</title>
</head>
<body>
<%
    request.setCharacterEncoding("utf-8");
    response.setCharacterEncoding("utf-8");
    //获取得到传递过来的id
    String bookname=request.getParameter("name");
    int number= Integer.parseInt(request.getParameter("number"));
    BookDao dao=new BookDao();
    dao.updatenumber(bookname,number);
    response.sendRedirect("adminnavcation.jsp");
%>
</body>
</html>

4.1.10管理员查看所有用户订单的方法

<%@ page import="java.util.List" %>
<%@ page import="bean.*" %>
<%@ page import="bean.ShoppingCar" %>
<%@ page import="java.util.ArrayList" %><%--
  Created by IntelliJ IDEA.
  User: Lenovo
  Date: 2019/11/17
  Time: 16:39
  To change this template use File | Settings | File Templates.
--%>
<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<%@taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
<html>
<head>
    <title>管理员查看订单</title>
</head>
<link rel="stylesheet" type="text/css" href="showallbooks.css">
<body style="margin: 0 auto; padding: 0; background-repeat: no-repeat">
<%

    ShoppingcarDao dao=new ShoppingcarDaoImpl();
    List<ShoppingCar> clist=dao.Queryallorderlist();
    pageContext.setAttribute("clist",clist);

%>
<c:if test="${empty(clist)}">
    <h1>暂无订单!</h1>
</c:if>

<%--如果购物车有购物项,就应该把购物项的信息显示给用户--%>
<c:if test="${!empty(clist)}">
<table id="tb">

     <tr>
     <td>买家</td>

     <td>书籍编号</td>

     <td>书名</td>

     <td>单价</td>

     <td>数量</td>

     <td>小计</td>

     </tr>

     <c:forEach var="clist" items="${clist}" varStatus="status">

     <tr>
     <td>${clist.username}</td>

     <td>${clist.bookid}</td>

     <td>${clist.bookname}</td>

     <td>${clist.bookprice}</td>

    <td>${clist.booknumber}</td>

    <td>${clist.littleprice}</td>
    </tr>
     </c:forEach>
    </c:if>
</table>
</body>
</html>

4.2用户功能实现

4.2.1用户类

4.2.2用户类dao接口

4.2.3用户类dao接口的实现方法(操作数据库)

package bean;

import utils.JDBCUtil;

import java.sql.*;

public class UserDaoImpl implements UserDao {

    @Override
    public void adduser(User u) {
        //连接数据库
        Connection conn = null;
        PreparedStatement psql=null;
        ResultSet rs=null;
        try {
            conn = JDBCUtil.getConnection();
            String sql = "insert into user value (?,?,?)";
            conn = JDBCUtil.getConnection();
            psql=conn.prepareStatement(sql);
            psql.setString(1,u.getName());
            psql.setString(2,u.getPassword());
            psql.setString(3,u.getAddr());
            int i = psql.executeUpdate();
            if(i>0){
                System.out.println("插入成功!");
            }else {
                System.out.println("插入失败!");
            }
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(psql, conn);
        }
    }

    @Override
    public User queryuser(String username) {

        //连接数据库
        Connection conn = null;
        Statement statement=null;
        ResultSet rs=null;
        User u=new User();

        try {
            conn = JDBCUtil.getConnection();
            statement = conn.createStatement();
            String sql = "select * from user where name ='" + username + "'";
            rs=statement.executeQuery(sql);
            while(rs.next()){

                u.setName(rs.getString("name"));
                u.setPassword(rs.getString("password"));
            }
            rs.close();
            conn.close();
            return u;
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(statement, conn);
        }
        return u;
    }
    public void updatepassword(String name,String password){
        Connection conn = null;
        PreparedStatement psql=null;
        ResultSet rs=null;
        try {
            conn = JDBCUtil.getConnection();
            psql=conn.prepareStatement("update user set password=? where name='" + name + "'");
            psql.setString(1,password);
            psql.execute();
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(psql, conn);
        }
    }

    public void updateaddr(String name,String addr){
        Connection conn = null;
        PreparedStatement psql=null;
        ResultSet rs=null;
        try {
            conn = JDBCUtil.getConnection();
            psql=conn.prepareStatement("update user set atm.user.address=? where name='" + name + "'");
            psql.setString(1,addr);
            psql.execute();
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(psql, conn);
        }
    }
}

4.2.4用户登录页面

4.2.5用户登录的service方法

import bean.User;
import bean.UserDaoImpl;

import javax.servlet.http.HttpSession;
import java.io.IOException;
import java.io.PrintWriter;

@javax.servlet.annotation.WebServlet(name = "loginServlet",urlPatterns="/loginServlet")
public class loginServlet extends javax.servlet.http.HttpServlet {

    protected void doPost(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) throws javax.servlet.ServletException, IOException {

        //设置编码和响应类型
        response.setContentType("text/html");
        response.setCharacterEncoding("utf-8");
        request.setCharacterEncoding("utf-8");
        HttpSession session =request.getSession(true);
        //         1.获得用户名和密码
        //       2.验证用户名和密码是否正确 "zhou" "123456"
        String username=request.getParameter("userName");
        String password=request.getParameter("userPasswd");
        //获得响应的输出流
        PrintWriter pw=response.getWriter();
        UserDaoImpl dao =new UserDaoImpl();
        String name=dao.queryuser(username).getName();
        String passwd=dao.queryuser(username).getPassword();
        if(username.equals(name)&&password.equals(passwd)){
            session.setAttribute("user",username);
            request.getRequestDispatcher("/books.jsp").forward(request,response);
        }else {
            //验证失败
            pw.println("<font color='green'><h2>登录失败</h2></font>");
        }
    }

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

4.2.5 用户注册实现的service方法

import utils.JDBCUtil;
import java.sql.PreparedStatement;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
@WebServlet(name = "RegistServlet",urlPatterns = "/RegistServlet")
public class RegistServlet extends HttpServlet {

    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        request.setCharacterEncoding("utf-8");
        response.setContentType("html/text;charset=utf-8");
        //1.获取数据
        String name = request.getParameter("name");
        String password = request.getParameter("password");
        String addr = request.getParameter("addr");

        //2.判断用户名不能为空
        if (name==null||"".equals(name)){
            System.out.println("用户名不能为空!");
            String s = "用户名不能为空";
            response.getWriter().write(s);
        }
        //连接数据库,插入数据
        Connection conn = null;
        PreparedStatement psta = null;
        String sql = "insert into user value (?,?,?)";

        try {
            conn = JDBCUtil.getConnection();
            psta = conn.prepareStatement(sql);
            psta.setString(1,name);
            psta.setString(2,password);
            psta.setString(3,addr);
            int i = psta.executeUpdate();
            if(i>0){
                response.sendRedirect("userlogin.html");
            }else {
                System.out.println("插入失败!");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(psta,conn);
        }
    }

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

4.2.6用户登陆后的显示的主界面

4.2.7用户修改密码的方法

4.2.8用户修改收货地址的方法

4.2.9用户把图书加入购物车的方法

4.2.10用户把图书从购物车中删除的方法

4.2.11用户购物车结算的方法

4.2.12用户查看本用户订单的方法

4.3购物车类

4.3.1购物车类

4.3.2购物车类dao接口

4.3.3购物车类dao接口的实现方法(操作数据库)

package bean;

import utils.JDBCUtil;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;

public class ShoppingcarDaoImpl implements ShoppingcarDao{

    public void DeleteBook(String id){
        //连接数据库
        Connection conn = null;
        Statement statement=null;
        ResultSet rs=null;
        try {
            conn = JDBCUtil.getConnection();
            statement = conn.createStatement();
            String sql = "delete  from shoppingcar where bookid="+id;
            statement.executeUpdate(sql);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(statement, conn);
        }
    }
    public Book querybook(String id){
        //连接数据库
        Connection conn = null;
        Statement statement=null;
        ResultSet rs=null;
        Book b=new Book();
        try {
            conn = JDBCUtil.getConnection();
            statement = conn.createStatement();
            String sql = "select * from atm.book where bID="+id;
            rs=statement.executeQuery(sql);
            while(rs.next()){

                ShoppingCar s=new ShoppingCar();
                b.setName(rs.getString(1));
                b.setAuthor(rs.getString(2));
                b.setType(rs.getString(3));
                b.setId(rs.getString(4));
                b.setNumber(rs.getInt(5));
                b.setPrice(rs.getInt(6));
            }
            rs.close();
            conn.close();
            return b;
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(statement, conn);
        }
        return b;
    }
    public void inserts(Book b,String username,int number){
        //连接数据库
        Connection conn = null;
        PreparedStatement psql=null;
        ResultSet rs=null;
        try {
            conn = JDBCUtil.getConnection();
            psql= conn.prepareStatement("insert shoppingcar(username, bookid, bookname, bookprice, booknumber)"+"values(?,?,?,?,?)");
            psql.setString(1,username);
            psql.setString(2, b.getId());
            psql.setString(3, b.getName());
            psql.setInt(4,b.getPrice());
            psql.setInt(5,number);
            psql.execute();
            conn.close();
        }
        catch (SQLException e){
            e.printStackTrace();
        }finally {
            JDBCUtil.close(psql, conn);
        }
    }
    public void update(Book b,String username,int number){
        //连接数据库
        Connection conn = null;
        PreparedStatement psql=null;
        ResultSet rs=null;
        List<ShoppingCar> list=new ArrayList<ShoppingCar>();
        try {
            conn = JDBCUtil.getConnection();
            psql= conn.prepareStatement("update shoppingcar set booknumber = ? where bookid=? and username in (select username from user where username='" + username + "')");
            //psql= conn.prepareStatement("update shoppingcar set booknumber = ? where bookid=?");
            //psql= conn.prepareStatement("update shoppingcar set booknumber = ? where (bookid=? and username='\" + username + \"')");
            //psql= conn.prepareStatement("update shoppingcar set booknumber = ? where bookid=? and username='\" + username + \"'");
            //psql= conn.prepareStatement("update shoppingcar set username,bookid,bookname,bookprice,booknumber=? where username=?");
            psql.setInt(1,number);
            psql.setString(2,b.getId());
            psql.execute();
            conn.close();
            } catch (SQLException e){
            e.printStackTrace();
        }finally {
            JDBCUtil.close(psql, conn);
        }
    }

    public ShoppingCar Queryone1(String username, String id) {
        //连接数据库
        Connection conn = null;
        Statement statement=null;
        ResultSet rs=null;
        ShoppingCar s=new ShoppingCar();
        try {
            conn = JDBCUtil.getConnection();
            statement = conn.createStatement();
            String sql = "select * from shoppingcar where  bookid="+id+" and username in (select username from  shoppingcar where username='" + username + "')";
            rs=statement.executeQuery(sql);
            {
                while(rs.next()){
                    s.setUsername(rs.getString(1));
                    s.setBookid(rs.getString(2));
                    s.setBookname(rs.getString(3));
                    s.setBookprice(rs.getInt(4));
                    s.setBooknumber(rs.getInt(5));
                }
            }
            rs.close();
            conn.close();
            return s;
        } catch (SQLException e){
            e.printStackTrace();
        }
        finally {
            JDBCUtil.close(statement, conn);
        }
        return s;
    }
    public int Queryone(String username, String id){
        //连接数据库
        Connection conn = null;
        Statement statement=null;
        ResultSet rs=null;
        int number=1;
        try {
            conn = JDBCUtil.getConnection();
            statement = conn.createStatement();
            String sql = "select * from shoppingcar where  username='" + username + "'" ;
            rs=statement.executeQuery(sql);
            {
                while(rs.next()){
                    if(rs.getString(2).equals(id))
                    number+=(rs.getInt(5));
                }
            }
            rs.close();
            conn.close();
        } catch (SQLException e){
            e.printStackTrace();
        }
        finally {
            JDBCUtil.close(statement, conn);
        }
        return number;
    }

    public int Queryone2(String username, String id){
        //连接数据库
        Connection conn = null;
        Statement statement=null;
        ResultSet rs=null;
        int number=0;
        try {
            conn = JDBCUtil.getConnection();
            statement = conn.createStatement();
            String sql = "select * from shoppingcar where  username='" + username + "'" ;
            rs=statement.executeQuery(sql);
            {
                while(rs.next()){
                    if(rs.getString(2).equals(id))
                        number=(rs.getInt(5));
                }
            }
            rs.close();
            conn.close();
        } catch (SQLException e){
            e.printStackTrace();
        }
        finally {
            JDBCUtil.close(statement, conn);
        }
        return number;
    }
    public List<ShoppingCar> Queryall(String username){
        //连接数据库
        Connection conn = null;
        Statement statement=null;
        ResultSet rs=null;
        List<ShoppingCar> list=new ArrayList<ShoppingCar>();
        try {
            conn = JDBCUtil.getConnection();
            statement = conn.createStatement();
            String sql = "select * from shoppingcar where username='" + username + "'";
            rs=statement.executeQuery(sql);
            while(rs.next()){
                ShoppingCar s=new ShoppingCar();
                s.setUsername(rs.getString(1));
                s.setBookid(rs.getString(2));
                s.setBookname(rs.getString(3));
                s.setBookprice(rs.getInt(4));
                s.setBooknumber(rs.getInt(5));
                list.add(s);
            }
            rs.close();
            conn.close();
            return list;
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(statement, conn);
        }
        return list;
    }

    public List<ShoppingCar> Queryallorderlist(){
        //连接数据库
        Connection conn = null;
        Statement statement=null;
        ResultSet rs=null;
        List<ShoppingCar> list=new ArrayList<ShoppingCar>();
        try {
            conn = JDBCUtil.getConnection();
            statement = conn.createStatement();
            String sql = "select * from orderlist";
            rs=statement.executeQuery(sql);
            while(rs.next()){
                ShoppingCar s=new ShoppingCar();
                s.setUsername(rs.getString(1));

                System.out.println(s.getUsername());//调试

                s.setBookid(rs.getString(2));
                s.setBookname(rs.getString(3));
                s.setBookprice(rs.getDouble(4));
                s.setBooknumber(rs.getInt(5));
                list.add(s);
            }
            rs.close();
            conn.close();
            return list;
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtil.close(statement, conn);
        }
        return list;
    }
    public void updatenumber(String id,int number){
        //连接数据库
        Connection conn = null;
        PreparedStatement psql=null;
        ResultSet rs=null;
        try {
            conn = JDBCUtil.getConnection();
            psql= conn.prepareStatement("update book set bNumber = ? where bID=?");
            psql.setInt(1,number);
            psql.setString(2,id);
            psql.execute();
            conn.close();
        } catch (SQLException e){
            e.printStackTrace();
        }
        finally {
            JDBCUtil.close(psql, conn);
        }
    }
    public void drop(String username){
        //连接数据库
        Connection conn = null;
        PreparedStatement psql=null;
        ResultSet rs=null;
        try {
            conn = JDBCUtil.getConnection();
            psql= conn.prepareStatement("delete from shoppingcar where username=?");
            psql.setString(1,username);
            psql.execute();
            conn.close();
        } catch (SQLException e){
            e.printStackTrace();
        }        finally {
            JDBCUtil.close(psql, conn);
        }
    }
    //单个结算后把记录写入订单表
    public void orderlist1(ShoppingCar s){
        //连接数据库
        Connection conn = null;
        PreparedStatement psql=null;
        ResultSet rs=null;
        try {
            conn = JDBCUtil.getConnection();
            psql= conn.prepareStatement("insert orderlist(customer, bookId, bookName, bookPrice, bookNumber)"+"values(?,?,?,?,?)");
                psql.setString(1,s.getUsername());
                psql.setString(2, s.getBookid());
                psql.setString(3, s.getBookname());
                psql.setDouble(4,s.getBookprice());
                psql.setInt(5,s.getBooknumber());
                psql.execute();
            conn.close();
        } catch (SQLException e){
            e.printStackTrace();
        }finally {
            JDBCUtil.close(psql, conn);
        }
    }
    //结算后把购物车记录写入订单表
    public void orderlist(List<ShoppingCar> list){
        //连接数据库
        Connection conn = null;
        PreparedStatement psql=null;
        ResultSet rs=null;
        try {
            conn = JDBCUtil.getConnection();
            psql= conn.prepareStatement("insert orderlist(customer, bookId, bookName, bookPrice, bookNumber)"+"values(?,?,?,?,?)");
            for(ShoppingCar s:list){
                psql.setString(1,s.getUsername());
                psql.setString(2, s.getBookid());
                psql.setString(3, s.getBookname());
                psql.setDouble(4,s.getBookprice());
                psql.setInt(5,s.getBooknumber());
                psql.execute();
            }
            conn.close();
        } catch (SQLException e){
            e.printStackTrace();
        }finally {
            JDBCUtil.close(psql, conn);
        }
    }
   public List<ShoppingCar> showuserorderlist(String username){
       //连接数据库
       Connection conn = null;
       Statement statement=null;
       ResultSet rs=null;
       List<ShoppingCar> list=new ArrayList<ShoppingCar>();
       try {
           conn = JDBCUtil.getConnection();
           statement = conn.createStatement();
           String sql = "select * from orderlist where customer='" + username + "'";
           rs=statement.executeQuery(sql);
           while(rs.next()){
               ShoppingCar s=new ShoppingCar();
               s.setBookid(rs.getString(2));
               s.setBookname(rs.getString(3));
               s.setBookprice(rs.getInt(4));
               s.setBooknumber(rs.getInt(5));
               list.add(s);
           }
           rs.close();
           conn.close();
           return list;
       } catch (SQLException e) {
           e.printStackTrace();
       }finally {
           JDBCUtil.close(statement, conn);
       }
       return list;
   }

    public void deleteonebook(String username,String id){
        //连接数据库
        Connection conn = null;
        PreparedStatement psql=null;
        ResultSet rs=null;
        try {
            conn = JDBCUtil.getConnection();
            psql= conn.prepareStatement("delete from shoppingcar where username=? and bookid in (select bookid from shoppingcar where bookid=?)");
            psql.setString(1,username);
            psql.setString(2,id);
            psql.execute();
            conn.close();
        } catch (SQLException e){
            e.printStackTrace();
        }        finally {
            JDBCUtil.close(psql, conn);
        }
    }
}

4.3.4购物车显示页面

 

5.3图书类及方法

5.3.1图书类

5.3.2图书类dao实现方法

5.3.3显示所有图书的方法

JDBCUtil工具类

package utils;
import javax.sql.DataSource;
import java.sql.*;
import bean.User;
import com.alibaba.druid.pool.DruidDataSourceFactory;

import java.util.Properties;
public class JDBCUtil {
    private  static DataSource ds ;
    //加载配置文件,创建数据库连接池
    static{

        try {
            Properties pro = new Properties();
            pro.load(JDBCUtil.class.getClassLoader().getResourceAsStream("druid.properties"));
            ds = DruidDataSourceFactory.createDataSource(pro);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    //获取连接池对象
    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }
    //释放资源
    public static void close(Statement sttm, Connection conn, ResultSet rs){
        if(sttm!=null){
            try {
                sttm.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(conn!=null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(rs!=null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void close(Statement sttm, Connection conn){
        close(sttm,conn,null);
    }
    public static DataSource getDs(){
        return ds;
    }

}

sql文件

/*
Navicat MySQL Data Transfer

Source Server         : DESKTOP-7UO4BFR
Source Server Version : 50725
Source Host           : localhost:3306
Source Database       : atm

Target Server Type    : MYSQL
Target Server Version : 50725
File Encoding         : 65001

Date: 2020-12-09 13:34:02
*/

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for `account`
-- ----------------------------
DROP TABLE IF EXISTS `account`;
CREATE TABLE `account` (
  `UserID` varchar(20) NOT NULL,
  `UserName` varchar(15) DEFAULT NULL,
  `money` int(11) DEFAULT NULL,
  PRIMARY KEY (`UserID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- ----------------------------
-- Records of account
-- ----------------------------
INSERT INTO `account` VALUES ('1815925066', '周文豪', '1400');
INSERT INTO `account` VALUES ('1815925067', '闫守建', '1400');

-- ----------------------------
-- Table structure for `admin`
-- ----------------------------
DROP TABLE IF EXISTS `admin`;
CREATE TABLE `admin` (
  `name` varchar(20) NOT NULL,
  `password` varchar(20) DEFAULT NULL,
  PRIMARY KEY (`name`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- ----------------------------
-- Records of admin
-- ----------------------------
INSERT INTO `admin` VALUES ('俞敏洪', '123456');
INSERT INTO `admin` VALUES ('李嘉诚', '123456');
INSERT INTO `admin` VALUES ('王健林', '123456');
INSERT INTO `admin` VALUES ('马云', '123456');

-- ----------------------------
-- Table structure for `book`
-- ----------------------------
DROP TABLE IF EXISTS `book`;
CREATE TABLE `book` (
  `bName` varchar(20) NOT NULL,
  `bWtiter` varchar(15) DEFAULT NULL,
  `bType` varchar(15) DEFAULT NULL,
  `bID` varchar(15) DEFAULT NULL,
  `bNumber` int(11) DEFAULT NULL,
  `bPrice` int(11) DEFAULT NULL,
  PRIMARY KEY (`bName`),
  KEY `bID` (`bID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- ----------------------------
-- Records of book
-- ----------------------------
INSERT INTO `book` VALUES ('三体', '刘慈欣', '科幻小说', '004', '29', '55');
INSERT INTO `book` VALUES ('三国演义', '罗贯中', '四大名著', '001', '21', '35');
INSERT INTO `book` VALUES ('假面山庄', '东野圭吾', '外国小说', '005', '25', '88');
INSERT INTO `book` VALUES ('昆虫记', '法布尔', '文学', '033', '40', '40');
INSERT INTO `book` VALUES ('比索寓言', '比索', '寓言故事', '008', '2', '20');
INSERT INTO `book` VALUES ('活着', '余华', '现实主义小说', '006', '6', '36');
INSERT INTO `book` VALUES ('西游记', '吴承恩', '四大名著', '002', '23', '30');
INSERT INTO `book` VALUES ('钢铁是怎样炼成的', '尼古拉·奥斯特洛夫斯基', '外国名著', '003', '34', '56');

-- ----------------------------
-- Table structure for `orderlist`
-- ----------------------------
DROP TABLE IF EXISTS `orderlist`;
CREATE TABLE `orderlist` (
  `customer` varchar(20) DEFAULT NULL,
  `bookID` varchar(20) DEFAULT NULL,
  `bookName` varchar(20) DEFAULT NULL,
  `bookPrice` double(20,0) DEFAULT NULL,
  `bookNumber` int(20) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- ----------------------------
-- Records of orderlist
-- ----------------------------
INSERT INTO `orderlist` VALUES ('Tom', '003', '钢铁是怎样炼成的', '56', '1');
INSERT INTO `orderlist` VALUES ('Tom', '004', '三体', '55', '1');
INSERT INTO `orderlist` VALUES ('Tom', '005', '假面山庄', '88', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '005', '假面山庄', '88', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '005', '假面山庄', '88', '3');
INSERT INTO `orderlist` VALUES ('周文豪', '006', '活着', '36', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '003', '钢铁是怎样炼成的', '56', '2');
INSERT INTO `orderlist` VALUES ('周文豪', '001', '三国演义', '35', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '004', '三体', '55', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '004', '三体', '55', '1');
INSERT INTO `orderlist` VALUES ('张世强', '004', '三体', '55', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '004', '三体', '55', '1');
INSERT INTO `orderlist` VALUES ('张世强', '001', '三国演义', '35', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '004', '三体', '55', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '001', '三国演义', '35', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '006', '活着', '36', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '004', '三体', '55', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '006', '活着', '36', '1');
INSERT INTO `orderlist` VALUES ('周文豪', '002', '西游记', '30', '2');
INSERT INTO `orderlist` VALUES ('闫守建', '007', '安徒生童话', '15', '1');
INSERT INTO `orderlist` VALUES ('闫守建', '004', '三体', '55', '1');
INSERT INTO `orderlist` VALUES ('闫守建', '003', '钢铁是怎样炼成的', '56', '1');

-- ----------------------------
-- Table structure for `shoppingcar`
-- ----------------------------
DROP TABLE IF EXISTS `shoppingcar`;
CREATE TABLE `shoppingcar` (
  `username` varchar(20) DEFAULT NULL,
  `bookid` varchar(20) DEFAULT NULL,
  `bookname` varchar(20) DEFAULT NULL,
  `bookprice` int(20) DEFAULT NULL,
  `booknumber` int(20) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- ----------------------------
-- Records of shoppingcar
-- ----------------------------

-- ----------------------------
-- Table structure for `user`
-- ----------------------------
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
  `name` varchar(15) NOT NULL,
  `password` varchar(20) DEFAULT NULL,
  `address` varchar(30) DEFAULT NULL,
  PRIMARY KEY (`name`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- ----------------------------
-- Records of user
-- ----------------------------
INSERT INTO `user` VALUES ('CATs', '123456', '奥术大师大奥所');
INSERT INTO `user` VALUES ('James', '123456', '奥术大师大奥所');
INSERT INTO `user` VALUES ('Tom', '123456', '南洋理工学院12号公寓205');
INSERT INTO `user` VALUES ('zhou', '123456', '南阳理工学院12#201');
INSERT INTO `user` VALUES ('侯明明', '123456', '南阳理工学院12#201');
INSERT INTO `user` VALUES ('周五', '123456', '是的撒多所多所多所多所多、');
INSERT INTO `user` VALUES ('周文豪', '123456', '南阳理工学院');
INSERT INTO `user` VALUES ('张世强', '123456', '南洋理工学院12号公寓201');
INSERT INTO `user` VALUES ('曹瑾', '123456', '南阳理工学院12#215');
INSERT INTO `user` VALUES ('朱命豪', '666666', '南阳理工学院');
INSERT INTO `user` VALUES ('王康', '123456', '河南大学');
INSERT INTO `user` VALUES ('米军臣', '123456', '南阳理工学院12#212');
INSERT INTO `user` VALUES ('胡广涛', '123456', '南阳理工学院12#218');
INSERT INTO `user` VALUES ('薛之谦', '123456', '南阳理工学院12#215');
INSERT INTO `user` VALUES ('邝凯兴', '123456', '南阳理工学院12#331');
INSERT INTO `user` VALUES ('闫守建', '123456', '南洋理工学院12号公寓201');
INSERT INTO `user` VALUES ('靳凌霄', '123456', '南阳理工学院12#201');

-- ----------------------------
-- Table structure for `user2`
-- ----------------------------
DROP TABLE IF EXISTS `user2`;
CREATE TABLE `user2` (
  `id` varchar(11) NOT NULL,
  `name` varchar(20) DEFAULT NULL,
  `password` varchar(20) DEFAULT NULL,
  `address` varchar(20) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- ----------------------------
-- Records of user2
-- ----------------------------
INSERT INTO `user2` VALUES ('1815925061', 'sdsdssdsd', '123456', '南阳理工');
INSERT INTO `user2` VALUES ('1815925066', '周文豪', '123456', '南阳理工');
INSERT INTO `user2` VALUES ('1815925110', '闫守建', '123456', '南阳理工');
INSERT INTO `user2` VALUES ('1815925116', '周六', '123456', '南阳理工');
INSERT INTO `user2` VALUES ('1815925118', '周五', '123456', '南阳理工');
INSERT INTO `user2` VALUES ('1815925167', '侯明明', '123456', '南阳理工');

-- ----------------------------
-- Table structure for `users`
-- ----------------------------
DROP TABLE IF EXISTS `users`;
CREATE TABLE `users` (
  `UserID` varchar(20) NOT NULL,
  `Username` varchar(15) DEFAULT NULL,
  `UserPassword` varchar(20) DEFAULT NULL,
  PRIMARY KEY (`UserID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- ----------------------------
-- Records of users
-- ----------------------------
INSERT INTO `users` VALUES ('1815925066', '周文豪', '123456');
INSERT INTO `users` VALUES ('1815925067', '闫守建', '123456');

数据库连接池

Druid.properties

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql:///atm?characterEncoding=utf8
username=root
password=zwh19991219
initialSize=5
maxActive=10
maxWait=3000
maxIdle=8
minIdle=3

需要用到的jar包

需要项目源码的同学可以私聊

MYSQL5.6 和 MYSQL 8.0版本的都有

标签:psql,INSERT,null,JavaWeb,rs,VALUES,书城,网上,conn
来源: https://blog.csdn.net/qq_43386944/article/details/117333340