JavaWeb：網上書店的案例

 

功能分析：

只有一個角色客戶，客戶可以

　　--查看圖書信息（包括查看圖書詳細信息，使用條件（例價格區間）查看圖書信息，對圖書進行翻頁）

　　--把圖書加入購物車

　　--查看購物車

　　--修改購物車（包括清空購物車，修改購物車單本圖書數量，刪除單本圖書）

　　--結賬（填寫用戶名和賬號信息）

　　--查看交易記錄

總體架構：

MVC 設計模式：

　　--model：POJO

　　--controller：Servlet

　　--view：JSP + EL + JSTL

技術選型：

　　數據庫：Mysql

　　數據源：C3P0

　　JDBC 工具：DBUtils

　　事務解決方案：Filter + ThreadLocal

　　Ajax 解決方案：jQuery + JavaScript + JSON + google-gson

　　層之間解耦方案：工廠設計模式

數據表設計：

在 Mysql 數據庫中建好這些數據表。

配置好環境

實體類設計：Account(賬戶表，用於支付)，User（客戶表，存儲客戶基本信息），Trade(交易項)，TradeItem(交易記錄)，Book，ShoppingCartItem，ShoppingCart

DAO 層設計：（這里先每個方法手動的獲取Connection，在后面操作事務時，再改成獲取統一的Connection）

　　- Dao 接口，定義 Dao 的基本操作，使用BaseDao 實現 Dao 接口。

　　- BaseDao ：使用 DBUtils 工具類提供 Dao 接口的具體實現。

　　   BookDao 接口：用於定義操作 Book 實體類的基本方法。

　　- BookDaoImpl ：使用 BaseDao 中的方法實現 BookDao。

Dao 接口 代碼：

package com.hnust.bookstore.dao;

import java.util.List;

/**
 * Dao 接口，定義 Dao 的基本操作，由BaseDao 提供實現。
 * @param <T>：Dao 實際操作的泛型類型。
 */
public interface Dao<T> {

    /**
     * 執行 update 操作（insert（但沒有返回值）、update、delete）
     * @param sql：待執行的 SQL 語句。
     * @param args：填充占位符的可變參數。
     */
    void update(String sql, Object...args);
    
    /**
     * 執行 insert 操作，返回插入后的記錄的ID
     * @param sql：待執行的 SQL 語句。
     * @param args：填充占位符的可變參數。
     * @return：插入新記錄的ID。
     */
    long insert(String sql, Object...args);
    
    /**
     * 執行單條記錄的查詢，返回與記錄對應的類的一個對象。
     * @param sql：待執行的SQL 語句。
     * @param args：填充占位符的可變參數。
     * @return：與記錄對應的類的一個對象。
     */
    T query(String sql, Object...args);
    
    /**
     * 執行多條記錄的查詢，返回與記錄對應的類的一個List。
     * @param sql：待執行的 SQL 語句。
     * @param args：填充占位符的可變參數。
     * @return：與記錄對應的類的一個 List。
     */
    List<T> queryForList(String sql, Object...args);
    
    /**
     * 執行一個屬性或值得查詢，例如查詢某一條記錄的一個字段或查詢某個統計信息，返回要查詢的值。
     * @param sql：待執行的 SQL 語句。
     * @param args：填充占位符的可變參數。
     * @return：返回要查詢的一個屬性或值。
     */
    <E> E getForValue(String sql, Object...args);
    
    /**
     * 執行批量根性操作
     * @param sql：待執行的 SQL 語句。
     * @param params：填充占位符的可變參數。
     */
    void batch(String sql, Object[]...params);
}

BookDao 接口 代碼：

package com.hnust.bookstore.dao;

import java.util.Collection;
import java.util.List;

import com.hnust.bookstore.domain.Book;
import com.hnust.bookstore.domain.ShoppingCartItem;
import com.hnust.bookstore.web.CriteriaBook;
import com.hnust.bookstore.web.Page;

public interface BookDao {

