自己平时使用过的一些mongodb命令记录

根据日期统计出某些手机号记录数

var data = db.spinetmp.aggregate([
	{$match: {status: 'visable', checkuserid: {$in: ['156****5285', '156****5194', '137****8875', '158****1125']}}},
	{$project: {mobile: '$checkuserid', date: {$dateToString: {format: "%Y-%m-%d", date: "$version" }}}},
	{$group: {_id: {mobile: '$mobile', date: "$date"}, count: {$sum: 1}}},
	{$sort: {'_id.mobile': 1, '_id.date': -1}}
]);
// 将数据转为csv格式
data.map(function(item) {
	return item._id.mobile + ',' + item._id.date + ',' + item.count;
}).join("\n");

倒出用户书单的描述和书的推荐语

var users = db.user.find({mobile_number: {$in: ['156****6041', '155****4511', '136****5641']}}, {_id: 0, mobile_number: 1, user_id: 1});

users.map(function(item) {
	item.floors = db.floor.find({user_id: item.user_id, type: {$exists: false}}, {user_id: 1, name: 1, desc: 1, item_list: 1}).toArray();
	item.floors = item.floors.map(function(item) {
		item.item_list = item.item_list.map(function(item) {
			return db.item.findOne({bid: item}, {bid: 1, title: 1, remark: 1});
		});
		return item;
	});
	return item;
});

根据出版社和书排出用户收藏最多的书

rs.slaveOk();
var data = db.library.aggregate([
	{$group: {_id: {publisher: '$publisher', bid: '$bid', title: '$title'}, count: {$sum: 1}}}
]);

// to csv
data
.toArray()
.sort(function(a, b) {
	return b.count - a.count;
})
.map(function(item) {
	return item._id.publisher + ',' + item._id.bid + ',' + item._id.title + ',' + item.count; 
})
.join("\n");

查出指定出版社前10名的书籍

rs.slaveOk();
var publishers = [
	'人民文学出版社',
	'上海译文出版社',
	'中华书局',
	'中信出版社',
	'商务印书馆',
	'生活·读书·新知三联书店',
	'广西师范大学出版社',
	'译林出版社',
	'新星出版社',
	'南海出版公司'
];
var data = db.library.aggregate([
	{$match: {publisher: {$in: publishers}}},
	{$group: {_id: {publisher: '$publisher', title: '$title'}, count: {$sum: 1}}}
]);

//findIndex是es6的函数，自己写。。。
var findIndex = function(fn) {
	var i = 0, r;
	while (this.length > i && !(r = fn(this[i], i, this))) i++;
	return r ? i : -1;
};

// to csv
data
// 对象数组化
.toArray()
// 按出版社归类排序
.sort(function(a, b) {
	return (publishers.indexOf(a._id.publisher) - publishers.indexOf(b._id.publisher)) || (b.count - a.count);
})
// 过滤出前10的书籍，这里可以用另一个数组对象来存储数据，减少运算步骤。
.filter(function(item, index, ary) {
	return index < (findIndex.call(ary, function(data) {
		return item._id.publisher === data._id.publisher;
	}) + 10);
})
// 格式化
.map(function(item) {
	return item._id.publisher + ',' + item._id.title + ',' + item.count; 
})
// toString
.join("\n");

ifNull的使用

db.library.aggregate([
	{$match: {user_id: '763532fec962ca3f5c96cd024860a43a'}},
	{$project: {read_status: {$ifNull: ["$read_status", "unread"]}}},
	{$group: {_id: '$read_status', total: {$sum: 1}}}
]);