PolarDB:クイックスタート

プラグインの作成

このトピックの操作を実行するには、特権アカウントを使用する必要があります。特権アカウントの作成方法の詳細については、「データベースアカウントの作成」をご参照ください。

CREATE EXTENSION age;

データベースの設定

各接続で、クエリを簡素化するために ag_catalog スキーマを search_path に追加し、get_cypher_keywords 関数を使用して拡張機能をロードします。

SET search_path = ag_catalog, "$user", public;
SELECT * FROM get_cypher_keywords() limit 0;

特権アカウントを使用してデータベースパラメーターを設定し、拡張機能を永続的にロードすることができます。これにより、各接続で前述の操作を繰り返す必要がなくなり、プロセスが簡素化されます。

ALTER DATABASE <dbname> SET search_path = "$user", public, ag_catalog;
ALTER DATABASE <dbname> SET session_preload_libraries TO 'age';

一般ユーザーへの AGE の使用許可

ag_catalog スキーマに対する USAGE 権限を一般ユーザーに付与できます。

GRANT USAGE ON SCHEMA ag_catalog TO <username>;

一般ユーザーが読み取り/書き込みユーザーである場合は、テーブルを作成するための CREATE 権限も付与する必要があります。

GRANT CREATE ON DATABASE <dbname> TO <username>;

クエリ構造

PolarDB では、Cypher クエリは ag_catalog スキーマ内の cypher という名前の関数を呼び出すことによって構築されます。この関数は SETOF レコードを返します。以下は典型的なクエリの例です。

SELECT * FROM cypher('graph_name', $$
/* ここに Cypher クエリを記述します */
$$) AS (result1 agtype, result2 agtype);

この例では、graph_name はグラフの名前です。/* */ 内のコンテンツを実際の Cypher クエリに置き換えてください。

グラフの作成

グラフを使用する前に、まずグラフを作成する必要があります。ag_catalog 名前空間の create_graph 関数を使用してグラフを作成できます。

構文：

SELECT create_graph('<graph_name>');

例：

moviedb という名前のグラフを作成します。

SELECT create_graph('moviedb');

データの挿入

次の SQL 文を使用して、サンプルデータを moviedb グラフに挿入できます。

SELECT * FROM cypher('moviedb', $$
  CREATE (matrix:Movie {title: 'The Matrix', released: 1997})
  CREATE (cloudAtlas:Movie {title: 'Cloud Atlas', released: 2012})
  CREATE (forrestGump:Movie {title: 'Forrest Gump', released: 1994})
  CREATE (keanu:Person {name: 'Keanu Reeves', born: 1964})
  CREATE (robert:Person {name: 'Robert Zemeckis', born: 1951})
  CREATE (tom:Person {name: 'Tom Hanks', born: 1956})
  CREATE (tom)-[:ACTED_IN {roles: ['Forrest']}]->(forrestGump)
  CREATE (tom)-[:ACTED_IN {roles: ['Zachry']}]->(cloudAtlas)
  CREATE (robert)-[:DIRECTED]->(forrestGump)
$$) AS (result1 agtype);

この文は、6 つのノードと 3 つのエッジを作成します。3 つのノードには Movie ラベルがあり、3 つのノードには Person ラベルがあります。2 つのエッジには ACTED_IN ラベルがあり、1 つのエッジには DIRECTED ラベルがあります。次のリレーションシップグラフが作成されます。

データのクエリ

SELECT * FROM cypher('graph_name', $$
  MATCH <patterns>
  RETURN <variables>
$$) AS (result1 agtype);

ノードまたはエッジの作成

Cypher では、CREATE キーワードを使用して新しいノードまたはエッジを作成できます。

構文：

SELECT * FROM cypher('<graph_name>', $$
  CREATE <patterns>
$$) AS (result1 agtype);

例：

• Person ラベルを持つノードを作成します。name プロパティを Tom Tykwer に、born プロパティを 1965 に設定します。

  SELECT * FROM cypher('moviedb', $$
    CREATE (:Person {name: 'Tom Tykwer', born: 1965})
  $$) AS (result1 agtype);

• Person Tom Tykwer と映画 Cloud Atlas の間にエッジを作成し、Tom Tykwer が映画 Cloud Atlas を監督したことを表します。

  SELECT * FROM cypher('moviedb', $$
    MATCH (p:Person), (m:Movie)
    WHERE p.name='Tom Tykwer' AND m.title='Cloud Atlas'                 
    CREATE (p)-[:DIRECTED]->(m)
  $$) AS (result1 agtype);

