DM8--SpringBoot整合达梦数据库

懒驴 2021年12月15日 3,949次浏览

在上一篇 DM8--达梦数据库（安装步骤） 中已经介绍了数据库DM8的安装步骤，接下来将主要介绍在项目中如何连接使用达梦数据库，在这里主要讲在SpringBoot项目中对达梦数据库的整合。

首先，我的实例项目是基于现有的SpringBoot+MyBatis-Plus+MySQL项目，实现同时集成MySQL数据源的同时，也集成达梦数据库，这样对于项目可以实现多数据源操作。

1. pom.xml配置

以下是整体项目使用打的架包信息

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.1.0</version>
        </dependency>
        <!-- mybatis plus 代码生成器依赖 -->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-generator</artifactId>
            <version>3.1.0</version>
        </dependency>
        <!--做多数据源-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
            <version>3.1.0</version>
        </dependency>
        <!-- 代码生成器模板 -->
        <dependency>
            <groupId>org.freemarker</groupId>
            <artifactId>freemarker</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!--commons-lang3-->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.6</version>
        </dependency>


        <!--解决Handler dispatch failed;nested exception is java.lang.NoClassDefFoundError: javax/xml/bind/DatatypeConverter-->
        <dependency>
            <groupId>javax.xml.bind</groupId>
            <artifactId>jaxb-api</artifactId>
            <version>2.3.0</version>
        </dependency>
        <dependency>
            <groupId>com.sun.xml.bind</groupId>
            <artifactId>jaxb-impl</artifactId>
            <version>2.3.0</version>
        </dependency>
        <dependency>
            <groupId>com.sun.xml.bind</groupId>
            <artifactId>jaxb-core</artifactId>
            <version>2.3.0</version>
        </dependency>
        <dependency>
            <groupId>javax.activation</groupId>
            <artifactId>activation</artifactId>
            <version>1.1.1</version>
        </dependency>
        <!--解决Handler dispatch failed;nested exception is java.lang.NoClassDefFoundError: javax/xml/bind/DatatypeConverter-->

        <!--达梦数据库驱动-->
        <!-- https://mvnrepository.com/artifact/com.dameng/Dm8JdbcDriver18 -->
	<dependency>
            <groupId>com.dameng</groupId>
            <artifactId>Dm8JdbcDriver18</artifactId>
            <version>8.1.1.49</version>
	</dependency>

</dependencies>

以上是整体项目使用打的架包，整合达梦数据库的重要驱动包为：

<!--达梦数据库驱动-->
<!-- https://mvnrepository.com/artifact/com.dameng/Dm8JdbcDriver18 -->
<dependency>
	<groupId>com.dameng</groupId>
	<artifactId>Dm8JdbcDriver18</artifactId>
	<version>8.1.1.49</version>
</dependency>

2. application.yml

application.yml文件的配置

spring:
  autoconfigure:
    #去除druid配置
    exclude: com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure
  datasource:
    #打开多数据源，加上上面的就可以实现多数据源的配置
    dynamic:
      primary: db_mysql # 配置默认数据库
      datasource:
        # 1. MySQL数据库配置
        db_mysql:
    	#打开多数据源，加上上面的就可以实现多数据源的配置
	#此处省略了MySQL的配置连接			
        #................
	#................
            # 合并多个DruidDataSource的监控数据
            use-global-data-source-stat: true
        # 1. MySQL数据库配置

        # 2. 达梦数据库[DM8]配置
        db_DM8:
          #达梦数据库driver类
          driver-class-name: dm.jdbc.driver.DmDriver
          #连接池
          type: com.alibaba.druid.pool.DruidDataSource
          #达梦数据库的连接地址 assets_DM为达梦的模式
          url: jdbc:dm://127.0.0.1:5236/DM_DB?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=utf-8
          #数据库账户
          username: 达梦数据库的账号
          #登录密码
          password: 达梦数据库自己设置的密码
          #连接池
          druid:
            # 通过connectProperties属性来打开mergeSql功能；慢SQL记录
            connection-properties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
            # 初始化大小,最小,最大
            initial-size: 5
            max-active: 50
            min-idle: 5
            # 配置获取连接等待超时时间
            max-wait: 80000
            # 打开PSCache，并且指定每个连接上PSCache的大小
            pool-prepared-statements: true
            max-pool-prepared-statement-per-connection-size: 20
            validation-query: SELECT 'x'
            validation-query-timeout: 60000
            test-on-borrow: true
            test-on-return: true
            test-while-idle: true
            # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
            time-between-eviction-runs-millis: 60000
            min-evictable-idle-time-millis: 300000
            log-abandoned: true
            remove-abandoned: true
            remove-abandoned-timeout: 1800
            filters: stat
        # 2. 达梦数据库[DM8]配置

	# 3. 如果自己需要，还可以配置更多的数据源


