first functions

Author: finalclass

index.js

@@ -0,0 +1 @@
+module.exports = require('./src/SQLiteTable');

package.json

@@ -0,0 +1,27 @@
+{
+  "name": "sqlite-table",
+  "version": "0.0.0",
+  "description": "SQLiteTable class for sqlite3 module",
+  "main": "index.js",
+  "scripts": {
+    "test": "jasmine-node spec/"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git@github.com:finalclass/sqlite-table.git"
+  },
+  "keywords": [
+    "sqlite3",
+    "db",
+    "table"
+  ],
+  "author": "Szymon Wygnański <s@finalclass.net> (http://finalclass.net/)",
+  "license": "ISC",
+  "bugs": {
+    "url": "https://github.com/finalclass/sqlite-table/issues"
+  },
+  "homepage": "https://github.com/finalclass/sqlite-table",
+  "dependencies": {
+    "sqlite3": "~2.2.7"
+  }
+}

spec/sqlite-table.spec.js

@@ -0,0 +1,73 @@
+var SQLiteTable = require('../src/SQLiteTable');
+var sqlite3 = require('sqlite3');
+
+describe('SQLiteTable', function () {
+  var db;
+  var table;
+
+  beforeEach(function (next) {
+    db = new sqlite3.Database(':memory:');
+    var sql = 'CREATE TABLE user(' +
+      'id INTEGER PRIMARY KEY, ' +
+      'firstName TEXT NOT NULL,' +
+      'lastName TEXT NOT NULL)';
+
+    db.run(sql, function (err) {
+      if (err) {
+        next(err);
+      } else {
+        table = new SQLiteTable(db);
+        table._tableName = 'user';
+        next();
+      }
+    });
+  });
+
+  it('insert', function (next) {
+    table.insert({firstName: 'Jan', lastName: 'Kowalski'}, function (err) {
+      expect(err).toBeFalsy();
+      db.get('select * from user', function (err, result) {
+        expect(err).toBeFalsy();
+        expect(result).not.toBeFalsy();
+        next();
+      });
+    });
+  });
+
+  it('update', function (next) {
+    db.run('INSERT INTO user(firstName, lastName) VALUES(?, ?)', 'Jan', 'Kowalski', function (err) {
+      table.update({id: 1, firstName: 'Jaś'}, function (err) {
+        expect(err).toBeFalsy();
+        db.all('select * from user', function (err, result) {
+          expect(err).toBeFalsy();
+          expect(result.length).toBe(1);
+          expect(result[0].firstName).toBe('Jaś');
+          next();
+        });
+      })
+    });
+  });
+
+  it('finds all', function (next) {
+    db.run('INSERT INTO user(firstName, lastName) VALUES(?,?)', 'Jan', 'Kowalski', function () {
+      db.run('INSERT INTO user(firstName, lastName) VALUES(?,?)', 'Jaś', 'Kowalski', function () {
+        table.find(1, function (err, result) {
+          expect(err).toBeFalsy();
+          expect(result.firstName).toBe('Jan');
+          expect(result.lastName).toBe('Kowalski');
+          table.find(2, function (err, result) {
+            expect(err).toBeFalsy();
+            expect(result.firstName).toBe('Jaś');
+            expect(result.lastName).toBe('Kowalski');
+            table.all(function (err, results) {
+              expect(err).toBeFalsy();
+              expect(results.length).toBe(2);
+              next();
+            });
+          });
+        });
+      });
+    });
+  });
+
+});

src/SQLiteTable.js

@@ -0,0 +1,93 @@
+/// <reference path="../../login-server/src/typings/tsd.d.ts"/>
+
+import sqlite3 = require('sqlite3');
+
+class SQLiteTable {
+
+  private _tableName:string;
+
+  constructor(private db:sqlite3.Database) {
+
+  }
+
+  public insert(data:any, next:(err?:Error)=>void):void {
+    var keys:string[] = Object.keys(data);
+    var keysVars:string[] = keys.map((key:string):string => '$' + key);
+    var objVars:any = this.getObjVars(data);
+
+    var sql:string = 'INSERT INTO ' + this.tableName
+      + '(' + keys.join(',') + ') '
+      + 'VALUES(' + keysVars.join(',') + ')';
+
+    this.db.run(sql, objVars, next);
+  }
+
+  private getObjVars(obj):any {
+    var objVars:any = {};
+
+    Object.keys(obj).forEach((key:string):void => {
+      objVars['$' + key] = obj[key];
+    });
+
+    return objVars;
+  }
+
+  public update(data:any, next:(err?:Error)=>void):void {
+    if (!data.id) {
+      next(new Error('id is not specified'));
+      return;
+    }
+    var keys:string[] = Object.keys(data);
+    var updateStmts:string[] = keys.map((key:string):string => {
+      return key + '=$' + key;
+    });
+    var objVars:any = this.getObjVars(data);
+
+    var sql:string = 'UPDATE ' + this.tableName
+      + ' SET ' + updateStmts.join(' , ')
+      + ' WHERE id=$id';
+
+    this.db.run(sql, objVars, next);
+  }
+
+  private getSQLSelectStmt(params:any):{sql:string; objVars:any} {
+    var objVars:any = this.getObjVars(params);
+    var whereStmts:string[] = Object.keys(params)
+      .map((key:string):string => key + '=$' + key);
+    var where:string = whereStmts.length > 0 ? ' WHERE ' + whereStmts.join(' AND ') : '';
+
+    return {
+      sql: 'SELECT * FROM ' + this.tableName + where,
+      objVars: objVars
+    };
+  }
+  public all(next:(err?:Error)=>void):void;
+  public all(params?:any, next?:(err?:Error)=>void):void {
+    if (typeof params === 'function') {
+      next = params;
+      params = {};
+    }
+    var stmt:{sql:string;objVars:any} = this.getSQLSelectStmt(params);
+    this.db.all(stmt.sql, stmt.objVars, next);
+  }
+
+  public find(params:string, next:(err?:Error)=>void):void;
+  public find(params:any, next:(err?:Error)=>void):void {
+    var typeofParams:string = typeof params;
+    if (typeofParams === 'string' || typeofParams === 'number') {
+      params = {id: params};
+    }
+    var stmt:{sql:string;objVars:any} = this.getSQLSelectStmt(params);
+    this.db.get(stmt.sql, stmt.objVars, next);
+  }
+
+  public get tableName():string {
+    if (!this._tableName) {
+      throw new Error('Table name is not specified');
+    }
+    return this._tableName;
+  }
+
+}
+
+export = SQLiteTable;

src/SQLiteTable.js.map

@@ -0,0 +1,5 @@
+declare module "debug" {
+  function debug(what:string):(msg:string, ...args:string[])=>void;
+
+export = debug;
+}