跳到主要内容

Paimon JDBC Catalog

本文档用于介绍通过 CREATE CATALOG 语句连接并访问使用 JDBC 接口的 Paimon Catalog 元数据服务时所支持的参数。

提示

该功能为试验功能,自 4.1.0 版本支持。

参数总览

属性名称描述默认值是否必须
paimon.jdbc.uri指定 JDBC 连接地址-
paimon.jdbc.userJDBC 连接用户名-
paimon.jdbc.passwordJDBC 连接密码-
warehouse指定 Paimon warehouse-
paimon.jdbc.driver_classJDBC 驱动类名,如 org.postgresql.Drivercom.mysql.cj.jdbc.Driver-
paimon.jdbc.driver_urlJDBC 驱动 JAR 包的路径-

注:

  1. Paimon JDBC Catalog 支持多种关系型数据库作为后端存储,包括 PostgreSQL、MySQL 等。

  2. 需要确保 JDBC 驱动 JAR 包可访问。可以通过 paimon.jdbc.driver_url 指定驱动位置。

示例配置

PostgreSQL 作为元数据存储

使用 PostgreSQL 数据库存储 Paimon 元数据:

CREATE CATALOG paimon_jdbc_postgresql PROPERTIES (
'type' = 'paimon',
'paimon.catalog.type' = 'jdbc',
'paimon.jdbc.uri' = 'jdbc:postgresql://127.0.0.1:5432/paimon_db',
'paimon.jdbc.user' = 'paimon_user',
'paimon.jdbc.password' = 'password',
'paimon.jdbc.driver_class' = 'org.postgresql.Driver',
'paimon.jdbc.driver_url' = '<jdbc_driver_jar>',
'warehouse' = 's3://bucket/warehouse',
's3.access_key' = '<ak>',
's3.secret_key' = '<sk>',
's3.endpoint' = 'https://s3.us-east-1.amazonaws.com',
's3.region' = 'us-east-1'
);

MySQL 作为元数据存储

使用 MySQL 数据库存储 Paimon 元数据:

CREATE CATALOG paimon_jdbc_mysql PROPERTIES (
'type' = 'paimon',
'paimon.catalog.type' = 'jdbc',
'paimon.jdbc.uri' = 'jdbc:mysql://127.0.0.1:3306/paimon_db',
'paimon.jdbc.user' = 'paimon_user',
'paimon.jdbc.password' = 'password',
'paimon.jdbc.driver_class' = 'com.mysql.cj.jdbc.Driver',
'paimon.jdbc.driver_url' = '<jdbc_driver_jar>',
'warehouse' = 's3://bucket/warehouse',
's3.access_key' = '<ak>',
's3.secret_key' = '<sk>',
's3.endpoint' = 'https://s3.us-east-1.amazonaws.com',
's3.region' = 'us-east-1'
);