dfdf

src/main/java/com/rehome/mqttclienttemperature/entity/Temperature.java

@@ -26,13 +26,13 @@ import java.util.Date;
 //同时创建普通索引和组合索引,注意普通索引每个索引名都不同，注意组合索引每个索引名都相同
 @Table(indexes = {@Index(name = "idx_dataDate", columnList = "dataDate"),@Index(name = "idx_locationDesc", columnList = "locationDesc"),@Index(name = "idx_dataHour", columnList = "dataHour"),@Index(name = "idx_dataMinute", columnList = "dataMinute"),@Index(name = "data_date_location_desc", columnList = "dataDate"),@Index(name = "data_date_location_desc", columnList = "locationDesc")})
 public class Temperature implements Serializable {
-    @Id
-    @GeneratedValue(strategy = GenerationType.IDENTITY)
-    @ApiModelProperty(value = "主键")
 //    @Id
+//    @GeneratedValue(strategy = GenerationType.IDENTITY)
 //    @ApiModelProperty(value = "主键")
-//    @GeneratedValue(strategy = GenerationType.SEQUENCE,generator="temperature_seq")
+    @Id
-//    @SequenceGenerator(name="temperature_seq", sequenceName="temperature_seq_appserver")
+    @ApiModelProperty(value = "主键")
+    @GeneratedValue(strategy = GenerationType.SEQUENCE,generator="temperature_seq")
+    @SequenceGenerator(name="temperature_seq", sequenceName="temperature_seq_appserver",initialValue = 1,allocationSize = 1)
     private Long id;
 
     @ApiModelProperty(value = "温度")

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

@@ -35,7 +35,9 @@ public class OracleTemperatureServiceImpl implements OracleTemperatureService {
         // 自定义一个线程池,内部包含8个线程
         ExecutorService customPool = Executors.newFixedThreadPool(8);
         CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
-            String sql = "insert into temperature(id,temperature, humidity, data_date, data_hour, data_minute, topic, location_desc, create_date) values(temperature_seq_appserver.NEXTVAL, ?, ?, ?, ?, ?, ?, ?, CURRENT_TIMESTAMP)";
+            //SYSTIMESTAMP
+            //CURRENT_TIMESTAMP
+            String sql = "insert into temperature(id,temperature, humidity, data_date, data_hour, data_minute, topic, location_desc, create_date) values(temperature_seq_appserver.NEXTVAL, ?, ?, ?, ?, ?, ?, ?, SYSTIMESTAMP)";
             List<Object> jdbcParamValues = new ArrayList<>();
 
             jdbcParamValues.add(temperature.getTemperature());