kingbase8 first commit

pom.xml

@@ -267,6 +267,28 @@
             <version>1.7.9</version>
         </dependency>
         <!--webservice 第三方库axis2 maven引用 Spring-axis end-->
+        <!--人大金仓数据库 start-->
+        <dependency>
+            <groupId>com.kingbase8</groupId>
+            <artifactId>kingbase8</artifactId>
+            <version>8.6.0</version>
+        </dependency>
+        <dependency>
+            <groupId>cn.com.kingbase</groupId>
+            <artifactId>KesDialect-for-hibernate4</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>org.postgresql</groupId>-->
+<!--            <artifactId>postgresql</artifactId>-->
+<!--            <version>42.3.9</version>-->
+<!--        </dependency>-->
+<!--        <dependency>-->
+<!--            <groupId>cn.com.kingbase</groupId>-->
+<!--            <artifactId>KesDialect-for-hibernate6.2</artifactId>-->
+<!--            <version>6.2</version>-->
+<!--        </dependency>-->
+        <!--人大金仓数据库 start-->
     </dependencies>
     <!--在项目中使用pom.xml进行下载依赖配置的话可以单独使用：
    注意：项目中使用的maven，如果已经在settings.xml中配置过后就无需在配置此项-->

src/main/java/com/rehome/mqttclienttemperature/controller/JdbcDemoController.java

@@ -70,7 +70,7 @@ public class JdbcDemoController {
         //配置数据源
         ds.setId("1");
         ds.setName("mysql");
-        ds.setUrl("jdbc:mysql://192.168.1.24:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true");
+        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");
@@ -89,16 +89,16 @@ public class JdbcDemoController {
      *
      * @return
      */
-    //@RequestMapping("/api/list")
+    @RequestMapping("/api/list")
     public ResponseDto queryList() {
         // 自定义一个线程池,内部包含8个线程
-        ExecutorService customPool = Executors.newFixedThreadPool(8);
+        ExecutorService customPool = Executors.newFixedThreadPool(4);
         // 自定义一个线程池,内部包含10个线程
         ExecutorService executorService = Executors.newFixedThreadPool(10);
         CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
             String sql = "select * from temperature where id = ?";
             List<Object> jdbcParamValues = new ArrayList<>();
-            for (int i = 2292104; i < 2298700; i++) {
+            for (int i = 0; i < 2310577; i++) {
                 jdbcParamValues.add(i + 1);
                 Gson gson = new Gson();
                 ResponseDto responseDto = JdbcUtil.executeSql(ds, sql, jdbcParamValues);

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

@@ -26,13 +26,9 @@ 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")
-    @SequenceGenerator(name="temperature_seq", sequenceName="temperature_seq_appserver")
     private Long id;
 
     @ApiModelProperty(value = "温度")

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

@@ -16,13 +16,9 @@ import java.util.Date;
 @Data
 @Entity
 public class WebServiceProvince implements Serializable {
-//    @Id
-//    @GeneratedValue(strategy = GenerationType.IDENTITY)
-//    @ApiModelProperty(value = "主键")
     @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
     @ApiModelProperty(value = "主键")
-    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "webService_province_seq")
-    @SequenceGenerator(name = "webService_province_seq", sequenceName = "webService_province_seq")
     private Long id;
 
     @ApiModelProperty(value = "洲、国内外省份")

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

@@ -29,13 +29,9 @@ import java.util.Date;
 //        @Index(name = "data_create_date_city_name", columnList = "cityName"), @Index(name = "data_create_date_city_name", columnList = "createDate")})
 public class WebServiceWeatherInfo {
 
-//    @Id
-//    @GeneratedValue(strategy = GenerationType.IDENTITY)
-//    @ApiModelProperty(value = "主键")
     @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
     @ApiModelProperty(value = "主键")
-    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "webService_weather_info_seq")
-    @SequenceGenerator(name = "webService_weather_info_seq", sequenceName = "webService_weather_info_seq")
     private Long id;
 
     @Column(length = 100)

src/main/resources/application.yml

@@ -9,35 +9,30 @@ logging:
 
 spring:
   datasource:
-    type: com.zaxxer.hikari.HikariDataSource
+    # =====================kingbase相关配置=====================
-#    driverClassName: com.microsoft.sqlserver.jdbc.SQLServerDriver
+    hikari:
-#    url: jdbc:sqlserver://127.0.0.1:1433;DatabaseName=appserver;encrypt=false;
+      #数据库线程池最大连接数
-#    username: sa
+      maximum-pool-size: 6
-#    password: Skyinno251,
+    # 数据库类型
-    #url: jdbc:mysql://192.168.3.29:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
+    name: kingbase
-    #url: jdbc:mysql://127.0.0.1:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
+    #数据库连接驱动
-    #url: jdbc:mysql://192.168.2.18:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
+    driver-class-name: com.kingbase8.Driver
-    #url: jdbc:mysql://192.168.1.92:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
+    #数据库连接url
-    #url: jdbc:mysql://192.168.3.7:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
+    url: jdbc:kingbase8://192.168.3.24:54321/appserver?currentSchema=appserver
-    #url: jdbc:mysql://192.168.3.7:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
+    #数据库连接账号
-    #url: jdbc:mysql://192.168.1.24:3306/weather?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
+    username: system
-    #url: jdbc:mysql://192.168.3.24:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
+    #数据库连接密码
-    #url: jdbc:mysql://192.168.3.9:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
+    password: 452131wW
-    #url: jdbc:mysql://192.168.1.24:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
-    #url: jdbc:mysql://47.242.184.139:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
-#    driverClassName: com.mysql.cj.jdbc.Driver #com.mysql.cj.jdbc.Driver com.mysql.jdbc.Driver
-#    username: root
-#    password: Skyinno251,
-    driverClassName: oracle.jdbc.driver.OracleDriver
-    url: jdbc:oracle:thin:@192.168.3.9:1521/orcl
-    username: appserver
-    password: appserver
   jpa:
-    database: oracle # 配置 DBMS 类型
+    # 配置是否将执行的 SQL 输出到日志
-    show-sql: true # 配置是否将执行的 SQL 输出到日志
+    show-sql: false
     open-in-view: true
-    hibernate:
+    properties:
-      ddl-auto: update  # 第一次建表create  后面用update，要不然每次重启都会新建表
+      hibernate:
+        dialect: org.hibernate.dialect.Kingbase8Dialect
+        ddl-auto: update
+        hbm2ddl:
+          auto: update
   servlet:
     multipart:
       # 开启 multipart 上传功能