1. 說明

presto并不能算是數(shù)據(jù)源朵逝，它只是一個(gè)數(shù)據(jù)查詢引擎窑业，通過presto集成多種數(shù)據(jù)源翔怎。
我這里已經(jīng)安裝好了presto并且集成了兩個(gè)oracle、一個(gè)mysql豆胸、一個(gè)hive奥洼、一個(gè)kudu

下面以spring boot為例介紹如何在druid中集成presto，實(shí)現(xiàn)數(shù)據(jù)查詢

2. 修改配置文件

spring:
  datasource-presto:
    type: com.alibaba.druid.pool.DruidDataSource
    driverClassName: com.facebook.presto.jdbc.PrestoDriver
    url: jdbc:presto://ip:8099
    username: 1234
    filters: default

3. 添加datasource的bean

    @Bean(name="prestoDataSource")
//    @Qualifier("kuduDataSource")
    @ConfigurationProperties(prefix ="spring.datasource-presto")
    public DataSource prestoDataSource(){
        DruidDataSource druidDataSource=new DruidDataSource();

        List list= new ArrayList<Filter>(){{add(logFilter);}};
        druidDataSource.setProxyFilters(list);
        return druidDataSource;
    }

4. 增加數(shù)據(jù)源配置

@Configuration
@MapperScan(basePackages = {"com.base.web.presto.*.dao"},sqlSessionFactoryRef = "prestoSessionFactory")
public class PrestoConfig {
    private static final String MAPPER_LOCATION = "classpath:prestomybatis/*/*.xml";

    @Autowired
    @Qualifier("prestoDataSource")
    private DataSource prestoDataSource;

    @Bean(name = "prestoTransactionManager")
    public DataSourceTransactionManager prestoTransactionManager() {
        return new DataSourceTransactionManager(prestoDataSource);
    }

    @Bean(name = "prestoSessionFactory")
    public SqlSessionFactory prestoSessionFactory(@Qualifier("prestoDataSource") DataSource prestoDataSource)
            throws Exception {
        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(prestoDataSource);
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources(PrestoConfig.MAPPER_LOCATION));
        //添加駝峰命名法 映射
        org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration();
        configuration.setMapUnderscoreToCamelCase(true);
        sessionFactory.setConfiguration(configuration);
        return sessionFactory.getObject();
    }
}

配置結(jié)束

5. 代碼測試

controller:

    @Autowired
    private PrestoDao prestoDao;
    @ResponseBody
    @GetMapping("/test")
    String test() throws InterruptedException {
        List<Bean1> bean1List = prestoDao.select1();
        List<Bean2> bean2List = prestoDao.select2();
        List<String> nsrmc = prestoDao.select3();
        return "timeout";
    }

xml:

    <select id="select1" resultType="com.base.web.presto.prestotest.domain.Bean1">
SELECT dzdz.djxh,hxzg.uuid
FROM dzdz.dzdz.dj_nsrxx dzdz right join hxzg.hx_zgxt.sb_zyssb_zb hxzg on dzdz.nsrsbh = hxzg.nsrsbh
    </select>
    <select id="select2" resultType="com.base.web.presto.prestotest.domain.Bean2">
      SELECT mysql.password,hive."desc"
FROM mysql22046.jcpt.auth_user mysql left join hive."default".hxzg_hive_dbs hive on mysql.id = hive.db_id
    </select>

    <select id="select3" resultType="java.lang.String">
        SELECT nsrmc
FROM hive.sjjsq_db.dwa_base_djxx limit 10
    </select>

debug運(yùn)行：

數(shù)據(jù)都查詢到了