添加redis

pom.xml

@@ -74,7 +74,10 @@
             <version>2.4</version>
             <classifier>jdk15</classifier>
         </dependency>
-
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
     </dependencies>
     <build>
         <plugins>

src/main/java/com/usky/annotion/SysLog.java

@@ -1,13 +0,0 @@
-package com.usky.annotion;
-
-import java.lang.annotation.*;
-
-/**
- * 自定义日志注解
- */
-@Target(ElementType.METHOD)
-@Retention(RetentionPolicy.RUNTIME)
-@Documented
-public @interface SysLog {
-    String value() default "";
-}

src/main/java/com/usky/controller/Statr.java

@@ -5,6 +5,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
 import org.springframework.stereotype.Service;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.ResponseBody;
 
 /**
@@ -18,10 +19,12 @@ import org.springframework.web.bind.annotation.ResponseBody;
 public class Statr {
     @Autowired
     private StartService startService;
+
     @RequestMapping("start")
     @ResponseBody
-    public String start(String tableName){
-        startService.start(tableName);
+    public String start(@RequestParam("tableName") String tableName,
+                        @RequestParam("time") String time) {
+        startService.start(tableName,time);
         return "操作成功！";
     }
 }

src/main/java/com/usky/service/StartService.java

@@ -8,5 +8,5 @@ package com.usky.service;
  * @createTime 2021/03/13/ 14:24:00
  */
 public interface StartService {
-    void start(String tableName);
+    void start(String tableName, String time);
 }

src/main/java/com/usky/service/StartServiceImpl.java

@@ -1,17 +1,14 @@
 package com.usky.service;
 
 import com.usky.utils.ListUtil;
-import com.usky.utils.MapUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.jdbc.core.JdbcTemplate;
-import org.springframework.jdbc.support.rowset.SqlRowSet;
 import org.springframework.stereotype.Service;
 
-import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
@@ -23,26 +20,23 @@ import java.util.Map;
  * @createTime 2021/03/13/ 14:25:00
  */
 @Service
-
 public class StartServiceImpl implements StartService {
     private static Logger logger = LoggerFactory.getLogger(StartServiceImpl.class);
     @Autowired
+    private StringRedisTemplate redisTemplate;
+    @Autowired
     @Qualifier("jdbcTemplate118")
     private JdbcTemplate jdbcTemplate118;
     @Autowired
     @Qualifier("jdbcTemplate187")
     private JdbcTemplate jdbcTemplate187;
-
     @Override
-    public void start(String tableName) {
-
-
+    public void start(String tableName, String time) {
+        String age = redisTemplate.opsForValue().get("age");
         List<Map<String, Object>> resList = query187Tables(tableName);
-        Boolean aBoolean = creatTable(resList);
-
+        Boolean aBoolean = creatTable(resList,time);
     }
-
-    public Boolean creatTable(List<Map<String, Object>> resList) {
+    public Boolean creatTable(List<Map<String, Object>> resList, String time) {
         if (ListUtil.isNotBlank(resList)) {
             Map<String, Object> tablNameMap = resList.get(0);
             String tableName = (String) tablNameMap.get("Table");
@@ -52,7 +46,7 @@ public class StartServiceImpl implements StartService {
             if (ListUtil.isBlank(maps)) {
                 jdbcTemplate118.execute(tableSql);
             }
-            String querySql = "select * from " + tableName + " as t where t.acquisition_time <(DATE_ADD(now(),INTERVAL -1 month))";
+            String querySql = "select * from " + tableName + " as t where t."+time+" <(DATE_ADD(now(),INTERVAL -1 month))";
             StringBuffer sb = new StringBuffer();
             List<Map<String, Object>> data187 = jdbcTemplate187.queryForList(querySql);
             for (Map<String, Object> objectMap : data187) {
@@ -67,60 +61,16 @@ public class StartServiceImpl implements StartService {
                 sb.deleteCharAt(sb.length() - 1);
                 String inSql = "INSERT INTO " + tableName + " VALUES (" + sb.toString() + ")";
                 int update = jdbcTemplate118.update(inSql);
-                String delSql="delete from "+tableName+" where id= "+objectMap.get("id")+"";
-                int update1 = jdbcTemplate187.update(delSql);
+                if (update!=0){
+                    String delSql="delete from "+tableName+" where id= "+objectMap.get("id")+"";
+                    int update1 = jdbcTemplate187.update(delSql);
+                }
                 sb.setLength(0);
-                int i=0;
-                System.out.println("inSql = " + i++);
             }
         }
-       /* String tableName = resList.get(0);
-        String tableSql = resList.get(1);
-    List list = (List) hibernateTemplate118.execute(new HibernateCallback() {
-        @Override
-        public Object doInHibernate(Session session) throws HibernateException {
-           return session.createSQLQuery("show tables like '" + tableName + "'").list();
-        }
-    });
-        if (ListUtil.isBlank(list)) {
-            int i = getSession118().createSQLQuery(tableSql).executeUpdate();
-        }
-        List list1 = (List) hibernateTemplate187.execute(new HibernateCallback() {
-            @Override
-            public Object doInHibernate(Session session) throws HibernateException {
-                return session.createSQLQuery("select * from " + tableName + " as t where t.acquisition_time <(DATE_ADD(now(),INTERVAL -1 month)) ").list();
-            }
-        });
-
-        for (Object o : list1) {
-            Object[] d = (Object[]) o;
-            StringBuffer sb = new StringBuffer();
-            for (int i = 0; i < d.length; i++) {
-                sb.append("'" + d[i] + "'");
-                sb.append(",");
-            }
-            // sb.r
-            sb.deleteCharAt(sb.length() - 1);
-            String inSql = "INSERT INTO " + tableName + " VALUES (" + sb.toString() + ")";
-           // int i = getSession118().createSQLQuery(inSql).executeUpdate();
-
-            Integer i = (Integer) hibernateTemplate118.execute(new HibernateCallback() {
-                @Override
-                public Object doInHibernate(Session session) throws HibernateException {
-                    return session.createSQLQuery(inSql).executeUpdate();
-                }
-            });
-
-
-
-        }*/
         return true;
     }
-
     public List<Map<String, Object>> query187Tables(String tableName) {
-
-
-        List<String> resList = new ArrayList<>();
         String sql = "show create table  " + tableName + "";
         return jdbcTemplate187.queryForList(sql);
 

src/main/resources/application.yml

@@ -1,6 +1,10 @@
 server:
   port: 8081
 spring:
+  redis:
+    host: 47.111.81.118
+    port: 6379
+    password: foobared
   datasource:
     first187:
       #driver-class-name: com.mysql.cj.jdbc.Driver