• JDBC封装组件


    组件编码 hzero-starter-jdbc

    一、简介

    1.1 概述

    hzero-starter-jdbc 提供基于JDBC的基本CRUD封装。可以与平台服务的数据源功能配合使用。

    1.2 组件坐标:

    <dependency>
        <groupId>org.hzero.starter</groupId>
        <artifactId>hzero-starter-jdbc</artifactId>
        <version>${hzero.starter.version}</version>
    </dependency>
    

    1.3 特性

    二、使用指南

    2.1 查询

    参数名称 参数类型 是否必须 说明
    driverClass String 驱动类
    datasourceUrl String 数据源连接URL
    username String 用户名
    password String 密码
    dbType enum 数据库类型
    dbPoolType enum 连接池类型
    options Map 连接池类型为NO时非必须 连接池参数
    DatasourceVO ds = datasourceHelper.getDatasource(DsConstants.DsPurpose.DR, BaseConstants.DEFAULT_TENANT_ID, "HZERO.PLATFORM");
    Map<String, Object> options = new HashMap<>(16);
    if (StringUtils.isNotEmpty(ds.getOptions())) {
        options = JSON.parseObject(ds.getOptions());
    }
    Query standardQuery = QueryFactory.create(
        ds.getDriverClass(), 
        ds.getDatasourceUrl(),
        ds.getUsername(), 
        ds.getPasswordEncrypted(), 
        DatabaseTypeEnum.MYSQL, 
        DBPoolTypeEnum.DRUID, options);
    return standardQuery.query("SELECT * FROM fd_language");
    

    2.2 增删改

    参数名称 参数类型 是否必须 说明
    driverClass String 驱动类
    datasourceUrl String 数据源连接URL
    username String 用户名
    password String 密码
    dbType enum 数据库类型
    dbPoolType enum 连接池类型
    options Map 连接池类型为NO时非必须 连接池参数
    DatasourceVO ds = datasourceHelper.getDatasource(DsConstants.DsPurpose.DR, BaseConstants.DEFAULT_TENANT_ID, "HZERO.PLATFORM");
    Map<String, Object> options = new HashMap<>(16);
    if (StringUtils.isNotEmpty(ds.getOptions())) {
        options = JSON.parseObject(ds.getOptions());
    }
    new Update(
        ds.getDriverClass(), 
        ds.getDatasourceUrl(), 
        ds.getUsername(), 
        ds.getPasswordEncrypted(), 
        DatabaseTypeEnum.MYSQL, 
        DBPoolTypeEnum.DRUID, 
        options)
            .executeAndClose("INSERT INTO at_jdbc(a) values('A')");
    

    2.3 Hive支持

    <dependency>
        <groupId>org.apache.hive</groupId>
        <artifactId>hive-jdbc</artifactId>
        <version>3.1.2</version>
        <optional>true</optional>
    </dependency>
    
    <exclusions>
        <exclusion>
            <groupId>javax.servlet</groupId>
            <artifactId>servlet-api</artifactId>
        </exclusion>
        <exclusion>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-1.2-api</artifactId>
        </exclusion>
    </exclusions>