spring 管理批量插入功能.

yongxin1024 · Dec 25, 2021 · cbaa3a9 · cbaa3a9
1 parent b77cfc0
commit cbaa3a9
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/HisRunDataServiceImpl.java b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/HisRunDataServiceImpl.java
@@ -17,6 +17,7 @@
 import com.google.common.collect.Lists;
 import lombok.AllArgsConstructor;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Date;
 import java.util.List;
@@ -128,6 +129,7 @@ public MonitorRespDTO queryThreadPoolLastTaskCount(MonitorQueryReqDTO reqDTO) {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void save(Message message) {
         List<RuntimeMessage> runtimeMessages = message.getMessages();
         List<HisRunDataInfo> hisRunDataInfos = Lists.newArrayList();