db change

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

@@ -20,14 +20,13 @@ 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.setUrl("jdbc:mysql://192.168.3.24:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true");
         ds.setUsername("root");
         ds.setPassword("Skyinno251,");
         ds.setDriver("com.mysql.cj.jdbc.Driver");

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

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