Skip to content

Latest commit

 

History

History
360 lines (279 loc) · 9.85 KB

postgresql.md

File metadata and controls

360 lines (279 loc) · 9.85 KB
Raw

PostgreSQL client

一、插件包名称

名称：postgresql

二、对应数据源sourceDTO及参数说明

PostgresqlSourceDTO

参数说明：

  • url

    • 描述：PostgreSQL数据库的jdbc连接字符串，参考文档：PostgreSQL官方文档
    • 必选：是
    • 默认值：无

  • username

    • 描述：数据源的用户名
    • 必选：否
    • 默认值：无

  • password

    • 描述：数据源指定用户名的密码
    • 必选：否
    • 默认值：无

  • schema

    • 描述：数据源指定库
    • 必选：否
    • 默认值：无

  • connection

    • 描述：数据源指定connection
    • 必选：否
    • 默认值：无

  • poolConfig

    • 描述：数据源池化参数，详见连接池使用
    • 必选：否
    • 默认值：无

三、支持的方发及使用demo

IClient客户端使用

构造sourceDTO

        PostgresqlSourceDTO sourceDTO = PostgresqlSourceDTO.builder()
                    .url("jdbc:postgresql://xxx:xxx/xxx?currentSchema=xxx")
                    .username("xxxx")
                    .password("xxxx")
                    .build();
1. 获取连接

入参类型：

  • PostgresqlSourceDTO：数据源连接信息

出参类型：

  • Connection：数据源连接

使用：

        IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        Connection conn = client.getCon(sourceDTO);
2. 校验数据源连通性

入参类型：

  • PostgresqlSourceDTO：数据源连接信息

出参类型：

  • Connection：数据源连接

使用：

        IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        Boolean isConnected = client.testCon(sourceDTO);
3. 执行查询

入参类型：

  • PostgresqlSourceDTO：数据源连接信息
  • SqlQueryDTO：查询信息

出参类型：

  • List<Map<String, Object>>：执行结果

使用：

        // 普通查询
        IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        String sql = "select * from dtstack limit 10";
        SqlQueryDTO queryDTO = SqlQueryDTO.builder().sql(sql).build();
        List<Map<String, Object>> mapList = client.executeQuery(sourceDTO, queryDTO);

        // 预编译查询
        IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        String sql = "select * from dtstack limit 10 where id > ? and id < ? ";
        List<Object> preFields = new ArrayList<>();
        preFields.add(2);
        preFields.add(5);
        SqlQueryDTO queryDTO = SqlQueryDTO.builder().sql(sql).preFields(preFields).build();
        List<Map<String, Object>> mapList = client.executeQuery(sourceDTO, queryDTO);
4. 执行不需要结果集的sql

入参类型：

  • PostgresqlSourceDTO：数据源连接信息
  • SqlQueryDTO：查询信息

出参类型：

  • Boolean：执行成功与否

使用：

        IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        String sql = "create table if not exists dtstack (id int)";
        SqlQueryDTO queryDTO = SqlQueryDTO.builder().sql(sql).build();
        client.executeSqlWithoutResultSet(sourceDTO, queryDTO);
5. 获取所有的表名称

入参类型：

  • PostgresqlSourceDTO：数据源连接信息
  • SqlQueryDTO：查询信息

出参类型：

  • List：表名称集合

使用：

        IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        SqlQueryDTO queryDTO = SqlQueryDTO.builder().build();
        List<String> tableList = client.getTableList(sourceDTO, queryDTO);
6. 获取指定schema下的的表名称

入参类型：

  • PostgresqlSourceDTO：数据源连接信息
  • SqlQueryDTO：查询信息

出参类型：

  • List：表名称集合

使用：

        IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        SqlQueryDTO queryDTO = SqlQueryDTO.builder().schema("dtstack").build();
        List<String> tableList = client.getTableListBySchema(source, queryDTO);
7. 获取表字段 Java 类的标准名称

入参类型：

  • PostgresqlSourceDTO：数据源连接信息
  • SqlQueryDTO：查询信息

出参类型：

  • List：表字段 Java 类的标准名称集合

使用：

        IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        SqlQueryDTO queryDTO = SqlQueryDTO.builder().tableName("dtstack").build();
        List<String> columnClassInfo = client.getColumnClassInfo(source, queryDTO);
8. 获取表字段信息

入参类型：

  • PostgresqlSourceDTO：数据源连接信息
  • SqlQueryDTO：查询信息

出参类型：

