美文网首页
spring boot + mybatis 多数据源及连表查询(

spring boot + mybatis 多数据源及连表查询(

作者: 蒲编 | 来源:发表于2017-07-09 20:29 被阅读0次

刚从python转Java,马上就开始写spring boot了,再写的时候遇到了很多问题,记一下。

首先是连接数据库的工具,我一开始学的时候是用的jdbc或hibernate,但我的项目的需求是这样的:
数据库的表已经有了,而且来自于两个不同的数据库,我只要老老实实取出来返回给前端就好了。

考虑到jdbc大家用的少,而hibernate选择update模式可能你一个字段没配上就gg了,呃,然后想到Mybatis有mybatis generator代码生成工具,而且字段可以选自己需要的写上就可以了,所以最后用的Mybatis。

biuld.gradle文件很简单我就不贴了,网上都有。
首先是多数据源,application.properties是这样的:

spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.ncuhomeblog.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.ncuhomeblog.url=jdbc:mysql://127.0.0.1:3306/ncuhomeblog?useSSL=false
spring.datasource.ncuhomeblog.username=root
spring.datasource.ncuhomeblog.password=123456

spring.datasource.ncuhomediary.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.ncuhomediary.url=jdbc:mysql://127.0.0.1:3306/ncuhomedairy?useSSL=false
spring.datasource.ncuhomediary.username=root
spring.datasource.ncuhomediary.password=123456

这里先定义了两个数据源,然后在config文件里:

@Configuration
@ConfigurationProperties("spring.datasource.ncuhomediary")
@MapperScan(basePackages = "cn.ncuhomer.mapper.ncuhomediary", sqlSessionFactoryRef = "ncuhomediarySessionFactory")
public class NcuhomeDiaryDatasSourceConfig {
    private static final Logger log = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());

    @NotNull
    private String username;

    @NotNull
    private String password;

    @NotNull
    private String url;

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public String getUrl() {
        return url;
    }

    public void setUrl(String url) {
        this.url = url;
    }

    @Bean
    public DataSource ncuhomeDairyDataSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl(url);
        dataSource.setUsername(username);
        dataSource.setPassword(password);
        return dataSource;
    }

    @Bean(name = "ncuhomediarySessionFactory")
    public SqlSessionFactory sqlSessionFactoryBean() throws Exception {

        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();

        //Can no longer use application.properties for mybatis configuration settings, so this is a hack for
        //application.properties: mybatis.configuration.map-underscore-to-camel-case=true
        org.apache.ibatis.session.Configuration ibatisConfiguration = new org.apache.ibatis.session.Configuration();
        ibatisConfiguration.setMapUnderscoreToCamelCase(true);
        sqlSessionFactoryBean.setConfiguration(ibatisConfiguration);

        sqlSessionFactoryBean.setDataSource(ncuhomeDairyDataSource());
        return sqlSessionFactoryBean.getObject();
    }
}

这里的@ConfigurationProperties("spring.datasource.ncuhomediary")是自动把属性文件的属性赋值给这个类的属性,一个一个@Value效果也是一样的。

另一个config也类似,只是不需要bean的名字以及sqlSessionFactoryRef,然后把mapperscan的扫描的地方换一下,两个方法上加@Primary就可以了。
加了@Primary就是告诉程序这是主数据库,先搞这,不是主数据库的得让程序知道mapper文件所对应的数据源是啥,所以Bean要带个名字,不然它就默认是主数据源了。

mapper文件在连表查询的时候一起讲。

mybatis其实完全可以用注释代替xml的。这里的需求是,posts这张表,只存了作者的id(created_by),我必须去users里根据id把作者的名字取出来,下面先给代码:

@Mapper
public interface NcuhomeBlogMapper {

    @Select("select * from posts where status='published' and visibility='public' order by updated_at desc limit 4")
    @Results({
            @Result(property = "title", column = "title"),
            @Result(property = "url", column = "slug"),
            @Result(property = "cover", column = "html"),
            @Result(property = "time", column = "updated_at"),
            @Result(property = "author", column = "created_by", one = @One(select = "cn.ncuhomer.mapper.ncuhomebloguser.NcuhomeBlogUserMapper.findById"))
    })
    public List<NcuhomeBlog> selectByCondition();
}
@Mapper
public interface NcuhomeBlogUserMapper {
    @Select("select * from users where id=#{id}")
    @Results({
            @Result(property = "name", column = "name")
    })
    public NcuhomeBlogUser findById(@Param(value = "id") Integer id);
}

就是@one的简单运用,这里要注意@one的那一行的@property,它的author属性的类型是一个author实体类。

这里再解释一下,这里连表查询,就是上面那个先把很多东西select出来,然后column再把craeted_by字段挑出来,传到@0ne对应的那个映射接口,它接收一个id,然后根据id查,最后把name字段筛选出来给上面那个映射接口的author属性,完成了连接查询。

相关文章

网友评论

      本文标题:spring boot + mybatis 多数据源及连表查询(

      本文链接:https://www.haomeiwen.com/subject/fprehxtx.html