Project is deprecated. No continue development, no bugfixing anymore.

---

lx-mongodb

Litixsoft backend driver for mongoDb based on mongojs.

Install

Documentation

http://www.litixsoft.de/products-lxmongodb.html (german)

Examples

Simple query

var lxDb = require('lx-mongodb'),
    db = lxDb.GetDb('localhost/blog?w=1&journal=True&fsync=True', ['users']),
    repo = lxDb.BaseRepo(db.users);

// get all users
repo.find(function(error, result) {
	console.log(result);
});

// add user
repo.insert({userName: 'wayne', age: 99}, function(error, result) {
	console.log(result);
});

Simple repository with JSON schema

var lxDb = require('lx-mongodb');

exports.UserRepository = function (collection) {
    var schema = function () {
            return {
                properties: {
                    _id: {
                        type: 'string',
                        required: false,
                        format: 'mongo-id',
                        key: true
                    },
                    email: {
                        type: 'string',
                        required: true,
                        format: 'email'
                    },
                    userName: {
                        type: 'string',
                        required: true,
                        sort: 1
                    }
                }
            };
        },
        baseRepo = lxDb.BaseRepo(collection, schema);

    return baseRepo;
};

var lxDb = require('lx-mongodb'),
    db = lxDb.GetDb('localhost/blog?w=1&journal=True&fsync=True', ['users']),
    userRepo = require('./userRepo.js').UserRepository(db.users);

// get all users
userRepo.find(function(err, res) {
    console.log(res); // array of users
});

// create new user
userRepo.insert({userName: 'Wayne', age: 99}, function(err, res) {
    console.log(res); // user object
});

Repository with validation

var lxDb = require('lx-mongodb');

exports.UserRepository = function (collection) {
    var schema = function () {
            return {
                properties: {
                    _id: {
                        type: 'string',
                        required: false,
                        format: 'mongo-id',
                        key: true
                    },
                    email: {
                        type: 'string',
                        required: true,
                        format: 'email'
                    },
                    userName: {
                        type: 'string',
                        required: true,
                        sort: 1
                    },
                    birthdate: {
                        type: 'string',
                        format: 'date-time'
                    },
                }
            };
        },
        baseRepo = lxDb.BaseRepo(collection, schema);

    // validation function for the userName
    baseRepo.checkUserName = function (doc, callback) {
        if (!doc) {
            callback(null, {valid: true});
            return;
        }

        var query = {
            userName: doc.userName,
            _id: {
                $ne: typeof doc._id === 'string' ? baseRepo.convertId(doc._id) : doc._id
            }
        };

        baseRepo.findOne(query, function (err, res) {
            if (err) {
                callback(err);
            } else if (res) {
                callback(null,
                    {
                        valid: false,
                        errors: [
                            {
                                attribute: 'checkUserName',
                                property: 'userName',
                                expected: false,
                                actual: true,
                                message: 'already exists'
                            }
                        ]
                    }
                );
            } else {
                callback(null, {valid: true});
            }
        });
    };

    // validation function
    baseRepo.validate = function (doc, isUpdate, schema, callback) {
        var userNameCheck = true;

        // check is update
        if (isUpdate) {
            for (var schemaProp in schema.properties) {
                if (schema.properties.hasOwnProperty(schemaProp)) {
                    if (!doc.hasOwnProperty(schemaProp)) {
                        schema.properties[schemaProp].required = false;
                    }
                }
            }

            if (!doc.hasOwnProperty('userName')) {
                userNameCheck = false;
            }
        }

        // json schema validate
        var valResult = val.validate(doc, schema, baseRepo.getValidationOptions());

        // register async validator
        if (userNameCheck) {
            val.asyncValidate.register(baseRepo.checkUserName, doc.userName);
        }

        // async validate
        val.asyncValidate.exec(valResult, callback);
    };

    return baseRepo;
};

var lxDb = require('lx-mongodb'),
    db = lxDb.GetDb('localhost/blog?w=1&journal=True&fsync=True', ['users']),
    userRepo = require('./userRepo.js').UserRepository(db.users);

// create new user
userRepo.insert({userName: 'Wayne', age: 99}, function(err, res) {
    console.log(res); // User Objekt
});

