一、技术选型
springboot2.4+、mybatisplus3.4+、mysql5.7+、redis3.0+
二、编写目的
如果产品开发默认数据库采用mysql，但是当客户提出数据库需要采用Sqlserver或者Oracle以及其他国产数据库时，程序中就不能出现方言性的sql语句，否则程序在个性化的sql上做不到数据库兼容，因此要想产品能兼容多种数据类型，则在编码时就要考虑将个性化的方言sql抽离出来。
三、数据库兼容方案
实现思路：
（1）应用启动时要根据数据源知道当前链接的数据库类型，并存到全局变量
（2）根据数据库类型自动设置mybatis-plus分页方言
（3）个性化方言实现不要在主业务中耦合（如：if mysql … else if sqlserver…）
（4）个性化方言实现可以多种数据库类型复用（如mysql、mariadb可以用一种实现）
（5）个性化方言实现类能根据数据库类型自动注入
代码实现：
根据url获取数据库类型
import com.baomidou.mybatisplus.annotation.DbType;import com.baomidou.mybatisplus.extension.toolkit.JdbcUtils;public class Dialect { private static DbType dbType = null; private static final String DB_URL = "spring.datasource.url"; public synchronized static DbType getDbType(){ if(dbType == null){ String url = PropUtil.getValue(DB_URL); dbType = JdbcUtils.getDbType(url); } return dbType; }}自定义注解（实现方言实现的选择注入）
import com.baomidou.mybatisplus.annotation.DbType;import org.springframework.context.annotation.Conditional;import java.lang.annotation.*;@Retention(RetentionPolicy.RUNTIME)@Target({ ElementType.TYPE, ElementType.METHOD })@Documented@Conditional(DbTypeCondition.class)public @interface ConditionalOnDbType { DbType[] types() default DbType.OTHER;}注解条件实现
import com.baomidou.mybatisplus.annotation.DbType;import org.springframework.context.annotation.Condition;import org.springframework.context.annotation.ConditionContext;import org.springframework.core.type.AnnotatedTypeMetadata;public class DbTypeCondition implements Condition { @Override public boolean matches(ConditionContext context, AnnotatedTypeMetadata metadata) { DbType[] dbTypes = (DbType[]) metadata.getAnnotationAttributes(ConditionalOnDbType.class.getName()).get("types"); for(DbType dbType : dbTypes){ if(Dialect.getDbType().equals(dbType)){ return true; } } return false; }}1、mybatisplus配置
分页方言配置
@Configurationpublic class MybatisPlusConfig { @Bean public MybatisPlusInterceptor mybatisPlusInterceptor() { MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); //添加分页插件 interceptor.addInnerInterceptor(new PaginationInnerInterceptor(Dialect.getDbType())); return interceptor; }}2、数据库YAML配置
数据源配置上注意驱动和URL的替换。
mysql配置
spring: datasource: driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://ip:3306/db?serverTimezone=Asia/Shanghai&useUnicode=true username: username password: password hikari: ## 最小空闲连接数 minimum-idle: 5 ## 最大连接数 maximum-pool-size: 20 ## 自动提交 auto-commit: true ## 连接池名称 pool-name: TmcHikariCP ## 超时时间(ms) connection-timeout: 30000sqlserver配置
spring: datasource: driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver url: jdbc:sqlserver://ip:1433;databasename=db_schema;trustServerCertificate=true;integratedSecurity=false; username: username password: password hikari: ## 最小空闲连接数 minimum-idle: 5 ## 最大连接数 maximum-pool-size: 20 ## 自动提交 auto-commit: true ## 连接池名称 pool-name: TmcHikariCP ## 超时时间(ms) connection-timeout: 30000 3、应用举例
方言抽离接口
public interface DialectService<T> { void conditon(QueryWrapper<T> queryWrapper, Map<String, Clazz> attrMap,Object k,Object v);}Mysql方言实现
import com.baomidou.mybatisplus.annotation.DbType;import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;import lombok.extern.slf4j.Slf4j;import org.springframework.stereotype.Service;import java.util.Map;@Slf4j@Service@ConditionalOnDbType(types = {DbType.MYSQL,DbType.MARIADB})public class MysqlFormDataDialectServiceImpl implements FormDataDialectService<FormDataEntity> { @Override public void conditon(QueryWrapper<FormDataEntity> queryWrapper, Map<String, Clazz> attrMap, Object k, Object v) { try { //替换时间类型判断（时间查询为时间段） Clazz.Format format = attrMap.get(k).getFormat(); if(Clazz.Format.DateTime.equals(format) || Clazz.Format.Date.equals(format)){ String[] dateArray = ObjectMapperHelper.mapper().readValue(v.toString(), String[].class); queryWrapper.ge("attr_json->'$." + k + "'", dateArray[0]); queryWrapper.lt("attr_json->'$." + k + "'", dateArray[1]); }else { queryWrapper.eq("attr_json->'$." + k + "'", v); } }catch (Exception e){ log.error("form data query k:{},v:{} error:{}",k,v,e.getMessage()); } }}Sqlserver方言实现
import com.baomidou.mybatisplus.annotation.DbType;import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;import lombok.extern.slf4j.Slf4j;import org.springframework.stereotype.Service;import java.util.Map;@Slf4j@Service@ConditionalOnDbType(types = {DbType.SQL_SERVER2005,DbType.SQL_SERVER})public class SqlServerFormDataDialectServiceImpl implements FormDataDialectService<FormDataEntity> { @Override public void conditon(QueryWrapper<FormDataEntity> queryWrapper, Map<String, Clazz> attrMap, Object k, Object v) { try { //替换时间类型判断（时间查询为时间段） Clazz.Format format = attrMap.get(k).getFormat(); if(Clazz.Format.DateTime.equals(format) || Clazz.Format.Date.equals(format)){ String[] dateArray = ObjectMapperHelper.mapper().readValue(v.toString(), String[].class); queryWrapper.ge("JSON_VALUE(attr_json, '$." + k + "')", dateArray[0]); queryWrapper.lt("JSON_VALUE(attr_json, '$." + k + "')", dateArray[1]); }else { queryWrapper.eq("JSON_VALUE(attr_json, '$." + k + "')", v); } }catch (Exception e){ log.error("form data query k:{},v:{} error:{}",k,v,e.getMessage()); } }}4、数据库脚本转换
最后注意数据库脚本从mysql到sqlserver的转换，可以用微软的工具Microsoft SQL Server Migration Assistant for MySQL，
可参照官网实现。
下载链接：https://www.microsoft.com/en-us/download/details.aspx?id=54257&6B49FDFB-8E5B-4B07-BC31-15695C5A2143=1
来源地址：https://blog.csdn.net/little_pig_lxl/article/details/130485475
