@@ -55,7 +55,7 @@ JDBC 连接器不是二进制发行版的一部分,请查阅[这里]({{< ref "
55
55
| PostgreSQL | ` org.postgresql ` | ` postgresql ` | [ 下载] ( https://jdbc.postgresql.org/download/ ) |
56
56
| Derby | ` org.apache.derby ` | ` derby ` | [ 下载] ( http://db.apache.org/derby/derby_downloads.html ) | |
57
57
| SQL Server | ` com.microsoft.sqlserver ` | ` mssql-jdbc ` | [ 下载] ( https://docs.microsoft.com/en-us/sql/connect/jdbc/download-microsoft-jdbc-driver-for-sql-server?view=sql-server-ver16 ) |
58
- | CrateDB | ` io.crate ` | ` crate-jdbc ` | [ Download ] ( https://repo1.maven.org/maven2/io/crate/crate-jdbc/ ) |
58
+ | CrateDB | ` io.crate ` | ` crate-jdbc ` | [ 下载 ] ( https://repo1.maven.org/maven2/io/crate/crate-jdbc/ ) |
59
59
60
60
当前,JDBC 连接器和驱动不在 Flink 二进制发布包中,请参阅[ 这里] ({{< ref "docs/dev/configuration/overview" >}})了解在集群上执行时何连接它们。
61
61
@@ -605,7 +605,41 @@ SELECT * FROM test_table;
605
605
SELECT * FROM mysql_catalog .given_database .test_table2;
606
606
SELECT * FROM given_database .test_table2 ;
607
607
```
608
+ <a name =" jdbc-catalog-for-cratedb " ></a >
608
609
610
+ ### JDBC Catalog for CrateDB
611
+
612
+ <a name =" cratedb-metaspace-mapping " ></a >
613
+
614
+ #### CrateDB 元空间映射
615
+
616
+ CrateDB 和 PostgreSQL 类似,但它只有一个默认名为 ` crate ` 的数据库。 此外它有一个额外的命名空间 ` schema ` ,一个 CrateDB 实例可以有多个 schema,其中一个 schema 默认名为"doc",每个 schema 可以包含多张表。 在 Flink 中,当查询由 CrateDB catalog 注册的表时,用户可以使用 ` schema_name.table_name ` 或者只有 ` table_name ` 。其中 ` schema_name ` 是可选的,默认值为 "doc"。
617
+
618
+ 因此,Flink Catalog 和 CrateDB catalog 之间的元空间映射如下:
619
+
620
+ | Flink Catalog Metaspace Structure | CrateDB Metaspace Structure |
621
+ | :------------------------------------| :-------------------------------|
622
+ | catalog name (defined in Flink only) | N/A |
623
+ | database name | database name (一直是 ` crate ` ) |
624
+ | table name | [ schema_name.] table_name |
625
+
626
+ Flink 中的 CrateDB 表的完整路径应该是 `` "<catalog>.<db>.`<schema.table>`" `` 。如果指定了 schema,请注意转义 ` <schema.table> ` 。
627
+
628
+ 这里提供了一些访问 CrateDB 表的例子:
629
+
630
+ ``` sql
631
+ -- 扫描 'doc' schema (即默认 schema)中的 'test_table' 表,schema 名称可以省略
632
+ SELECT * FROM mycatalog .crate .doc .test_table ;
633
+ SELECT * FROM crate .doc .test_table;
634
+ SELECT * FROM doc .test_table ;
635
+ SELECT * FROM test_table;
636
+
637
+ -- 扫描 'custom_schema' schema 中的 'test_table2' 表
638
+ -- 自定义 schema 不能省略,并且必须与表一起转义
639
+ SELECT * FROM mycatalog .crate .` custom_schema.test_table2`
640
+ SELECT * FROM crate.` custom_schema.test_table2` ;
641
+ SELECT * FROM ` custom_schema.test_table2` ;
642
+ ```
609
643
<a name =" data-type-mapping " ></a >
610
644
611
645
数据类型映射
0 commit comments