    /**
     * 根據 bookId 獲取指定的 Book 對象
     * @param bookId
     * @return
     */
    public abstract Book getBook(int bookId);
    
    /**
     * 根據傳入的CriteriaBook 對象返回對應的 Page 對象。
     * @param cb
     * @return
     */
    public abstract Page<Book> getPage(CriteriaBook cb);
    
    /**
     * 根據傳入的 CriteriaBook 對象返回對應的記錄個數。
     * @param cb
     * @return
     */
    public abstract long getTotalBookNumber(CriteriaBook cb);

    /**
     * 根據傳入的 CriteriaBook 和 pageSize 返回當前頁對應的 List。
     * @param cb
     * @param pageSize
     * @return
     */
    public abstract List<Book> getPageList(CriteriaBook cb, int pageSize);

    /**
     * 返回指定的 id 的 book 的 storeNumber 字段的值。
     * @param id
     * @return
     */
    public abstract int getStoreNumber(Integer bookId);
    
    /**
     * 根據傳入的 ShoppingCartItem 的集合，
     * 批量更新 books 數據表的 storenumber 和 salesnumber 字段的值
     * @param items
     */
    public abstract void batchUpdateStoreNUmberAndSalesAmount(Collection<ShoppingCartItem> items);
}

AccountDao 接口 代碼：

package com.hnust.bookstore.dao;

import com.hnust.bookstore.domain.Account;

public interface AccountDao {
    
    /**
     * 根據傳入的 accountId 獲取對應的 Account 對象。
     * @param accountId
     * @return
     */
    public abstract Account get(Integer accountId);
    
    /**
     * 根據傳入的 accountId、amount 更新指定賬戶的余額：扣除 amount 指定的錢數。
     * @param accountId
     * @param amount
     */
    public abstract void updateBalance(Integer accountId, float amount);
}

TradeDao 接口 代碼：

package com.hnust.bookstore.dao;

import java.util.Set;

import com.hnust.bookstore.domain.Trade;

public interface TradeDao {
    
    /**
     * 向數據表中插入 Trade 對象
     * @param trade
     */
    public abstract void insert(Trade trade);
    
    /**
     * 根據 userId 獲取和其關聯的 Trade 的集合
     * @param userId
     * @return
     */
    public abstract Set<Trade> getTradesWithUserId(Integer userId);
}

TradeItemDao 接口 代碼：

package com.hnust.bookstore.dao;

import java.util.Collection;
import java.util.Set;

import com.hnust.bookstore.domain.TradeItem;

public interface TradeItemDao {

    /**
     * 批量保存 TradeItem 對象
     * @param items
     */
    public abstract void batchSave(Collection<TradeItem> items);
    
    /**
     * 根據 tradeId 獲取和其關聯的 TradeItem 的集合。
     * @param tradeId
     * @return
     */
    public abstract Set<TradeItem> getTradeItemsWithTradeId(Integer tradeId);
}

UserDao 接口 代碼：

package com.hnust.bookstore.dao;

import com.hnust.bookstore.domain.User;

public interface UserDao {

    /**
     * 根據用戶名獲取 User 對象。
     * @param userName
     * @return
     */
    public abstract User getUser(String userName);
}

封裝翻頁信息的 Page 類：

　　-pageNo (當前頁的頁碼)

　　-list (本業需要顯示的 list （選購的書籍的集合）)

　　-pageSize (每頁顯示多少條記錄)

　　-totalItemNumber (總的記錄數，用來計算總的頁數)

　　-Page(int) : 構造器，初始化當前頁的頁碼 pageNo，在Servlet 里面對其進行賦值。

　　-getPageNo()：返回當前頁的頁碼，注意：需通過 getTatalPageNumber() 進行校驗，因為有可能傳入的頁碼不一定是合法的。

　　-getList()：

　　-setList()：設置當前頁需要顯示的 List 對象，是在 DAO 對其進行賦值。

　　-getPageSize()：返回當前頁顯示多少條記錄

