fred.boniface/OwlBoard
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects 1 Releases Wiki Activity

Add check before dropping collection

Browse Source
This commit is contained in:
Fred Boniface 2023-01-11 10:21:27 +00:00
parent 1c269571b7
commit 0317dc723a
1 changed files with 16 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/services/dbAccess.services.js
View File

@ -13,20 +13,24 @@ const client = new MongoClient(uri);
const db = client.db(dbName); const db = client.db(dbName);
async function dropCollection(coll){ async function dropCollection(coll){
log.out(`DbAccess.dropCollection: checking if collection exists: ${coll}`)
//Some Code Here:
await client.connect(); await client.connect();
var cols = await db.listCollections().toArray()
log.out(`dbAccess.dropCollection: Existing collections: ${JSON.stringify(cols)}`)
// If (any object in the Array contains name:{coll} then exsists. If not doesn't exist.)
// check if collection contains any documents, if it doesn't, it is either empty or non-existent - it doesn't need dropping.
// If Collection Exists: var collection = db.collection(coll);
log.out(`DbAccess.dropCollection: dropping collection: ${coll}`) var count = await collection.countDocuments();
log.out(`DbAccess.dropCollection: Collection '${coll}' contains ${count} documents`)
if (count == 0) {
log.out(`DbAccess.dropCollection: Collection '${coll}' is empty. Do not need to drop`)
} else {
log.out(`DbAccess.dropCollection: dropping collection: '${coll}'`)
db.dropCollection(coll); db.dropCollection(coll);
log.out(`DbAccess.dropCollection: dropped collection: ${coll}`) log.out(`DbAccess.dropCollection: dropped collection: '${coll}'`)
// Else Do Nothing }
// ALTERNATIVE METHOD - Appears to not be needed:
// This code returns and prints an array containing an object for each existing collection.
// var cols = await db.listCollections().toArray()
// log.out(`dbAccess.dropCollection: Existing collections: ${JSON.stringify(cols)}`)
// If (any object in the Array contains name:{coll} then exsists. If not doesn't exist.)
} }
async function putCorpus(data){ async function putCorpus(data){