@etpdatasystems/etp.common.accessmongodbhelper
v1.0.56
Published
NPM Package to manage MongoDB database
Readme
Etp.Common.AccessMongoDbHelper
This helper permits to do find, distinct, count, insert, udpate and delete into MongoDb database with Mongoose :
- connexion()
- get(jsonFilter, includedFields, expectedFields) - get({}, [], [])
- count(jsonFilter) - count({})
- distinct(jsonFilter, field) - distinct({}, 'key')
- save(modelMongoose, data) - save(ModelMongoOse, {})
- delete(modelMongoose, data) - delete(ModelMongoOse, {})
Introduction
Etp.Common.FlowAccessMongodb needs configuration from a program/main config file as :
"database": {
"db":{
"server": "urlServer",
"port": port,
"login": "login",
"password": "login",
"collections_[key]" : "collectionInMongoDb",
"awsServer" : false
}
}
Usage
To use this package above-mentioned :
- To insert/update data :
- import mongoose from 'mongoose';
- import initMongoAccess, { connexion, get, getWithPopulate, count, distinct, aggregate, save, delete as deleteItem } from '@etpdatasystems/etp.common.accessmongodbhelper';
- let _model = mongoose.model("collectionName", { MongoOseSchema });
- initMongoAccess(_model, config['db']);
- await _connexion();
- save(_model, flow)
-.then(data => {
- data contains the issuer identifier inserted.
-})
-.catch(err => {
- console.log(err);
-})
-.finally(end => {
- dispose();
-});
- To select / distinct / count data in MongoDb :
- import mongoose from 'mongoose';
- import initMongoAccess, { connexion, get, getWithPopulate, count, distinct, aggregate, save, delete as deleteItem } from '@etpdatasystems/etp.common.accessmongodbhelper';
- let _model = mongoose.model("collectionName", { MongoOseSchema });
- initMongoAccess(_model, config['db']);
- await _connexion();
- get({}, [], []])
-.then(data => {
- data contains the issuer identifier inserted.
-})
-.catch(err => {
- console.log(err);
-})
-.finally(end => {
- dispose();
-});
- count({ key : "value" });
- distinct({ key : "value" });
- To delete data in MongoDb :
- import mongoose from 'mongoose';
- import initMongoAccess, { connexion, get, getWithPopulate, count, distinct, aggregate, save, delete as deleteItem } from '@etpdatasystems/etp.common.accessmongodbhelper';
- let _model = mongoose.model("collectionName", { MongoOseSchema });
- initMongoAccess(_model, config['db']);
- await _connexion();
- delete(_model, flow)
-.then(data => {
- data contains the issuer identifier inserted.
-})
-.catch(err => {
- console.log(err);
-})
-.finally(end => {
- dispose();
-});