ES 6は最も簡単な方式でMongoDBにアクセスします.
前書きMongoDBがますます流行っています.NodeJSもますます流行っています.最初にKOAフレームを使ったかもしれませんが、KOAでES 6でMongoDBにアクセスするにはどうすればいいですか?Githubにはよく似たような案があります.例えば、引き続きmongoogleのPromise方式でデータベースを操作してもいいです.私のプロジェクトは比較的簡単で、複雑なフレームを使いたくなくて、自分でHelperを書いてデータベースに接続したらいいです.
コードは簡単です.私は貼り出して、オフィシャルドライバーにPromiseケースを作って、すべての操作をオフィシャルPromiseに戻します.そして、yieldの呼び出しはこのように簡単です.
コードは簡単です.私は貼り出して、オフィシャルドライバーにPromiseケースを作って、すべての操作をオフィシャルPromiseに戻します.そして、yieldの呼び出しはこのように簡単です.
// helper_mongo.js
// freewolf
//
var MongoClient = require('mongodb').MongoClient;
var ObjectID = require('mongodb').ObjectID;
var mongoLink = '';
// MongoLink mongodb://user:password@yourserver
//
var insert = function(collectionName, obj) {
return new Promise(function(resolve, reject) {
MongoClient.connect(mongoLink, function(err, db) {
if (err) reject(err);
var collection = db.collection(collectionName);
collection.insert(obj, {w: 1}, function(err, res) {
db.close();
if (err) reject(err);
else resolve(res[0]);
});
});
});
}
//
var update = function(collectionName, obj) {
return new Promise(function(resolve, reject) {
MongoClient.connect(mongoLink, function(err, db) {
if (err) reject(err);
var collection = db.collection(collectionName);
collection.update({_id: new ObjectID(obj._id)}, obj, {upsert: true,w: 1}, function(err, res) {
db.close();
if (err) reject(err);
else resolve(res);
});
});
});
}
//
var findOne = function (collectionName, query, option) {
return new Promise(function(resolve, reject) {
MongoClient.connect(mongoLink, function(err, db) {
if (err) reject(err);
var collection = db.collection(collectionName);
if(option==undefined || option==null)
{
collection.findOne(query, function(err, res) {
db.close();
if (err) reject(err);
else resolve(res);
});
}else{
collection.findOne(query, option, function(err, res) {
db.close();
if (err) reject(err);
else resolve(res);
});
}
});
});
}
//
var find = function(collectionName, query, option) {
return new Promise(function(resolve, reject) {
MongoClient.connect(mongoLink, function(err, db) {
if (err) reject(err);
var collection = db.collection(collectionName);
if(option==undefined || option==null)
{
collection.find(query).toArray(function(err, res) {
db.close();
if (err) reject(err);
else resolve(res);
});
}else{
collection.find(query, option).toArray(function(err, res) {
db.close();
if (err) reject(err);
else resolve(res);
});
}
});
});
}
//
var remove = function(collectionName, query) {
return new Promise(function(resolve, reject) {
MongoClient.connect(mongoLink, function(err, db) {
if (err) reject(err);
var collection = db.collection(collectionName);
collection.remove(query, {w: 1}, function(err, res) {
db.close();
if (err) reject(err);
else resolve(res);
});
});
});
}
//
var count = function(collectionName, query, option) {
return new Promise(function(resolve, reject) {
MongoClient.connect(mongoLink, function(err, db) {
if (err) reject(err);
var collection = db.collection(collectionName);
if(query==undefined || query==null)
query = {};
if(option==undefined || option==null)
{
collection.count(query, function(err, count) {
db.close();
if (err) reject(err);
else resolve(count);
});
}else{
collection.count(query, option, function(err, count) {
db.close();
if (err) reject(err);
else resolve(count);
});
}
});
});
}
module.exports.insert = insert;
module.exports.update = update;
module.exports.findOne = findOne;
module.exports.find = find;
module.exports.remove = remove;
module.exports.count = count;
// service.js
var ObjectID = require('mongodb').ObjectID;
var helperMongo = require('./helper_mongo');
module.exports = {
//
insert : function * (obj){
var res = yield helperMongo.insert(this.collectionName, obj);
return res;
},
//
update : function * (obj){
var res = yield helperMongo.update(this.collectionName, obj);
return res;
},
//
remove : function * (id){
var res = yield helperMongo.remove(this.collectionName, { _id : new ObjectID(id) });
return res;
},
//
find : function * (query, option){
var res = yield helperMongo.find(this.collectionName, query, option);
return res;
},
//
findOne : function * (query, option){
var res = yield helperMongo.findOne(this.collectionName, query, option);
return res;
},
//
getAll : function * (){
var res = yield helperMongo.find(this.collectionName, {});
return res;
},
// id
getById : function * (id){
var res = yield helperMongo.findOne(this.collectionName, { _id : new ObjectID(id) });
return res;
},
// id
getByIds :function * (ids, option){
ids = ids.map(function(id) { return new ObjectID(id); });
var res = yield helperMongo.find(this.collectionName, {_id: {$in: ids}}, option);
return res;
},
// （ ）
getByPage : function*(query, sort, pageSize, pageNum){
if(!query)
query = {};
if(!sort)
sort = [['_id', 'desc']];
var option = {
sort : sort,
limit: pageSize,
skip : (pageNum - 1) * pageSize
};
var res = yield helperMongo.find(this.collectionName, query, option);
return res;
},
//
count : function * (query){
if(!query)
query = {};
var res = yield helperMongo.count(this.collectionName, query);
return res;
}
}// service_user.js
var service = require('./service');
var helperMongo = require('../helper_mongo');
var ObjectID = require('mongodb').ObjectID;
var Service = function(){
this.collectionName = 'users';
//
this.getByInviteCode = function * (inviteCode){
var res = yield this.findOne({ invitecode : inviteCode });
return res;
}
if(Service.instance == null)
{
Service.instance = this;
}
return Service.instance;
}
Service.prototype = service;
module.exports = Service;var co = require('co');
var ServiceUser = require('./service_user.js');
var serviceUser = new ServiceUser();
// service_user.js WS
// Demo
co(function*(){
var user = {name:'freewolf', password:'123', invitecode:'abcd'};
//
yield serviceUser.insert(user);
// service
var user1 = yield serviceUser.find({name:'freewolf'});
//
var user2 = yield serviceUser.getByInviteCode('abcd');
//
var sort = [['lastedittime', 'desc']];
var pageSize = 20; // 20
var pageNum = 1; //
var users = yield serviceUser.getByPage({}, sort, pageSize, pageNum);
// ......
});