概述
本人最近接到一个任务,将一个系统改成同时兼容Oracle和Postgresql(原来是仅支持Oracle)。虽然大部分的sql语句通用,但是还有许多语法存在差异,所以我们可以通过mybatis自身提供的databaseIdProvider解决这个问题,这里记录一下过程。
databaseId属性: 如果配置了 databaseIdProvider,MyBatis 会加载所有的不带 databaseId 或匹配当前 databaseId 的语句;如果带或者不带的语句都有,则不带的会被忽略。新增,修改和删除都有这个属性。
配置
pom依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--oracle-->
<dependency>
<groupId>com.oracle</groupId>
<artifactId>ojdbc6</artifactId>
<version>11.2.0.3</version>
</dependency>
<!--postgresql-->
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
<version>9.4.1212</version>
</dependency>
<!-- 集成mybatis -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.1</version>
</dependency>
<!--fastjson-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.16</version>
</dependency>
<!-- druid数据库连接池组件 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.10</version>
</dependency>
配置文件
application.yml
# 切换对应的环境 postgresql MysqL
spring:
profiles:
active: postgresql
# mybatis配置
mybatis:
mapper-locations: classpath:mapper/**/*.xml
type-aliases-package: com.valten.**.model
# showsql 控制台打印sql日志
logging:
level:
com:
valten:
dao: debug
application-MysqL.yml
# 端口
server:
port: 8001
# 数据源配置
spring:
datasource:
hikari:
jdbc-url: jdbc:MysqL://127.0.0.1:3306/test?&useSSL=false
driver-class-name: com.MysqL.jdbc.Driver
username: root
password: 123456
application-postgresql.yml
# 端口
server:
port: 8002
# 数据源配置
spring:
datasource:
hikari:
jdbc-url: jdbc:postgresql://127.0.0.1:5432/test
driver-class-name: org.postgresql.Driver
username: root
password: 123456
注意 SpringBoot1和2的数据原配置写法区别
数据源配置类
@Configuration
public class DataSourceConfig {
@Value("${mybatis.mapper-locations}")
private String mapperLocations;
@Primary
@Bean(name = "dataSource")
@ConfigurationProperties("spring.datasource.hikari")
public DataSource dataSource() {
return DataSourceBuilder.create().build();
}
@Bean
public JdbcTemplate jdbcTemplate() {
return new JdbcTemplate(dataSource());
}
@Bean
public DatabaseIdProvider databaseIdProvider() {
DatabaseIdProvider databaseIdProvider = new vendorDatabaseIdProvider();
Properties p = new Properties();
p.setProperty("Oracle", "oracle");
p.setProperty("MysqL", "MysqL");
p.setProperty("Postgresql", "postgresql");
p.setProperty("DB2", "db2");
p.setProperty("sql Server", "sqlserver");
databaseIdProvider.setProperties(p);
return databaseIdProvider;
}
@Primary
@Bean
public sqlSessionfactorybean sqlSessionfactorybean(@Qualifier("dataSource") DataSource dataSource) throws Exception {
sqlSessionfactorybean factorybean = new sqlSessionfactorybean();
factorybean.setDataSource(dataSource);
factorybean.setDatabaseIdProvider(databaseIdProvider());
factorybean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapperLocations));
return factorybean;
}
}
UserMapper.xml
<select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
select
<if test="_databaseId == 'oracle'">
account
</if>
<if test="_databaseId == 'postgresql'">
dep_code
</if>
from SYS_USER
where ID = #{id,jdbcType=CHAR}
</select>
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。