Initial commit

Author: dragon-idea

src/com/longdi/dao/BookDao.java

@@ -0,0 +1,27 @@
+package com.longdi.dao;
+
+import com.longdi.pojo.Book;
+
+import java.util.List;
+
+/**
+ * @author: 龍弟
+ * @description
+ * @date: 2021/9/18 12:19
+ */
+public interface BookDao {
+    public int addBook(Book book);
+    public int deleteBookById(Integer id);
+    public int updateBook(Book book);
+
+    public Book queryBookById(Integer id);
+    public List<Book> queryBooks();
+
+    Integer queryForPageTotalCount();
+
+    List<Book> queryForPageItems(int begin, int pageSize);
+
+    List<Book> queryForPageItemsByPrice(int begin, int pageSize, int min, int max);
+
+    Integer queryForPageTotalCountByPrice(int min, int max);
+}

src/com/longdi/dao/OrderDao.java

@@ -0,0 +1,9 @@
+package com.longdi.dao;
+
+import com.longdi.pojo.Order;
+
+public interface OrderDao {
+
+    public int saveOrder(Order order);
+
+}

src/com/longdi/dao/OrderItemDao.java

@@ -0,0 +1,7 @@
+package com.longdi.dao;
+
+import com.longdi.pojo.OrderItem;
+
+public interface OrderItemDao {
+    public int saveOrderItem(OrderItem orderItem);
+}

src/com/longdi/dao/UserDao.java

@@ -0,0 +1,35 @@
+package com.longdi.dao;
+
+import com.longdi.pojo.User;
+
+/**
+ * @author: 龍弟
+ * @description
+ * @date: 2021/9/16 18:40
+ */
+public interface UserDao {
+
+    /**
+     * 根据用户名查询用户信息
+     * @param username 用户名
+     * @return 如果返回null,说明没有这个用户。反之亦然
+     */
+    public User queryUserByUsername(String username);
+
+    /**
+     * 根据 用户名和密码查询用户信息
+     * @param username
+     * @param password
+     * @return 如果返回null,说明用户名或密码错误,反之亦然
+     */
+    public User queryUserByUsernameAndPassword(String username, String password);
+
+    /**
+     * 保存用户信息
+     * @param user
+     * @return 返回-1表示操作失败，其他是sql语句影响的行数
+     */
+    public int saveUser(User user);
+
+
+}

src/com/longdi/dao/impl/BaseDao.java

@@ -0,0 +1,98 @@
+package com.longdi.dao.impl;
+
+import com.longdi.utils.JdbcUtils;
+import org.apache.commons.dbutils.QueryRunner;
+import org.apache.commons.dbutils.handlers.BeanHandler;
+import org.apache.commons.dbutils.handlers.BeanListHandler;
+import org.apache.commons.dbutils.handlers.ScalarHandler;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.List;
+
+/**
+ * @author: 龍弟
+ * @description
+ * @date: 2021/9/16 18:01
+ */
+public abstract class BaseDao {
+
+    //使用DbUtils操作数据库
+    private QueryRunner queryRunner = new QueryRunner();
+
+    /**
+     * update() 方法用来执行：Insert\Update\Delete语句
+     *
+     * @return 如果返回-1,说明执行失败<br/>返回其他表示影响的行数
+     */
+    public int update(String sql, Object... args) {
+
+        System.out.println(" BaseDao 程序在[" +Thread.currentThread().getName() + "]中");
+
+        Connection connection = JdbcUtils.getConnection();
+        try {
+            return queryRunner.update(connection, sql, args);
+        } catch (SQLException e) {
+            e.printStackTrace();
+            throw new RuntimeException(e);
+        }
+    }
+
+    /**
+     * 查询返回一个javaBean的sql语句
+     *
+     * @param type 返回的对象类型
+     * @param sql  执行的sql语句
+     * @param args sql对应的参数值
+     * @param <T>  返回的类型的泛型
+     * @return
+     */
+    public <T> T queryForOne(Class<T> type, String sql, Object... args) {
+        Connection con = JdbcUtils.getConnection();
+        try {
+            return queryRunner.query(con, sql, new BeanHandler<T>(type), args);
+        } catch (SQLException e) {
+            e.printStackTrace();
+            throw new RuntimeException(e);
+        }
+    }
+
+    /**
+     * 查询返回多个javaBean的sql语句
+     *
+     * @param type 返回的对象类型
+     * @param sql  执行的sql语句
+     * @param args sql对应的参数值
+     * @param <T>  返回的类型的泛型
+     * @return
+     */
+    public <T> List<T> queryForList(Class<T> type, String sql, Object... args) {
+        Connection con = JdbcUtils.getConnection();
+        try {
+            return queryRunner.query(con, sql, new BeanListHandler<T>(type), args);
+        } catch (SQLException e) {
+            e.printStackTrace();
+            throw new RuntimeException(e);
+        }
+    }
+
+    /**
+     * 执行返回一行一列的sql语句
+     * @param sql   执行的sql语句
+     * @param args  sql对应的参数值
+     * @return
+     */
+    public Object queryForSingleValue(String sql, Object... args){
+
+        Connection conn = JdbcUtils.getConnection();
+
+        try {
+            return queryRunner.query(conn, sql, new ScalarHandler(), args);
+        } catch (SQLException e) {
+            e.printStackTrace();
+            throw new RuntimeException(e);
+        }
+
+    }
+
+}

