JDBC数据源_开源大数据平台 E-MapReduce(EMR)-阿里云帮助中心

通过JDBC Catalog，您可以直接查询MySQL、PostgreSQL及其协议兼容的数据源中的数据。本文为您介绍如何创建和查看JDBC Catalog。

创建JDBC Catalog

语法

CREATE EXTERNAL CATALOG <catalog_name>
PROPERTIES
( 
  "key"="value", 
  ...
);

参数说明

catalog_name：JDBC Catalog的名称，必选参数。命名要求如下：
- 必须由字母（a~z或A~Z）、数字（0~9）或下划线（_）组成，并且只能以字母开头。
- 总长度不能超过64个字符。
PROPERTIES： JDBC Catalog的属性。包含如下配置项：

属性	是否必选	说明
type	是	数据源类型，固定取值为 `jdbc`。
user	是	目标数据库登录用户名。
password	是	目标数据库用户登录密码。
jdbc_uri	是	JDBC驱动程序连接目标数据库的URI。如果使用MySQL，格式为：`"jdbc:mysql://ip:port"`。如果使用PostgreSQL，格式为：`"jdbc:postgresql://ip:port/db_name"`。
driver_url	是	用于下载JDBC驱动程序JAR包的URL。对于Serverless StarRocks实例，您需要将JDBC驱动程序JAR包上传到OSS上，请参见简单上传，然后将driver_url配置成包含对应内网Endpoint的HTTP URL，例如：`http://<YourBucketName>.oss-cn-xxxx-internal.aliyuncs.com/mysql-connector-java-*.jar`。
driver_class	是	JDBC驱动程序的类名称。以下是常见数据库引擎支持的JDBC驱动程序类名称： MySQL： MySQL 5.x及以前版本，请使用`com.mysql.jdbc.Driver`。 MySQL 6.x及之后的版本，请使用`com.mysql.cj.jdbc.Driver`。 PostgreSQL：请使用`org.postgresql.Driver`。

示例

CREATE EXTERNAL CATALOG mysql_catalog
PROPERTIES
(
    "type"="jdbc",
    "user"="root",
    "password"="xxxxx",
    "jdbc_uri"="jdbc:mysql://127.0.0.1:3306",
    "driver_url"="http://<YourBucketName>.oss-cn-xxxx-internal.aliyuncs.com/mysql-connector-java-*.jar",
    "driver_class"="com.mysql.cj.jdbc.Driver"
);

说明

示例中的mysql-connector-java-*.jar，请根据MySQL Driver的实际版本填写。

查看JDBC Catalog中的表数据

您可以通过SELECT查询目标数据库中的目标表。

SELECT * FROM <catalog_name>.<database_name>.<table_name>;