scyllorm

import { BaseModel, Column, Entity, Index, PrimaryKeyColumn } from 'scyllorm'; import { connect } from 'cassandra-driver'; @Entity('employees') @Index('employees_first_name_idx', 'first_name') class Employee extends BaseModel { @PrimaryKeyColumn('INT', { partitionKey: true }) id: number; @PrimaryKeyColumn('TEXT', { clusteringKey: true }) first_name: string; @Column('TEXT') last_name: string; @Column('INT') age: number; } async function main() { const connection = await connect({ contactPoints: ['localhost:9042'], localDataCenter: 'datacenter1', credentials: { username: 'cassandra', password: 'cassandra' } }); await connection.execute("CREATE KEYSPACE IF NOT EXISTS test WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 }"); const repo = connection.getRepository(Employee); const emp = new Employee(); emp.id = 1; emp.first_name = 'John'; emp.last_name = 'Doe'; emp.age = 30; await repo.save(emp); const found = await repo.findOne({ id: 1 }); console.log(found); } main().catch(console.error);