🔗 virtuoso-connector

Package that allows you to create a direct connection to the Virtuoso database and run queries on it. Connection can be used to execute both SQL and SPARQL queries, or even internal database stored procedures.

ℹ Background

Since there is no native Virtuoso driver for NodeJS, the only option is to use Java bindings, which enables communication between a JDBC driver and a NodeJS application.

The @naxmefy/jdbc package provides support for communication with the JDBC driver, which is appropriate because Virtuoso provides a JDBC driver and thus they can be used together. The only disadvantage of this approach is that the process needs to start JVM and whenever it crashes, it crashes the whole application. To prevent the crash of the whole application, the DatabaseConnection manages a pool of child processes (forks) (DatabaseConnectionChild) which are responsible for the queries execution.

Selection of the child process is made by Round Robin load balancing mechanism. Delegation of the execution is done in the form of sending messages through the IPC channel, with a unified interface defined in types.ts file. Once the query inside the message is being resolved by the child process, it sends a new message with the response back to the service. In case of a crash of the JVM, for instance, due to the broken connection with the database or segmentation fault, the child will be terminated and deleted from the pool. Because the child processes are detached from the parent, they do not crash the application, but only themselves.

⭐️ Features

• connection pool,
• support of SPARQL query builder syntax (@tpluscode/rdf-string, @tpluscode/sparql-builder),
• support for executing stored procedures or even SQL

🚀 Installation

yarn add virtuoso-connector

npm install virtuoso-connector

Note: Install peer dependencies if needed

🤘🏻 Usage

import { DatabaseConnection } from 'virtuoso-connector'

const db = new DatabaseConnection({
  url: 'jdbc:virtuoso://127.0.0.1:1111/CHARSET=UTF-8',
  username: 'dba',
  password: 'dba',
  driverPath: '/usr/local/vos/lib/jdbc-4.2/virtjdbc4_2.jar',
  lazy: false,
  maxQueryTimeout: 360, // optional (in seconds), 0 = unlimited
  poolSize: 2 // max active connections
})

const results = await db.query(`
  SELECT ?s ?p ?o 
  WHERE { ?s ?p ?o }
  LIMIT 10
`)

results.forEach(result => {
  console.info(result.s, result.p, result.o)
})

// Destroy connection
db.destroy()

// Example preview of results (with LIMIT 1)
[{
  s: NamedNode {
    termType: 'NamedNode',
    value: 'http://www.openlinksw.com/virtrdf-data-formats#default-iid'
  },
  p: NamedNode {
    termType: 'NamedNode', 
    value: 'http://www.w3.org/1999/02/22-rdf-syntax-ns#type'
  },
  o: NamedNode {
    termType: 'NamedNode',
    value: 'http://www.openlinksw.com/schemas/virtrdf#QuadMapFormat'
  } 
}]