基于Java SSM實現(xiàn)Excel數(shù)據(jù)批量導(dǎo)入
導(dǎo)入Maven依賴
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>easyexcel</artifactId>
<version>${easyexcel.version}</version>
</dependency>
Mapper及映射文件
UserMapper.java
@Mapper
public interface UserMapper {
int batchInsert(@Param("list") List<User> list);
}
UserMapper.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.hc.mapper.UserMapper">
<resultMap id="BaseResultMap" type="com.hc.domain.User">
<!--@mbg.generated-->
<!--@Table tb_user-->
<id column="id" jdbcType="BIGINT" property="id" />
<result column="nickname" jdbcType="VARCHAR" property="nickname" />
<result column="avatar" jdbcType="VARCHAR" property="avatar" />
<result column="account" jdbcType="VARCHAR" property="account" />
<result column="password" jdbcType="VARCHAR" property="password" />
<result column="gender" jdbcType="TINYINT" property="gender" />
<result column="tel" jdbcType="VARCHAR" property="tel" />
<result column="email" jdbcType="VARCHAR" property="email" />
<result column="qq" jdbcType="VARCHAR" property="qq" />
<result column="wechat" jdbcType="VARCHAR" property="wechat" />
<result column="salt" jdbcType="VARCHAR" property="salt" />
<result column="info" jdbcType="VARCHAR" property="info" />
<result column="status" jdbcType="TINYINT" property="status" />
<result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
<result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
</resultMap>
<sql id="Base_Column_List">
<!--@mbg.generated-->
id, nickname, avatar, account, `password`, gender, tel, email, qq, wechat, salt,
info, `status`, create_time, update_time
</sql>
<insert id="batchInsert" keyColumn="id" keyProperty="id" parameterType="map" useGeneratedKeys="true">
<!--@mbg.generated-->
insert into tb_user
(nickname, avatar, account, `password`, gender, tel, email, qq, wechat, salt, info,
`status`, create_time, update_time)
values
<foreach collection="list" item="item" separator=",">
(#{item.nickname,jdbcType=VARCHAR}, #{item.avatar,jdbcType=VARCHAR}, #{item.account,jdbcType=VARCHAR},
#{item.password,jdbcType=VARCHAR}, #{item.gender,jdbcType=TINYINT}, #{item.tel,jdbcType=VARCHAR},
#{item.email,jdbcType=VARCHAR}, #{item.qq,jdbcType=VARCHAR}, #{item.wechat,jdbcType=VARCHAR},
#{item.salt,jdbcType=VARCHAR}, #{item.info,jdbcType=VARCHAR}, #{item.status,jdbcType=TINYINT},
#{item.createTime,jdbcType=TIMESTAMP}, #{item.updateTime,jdbcType=TIMESTAMP})
</foreach>
</insert>
</mapper>
Excel監(jiān)聽器
@Log4j2
@Service
public class UserExcelListener extends AnalysisEventListener<User> {
@Resource
private UserMapper userMapper;
/**
* 批處理閾值
*/
private static final int BATCH_COUNT = 250;
@Getter
List<User> list = new ArrayList<>(BATCH_COUNT);
@Override
public void invoke(User user, AnalysisContext analysisContext) { //逐行讀取數(shù)據(jù)
log.info("********** 解析到一條數(shù)據(jù):{}", JSON.toJSONString(user));
list.add(user);
if (list.size() >= BATCH_COUNT) {
System.out.println("已經(jīng)解析"+list.size()+"條數(shù)據(jù)");
//每250條,往數(shù)據(jù)庫中存一次
int batchInsertRes = userMapper.batchInsert(list);
System.out.println(batchInsertRes);
list.clear();
}
}
@Override
public void doAfterAllAnalysed(AnalysisContext analysisContext) {
log.info("**********所有數(shù)據(jù)解析完成!");
}
}
測試
@ExtendWith(SpringExtension.class)
@ContextConfiguration("/applicationContext.xml")
public class ExcelUtilTest {
@Resource
private UserExcelListener userExcelListener;
@Test
void userListener(){
EasyExcel.read("E:\\Projects\\WorksDisplay\\data\\users.xlsx", User.class, userExcelListener)
.sheet()
.doRead();
}
}
到此這篇關(guān)于基于Java SSM實現(xiàn)Excel數(shù)據(jù)批量導(dǎo)入的文章就介紹到這了,更多相關(guān)Java? Excel數(shù)據(jù)批量導(dǎo)入內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
SSH結(jié)合jquery實現(xiàn)三級聯(lián)動效果
這篇文章主要為大家詳細(xì)介紹了SSH結(jié)合jquery實現(xiàn)三級聯(lián)動效果,具有一定的參考價值,感興趣的小伙伴們可以參考一下2017-01-01
Java攔截過濾器模式 (Intercepting Filter )實現(xiàn)方法
攔截過濾器模式(Intercepting Filter Pattern)用于對應(yīng)用程序的請求或響應(yīng)做一些預(yù)處理/后處理,本文通過實例代碼介紹Java攔截過濾器模式 (Intercepting Filter )的相關(guān)知識,感興趣的朋友跟隨小編一起看看吧2024-03-03
Springboot集成JUnit5優(yōu)雅進行單元測試的示例
這篇文章主要介紹了Springboot集成JUnit5優(yōu)雅進行單元測試的示例,幫助大家更好的理解和使用springboot框架,感興趣的朋友可以了解下2020-10-10
SpringBoot使用Spring Test進行集成測試的流程步驟
Spring Test 是 Spring Framework 提供的一個測試框架,它可以幫助我們進行集成測試,在本文中,我們將介紹如何使用 Spring Test 進行集成測試,需要的朋友可以參考下2023-06-06
SpringBoot+Jpa項目配置雙數(shù)據(jù)源的實現(xiàn)
本文主要介紹了SpringBoot+Jpa項目配置雙數(shù)據(jù)庫源的實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下2021-12-12

