nowstart.md

下载代码

使用git工具把项目clone到本地

git clone http://gitlab.prod.dtstack.cn/dt-insight-plat/dt-center-common-loader.git

编译插件

mvn clean install -DskipTests

配置pom依赖

项目若想使用数据源插件，需要在项目中依赖common-loader的core模块

<dependency>
    <groupId>com.dtstack.dtcenter</groupId>
    <artifactId>common.loader.core</artifactId>
    <version>1.4.0-SNAPSHOT</version>
</dependency>

配置插件路径

打包完的插件在core模块下的pluginLibs目录下，需要将该目录放到项目的根路径下，也可以通过ClientCache.setUserDir("xxx")重新定义插件包位置;

具体使用

每种数据源支持的方法和详细使用请看对应的文档

分为两种方案：

1. 类似于 DriverManger.getConnection 类似，直接使用 Connection 去做二次开发使用

    // 不使用插件获取连接的方式
    String url = "jdbc:mysql://xxx/xxx";
    Properties prop = new Properties();
    prop.put("user", "xxxx");
    prop.put("password", "xxxx");
    Class.forName(dataBaseType.getDriverClassName());
    Connection conn = DriverManager.getConnection(url, prop);

    // 插件获取连接的方式
    @Test
    public void getMysqlConnection() throws Exception {
    IClient client = ClientCache.getClient(DataSourceType.MySql5.getVal());
        Mysql5SourceDTO source = Mysql5SourceDTO.builder()
            .url("jdbc:mysql://xxxx")
            .username("xxxx")
            .password("xxxx")
            .poolConfig(PoolConfig.builder().build())
            .build();
        Connection conn = client.getCon(source);
    }

2. 直接使用工具封装的方法，具体见各数据源对应的使用文档

    private static final IClient client = ClientCache.getClient(DataSourceType.MySQL.getVal());

    @Test
    public void testMysqlConnection() throws Exception {
        IClient client = ClientCache.getClient(DataSourceType.MySql5.getVal());
        Mysql5SourceDTO source = Mysql5SourceDTO.builder()
            .url("jdbc:mysql://xxxx")
            .username("xxxx")
            .password("xxxx")
            .poolConfig(PoolConfig.builder().build())
            .build();
        Boolean isConnect = client.testConn(source);
    }

    //kafka客户端插件使用
    @Test
    public void getTopicList() throws Exception {
        IKafka client = ClientCache.getKafka(DataSourceType.KAFKA_09.getVal());
        KafkaSourceDTO source = KafkaSourceDTO.builder()
                        .url("xxxx")
                        .build();
        List<String> topicList = client.getTopicList(source);
    }