6.9.1.5.3 基本的な問合せの実行

opg4py.pgql Pythonラッパーを使用して、PGQL問合せを実行できます。

Pythonクライアントを使用したPGQL問合せの実行

  • 次のように問い合せるグラフを設定します。
    >>> pgql_conn.set_graph("<graph_name>")
    

    <graph_name>は、グラフの名前です。

  • PGQL SELECT問合せを定義して実行します。次に例を示します。
    >>> pgql = "SELECT e.from_acct_id, e.to_acct_id, e.amount FROM MATCH (n:accounts) -[e:transfers]-> (m:accounts) on bank_graph limit 10"
    
  • 次のように結果セットを実行して出力します。
    >>> pgql_result_set = pgql_statement.execute_query(pgql)
    >>> pgql_result_set.print()
    +------------------------------------+
    | FROM_ACCT_ID | TO_ACCT_ID | AMOUNT |
    +------------------------------------+
    | 781.0        | 712.0      | 1000.0 |
    | 190.0        | 555.0      | 1000.0 |
    | 191.0        | 329.0      | 1000.0 |
    | 198.0        | 57.0       | 1000.0 |
    | 220.0        | 441.0      | 1000.0 |
    | 251.0        | 387.0      | 1000.0 |
    | 254.0        | 188.0      | 1000.0 |
    | 259.0        | 305.0      | 1000.0 |
    | 261.0        | 145.0      | 1000.0 |
    | 263.0        | 40.0       | 1000.0 |
    +------------------------------------+
    
    PgqlResultSet(java_pgql_result_set: oracle.pg.rdbms.pgql.PgqlResultSet, # of results: 0)
    
    

また、to_pandas()メソッドを使用して、前述のコードで取得したPGQL結果セットをPandasデータフレームに変換できます。

ノート:

to_pandas()のコールを正常に実行するには、システムにpandasパッケージをインストールする必要があります。このパッケージは、Pythonクライアントのインストール時に自動的にインストールされます。ただし、to_pandas()のコールに失敗した場合は、pandasモジュールがシステムにインストールされているかどうかを確認してください。このモジュールが見つからない場合は、pandasパッケージを手動でインストールします。