// JSON schema validation of the user
userRepo.validate({userName: 'Wayne', age: 99}, function(err, res) {
    res.valid === false // true
    res.errors[0].property === 'email' // true
    res.errors[0].message === 'email is required' // true
});

// async schema validation of the user
userRepo.validate({userName: 'Wayne', age: 99}, function(err, res) {
    res.valid === false // true
    res.errors[0].property === 'userName' // true
    res.errors[0].message === 'userName already exists' // true
});

API

Database connection

• getDb

Base repository

• BaseRepository
• aggregate
• createNewId
• convertId
• count
• find
• findOne
• findOneById
• getCollection
• getSchema
• getValidationOptions
• insert
• remove
• update

Gridfs base repository

• GridFsBaseRepo
• convertId
• delete
• get
• getCollection
• getValidationOptions
• put

Database connection

#### getDb(connectionString, collections, gridFsCollections) Creates a connection to the mongoDb using a connection string. The db and the connections are stored in memory.

Note: When querying the metadata of gridFsCollections, you need to add them to the collections array. See examples.

Arguments

• connectionString {!string} - The connection string.
• collections {!Array.<string>} - The names of the mongo collections.
• gridFsCollections {Array.<string>=} - The names of the gridfs collections.

var lxDb = require('lx-mongodb'),
    db = lxDb.GetDb('localhost:27017/blog?w=0&journal=True&fsync=True', ['posts', 'tags', 'comments']);

// with gridfs collections
var lxDb = require('lx-mongodb'),
    db = lxDb.GetDb('localhost:27017/blog?w=0&journal=True&fsync=True', ['posts', 'tags', 'comments'], ['documents']);

// with gridfs collections and collection for querying the gridfs metadata
var lxDb = require('lx-mongodb'),
    db = lxDb.GetDb('localhost:27017/blog?w=0&journal=True&fsync=True', ['posts', 'tags', 'comments', 'documents.files', 'pdf.files'], ['documents', 'pdf']);

---

Base repository

#### BaseRepository(collection, schema) Creates a new repository with the base mongoDb operations. Each mongoDb collection uses the base repository. If you need all the functions of the native mongoDb js driver, you can call `getCollection()` on the base repository to get the mongoDb collection.

Arguments

• collection {!Object} - The mongoDb colllection.
• schema {(Object|Function)=} - The JSON schema. Is used to get the id field and the default sorting.

var lxDb = require('lx-mongodb'),
    db = lxDb.GetDb('localhost:27017/blog?w=0&journal=True&fsync=True', ['posts', 'tags', 'comments']),
    postRepo = lxDb.BaseRepo(db.posts);

--

#### aggregate(pipeline, options, callback) Execute an aggregation framework pipeline against the collection, needs MongoDB >= 2.1.

Arguments

• pipeline {!Array} - The aggregation framework pipeline.
• options {Object=} - The additional options.
• callback {function(err, res)} - The callback function.

var lxDb = require('lx-mongodb'),
    db = lxDb.GetDb('localhost:27017/blog?w=0&journal=True&fsync=True', ['users']),
    repo = lxDb.BaseRepo(db.users),
    pipeline = [
        {$project: {age: 1}},
        {$group: {_id: {age: '$age'}, count: { $sum: 1}}},
        {$project: {_id: '$_id', age: '$age', count: '$count'}}
    ];

    repo.aggregate(pipeline, {}, function(error, result) {
        // more logic here
    });

--

#### convertId(id) Converts a `string` to a mongo `ObjectID` and vice versa.

Arguments

• id {Object|string} - The id to convert.

var repo = BaseRepo(collection, schema),
    _id = repo.createNewId(),
    idString = repo.convertId(_id);

typeof idString === 'string'; // true

--

#### createNewId() Returns a new mongo ObjectId.

var repo = BaseRepo(collection, schema),
    _id = repo.createNewId();

_id instanceof ObjectID === true; // true

--

#### count(query, options, callback) Returns the number of records.

Arguments

• query {Object|function(err, res)=} - The query.
• options {Object|function(err, res)=} - The options object or the callback.
• callback {!function(err, res)} - The callback function.

