云服务器内容精选

华为云首页用户手册

DWS-Connector

数据仓库服务 GaussDB(DWS)-引入依赖:概述

概述 dws-connector-flink是在dws-client的基础上对接Flink的一个工具，工具为对dws-client的包装，整体入库能力跟dws-client一致。dws-connector-flink为 GaussDB (DWS)团队自研工具，后续将根据GaussDB(DWS)数据库持续优化。 dws-flink-connector的DWS-Connector只支持单并发查询存量数据，暂不支持并行读取。

数据仓库服务 GaussDB(DWS) dws-connector-flink
数据仓库服务 GaussDB(DWS)-dws-client:异常处理

异常处理异常可分为三类： InvalidException运行时异常不显示抛出，触发在请求参数无效时。 DwsClientException对所有异常的封装，包含被解析的code以及原始异常。 DwsClientRecordException对DwsClientException的扩展，包含写入异常的数据集合以及对应DwsClientException异常。异常code对照： public enum ExceptionCode { /** * 无效参数 */ INVALID_CONFIG(1), /** * 连接异常 */ CONNECTION_ERROR(100), /** * 只读 */ READ_ONLY(101), /** * 超时 */ TIMEOUT(102), /** * 连接数过多 */ TOO_MANY_CONNECTIONS(103), /** * 加锁异常 */ LOCK_ERROR(104), /** * 认证失败 */ AUTH_FAIL(201), /** * 已经关闭 */ ALREADY_CLOSE(202), /** * 无权限 */ PERMISSION_DENY(203), SYNTAX_ERROR(204), /** * 内部异常 */ INTERNAL_ERROR(205), /** * 中断异常 */ INTERRUPTED(206), /** * 表未发现 */ TABLE_NOT_FOUND(207), CONSTRAINT_VIOLATION(208), DATA_TYPE_ERROR(209), DATA_VALUE_ERROR(210), /** * 解析不到的异常 */ UNKNOWN_ERROR(500); private final int code; }

数据仓库服务 GaussDB(DWS) DWS-Connector
数据仓库服务 GaussDB(DWS)-dws-client:简介

简介 dws-client是一款基于DWS JDBC实现的高性能、便捷入库工具，用户在使用时必须保证JDBC可以连接。其中使用dws-client入库具备如下优势： dws-client提供对缓存的空间、时间维度的限制，支持攒批提升入库性能，以满足业务在高峰低谷期的入库实时性。攒批：在实时性要求不严格的场景，对单条数据操作进行缓存，待缓存至多条后批量操作，以提升写入性能。支持并发入库。内部实现多种高性能入库方式、主键冲突策略，满足各种场景入库需求。 API方式交互，低门槛使用。

数据仓库服务 GaussDB(DWS) DWS-Connector