import ChangeLog from ‘../changelog/connector-jdbc.md’;
JDBC Oracle 源连接器
通过 JDBC 读取外部数据源数据。
Spark
Flink
SeaTunnel Zeta
支持查询 SQL 并可以实现投影效果。
| 数据源 | 支持的版本 | 驱动 | 连接串 | Maven |
|---|---|---|---|---|
| Oracle | 不同的依赖版本有不同的驱动类 | oracle.jdbc.OracleDriver | jdbc:oracle:thin:@datasource01:1523:xe | https://mvnrepository.com/artifact/com.oracle.database.jdbc/ojdbc8 |
- 您需要确保 jdbc 驱动程序 jar 包 已放置在目录
${SEATUNNEL_HOME}/plugins/中。- 要支持 i18n 字符集，请将
orai18n.jar复制到$SEATUNNEL_HOME/plugins/目录。
- 您需要确保 jdbc 驱动程序 jar 包 已放置在目录
${SEATUNNEL_HOME}/lib/中。- 要支持 i18n 字符集，请将
orai18n.jar复制到$SEATUNNEL_HOME/lib/目录。
| Oracle 数据类型 | SeaTunnel 数据类型 |
|---|---|
| INTEGER | DECIMAL(38,0) |
| FLOAT | DECIMAL(38, 18) |
| NUMBER(precision <= 9, scale == 0) | INT |
| NUMBER(9 < precision <= 18, scale == 0) | BIGINT |
| NUMBER(18 < precision, scale == 0) | DECIMAL(38, 0) |
| NUMBER(scale != 0) | DECIMAL(38, 18) |
| BINARY_DOUBLE | DOUBLE |
| BINARY_FLOAT REAL | FLOAT |
| CHAR NCHAR VARCHAR NVARCHAR2 VARCHAR2 LONG ROWID NCLOB CLOB XML | STRING |
| DATE | TIMESTAMP |
| TIMESTAMP TIMESTAMP WITH LOCAL TIME ZONE | TIMESTAMP |
| BLOB RAW LONG RAW BFILE | BYTES |
| 参数名 | 类型 | 必须 | 默认值 | 描述 |
|---|---|---|---|---|
| url | String | 是 | - | JDBC 连接的 URL。参考示例：jdbc:oracle:thin:@datasource01:1523:xe |
| driver | String | 是 | - | 用于连接到远程数据源的 jdbc 类名，如果您使用 Oracle，值为 oracle.jdbc.OracleDriver。 |
| username | String | 否 | - | 连接实例用户名 |
| password | String | 否 | - | 连接实例密码 |
| query | String | 是 | - | 查询语句 |
| connection_check_timeout_sec | Int | 否 | 30 | 等待用于验证连接的数据库操作完成的时间（秒） |
| partition_column | String | 否 | - | 用于并行性分割的列名，仅支持数值类型，仅支持数值类型主键，只能配置一列。 |
| partition_lower_bound | BigDecimal | 否 | - | partition_column 的最小值用于扫描，如果未设置，SeaTunnel 将查询数据库获取最小值。 |
| partition_upper_bound | BigDecimal | 否 | - | partition_column 的最大值用于扫描，如果未设置，SeaTunnel 将查询数据库获取最大值。 |
| partition_num | Int | 否 | job parallelism | 分割数量，仅支持正整数。默认值是任务并行度。 |
| fetch_size | Int | 否 | 0 | 对于返回大量对象的查询，您可以配置查询中使用的行提取大小，以通过减少满足选择条件所需的数据库命中次数来提高性能。零表示使用 jdbc 默认值。 |
| properties | Map | 否 | - | 其他连接配置参数，当 properties 和 URL 具有相同参数时，优先级由驱动程序的具体实现确定。例如，在 Oracle 中，properties 优先于 URL。 |
| use_regex | Boolean | 否 | false | 控制 table_path 的正则表达式匹配。设置为 true 时，table_path 将被视为正则表达式模式。设置为 false 或未指定时，table_path 将被视为精确路径（无正则表达式匹配）。 |
| table_path | String | 否 | - | 表的完整路径，您可以使用此配置代替 query。示例： “test_schema.table1” |
| table_list | Array | 否 | - | 要读取的表列表，您可以使用此配置代替 table_path。 |
| where_condition | String | 否 | - | 所有表/查询的通用行过滤条件，必须以 where 开头。 |
| split.size | Int | 否 | 8096 | 一个分割中有多少行。 |
| common-options | 否 | - | 源插件通用参数，请参考 源通用选项 详见。 |