mybatis连接phoenix操作hbase

直接上代码

@Configuration
public class HBaseConfig {
 
    @Primary
    @Bean
    @ConfigurationProperties(prefix="spring.datasource.druid.mybatis")
    public DataSource druidDataSource() {
        return DruidDataSourceBuilder.create().build();
    }
 
    @Bean
    @ConfigurationProperties(prefix="spring.datasource.druid.hbase")
    public DataSource phoenixDataSource() {
        return DruidDataSourceBuilder.create().build();
    }
 
    @Bean
    public JdbcTemplate jdbcTemplate() {
        JdbcTemplate jdbcTemplate = new JdbcTemplate();
        jdbcTemplate.setDataSource(phoenixDataSource());
        jdbcTemplate.setLazyInit(false);
        return jdbcTemplate;
    }
 
    @Configuration
    @MapperScan(basePackages = {"com.tiku.dao"}, sqlSessionFactoryRef = "sqlSessionFactory0")
    @EnableConfigurationProperties(MybatisProperties.class)
    public class DataSourceConfig0 {
 
        @Autowired
        private MybatisProperties mybatisProperties;
 
        @Bean
        public SqlSessionFactory sqlSessionFactory0() {
            SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
            sqlSessionFactoryBean.setDataSource(druidDataSource());
            if (mybatisProperties != null && mybatisProperties.getConfiguration() != null) {
                sqlSessionFactoryBean.setConfiguration(mybatisProperties.getConfiguration());
            }
            if (mybatisProperties != null && mybatisProperties.getConfigurationProperties() != null) {
                sqlSessionFactoryBean.setConfigurationProperties(mybatisProperties.getConfigurationProperties());
            }
            try {
                return sqlSessionFactoryBean.getObject();
            } catch (Exception e) {
                e.printStackTrace();
            }
            return null;
        }
 
        @Bean
        public SqlSessionTemplate sqlSessionTemplate0() {
            SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory0()); // 使用上面配置的Factory
            return template;
        }
    }
 
    @Configuration
    @MapperScan(basePackages = {"com.tiku.hbase"}, sqlSessionFactoryRef = "sqlSessionFactory1")
    public class DataSourceConfig1 {
        @Bean
        public SqlSessionFactory sqlSessionFactory1() {
            SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
            sqlSessionFactoryBean.setDataSource(phoenixDataSource());
            try {
                return sqlSessionFactoryBean.getObject();
            } catch (Exception e) {
                e.printStackTrace();
            }
            return null;
        }
 
        @Bean
        public SqlSessionTemplate sqlSessionTemplate1() {
            SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory1());
            return template;
        }
    }
 
}

这种方式就不需要通过原生的jdbc连接操作hbase了, 刚弄的时候觉得这太坑了吧,后来想着,phoenix是实现了jdbc驱动操作hbase,所以可以通过mybatis配置多数据源就能达到同时操作mysql和hbase