var repo = BaseRepo(collection, schema);

// count all
repo.count(function(err, res) {
    // more logic here
});

// count with query
repo.count({name: 'wayne'}, function(err, res) {
    // more logic here
});

// count all with options
repo.count({skip: 1, limit: 5}, function(err, res) {
    // more logic here
});

--

#### find(query, options, callback) Gets the records from the mongoDb.

Arguments

• query {Object|function(err, res)=} - The query.
• options {Object|function(err, res)=} - The mongoDb query options.
• options.fields {(Array|Object)=} - The fields which should be returned by the query.
• options.limit {Number=} - The number of records which should be returned by the query.
• options.skip {Number=}- The number of records which should be skipped by the query.
• options.sort {(Array|String|Object)=} - The sorting of the returned records.
• callback {!function(err, res)} - The callback function.

var repo = BaseRepo(collection, schema);

// find all
repo.find(function(err, res) {
    // more logic here
});

// find and convert mongo-id
repo.find({_id: '511106fc574d81d815000001'}, function(err, res) {
    // more logic here
});

// find with query
repo.find({name: 'Litixsoft'}, {skip: 0, limit: 10, sort: {name: 1}, fields: ['name', 'city']}, function(err, res) {
    // more logic here
});

// find all with options
repo.find({skip: 0, limit: 10, sort: {name: 1}, fields: ['name', 'city']}, function(err, res) {
    // more logic here
});

--

#### findOne(query, options, callback) Gets one record from the mongoDb.

Arguments

• query {!Object} - The query.
• options {Object|function(err, res)=} - The mongoDb query options or the callback.
• options.fields {(Array|Object)=} - The fields which should be returned by the query.
• options.limit {Number=} - The number of records which should be returned by the query.
• options.skip {Number=}- The number of records which should be skipped by the query.
• options.sort {(Array|String|Object)=} - The sorting of the returned records.
• callback {!function(err, res)} - The callback function.

var repo = BaseRepo(collection, schema);

repo.findOne({name: 'Litixsoft'}, function(err, res) {
    // more logic here
});

repo.findOne({name: 'Litixsoft'}, {skip: 0, limit: 10, sort: {name: 1}, fields: ['name', 'city']}, function(err, res) {
    // more logic here
});

--

#### findOneById(id, options, callback) Gets one record by id from the mongoDb.

Arguments

• id {!Object|string} - The id.
• options {Object|function(err, res)} - The mongoDb query options or the callback.
• options.fields {(Array|Object)=} - The fields which should be returned by the query.
• callback {!function(err, res)} - The callback function.

var repo = BaseRepo(collection, schema),
    myId = repo.convertId('5108e9333cb086801f000035');

repo.findOneById('5108e9333cb086801f000035', function(err, res) {
    // more logic here
});

repo.findOneById(myId, {fields: ['name', 'city']}, function(err, res) {
    // more logic here
});

--

#### getCollection() Returns the mongoDb collection object.

var repo = BaseRepo(collection, schema),
    myCollection = repo.getCollection();

collection == myCollection; // true

--

#### getSchema() Returns the JSON schema.

var repo = BaseRepo(collection, schema),
    mySchema = repo.getSchema();

schema == mySchema; // true

--

#### getValidationOptions() Returns an object with the validation options. This is especially useful in combination with [lx-valid](https://github.com/litixsoft/lx-valid). The method `convert()` can also be used by other schema validators.

var repo = BaseRepo(collection, schema),
    options = repo.getValidationOptions();

options.deleteUnknownProperties === true; // true
typeof options.convert === 'function'; // true

--

#### insert(doc, options, callback) Creates one or more records in the mongoDb.

Arguments

• doc {!Object|!Array} - The document/s.
• options {Object|function(err, res)=} - The options object or the callback.
• callback {function(err, res)=} - The callback function.

var repo = BaseRepo(collection, schema);

// insert
repo.insert({name: 'Litixsoft', city: 'Leipzig'});

// insert with callback
repo.insert({name: 'Litixsoft', city: 'Leipzig'}, function(err, res) {
    // more logic here
});