src/com/longdi/dao/impl/BookDaoImpl.java

@@ -0,0 +1,74 @@
+package com.longdi.dao.impl;
+
+import com.longdi.dao.BookDao;
+import com.longdi.pojo.Book;
+
+import java.util.List;
+
+/**
+ * @author: 龍弟
+ * @description
+ * @date: 2021/9/18 12:23
+ */
+public class BookDaoImpl extends BaseDao implements BookDao {
+    @Override
+    public int addBook(Book book) {
+
+        String sql = "insert into t_book(`name`,`author`,`price`,`sales`,`stock`,`img_path`) values(?,?,?,?,?,?)";
+
+        return update(sql, book.getName(),book.getAuthor(),book.getPrice(),book.getSales(),book.getStock(),book.getImgPath());
+
+    }
+
+    @Override
+    public int deleteBookById(Integer id) {
+        String sql = "delete from t_book where id = ?";
+        return update(sql, id);
+    }
+
+    @Override
+    public int updateBook(Book book) {
+        String sql = "update t_book set `name`=?,`author`=?,`price`=?,`sales`=?,`stock`=?,`img_path`=? where id = ?";
+        return update(sql,book.getName(),book.getAuthor(),book.getPrice(),book.getSales(),book.getStock(),book.getImgPath(),book.getId());
+    }
+
+    @Override
+    public Book queryBookById(Integer id) {
+        String sql = "select `id` , `name` , `author` , `price` , `sales` , `stock` , `img_path` imgPath from t_book where id = ?";
+        return queryForOne(Book.class, sql,id);
+    }
+
+    @Override
+    public List<Book> queryBooks() {
+        String sql = "select `id` , `name` , `author` , `price` , `sales` , `stock` , `img_path` imgPath from t_book";
+        return queryForList(Book.class, sql);
+    }
+
+
+    @Override
+    public Integer queryForPageTotalCount() {
+        String sql = "select count(*) from t_book";
+        Number count = (Number) queryForSingleValue(sql);
+        return count.intValue();
+    }
+
+    @Override
+    public List<Book> queryForPageItems(int begin, int pageSize) {
+        String sql = "select `id` , `name` , `author` , `price` , `sales` , `stock` , `img_path` imgPath from t_book limit ?,?";
+        return queryForList(Book.class,sql,begin,pageSize);
+    }
+
+    @Override
+    public Integer queryForPageTotalCountByPrice(int min, int max) {
+        String sql = "select count(*) from t_book where price between ? and ?";
+        Number count = (Number) queryForSingleValue(sql,min,max);
+        return count.intValue();
+    }
+
+    @Override
+    public List<Book> queryForPageItemsByPrice(int begin, int pageSize, int min, int max) {
+        String sql = "select `id`,`name`,`author`,`price`,`sales`,`stock`,`img_path` imgPath " +
+                "from t_book where price between ? and ? order by price limit ?,?";
+        return queryForList(Book.class,sql,min,max,begin,pageSize);
+    }
+}

src/com/longdi/dao/impl/OrderDaoImpl.java

