From 028d5568c2e8c8f649b1f395d76826944cd5f1a9 Mon Sep 17 00:00:00 2001
From: whycrzg <ruanzhigang@whycst.com>
Date: 星期二, 02 二月 2021 09:32:13 +0800
Subject: [PATCH] update databaseBackup#
---
src/main/java/com/fgkj/services/Database_backupService.java | 50 +++++++++++++++++++++++++++++++++++++-------------
1 files changed, 37 insertions(+), 13 deletions(-)
diff --git a/src/main/java/com/fgkj/services/Database_backupService.java b/src/main/java/com/fgkj/services/Database_backupService.java
index 9a3e85c..8e91589 100644
--- a/src/main/java/com/fgkj/services/Database_backupService.java
+++ b/src/main/java/com/fgkj/services/Database_backupService.java
@@ -5,7 +5,11 @@
import com.fgkj.dto.ServiceModelOnce;
import com.fgkj.mapper.impl.Database_backupMapper;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.TransactionDefinition;
+import org.springframework.transaction.TransactionStatus;
+import org.springframework.transaction.annotation.Transactional;
import java.util.List;
@@ -17,14 +21,31 @@
@Resource
private Database_backupMapper mapper;;
+ @Autowired
+ DataSourceTransactionManager dataSourceTransactionManager;
+ @Autowired
+ TransactionDefinition transactionDefinition;
//鏍规嵁鏁版嵁搴撳悕鍜岃〃鍚嶄慨鏀瑰浠芥暟鎹簱鐨勪娇鑳�(澶氱瑪璁板綍)
public ServiceModel updatePro(List<Database_backup> obj) {
- boolean bl=mapper.updatePro(obj)>0;
- if(bl){
+ ServiceModel model = new ServiceModel();
+ TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);
+ boolean bl = true;
+ try {
+ bl = mapper.updatePro(obj) > 0;
+ } catch (Exception e) {
+ e.printStackTrace();
+ dataSourceTransactionManager.rollback(transactionStatus);
+ model.setCode(0);
+ model.setMsg("淇敼澶辫触!");
+ return model;
+ }
+ if (bl) {
+ dataSourceTransactionManager.commit(transactionStatus);
model.setCode(1);
model.setMsg("淇敼鎴愬姛!");
- }else{
+ } else {
+ dataSourceTransactionManager.rollback(transactionStatus);
model.setCode(0);
model.setMsg("淇敼澶辫触!");
}
@@ -32,11 +53,12 @@
}
//鏍规嵁鏁版嵁搴撳悕鍜岃〃鍚嶄慨鏀瑰浠芥暟鎹簱鐨勪娇鑳�(涓�閿慨鏀�)
public ServiceModel updateProAll() {
- boolean bl=mapper.updateProAll()>0;
- if(bl){
+ ServiceModel model = new ServiceModel();
+ boolean bl = mapper.updateProAll() > 0;
+ if (bl) {
model.setCode(1);
model.setMsg("淇敼鎴愬姛!");
- }else{
+ } else {
model.setCode(0);
model.setMsg("淇敼澶辫触!");
}
@@ -47,6 +69,7 @@
//鏌ヨ鎵�鏈夋暟鎹簱澶囦唤淇℃伅
public ServiceModel searchAll() {
+ ServiceModel model = new ServiceModel();
List list=mapper.searchAll();
if(list!=null&&list.size()>0){
model.setData(list);
@@ -61,6 +84,7 @@
//鏌ヨ鏁版嵁搴撳浠借〃涓墍鏈夌殑鏁版嵁搴�
public ServiceModel searchAllDatabase() {
+ ServiceModel model = new ServiceModel();
List list=mapper.searchAllDatabase();
if(list!=null&&list.size()>0){
model.setData(list);
@@ -75,6 +99,7 @@
//鏍规嵁鏁版嵁搴撳悕鏌ヨ鎵�鏈夌殑琛�
public ServiceModel searchAllTable(Database_backup obj) {
+ ServiceModel model = new ServiceModel();
List list=mapper.searchAllTable(obj);
if(list!=null&&list.size()>0){
model.setData(list);
@@ -89,17 +114,16 @@
//鏌ヨ涓暟
public ServiceModelOnce searchNum() {
ServiceModelOnce model = new ServiceModelOnce();
- Database_backup baseup=new Database_backup();
+ Database_backup baseup = new Database_backup();
//鎬绘暟
baseup.setNum(0);
- int sum=mapper.searchNum(baseup);
+ int sum = mapper.searchNum(baseup);
//澶勪簬澶囦唤鐨勬暟鐩�
baseup.setNum(1);
- int baseup_num=mapper.searchNum(baseup);
- //TODO perry
- model.setSum(sum);
- model.setNewsum(baseup_num);
- model.setCode(1);
+ int baseup_num = mapper.searchNum(baseup);
+ model.setSum(sum);
+ model.setNewsum(baseup_num);
+ model.setCode(1);
return model;
}
}
--
Gitblit v1.9.1