theluyuan/blog-server
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

自动递增

Browse Source
This commit is contained in:
pplokijuhyg
2019-11-19 13:37:11 +08:00
parent d6e08d9ed5
commit 073211bd97
3 changed files with 53 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
bin/mongodb.js
View File

@@ -1,7 +1,38 @@
var MongoClient = require('mongodb').MongoClient;
var dburl;
let add = (set, data, url = dburl) => {
let idadd = async (set) => {
let id = 0
if (set == "idadd") {
return 0;
} else {
await find('idadd', { 'set': set }).then((res) => {
if (res.data.length != 0) {
id = res.data[0].num_key
} else {
id = 1
}
})
}
if (id == 1) {
await add('idadd', { set, 'num_key': 2 })
} else if (set != "idadd") {
console.log(id)
await update('idadd', { 'set': set }, { 'num_key': id + 1 })
}
console.log(id)
return id
}
let add = async (set, data, url = dburl) => {
if (set != "idadd") {
let id = await idadd(set)
data.num_key = id
}
return new Promise((resolve, reject) => {
MongoClient.connect(url.url, { useUnifiedTopology: true, useNewUrlParser: true }, function (err, db) {
if (err) throw err;
var dbo = db.db(url.dbname);
@@ -18,8 +49,16 @@ let add = (set, data, url = dburl) => {
});
})
}
let adds = (set, data, url = dburl) => {
let adds = async (set, data, url = dburl) => {
if (set != "idadd") {
for (let i in data) {
let id = await idadd(set)
data[i].num_key = id
}
}
return new Promise((resolve, reject) => {
MongoClient.connect(url.url, { useUnifiedTopology: true, useNewUrlParser: true }, function (err, db) {
if (err) throw err;
var dbo = db.db(url.dbname);
@@ -36,7 +75,7 @@ let adds = (set, data, url = dburl) => {
});
})
}
let remove = (set, where, url = dburl) => {
let remove = async (set, where, url = dburl) => {
return new Promise((resolve, reject) => {
MongoClient.connect(url.url, { useUnifiedTopology: true, useNewUrlParser: true }, function (err, db) {
if (err) throw err;
@@ -54,7 +93,7 @@ let remove = (set, where, url = dburl) => {
});
})
}
let removes = (set, where, url = dburl) => {
let removes = async (set, where, url = dburl) => {
return new Promise((resolve, reject) => {
if (where == "" || Object.keys(where).length == 0) {
reject({ code: 1 })
@@ -75,7 +114,7 @@ let removes = (set, where, url = dburl) => {
});
})
}
let find = (set, where = {}, page = 0, num = 0, url = dburl) => {
let find = async (set, where = {}, page = 0, num = 0, url = dburl) => {
return new Promise((resolve, reject) => {
if (num == 0) {
MongoClient.connect(url.url, { useUnifiedTopology: true, useNewUrlParser: true }, function (err, db) {
@@ -111,7 +150,7 @@ let find = (set, where = {}, page = 0, num = 0, url = dburl) => {
})
}
let update = (set, where = {}, data, defin = true, url = dburl) => {
let update = async (set, where = {}, data, defin = true, url = dburl) => {
return new Promise((resolve, reject) => {
MongoClient.connect(url.url, { useUnifiedTopology: true, useNewUrlParser: true }, function (err, db) {
if (err) throw err;
@@ -132,7 +171,7 @@ let update = (set, where = {}, data, defin = true, url = dburl) => {
});
})
}
let updates = (set, where = {}, data, url = dburl) => {
let updates = async (set, where = {}, data, url = dburl) => {
return new Promise((resolve, reject) => {
MongoClient.connect(url.url, { useUnifiedTopology: true, useNewUrlParser: true }, function (err, db) {
if (err) throw err;