update

whycrzg

2021-02-23 351b9a53cb9ecebdf8f79db0117f540d9c42c2a4

 src/main/java/com/fgkj/services/Database_backupService.java

@@ -2,27 +2,50 @@

import com.fgkj.dto.Database_backup;
import com.fgkj.dto.ServiceModel;
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;

import javax.annotation.Resource;
@Service
public class Database_backupService {

   private ServiceModel model;
   ServiceModel model = new ServiceModel();

   @Autowired
   @Resource
   private Database_backupMapper mapper;;
   @Autowired
   DataSourceTransactionManager dataSourceTransactionManager;
   @Autowired
   TransactionDefinition transactionDefinition;
   
   //根据数据库名和表名修改备份数据库的使能(多笔记录)
   public ServiceModel updatePro(Object obj) {
      boolean bl=mapper.updatePro(obj);
      if(bl){
   public ServiceModel updatePro(List<Database_backup> obj) {
      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("修改失败!");
      }
@@ -30,11 +53,12 @@
   }
   //根据数据库名和表名修改备份数据库的使能(一键修改)
   public ServiceModel updateProAll() {
      boolean bl=mapper.updateProAll();
      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("修改失败!");
      }
@@ -45,6 +69,7 @@
   
   //查询所有数据库备份信息
   public ServiceModel searchAll() {
      ServiceModel model = new ServiceModel();
      List list=mapper.searchAll();
      if(list!=null&&list.size()>0){
         model.setData(list);
@@ -59,6 +84,7 @@
   
   //查询数据库备份表中所有的数据库
   public ServiceModel searchAllDatabase() {
      ServiceModel model = new ServiceModel();
      List list=mapper.searchAllDatabase();
      if(list!=null&&list.size()>0){
         model.setData(list);
@@ -72,7 +98,8 @@
   }

   //根据数据库名查询所有的表
   public ServiceModel searchAllTable(Object obj) {
   public ServiceModel searchAllTable(Database_backup obj) {
      ServiceModel model = new ServiceModel();
      List list=mapper.searchAllTable(obj);
      if(list!=null&&list.size()>0){
         model.setData(list);
@@ -85,17 +112,18 @@
      return model;
   }
   //查询个数
   public ServiceModel searchNum() {
      Database_backup baseup=new Database_backup();
   public ServiceModelOnce searchNum() {
      ServiceModelOnce model = new ServiceModelOnce();
      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);
      int baseup_num = mapper.searchNum(baseup);
      model.setSum(sum);
      model.setNewsum(baseup_num);
      model.setCode(1);
      return model;
   }
}