使用：

        IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        SqlQueryDTO queryDTO = SqlQueryDTO.builder().tableName("dtstack").build();
        List<ColumnMetaDTO> columnMetaData = client.getColumnMetaData(source, queryDTO);
9. 获取表注释

入参类型：

  • PostgresqlSourceDTO：数据源连接信息
  • SqlQueryDTO：查询信息

出参类型：

  • String：表字段 Java 类的标准名称集合

使用：

        IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        SqlQueryDTO queryDTO = SqlQueryDTO.builder().tableName("dtstack").build();
        String comment = client.getTableMetaComment(source, queryDTO);
10. 数据预览

入参类型：

  • PostgresqlSourceDTO：数据源连接信息
  • SqlQueryDTO：查询信息

出参类型：

  • List<List>：预览数据信息

    使用：

            IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        SqlQueryDTO queryDTO = SqlQueryDTO.builder().tableName("dtstack").previewNum(200).build();
        List<List<Object>> previewDate = client.getPreview(source, queryDTO);
    11. 获取所有库

    入参类型：

    • PostgresqlSourceDTO：数据源连接信息
    • SqlQueryDTO：查询信息

    出参类型：

    • List：库集合

    使用：

            IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        List<String> allDatabases = client.getAllDatabases(source, SqlQueryDTO.builder().build());
    12. 获取当前使用的schema

    入参类型：

    • PostgresqlSourceDTO：数据源连接信息
    • SqlQueryDTO：查询信息

    出参类型：

    • String：正在使用的schema

    使用：

            IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        String currentDatabase = client.getCurrentDatabase(source);
    13. 根据sql获取字段信息

    入参类型：

    • PostgresqlSourceDTO：数据源连接信息
    • SqlQueryDTO：查询信息

    出参类型：

    使用：

            IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        SqlQueryDTO queryDTO = SqlQueryDTO.builder().sql("select * from dtstack").build();
        List<ColumnMetaDTO> result = client.getColumnMetaDataWithSql(source, queryDTO);
    14. 获取数据下载器

    入参类型：

    • PostgresqlSourceDTO：数据源连接信息
    • SqlQueryDTO：查询信息

    出参类型：

    • IDownloader：表数据下载器

    使用：

            IClient client = ClientCache.getClient(DataSourceType.PostgreSQL.getVal());
        SqlQueryDTO queryDTO = SqlQueryDTO.builder().sql("select * from nanqi").build();
        IDownloader downloader = client.getDownloader(source, queryDTO);
        downloader.configure();
        List<String> metaInfo = downloader.getMetaInfo();
        System.out.println(metaInfo);
        while (!downloader.reachedEnd()){
            List<List<String>> result = (List<List<String>>)downloader.readNext();
            for (List<String> row : result){
                System.out.println(row);
            }
        }
    ITable客户端使用

    构造sourceDTO

            PostgresqlSourceDTO sourceDTO = PostgresqlSourceDTO.builder()
                    .url("jdbc:postgresql://xxx:xxx/xxx?currentSchema=xxx")
                    .username("xxxx")
                    .password("xxxx")
                    .build();
    1. 获取表占用存储

    入参类型：

    • PostgresqlSourceDTO：数据源连接信息
    • schema：schema名称
    • tableName：表名

    出参类型：

    • Long：表占用存储，单位：byte

    使用：

            ITable tableClient = ClientCache.getTable(DataSourceType.PostgreSQL.getVal());
        Long tableSize = tableClient.getTableSize(source, "public", "xxxx");
    2. 重命名表

    入参类型：

    • PostgresqlSourceDTO：数据源连接信息
    • oldTableName：旧表名
    • newTableName：新表名

    出参类型：

    • Boolean: 是否成功

    使用：

            ITable client = ClientCache.getTable(DataSourceType.PostgreSQL.getVal());
        Boolean renameCheck1 = client.renameTable(source, "pg_test", "pg_test2");
    3. 删除表

    入参类型：

    • PostgresqlSourceDTO：数据源连接信息
    • tableName：表名

    出参类型：

    • Boolean: 是否删除成功

    使用：

            ITable client = ClientCache.getTable(DataSourceType.PostgreSQL.getVal());
        Boolean dropCheck = client.dropTable(source, "pg_test");
    4. 判断表是否是视图

    入参类型：

    • PostgresqlSourceDTO：数据源连接信息
    • tableName：表名

    出参类型：

    • Boolean: 是否是视图

    使用：

            ITable client = ClientCache.getTable(DataSourceType.PostgreSQL.getVal());
        Boolean check = client.isView(source, null, "pg_test_view");