diff --git a/src/main/java/com/rehome/mqttclienttemperature/service/impl/MysqlTemperatureServiceImpl.java b/src/main/java/com/rehome/mqttclienttemperature/service/impl/MysqlTemperatureServiceImpl.java index b074699..c285bee 100644 --- a/src/main/java/com/rehome/mqttclienttemperature/service/impl/MysqlTemperatureServiceImpl.java +++ b/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"); diff --git a/src/main/java/com/rehome/mqttclienttemperature/service/impl/TemperatureServiceImpl.java b/src/main/java/com/rehome/mqttclienttemperature/service/impl/TemperatureServiceImpl.java index d6ab240..112e06a 100644 --- a/src/main/java/com/rehome/mqttclienttemperature/service/impl/TemperatureServiceImpl.java +++ b/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 - //private MysqlTemperatureService mysqlTemperatureService; + @Resource + 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));