@@ -0,0 +1,13 @@
+package com.longdi.dao.impl;
+
+import com.longdi.dao.OrderDao;
+import com.longdi.pojo.Order;
+
+public class OrderDaoImpl extends BaseDao implements OrderDao {
+    @Override
+    public int saveOrder(Order order) {
+        String sql = "insert into t_order(`order_id`,`create_time`,`price`,`status`,`user_id`) values(?,?,?,?,?)";
+
+        return update(sql,order.getOrderId(),order.getCreateTime(),order.getPrice(),order.getStatus(),order.getUserId());
+    }
+}

src/com/longdi/dao/impl/OrderItemDaoImpl.java

@@ -0,0 +1,12 @@
+package com.longdi.dao.impl;
+
+import com.longdi.dao.OrderItemDao;
+import com.longdi.pojo.OrderItem;
+
+public class OrderItemDaoImpl extends BaseDao implements OrderItemDao {
+    @Override
+    public int saveOrderItem(OrderItem orderItem) {
+        String sql = "insert into t_order_item(`name`,`count`,`price`,`total_price`,`order_id`) values(?,?,?,?,?)";
+        return update(sql,orderItem.getName(),orderItem.getCount(),orderItem.getPrice(),orderItem.getTotalPrice(),orderItem.getOrderId());
+    }
+}

src/com/longdi/dao/impl/UserDaoImpl.java

@@ -0,0 +1,29 @@
+package com.longdi.dao.impl;
+
+import com.longdi.dao.UserDao;
+import com.longdi.pojo.User;
+
+/**
+ * @author: 龍弟
+ * @description
+ * @date: 2021/9/16 18:44
+ */
+public class UserDaoImpl extends  BaseDao implements UserDao {
+    @Override
+    public User queryUserByUsername(String username) {
+        String sql = "select `id`,`username`,`password`,`email` from t_user where username = ?";
+        return queryForOne(User.class, sql, username);
+    }
+
+    @Override
+    public User queryUserByUsernameAndPassword(String username, String password) {
+        String sql = "select `id`,`username`,`password`,`email` from t_user where username = ? and password = ?";
+        return queryForOne(User.class, sql, username,password);
+    }
+
+    @Override
+    public int saveUser(User user) {
+        String sql = "insert into t_user(`username`,`password`,`email`) values(?,?,?)";
+        return update(sql, user.getUsername(),user.getPassword(),user.getEmail());
+    }
+}

src/com/longdi/filter/ManagerFilter.java

@@ -0,0 +1,36 @@
+package com.longdi.filter;
+
+import javax.servlet.*;
+import javax.servlet.http.HttpServletRequest;
+import java.io.IOException;
+
+/**
+ * @author: 龍弟
+ * @description
+ * @date: 2021/9/21 21:04
+ */
+public class ManagerFilter implements Filter {
+
+    @Override
+    public void init(FilterConfig filterConfig) throws ServletException {
+
+    }
+
+    @Override
+    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
+        HttpServletRequest httpServletRequest = (HttpServletRequest) servletRequest;
+
+        Object user = httpServletRequest.getSession().getAttribute("user");
+
+        if (user == null) {
+            httpServletRequest.getRequestDispatcher("/pages/user/login.jsp").forward(servletRequest,servletResponse);
+        } else {
+            filterChain.doFilter(servletRequest,servletResponse);
+        }
+    }
+
+    @Override
+    public void destroy() {
+
+    }
+}

src/com/longdi/filter/TransactionFilter.java

@@ -0,0 +1,31 @@
+package com.longdi.filter;
+
+import com.longdi.utils.JdbcUtils;
+
+import javax.servlet.*;
+import java.io.IOException;
+
+public class TransactionFilter implements Filter {
+
+    @Override
+    public void init(FilterConfig filterConfig) throws ServletException {
+
+    }
+
+    @Override
+    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
+        try {
+            filterChain.doFilter(servletRequest,servletResponse);
+            JdbcUtils.commitAndClose();// 提交事务
+        } catch (Exception e) {
+            JdbcUtils.rollbackAndClose();//回滚事务
+            e.printStackTrace();
+            throw new RuntimeException(e);//把异常抛给Tomcat管理展示友好的错误页面
+        }
+    }
+
+    @Override
+    public void destroy() {
+
+    }
+}