1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
'use strict'
const mongoose = require('mongoose')
const schema = require('./schema')
// the default mongodb url (local server)
const mongodbURL = process.env.DB_URL || 'mongodb://127.0.0.1:27017'
mongoose.connect(mongodbURL, {
useNewUrlParser: true,
useUnifiedTopology: true,
useFindAndModify: false
})
const Count = mongoose.connection.model('Count', schema)
function getNum(name) {
return Count
.findOne({ name }, '-_id -__v')
.exec()
}
function getAll() {
return Count
.find({ }, '-_id -__v')
.exec()
}
function setNum(name, num) {
return Count
.findOneAndUpdate({ name }, { name, num }, { upsert: true })
.exec()
}
function setNumMulti(counters) {
const bulkOps = counters.map(obj => {
const { name, num } = obj
return {
updateOne: {
filter: { name },
update: { name, num },
upsert: true
}
}
})
return Count.bulkWrite(bulkOps, { ordered : false })
}
module.exports = {
getNum,
getAll,
setNum,
setNumMulti
}
|