ScalarDB SQL 文法

注記

このページは英語版のページが機械翻訳されたものです。英語版との間に矛盾または不一致がある場合は、英語版を正としてください。

• DDL
  • CREATE NAMESPACE
  • CREATE TABLE
  • CREATE INDEX
  • TRUNCATE TABLE
  • DROP INDEX
  • DROP TABLE
  • DROP NAMESPACE
  • CREATE COORDINATOR TABLES
  • TRUNCATE COORDINATOR TABLES
  • DROP COORDINATOR TABLES
  • ALTER TABLE
• DML
  • SELECT
  • INSERT
  • UPSERT
  • UPDATE
  • DELETE
• DCL
  • CREATE USER
  • ALTER USER
  • DROP USER
  • GRANT
  • REVOKE
  • CREATE ABAC_POLICY
  • ENABLE ABAC_POLICY
  • DISABLE ABAC_POLICY
  • CREATE ABAC_LEVEL
  • DROP ABAC_LEVEL
  • CREATE ABAC_COMPARTMENT
  • DROP ABAC_COMPARTMENT
  • CREATE ABAC_GROUP
  • DROP ABAC_GROUP
  • SET ABAC_LEVEL
  • ADD ABAC_COMPARTMENT
  • REMOVE ABAC_COMPARTMENT
  • ADD ABAC_GROUP
  • REMOVE ABAC_GROUP
  • DROP ABAC_USER_TAG_INFO
  • CREATE ABAC_NAMESPACE_POLICY
  • ENABLE ABAC_NAMESPACE_POLICY
  • DISABLE ABAC_NAMESPACE_POLICY
  • CREATE ABAC_TABLE_POLICY
  • ENABLE ABAC_TABLE_POLICY
  • DISABLE ABAC_TABLE_POLICY
• Others
  • USE
  • BEGIN
  • START TRANSACTION
  • JOIN
  • PREPARE
  • VALIDATE
  • COMMIT
  • ROLLBACK
  • ABORT
  • SET MODE
  • SHOW NAMESPACES
  • SHOW TABLES
  • DESCRIBE
  • SUSPEND
  • RESUME
  • SHOW USERS
  • SHOW GRANTS
  • SHOW ABAC_POLICY
  • SHOW ABAC_POLICIES
  • SHOW ABAC_LEVEL
  • SHOW ABAC_LEVELS
  • SHOW ABAC_COMPARTMENT
  • SHOW ABAC_COMPARTMENTS
  • SHOW ABAC_GROUP
  • SHOW ABAC_GROUPS
  • SHOW ABAC_USER_TAG_INFO
  • SHOW ABAC_NAMESPACE_POLICY
  • SHOW ABAC_NAMESPACE_POLICIES
  • SHOW ABAC_TABLE_POLICY
  • SHOW ABAC_TABLE_POLICIES
• リテラル
  • テキスト
  • 数字
  • 日付と時刻

DDL

警告

各 DDL コマンドは複数の書き込み操作をトリガーしますが、これらの操作はアトミックに実行されないため、コマンドが途中で失敗した場合、一貫性のない状態に遭遇する可能性があります。この非一貫性の問題を解決するには、テーブルを修復してください。詳細については、次のページを参照してください。

• Java API を使用したテーブルの修復
• ScalarDB Schema Loader を使用したテーブルの修復

CREATE NAMESPACE

テーブルは1つの名前空間に属しているため、テーブルを作成する前に名前空間を作成する必要があります。CREATE NAMESPACE コマンドは名前空間を作成します。

文法

CREATE NAMESPACE [IF NOT EXISTS] <namespace name> [WITH creation_options]

creation_options: <option name>=<option value> [AND <option name>=<option value>] ...

creation_options の詳細については、作成オプションを参照してください。

例

CREATE NAMESPACE の例は次のとおりです。

-- Create a namespace "ns"
CREATE NAMESPACE ns;

-- Create a namespace only if it does not already exist
CREATE NAMESPACE IF NOT EXISTS ns;

-- Create a namespace with options
CREATE NAMESPACE ns WITH 'option1' = 'value1' AND 'option2' = 'value2' AND 'option3' = 'value3';

CREATE NAMESPACE のステートメントオブジェクトを構築する例は次のとおりです。

// Create a namespace "ns"
CreateNamespaceStatement statement1 = StatementBuilder.createNamespace("ns").build();

// Create a namespace only if it does not already exist
CreateNamespaceStatement statement2 =
    StatementBuilder.createNamespace("ns").ifNotExists().build();

// Create a namespace with options
CreateNamespaceStatement statement3 =
    StatementBuilder.createNamespace("ns")
        .withOption("option1", "value1")
        .withOption("option2", "value2")
        .withOption("option3", "value3")
        .build();

CREATE TABLE

CREATE TABLE コマンドはテーブルを作成します。

ScalarDB データモデルの詳細については、ScalarDB 設計ドキュメントを参照してください。

文法

単一の列で構成される主キーを持つテーブルを作成します。

CREATE TABLE [IF NOT EXISTS] [<namespace name>.]<table name> (
  <primary key column name> data_type PRIMARY KEY,
  <column name> data_type,
  ...
) [WITH creation_options]

data_type: BOOLEAN | INT | BIGINT | FLOAT | DOUBLE | TEXT | BLOB | DATE | TIME | TIMESTAMP | TIMESTAMPTZ
creation_options: <option name>=<option value> [AND <option name>=<option value>] ...

• 主キー以外の列に ENCRYPTED を指定して、それらの列のデータを暗号化できます。

1つのパーティションキー列と複数のクラスタリングキー列で構成される主キーを持つテーブルを作成します。

CREATE TABLE [IF NOT EXISTS] [<namespace name>.]<table name> (
  <partition key column name> data_type,
  <clustering key column name> data_type,
  ...,
  <column name> data_type [ENCRYPTED],
  ...,
  PRIMARY KEY (<partition key column name>, <clustering key column name> [, <clustering key column name>] ...)
) [WITH [clustering_order_definition [AND creation_options]] | creation_options]

clustering_order_definition: CLUSTERING ORDER BY (<clustering key column name> [clustering_order] [, <clustering key column name> [clustering_order]] ...)
clustering_order: ASC | DESC

• clustering_order を省略すると、デフォルトのクラスタリング順序 ASC が使用されます。

複数のパーティションキー列と複数のクラスタリングキー列で構成される主キーを持つテーブルを作成します。

CREATE TABLE [IF NOT EXISTS] [<namespace name>.]<table name> (
  <partition key column name> data_type,
  ...,
  <clustering key column name> data_type,
  ...,
  <column name1> data_type [ENCRYPTED],
  <column name2> data_type [ENCRYPTED],
  ...,
  PRIMARY KEY ((<partition key column name> [, <partition key column name>] ...), <clustering key column name> [, <clustering key column name>] ...)
) [WITH [clustering_order_definition [AND creation_options]] | creation_options]

例

CREATE TABLE の例は次のとおりです。

-- Create a table with a primary key ("c1") and creation options
CREATE TABLE ns.tbl (
  c1 INT PRIMARY KEY,
  c2 TEXT,
  c3 FLOAT,
  c4 BIGINT,
  c5 BOOLEAN
) WITH 'option1' = 'value1' AND 'option2' = 'value2' AND 'option3' = 'value3';

-- Create a table with a partition key ("c1") and a clustering key ("c2" and "c3") with clustering order definition only if it does not already exist
CREATE TABLE IF NOT EXISTS tbl (
  c1 INT,
  c2 TEXT,
  c3 FLOAT,
  c4 BIGINT,
  c5 BOOLEAN,
  PRIMARY KEY (c1, c2, c3)
) WITH CLUSTERING ORDER BY (c2 DESC, c3 ASC);

-- Create a table with a partition key ("c1", "c2") and a clustering key ("c3" and "c4") with clustering order definition and creation options
CREATE TABLE ns.tbl (
  c1 INT,
  c2 TEXT,
  c3 FLOAT,
  c4 BIGINT,
  c5 BOOLEAN,
  PRIMARY KEY ((c1, c2), c3, c4)
) WITH CLUSTERING ORDER BY (c3 DESC, c4 ASC) AND 'option1' = 'value1' AND 'option2' = 'value2' AND 'option3' = 'value3';

-- Create a table with a primary key ("c1") and encrypted columns ("c2", "c3", "c4", and "c5")
CREATE TABLE ns.tbl (
  c1 INT PRIMARY KEY,
  c2 TEXT ENCRYPTED,
  c3 FLOAT ENCRYPTED,
  c4 BIGINT ENCRYPTED,
  c5 BOOLEAN ENCRYPTED
);

CREATE TABLE のステートメントオブジェクトを構築する例は次のとおりです。

// Create a table with a primary key ("c1") and creation options
CreateTableStatement statement1 =
    StatementBuilder.createTable("ns", "tbl")
        .withPartitionKey("c1", DataType.INT)
        .withColumn("c2", DataType.TEXT)
        .withColumn("c3", DataType.FLOAT)
        .withColumn("c4", DataType.BIGINT)
        .withColumn("c5", DataType.BOOLEAN)
        .withOption("option1", "value1")
        .withOption("option2", "value2")
        .withOption("option3", "value3")
        .build();

// Create a table with a partition key ("c1") and a clustering key ("c2" and "c3") with clustering order definition
CreateTableStatement statement2 =
    StatementBuilder.createTable("tbl")
        .ifNotExists()
        .withPartitionKey("c1", DataType.INT)
        .withClusteringKey("c2", DataType.TEXT)
        .withClusteringKey("c3", DataType.FLOAT)
        .withColumn("c4", DataType.BIGINT)
        .withColumn("c5", DataType.BOOLEAN)
        .withClusteringOrder("c2", ClusteringOrder.DESC)
        .withClusteringOrder("c3", ClusteringOrder.ASC)
        .build();

// Create a table with a partition key ("c1", "c2") and a clustering key ("c3" and "c4") with clustering order definition and creation options
CreateTableStatement statement3 =
    StatementBuilder.createTable("ns", "tbl")
        .withPartitionKey("c1", DataType.INT)
        .withPartitionKey("c2", DataType.TEXT)
        .withClusteringKey("c3", DataType.FLOAT)
        .withClusteringKey("c4", DataType.BIGINT)
        .withColumn("c5", DataType.BOOLEAN)
        .withClusteringOrder("c3", ClusteringOrder.DESC)
        .withClusteringOrder("c4", ClusteringOrder.ASC)
        .withOption("option1", "value1")
        .withOption("option2", "value2")
        .withOption("option3", "value3")
        .build();

// Create a table with a primary key ("c1") and encrypted columns ("c2", "c3", "c4", and "c5")
CreateTableStatement statement4 =
    StatementBuilder.createTable("ns", "tbl")
        .withPartitionKey("c1", DataType.INT)
        .withColumn("c2", DataType.TEXT, true)
        .withColumn("c3", DataType.FLOAT, true)
        .withColumn("c4", DataType.BIGINT, true)
        .withColumn("c5", DataType.BOOLEAN, true)
        .build();

CREATE INDEX

CREATE INDEX コマンドは、テーブルにセカンダリインデックスを作成します。

注記

暗号化された列にセカンダリインデックスを作成することはできません。

文法

CREATE INDEX [IF NOT EXISTS] ON [<namespace name>.]<table name> (<column name>)

例

CREATE INDEX の例は次のとおりです。

-- Create a secondary index on a column "c4" of a table "ns.tbl"
CREATE INDEX ON ns.tbl (c4);

-- Create a secondary index only if it does not already exist
CREATE INDEX IF NOT EXISTS ON tbl (c4);

-- Create a secondary index with options
CREATE INDEX ON ns.tbl (c4) WITH 'option1' = 'value1' AND 'option2' = 'value2' AND 'option3' = 'value3';

CREATE INDEX のステートメントオブジェクトを構築する例は次のとおりです。

// Create a secondary index on a column "c4" of a table "ns.tbl"
CreateIndexStatement statement1 =
    StatementBuilder.createIndex().onTable("ns", "tbl").column("c4").build();

// Create a secondary index only if it does not already exist
CreateIndexStatement statement2 =
    StatementBuilder.createIndex().ifNotExists().onTable("tbl").column("c4").build();

// Create a secondary index with options
CreateIndexStatement statement3 =
    StatementBuilder.createIndex()
        .onTable("ns", "tbl")
        .column("c4")
        .withOption("option1", "value1")
        .withOption("option2", "value2")
        .withOption("option3", "value3")
        .build();

TRUNCATE TABLE

TRUNCATE TABLE コマンドはテーブルのすべての行を削除します。

文法

TRUNCATE TABLE [<namespace name>.]<table name>

例

TRUNCATE TABLE の例は次のとおりです。

-- Truncate a table "ns.tbl"
TRUNCATE TABLE ns.tbl;

TRUNCATE TABLE のステートメントオブジェクトを構築する例は次のとおりです。

// Truncate a table "ns.tbl"
TruncateTableStatement statement = StatementBuilder.truncateTable("ns", "tbl").build();

DROP INDEX

DROP INDEX コマンドはセカンダリインデックスを削除します。

文法

DROP INDEX [IF EXISTS] ON [<namespace name>.]<table name> (<column name>)

例

DROP INDEX の例は次のとおりです。

-- Drop a secondary index on a column "c4" of a table "ns.tbl"
DROP INDEX ON ns.tbl (c4);

-- Drop a secondary index only if it exists
DROP INDEX IF EXISTS ON tbl (c4);

DROP INDEX のステートメントオブジェクトを構築する例は次のとおりです。

// Drop a secondary index on a column "c4" of a table "ns.tbl"
DropIndexStatement statement1 =
    StatementBuilder.dropIndex().onTable("ns", "tbl").column("c4").build();

// Drop a secondary index only if it exists
DropIndexStatement statement2 =
    StatementBuilder.dropIndex().ifExists().onTable("ns", "tbl").column("c4").build();

DROP TABLE

DROP TABLE コマンドはテーブルを削除します。

文法

DROP TABLE [IF EXISTS] [<namespace name>.]<table name>

例

DROP TABLE の例は次のとおりです。

-- Drop a table "ns.tbl"
DROP TABLE ns.tbl;

-- Drop a table only if it exists
DROP TABLE IF EXISTS tbl;

DROP TABLE のステートメントオブジェクトを構築する例は次のとおりです。

// Drop a table "ns.tbl"
DropTableStatement statement1 = StatementBuilder.dropTable("ns", "tbl").build();

// Drop a table only if it exists
DropTableStatement statement2 = StatementBuilder.dropTable("ns", "tbl").ifExists().build();

DROP NAMESPACE

DROP NAMESPACE コマンドは名前空間を削除します。

文法

DROP NAMESPACE [IF EXISTS] <namespace name> [CASCADE]

例

DROP NAMESPACE の例は次のとおりです。

-- Drop a namespace "ns"
DROP NAMESPACE ns;

-- Drop a namespace only if it exists
DROP NAMESPACE IF EXISTS ns;

-- Drop a namespace with cascade
DROP NAMESPACE ns CASCADE;

DROP NAMESPACE のステートメントオブジェクトを構築する例は次のとおりです。

// Drop a namespace "ns"
DropNamespaceStatement statement1 = StatementBuilder.dropNamespace("ns").build();

// Drop a namespace only if it exists
DropNamespaceStatement statement2 = StatementBuilder.dropNamespace("ns").ifExists().build();

// Drop a namespace with cascade
DropNamespaceStatement statement3 = StatementBuilder.dropNamespace("ns").cascade().build();

CREATE COORDINATOR TABLES

CREATE COORDINATOR TABLES コマンドは Coordinator テーブルを作成します。

文法

CREATE COORDINATOR TABLES [IF NOT {EXIST|EXISTS}] [WITH creation_options]

creation_options: <option name>=<option value> [AND <option name>=<option value>] ...

例

Examples of CREATE COORDINATOR TABLES are as follows:

-- Create coordinator tables
CREATE COORDINATOR TABLES;

-- Create coordinator tables only if they do not already exist
CREATE COORDINATOR TABLES IF NOT EXIST;

