This is a PostgreSQL adapter for livedb. It does not yet implement the livedb query interface.
npm install --save livedb-postgresqllivedb-postgresql has relatively relaxed requirements for the database it connects to. The table names can be anything, as they're set when creating an instance of livedb-postgresql.
| Column Name | Type |
|---|---|
| collection | text |
| name | text |
| data | json |
| Column Name | Type |
|---|---|
| collection_name | text |
| document_name | text |
| version | bigint |
| data | json |
Here is an example SQL statement that will work with livedb-postgresql:
CREATE TABLE documents(
collection text NOT NULL,
name text NOT NULL,
data json NOT NULL
);
CREATE UNIQUE INDEX documents_collection_name ON documents(collection, name);
CREATE TABLE operations(
collection_name text NOT NULL,
document_name text NOT NULL,
version bigint NOT NULL,
data json NOT NULL
);
CREATE UNIQUE INDEX operations_cname_docname_version ON operations(collection_name, document_name, version);var LivePg = require('livedb-postgresql');
var livedb = require('livedb');
var redis = require('redis');
// Redis clients
var redisURL = require('url').parse(process.env.REDIS_URL);
var redisPass = redisURL.auth.split(':')[1];
var redis1 = redis.createClient(redisURL.port, redisURL.hostname, { auth_pass: redisPass });
var redis2 = redis.createClient(redisURL.port, redisURL.hostname, { auth_pass: redisPass });
// Postgres clients
var connString = process.env.DATABASE_URL;
var poolSize = 20; // default pool size is 10
var snapshotDb = new LivePg(connString, poolSize);
var opLog = new LivePg(connString);
var driver = livedb.redisDriver(opLog, redis1, redis2);
var liveClient = livedb.client({ snapshotDb: snapshotDb, driver: driver });After creating database tables:
PG_URL=postgres://localhost:5432/livedb-postgresql_test npm test