集成

pom.xml

<!--   达梦数据库     -->
<dependency>
    <groupId>com.dameng</groupId>
    <artifactId>Dm8JdbcDriver18</artifactId>
    <version>8.1.1.49</version>
</dependency>

<dependency>
    <groupId>com.dameng</groupId>
    <artifactId>DmDialect-for-hibernate5.0</artifactId>
    <version>8.1.1.49</version>
</dependency>

<dependency>
    <!--注意：只有这个版本的hibernate兼容达梦数据库 -->
    <groupId>org.hibernate</groupId>
    <artifactId>hibernate-core</artifactId>
    <version>5.3.18.Final</version>
</dependency>

application.yml

spring:
  datasource:
    url: jdbc:dm://127.0.0.1:5236?schema=xxxxx
    username: SYSDBA
    password: 123456789
    type: com.alibaba.druid.pool.DruidDataSource
    driverClassName: dm.jdbc.driver.DmDriver
    druid: # 记得将merge-sql相关关闭
  jpa:
    properties:
      hibernate:
        dialect: org.hibernate.dialect.DmDialect

Entity#id说明

@Id
@GeneratedValue(strategy = GenerationType.SEQUENCE)
private Integer id = 0;

# IDENTITY：mysql有效
# SEQUENCE：达梦有效

达梦配置 - 基础操作mapper

public interface DmSQLMapper {

    void on(@Param("tableName") String tableName);


    void off(@Param("tableName") String tableName);

}

// 对应的xml 
<update id="on">
    set IDENTITY_INSERT ${tableName} ON;
</update>

<update id="off">
    set IDENTITY_INSERT ${tableName} OFF;
</update>

达梦配置 - 自定义保存注解

@Documented
@Target({ElementType.PARAMETER,
        ElementType.METHOD,
        ElementType.TYPE_USE,
        ElementType.TYPE_PARAMETER})
@Retention(RetentionPolicy.RUNTIME)
public @interface DmSave {

    String[] className() default "";
}

达梦配置 - 保存监听

@Component
@Slf4j
public class DmListener {

    @Autowired
    private DmSQLMapper dmSQLMapper;


    /**
     * 在保存之前调用
     */
    @PrePersist
    public void prePersist(Object source){
        String name = source.getClass().getAnnotation(Table.class).name();

        log.info("表名: " + name);
        dmSQLMapper.on(name);
    }

    /**
     * 在保存之后调用
     */
    @PostPersist
    public void postPersist(Object source){
        String name = source.getClass().getAnnotation(Table.class).name();
        dmSQLMapper.off(name);
        log.info("表名: " + name);
    }

}

达梦配置 - 日志切面

@Aspect
@Component
@Slf4j
public class DmSystemLogAspect {

    @Autowired
    private DmSQLMapper dmSQLMapper;


    @Pointcut("@annotation(xxx.annotataion.DmSave)")
    public void controllerAspect(){

    }

    @Before("controllerAspect()")
    public void on(JoinPoint point){
        // 获取注解中的参数值
        MethodSignature methodSignature = (MethodSignature)point.getSignature();
        Method method = methodSignature.getMethod();

        // 获取注解Action
        DmSave annotation = method.getAnnotation(DmSave.class);

        // 获取了参数类名
        String[] strings = annotation.className();

        if (strings.length > 0){
            // 进行达梦数据库on操作
            for (String tableName : strings) {
                log.info("开启类名" + tableName);

                dmSQLMapper.on(tableName);
            }
        }
    }
}

出现的问题

仅当指定列列表，且SET IDENTITY_INSERT为ON时

说明

默认情况下，达梦数据库是不允许对自增的列（例如：id）进行插入操作的。如果使用mybatis手动sql进行insert，应该不会出现很大的问题。但是，使用 jpa 进行save或者saveAll的都是实体，默认是携带id字段的（虽然为null或者0），但是还是报错。

解决

在保存之前，使用语句 set IDENTITY_INSERT ${tableName} ON 即可解决问题，就像上面的mapper文件一样，每次save或者saveAll之前手动调用一次，或者使用监听器或者切面统一进行处理

在同一个数据库连接中，同时只能针对一张表进行该操作的开启，如果开启下一张表，那么上一张会自动关闭

另外一种情况

如果使用了该语句，还没解决问题，注意是否在方法或者类上加了事务注解（@Transactional）
例如：

@Transactional(rollbackFor = Exception.class)
public void saveData(){
	dmSQLMapper.on("user");
	userRepository.save(user);
	
	dmSQLMapper.on("user_role");
	userRoleRepository.saveAll(userRoleList);
}

在上面这个案例中，虽然save或saveAll之前，都对相应的表进行了开启，但是执行时，还是会报出 SET IDENTITY_INSERT 的错误。
这是因为在开启了事务之后，sql语句的执行顺序发生了变化，真正需要保存数据的sql放到了对数据不产生影响的sql的后面，而且这种错误很难发现，在控制台是打印不出来的，只有在开启了SQL打印的情况下，跟踪每一条sql才会发现。

认为SQL执行的顺序：