MERGE を使用した重複データ挿入の回避

同じ CREATE 文が複数回実行されると、複数の重複データエントリが挿入されます。このような重複データを防ぐために、挿入に MERGE キーワードを使用できます。MERGE は選択または挿入操作を実行します。まず、データがデータベースに既に存在するかどうかを確認します。データが存在する場合、データをそのまま返すか、既存のノードまたはリレーションシップを更新します。データが存在しない場合、Cypher は指定された情報に基づいてデータを作成します。

構文：

SELECT * FROM cypher('<graph_name>', $$
  MERGE <patterns>
$$) AS (result1 agtype);

例：

• Person ラベルを持つノードを作成します。name プロパティを Tom Cruise に、born プロパティを 1962 に設定します。

  SELECT * FROM cypher('moviedb', $$
    MERGE (:Person {name: 'Tom Cruise', born: 1962})
  $$) AS (result1 agtype);

• Tom Hanks と Tom Cruise の間にエッジを作成し、友人関係を表します。

  SELECT * FROM cypher('moviedb', $$
    MATCH (t1:Person),(t2:Person)
    WHERE t1.name='Tom Hanks' AND t2.name='Tom Cruise'                 
    MERGE (t1)-[:FRIEND]-(t2)
  $$) AS (result1 agtype);

更新

既に存在するノードやリレーションシップについては、必要なパターンに一致させてプロパティを変更し、SET キーワードを使用してプロパティを追加または更新できます。

構文：

SELECT * FROM cypher('<graph_name>', $$
  MATCH <patterns>
  SET <property>
  RETURN <variable>
$$) AS (result1 agtype);

例：

• Person Tom Tykwer の生年を 1970 に変更します。

  SELECT * FROM cypher('moviedb', $$
    MATCH (p:Person {name: 'Tom Tykwer', born: 1965})
    SET p.born = 1970
    RETURN p
  $$) AS (result1 agtype);

• Person Tom Tykwer に、値が male の gender プロパティを追加します。

  SELECT * FROM cypher('moviedb', $$
    MATCH (p:Person {name: 'Tom Tykwer', born: 1970})
    SET p.gender = 'male'
    RETURN p
  $$) AS (result1 agtype);

削除

Cypher では、DELETE キーワードを使用してノードとエッジを削除できます。

SELECT * FROM cypher('<graph_name>', $$
  MATCH <patterns>
  DELETE <variable>
$$) AS (result1 agtype);

SELECT * FROM cypher('moviedb', $$
  MATCH (p:Person)-[r:DIRECTED]->(m:Movie)
  WHERE p.name='Tom Tykwer' AND m.title='Cloud Atlas'                 
  DELETE r
$$) AS (result1 agtype);

SELECT * FROM cypher('<グラフ名>', $$
  MATCH <パターン>
  DELETE <変数>
$$) AS (result1 agtype);

SELECT * FROM cypher('moviedb', $$
  MATCH (p:Person {name: 'Tom Tykwer', born: 1970})              
  DELETE p
$$) AS (result1 agtype);

SELECT * FROM cypher('<graph_name>', $$
  MATCH <patterns>
  DETACH DELETE <variable>
$$) AS (result1 agtype);

SELECT * FROM cypher('moviedb', $$
  MATCH (p:Person {name: 'Tom Hanks', born: 1956})              
  DETACH DELETE p
$$) AS (result1 agtype);

SELECT * FROM cypher('<graph_name>', $$
  MATCH <match_pattern>
  REMOVE <property>
$$) AS (result1 agtype);

SELECT * FROM cypher('moviedb', $$
  MATCH (m:Movie {title: 'Cloud Atlas', released: 2012})              
  REMOVE m.released
  RETURN m
$$) AS (result1 agtype);

可視化ツール

PolarDB for PostgreSQL と は、オープンソースのグラフエンジン Apache AGE を統合しています。これにより、同じクラスター内で標準 SQL と業界をリードする openCypher グラフクエリ言語の両方を使用できます。グラフデータを効率的に格納、クエリ、分析して、複雑なリレーションシップシナリオに対応できます。詳細については、「グラフアプリケーション」をご参照ください。