lagash-dbaccess v1.1.4

lagash-dbaccess

dbaccess abstractions for node

Usage:

• Before any usage, call RepositoryBase.connect(connection) with an instance of the db connection.

• To execute queries to the database, extend the RepositoryBase class and use its methods.

Example:

import {RepositoryBase, DBQueryParameter, DBTypes} from "lagash-dbaccess";

export default class SampleRepository extends RepositoryBase {

    async count(table: string, dateColumn: string, from: Date, to: Date): Promise<number> {

        let query = `SELECT COUNT(*) AS count FROM ${table} 
                     WHERE (${dateColumn}>=@from AND ${dateColumn}<=@to)`;

        let result = await this.execute<any>(query,
            new DBQueryParameter("from", from, DBTypes.DateTime),
            new DBQueryParameter("to", to, DBTypes.DateTime));

        if (result[0] == undefined) {
            throw new Error("Something went wrong when querying the DB.");
        }

        return result[0].count;

    }

    async getSampleEntities() {
        let query = `SELECT id, field1, field2, field3 FROM SampleEntities`;
        return this.execute<SampleEntity>(query);
    }

    async deleteSampleEntity(id: string) {
        let query = `DELETE FROM SampleEntities WHERE id = @id`;
        return this.executeNonQuery(query, new DBQueryParameter("id", id, DBTypes.NVarChar));
    }

}

To execute queries inside a transaction

let repo = new SampleRepository();

await repo.beginTransaction();

let entities = await repo.getSampleEntities();
if (entities.length > 0) {
    repo.deleteSampleEntity(entities[0].id);
}

repo.commitTransaction();

To execute queries from different repositories within the same transaction

let repo1 = new SampleRepository();
let repo2 = new SampleRepository();

await repo1.beginTransaction();
repo1.joinOtherRepositoryToCurrentTransaction(repo2);
let entities = await repo1.getSampleEntities();
if (entities.length > 0) {
    repo2.deleteSampleEntity(entities[0].id);
}

repo1.commitTransaction(); // or repo2.commitTransaction()