【JAVA高併發秒殺API之DAO層】課程筆記
阿新 • • 發佈:2019-01-11
最近在慕課網上學習了【JAVA高併發秒殺API】系列課程,在此整理課程內容!
課程收穫:1、學習瞭如何通過maven建立web專案,pom.xml 檔案依賴管理。
2、學習如何整合spring+mybatis
3、學習了相關配置檔案的書寫。
一、使用maven建立web專案
建立過程省略。。。
建立完畢,目錄結構如下:
相關說明:src/main/java下面放 java程式碼
src/main/resources下面放 配置檔案等。
src/test/是相關 單元測試的檔案。
可以新建一個src/test/sql/ 下面存放 建立資料庫和表格的SQL原始碼
首先需要修改web.xml中的servlet版本:
version="3.0" metadata-complete="true"> <!-- 修改servlet版本 --> </web-app>建立完畢之後需要填寫pom.xml檔案,常用的依賴包已經配置在pom.xml之中,具體如下:
<modelVersion>4.0.0</modelVersion>二、連線資料庫相關配置
如下圖,在src/main/resources 下建立jdbc.properties 檔案(驅動、url、使用者名稱、密碼等設定)
在src/main/resources 下建立mybatis-config.xml 檔案(配置mybatis全域性屬性)
在src/main/resources下新建資料夾spring和mapper:spring下主要存spring相關配置檔案,mapper主要存DAO的相關對映。
在src/main/resources/spring/下建立檔案spring-dao.xml 檔案(配置連線資料庫,整合mybatis配置)
jdbc.properties檔案內容:(注意變數名必須這樣寫,不能自定義)
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" <configuration> <!-- 配置全域性屬性 --> <settings> <!-- 使用jdbc的getGeneratedKeys獲取資料庫自增主鍵值 --> <setting name="useGeneratedKeys" value="true"/> <!-- 使用列別名替換列名 預設:true --> <setting name="useColumnLabel" value="true"/> <!-- 開啟駝峰命名自動轉換 --> <setting name="mapUnderscoreToCamelCase" value="true"/> </settings> </configuration> spring-dao.xml檔案內容:(注意:classpath指代的是src/main/java和src/main/resources)
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN"
"http://www.w3.org/2002/xmlspec/dtd/2.10/xmlspec.dtd"> <!-- 配置整合mybatis過程 --> <!-- 1:配置資料庫相關引數 properties的屬性:${url} --> <context:property-placeholder location="classpath:jdbc.properties"/> <!-- 2:資料庫的連線池 --> <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close"> <!-- 配置連線池屬性 --> <property name="driverClass" value="${jdbc.driverClass}"></property> <property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property> <property name="user" value="${jdbc.user}"></property> <property name="password" value="${jdbc.password}"></property> <!--連線池中保留的最小連線數。--> <property name="minPoolSize" value="10"></property> <!--連線池中保留的最大連線數。Default: 15 --> <property name="maxPoolSize" value="30"></property> <!--關閉連線後不自動commit --> <property name="autoCommitOnClose" value="false"></property> <!-- 獲取連線超時時間 --> <property name="checkoutTimeout" value="1000"></property> <!--定義在從資料庫獲取新連線失敗後重復嘗試的次數。Default: 30 --> <property name="acquireRetryAttempts" value="2" /> </bean> <!-- 3:配置SqlSessionFactory物件 --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <!-- 注入c3p0資料庫連線池 --> <property name="dataSource" ref="dataSource" /> <!-- 配置mybatis全域性配置檔案:mybatis-config.xml --> <property name="configLocation" value="classpath:mybatis-config.xml"></property> <!-- 掃描entity包,使用別名 --> <property name="typeAliasesPackage" value="org.seckill.entity"></property> <!-- 掃描sql配置檔案:mapper需要的xml檔案 --> <property name="mapperLocations" value="classpath:mapper/*.xml"></property> </bean> <!-- 4:配置掃描Dao介面包,動態實現Dao介面,注入到spring容器中 --> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <!-- 注入sqlSessionFactroy --> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property> <!-- 給出掃描Dao介面包 --> <property name="basePackage" value="org.seckill.dao" /> </bean> </beans> (注意:程式碼中高亮部分相關檔案的位置可以根據具體專案進行填寫) 至此,基本配置完畢!
三、編寫DAO以及DAO對映
在編寫DAO之前,需要建立資料庫表格(建立過程省略。。。) 相關SQL語句:schema.sql檔案 -- 資料庫初始化指令碼 -- 建立資料庫 CREATE DATABASE seckill; -- 使用資料庫 use seckill; -- 建立秒殺庫存表 CREATE TABLE seckill( seckill_id bigint NOT NULL AUTO_INCREMENT COMMENT '商品庫存id', name varchar(120) NOT NULL COMMENT '商品名稱', number int NOT NULL COMMENT '庫存數量', create_time timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '建立時間', start_time DATETIME NOT NULL COMMENT '秒殺開啟時間', end_time DATETIME NOT NULL COMMENT '秒殺結束時間', PRIMARY KEY(seckill_id), key idx_start_time(start_time), key idx_end_time(end_time), key idx_create_time(create_time) )ENGINE=InnoDB AUTO_INCREMENT=1000 DEFAULT CHARSET=utf8 COMMENT='秒殺庫存表'; -- 初始化資料 insert into seckill(name, number, start_time, end_time) values ('1000元秒殺iphon6', 100, '2015-11-01 00:00:00', '2015-11-02 00:00:00'), ('500元秒殺ipadmini2', 200, '2016-06-24 00:00:00', '2016-06-25 00:00:00'), ('300元秒殺小米手機', 300, '2016-06-26 00:00:00', '2015-06-27 00:00:00'), ('1999元秒殺ipadAir', 400, '2016-06-29 00:00:00', '2016-06-30 00:00:00'), ('5999元秒殺macbook', 500, '2016-06-29 00:00:00', '2016-06-30 00:00:00'); -- 秒殺成功明細表 -- 使用者登入相關的資訊 CREATE TABLE success_killed( seckill_id bigint NOT NULL COMMENT '商品庫存id', user_phone bigint NOT NULL COMMENT '使用者手機號', state tinyint NOT NULL DEFAULT -1 COMMENT '狀態標識:-1:無效 0:成功 1:已付款', create_time timestamp NOT NULL COMMENT '建立時間', PRIMARY KEY (seckill_id, user_phone), KEY idx_create_time(create_time) )ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='秒殺成功明細表'; 這裡有兩個表:seckill和success_killed表。 我們需要兩個包:(1)org.seckill.entity包(儲存實體) (2)org.seckill.dao包(儲存與實體對應的DAO) 主要分三步:首先在src/main/java下的 org.seckill.entity 包建立實體 然後在src/main/java下的 org.seckill.dao 包建立對應的DAO 最後在src/main/resources下的mapper資料夾下建立對應的 XXXDao.xml 配置檔案(SQL語句寫在配置檔案中)第一步:建立實體 Seckill. java檔案: package org.seckill.entity; import java.util.Date; public class Seckill { private long seckillId; private String name; private int number; private Date createTime; private Date startTime; private Date endTime; public long getSeckillId() { return seckillId; } public void setSeckillId(long seckillId) { this.seckillId = seckillId; } public String getName() { return name; } public void setName(String name) { this.name = name; } public int getNumber() { return number; } public void setNumber(int number) { this.number = number; } public Date getCreateTime() { return createTime; } public void setCreateTime(Date createTime) { this.createTime = createTime; } public Date getStartTime() { return startTime; } public void setStartTime(Date startTime) { this.startTime = startTime; } public Date getEndTime() { return endTime; } public void setEndTime(Date endTime) { this.endTime = endTime; } //複寫toString()方法 @Override public String toString() { return "Seckill [seckillId=" + seckillId + ", name=" + name + ", number=" + number + ", createTime=" + createTime + ", startTime=" + startTime + ", endTime=" + endTime + "]"; } } SuccessKilled.java檔案: package org.seckill.entity; import java.util.Date; public class SuccessKilled { private long seckillId; private long userPhone; private short state; //狀態標識:-1:無效 0:成功 1:已付款 private Date createTime; //多對一:多個SuccessKilled對應一個Seckill private Seckill seckill; public long getSeckillId() { return seckillId; } public void setSeckillId(long seckillId) { this.seckillId = seckillId; } public long getUserPhone() { return userPhone; } public void setUserPhone(long userPhone) { this.userPhone = userPhone; } public short getState() { return state; } public void setState(short state) { this.state = state; } public Date getCreateTime() { return createTime; } public void setCreateTime(Date createTime) { this.createTime = createTime; } public Seckill getSeckill() { return seckill; } public void setSeckill(Seckill seckill) { this.seckill = seckill; } @Override public String toString() { return "SuccessKilled [seckillId=" + seckillId + ", userPhone=" + userPhone + ", state=" + state + ", createTime=" + createTime + "]"; } } 第二步:建立DAO (注意:當DAO類中的方法有多個形參的時候,需要通過註解@Param("XXX")來告訴Mybatis需要的引數) SeckillDao.java檔案: package org.seckill.dao; import java.util.Date; import java.util.List; import org.apache.ibatis.annotations.Param; import org.seckill.entity.Seckill; public interface SeckillDao { /** * 減庫存 * @param seckillId * @param killTime * @return 如果返回>1, 表示更新的記錄行數 */ int reduceNumber(@Param("seckillId") long seckillId, @Param("killTime") Date killTime); /** * 根據ID查詢秒殺物件 * @param seckillId * @return */ Seckill queryById(long seckillId); /** * 根據偏移量查詢秒殺商品列表 * @param offset * @param limit * @return */ List<Seckill> queryAll(@Param("offset") int offset, @Param("limit") int limit); } SuccessKilledDao.java檔案: package org.seckill.dao; import org.apache.ibatis.annotations.Param; import org.seckill.entity.SuccessKilled; public interface SuccessKilledDao { /** * 插入購買明細,可過濾重複 * @param seckillId