-- Create coordinator tables with options
CREATE COORDINATOR TABLES WITH 'option1' = 'value1' AND 'option2' = 'value2' AND 'option3' = 'value3';

CREATE COORDINATOR TABLES のステートメントオブジェクトを構築する例は次のとおりです。

// Create coordinator tables
CreateCoordinatorTablesStatement statement1 =
    StatementBuilder.createCoordinatorTables().build();

// Create coordinator tables only if they do not already exist
CreateCoordinatorTablesStatement statement2 =
    StatementBuilder.createCoordinatorTables().ifNotExist().build();

// Create coordinator tables with options
CreateCoordinatorTablesStatement statement3 =
    StatementBuilder.createCoordinatorTables()
        .withOption("option1", "value1")
        .withOption("option2", "value2")
        .withOption("option3", "value3")
        .build();

TRUNCATE COORDINATOR TABLES

TRUNCATE COORDINATOR TABLES コマンドは Coordinator テーブルのすべての行を削除します。

文法

TRUNCATE COORDINATOR TABLES

例

TRUNCATE COORDINATOR TABLES のステートメントオブジェクトを構築する例を次に示します。

// Truncate coordinator tables
TruncateCoordinatorTablesStatement statement =
    StatementBuilder.truncateCoordinatorTables().build();

DROP COORDINATOR TABLES

DROP COORDINATOR TABLES コマンドは Coordinator テーブルを削除します。

文法

DROP COORDINATOR TABLES [IF {EXIST|EXISTS}]

例

DROP COORDINATOR TABLES の例は次のとおりです。

-- Drop coordinator tables
DROP COORDINATOR TABLES;

-- Drop coordinator tables if they exist
DROP COORDINATOR TABLES IF EXIST;

DROP COORDINATOR TABLES のステートメントオブジェクトを構築する例は次のとおりです。

// Drop coordinator tables
DropCoordinatorTablesStatement statement1 = StatementBuilder.dropCoordinatorTables().build();

// Drop coordinator tables if they exist
DropCoordinatorTablesStatement statement2 =
    StatementBuilder.dropCoordinatorTables().ifExist().build();

ALTER TABLE

ALTER TABLE コマンドはテーブルを変更します (例: 列の追加)。

警告

テーブルに新しい列を追加する場合は、基盤となるストレージによって実行時間が大きく異なる可能性があるため、慎重に検討する必要があります。特にデータベースが本番環境で実行されている場合は、以下の点を考慮して適切に計画を立ててください。

• Cosmos DB for NoSQL および DynamoDB の場合: テーブルスキーマは変更されないため、列の追加はほぼ瞬時に行われます。別のテーブルに格納されているテーブルメタデータのみが更新されます。
• Cassandra の場合: 列を追加すると、スキーマメタデータのみが更新され、既存のスキーマレコードは変更されません。クラスタートポロジが実行時間の主な要因です。スキーマメタデータの変更は、ゴシッププロトコルを介して各クラスターノードに共有されます。このため、クラスターが大きいほど、すべてのノードが更新されるまでの時間が長くなります。
• リレーショナルデータベース (MySQL、Oracle など) の場合: 列の追加は実行にそれほど時間がかかりません。

文法

ALTER TABLE [<namespace name>.]<table name> ADD [COLUMN] <column name> data_type [ENCRYPTED]

data_type: BOOLEAN | INT | BIGINT | FLOAT | DOUBLE | TEXT | BLOB | DATE | TIME | TIMESTAMP | TIMESTAMPTZ

• 列に ENCRYPTED を指定して、その列のデータを暗号化できます。

例

ALTER TABLE の例は次のとおりです。

-- Add a new column "new_col" to "ns.tbl"
ALTER TABLE ns.tbl ADD COLUMN new_col INT;

-- Add a new encrypted column "new_col" to "ns.tbl"
ALTER TABLE ns.tbl ADD COLUMN new_col TEXT ENCRYPTED;

ALTER TABLE のステートメントオブジェクトを構築する例は次のとおりです。

// Add a new column "new_col" to "ns.tbl"
AlterTableAddColumnStatement statement =
    StatementBuilder.alterTable("ns", "tbl").addColumn("new_col", DataType.INT).build();

// Add a new encrypted column "new_col" to "ns.tbl"
AlterTableAddColumnStatement statement =
    StatementBuilder.alterTable("ns", "tbl").addColumn("new_col", DataType.TEXT, true).build();

DML

SELECT

SELECT コマンドは、データベースからレコードを取得します。ScalarDB SQL は、ScalarDB の Get、パーティション Scan、およびクロスパーティション Scan 操作のいずれかを使用して、データベースからレコードを取得し、SELECT コマンドの実行プランを作成します。最良の結果を得るには、クロスパーティションスキャンの使用を避けるため、WHERE 句で主キー列を可能な限り一意に指定します。クロスパーティションスキャンを使用すると、特に非 JDBC データベースでパフォーマンスと一貫性の問題が発生する可能性があります。操作の選択については、次のルールを参照してください。前者は後者よりも優先され、より効率的です。ScalarDB データモデルは、データのモデリングとアクセスに関するベストプラクティスを理解するのにも役立ちます。

1. WHERE 句で主キー列を完全に指定すると、SELECT コマンドは単一パーティション内の単一レコードに対して Get 操作を使用します。
2. パーティションキーを完全に指定し、WHERE 句と ORDER BY 句でクラスタリングキーと順序を適切に指定すると、SELECT コマンドは単一パーティション内のレコードに対して Scan 操作を使用します。詳細については、パーティションスキャンとインデックススキャンの例を参照してください。
3. ORDER BY 句を使用せずに WHERE 句で equal to (=) 演算子を使用してインデックス列の値を指定すると、SELECT コマンドはインデックス Scan 操作を使用します。
4. その他の場合、SELECT コマンドはクロスパーティション Scan 操作に変換されます。

任意の条件と順序でパーティション間でレコードを柔軟に取得したい場合は、クロスパーティションスキャンオプションと、フィルタリングおよび順序付けオプション付きのクロスパーティションスキャンを有効にする必要があります。現在、順序付けオプションは JDBC データベースでのみ使用できます。設定の詳細については、クロスパーティションスキャン設定および ScalarDB Cluster SQL クライアント設定を参照してください。

警告

非 JDBC データベースの場合、SERIALIZABLE 分離レベルでクロスパーティションスキャンを有効にした場合でも、トランザクションは読み取りコミットスナップショット分離 (SNAPSHOT) で実行される可能性があります。これは、より低い分離レベルです。非 JDBC データベースを使用する場合は、トランザクションの一貫性が重要でない場合にのみ、クロスパーティションスキャンを使用してください。

文法

SELECT projection [, projection] ...
  FROM [<namespace name>.]<table name> [AS <alias>] [join_specification [join_specification] ...]
  [WHERE and_predicates [OR and_predicates ...] | or_predicates [AND or_predicates ...]]
  [ORDER BY identifier [order] [, identifier [order]] ...]
  [LIMIT <limit>]
  [WITH operation_attributes_or_abac_read_tags]

projection: * | identifier [AS <alias>]
join_specification: [INNER] JOIN [<namespace name>.]<table name> [AS <alias>] ON join_predicate [AND join_predicate] ... | {LEFT|RIGHT} [OUTER] JOIN [<namespace name>.]<table name> [AS <alias>] ON join_predicate [AND join_predicate] ...
join_predicate: identifier = identifier
and_predicates: predicate | (predicate [AND predicate ...])
or_predicates: predicate | (predicate [OR predicate ...])
predicate: identifier operator <literal> | identifier BETWEEN <literal> AND <literal> | identifier [NOT] LIKE <pattern> [ESCAPE <escape character>] | identifier IS [NOT] NULL
identifier: [[<namespace name>.]<table name>.]<column name> | [alias.]<column name>
operator: = | <> | != | > | >= | < | <=
order: ASC | DESC
operation_attributes_or_abac_read_tags: operation_attribute_or_abac_read_tag [AND operation_attribute_or_abac_read_tag] ...
operation_attribute_or_abac_read_tag: operation_attribute | abac_read_tag
operation_attribute: <operation attribute name>=<operation attribute value>
abac_read_tag: ABAC_READ_TAG <abac read tag> FOR [POLICY] <abac policy name>

注記

JOIN 句:

• [INNER] JOIN および LEFT [OUTER] JOIN の場合:
  • join_predicate には、右側のテーブルのすべての主キー列またはセカンダリインデックス列のいずれかが含まれている必要があります。
  • WHERE 述語および ORDER BY 句には、FROM 句で指定されたテーブルの列のみを含めることができます。
• RIGHT [OUTER] JOIN の場合:
  • 最初の join_specification として指定する必要があります。
  • join_predicate には、左側のテーブルのすべての主キー列またはセカンダリインデックス列が含まれている必要があります。
  • WHERE 述語および ORDER BY 句には、RIGHT OUTER JOIN 句で指定されたテーブルの列のみを指定できます。

WHERE 句:

• WHERE 句の任意の列に任意の述語を使用できます。
• WHERE 句では、述語は and_predicates の OR 形式 (論理和標準形と呼ばれます) または or_predicates の AND 形式 (論理積標準形と呼ばれます) である必要があります。
• 複数の述語を持つ複数の and_predicates または or_predicates を接続する場合は、and_predicates と or_predicates を括弧で囲む必要があります。
• バインドマーカー (位置指定 ? および名前指定 :<name>) に <literal> を指定できます。リテラル文法については、リテラルセクションを参照してください。
• WHERE 句で暗号化された列を指定することはできません。

LIKE 述語:

• <pattern> 内の _ は任意の1文字に一致します。
• <pattern> 内の % は0個以上の文字の任意のシーケンスに一致します。
• <pattern> 内の \ はデフォルトでエスケープ文字として機能します。
  • ESCAPE 句を指定してエスケープ文字を変更できます。
  • 空のエスケープ文字 ESCAPE '' を指定してエスケープ文字を無効にすることができます。

ORDER BY 句:

• ORDER BY 句の任意の列に order を指定できます。
• order を省略すると、デフォルトの順序 ASC が使用されます。
• ORDER BY 句では暗号化された列を指定できません。

LIMIT 句:

• バインドマーカー (位置指定 ? および名前指定 :<name>) に <limit> を指定できます。

ScalarDB のデータベースからデータを取得する方法の詳細については、Get 操作および Scan 操作を参照してください。

パーティションスキャンとインデックススキャンの例

次のようなテーブルとインデックスがあるとします。

CREATE TABLE ns.tbl (
  c1 INT,
  c2 TEXT,
  c3 FLOAT,
  c4 BIGINT,
  c5 BOOLEAN,
  PRIMARY KEY (c1, c2, c3)
) WITH CLUSTERING ORDER BY (c2 DESC, c3 ASC);

CREATE INDEX ON ns.tbl (c4);

SELECT の例は次のとおりです。

-- With a full primary key
SELECT * FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23;

-- With a full primary key and predicates for non-primary-key columns
SELECT * FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23 AND c4 < 100;

-- With a partial primary key
SELECT * FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa';

-- With a partial primary key and predicates for non-primary-key columns
SELECT * FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa' AND (c4 < 100 OR c4 > 500);

-- With projections and a partition key and clustering-key boundaries
SELECT c1, c2, c3, c5 FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa' AND c3 >= 1.23 AND c3 < 4.56;

-- With projections and a partition key and clustering-key boundaries and orders and limit
SELECT c1 AS a, c2 AS b, c3 AS c, c5 FROM ns.tbl WHERE c1 = 10 AND c2 > 'aaa' AND c2 <= 'ddd' ORDER BY c2 ASC, c3 DESC LIMIT 10;

-- With an equality predicate for an indexed column
SELECT * FROM ns.tbl WHERE c4 = 100;

-- With an equality predicate for an indexed column and predicates for non-primary-key columns
SELECT * FROM ns.tbl WHERE c4 = 100 AND c5 = false;

-- With projections and an indexed column and limit
SELECT c1, c2, c3, c4 FROM ns.tbl WHERE c4 = 100 LIMIT 10;

-- With positional bind markers
SELECT * FROM ns.tbl WHERE c1 = ? AND c2 > ? AND c2 <= ? ORDER BY c2 ASC, c3 DESC LIMIT ?;

-- With operations attributes
SELECT * FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23 WITH 'attribute1' = 'value1' AND 'attribute2' = 'value2';

-- With an ABAC read tag
SELECT * FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23 WITH ABAC_READ_TAG 'read_tag1' FOR POLICY policy1;

-- With operations attributes and an ABAC read tag
SELECT * FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23 WITH 'attribute1' = 'value1' AND 'attribute2' = 'value2' AND ABAC_READ_TAG 'read_tag1' FOR POLICY policy1;

SELECT のステートメントオブジェクトを構築する例は次のとおりです。

// With a full primary key
SelectStatement statement1 =
    StatementBuilder.select()
        .from("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .and(Predicate.column("c4").isLessThan(Value.of(100)))
        .build();

// With a full primary key and predicates for non-primary-key columns
SelectStatement statement1 =
    StatementBuilder.select()
        .from("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c4").isEqualTo(Value.of(1.23F)))
        .and(Predicate.column("c4").isLessThan(Value.of(100)))
        .build();

