Node.js API

See the following link for the full documentation of the Node.js API.

Node.js API documentation

Sync and Async APIs

Ryugraph provides both a sync and an async Node.js API. The async API is the default and is more commonly used when building Ryugraph applications in Node.js.

Async API

The asynchronous API is commonly used when writing Ryugraph applications in Node.js.

const ryugraph = require("ryugraph");

(async () => {
  // Create an empty on-disk database and connect to it
  const db = new ryugraph.Database("example.ryugraph");
  const conn = new ryugraph.Connection(db);

  // Create the tables
  await conn.query("CREATE NODE TABLE User(name STRING PRIMARY KEY, age INT64)");
  await conn.query("CREATE NODE TABLE City(name STRING PRIMARY KEY, population INT64)");
  await conn.query("CREATE REL TABLE Follows(FROM User TO User, since INT64)");
  await conn.query("CREATE REL TABLE LivesIn(FROM User TO City)");

  // Load the data
  await conn.query('COPY User FROM "./data/user.csv"');
  await conn.query('COPY City FROM "./data/city.csv"');
  await conn.query('COPY Follows FROM "./data/follows.csv"');
  await conn.query('COPY LivesIn FROM "./data/lives-in.csv"');

  const queryResult = await conn.query("MATCH (a:User)-[f:Follows]->(b:User) RETURN a.name, f.since, b.name;");

  // Get all rows from the query result
  const rows = await queryResult.getAll();

  // Print the rows
  for (const row of rows) {
    console.log(row);
  }
})();

Sync API

In addition to the standard async Node.js API, Ryugraph also provides a synchronous Node.js API. This is useful for running Ryugraph in a synchronous context, such as debugging or applications where async operations are not desired.

const ryugraph = require("ryugraph");

// Create an empty on-disk database and connect to it
const db = new ryugraph.Database("example.ryugraph");
const conn = new ryugraph.Connection(db);

// Create the tables
conn.querySync("CREATE NODE TABLE User(name STRING PRIMARY KEY, age INT64)");
conn.querySync("CREATE NODE TABLE City(name STRING PRIMARY KEY, population INT64)");
conn.querySync("CREATE REL TABLE Follows(FROM User TO User, since INT64)");
conn.querySync("CREATE REL TABLE LivesIn(FROM User TO City)");

// Load the data
conn.querySync('COPY User FROM "./data/user.csv"');
conn.querySync('COPY City FROM "./data/city.csv"');
conn.querySync('COPY Follows FROM "./data/follows.csv"');
conn.querySync('COPY LivesIn FROM "./data/lives-in.csv"');

const queryResult = conn.querySync(
    """
    MATCH (a:User)-[f:Follows]->(b:User)
    RETURN a.name, f.since, b.name;
    """
);

// Get all rows from the query result
const rows = queryResult.getAllSync();

// Print the rows
for (const row of rows) {
  console.log(row);
}

See the Node.js API documentation for more details on the methods available in the sync and async APIs.

Run multiple queries in one execution

Similarly, in the Node.js API, you can execute multiple Cypher queries separated by semicolons in a single execution. The API will return a list of QueryResult objects.

Async API

const results = await conn.query("RETURN 1; RETURN 2; RETURN 3");
for (const result of results) {
  const rows = await result.getAll();
  console.log(rows);
}

Sync API

const resultsSync = conn.querySync("RETURN 1; RETURN 2; RETURN 3");
for (const result of resultsSync) {
  const rows = result.getAllSync();
  console.log(rows);
}

This will return:

[[1]]
[[2]]
[[3]]