Spring boot 整合Mybatis

引入依赖

    org.springframework.boot
    spring-boot-starter-web


    org.mybatis.spring.boot
    mybatis-spring-boot-starter
    2.1.4



    mysql
    mysql-connector-java
    runtime

数据库

create table user
(
    id       int auto_increment
        primary key,
    username varchar(255) null,
    address  varchar(255) null
);

INSERT INTO db_01.user (id, username, address) VALUES (1, 'javaboy', 'www.javaboy.org');
INSERT INTO db_01.user (id, username, address) VALUES (2, 'itboyhub', 'www.itboyhub.com');

User

@Data
public class User {
    private Long id;
    private String username;
    private String address;

}

UserMapper

public interface UserMapper {
    @Select("select * from user where id=#{id}")
    User getUserById(Long id);

    @Results({
            @Result(property = "address",column = "address1")
    })
    @Select("select * from user")
    List getAllUsers();

    @Insert("insert into user (username,address1) values (#{username},#{address})")
    @SelectKey(statement = "select last_insert_id()",keyProperty = "id",before = false,resultType = Long.class)
    Integer addUser(User user);

    @Delete("delete from user where id=#{id}")
    Integer deleteById(Long id);

    @Update("update user set username=#{username} where id=#{id}")
    Integer updateById(String username, Long id);
}

测试

@Autowired
UserMapper userMapper;

@Test
void contextLoads() {
    User user = userMapper.getUserById(9L);
    System.out.println(user);
}

@Test
void tes1() {
    List users = userMapper.getAllUsers();
    System.out.println(users);
}

@Test
void test2() {
    User user = new User();
    user.setUsername("zhangsan");
    user.setAddress("shenzhen");
    userMapper.addUser(user);
    System.out.println("user.getId() = " + user.getId());
}

@Test
void test3() {
    userMapper.deleteById(12L);
    userMapper.updateById("123", 11L);
}

Xml 方式

public interface UserMapper2 {
    User getUserById(Long id);
    List getAllUsers();
    Integer addUser(User user);
    Integer deleteById(Long id);
    Integer updateById(String username, Long id);
}

    
        
        
        
    

    
        select * from user where id=#{id};
    

    
        select * from user ;
    

    
        insert into user (username,address1) values (#{username},#{address});
    

    
        delete from user where id=#{id}
    
    
        update user set username = #{username} where id=#{id};
    

测试

@Autowired
UserMapper2 userMapper2;
@Test
void test4() {
    User user = userMapper2.getUserById(9L);
    System.out.println("user = " + user);
    List allUsers = userMapper2.getAllUsers();
    System.out.println("allUsers = " + allUsers);
    User u = new User();
    u.setUsername("lisi");
    u.setAddress("guangzhou");
    userMapper2.addUser(u);
    System.out.println(u.getId());
    userMapper2.deleteById(9L);
    userMapper2.updateById("zhangsan", 4L);
}

项目结构如图

application.properties

spring.datasource.one.jdbcUrl=jdbc:mysql:///db_01?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
spring.datasource.one.username=root
spring.datasource.one.password=666666

spring.datasource.two.jdbcUrl=jdbc:mysql:///db_02?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
spring.datasource.two.username=root
spring.datasource.two.password=666666

User

@Data
public class User {
    private Long id;
    private String username;
    private String address;
}

UserMapper1

public interface UserMapper1 {
    List getAllUsers();
}

UserMapper1.xml

    
        select * from user;
    


 
UserMapper2
 
public interface UserMapper2 {
    List getAllUsers();
}
 
UserMapper2.xml
 



    
        select * from user;
    

数据源配置

@Configuration
public class DataSourceConfig {
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.one")
    DataSource dsOne() {
        return new HikariDataSource();
    }
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.two")
    DataSource dsTwo() {
        return new HikariDataSource();
    }
}

配置数据库1

@Configuration
@MapperScan(basePackages = "org.javaboy.mybatismulti.mapper1",
        sqlSessionFactoryRef = "sqlSessionFactory1",
        sqlSessionTemplateRef = "sqlSessionTemplate1")
public class MyBatisConfigOne {
    @Autowired
    @Qualifier("dsOne")
    DataSource ds;

    @Bean
    SqlSessionFactory sqlSessionFactory1() {
        SqlSessionFactory sqlSessionFactory = null;
        try {
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(ds);
            sqlSessionFactory = bean.getObject();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return sqlSessionFactory;
    }

    @Bean
    SqlSessionTemplate sqlSessionTemplate1() {
        return new SqlSessionTemplate(sqlSessionFactory1());
    }
}

配置数据2

@Configuration
@MapperScan(basePackages = "org.javaboy.mybatismulti.mapper2",sqlSessionFactoryRef = "sqlSessionFactory2",sqlSessionTemplateRef = "sqlSessionTemplate2")
public class MyBatisConfigTwo {
    @Autowired
    @Qualifier("dsTwo")
    DataSource ds;

    @Bean
    SqlSessionFactory sqlSessionFactory2() {
        SqlSessionFactory sqlSessionFactory = null;
        try {
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(ds);
            sqlSessionFactory = bean.getObject();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return sqlSessionFactory;
    }

    @Bean
    SqlSessionTemplate sqlSessionTemplate2() {
        return new SqlSessionTemplate(sqlSessionFactory2());
    }
}

测试

@SpringBootTest
class MybatismultiApplicationTests {

    @Autowired
    UserMapper1 userMapper1;
    @Autowired
    UserMapper2 userMapper2;
    @Test
    void contextLoads() {
        System.out.println("userMapper1.getAllUsers() = " + userMapper1.getAllUsers());
        System.out.println("userMapper2.getAllUsers() = " + userMapper2.getAllUsers());
    }

}