// insert with options and callback
repo.insert({name: 'Litixsoft'}, {w: 1}, function(err, res) {
    // more logic here
})

--

#### remove(query, options, callback) Deletes one or more records in the mongoDb.

Arguments

• query {Object=} - The query.
• options {Object=} - The mongo options.
• callback {function(err, res)=} - The callback function.

var repo = BaseRepo(collection, schema);

// remove all
repo.remove();

// remove with callback and coverting of mongo-id
repo.remove({_id: '5108e9333cb086801f000035'}, function(err, res) {
    // more logic here
});

// remove with options
repo.remove({city: 'Berlin'}, {w: 1}, function(err, res) {
    // more logic here
});

--

#### update(query, update, options, callback) Updates one or more records in the mongoDb.

Arguments

• query {!Object} - The query.
• update {!Object} - The data to update.
• options {Object=} - The options for multi update.
• callback {!function(err, res)} - The callback function.

var repo = BaseRepo(collection, schema);

repo.update({_id: '5108e9333cb086801f000035'}, {name: 'Litixsoft GmbH'}, function(err, res) {
    // more logic here
});

repo.update({_id: '5108e9333cb086801f000035'}, {$set: {name: 'Litixsoft GmbH', city: 'Palo Alto'}}, function(err, res) {
    // more logic here
});

repo.update({}, {$set: {name: 'Litixsoft GmbH', city: 'Palo Alto'}}, {multi: true}, function(err, res) {
    // more logic here
});

---

GridFs base repository

#### GridFsBaseRepo(collection) Creates a new repository with the base mongoDb gridfs operations.

Arguments

• collection {!Object} - The mongoDb gridfs colllection.

var lxDb = require('lx-mongodb'),
    db = lxDb.GetDb('localhost:27017/blog?w=0&journal=True&fsync=True', ['posts', 'tags', 'comments'], ['documents']),
    documentsRepo = lxDb.GridFsBaseRepo(db.documents);

--

#### convertId(id) Converts a `string` to a mongo `ObjectID` and vice versa.

Arguments

• id {Object|string} - The id to convert.

var repo = GridFsBaseRepo(collection),
    _id = repo.createNewId(),
    idString = repo.convertId(_id);

typeof idString === 'string'; // true

--

#### delete(id, callback) Deletes a file from the collection.

Arguments

• id {Object|string} - The id of the file.
• callback {function(err, res)} - The callback function.

var repo = GridFsBaseRepo(collection);

repo.delete('5108e9333cb086801f000035', function(err, res) {
    // more logic here
});

--

#### get(id, callback) Gets a file from the collection.

Arguments

• id {Object|string} - The id of the file.
• callback {function(err, res)} - The callback function.

var repo = GridFsBaseRepo(collection);

repo.get('5108e9333cb086801f000035', function(err, res) {
    // more logic here
});

--

#### getCollection() Returns the mongoDb gridfs collection object.

var repo = GridFsBaseRepo(collection),
    myCollection = repo.getCollection();

collection == myCollection; // true
#### getValidationOptions()
Returns an object with the validation options. This is especially useful in combination with [lx-valid](https://github.com/litixsoft/lx-valid).
The method `convert()` can also be used by other schema validators.

```js
var repo = GridFsBaseRepo(collection),
    options = repo.getValidationOptions();

options.deleteUnknownProperties === true; // true
options.trim === true; // true
options.strictRequired === true; // true
typeof options.convert === 'function'; // true

--

#### put(data, options, callback) Inserts a file to the collection.

Arguments

• data {Object} - The buffer with the binary data of the file.
• options {Object} - The options for the file.
• callback {function(err, res)} - The callback function.

var repo = GridFsBaseRepo(collection);

repo.put(new Buffer('Litixsoft'), {metadata: {'type': 'string'}}, function(err, res) {
    // more logic here
});

Contributing

In lieu of a formal styleguide take care to maintain the existing coding style. Add unit tests for any new or changed functionality. Please create descriptive commit messages. We use a git hook to validate the commit messages against these rules. Lint and test your code using grunt.

Author

Litixsoft GmbH

License

Copyright (C) 2013-2014 Litixsoft GmbH [email protected] Licensed under the MIT license.

Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.