一，SpringBoot整合Mybatis
MyBatis 是一款优秀的持久层框架，它支持定制化 SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。MyBatis 可以使用简单的 XML 或注解来配置和映射原生信息，将接口和 Java 的 POJOs(Plain Old Java Objects,普通的 Java对象)映射成数据库中的记录。
1）MyBATIS 目前提供了三种语言实现的版本，包括：Java、.NET以及Ruby。（我主要学习java，就讲java的使用
2）它提供的持久层框架包括SQL Maps和Data Access Objects（DAO）。
3）mybatis与hibernate的对比？
mybatis提供一种“半自动化”的ORM实现。这里的“半自动化”，是相对Hibernate等提供了全面的数据库封装机制的“全自动化”ORM实现而言，“全自动”ORM实现了POJO和数据库表之间的映射，以及 SQL 的自动生成和执行。而mybatis的着力点，则在于POJO与SQL之间的映射关系。
第一步，引入Spring Boot 依赖
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.1.1</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
第二步，在application.properties中配置连接数据库相关配置
spring.datasource.url=jdbc:mysql://localhost:3306/test
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
第三步，加入Mapper层，Service层
mapper层：
package com.crisp.mapper;
import com.crisp.entity.User;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
public interface UserMapper {
@Select("SELECT * FROM USERS WHERE NAME = #{name}")
User findByName(@Param("name") String name);
@Insert("INSERT INTO USERS(NAME, AGE) VALUES(#{name}, #{age})")
int insert(@Param("name") String name, @Param("age") Integer age);
}
Service层：
package com.crisp.service;
import com.crisp.mapper.UserMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
@Slf4j
public class UserService {
@Autowired
private UserMapper userMapper;
public int insertUser(String name,Integer age){
int result=userMapper.insert(name,age);
log.info("{}",result);
return result;
}
}
第四步，在启动主程序中加入mapper扫包范围 @MapperScan(basePackages = {"com.crisp"})
图片1.png
二，@Transactional 整合事务
事务管理对于企业应用来说是至关重要的，即使出现异常情况，它也可以保证数据的一致性，当一个事务中有异常发生，通过事务可以回滚操作。
第一步，直接添加@Transactional注解即可实现
@Service
@Slf4j
@Transactional
public class UserService {
@Autowired
private UserMapper userMapper;
public int insertUser(String name,Integer age){
int result=userMapper.insert(name,age);
int i=1/age;
log.info("{}",result);
return result;
}
}
三，整合多数据源，使用分包拆分多数据源
一个项目中存在多个数据源，一般可以采用两种方式划分，分包和注解
注解：在每个方法上加注解指向数据源
分包：拆分为多个包，每个包对应不同的数据源，类似把不同的业务打成不同的jar包
第一步，我们分两个包，分别建立mapper和service
image.png
源代码：
public interface UserMapperTest01 {
@Select("SELECT * FROM USERS WHERE NAME = #{name}")
User findByName(@Param("name") String name);
@Insert("INSERT INTO USERS(NAME, AGE) VALUES(#{name}, #{age})")
int insert(@Param("name") String name, @Param("age") Integer age);
}
public class UserServiceTest01 {
@Autowired
private UserMapperTest01 userMapperTest01;
public int insertUser(String name,Integer age){
int result=userMapperTest01.insert(name,age);
log.info("{}",result);
return result;
}
}
第二步，配置文件中配置两个数据源
###datasource1
spring.datasource.test1.driver-class-name = com.mysql.jdbc.Driver
spring.datasource.test1.jdbc-url = jdbc:mysql://localhost:3306/test01?useUnicode=true&characterEncoding=utf-8
spring.datasource.test1.username = root
spring.datasource.test1.password = 123456
###datasource2
spring.datasource.test2.driver-class-name = com.mysql.jdbc.Driver
spring.datasource.test2.jdbc-url = jdbc:mysql://localhost:3306/test02?useUnicode=true&characterEncoding=utf-8
spring.datasource.test2.username = root
spring.datasource.test2.password = 123456
第三步，新增数据源配置
image.png
// DataSource01
@Configuration // 注册到springboot容器中
@MapperScan(basePackages = "com.crisp.test01", sqlSessionFactoryRef = "test1SqlSessionFactory")
public class DataSource1Config {
@Bean(name = "test1DataSource")
@ConfigurationProperties(prefix = "spring.datasource.test1")
public DataSource testDataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "test1SqlSessionFactory")
public SqlSessionFactory testSqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource)
throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dataSource);
// bean.setMapperLocations(
// new
// PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/test1/*.xml"));
return bean.getObject();
}
@Bean(name = "test1TransactionManager")
public DataSourceTransactionManager testTransactionManager(@Qualifier("test1DataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Bean(name = "test1SqlSessionTemplate")
public SqlSessionTemplate testSqlSessionTemplate(
@Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
}
拷贝DataSource1Config复制成DataSource2Config，将test1替换为test2
第四步，创建Controller测试效果
@RestController
public class MybatisMutiliDataSourceController {
@Autowired
private UserServiceTest01 userServiceTest01;
@RequestMapping("/addUser01")
public Integer insertUser01(String name,Integer age){
return userServiceTest01.insertUser(name,age);
}
@Autowired
private UserServiceTest02 userServiceTest02;
@RequestMapping("/addUser02")
public Integer insertUser02(String name,Integer age){
return userServiceTest02.insertUser(name,age);
}
}
image.png
image.png
image.png
image.png
四，多数据源事务管理
在整合多数据源配置多数据源时，存在多个事务管理器
@Bean(name = "test1TransactionManager")
public DataSourceTransactionManager testTransactionManager(@Qualifier("test1DataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Bean(name = "test2TransactionManager")
public DataSourceTransactionManager testTransactionManager(@Qualifier("test2DataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
因此配置事务时需要在service中指定使用哪个事务管理器
@Transactional(transactionManager = "test1TransactionManager")
public int insertUser(String name,Integer age){
