本节为您介绍如何在GQL语句中使用Connection对象的gql()方法和gqlStream()方法查询数据库。

每个示例主要展示如何使用所列方法。点击完整示例查看完整代码示例。

GQL（图查询语言）是符合ISO标准的图数据库查询语言。更多GQL的详细信息，请参阅本文档。

gql()

在当前图集或数据库上执行GQL查询语句并返回查询结果。

参数：

• string：待执行的GQL查询语句。
• RequestConfig（可选)：配置请求。

返回值：

• Response：请求的结果。

// 获取图集miniCircle中movie下的5个点并打印其名称

let requestConfig = <RequestType.RequestConfig>{
  graphSetName: "miniCircle",
  useMaster: true,
};

let resp = await conn.gql(
  "MATCH (n:movie) RETURN n LIMIT 5",
  requestConfig
);

let node_list = resp.data?.get(0).asNodes();
node_list?.forEach((node) => {
  console.log(node.get("name"));
});

The Shawshank Redemption
Farewell My Concubine
Léon: The Professional
Titanic
Life is Beautiful

更多示例，请参阅嬴图数据与Node.js类型映射。

gqlStream()

在当前图集或数据库上执行GQL查询语句并以增量形式返回查询结果。在处理大型数据集时，无需立刻加载所有数据至内存中。

参数：

• string：待执行的GQL查询语句。
• QueryResponseStream：流处理监听器。
• RequestConfig（可选）：配置请求。

返回值：

• void

// 获取图集miniCircle的1步路径

let requestConfig = <RequestType.RequestConfig>{
  graphSetName: "miniCircle",
  useMaster: true,
};

let count = 0;
let resp = await conn.gqlStream(
  "MATCH p = ()-[]-() RETURN p",
  {
    onData: async (res) => {
      let paths = res.data?.get(0).asPaths();
      count = count + (paths?.length || 0);
      console.log(count);
    },
    onEnd: () => {
      console.log("End");
    },
    onStart: () => {
      console.log("Start");
    },
    onError: (err) => {
      console.log(err);
    },
  },
  requestConfig
);

Start
Count = 1390
End

完整示例

import { ConnectionPool, printers } from "@ultipa-graph/ultipa-node-sdk5";
import { RequestType } from "@ultipa-graph/ultipa-node-sdk5/dist/types"; 

let sdkUsage = async () => {
  // 设置连接
  //URI示例: hosts="mqj4zouys.us-east-1.cloud.ultipa.com:60010"
  let hosts = [
    "192.168.1.85:60061",
    "192.168.1.86:60061",
    "192.168.1.87:60061",
  ];
  let username = "***";
  let password = "***";
  let connPool = new ConnectionPool(hosts, username, password);

  // 建立与数据库的连接
  let conn = await connPool.getActive();
  let isSuccess = await conn.test();
  console.log(isSuccess);

  // 配置请求
  let requestConfig = <RequestType.RequestConfig>{
    graphSetName: "miniCircle",
    useMaster: true,
  };

  // 获取10个点并打印返回的第一个点的_id和name属性值
  let resp = await conn.gql(
    "MATCH (n:movie) RETURN n LIMIT 10",
    requestConfig
  );

  let node_list = resp.data?.get(0).asNodes();
  if (node_list && node_list.length > 0) {
    console.log(node_list[0]._id, node_list[0].get("name"));
  }
};

sdkUsage().then(console.log).catch(console.log);