(dbId, params, callback)
| 221 | } |
| 222 | |
| 223 | async function MongoBulkWrite(dbId, params, callback) { |
| 224 | try { |
| 225 | if (typeof callback !== "function") callback = null; |
| 226 | if (typeof params !== "object") return null; |
| 227 | if (typeof params.collection !== "string") return null; |
| 228 | if (typeof params.operations !== "object") return null; |
| 229 | const collection = global.MongoConnections[dbId].collection(params.collection) |
| 230 | const result = await collection.bulkWrite(params.operations); |
| 231 | return callback ? callback(result) : result; |
| 232 | } catch (error) { |
| 233 | ParseError("MongoDB bulk write error catched:", error.message); |
| 234 | return callback ? callback(null) : null; |
| 235 | } |
| 236 | } |
| 237 | |
| 238 | async function MongoReplaceOne(dbId, params, callback) { |
| 239 | try { |
nothing calls this directly
no test coverage detected