Cassandra Repository

Installation

$ npm install --save cassandra-repository

Usage

const CassandraRepository = require('cassandra-repository');

class CatRepository extends CassandraRepository {
  constructor(cassandra, modelName) {
    super(cassandra, modelName);
  }
}

// or if you dont need custom functionality

const repo = new CassandraRepository(cassandra, modelName);

Getting Started

'use strict';

const Cassandra = require('express-cassandra');
const CassandraRepository = require('cassandra-repository');

const cassandra = Cassandra.createClient({
  clientOptions: {
    contactPoints: ['127.0.0.1'],
    protocolOptions: { port: 9042 },
    keyspace: 'mykeyspace',
    queryOptions: { consistency: Cassandra.consistencies.one }
  },
  ormOptions: {
    defaultReplicationStrategy: {
      class: 'SimpleStrategy',
      replication_factor: 1
    },
    migration: 'safe',
    createKeyspace: true
  }
});

export const modelName = 'Cats';

// configure a schema
export const schema = {
  fields: {
    _id: 'text',
    name: 'text'
  },
  key: ['_id']
};

let cassandraRepo;

// json object
const cat = { name : 'Fido' };

cassandra.connect(() => {

  // register it to cassandra
  cassandra.loadSchema(modelName, schema);
  repo = new CassandraRepository(cassandra, modelName);
  
  repo.add(cat, (err, data) => {
    console.log(data);
    repo.disconnect();
  });
});

License

MIT © Ben Lugavere