数据目录

向表中插入一些样本数据：指定 1 到 6 整数类型的 id 列，date 列范围为 2023.01.01 到 2023.01.12，value 列为1到12的整数。生成的总数据量为 12 行。

dbUrl = exec dbUrl from getSchemaByCatalog("trading") where schema = "stock"
id = 1 2 3 4 5 6 1 2 3 4 5 6
date = 2023.01.01..2023.01.12
value = 1..12
data = table( id, date, value)
loadTable(dbUrl[0], "quote").append!(data)
select * from stock.quote

返回表 trading.stock.quote（自动按照 id 列排序）：

下表为目前已支持的 SQL 操作。

以下给出部分使用示例：

（1）返回满足指定条件的数据

从 stock.quote 中查询 id 为 1 的数据。

select * from stock.quote where id = 1

返回结果：

（2）更新满足指定条件的数据

将 stock.quote 中查询 id 为 2 的行的 value 值更新为 -1.0。

update stock.quote set value = -1.0 where id = 2
select * from stock.quote where id = 2

部分返回结果：

（3）删除满足指定条件的数据

删除并返回 stock.quote 中 id 为 3 的数据。

delete from stock.quote where id = 3
select * from stock.quote where id = 3

返回结果为空表，符合预期。

注意：如果脚本中存在一个相同命名的变量名时，使用该 schema 进行查询等操作可能失败。

例如，定义一个命名为 stock 的变量，与 catalog stock 歧义。在 DolphinDBScript 中将优先将其解析为变量名，所以执行如下 select 语句时会报错。

stock=1
select * from stock.quote where id = 1; //getMember method not supported

可使用 undef 函数取消该变量：

undef(`stock)

如下汇总了 catalog 相关的基本操作语句或函数，可点击对应链接以阅读详情页面。

可以使用 renameCatalog、renameSchema 函数对 catalog 或 schema 重命名。

renameCatalog("trading", "trading2") 
getAllCatalogs() // => ["trading2"]

renameSchema("trading", "stock", "stock1") 
exec schema from getSchemaByCatalog("trading") // => ["stock1"]

use catalog trading;
create database stock partitioned by VALUE(1..10), engine='OLAP'

使用 create database 语句创建的 schema，其 dbUrl 的默认格式为dfs://_{trading}_{stock}_{timestamp}。可通过 getSchemaByCatalog 进行查看。

getSchemaByCatalog("trading")

返回结果：

注意，dbUrl 是全局唯一且不变的，即使 schema 或者 catalog 进行重命名操作，dbUrl 也不会变。

从控制节点日志中寻找对应的 Audit Log。Audit Log 包含具体操作的 catalog，schema，操作者等信息。格式如下：

ACL Audit: function createSchema [catalog=trading,dbUrl=dfs://db1,schema=stock2], 
    called by user [xxx]

如下汇总了运维相关的函数，可点击阅读详情。

提供如下权限设置项用于控制当前 catalog 中的所有操作。

在处理 catalog 级别的权限操作时，与原有处理逻辑保持相同，遵循着“范围覆盖”原则。如：

createSchema("cat1", "dfs://db1", "db")
deny(`user, DB_READ, "dfs://db1")
grant(`user, CATALOG_READ, "catalog") //前面的deny被消除

提供以“SCHEMA_”为前缀的多种权限设置项，与原有处理逻辑相同。其中 obj 的语法需要为 “catalogName.schemaName”。如：

grant(`user, SCHEMA_MANAGE, "catalog1.schema1")

schema 相关操作的 obj 字符串格式为 catalog.schema。

下例中，为用户 Adam 赋予 trading（catalog） 下的 stock（schema）中的所有表的只读权限。

grant("Adam", SCHEMA_READ, "trading.stock")

如果在在多集群管理中指定 catalog 和 schema 的权限，需要

• 在用户（user）后面需要加上 @<cluster_identifier>，以指示该用户属于哪个集群。

• 在应用对象/约束规则（objs）后面加上 @<cluster_identifier>，以指示进行权限管理的对象属于哪个集群。

例如：如果集群 cluster2 上的用户 user1 想要读取集群 cluster1 上的表 trading.stock.quote，则需要在 MoM 上执行以下脚本以授予相应权限：

grant("user1@cluster2", TABLE_READ, "trading.stock.quote@cluster1")