logging:
  level:
    org:
      springframework:
        boot:
          autoconfigure:
            logging: info

3. application-mybatisplus.yml

application-mybatisplus.yml文件为mybatisplus的相关配置信息，因为配置了多数据源的原因，如果需要配置不同的mapper扫描路径，则需要做相应的修改，如下：

mybatis-plus:
  global-config:
    db-config:
      id-type: auto
      field-strategy: not_empty
      table-underline: true
      db-type: mysql
      logic-delete-value: 1 # 逻辑已删除值(默认为 1)
      logic-not-delete-value: 0 # 逻辑未删除值(默认为 0)
  #这里做了不同数据源对应不同的目录，所以需要配置多个xml的路径信息
  mapper-locations: classpath:/mappers/db_MySQL/**.xml, classpath*:/mappers/db_DM8/**.xml

4. Druid-MySQL的配置

这是一开始配置的MySQL主数据源的Config

import com.baomidou.mybatisplus.core.injector.ISqlInjector;
import com.baomidou.mybatisplus.extension.injector.LogicSqlInjector;
import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
import com.baomidou.mybatisplus.extension.plugins.PerformanceInterceptor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Profile;

/***
 * MyBatisPlus配置类
 */
@Configuration
public class MyBatisPlusConfig {

    private final static Logger logger = LoggerFactory.getLogger(MyBatisPlusConfig.class);

    /***
     * 配置分页插件
     * @return
     */
    @Bean
    public PaginationInterceptor paginationInterceptor() {
        logger.debug("注册分页插件");
        return new PaginationInterceptor();
    }

    /***
     * SQL执行效率插件
     * @return
     */
    @Bean
    @Profile({"test"})// 设置 dev test 环境开启
    public PerformanceInterceptor performanceInterceptor() {
        return new PerformanceInterceptor();
    }

    /***
     * 逻辑删除用
     * @return
     */
    @Bean
    public ISqlInjector sqlInjector() {
        return new LogicSqlInjector();
    }

}

MyBatisPlus的配置即为以上的信息。

5. 修改主程序入口注解

对于多数据源，需要将 @SpringBootApplication(exclude = DataSourceAutoConfiguration.class ) 修改为 @SpringBootApplication(exclude = DruidDataSourceAutoConfigure.class )

主程序入口代码如下：

import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;


/***
 * 主程序启动类
 */
//DataSourceAutoConfiguration
@SpringBootApplication(exclude = {DruidDataSourceAutoConfigure.class})
//此为Mapper的对应需要扫描的包
@MapperScan( basePackages = {"com.mapper.db_MySQL", "com.mapper.db_DM8"})
@Configuration
@EnableAsync    //添加启动类 @EnableAsync
public class DM8Application {

    public static void main(String[] args) {
        SpringApplication.run(DM8Application.class, args);
    }

}

通过以上的配置信息，即可实现多数据源了，启动一下项目，如果出现以下的内容则表示多数据源配置成功了。

启动项目，表示配置成功的示意图


6. 使用达梦数据源测试

对于多数据源下，配置的有默认的数据源。yml配置的信息：

dynamic:
      primary: db_mysql  #配置默认数据库

当我们需要使用非默认数据源的时候，需要在对于的Service类的查询方法中注解上对于的数据源，其它的操作与普通的MySQL+MyBatis的操作一样。
使用达梦数据源的代码示例：

Service类

/***
 * 测试查询数据
 */
 @Override
 //在对应的操作方法上面配置上对应的数据源信息
 //使用  @DS 注解
 @DS("db_DM8")	
 public List<TableTestEntity> getSelectAll() {
 	return this.tableTestEntityMapper.getSelectAll();
 }

XML配置SQL信息

<select id="getSelectAll" resultMap="tableTestEntity">
	select * from "DM_DB"."TABLE_TEST" ;
</select>

测试可以查询到数据！成功！

上一篇： 负载均衡算法