add mysql

.idea/workspace.xml

@@ -4,10 +4,11 @@
     <option name="autoReloadType" value="SELECTIVE" />
   </component>
   <component name="ChangeListManager">
-    <list default="true" id="eacd3dd8-1e95-428c-a6af-1aadb9921989" name="Default Changelist" comment="">
+    <list default="true" id="eacd3dd8-1e95-428c-a6af-1aadb9921989" name="Default Changelist" comment="3.25">
+      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/service/MysqlTemperatureService.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/service/impl/MysqlTemperatureServiceImpl.java" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/service/impl/TemperatureServiceImpl.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/service/impl/TemperatureServiceImpl.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/main/resources/application.yml" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/resources/application.yml" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -23,7 +24,20 @@
       </list>
     </option>
   </component>
+  <component name="Git.Pull.Settings">
+    <option name="OPTIONS">
+      <set>
+        <option value="REBASE" />
+      </set>
+    </option>
+  </component>
   <component name="Git.Settings">
+    <option name="PUSH_TAGS">
+      <GitPushTagMode>
+        <option name="argument" value="--follow-tags" />
+        <option name="title" value="Current Branch" />
+      </GitPushTagMode>
+    </option>
     <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
   </component>
   <component name="GitSEFilterConfiguration">
@@ -190,8 +204,17 @@
       <workItem from="1752296158629" duration="60000" />
       <workItem from="1752296228658" duration="196000" />
       <workItem from="1752296479168" duration="85000" />
-      <workItem from="1752298097937" duration="2655000" />
+      <workItem from="1752298097937" duration="2711000" />
+      <workItem from="1752504387686" duration="801000" />
     </task>
+    <task id="LOCAL-00001" summary="3.25">
+      <created>1752307229554</created>
+      <option name="number" value="00001" />
+      <option name="presentableId" value="LOCAL-00001" />
+      <option name="project" value="LOCAL" />
+      <updated>1752307229554</updated>
+    </task>
+    <option name="localTasksCounter" value="2" />
     <servers />
   </component>
   <component name="TypeScriptGeneratedFilesManager">
@@ -209,6 +232,10 @@
     </option>
     <option name="oldMeFiltersMigrated" value="true" />
   </component>
+  <component name="VcsManagerConfiguration">
+    <MESSAGE value="3.25" />
+    <option name="LAST_COMMIT_MESSAGE" value="3.25" />
+  </component>
   <component name="XSLT-Support.FileAssociations.UIState">
     <expand />
     <select />

src/main/java/com/rehome/mqttclienttemperature/service/MysqlTemperatureService.java

@@ -0,0 +1,8 @@
+package com.rehome.mqttclienttemperature.service;
+
+import com.rehome.mqttclienttemperature.dto.ResponseDto;
+import com.rehome.mqttclienttemperature.entity.Temperature;
+
+public interface MysqlTemperatureService {
+    ResponseDto saveTemperature(Temperature temperature);
+}

src/main/java/com/rehome/mqttclienttemperature/service/impl/MysqlTemperatureServiceImpl.java

@@ -0,0 +1,78 @@
+package com.rehome.mqttclienttemperature.service.impl;
+
+import com.google.gson.Gson;
+import com.rehome.mqttclienttemperature.datasource.DataSource;
+import com.rehome.mqttclienttemperature.dto.ResponseDto;
+import com.rehome.mqttclienttemperature.entity.Temperature;
+import com.rehome.mqttclienttemperature.service.MysqlTemperatureService;
+import com.rehome.mqttclienttemperature.service.OracleTemperatureService;
+import com.rehome.mqttclienttemperature.service.PostgresSqlTemperatureService;
+import com.rehome.mqttclienttemperature.service.SqlServerTemperatureService;
+import com.rehome.mqttclienttemperature.utils.JdbcUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+@Slf4j
+@Service
+
+public class MysqlTemperatureServiceImpl implements MysqlTemperatureService {
+    public static DataSource ds = new DataSource();
+    static {
+        //配置数据源
+        ds.setId("3306");
+        ds.setName("mysql");
+        ds.setUrl("jdbc:mysql://192.168.3.9:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true");
+        ds.setUsername("root");
+        ds.setPassword("Skyinno251,");
+        ds.setDriver("com.mysql.cj.jdbc.Driver");
+    }
+
+    @Override
+    public ResponseDto saveTemperature(Temperature temperature) {
+        // 自定义一个线程池,内部包含8个线程
+        ExecutorService customPool = Executors.newFixedThreadPool(2);
+        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
+            //SYSTIMESTAMP
+            //CURRENT_TIMESTAMP
+            //HIBERNATE_SEQUENCE
+            //temperature_seq_appserver
+            String sql = "insert into temperature(temperature, humidity, data_date, data_hour, data_minute, topic, location_desc, create_date) values(?, ?, ?, ?, ?, ?, ?, CURRENT_TIMESTAMP())";
+            List<Object> jdbcParamValues = new ArrayList<>();
+
+            jdbcParamValues.add(temperature.getTemperature());
+            jdbcParamValues.add(temperature.getHumidity());
+            jdbcParamValues.add(temperature.getDataDate());
+            jdbcParamValues.add(temperature.getDataHour());
+            jdbcParamValues.add(temperature.getDataMinute());
+            jdbcParamValues.add(temperature.getTopic());
+            jdbcParamValues.add(temperature.getLocationDesc());
+            //jdbcParamValues.add(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(temperature.getCreateDate()));
+
+            Gson gson = new Gson();
+            ResponseDto responseDto = JdbcUtil.executeSql(ds, sql, jdbcParamValues);
+            String dbQueryResult = gson.toJson(responseDto);
+            log.info(dbQueryResult);
+            jdbcParamValues.clear();
+
+            if(responseDto.isSuccess()){
+                return "数据库同步成功";
+            }
+            return "数据库同步失败";
+        }, customPool);
+
+        ResponseDto responseDto = future.thenApply(result -> {
+            log.info("Result: " + result);
+            if("数据库同步成功".equals(result)){
+                return ResponseDto.successWithMsg(result);
+            }
+            return ResponseDto.fail(result);
+        }).join();
+        return responseDto;
+    }
+}

src/main/java/com/rehome/mqttclienttemperature/service/impl/TemperatureServiceImpl.java

@@ -33,6 +33,9 @@ public class TemperatureServiceImpl implements TemperatureService {
     private KingbaseTemperatureService kingbaseTemperatureService;
     @Resource
     private PostgresSqlTemperatureService postgresSqlTemperatureService;
+    @Resource
+    private MysqlTemperatureService mysqlTemperatureService;
+
 
 
     @Override
@@ -70,6 +73,7 @@ public class TemperatureServiceImpl implements TemperatureService {
             temperature.setTemperature(strDataTemperature[1]);
 
             this.temperatureRepository.save(temperature);
+            mysqlTemperatureService.saveTemperature(temperature);
 //            ResponseDto responseDtoOracle = this.oracleTemperatureService.saveTemperature(temperature);
 //            log.info(new Gson().toJson(responseDtoOracle));