目录
一、达梦数据库的安装和使用
1、达梦数据库下载
2、Windows环境安装达梦数据库
二、MYSQL数据库 迁移至 达梦数据库
1、DM控制台工具：Console
2、DM数据迁移工具：DTS
2、Maven导入达梦数据库驱动包
3、表的实体类映射。【访问形式：模式名.表名】
4、XML文件：查询表【模式名.表名】
5、MYSQL字段类型与DM数据类型的转换。【DM：达梦数据库】
6、达梦数据库分页插件
7、SQL适配关键字列名
一、达梦数据库的安装和使用
1、达梦数据库下载
产品下载 | 达梦数据库
2、Windows环境安装达梦数据库
参考文章： Windows环境安装达梦数据库_达梦数据库安装-CSDN博客
二、MYSQL数据库 迁移至 达梦数据库
参考文章：MySQL数据迁移至达梦数据库_mysql迁移达梦-CSDN博客
在安装的tool目录下，查找相关的工具：
1、DM控制台工具：Console
服务器配置又该有两种方式：①DM控制台工具修改；②配置文件修改。
方法一：服务器配置：设置系统兼容性(DM控制台工具），兼容MySQL
方法二：（1）查找dm.ini文件
（2）dm.ini修改【#compatibility】的【COMPATIBLE_MODE】=4
(3)重启Dameng服务
2、DM数据迁移工具：DTS
在这里操作：MYSQL数据库迁移至DM数据库
注意：当迁移过程中出现下面问题时，如有触发器或者外键,需要先关掉触发器和外键,然后进行迁移,不然会导致迁移失败。
MYSQL的数据表转换成DM的数据表时，点击转换按钮。如下：
设置【1：迁移策略选项】
设置【2：列映射选项】
3、添加用户：如果导入的DM数据库需要和MYSQL的用户一样，添加ROOT用户。
三、Spring项目整合达梦数据库
1、配置java项目连接达梦，切换数据连接驱动
2、Maven导入达梦数据库驱动包
3、表的实体类映射。【访问形式：模式名.表名】
4、XML文件：查询表【模式名.表名】
5、MYSQL字段类型与DM数据类型的转换。【DM：达梦数据库】
package com.company.common.core.annotation;
/**
* 数据库类型
*
* @author kally
* @date 2023/12/13
*/
public enum DbType {
/**
* 数据库类型（类型，描述）
*/
MYSQL("mysql", "MySql数据库"),
MARIADB("mariadb", "MariaDB数据库"),
ORACLE("oracle", "Oracle11g及以下数据库(高版本推荐使用ORACLE_NEW)"),
ORACLE_12C("oracle12c", "Oracle12c+数据库"),
DB2("db2", "DB2数据库"),
H2("h2", "H2数据库"),
HSQL("hsql", "HSQL数据库"),
SQLITE("sqlite", "SQLite数据库"),
POSTGRE_SQL("postgresql", "Postgre数据库"),
SQL_SERVER2005("sqlserver2005", "SQLServer2005数据库"),
SQL_SERVER("sqlserver", "SQLServer数据库"),
DM("dm", "达梦数据库"),
XU_GU("xugu", "虚谷数据库"),
KINGBASE_ES("kingbasees", "人大金仓数据库"),
PHOENIX("phoenix", "Phoenix HBase数据库"),
GAUSS("zenith", "Gauss 数据库"),
CLICK_HOUSE("clickhouse", "clickhouse 数据库"),
GBASE("gbase", "南大通用(华库)数据库"),
GBASE_8S("gbase-8s", "南大通用数据库 GBase 8s"),
@Deprecated
GBASEDBT("gbasedbt", "南大通用数据库"),
@Deprecated
GBASE_INFORMIX("gbase 8s", "南大通用数据库 GBase 8s"),
SINODB("sinodb", "星瑞格数据库"),
OSCAR("oscar", "神通数据库"),
SYBASE("sybase", "Sybase ASE 数据库"),
OCEAN_BASE("oceanbase", "OceanBase 数据库"),
FIREBIRD("Firebird", "Firebird 数据库"),
HIGH_GO("highgo", "瀚高数据库"),
CUBRID("cubrid", "CUBRID数据库"),
GOLDILOCKS("goldilocks", "GOLDILOCKS数据库"),
CSIIDB("csiidb", "CSIIDB数据库"),
SAP_HANA("hana", "SAP_HANA数据库"),
IMPALA("impala", "impala数据库"),
VERTICA("vertica", "vertica数据库"),
XCloud("xcloud", "行云数据库"),
REDSHIFT("redshift", "亚马逊redshift数据库"),
OPENGAUSS("openGauss", "华为 opengauss 数据库"),
TDENGINE("TDengine", "TDengine数据库"),
INFORMIX("informix", "Informix数据库"),
UXDB("uxdb", "优炫数据库"),
LEALONE("lealone", "Lealone数据库"),
OTHER("other", "其他数据库");
private final String db;
private final String desc;
public static DbType getDbType(String dbType) {
DbType[] var1 = values();
int var2 = var1.length;
for (int var3 = 0; var3 < var2; ++var3) {
DbType type = var1[var3];
if (type.db.equalsIgnoreCase(dbType)) {
return type;
}
}
return OTHER;
}
public String getDb() {
return this.db;
}
public String getDesc() {
return this.desc;
}
/**
* 数据库类型
*
* @param db 数据库
* @param desc 描述
*/
private DbType(final String db, final String desc) {
this.db = db;
this.desc = desc;
}
}
6、达梦数据库分页插件
7、SQL适配关键字列名
mysql使用反引号来区分列名和关键字；达梦数据库使用双引号来区分；实体类映射字段之前的修改。
MybatisPlusConfig.java文件再加入下列代码,复制即可。
@Bean
public DmFieldCustomizer getDmFieldCustomizer() {
return new DmFieldCustomizer();
}
/**
* 在mybatisPlus加载进spring容器之前自定义某些配置
*
* @author HetFrame
*/
public static class DmFieldCustomizer implements MybatisPlusPropertiesCustomizer {
public DmFieldCustomizer() {
log.info("加载DmFieldCustomizer...");
}
@SneakyThrows
@Override
public void customize(MybatisPlusProperties properties) {
// 使用达梦数据库
if (Arrays.toString(properties.getMapperLocations()).contains("dm")) {
log.info("使用达梦数据库");
//实体类的class
List<Class<?>> classList = new ArrayList<>();
PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
//找到所有实体类的class
Resource[] resources = resolver.getResources("classpath*:com/**/entity/**/*.class");
for (Resource res : resources) {
// 先获取resource的元信息，然后获取class元信息，最后得到 class 全路径
String clsName = new SimpleMetadataReaderFactory().getMetadataReader(res).getClassMetadata().getClassName();
// 通过名称加载
Class<?> clazz = Class.forName(clsName);
classList.add(clazz);
}
classList.forEach(e -> {
List<Field> list = TableInfoHelper.getAllFields(e);
list.forEach(field -> {
TableField tableField = field.getAnnotation(TableField.class);
String metaColName;
if (tableField != null && StringUtils.isNotBlank(metaColName = tableField.value()) && metaColName.contains("`")) {
String newColName = metaColName.replace("`", "\"");
InvocationHandler invocationHandler = Proxy.getInvocationHandler(tableField);
try {
Field memberValues = invocationHandler.getClass().getDeclaredField("memberValues");
memberValues.setAccessible(true);
Map memberValuesMap = (Map) memberValues.get(invocationHandler);
memberValuesMap.put("value", newColName);
log.info("将实体类映射字段{}修改为{}", metaColName, newColName);
} catch (NoSuchFieldException | IllegalAccessException exception) {
throw new RuntimeException(exception);
}
}
});
});
} else {
log.info("使用mysql数据库");
}
}
}package com.company.common.framework.mybatis;
import com.baomidou.mybatisplus.autoconfigure.MybatisPlusProperties;
/**
* MybatisPlusPropertiesCustomizer 用于在读取 properties 之后进行一些自定义操作
*
* @author kally
* @date 2023/12/13
*/
public interface MybatisPlusPropertiesCustomizer {
/**
* mysql中我们使用反引号来区分列名和关键字；但在达梦数据库中，使用双引号来区分。
* 而如果创建实体类在注解 @TableField 中使用了反引号例如 @TableField(`range`)，
* 这种我们改了的话，mysql 就用不了，不改达梦就用不了。所以从代码入手，在启动时用反射修改值。
* 达梦数据库某些关键字例如 audit，在 mysql 中不是关键字的，需要手动设置 @TableField(`audit`)。
*/
/**
* MybatisPlusPropertiesCustomizer 用于在读取 properties 之后进行一些自定义操作
*
* @param properties {@link MybatisPlusProperties}
*/
void customize(MybatisPlusProperties properties);
}