mybatis连接phoenix操作hbase

雨点打透心脏的1/2处 2022-03-09 18:38 694阅读 0赞

直接上代码

@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