　　-getTotalPageNumber()：獲取總頁碼數，需計算得出

　　-setTotalItemNumber()：設置總的記錄數，是在 DAO 對其進行賦值。

　　-isHasNext()

　　-isHasPrev()

　　-getPrevPage()

　　-getNextPage()

封裝查詢條件的 CriteriaBook 類：

　　-minPrice：價格區間的最小值，默認為 0 

　　-maxPrice：價格區間的最大值，默認為 Integer.MAX_VALUE

　　-pageNo：當前頁的頁碼

　　-CriteriaBook()

　　-CriteriaBook(int, int, int)

　　-getMinPrice()

　　-setMinPrice(int)

　　-getMaxPrice()

　　-setMaxPrice(int)

　　-getPageNo()

　　-setPageNo(int)

　　-toString()

BaseDao 代碼：

package com.hnust.bookstore.dao.impl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.List;

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 com.hnust.bookstore.dao.Dao;
import com.hnust.bookstore.db.JDBCUtils;
import com.hnust.bookstore.utils.ReflectionUtils;
import com.hnust.bookstore.web.ConnectionContext;
import com.sun.org.apache.regexp.internal.recompile;

public class BaseDao<T> implements Dao<T> {

    private QueryRunner queryRunner = new QueryRunner();
    
    private Class<T> clazz;
    
    public BaseDao(){
        clazz = ReflectionUtils.getSuperGenericType(getClass());
    }
    
    @Override
    public void update(String sql, Object... args) {
        
        Connection conn = null;
        
        try {
            //獲取連接
            conn = JDBCUtils.getConnection();
            queryRunner.update(conn, sql, args);
            
        } catch (Exception e) {
            e.printStackTrace(); }
        }finally{
            JDBCUtils.release(conn);
        }
    }

    @Override
    public long insert(String sql, Object... args) {
        
        long id = 0;
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        
        try {
            conn = JDBCUtils.getConnection();
            ps = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
            
            if(args != null){
                for(int i = 0; i < args.length; i++){
                    ps.setObject(i + 1, args[i]);
                }
            }
            ps.executeUpdate();
            //獲取生成的主鍵值
            rs = ps.getGeneratedKeys();
            if(rs.next()){
                id = rs.getLong(1);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            JDBCUtils.release(rs, ps);
            JDBCUtils.release(conn);
        }
        return id;
    }

    @Override
    public T query(String sql, Object... args) {
        Connection conn = null;
        
        try {
            conn = JDBCUtils.getConnection();
            return queryRunner.query(conn, sql, new BeanHandler<>(clazz), args);
        } catch (Exception e) {
            e.printStackTrace();
        }
        finally{
            JDBCUtils.release(conn);
        }
        return null;
    }

    @Override
    public List<T> queryForList(String sql, Object... args) {
        
        Connection conn = null;
        try {
            conn = JDBCUtils.getConnection();
            return queryRunner.query(conn, sql, new BeanListHandler<>(clazz), args);
        } catch (Exception e) {
            e.printStackTrace();
        }
        finally{
            JDBCUtils.release(conn);
        }
        return null;
    }

    @Override
    public <E> E getForValue(String sql, Object... args) {
        Connection conn = null;
        
        try {
            conn = JDBCUtils.getConnection();
            return (E) queryRunner.query(conn, sql, new ScalarHandler(), args);
        } catch (Exception e) {
            e.printStackTrace();
        }
        finally{
            JDBCUtils.release(conn);
        }
        return null;
    }

    @Override
    public void batch(String sql, Object[]... params) {
        Connection conn = null;
        
        try {
            conn = JDBCUtils.getConnection();
            queryRunner.batch(conn, sql, params);
        } catch (Exception e) {
            e.printStackTrace();
        }
        finally{
            JDBCUtils.release(conn);
        }
    }

}

最后完成對以上剩余DAO層的實現，BookDaoImpl、AccountDaoImpl、TradeDaoImpl、TradeItemDaoImpl、UserDaoImpl。

明天繼續，over。