// With a partial primary key
SelectStatement statement2 =
    StatementBuilder.select()
        .from("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .build();

// With a partial primary key and predicates for non-primary-key columns
SelectStatement statement2 =
    StatementBuilder.select()
        .from("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(
            AndPredicateList.predicate(Predicate.column("c4").isLessThan(Value.of(100)))
                .and(Predicate.column("c4").isGreaterThan(Value.of(500)))
                .build())
        .build();

// With projections and a partition key and clustering-key boundaries
SelectStatement statement3 =
    StatementBuilder.select("c1", "c2", "c3", "c5")
        .from("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isGreaterThanOrEqualTo(Value.of(1.23F)))
        .and(Predicate.column("c3").isLessThan(Value.of(4.56F)))
        .build();

// With projections and a partition key and clustering key boundaries and orders and limit
SelectStatement statement4 =
   StatementBuilder.select(
             Projection.column("c1").as("a"),
             Projection.column("c2").as("b"),
             Projection.column("c3").as("c"),
             Projection.column("c5").as("d"))
        .from("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isGreaterThan(Value.of("aaa")))
        .and(Predicate.column("c2").isLessThanOrEqualTo(Value.of("ddd")))
        .orderBy(Ordering.column("c2").asc(), Ordering.column("c3").desc())
        .limit(10)
        .build();

// With an equality predicate for an indexed column
SelectStatement statement5 =
    StatementBuilder.select()
        .from("ns", "tbl")
        .where(Predicate.column("c4").isEqualTo(Value.of(100)))
        .build();

// With an equality predicate for an indexed column and predicates for non-primary-key columns
SelectStatement statement5 =
    StatementBuilder.select()
        .from("ns", "tbl")
        .where(Predicate.column("c4").isEqualTo(Value.of(100)))
        .and(Predicate.column("c5").isEqualTo(Value.of(false)))
        .build();

// With projections and an indexed column and limit
SelectStatement statement6 =
    StatementBuilder.select("c1", "c2", "c3", "c4")
        .from("ns", "tbl")
        .where(Predicate.column("c4").isEqualTo(Value.of(100)))
        .limit(10)
        .build();

// With positional bind markers
SelectStatement statement7 =
    StatementBuilder.select()
        .from("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(BindMarker.positional()))
        .and(Predicate.column("c2").isGreaterThan(BindMarker.positional()))
        .and(Predicate.column("c2").isLessThanOrEqualTo(BindMarker.positional()))
        .orderBy(Ordering.column("c2").asc(), Ordering.column("c3").desc())
        .limit(BindMarker.positional())
        .build();

// With operations attributes
SelectStatement statement8 =
    StatementBuilder.select()
        .from("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .withAttribute("attribute1", "value1")
        .withAttribute("attribute2", "value2")
        .build();

// With an ABAC read tag
SelectStatement statement9 =
    StatementBuilder.select()
        .from("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .withAbacReadTag("read_tag1", "policy1")
        .build();

// With operations attributes and an ABAC read tag
SelectStatement statement10 =
    StatementBuilder.select()
        .from("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .withAttribute("attribute1", "value1")
        .withAttribute("attribute2", "value2")
        .withAbacReadTag("read_tag1", "policy1")
        .build();

JOIN を使用した SELECT の例は次のとおりです。

-- For INNER JOIN and LEFT OUTER JOIN:
SELECT * FROM tbl1 as t1
  INNER JOIN tbl2 as t2 on t1.col1=t2.id1 and t1.col2=t2.id2 -- This part must have all primary key columns or a secondary index column of `tbl2`.
  WHERE t1.pkey=1 -- Only columns of `tbl1` can be specified here.
  ORDER BY t1.ckey DESC; -- Only columns of `tbl1` can be specified here.

SELECT * FROM tbl1 as t1
  INNER JOIN tbl2 as t2 on t1.col1=t2.id -- This part must have all primary key columns or a secondary index column of `tbl2`.
  LEFT OUTER JOIN tbl3 as t3 on t1.col2=t3.id -- This part must have all primary key columns or a secondary index column of `tbl3`.
  WHERE t1.pkey=1 -- Only columns of `tbl1` can be specified here.
  ORDER BY t1.ckey DESC; -- Only columns of `tbl1` can be specified here.

-- For RIGHT OUTER JOIN:
SELECT * FROM tbl1 as t1
  RIGHT OUTER JOIN tbl2 as t2 on t1.id=t2.col -- Acceptable as the first join. And this part must have all primary key columns or a secondary index column of `tbl1`.
  LEFT OUTER JOIN tbl3 as t3 on t1.col2=t3.id
  WHERE t2.pkey=1 -- Only columns of `tbl2` can be specified here.
  ORDER BY t2.ckey DESC; -- Only columns of `tbl2` can be specified here.

SELECT * FROM tbl1 as t1
  RIGHT OUTER JOIN tbl2 as t2 on t1.id1=t2.col1 and t1.id2=t2.col2 -- This part must have all primary key columns or a secondary index column of `tbl1`.
  WHERE t2.pkey=1 -- Only columns of `tbl2` can be specified here.
  ORDER BY t2.ckey DESC; -- Only columns of `tbl2` can be specified here.

JOIN を使用して SELECT のステートメントオブジェクトを構築する例は次のとおりです。

// For INNER JOIN and LEFT OUTER JOIN:
SelectStatement statement1 =
   StatementBuilder.select()
        .from("tbl1", "t1")
        .innerJoin("tbl2", "t2")
        .on(JoinPredicate.column("t1", "col1").isEqualTo("t2", "id1"))
        .and(JoinPredicate.column("t1", "col2").isEqualTo("t2", "id2")) // This part must have all primary key columns or a secondary index column of `tbl2`.
        .where(Predicate.column("t1", "pkey").isEqualTo(Value.of(1))) // Only columns of `tbl1` can be specified here.
        .orderBy(Ordering.column("t1", "ckey").desc()) // Only columns of `tbl1` can be specified here.
        .build();

SelectStatement statement2 =
    StatementBuilder.select()
        .from("tbl1", "t1")
        .innerJoin("tbl2", "t2")
        .on(JoinPredicate.column("t1", "col1").isEqualTo("t2", "id")) // This part must have all primary key columns or a secondary index column of `tbl2`.
        .leftOuterJoin("tbl3", "t3")
        .on(JoinPredicate.column("t1", "col2").isEqualTo("t3", "id")) // This part must have all primary key columns or a secondary index column of `tbl3`.
        .where(Predicate.column("t1", "pkey").isEqualTo(Value.of(1))) // Only columns of `tbl1` can be specified here.
        .orderBy(Ordering.column("t1", "ckey").desc()) // Only columns of `tbl1` can be specified here.
        .build();

// For RIGHT OUTER JOIN:
SelectStatement statement3 =
    StatementBuilder.select()
        .from("tbl1", "t1")
        .rightOuterJoin("tbl2", "t2")
        .on(JoinPredicate.column("t1", "id").isEqualTo("t2", "col")) // Acceptable as the first join. And this part must have all primary key columns or a secondary index column of `tbl1`.
        .leftOuterJoin("tbl3", "t3")
        .on(JoinPredicate.column("t1", "col2").isEqualTo("t3", "id"))
        .where(Predicate.column("t2", "pkey").isEqualTo(Value.of(1))) // Only columns of `tbl2` can be specified here.
        .orderBy(Ordering.column("t2", "ckey").desc()) // Only columns of `tbl2` can be specified here.
        .build();

SelectStatement statement4 =
    StatementBuilder.select()
        .from("tbl1", "t1")
        .rightOuterJoin("tbl2", "t2")
        .on(JoinPredicate.column("t1", "id1").isEqualTo("t2", "col1"))
        .and(JoinPredicate.column("t1", "id2").isEqualTo("t2", "col2")) // This part must have all primary key columns or a secondary index column of `tbl1`.
        .where(Predicate.column("t2", "pkey").isEqualTo(Value.of(1))) // Only columns of `tbl2` can be specified here.
        .orderBy(Ordering.column("t2", "ckey").desc()) // Only columns of `tbl2` can be specified here.
        .build();

クロスパーティションスキャンの例

たとえば、次のテーブルがあるとします。

CREATE TABLE ns.user (
  id INT,
  name TEXT,
  age INT,
  height FLOAT,
  PRIMARY KEY (id)
)

クロスパーティションスキャンを使用した SELECT の例は次のとおりです。

-- Without the WHERE clause to retrieve all the records of a table
SELECT * FROM ns.user;

-- Without the WHERE clause and with projections and a limit
SELECT id, name FROM ns.user LIMIT 10;

-- With AND predicates for non-primary-key columns
SELECT * FROM ns.user WHERE age > 10 AND height > 140;

-- With OR predicates for non-primary key columns
SELECT * FROM ns.user WHERE age > 10 OR height > 140;

-- With OR-wise of AND predicates
SELECT * FROM ns.user WHERE (age > 10 AND height > 150) OR (age > 15 AND height > 145);

-- With AND-wise of OR predicates
SELECT * FROM ns.user WHERE (age < 10 OR age > 65) AND (height < 145 OR height > 175);

-- With LIKE predicates
SELECT * FROM ns.user WHERE name LIKE 'A%' OR name NOT LIKE 'B_b';

-- With LIKE predicates with an escape character
SELECT * FROM ns.user WHERE name LIKE '+%Alice' ESCAPE '+';

-- With IS NULL predicates
SELECT * FROM ns.user WHERE name IS NOT NULL AND age IS NULL;

-- With projections
SELECT name, age, height FROM ns.user WHERE (age < 10 OR age > 65) AND age <> 0;

-- With limit
SELECT name, age, height FROM ns.user WHERE age < 10 OR age > 65 LIMIT 10;

-- With orderings
SELECT * FROM ns.user WHERE age < 10 ORDER BY height DESC;

-- With orderings without the WHERE clause
SELECT * FROM ns.user ORDER BY height;

-- With positional bind markers
SELECT * FROM ns.user WHERE age < ? ORDER BY age ASC, height DESC LIMIT ?;

JOIN 句を使用する例については、パーティションスキャンとインデックススキャンの例を参照してください。

SELECT のステートメントオブジェクトを構築する例は次のとおりです。

// Without the WHERE clause to retrieve all the records of a table
SelectStatement statement1 = StatementBuilder.select().from("ns", "user").build();

// Without the WHERE clause and with projections and a limit
SelectStatement statement2 =
    StatementBuilder.select("id", "name").from("ns", "user").limit(10).build();

// With AND predicates for non-primary-key columns
SelectStatement statement2 =
    StatementBuilder.select()
        .from("ns", "user")
        .where(Predicate.column("age").isGreaterThan(Value.of(10)))
        .and(Predicate.column("height").isGreaterThan(Value.of(140.0F)))
        .build();

// With OR predicates for non-primary key columns
SelectStatement statement3 =
    StatementBuilder.select()
        .from("ns", "user")
        .where(Predicate.column("age").isGreaterThan(Value.of(10)))
        .or(Predicate.column("height").isGreaterThan(Value.of(140.0F)))
        .build();

// With OR-wise of AND predicates
SelectStatement statement4 =
    StatementBuilder.select()
        .from("ns", "user")
        .where(
            AndPredicateList.predicate(Predicate.column("age").isGreaterThan(Value.of(10)))
                .and(Predicate.column("height").isGreaterThan(Value.of(140.0F)))
                .build())
        .or(
            AndPredicateList.predicate(Predicate.column("age").isGreaterThan(Value.of(15)))
                .and(Predicate.column("height").isGreaterThan(Value.of(145.0F)))
                .build())
        .build();

// With AND-wise of OR predicates
SelectStatement statement5 =
    StatementBuilder.select()
        .from("ns", "user")
        .where(
            OrPredicateList.predicate(Predicate.column("age").isLessThan(Value.of(10)))
                .or(Predicate.column("age").isGreaterThan(Value.of(65)))
                .build())
        .and(
            OrPredicateList.predicate(Predicate.column("height").isLessThan(Value.of(145.0F)))
                .or(Predicate.column("height").isGreaterThan(Value.of(175.0F)))
                .build())
        .build();

// With LIKE predicates
SelectStatement statement6 =
    StatementBuilder.select()
        .from("ns", "user")
        .where(Predicate.column("name").isLike(Value.of("A%")))
        .or(Predicate.column("name").isNotLike(Value.of("B_b")))
        .build();

// With LIKE predicates with an escape character
SelectStatement statement7 =
    StatementBuilder.select()
        .from("ns", "user")
        .where(Predicate.column("name").isLike(Value.of("+%Alice"), Value.of("+")))
        .build();

// With IS NULL predicates
SelectStatement statement8 =
    StatementBuilder.select()
        .from("ns", "user")
        .where(Predicate.column("name").isNotNull())
        .and(Predicate.column("age").isNull())
        .build();

// With projections
SelectStatement statement9 =
    StatementBuilder.select("name", "age", "height")
        .from("ns", "user")
        .where(
            OrPredicateList.predicate(Predicate.column("age").isLessThan(Value.of(10)))
                .or(Predicate.column("age").isGreaterThan(Value.of(65)))
                .build())
        .and(Predicate.column("height").isNotEqualTo(Value.of(0)))
        .build();

// With limit
SelectStatement statement10 =
    StatementBuilder.select("name", "age", "height")
        .from("ns", "user")
        .where(Predicate.column("age").isLessThan(Value.of(10)))
        .or(Predicate.column("age").isGreaterThan(Value.of(65)))
        .limit(10)
        .build();

// With orderings
SelectStatement statement11 =
    StatementBuilder.select()
        .from("ns", "user")
        .where(Predicate.column("age").isLessThan(Value.of(10)))
        .orderBy(Ordering.column("height").desc())
        .build();

// With orderings without the WHERE clause
SelectStatement statement12 =
    StatementBuilder.select()
        .from("ns", "user")
        .orderBy(Ordering.column("height").desc())
        .build();

// With positional bind markers
SelectStatement statement13 =
    StatementBuilder.select()
        .from("ns", "user")
        .where(Predicate.column("age").isLessThan(BindMarker.positional()))
        .orderBy(Ordering.column("age").asc(), Ordering.column("height").desc())
        .limit(BindMarker.positional())
        .build();

JOIN 句を使用する例については、パーティションスキャンとインデックススキャンの例を参照してください。

INSERT

INSERT コマンドは、データベースに新しいレコードを挿入します。対象レコードのいずれかがすでに存在する場合、トランザクション競合エラーがスローされます。

このコマンドは次の列を返します:

• updateCount: INT - 挿入されたレコードの数

文法

INSERT INTO [<namespace name>.]<table name> [(<column name> [, <column name>] ...)]
  VALUES (<literal> [, <literal>] ...) [, (<literal> [, <literal>] ...)] ...
  [WITH operation_attributes_or_abac_read_tags_or_abac_write_tags]

operation_attributes_or_abac_read_tags_or_abac_write_tags: operation_attribute_or_abac_read_tag_or_abac_write_tag [AND operation_attribute_or_abac_read_tag_or_abac_write_tag] ...
operation_attribute_or_abac_read_tag_or_abac_write_tag: operation_attribute | abac_read_tag | abac_write_tag
operation_attribute: <operation attribute name>=<operation attribute value>
abac_read_tag: ABAC_READ_TAG <abac read tag> FOR [POLICY] <abac policy name>
abac_write_tag: ABAC_WRITE_TAG <abac write tag> FOR [POLICY] <abac policy name>

• INSERT では完全な主キーを指定する必要があります。
• バインドマーカー (位置 ? および名前 :<name>) に <literal> を指定できます。リテラル文法については、リテラルセクションを参照してください。

例

INSERT の例は次のとおりです。

-- Insert a record without specifying column names
INSERT INTO ns.tbl VALUES (10, 'aaa', 1.23, 100, true);

-- Insert a record with column names
INSERT INTO ns.tbl (c1, c2, c3, c4) VALUES (10, 'aaa', 1.23, 100);

-- With positional bind markers
INSERT INTO tbl VALUES (?, ?, ?, ?, ?);

-- Insert multiple records
INSERT INTO ns.tbl (c1, c2, c3, c4) VALUES (10, 'aaa', 1.23, 100), (20, 'bbb', 4.56, 200);

INSERT のステートメントオブジェクトを構築する例は次のとおりです。

// Insert a record without specifying column names.
InsertStatement statement1 = StatementBuilder.insertInto("ns", "tbl")
    .values(Value.ofInt(10), Value.ofText("aaa"), Value.of(1.23F), Value.of(100L), Value.of(true))
    .build();

// Insert a record with column names.
InsertStatement statement2 = StatementBuilder.insertInto("ns", "tbl")
    .columns("c1", "c2", "c3", "c4", "c5")
    .values(Value.ofInt(10), Value.ofText("aaa"), Value.of(1.23F), Value.of(100L), Value.of(true))
    .build();

// With positional bind markers
InsertStatement statement3 =
    StatementBuilder.insertInto("tbl")
        .columns("c1", "c2", "c3", "c4", "c5")
        .values(
            BindMarker.positional(),
            BindMarker.positional(),
            BindMarker.positional(),
            BindMarker.positional(),
            BindMarker.positional())
        .build();

// Insert multiple records.
InsertStatement statement4 = StatementBuilder.insertInto("ns", "tbl")
    .columns("c1", "c2", "c3", "c4", "c5")
    .values(Value.ofInt(10), Value.ofText("aaa"), Value.of(1.23F), Value.of(100L), Value.of(true))
    .values(Value.ofInt(20), Value.ofText("bbb"), Value.of(2.46F), Value.of(200L), Value.of(false))
    .build();

UPSERT

UPSERT コマンドは、データベースに新しいレコードが存在しない場合はそれを挿入し、すでに存在する場合はターゲットレコードを更新します。

このコマンドは次の列を返します:

• updateCount: INT - 挿入または更新されたレコードの数

文法

UPSERT INTO [<namespace name>.]<table name> [(<column name> [, <column name>] ...)]
  VALUES (<literal> [, <literal>] ...) [, (<literal> [, <literal>] ...)] ...
  [WITH operation_attributes]

operation_attributes: <operation attribute name>=<operation attribute value> [AND <operation attribute name>=<operation attribute value>] ...

• INSERT では完全な主キーを指定する必要があります。
• バインドマーカー (位置 ? および名前 :<name>) に <literal> を指定できます。リテラル文法については、リテラルセクションを参照してください。

例

UPSERT の例は次のとおりです。

-- Upsert a record without specifying column names.
UPSERT INTO ns.tbl VALUES (10, 'aaa', 1.23, 100, true);

-- Upsert a record with column names.
UPSERT INTO ns.tbl (c1, c2, c3, c4) VALUES (10, 'aaa', 1.23, 100);

-- With positional bind markers
UPSERT INTO tbl VALUES (?, ?, ?, ?, ?);

-- Upsert multiple records.
UPSERT INTO ns.tbl (c1, c2, c3, c4) VALUES (10, 'aaa', 1.23, 100), (20, 'bbb', 4.56, 200);

-- With operations attributes
UPSERT INTO ns.tbl VALUES (10, 'aaa', 1.23, 100, true) WITH 'attribute1' = 'value1' AND 'attribute2' = 'value2';

-- With an ABAC read tag and an ABAC write tag
UPSERT INTO ns.tbl VALUES (10, 'aaa', 1.23, 100, true) WITH ABAC_READ_TAG 'read_tag1' FOR POLICY policy1 AND ABAC_WRITE_TAG 'write_tag1' FOR POLICY policy1;

-- With operations attributes and ABAC read and write tags
UPSERT INTO ns.tbl VALUES (10, 'aaa', 1.23, 100, true) WITH 'attribute1' = 'value1' AND 'attribute2' = 'value2' AND ABAC_READ_TAG 'read_tag1' FOR POLICY policy1 AND ABAC_WRITE_TAG 'write_tag1' FOR POLICY policy1;

UPSERT のステートメントオブジェクトを構築する例は次のとおりです。

// Upsert a record without specifying column names.
UpsertStatement statement1 =
    StatementBuilder.upsertInto("ns", "tbl")
        .values(
            Value.ofInt(10),
            Value.ofText("aaa"),
            Value.of(1.23F),
            Value.of(100L),
            Value.of(true))
        .build();

// Upsert a record with column names.
UpsertStatement statement2 =
    StatementBuilder.upsertInto("ns", "tbl")
        .columns("c1", "c2", "c3", "c4", "c5")
        .values(
            Value.ofInt(10),
            Value.ofText("aaa"),
            Value.of(1.23F),
            Value.of(100L),
            Value.of(true))
        .build();

// With positional bind markers
UpsertStatement statement3 =
    StatementBuilder.upsertInto("tbl")
        .columns("c1", "c2", "c3", "c4", "c5")
        .values(
            BindMarker.positional(),
            BindMarker.positional(),
            BindMarker.positional(),
            BindMarker.positional(),
            BindMarker.positional())
        .build();

// Upsert multiple records.
UpsertStatement statement4 =
    StatementBuilder.upsertInto("ns", "tbl")
        .columns("c1", "c2", "c3", "c4", "c5")
        .values(
            Value.ofInt(10),
            Value.ofText("aaa"),
            Value.of(1.23F),
            Value.of(100L),
            Value.of(true))
        .values(
            Value.ofInt(20),
            Value.ofText("bbb"),
            Value.of(2.46F),
            Value.of(200L),
            Value.of(false))
        .build();

// With operations attributes
UpsertStatement statement5 =
    StatementBuilder.upsertInto("ns", "tbl")
        .values(
            Value.ofInt(10),
            Value.ofText("aaa"),
            Value.of(1.23F),
            Value.of(100L),
            Value.of(true))
        .withAttribute("attribute1", "value1")
        .withAttribute("attribute2", "value2")
        .build();

// With an ABAC read tag and an ABAC write tag
UpsertStatement statement6 =
    StatementBuilder.upsertInto("ns", "tbl")
        .values(
            Value.ofInt(10),
            Value.ofText("aaa"),
            Value.of(1.23F),
            Value.of(100L),
            Value.of(true))
        .withAbacReadTag("read_tag1", "policy1")
        .withAbacWriteTag("write_tag1", "policy1")
        .build();

// With operations attributes and ABAC read and write tags
UpsertStatement statement7 =
    StatementBuilder.upsertInto("ns", "tbl")
        .values(
            Value.ofInt(10),
            Value.ofText("aaa"),
            Value.of(1.23F),
            Value.of(100L),
            Value.of(true))
        .withAttribute("attribute1", "value1")
        .withAttribute("attribute2", "value2")
        .withAbacReadTag("read_tag1", "policy1")
        .withAbacWriteTag("write_tag1", "policy1")
        .build();

UPDATE

UPDATE コマンドは、データベース内の既存のレコードを更新します。WHERE 句に任意の条件を指定してレコードをフィルタリングできます。ただし、特に非 JDBC データベースでは、クロスパーティション操作によってパフォーマンスと一貫性の問題が発生する可能性があるため、クロスパーティション操作を回避するには、主キーを可能な限り一意に指定することをお勧めします。ScalarDB SQL は、Get または Scan 操作を使用してターゲットレコードを識別する UPDATE コマンドの実行プランを作成するため、レコードの選択にも同じルールが適用されます。クロスパーティション操作を引き起こす WHERE 句の種類を理解し、そのような操作を回避するには、SELECT を参照してください。

WHERE 句を指定せずにパーティション全体のすべてのレコードを更新する場合は、クロスパーティションスキャンオプションを有効にする必要があります。また、WHERE 句で任意の条件を使用してパーティション全体のレコードを柔軟に更新する場合は、フィルタリングオプション付きのクロスパーティションスキャンを有効にする必要があります。設定の詳細については、クロスパーティションスキャン設定および ScalarDB Cluster SQL クライアント設定を参照してください。

警告

非 JDBC データベースの場合、SERIALIZABLE 分離レベルでクロスパーティションスキャンを有効にした場合でも、トランザクションは読み取りコミットスナップショット分離 (SNAPSHOT) で実行される可能性があります。これは、より低い分離レベルです。非 JDBC データベースを使用する場合は、トランザクションの一貫性が重要でない場合にのみ、クロスパーティションスキャンを使用してください。

このコマンドは次の列を返します:

• updateCount: INT - 更新されたレコードの数

文法

UPDATE [<namespace name>.]<table name> [AS <alias>]
  SET <column identifier> = <literal> [, <column identifier> = <literal>] ...
  [WHERE and_predicates [OR and_predicates ...] | or_predicates [AND or_predicates ...]]
  [WITH operation_attributes_or_abac_read_tags_or_abac_write_tags]

identifier: [[<namespace name>.]<table name>.]<column name> | [alias.]<column name>
and_predicates: predicate | (predicate [AND predicate ...])
or_predicates: predicate | (predicate [OR predicate ...])
predicate: <identifier> operator <literal> | <identifier> BETWEEN <literal> AND <literal> | <identifier> [NOT] LIKE <pattern> [ESCAPE <escape character>] | <identifier> IS [NOT] NULL
operator: = | <> | != | > | >= | < | <=
operation_attributes_or_abac_read_tags_or_abac_write_tags: operation_attribute_or_abac_read_tag_or_abac_write_tag [AND operation_attribute_or_abac_read_tag_or_abac_write_tag] ...
operation_attribute_or_abac_read_tag_or_abac_write_tag: operation_attribute | abac_read_tag | abac_write_tag
operation_attribute: <operation attribute name>=<operation attribute value>
abac_read_tag: ABAC_READ_TAG <abac read tag> FOR [POLICY] <abac policy name>
abac_write_tag: ABAC_WRITE_TAG <abac write tag> FOR [POLICY] <abac policy name>

注記

WHERE 句:

• WHERE 句の任意の列に任意の述語を使用できます。
• WHERE 句では、述語は and_predicates の OR 形式 (論理和標準形と呼ばれます) または or_predicates の AND 形式 (論理積標準形と呼ばれます) である必要があります。
• 複数の述語を持つ複数の and_predicates または or_predicates を接続する場合は、and_predicates と or_predicates を括弧で囲む必要があります。
• バインドマーカー (位置 ? および名前 :<name>) に <literal> を指定できます。リテラル文法については、リテラルセクションを参照してください。
• WHERE 句で暗号化された列を指定することはできません。

LIKE 述語:

• <pattern> 内の _ は任意の1文字に一致します。
• <pattern> 内の % は0個以上の文字の任意のシーケンスに一致します。
• <pattern> 内の \ はデフォルトでエスケープ文字として機能します。
  • ESCAPE 句を指定してエスケープ文字を変更できます。
  • 空のエスケープ文字 ESCAPE '' を指定してエスケープ文字を無効にすることができます。

主キーを指定した例

たとえば、次のテーブルがあるとします。

CREATE TABLE ns.tbl (
  c1 INT,
  c2 TEXT,
  c3 FLOAT,
  c4 BIGINT,
  c5 BOOLEAN,
  PRIMARY KEY (c1, c2, c3)
) WITH CLUSTERING ORDER BY (c2 DESC, c3 ASC);

完全な主キーを指定した UPDATE の例は次のとおりです。

-- Update a record
UPDATE ns.tbl SET c4 = 200, c5 = false WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23;

-- With positional bind markers
UPDATE ns.tbl SET c4 = ?, c5 = ? WHERE c1 = ? AND c2 = ? AND c3 = ?;

-- With operations attributes
UPDATE ns.tbl SET c4 = 200, c5 = false WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23 WITH 'attribute1' = 'value1' AND 'attribute2' = 'value2';

-- With an ABAC read tag and an ABAC write tag
UPDATE ns.tbl SET c4 = 200, c5 = false WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23 WITH ABAC_READ_TAG 'read_tag1' FOR POLICY policy1 AND ABAC_WRITE_TAG 'write_tag1' FOR POLICY policy1;

-- With operations attributes and ABAC read and write tags
UPDATE ns.tbl SET c4 = 200, c5 = false WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23 WITH 'attribute1' = 'value1' AND 'attribute2' = 'value2' AND ABAC_READ_TAG 'read_tag1' FOR POLICY policy1 AND ABAC_WRITE_TAG 'write_tag1' FOR POLICY policy1;

UPDATE のステートメントオブジェクトを構築する例は次のとおりです。

// Update a record
UpdateStatement statement1 =
    StatementBuilder.update("ns", "tbl")
        .set(
            Assignment.column("c4").value(Value.of(200L)),
            Assignment.column("c5").value(Value.of(false)))
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .build();

// With positional bind markers
UpdateStatement statement2 =
    StatementBuilder.update("tbl")
        .set(
            Assignment.column("c4").value(BindMarker.positional()),
            Assignment.column("c5").value(BindMarker.positional()))
        .where(Predicate.column("c1").isEqualTo(BindMarker.positional()))
        .and(Predicate.column("c2").isEqualTo(BindMarker.positional()))
        .and(Predicate.column("c3").isEqualTo(BindMarker.positional()))
        .build();

// With operations attributes
UpdateStatement statement3 =
    StatementBuilder.update("ns", "tbl")
        .set(
            Assignment.column("c4").value(Value.of(200L)),
            Assignment.column("c5").value(Value.of(false)))
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .withAttribute("attribute1", "value1")
        .withAttribute("attribute2", "value2")
        .build();

// With an ABAC read tag and an ABAC write tag
UpdateStatement statement4 =
    StatementBuilder.update("ns", "tbl")
        .set(
            Assignment.column("c4").value(Value.of(200L)),
            Assignment.column("c5").value(Value.of(false)))
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .withAbacReadTag("read_tag1", "policy1")
        .withAbacWriteTag("write_tag1", "policy1")
        .build();

// With operations attributes and ABAC read and write tags
UpdateStatement statement5 =
    StatementBuilder.update("ns", "tbl")
        .set(
            Assignment.column("c4").value(Value.of(200L)),
            Assignment.column("c5").value(Value.of(false)))
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .withAttribute("attribute1", "value1")
        .withAttribute("attribute2", "value2")
        .withAbacReadTag("read_tag1", "policy1")
        .withAbacWriteTag("write_tag1", "policy1")
        .build();

完全な主キーが指定されていない例

たとえば、次のテーブルがあるとします。

CREATE TABLE ns.user (
  id INT,
  name TEXT,
  age INT,
  height FLOAT,
  PRIMARY KEY (id)
)

完全な主キーを指定しない UPDATE の例は次のとおりです。

-- Without the WHERE clause to update all the records of a table
UPDATE ns.user SET age = 31;

-- With AND predicates for non-primary key columns
UPDATE ns.user SET age = 31 WHERE age > 10 AND height > 140;

-- With OR predicates for non-primary key columns
UPDATE ns.user SET age = 31 WHERE age > 10 OR height > 140;

-- With OR-wise of AND predicates
UPDATE ns.user SET age = 31 WHERE (age > 10 AND height > 150) OR (age > 15 AND height > 145);

-- With AND-wise of OR predicates
UPDATE ns.user SET age = 31 WHERE (age < 10 OR age > 65) AND (height < 145 OR height > 175);

-- With LIKE predicates
UPDATE ns.user SET age = 31 WHERE name LIKE 'A%' OR name NOT LIKE 'B_b';

-- With LIKE predicates with an escape character
UPDATE ns.user SET age = 31 WHERE name LIKE '+%Alice' ESCAPE '+';

-- With IS NULL predicates
UPDATE ns.user SET age = 31 WHERE name IS NOT NULL AND age IS NULL;

-- With positional bind markers
UPDATE ns.user SET age = ? WHERE age < ?;

UPDATE のステートメントオブジェクトを構築する例は次のとおりです。

// Without the WHERE clause to update all the records of a table
UpdateStatement statement1 =
    StatementBuilder.update("ns", "user")
        .set(Assignment.column("age").value(Value.of(30)))
        .build();

// With AND predicates for non-primary key columns
UpdateStatement statement2 =
    StatementBuilder.update("ns", "user")
        .set(Assignment.column("age").value(Value.of(30)))
        .where(Predicate.column("age").isGreaterThan(Value.of(10)))
        .and(Predicate.column("height").isGreaterThan(Value.of(140.0F)))
        .build();

// With OR predicates for non-primary key columns
UpdateStatement statement3 =
    StatementBuilder.update("ns", "user")
        .set(Assignment.column("age").value(Value.of(30)))
        .where(Predicate.column("age").isGreaterThan(Value.of(10)))
        .or(Predicate.column("height").isGreaterThan(Value.of(140.0F)))
        .build();

// With OR-wise of AND predicates
UpdateStatement statement4 =
    StatementBuilder.update("ns", "user")
        .set(Assignment.column("age").value(Value.of(30)))
        .where(
            AndPredicateList.predicate(Predicate.column("age").isGreaterThan(Value.of(10)))
                .and(Predicate.column("height").isGreaterThan(Value.of(140.0F)))
                .build())
        .or(
            AndPredicateList.predicate(Predicate.column("age").isGreaterThan(Value.of(15)))
                .and(Predicate.column("height").isGreaterThan(Value.of(145.0F)))
                .build())
        .build();

// With AND-wise of OR predicates
UpdateStatement statement5 =
    StatementBuilder.update("ns", "user")
        .set(Assignment.column("age").value(Value.of(30)))
        .where(
            OrPredicateList.predicate(Predicate.column("age").isLessThan(Value.of(10)))
                .or(Predicate.column("age").isGreaterThan(Value.of(65)))
                .build())
        .and(
            OrPredicateList.predicate(Predicate.column("height").isLessThan(Value.of(145.0F)))
                .or(Predicate.column("height").isGreaterThan(Value.of(175.0F)))
                .build())
        .build();

// With LIKE predicates
UpdateStatement statement6 =
    StatementBuilder.update("ns", "user")
        .set(Assignment.column("age").value(Value.of(30)))
        .where(Predicate.column("name").isLike(Value.of("A%")))
        .or(Predicate.column("name").isNotLike(Value.of("B_b")))
        .build();

// With LIKE predicates with an escape character
UpdateStatement statement7 =
    StatementBuilder.update("ns", "user")
        .set(Assignment.column("age").value(Value.of(30)))
        .where(Predicate.column("name").isLike(Value.of("+%Alice"), Value.of("+")))
        .build();

// With IS NULL predicates
UpdateStatement statement8 =
    StatementBuilder.update("ns", "user")
        .set(Assignment.column("age").value(Value.of(30)))
        .where(Predicate.column("name").isNotNull())
        .and(Predicate.column("age").isNull())
        .build();

// With positional bind markers
UpdateStatement statement9 =
    StatementBuilder.update("ns", "user")
        .set(Assignment.column("age").value(BindMarker.positional()))
        .where(Predicate.column("age").isLessThan(BindMarker.positional()))
        .build();

DELETE

DELETE コマンドは、データベース内のレコードを削除します。WHERE 句に任意の条件を指定してレコードをフィルターできます。ただし、特に非 JDBC データベースでは、クロスパーティション操作によってパフォーマンスと一貫性の問題が発生する可能性があるため、クロスパーティション操作を回避するには、可能な限り主キーを一意に指定することをお勧めします。ScalarDB SQL は、ターゲットレコードを識別するために Get または Scan 操作を使用する DELETE コマンドの実行プランを作成するため、レコードの選択にも同じルールが適用されます。クロスパーティション操作を引き起こす WHERE 句の種類を理解し、そのような操作を回避するには、SELECT を参照してください。

WHERE 句を指定せずにパーティション全体のすべてのレコードを削除する場合は、クロスパーティションスキャンオプションを有効にする必要があります。また、WHERE 句で任意の条件を使用してパーティション全体のレコードを柔軟に削除する場合は、フィルタリングオプションを使用したクロスパーティションスキャンを有効にする必要があります。設定の詳細については、クロスパーティションスキャン設定および ScalarDB Cluster SQL クライアント設定を参照してください。

警告

非 JDBC データベースの場合、SERIALIZABLE 分離レベルでクロスパーティションスキャンを有効にした場合でも、トランザクションは読み取りコミットスナップショット分離 (SNAPSHOT) で実行される可能性があります。これは、より低い分離レベルです。非 JDBC データベースを使用する場合は、トランザクションの一貫性が重要でない場合にのみ、クロスパーティションスキャンを使用してください。

このコマンドは次の列を返します:

• updateCount: INT - 削除されたレコードの数

文法

DELETE FROM [<namespace name>.]<table name> [AS <alias>]
  [WHERE and_predicates [OR and_predicates ...] | or_predicates [AND or_predicates ...]]
  [WITH operation_attributes_or_abac_read_tags_or_abac_write_tags]

identifier: [[<namespace name>.]<table name>.]<column name> | [alias.]<column name>
and_predicates: predicate | (predicate [AND predicate ...])
or_predicates: predicate | (predicate [OR predicate ...])
predicate: <identifier> operator <literal> | <identifier> BETWEEN <literal> AND <literal> | <identifier> [NOT] LIKE <pattern> [ESCAPE <escape character>] | <identifier> IS [NOT] NULL
operator: = | <> | != | > | >= | < | <=
operation_attributes_or_abac_read_tags_or_abac_write_tags: operation_attribute_or_abac_read_tag_or_abac_write_tag [AND operation_attribute_or_abac_read_tag_or_abac_write_tag] ...
operation_attribute_or_abac_read_tag_or_abac_write_tag: operation_attribute | abac_read_tag | abac_write_tag
operation_attribute: <operation attribute name>=<operation attribute value>
abac_read_tag: ABAC_READ_TAG <abac read tag> FOR [POLICY] <abac policy name>
abac_write_tag: ABAC_WRITE_TAG <abac write tag> FOR [POLICY] <abac policy name>

注記

WHERE 句:

• WHERE 句の任意の列に任意の述語を使用できます。
• WHERE 句では、述語は and_predicates の OR 形式 (論理和標準形と呼ばれます) または or_predicates の AND 形式 (論理積標準形と呼ばれます) である必要があります。
• 複数の述語を持つ複数の and_predicates または or_predicates を接続する場合は、and_predicates と or_predicates を括弧で囲む必要があります。
• バインドマーカー (位置 ? および名前 :<name>) に <literal> を指定できます。リテラル文法については、リテラルセクションを参照してください。
• WHERE 句で暗号化された列を指定することはできません。

LIKE 述語:

• <pattern> 内の _ は任意の1文字に一致します。
• <pattern> 内の % は0個以上の文字の任意のシーケンスに一致します。
• <pattern> 内の \ はデフォルトでエスケープ文字として機能します。
  • ESCAPE 句を指定してエスケープ文字を変更できます。
  • 空のエスケープ文字 ESCAPE '' を指定してエスケープ文字を無効にすることができます。

主キーを指定した例

たとえば、次のテーブルがあるとします。

CREATE TABLE ns.tbl (
  c1 INT,
  c2 TEXT,
  c3 FLOAT,
  c4 BIGINT,
  c5 BOOLEAN,
  PRIMARY KEY (c1, c2, c3)
) WITH CLUSTERING ORDER BY (c2 DESC, c3 ASC);

DELETE の例は次のとおりです。

-- Delete a record
DELETE FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23;

-- With positional bind markers
DELETE FROM tbl WHERE c1 = ? AND c2 = ? AND c3 = ?;

-- With operations attributes
DELETE FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23 WITH 'attribute1' = 'value1' AND 'attribute2' = 'value2';

-- With an ABAC read tag and an ABAC write tag
DELETE FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23 WITH ABAC_READ_TAG 'read_tag1' FOR POLICY policy1 AND ABAC_WRITE_TAG 'write_tag1' FOR POLICY policy1;

-- With operations attributes and ABAC read and write tags
DELETE FROM ns.tbl WHERE c1 = 10 AND c2 = 'aaa' AND c3 = 1.23 WITH 'attribute1' = 'value1' AND 'attribute2' = 'value2' AND ABAC_READ_TAG 'read_tag1' FOR POLICY policy1 AND ABAC_WRITE_TAG 'write_tag1' FOR POLICY policy1;

DELETE のステートメントオブジェクトを構築する例は次のとおりです。

// Delete a record
DeleteStatement statement1 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .build();

// With positional bind markers
DeleteStatement statement2 =
    StatementBuilder.deleteFrom("tbl")
        .where(Predicate.column("c1").isEqualTo(BindMarker.positional()))
        .and(Predicate.column("c2").isEqualTo(BindMarker.positional()))
        .and(Predicate.column("c3").isEqualTo(BindMarker.positional()))
        .build();

// With operations attributes
DeleteStatement statement3 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .withAttribute("attribute1", "value1")
        .withAttribute("attribute2", "value2")
        .build();

// With an ABAC read tag and an ABAC write tag
DeleteStatement statement4 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .withAbacReadTag("read_tag1", "policy1")
        .withAbacWriteTag("write_tag1", "policy1")
        .build();

// With operations attributes and ABAC read and write tags
DeleteStatement statement5 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(Predicate.column("c1").isEqualTo(Value.of(10)))
        .and(Predicate.column("c2").isEqualTo(Value.of("aaa")))
        .and(Predicate.column("c3").isEqualTo(Value.of(1.23F)))
        .withAttribute("attribute1", "value1")
        .withAttribute("attribute2", "value2")
        .withAbacReadTag("read_tag1", "policy1")
        .withAbacWriteTag("write_tag1", "policy1")
        .build();

完全な主キーが指定されていない例

たとえば、次のテーブルがあるとします。

CREATE TABLE ns.user (
  id INT,
  name TEXT,
  age INT,
  height FLOAT,
  PRIMARY KEY (id)
)

クロスパーティションスキャンフィルタリングを使用した DELETE の例は次のとおりです。

-- Without the WHERE clause to delete all the records of a table
DELETE FROM ns.user;

-- With AND predicates for non-primary key columns
DELETE FROM ns.user WHERE age > 10 AND height > 140;

-- With OR predicates for non-primary key columns
DELETE FROM ns.user WHERE age > 10 OR height > 140;

-- With OR-wise of AND predicates
DELETE FROM ns.user WHERE (age > 10 AND height > 150) OR (age > 15 AND height > 145);

-- With AND-wise of OR predicates
DELETE FROM ns.user WHERE (age < 10 OR age > 65) AND (height < 145 OR height > 175);

-- With LIKE predicates
DELETE FROM ns.user WHERE name LIKE 'A%' OR name NOT LIKE 'B_b';

-- With LIKE predicates with an escape character
DELETE FROM ns.user WHERE name LIKE '+%Alice' ESCAPE '+';

-- With IS NULL predicates
DELETE FROM ns.user WHERE name IS NOT NULL AND age IS NULL;

-- With positional bind markers
DELETE FROM ns.user WHERE age < ?;

DELETE のステートメントオブジェクトを構築する例は次のとおりです。

// Without the WHERE clause to delete all the records of a table
DeleteStatement statement1 = StatementBuilder.deleteFrom("ns", "tbl").build();

// With AND predicates for non-primary key columns
DeleteStatement statement2 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(Predicate.column("age").isGreaterThan(Value.of(10)))
        .and(Predicate.column("height").isGreaterThan(Value.of(140.0F)))
        .build();

// With OR predicates for non-primary key columns
DeleteStatement statement3 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(Predicate.column("age").isGreaterThan(Value.of(10)))
        .or(Predicate.column("height").isGreaterThan(Value.of(140.0F)))
        .build();

// With OR-wise of AND predicates
DeleteStatement statement4 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(
            AndPredicateList.predicate(Predicate.column("age").isGreaterThan(Value.of(10)))
                .and(Predicate.column("height").isGreaterThan(Value.of(140.0F)))
                .build())
        .or(
            AndPredicateList.predicate(Predicate.column("age").isGreaterThan(Value.of(15)))
                .and(Predicate.column("height").isGreaterThan(Value.of(145.0F)))
                .build())
        .build();

// With AND-wise of OR predicates
DeleteStatement statement5 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(
            OrPredicateList.predicate(Predicate.column("age").isLessThan(Value.of(10)))
                .or(Predicate.column("age").isGreaterThan(Value.of(65)))
                .build())
        .and(
            OrPredicateList.predicate(Predicate.column("height").isLessThan(Value.of(145.0F)))
                .or(Predicate.column("height").isGreaterThan(Value.of(175.0F)))
                .build())
        .build();

// With LIKE predicates
DeleteStatement statement6 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(Predicate.column("name").isLike(Value.of("A%")))
        .or(Predicate.column("name").isNotLike(Value.of("B_b")))
        .build();

// With LIKE predicates with an escape character
DeleteStatement statement7 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(Predicate.column("name").isLike(Value.of("+%Alice"), Value.of("+")))
        .build();

// With IS NULL predicates
DeleteStatement statement8 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(Predicate.column("name").isNotNull())
        .and(Predicate.column("age").isNull())
        .build();

// With positional bind markers
DeleteStatement statement9 =
    StatementBuilder.deleteFrom("ns", "tbl")
        .where(Predicate.column("age").isLessThan(BindMarker.positional()))
        .build();

DCL

CREATE USER

CREATE USER コマンドは、指定されたユーザー名、パスワード、およびユーザー属性を持つ新しいユーザーを作成します。

文法

CREATE USER <username> [WITH] {PASSWORD <password> | SUPERUSER | NO_SUPERUSER} ...

• ユーザーにパスワードを指定しない場合、ユーザーはパスワードなしで作成されます。
• ユーザーに SUPERUSER 属性を指定すると、ユーザーはスーパーユーザーになります。
• ユーザーに NO_SUPERUSER 属性を指定すると、ユーザーは通常のユーザーになります。
• ユーザーに SUPERUSER または NO_SUPERUSER のどちらも指定しない場合、ユーザーは通常のユーザーになります。

例

CREATE USER の例は次のとおりです。

-- Create a user with a password as a superuser.
CREATE USER user1 WITH PASSWORD 'password1' SUPERUSER;

-- Create a user with a password.
CREATE USER user2 WITH PASSWORD 'password2';

-- Create a user without a password.
CREATE USER user3;

CREATE USER のステートメントオブジェクトを構築する例は次のとおりです。

// Create a user with a password and the `SUPERUSER` attribute.
CreateUserStatement statement1 =
    StatementBuilder.createUser("user1").with("password", UserOption.SUPERUSER).build();

// Create a user with a password.
CreateUserStatement statement2 = StatementBuilder.createUser("user1").with("password").build();

// Create a user without a password.
CreateUserStatement statement3 = StatementBuilder.createUser("user1").build();

ALTER USER

ALTER USER コマンドは、指定されたユーザーのパスワードとユーザー属性を変更します。

文法

ALTER USER <username> [WITH] {PASSWORD <password> | SUPERUSER | NO_SUPERUSER} ...

• ユーザーに SUPERUSER 属性を指定すると、ユーザーはスーパーユーザーになります。
• ユーザーに NO_SUPERUSER 属性を指定すると、ユーザーは通常のユーザーになります。

例

ALTER USER の例は次のとおりです。

-- Change the password of a user.
ALTER USER user1 WITH PASSWORD 'password1';

-- Change a user to a superuser.
ALTER USER user1 WITH SUPERUSER;

ALTER USER のステートメントオブジェクトを構築する例は次のとおりです。

// Change the password of a user.
AlterUserStatement statement1 = StatementBuilder.alterUser("user1").with("password2").build();

// Change a user to a superuser.
AlterUserStatement statement2 =
        StatementBuilder.alterUser("user1").with(UserOption.SUPERUSER).build();

DROP USER

DROP USER コマンドは指定されたユーザーを削除します。

文法

DROP USER <username>

例

DROP USER の例は次のとおりです。

-- Delete a user.
DROP USER user1;

DROP USER のステートメントオブジェクトを構築する例は次のとおりです。

// Delete a user.
DropUserStatement statement = StatementBuilder.dropUser("user1").build();

GRANT

GRANT コマンドは指定されたユーザーに権限を付与します。

文法

GRANT {privilege [, privilege] ... | ALL [PRIVILEGES]} ON [TABLE] <table name> [, <table name>] ... TO [USER] <username> [, <username>] ... [WITH GRANT OPTION]
GRANT {privilege [, privilege] ... | ALL [PRIVILEGES]} ON NAMESPACE <namespace name> [, <namespace name>] ... TO [USER] <username> [, <username>] ... [WITH GRANT OPTION]

privilege: SELECT | INSERT | UPDATE | DELETE | CREATE | DROP | TRUNCATE | ALTER

• INSERT 権限と UPDATE 権限を一緒に付与する必要があります。
• ユーザーに UPDATE 権限または DELETE 権限を付与するには、対象ユーザーに SELECT 権限が必要です。
• WITH GRANT OPTION オプションを指定すると、ユーザーは他のユーザーに権限を付与できます。

例

GRANT の例は次のとおりです。

-- Grant the SELECT privilege on a table to a user.
GRANT SELECT ON ns.tbl TO user1;

-- Grant the SELECT privilege on tables to users.
GRANT SELECT ON ns.tbl1, ns.tbl2 TO user1, user2;

-- Grant the SELECT privilege on all tables in a namespace to a user.
GRANT SELECT ON NAMESPACE ns TO user1;

-- Grant all privileges and GRANT OPTION on a table to a user.
GRANT ALL ON ns.tbl TO user1 WITH GRANT OPTION;

-- Grant all privileges and GRANT OPTION on all tables in a namespace to a user.
GRANT ALL ON NAMESPACE ns TO user1 WITH GRANT OPTION;

GRANT のステートメントオブジェクトを構築する例は次のとおりです。

// Grant the SELECT privilege on a table to a user.
GrantStatement statement1 =
    StatementBuilder.grant(Privilege.SELECT).onTable("ns", "tbl").toUser("user1").build();

// Grant the SELECT privilege on tables to users.
GrantStatement statement2 =
    StatementBuilder.grant(Privilege.SELECT)
        .onTable("ns", "tbl1", "ns", "tbl2")
        .toUser("user1", "user2")
        .build();

// Grant the SELECT privilege on all tables in a namespace to a user.
GrantStatement statement3 =
    StatementBuilder.grant(Privilege.SELECT).onNamespace("ns").toUser("user1").build();

// Grant all privileges and GRANT OPTION on a table to a user.
GrantStatement statement4 =
    StatementBuilder.grant(Privilege.values())
        .onTable("ns", "tbl")
        .toUser("user1")
        .withGrantOption()
        .build();

// Grant all privileges and GRANT OPTION on all tables in a namespace to a user.
GrantStatement statement5 =
    StatementBuilder.grant(Privilege.values())
        .onNamespace("ns")
        .toUser("user1")
        .withGrantOption()
        .build();

REVOKE

REVOKE コマンドは、指定されたユーザーの権限を取り消します。

文法

REVOKE {privilege [, privilege] ... | ALL [PRIVILEGES]} [, GRANT OPTION] ON [TABLE] <table name> [, <table name>] ... FROM [USER] <username> [, <username>] ...
REVOKE GRANT OPTION ON [TABLE] <table name> [, <table name>] ... FROM [USER] <username> [, <username>] ...
REVOKE {privilege [, privilege] ... | ALL [PRIVILEGES]} [, GRANT OPTION] ON NAMESPACE <namespace name> [, <namespace name>] ... FROM [USER] <username> [, <username>] ...
REVOKE GRANT OPTION ON NAMESPACE <namespace name> [, <namespace name>] ... FROM [USER] <username> [, <username>] ...

privilege: SELECT | INSERT | UPDATE | DELETE | CREATE | DROP | TRUNCATE | ALTER

• INSERT 権限と UPDATE 権限は同時に取り消す必要があります。
• 対象ユーザーが INSERT 権限または UPDATE 権限を持っている場合、それらのユーザーから SELECT 権限を取り消すことはできません。

例

REVOKE の例は次のとおりです。

-- Revoke the SELECT privilege on a table from a user.
REVOKE SELECT ON ns.tbl FROM user1;

-- Revoke the SELECT privilege on tables from users.
REVOKE SELECT ON ns.tbl1, ns.tbl2 FROM user1, user2;

-- Revoke the SELECT privilege on all tables in a namespace from a user.
REVOKE SELECT ON NAMESPACE ns FROM user1;

-- Revoke all privileges and GRANT OPTION on a table from a user.
REVOKE ALL, GRANT OPTION ON ns.tbl FROM user1;

-- Revoke all privileges and GRANT OPTION on all tables in a namespace from a user.
REVOKE ALL, GRANT OPTION ON NAMESPACE ns FROM user1;

REVOKE のステートメントオブジェクトを構築する例は次のとおりです。

// Revoke the SELECT privilege on a table from a user.
RevokeStatement statement1 =
    StatementBuilder.revoke(Privilege.SELECT).onTable("ns", "tbl").fromUser("user1").build();

// Revoke the SELECT privilege on tables from users.
RevokeStatement statement2 =
    StatementBuilder.revoke(Privilege.SELECT)
        .onTable("ns", "tbl1", "ns", "tbl2")
        .fromUser("user1", "user2")
        .build();

// Revoke the SELECT privilege on all tables in a namespace from a user.
RevokeStatement statement3 =
    StatementBuilder.revoke(Privilege.SELECT).onNamespace("ns").fromUser("user1").build();

// Revoke all privileges and GRANT OPTION on a table from a user.
RevokeStatement statement4 =
    StatementBuilder.revoke(Privilege.values())
        .onTable("ns", "tbl")
        .fromUser("user1")
        .build();

// Revoke all privileges and GRANT OPTION on all tables in a namespace from a user.
RevokeStatement statement5 =
    StatementBuilder.revoke(Privilege.values())
        .onNamespace("ns")
        .fromUser("user1")
        .build();

CREATE ABAC_POLICY

CREATE ABAC_POLICY コマンドは、指定されたポリシー名とデータタグ列名を使用して新しい ABAC ポリシーを作成します。新しく追加されたポリシーはデフォルトで有効になります。

文法

CREATE ABAC_POLICY <POLICY_NAME> [WITH [DATA_TAG_COLUMN] <DATA_TAG_COLUMN_NAME>];

• データタグ列名を指定しない場合、デフォルトのデータタグ列名は <POLICY_NAME>_data_tag になります。

例

CREATE ABAC_POLICY の例は次のとおりです。

-- Create an ABAC policy with the default data tag column name.
CREATE ABAC_POLICY policy1;

-- Create an ABAC policy with a custom data tag column name.
CREATE ABAC_POLICY policy2 WITH DATA_TAG_COLUMN data_tag;

CREATE ABAC_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Create an ABAC policy with the default data tag column name.
CreateAbacPolicyStatement statement1 = StatementBuilder.createAbacPolicy("policy1").build();

// Create an ABAC policy with a custom data tag column name.
CreateAbacPolicyStatement statement2 =
    StatementBuilder.createAbacPolicy("policy1")
        .withDataTagColumn("data_tag")
        .build();

ENABLE ABAC_POLICY

ENABLE ABAC_POLICY コマンドは、指定された ABAC ポリシーを有効にします。

文法

ENABLE ABAC_POLICY <POLICY_NAME>;

例

ENABLE ABAC_POLICY の例は次のとおりです。

-- Enable an ABAC policy.
ENABLE ABAC_POLICY policy1;

ENABLE ABAC_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Enable an ABAC policy.
EnableAbacPolicyStatement statement = StatementBuilder.enableAbacPolicy("policy1").build();

DISABLE ABAC_POLICY

DISABLE ABAC_POLICY コマンドは、指定された ABAC ポリシーを無効にします。このコマンドは、指定されたポリシーに関連付けられたすべての名前空間およびテーブルの ABAC 機能を実質的に無効にします。

文法

DISABLE ABAC_POLICY <POLICY_NAME>;

例

DISABLE ABAC_POLICY の例は次のとおりです。

-- Disable an ABAC policy.
DISABLE ABAC_POLICY policy1;

DISABLE ABAC_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Disable an ABAC policy.
DisableAbacPolicyStatement statement = StatementBuilder.disableAbacPolicy("policy1").build();

CREATE ABAC_LEVEL

CREATE ABAC_LEVEL コマンドは、指定されたポリシー内で指定されたレベルの短縮名、長い名前、およびレベル番号を使用して新しい ABAC レベルを作成します。

文法

CREATE ABAC_LEVEL <LEVEL_SHORT_NAME> WITH [LONG_NAME] <LEVEL_LONG_NAME> AND [LEVEL_NUMBER] <LEVEL_NUMBER> IN [POLICY] <POLICY_NAME>;

例

CREATE ABAC_LEVEL の例は次のとおりです。

-- Create an ABAC level.
CREATE ABAC_LEVEL l1 WITH LONG_NAME level1 AND LEVEL_NUMBER 10 IN POLICY policy1;

CREATE ABAC_LEVEL のステートメントオブジェクトを構築する例は次のとおりです。

// Create an ABAC level.
CreateAbacLevelStatement statement =
    StatementBuilder.createAbacLevel("l1")
        .withLongName("level1")
        .andLevelNumber(10)
        .inPolicy("policy1")
        .build();

DROP ABAC_LEVEL

DROP ABAC_LEVEL コマンドは、指定されたポリシー内の指定された ABAC レベルを削除します。

文法

DROP ABAC_LEVEL <LEVEL_SHORT_NAME> IN [POLICY] <POLICY_NAME>;

例

DROP ABAC_LEVEL の例は次のとおりです。

-- Drop an ABAC level.
DROP ABAC_LEVEL l1 IN POLICY policy1;

DROP ABAC_LEVEL のステートメントオブジェクトを構築する例は次のとおりです。

// Drop an ABAC level.
DropAbacLevelStatement statement =
    StatementBuilder.dropAbacLevel("l1").inPolicy("policy1").build();

CREATE ABAC_COMPARTMENT

CREATE ABAC_COMPARTMENT コマンドは、指定されたポリシー内で指定されたコンパートメントの短縮名と長い名前を使用して新しい ABAC コンパートメントを作成します。

文法

CREATE ABAC_COMPARTMENT <COMPARTMENT_SHORT_NAME> WITH [LONG_NAME] <COMPARTMENT_LONG_NAME> IN [POLICY] <POLICY_NAME>;

例

CREATE ABAC_COMPARTMENT の例は次のとおりです。

-- Create an ABAC compartment.
CREATE ABAC_COMPARTMENT c1 WITH LONG_NAME compartment1 IN POLICY policy1;

CREATE ABAC_COMPARTMENT のステートメントオブジェクトを構築する例は次のとおりです。

// Create an ABAC compartment.
CreateAbacCompartmentStatement statement =
    StatementBuilder.createAbacCompartment("c1")
        .withLongName("compartment1")
        .inPolicy("policy1")
        .build();

DROP ABAC_COMPARTMENT

DROP ABAC_COMPARTMENT コマンドは、指定されたポリシー内の指定された ABAC コンパートメントを削除します。

文法

DROP ABAC_COMPARTMENT <COMPARTMENT_SHORT_NAME> IN [POLICY] <POLICY_NAME>;

例

DROP ABAC_COMPARTMENT の例は次のとおりです。

-- Drop an ABAC compartment.
DROP ABAC_COMPARTMENT c1 IN POLICY policy1;

DROP ABAC_COMPARTMENT のステートメントオブジェクトを構築する例は次のとおりです。

// Drop an ABAC compartment.
DropAbacCompartmentStatement statement =
    StatementBuilder.dropAbacCompartment("c1").inPolicy("policy1").build();

CREATE ABAC_GROUP

CREATE ABAC_GROUP コマンドは、指定されたポリシー内で指定された短縮名、長い名前、およびオプションで親グループを使用して新しい ABAC グループを作成します。

文法

CREATE ABAC_GROUP <GROUP_SHORT_NAME> WITH [LONG_NAME] <GROUP_LONG_NAME> [AND [PARENT_GROUP] <PARENT_GROUP_SHORT_NAME>] IN [POLICY] <POLICY_NAME>;

例

CREATE ABAC_GROUP の例は次のとおりです。

-- Create an ABAC group with a parent group.
CREATE ABAC_GROUP g1 WITH LONG_NAME group1 AND PARENT_GROUP g0 IN POLICY policy1;

-- Create an ABAC group without a parent group.
CREATE ABAC_GROUP g2 WITH LONG_NAME group2 IN POLICY policy1;

CREATE ABAC_GROUP のステートメントオブジェクトを構築する例は次のとおりです。

// Create an ABAC group with a parent group.
CreateAbacGroupStatement statement1 =
    StatementBuilder.createAbacGroup("g1")
        .withLongName("group1")
        .andParentGroup("g0")
        .inPolicy("policy1")
        .build();

// Create an ABAC group without a parent group.
CreateAbacGroupStatement statement2 =
    StatementBuilder.createAbacGroup("g2").withLongName("group2").inPolicy("policy1").build();

DROP ABAC_GROUP

DROP ABAC_GROUP コマンドは、指定されたポリシー内の指定された ABAC グループを削除します。

文法

DROP ABAC_GROUP <GROUP_SHORT_NAME> IN [POLICY] <POLICY_NAME>;

例

DROP ABAC_GROUP の例は次のとおりです。

-- Drop an ABAC group.
DROP ABAC_GROUP g1 IN POLICY policy1;

DROP ABAC_GROUP のステートメントオブジェクトを構築する例は次のとおりです。

// Drop an ABAC group.
DropAbacGroupStatement statement =
    StatementBuilder.dropAbacGroup("g1").inPolicy("policy1").build();

SET ABAC_LEVEL

SET ABAC_LEVEL コマンドは、指定されたポリシー内の指定されたユーザーに対して指定された ABAC レベルを設定します。

文法

SET ABAC_LEVEL <LEVEL_SHORT_NAME> [AND [DEFAULT_LEVEL] <DEFAULT_LEVEL_SHORT_NAME>] [AND [ROW_LEVEL] <ROW_LEVEL_SHORT_NAME>] FOR [USER] <USER_NAME> IN [POLICY] <POLICY_NAME>;

• デフォルトレベルを省略すると、<LEVEL_SHORT_NAME> で指定されたレベルがデフォルトレベルとして使用されます。
• 行レベルを省略すると、デフォルトレベルが行レベルとして使用されます。

例

SET ABAC_LEVEL の例は次のとおりです。

-- Set the levels for a user.
SET ABAC_LEVEL l1 AND DEFAULT_LEVEL l2 AND ROW_LEVEL l3 FOR USER user1 IN POLICY policy1;

-- Set the levels for a user without a row level.
SET ABAC_LEVEL l1 AND DEFAULT_LEVEL l2 FOR USER user1 IN POLICY policy1;

-- Set the levels for a user without a default level and a row level.
SET ABAC_LEVEL l1 FOR USER user1 IN POLICY policy1;

SET ABAC_LEVEL のステートメントオブジェクトを構築する例は次のとおりです。

// Set the levels for a user.
SetAbacLevelsForUserStatement statement1 =
    StatementBuilder.setAbacLevel("l1")
        .andDefaultLevel("l2")
        .andRowLevel("l3")
        .forUser("user1")
        .inPolicy("policy1")
        .build();

// Set the levels for a user without a row level.
SetAbacLevelsForUserStatement statement2 =
    StatementBuilder.setAbacLevel("l1")
        .andDefaultLevel("l2")
        .forUser("user1")
        .inPolicy("policy1")
        .build();

// Set the levels for a user without a default level and a row level.
SetAbacLevelsForUserStatement statement3 =
    StatementBuilder.setAbacLevel("l1").forUser("user1").inPolicy("policy1").build();

ADD ABAC_COMPARTMENT

ADD ABAC_COMPARTMENT コマンドは、指定されたポリシー内の指定されたユーザーに指定された ABAC コンパートメントを追加します。

文法

ADD ABAC_COMPARTMENT <COMPARTMENT_SHORT_NAME> TO [USER] <USER_NAME> [WITH {accessMode [AND default] [AND row] | default [AND row] | row}] IN [POLICY] <POLICY_NAME>;

accessMode: READ_ONLY_ACCESS | READ_WRITE_ACCESS
default: DEFAULT [= {TRUE | FALSE}]
row: ROW [= {TRUE | FALSE}]

• アクセスモードを省略すると、デフォルトのアクセスモードは READ_ONLY_ACCESS になります。
• デフォルト部分を省略すると、コンパートメントはデフォルトのコンパートメントに含まれます。
• 行部分を省略すると、コンパートメントは行コンパートメントに含まれません。
• default または row のブーリアンリテラルを省略すると、default または row の値は TRUE に設定されます。

例

ADD ABAC_COMPARTMENT の例は次のとおりです。

-- Add a compartment to a user without specifying the access mode, default, and row.
ADD ABAC_COMPARTMENT c1 TO USER user1 IN POLICY policy1;

-- Add a compartment to a user with the READ_WRITE_ACCESS access mode.
ADD ABAC_COMPARTMENT c1 TO USER user1 WITH READ_WRITE_ACCESS IN POLICY policy1;

-- Add a compartment to a user with specifying the default.
ADD ABAC_COMPARTMENT c1 TO USER user1 WITH DEFAULT IN POLICY policy1;

-- Add a compartment to a user with specifying the row to TRUE.
ADD ABAC_COMPARTMENT c1 TO USER user1 WITH ROW = TRUE IN POLICY policy1;

ADD ABAC_COMPARTMENT のステートメントオブジェクトを構築する例は次のとおりです。

// Add a compartment to a user without specifying the access mode, default, and row.
AddAbacCompartmentToUserStatement statement1 =
    StatementBuilder.addAbacCompartment("c1").toUser("user1").inPolicy("policy1").build();

// Add a compartment to a user with the READ_WRITE_ACCESS access mode.
AddAbacCompartmentToUserStatement statement2 =
    StatementBuilder.addAbacCompartment("c1")
        .toUser("user1")
        .withReadWriteAccess()
        .inPolicy("policy1")
        .build();

// Add a compartment to a user with specifying the default.
AddAbacCompartmentToUserStatement statement3 =
    StatementBuilder.addAbacCompartment("c1")
        .toUser("user1")
        .withDefault()
        .inPolicy("policy1")
        .build();

// Add a compartment to a user with specifying the row to TRUE.
AddAbacCompartmentToUserStatement statement4 =
    StatementBuilder.addAbacCompartment("c1")
        .toUser("user1")
        .withRow(true)
        .inPolicy("policy1")
        .build();

REMOVE ABAC_COMPARTMENT

REMOVE ABAC_COMPARTMENT コマンドは、指定されたポリシー内の指定されたユーザーから指定されたコンパートメントを削除します。

文法

REMOVE ABAC_COMPARTMENT <COMPARTMENT_SHORT_NAME> FROM [USER] <USER_NAME> IN [POLICY] <POLICY_NAME>;

例

REMOVE ABAC_COMPARTMENT の例は次のとおりです。

-- Remove a compartment from a user.
REMOVE ABAC_COMPARTMENT c1 FROM USER user1 IN POLICY policy1;

REMOVE ABAC_COMPARTMENT のステートメントオブジェクトを構築する例は次のとおりです。

// Remove a compartment from a user.
RemoveAbacCompartmentFromUserStatement statement =
    StatementBuilder.removeAbacCompartment("c1").fromUser("user1").inPolicy("policy1").build();

ADD ABAC_GROUP

ADD ABAC_GROUP コマンドは、指定されたポリシー内の指定されたユーザーに指定された ABAC グループを追加します。

文法

ADD ABAC_GROUP <GROUP_SHORT_NAME> TO [USER] <USER_NAME> [WITH {accessMode [AND default] [AND row] | default [AND row] | row}] IN [POLICY] <POLICY_NAME>;

accessMode: READ_ONLY_ACCESS | READ_WRITE_ACCESS
default: DEFAULT [= {TRUE | FALSE}]
row: ROW [=  {TRUE | FALSE}]

• アクセスモードを省略すると、デフォルトのアクセスモードは READ_ONLY_ACCESS になります。
• デフォルト部分を省略すると、グループはデフォルトのコンパートメントに含まれます。
• 行部分を省略すると、グループは行コンパートメントに含まれません。
• default または row のブーリアンリテラルを省略すると、default または row の値は TRUE に設定されます。

例

ADD ABAC_GROUP の例は次のとおりです。

-- Add a group to a user without specifying the access mode, default, and row.
ADD ABAC_GROUP g1 TO USER user1 IN POLICY policy1;

-- Add a group to a user with the READ_WRITE_ACCESS access mode.
ADD ABAC_GROUP g1 TO USER user1 WITH READ_WRITE_ACCESS IN POLICY policy1;

-- Add a group to a user with specifying the default.
ADD ABAC_GROUP g1 TO USER user1 WITH DEFAULT IN POLICY policy1;

-- Add a group to a user with specifying the row to TRUE.
ADD ABAC_GROUP g1 TO USER user1 WITH ROW = TRUE IN POLICY policy1;

ADD ABAC_GROUP のステートメントオブジェクトを構築する例は次のとおりです。

// Add a group to a user without specifying the access mode, default, and row.
AddAbacGroupToUserStatement statement1 =
    StatementBuilder.addAbacGroup("g1").toUser("user1").inPolicy("policy1").build();

// Add a group to a user with the READ_WRITE_ACCESS access mode.
AddAbacGroupToUserStatement statement2 =
    StatementBuilder.addAbacGroup("g1")
        .toUser("user1")
        .withReadWriteAccess()
        .inPolicy("policy1")
        .build();

// Add a group to a user with specifying the default.
AddAbacGroupToUserStatement statement3 =
    StatementBuilder.addAbacGroup("g1")
        .toUser("user1")
        .withDefault()
        .inPolicy("policy1")
        .build();

// Add a group to a user with specifying the row to TRUE.
AddAbacGroupToUserStatement statement4 =
    StatementBuilder.addAbacGroup("g1")
        .toUser("user1")
        .withRow(true)
        .inPolicy("policy1")
        .build();

REMOVE ABAC_GROUP

REMOVE ABAC_GROUP コマンドは、指定されたポリシー内の指定されたユーザーから指定された ABAC グループを削除します。

文法

REMOVE ABAC_GROUP <GROUP_SHORT_NAME> FROM [USER] <USER_NAME> IN [POLICY] <POLICY_NAME>;

例

REMOVE ABAC_GROUP の例は次のとおりです。

-- Remove a group from a user.
REMOVE ABAC_GROUP g1 FROM USER user1 IN POLICY policy1;

REMOVE ABAC_GROUP のステートメントオブジェクトを構築する例は次のとおりです。

// Remove a group from a user.
RemoveAbacGroupFromUserStatement statement =
    StatementBuilder.removeAbacGroup("g1").fromUser("user1").inPolicy("policy1").build();

DROP ABAC_USER_TAG_INFO

DROP ABAC_USER_TAG_INFO コマンドは、指定されたポリシー内の指定されたユーザーから指定された ABAC ユーザータグ情報を削除します。

文法

DROP ABAC_USER_TAG_INFO FROM [USER] <USER_NAME> IN [POLICY] <POLICY_NAME>;

例

DROP ABAC_USER_TAG_INFO の例は次のとおりです。

-- Drop user tag information from a user.
DROP ABAC_USER_TAG_INFO FROM USER user1 IN POLICY policy1;

DROP ABAC_USER_TAG_INFO のステートメントオブジェクトを構築する例は次のとおりです。

// Drop user tag information from a user.
DropAbacUserTagInfoFromUserStatement statement =
    StatementBuilder.dropAbacUserTagInfoFromUser("user1").inPolicy("policy1").build();

CREATE ABAC_NAMESPACE_POLICY

CREATE ABAC_NAMESPACE_POLICY コマンドは、指定されたポリシーと名前空間を使用して、指定された名前空間ポリシー名で新しい ABAC 名前空間ポリシーを作成します。このコマンドは、ポリシーを指定された名前空間に適用するために使用されます。新しく追加された名前空間ポリシーはデフォルトで有効になります。

文法

CREATE ABAC_NAMESPACE_POLICY <NAMESPACE POLICY_NAME> USING [POLICY] <POLICY_NAME> AND [NAMESPACE] <NAMESPACE_NAME>;

例

CREATE ABAC_NAMESPACE_POLICY の例は次のとおりです。

-- Create an ABAC namespace policy.
CREATE ABAC_NAMESPACE_POLICY ns_policy1 USING POLICY policy1 AND NAMESPACE ns;

CREATE ABAC_NAMESPACE_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Create an ABAC namespace policy.
CreateAbacNamespacePolicyStatement statement =
    StatementBuilder.createAbacNamespacePolicy("ns_policy1")
        .usingPolicy("policy1")
        .andNamespace("ns")
        .build();

ENABLE ABAC_NAMESPACE_POLICY

ENABLE ABAC_NAMESPACE_POLICY コマンドは、指定された ABAC 名前空間ポリシーを有効にします。

文法

ENABLE ABAC_NAMESPACE_POLICY <NAMESPACE POLICY_NAME>;

例

ENABLE ABAC_NAMESPACE_POLICY の例は次のとおりです。

-- Enable an ABAC namespace policy.
ENABLE ABAC_NAMESPACE_POLICY ns_policy1;

ENABLE ABAC_NAMESPACE_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Enable an ABAC namespace policy.
EnableAbacNamespacePolicyStatement statement =
    StatementBuilder.enableAbacNamespacePolicy("ns_policy1").build();

DISABLE ABAC_NAMESPACE_POLICY

DISABLE ABAC_NAMESPACE_POLICY コマンドは、指定された ABAC 名前空間ポリシーを無効にします。このコマンドは、指定された名前空間ポリシーに関連付けられた名前空間の ABAC 機能を実質的に無効にします。

文法

DISABLE ABAC_NAMESPACE_POLICY <NAMESPACE POLICY_NAME>;

例

DISABLE ABAC_NAMESPACE_POLICY の例は次のとおりです。

-- Disable an ABAC namespace policy.
DISABLE ABAC_NAMESPACE_POLICY ns_policy1;

DISABLE ABAC_NAMESPACE_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Disable an ABAC namespace policy.
DisableAbacNamespacePolicyStatement statement =
    StatementBuilder.disableAbacNamespacePolicy("ns_policy1").build();

CREATE ABAC_TABLE_POLICY

CREATE ABAC_TABLE_POLICY コマンドは、指定されたポリシーとテーブルを使用して、指定されたテーブルポリシー名で新しい ABAC テーブルポリシーを作成します。このコマンドは、ポリシーを指定されたテーブルに適用するために使用されます。新しく追加されたテーブルポリシーはデフォルトで有効になります。

文法

CREATE ABAC_TABLE_POLICY <TABLE_POLICY_NAME> USING [POLICY] <POLICY_NAME> AND [TABLE] <NAMESPACE_NAME>.<TABLE_NAME>;

例

CREATE ABAC_TABLE_POLICY の例は次のとおりです。

-- Create an ABAC table policy.
CREATE ABAC_TABLE_POLICY tbl_policy1 USING POLICY policy1 AND TABLE ns.tbl;

CREATE ABAC_TABLE_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Create an ABAC table policy.
CreateAbacTablePolicyStatement statement =
    StatementBuilder.createAbacTablePolicy("tbl_policy1")
        .usingPolicy("policy1")
        .andTable("ns", "tbl")
        .build();

ENABLE ABAC_TABLE_POLICY

ENABLE ABAC_TABLE_POLICY コマンドは、指定された ABAC テーブルポリシーを有効にします。

文法

ENABLE ABAC_TABLE_POLICY <TABLE_POLICY_NAME>;

例

ENABLE ABAC_TABLE_POLICY の例は次のとおりです。

-- Enable an ABAC table policy.
ENABLE ABAC_TABLE_POLICY tbl_policy1;

ENABLE ABAC_TABLE_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Enable an ABAC table policy.
EnableAbacTablePolicyStatement statement =
    StatementBuilder.enableAbacTablePolicy("tbl_policy1").build();

DISABLE ABAC_TABLE_POLICY

DISABLE ABAC_TABLE_POLICY コマンドは、指定された ABAC テーブルポリシーを無効にします。このコマンドは、指定されたテーブルポリシーに関連付けられたテーブルの ABAC 機能を実質的に無効にします。

文法

DISABLE ABAC_TABLE_POLICY <TABLE_POLICY_NAME>;

例

DISABLE ABAC_TABLE_POLICY の例は次のとおりです。

-- Disable an ABAC table policy.
DISABLE ABAC_TABLE_POLICY tbl_policy1;

DISABLE ABAC_TABLE_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Disable an ABAC table policy.
DisableAbacTablePolicyStatement statement =
    StatementBuilder.disableAbacTablePolicy("tbl_policy1").build();

その他

USE

USE コマンドはデフォルトの名前空間を指定します。SQL で名前空間名が省略されている場合は、デフォルトの名前空間が使用されます。

文法

USE <namespace name>

例

USE の例は次のとおりです。

-- Specify a default namespace name "ns"
USE ns;

USE のステートメントオブジェクトを構築する例は次のとおりです。

// Specify a default namespace name "ns"
UseStatement statement = StatementBuilder.use("ns").build();

BEGIN

BEGIN コマンドはトランザクションを開始します。

このコマンドは次の列を返します:

• transactionId: TEXT - 開始したトランザクションに関連付けられたトランザクション ID

文法

BEGIN

例

BEGIN のステートメントオブジェクトを構築する例は次のとおりです。

// Begin a transaction
BeginStatement statement = StatementBuilder.begin().build();

START TRANSACTION

START TRANSACTION コマンドはトランザクションを開始します。このコマンドは BEGIN の別名です。

このコマンドは次の列を返します:

• transactionId: TEXT - 開始したトランザクションに関連付けられたトランザクション ID

文法

START TRANSACTION

例

START TRANSACTION のステートメントオブジェクトを構築する例は次のとおりです。

// Start a transaction.
StartTransactionStatement statement = StatementBuilder.startTransaction().build();

JOIN

JOIN コマンドは、指定されたトランザクション ID に関連付けられたトランザクションを結合します。

文法

JOIN <transaction ID>

例

JOIN の例は次のとおりです。

-- Join a transaction
JOIN 'id';

JOIN のステートメントオブジェクトを構築する例は次のとおりです。

// Join a transaction
JoinStatement statement = StatementBuilder.join("id").build();

PREPARE

PREPARE コマンドは現在のトランザクションを準備します。

文法

PREPARE

例

PREPARE のステートメントオブジェクトを構築する例は次のとおりです。

// Prepare the current transaction
PrepareStatement statement = StatementBuilder.prepare().build();

VALIDATE

VALIDATE コマンドは現在のトランザクションを検証します。

文法

VALIDATE

例

VALIDATE のステートメントオブジェクトを構築する例は次のとおりです。

// Validate the current transaction
ValidateStatement statement = StatementBuilder.validate().build();

COMMIT

COMMIT コマンドは現在のトランザクションをコミットします。

文法

COMMIT

例

COMMIT のステートメントオブジェクトを構築する例は次のとおりです。

// Commit the current transaction
CommitStatement statement = StatementBuilder.commit().build();

ROLLBACK

ROLLBACK コマンドは現在のトランザクションをロールバックします。

文法

ROLLBACK

例

ROLLBACK のステートメントオブジェクトを構築する例は次のとおりです。

// Rollback the current transaction
RollbackStatement statement = StatementBuilder.rollback().build();

ABORT

ABORT コマンドは現在のトランザクションをロールバックします。このコマンドは ROLLBACK の別名です。

文法

ABORT

例

ABORT のステートメントオブジェクトを構築する例は次のとおりです。

// Abort the current transaction.
AbortStatement statement = StatementBuilder.abort().build();

SET MODE

SET MODE コマンドは、現在のトランザクションモードを切り替えます。

文法

SET MODE transaction_mode

transaction_mode: TRANSACTION | TWO_PHASE_COMMIT_TRANSACTION

例

SET MODE の例は次のとおりです。

-- Switch the current transaction mode to Two-phase Commit Transaction
SET MODE TWO_PHASE_COMMIT_TRANSACTION;

SET MODE のステートメントオブジェクトを構築する例は次のとおりです。

// Switch the current transaction mode to Two-phase Commit Transaction
SetModeStatement statement =
    StatementBuilder.setMode(TransactionMode.TWO_PHASE_COMMIT_TRANSACTION).build();

SHOW NAMESPACES

SHOW NAMESPACES コマンドは名前空間名を表示します。

このコマンドは次の列を返します:

• namespaceName: TEXT - 名前空間名

文法

SHOW NAMESPACES

例

SHOW NAMESPACES のステートメントオブジェクトを構築する例は次のとおりです。

// Show namespace names.
ShowNamespacesStatement statement = StatementBuilder.showNamespaces().build();

SHOW TABLES

SHOW TABLES コマンドは、名前空間内のテーブル名を表示します。名前空間名を省略すると、デフォルトの名前空間が使用されます。

このコマンドは次の列を返します:

• tableName: TEXT - テーブル名

文法

SHOW TABLES [FROM <namespace name>]

例

SHOW TABLES の例は次のとおりです。

-- Show table names in the default namespace
SHOW TABLES;

-- Show table names in a namespace "ns"
SHOW TABLES FROM ns;

SHOW TABLES のステートメントオブジェクトを構築する例は次のとおりです。

// Show table names in the default namespace
ShowTablesStatement statement1 = StatementBuilder.showTables().build();

// Show table names in a namespace "ns"
ShowTablesStatement statement2 = StatementBuilder.showTables().from("ns").build();

DESCRIBE

DESCRIBE コマンドは、指定されたテーブルの列メタデータを返します。

このコマンドは次の列を返します:

• columnName: TEXT - テーブル名
• type: TEXT - タイプ名
• isPrimaryKey: BOOLEAN - 主キーに含まれるかどうか
• isPartitionKey: BOOLEAN - パーティションキーの列部分であるかどうか
• isClusteringKey: BOOLEAN - クラスタリングキーの列部分であるかどうか
• clusteringOrder: TEXT - クラスタリング順序
• isIndexed: BOOLEAN - インデックス付き列であるかどうか

文法

DESCRIBE [<namespace name>.]<table name>

DESC [<namespace name>.]<table name>

例

DESCRIBE の例は次のとおりです。

-- Returns column metadata for "ns.tbl"
DESCRIBE ns.tbl;

-- Returns column metadata for "tbl"
DESC tbl;

DESCRIBE のステートメントオブジェクトを構築する例は次のとおりです。

// Returns column metadata for "ns.tbl"
DescribeStatement statement1 = StatementBuilder.describe("ns", "tbl").build();

// Returns column metadata for "tbl"
DescribeStatement statement2 = StatementBuilder.describe("tbl").build();

SUSPEND

SUSPEND コマンドは、現在のセッションで進行中のトランザクションを一時停止します。

文法

SUSPEND

例

SUSPEND のステートメントオブジェクトを構築する例は次のとおりです。

// Suspend the ongonig transaction in the current session
SuspendStatement statement = StatementBuilder.suspend().build();

RESUME

RESUME コマンドは、現在のセッションで指定されたトランザクション ID に関連付けられたトランザクションを再開します。

文法

RESUME <transaction ID>

例

RESUME の例は次のとおりです。

-- Resume a transaction
RESUME 'id';

RESUME のステートメントオブジェクトを構築する例は次のとおりです。

// Resume a transaction
ResumeStatement statement = StatementBuilder.resume("id").build();

SHOW USERS

SHOW USERS コマンドは、ユーザー名とユーザー属性を表示します。スーパーユーザーの場合は、すべてのユーザーを表示できます。通常のユーザーの場合は、自分のユーザー名と属性のみを表示できます。

このコマンドは次の列を返します:

• username: TEXT - ユーザー名
• isSuperuser: BOOLEAN - ユーザーがスーパーユーザーであるかどうか

文法

SHOW USERS

例

SHOW USERS の例は次のとおりです。

-- Show usernames and user attributes
SHOW USERS;

SHOW USERS のステートメントオブジェクトを構築する例は次のとおりです。

// Show usernames and user attributes
ShowUsersStatement statement = StatementBuilder.showUsers().build();

SHOW GRANTS

SHOW GRANTS コマンドは、現在のユーザーまたは指定されたユーザーに付与された権限を表示します。

このコマンドは次の列を返します:

• name: TEXT - タイプに応じて名前空間名またはテーブル名
• type: TEXT - オブジェクトのタイプ (NAMESPACE または TABLE)
• privilege: TEXT - 権限

文法

-- Show privileges granted to the current user
SHOW GRANTS

-- Show privileges granted to the specified user
SHOW GRANTS FOR [USER] <username>

例

SHOW GRANTS の例は次のとおりです。

-- Show privileges granted to the current user
SHOW GRANTS;

-- Show privileges granted to user1
SHOW GRANTS FOR user1;

SHOW GRANTS のステートメントオブジェクトを構築する例は次のとおりです。

// Show privileges granted to the current user
ShowGrantsStatement statement1 = StatementBuilder.showGrants().build();

// Show privileges granted to user1
ShowGrantsStatement statement2 = StatementBuilder.showGrants().forUser("user1").build();

SHOW ABAC_POLICY

SHOW ABAC_POLICY コマンドは、指定された ABAC ポリシーを表示します。

このコマンドは次の列を返します:

• name: TEXT - ポリシー名
• dataTagColumnName: TEXT - データタグ列名
• state: TEXT - ポリシーの状態 (ENABLED または DISABLED)

文法

SHOW ABAC_POLICY <POLICY_NAME>;

例

SHOW ABAC_POLICY の例は次のとおりです。

-- Show the specified ABAC policy
SHOW ABAC_POLICY policy1;

SHOW ABAC_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Show the specified ABAC policy
ShowAbacPolicyStatement statement = StatementBuilder.showAbacPolicy("policy1").build();

SHOW ABAC_POLICIES

SHOW ABAC_POLICIES コマンドは、すべての ABAC ポリシーを表示します。

このコマンドは次の列を返します:

• name: TEXT - ポリシー名
• dataTagColumnName: TEXT - データタグ列名
• state: TEXT - ポリシーの状態 (ENABLED または DISABLED)

文法

SHOW ABAC_POLICIES;

例

SHOW ABAC_POLICIES の例は次のとおりです。

-- Show all ABAC policies
SHOW ABAC_POLICIES;

SHOW ABAC_POLICIES のステートメントオブジェクトを構築する例は次のとおりです。

// Show all ABAC policies
ShowAbacPoliciesStatement statement = StatementBuilder.showAbacPolicies().build();

SHOW ABAC_LEVEL

SHOW ABAC_LEVEL コマンドは、指定されたポリシー内の指定された ABAC レベルを表示します。

このコマンドは次の列を返します:

• policyName: TEXT - ポリシー名
• shortName: TEXT - レベルの短縮名
• longName: TEXT - レベルの長い名前
• levelNumber: INTEGER - レベルのレベル番号

文法

SHOW ABAC_LEVEL <LEVEL_SHORT_NAME> IN [POLICY] <POLICY_NAME>;

例

SHOW ABAC_LEVEL の例は次のとおりです。

-- Show the specified ABAC level in the specified policy
SHOW ABAC_LEVEL l1 IN POLICY policy1;

SHOW ABAC_LEVEL のステートメントオブジェクトを構築する例は次のとおりです。

// Show the specified ABAC level in the specified policy
ShowAbacLevelStatement statement = StatementBuilder.showAbacLevel("l1").inPolicy("policy1").build();

SHOW ABAC_LEVELS

SHOW ABAC_LEVELS コマンドは、指定されたポリシー内のすべての ABAC レベルを表示します。

このコマンドは次の列を返します:

• policyName: TEXT - ポリシー名
• shortName: TEXT - レベルの短縮名
• longName: TEXT - レベルの長い名前
• levelNumber: INTEGER - レベルのレベル番号

文法

SHOW ABAC_LEVELS IN [POLICY] <POLICY_NAME>;

例

SHOW ABAC_LEVELS の例は次のとおりです。

-- Show all ABAC levels in the specified policy
SHOW ABAC_LEVELS IN POLICY policy1;

SHOW ABAC_LEVELS のステートメントオブジェクトを構築する例は次のとおりです。

// Show all ABAC levels in the specified policy
ShowAbacLevelsStatement statement = StatementBuilder.showAbacLevelsInPolicy("policy1").build();

SHOW ABAC_COMPARTMENT

SHOW ABAC_COMPARTMENT コマンドは、指定されたポリシー内の指定された ABAC コンパートメントを表示します。

このコマンドは次の列を返します:

• policyName: TEXT - ポリシー名
• shortName: TEXT - コンパートメントの短縮名
• longName: TEXT - コンパートメントの長い名前

文法

SHOW ABAC_COMPARTMENT <COMPARTMENT_SHORT_NAME> IN [POLICY] <POLICY_NAME>;

例

SHOW ABAC_COMPARTMENT の例は次のとおりです。

-- Show the specified ABAC compartment in the specified policy
SHOW ABAC_COMPARTMENT c1 IN POLICY policy1;

SHOW ABAC_COMPARTMENT のステートメントオブジェクトを構築する例は次のとおりです。

// Show the specified ABAC compartment in the specified policy
ShowAbacCompartmentStatement statement =
    StatementBuilder.showAbacCompartment("c1").inPolicy("policy1").build();

SHOW ABAC_COMPARTMENTS

SHOW ABAC_COMPARTMENTS コマンドは、指定されたポリシー内のすべての ABAC コンパートメントを表示します。

このコマンドは次の列を返します:

• policyName: TEXT - ポリシー名
• shortName: TEXT - コンパートメントの短縮名
• longName: TEXT - コンパートメントの長い名前

文法

SHOW ABAC_COMPARTMENTS IN [POLICY] <POLICY_NAME>;

例

SHOW ABAC_COMPARTMENTS の例は次のとおりです。

-- Show all ABAC compartments in the specified policy
SHOW ABAC_COMPARTMENTS IN POLICY policy1;

SHOW ABAC_COMPARTMENTS のステートメントオブジェクトを構築する例は次のとおりです。

// Show all ABAC compartments in the specified policy
ShowAbacCompartmentsStatement statement =
    StatementBuilder.showAbacCompartmentsInPolicy("policy1").build();

SHOW ABAC_GROUP

SHOW ABAC_GROUP コマンドは、指定されたポリシー内の指定された ABAC グループを表示します。

このコマンドは次の列を返します:

• policyName: TEXT - ポリシー名
• shortName: TEXT - グループの短縮名
• longName: TEXT - グループの長い名前
• parentGroupShortName: TEXT - 親グループの短縮名。グループに親グループがない場合、この列は null になります。

文法

SHOW ABAC_GROUP <GROUP_SHORT_NAME> IN [POLICY] <POLICY_NAME>;

例

SHOW ABAC_GROUP の例は次のとおりです。

-- Show the specified ABAC group in the specified policy
SHOW ABAC_GROUP g1 IN POLICY policy1;

SHOW ABAC_GROUP のステートメントオブジェクトを構築する例は次のとおりです。

// Show the specified ABAC group in the specified policy
ShowAbacGroupStatement statement =
    StatementBuilder.showAbacGroup("g1").inPolicy("policy1").build();

SHOW ABAC_GROUPS

SHOW ABAC_GROUPS コマンドは、指定されたポリシー内のすべての ABAC グループを表示します。

このコマンドは次の列を返します:

• policyName: TEXT - ポリシー名
• shortName: TEXT - グループの短縮名
• longName: TEXT - グループの長い名前
• parentGroupShortName: TEXT - 親グループの短縮名。グループに親グループがない場合、この列は null になります。

文法

SHOW ABAC_GROUPS IN [POLICY] <POLICY_NAME>;

例

SHOW ABAC_GROUPS の例は次のとおりです。

-- Show all ABAC groups in the specified policy
SHOW ABAC_GROUPS IN POLICY policy1;

SHOW ABAC_GROUPS のステートメントオブジェクトを構築する例は次のとおりです。

// Show all ABAC groups in the specified policy
ShowAbacGroupsStatement statement = StatementBuilder.showAbacGroupsInPolicy("policy1").build();

SHOW ABAC_USER_TAG_INFO

SHOW ABAC_USER_TAG_INFO コマンドは、指定されたポリシー内の指定されたユーザーの ABAC ユーザータグ情報を表示します。

このコマンドは次の列を返します:

• policyName: TEXT - ポリシー名
• username: TEXT - ユーザー名
• readTag: TEXT - 読み取りタグ
• writeTag: TEXT - 書き込みタグ
• defaultReadTag: TEXT - デフォルトの読み取りタグ
• defaultWriteTag: TEXT - デフォルトの書き込みタグ
• rowTag: TEXT - 行タグ

文法

SHOW ABAC_USER_TAG_INFO [FOR USER <USER_NAME>] IN [POLICY] <POLICY_NAME>;

• ユーザーを省略すると、現在のユーザーのユーザータグ情報が表示されます。

例

SHOW ABAC_USER_TAG_INFO の例は次のとおりです。

-- Show the ABAC user tag information for the current user in the specified policy
SHOW ABAC_USER_TAG_INFO IN POLICY policy1;

-- Show the ABAC user tag information for user1 in the specified policy
SHOW ABAC_USER_TAG_INFO FOR USER user1 IN POLICY policy1;

SHOW ABAC_USER_TAG_INFO のステートメントオブジェクトを構築する例は次のとおりです。

// Show the ABAC user tag information for the current user in the specified policy
ShowAbacUserTagInfoStatement statement1 =
    StatementBuilder.showAbacUserTagInfo().inPolicy("policy1").build();

// Show the ABAC user tag information for user1 in the specified policy
ShowAbacUserTagInfoStatement statement2 =
    StatementBuilder.showAbacUserTagInfo().forUser("user1").inPolicy("policy1").build();

SHOW ABAC_NAMESPACE_POLICY

SHOW ABAC_NAMESPACE_POLICY コマンドは、指定された ABAC 名前空間ポリシーを表示します。

このコマンドは次の列を返します:

• name: TEXT - 名前空間ポリシーの名前
• policyName: TEXT - ポリシー名
• namespaceName: TEXT - 名前空間名
• state: TEXT - ポリシーの状態 (ENABLED または DISABLED)

文法

SHOW ABAC_NAMESPACE_POLICY <NAMESPACE_POLICY_NAME>;

例

SHOW ABAC_NAMESPACE_POLICY の例は次のとおりです。

-- Show the specified ABAC namespace policy
SHOW ABAC_NAMESPACE_POLICY ns_policy1;

SHOW ABAC_NAMESPACE_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Show the specified ABAC namespace policy
ShowAbacNamespacePolicyStatement statement =
    StatementBuilder.showAbacNamespacePolicy("ns_policy1").build();

SHOW ABAC_NAMESPACE_POLICIES

SHOW ABAC_NAMESPACE_POLICIES コマンドは、すべての ABAC 名前空間ポリシーを表示します。

このコマンドは次の列を返します:

• name: TEXT - 名前空間ポリシーの名前
• policyName: TEXT - ポリシー名
• namespaceName: TEXT - 名前空間名
• state: TEXT - ポリシーの状態 (ENABLED または DISABLED)

文法

SHOW ABAC_NAMESPACE_POLICIES

例

SHOW ABAC_NAMESPACE_POLICIES の例は次のとおりです。

-- Show all ABAC namespace policies
SHOW ABAC_NAMESPACE_POLICIES;

SHOW ABAC_NAMESPACE_POLICIES のステートメントオブジェクトを構築する例は次のとおりです。

// Show all ABAC namespace policies
ShowAbacNamespacePoliciesStatement statement =
    StatementBuilder.showAbacNamespacePolicies().build();

SHOW ABAC_TABLE_POLICY

SHOW ABAC_TABLE_POLICY コマンドは、指定された ABAC テーブルポリシーを表示します。

このコマンドは次の列を返します:

• name: TEXT - テーブルポリシーの名前
• policyName: TEXT - ポリシー名
• namespaceName: TEXT - 名前空間名
• tableName: TEXT - テーブル名
• state: TEXT - ポリシーの状態 (ENABLED または DISABLED)

文法

SHOW ABAC_TABLE_POLICY <TABLE_POLICY_NAME>;

例

SHOW ABAC_TABLE_POLICY の例は次のとおりです。

-- Show the specified ABAC table policy
SHOW ABAC_TABLE_POLICY tbl_policy1;

SHOW ABAC_TABLE_POLICY のステートメントオブジェクトを構築する例は次のとおりです。

// Show the specified ABAC table policy
ShowAbacTablePolicyStatement statement =
    StatementBuilder.showAbacTablePolicy("tbl_policy1").build();

SHOW ABAC_TABLE_POLICIES

SHOW ABAC_TABLE_POLICIES コマンドは、すべての ABAC テーブルポリシーを表示します。

このコマンドは次の列を返します:

• name: TEXT - テーブルポリシーの名前
• policyName: TEXT - ポリシー名
• namespaceName: TEXT - 名前空間名
• tableName: TEXT - テーブル名
• state: TEXT - ポリシーの状態 (ENABLED または DISABLED)

文法

SHOW ABAC_TABLE_POLICIES;

例

SHOW ABAC_TABLE_POLICIES の例は次のとおりです。

-- Show all ABAC table policies
SHOW ABAC_TABLE_POLICIES;

SHOW ABAC_TABLE_POLICIES のステートメントオブジェクトを構築する例は次のとおりです。

// Show all ABAC table policies
ShowAbacTablePoliciesStatement statement = StatementBuilder.showAbacTablePolicies().build();

リテラル

リテラルと列の値は同義であり、SQL ステートメントを記述するときに使用される固定データ値を参照します。たとえば、1、'abc'、1.23、および '2024-05-19' はリテラルです。

テキスト

テキストリテラルは、'abc' や 'abc def' など、一重引用符 ' で囲まれた文字のシーケンスです。

数値

数値リテラルには、正確な値 (INTEGER および BIGINT) と近似値 (FLOAT および DOUBLE) のリテラルが含まれます。

正確な値リテラルは、123 や -5 などの数字のシーケンスです。

近似値リテラルは、4.754 や -1.2 などの小数点付きの数字のシーケンスです。

日付と時刻

日付と時刻リテラルは、DATE、TIME、TIMESTAMP、および TIMESTAMPTZ 値を表す特定の形式に従うテキストリテラルです。

ScalarDB データ型	形式	注記	例
DATE	'YYYY-MM-DD'		'2024-05-19'
TIME	'HH:MM:[SS[.FFFFFF]]'	秒と小数秒 (最大1マイクロ秒) はオプションです。	'12:34'、'12:34:56'、'12:34:56.789123'
TIMESTAMP	'YYYY-MM-DD HH:MM:[SS[.FFF]]'	秒と小数秒 (最大1ミリ秒) はオプションです。	'2024-05-19 12:34'、'2024-05-19 12:34:56'、'2024-05-19 12:34:56.789'
TIMESTAMPTZ	'YYYY-MM-DD HH:MM:[SS[.FFF]] Z'	秒と小数秒 (最大1ミリ秒) はオプションです。	'2024-05-19 12:34 Z'、'2024-05-19 12:34:56 Z'、'2024-05-19 12:34:56.789 Z'