mongodbeginner/index.js at master · integral0523/mongodbeginner · GitHub

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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
const mongodb = require('mongodb')
const b = {
    update : async(dbName, collectionName, filter, update, dbUrl="mongodb://localhost:27017")=>{
        client = await mongodb.MongoClient.connect(dbUrl,{useNewUrlParser:true, useUnifiedTopology: true });
        db = await client.db(dbName)
        await db.collection(collectionName).updateOne(filter,{$set:update},(err,res)=>{
            if(err){
                console.error(err)
                client.close()
                return false
            }
            client.close()
            return true
        })
    },
    insert : async(dbName, collectionName, insert, dbUrl="mongodb://localhost:27017")=>{
        client = await mongodb.MongoClient.connect(dbUrl,{useNewUrlParser:true, useUnifiedTopology: true });
        db = await client.db(dbName)
        await db.collection(collectionName).insertOne(insert,(err,res)=>{
            if(err){
                console.error(err)
                client.close()
                return false
            }
            client.close()
            return true
        })
    },
    upsert : async(dbName, collectionName, filter, update, dbUrl="mongodb://localhost:27017")=>{
        client = await mongodb.MongoClient.connect(dbUrl,{useNewUrlParser:true, useUnifiedTopology: true });
        db = await client.db(dbName)
        await db.collection(collectionName).updateOne(filter,{$set:{update}},{upsert:true},(err,res)=>{
            if(err){
                console.error(err)
                client.close()
                return false
            }
            client.close()
            return true
        })
    },
    find : async(dbName, collectionName, filter, dbUrl="mongodb://localhost:27017")=>{
        client = await mongodb.MongoClient.connect(dbUrl,{useNewUrlParser:true, useUnifiedTopology: true });
        db = await client.db(dbName)
        documents = await db.collection(collectionName).find(filter).toArray()
        client.close()
        return documents
    },
    findOne : async(dbName, collectionName, filter, dbUrl="mongodb://localhost:27017")=>{
        client = await mongodb.MongoClient.connect(dbUrl,{useNewUrlParser:true, useUnifiedTopology: true });
        db = await client.db(dbName)
        documents = await db.collection(collectionName).find(filter).toArray()
        client.close()
        return documents[0]
    },
    remove: async(dbName, collectionName, filter, dbUrl="mongodb://localhost:27017")=>{
        client = await mongodb.MongoClient.connect(dbUrl,{useNewUrlParser:true, useUnifiedTopology: true });
        db = await client.db(dbName)
        await db.collection(collectionName).remove(filter,(err,res)=>{
            if(err){
                console.error(err)
                client.close()
                return false
            }
            client.close()
            return true
        })
    }
}
module.exports = b;