How to use the MongoClient function from mongodb

Find comprehensive JavaScript mongodb.MongoClient code examples handpicked from public code repositorys.

mongodb.MongoClient is a class used to create a client object to connect to a MongoDB server instance.

20
21
22
23
24
25
26
27
28
## Use

```js
const mongo = require('mongodb');

const client = new mongo.MongoClient(uri);
await client.connect();
// get a collection
const collection = client.collection('artists');
fork icon73
star icon466
watch icon16

133
134
135
136
137
138
139
140
141
142
  complete: '=',
  incomplete: ' ',
  clear: true
});

const client = new MongoClient(uri);

(async function main() {
  try {
    await client.connect();
fork icon13
star icon113
watch icon21

How does mongodb.MongoClient work?

mongodb.MongoClient is a class in the MongoDB Node.js driver that represents a client for connecting to a MongoDB deployment, allowing you to establish a connection to a MongoDB database server and perform CRUD (Create, Read, Update, Delete) operations on a database using JavaScript. When you call MongoClient.connect() method with the required URL and options, it returns a Promise that resolves to a connected MongoClient instance that can be used to interact with the database. The MongoClient class also provides several other methods and properties to manage database connections and configurations.

76
77
78
79
80
81
82
83
84
origin:
```js
var mongo = require('mongodb');
var Db = mongo.Db;
var Server = mongo.Server;
var MongoClient = mongo.MongoClient;
var ReplSetServers = mongo.ReplSetServers;
...
```
fork icon174
star icon0
watch icon67

+ 7 other calls in file

296
297
298
299
300
301
302
303
304
305
exports.logError = async (logData) => {
  const options = {
    useUnifiedTopology: true,
    useNewUrlParser: true,
  };
  const client = new MongoClient(process.env.DBSTRING, options);
  await client.connect();
  await client
    .db("errors")
    .collection("bugs")
fork icon5
star icon91
watch icon0

Ai Example

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
const { MongoClient } = require("mongodb");

// Connection URL
const url = "mongodb://localhost:27017";

// Database Name
const dbName = "myproject";

// Use connect method to connect to the server
MongoClient.connect(url, function (err, client) {
  console.log("Connected successfully to server");

  const db = client.db(dbName);

  client.close();
});

In this example, we're connecting to a MongoDB database running on the local machine using the mongodb protocol and port number 27017. Once the connection is established, we get a reference to the myproject database and then close the connection using client.close().

25
26
27
28
29
30
31
32
33
34
if ( config.database.replicaSet )
    url      += `/?replicaSet=${config.database.replicaSet}&w=majority`;

config.debug.extend && debug('MongoDB Connect: ', url );

const client            = new MongoClient(
    url,
    {
        readPreference:     ReadPref.NEAREST,
        w:                  'majority'
fork icon4
star icon6
watch icon0

859
860
861
862
863
864
865
866
867
868
869
};


/* --- Store Shopify data in database --- */
const insertDB = function (key, data, collection = MONGO_COLLECTION) {
  return new Promise(function (resolve, reject) {
    mongo.MongoClient.connect(MONGO_URL).then(function (db) {
      //console.log(`insertDB Connected: ${MONGO_URL}`);
      var dbo = db.db(MONGO_DB_NAME);
      console.log(`insertDB Used: ${MONGO_DB_NAME} - ${collection}`);
      console.log(`insertDB insertOne, _id:${key}`);
fork icon2
star icon3
watch icon1

+ 17 other calls in file

28
29
30
31
32
33
34
35
36
37
38
// end-datakeyopts


async function run() {
  // start-create-index
  const uri = credentials.MONGODB_URI;
  const keyVaultClient = new MongoClient(uri);
  await keyVaultClient.connect();
  const keyVaultDB = keyVaultClient.db(keyVaultDatabase);
  // Drop the Key Vault Collection in case you created this collection
  // in a previous run of this application.
fork icon1
star icon0
watch icon0

19
20
21
22
23
24
25
26
27
28
29
30
// end-kmsproviders


async function run() {
  // start-schema
  const uri = credentials.MONGODB_URI;
  const unencryptedClient = new MongoClient(uri);
  await unencryptedClient.connect();
  const keyVaultClient = unencryptedClient.db(eDB).collection(eKV);


  const dek1 = await keyVaultClient.findOne({ keyAltNames: "dataKey1" });
fork icon1
star icon0
watch icon0

1
2
3
4
5
6
7
8
9
10
11
12
const { MongoClient, ObjectId } = require("mongodb");
const himalaya = require("himalaya");
const { v4: uuidv4 } = require("uuid");


const dbPath = "mongodb://127.0.0.1:27017/heroku_wbj38s57?serverSelectionTimeoutMS=60000";
const client = new MongoClient(dbPath);
const dbName = "heroku_wbj38s57";


const removeHTML = (input) => {
  return input.replace(/<\/?[^>]+(>|$)/g, "");
fork icon0
star icon19
watch icon6

+ 4 other calls in file

16
17
18
19
20
21
22
23
24
const mongouri = bot.mongouri;

//Error Checking (unlikely, but just in case)
if (!id) { console.log('....What? How?'); return interaction.editReply("Uh oh, something happened with the Stripe Discord ID check, please contact support!"); }

// const client = new MongoClient(mongouri, { useNewUrlParser: true, useUnifiedTopology: true, serverApi: ServerApiVersion.v1 });
new Promise(async function(resolve, reject) {
    bot.mongoconnection.then(async (client) => {
        // if (err) { return console.log(err); }
fork icon0
star icon3
watch icon1

+ 9 other calls in file

105
106
107
108
109
110
111
112
113
114
115
} else {
    mongouritemp = require('./config.json').mongooseURI;
}
const mongouri = mongouritemp;
bot.mongouri = mongouri;
const client = new MongoClient(mongouri, { useNewUrlParser: true, useUnifiedTopology: true, serverApi: ServerApiVersion.v1 });
bot.mongoconnection = client.connect();


//Error stuff
var preverr = "";
fork icon0
star icon3
watch icon1

+ 4 other calls in file

-1
fork icon0
star icon1
watch icon1

+ 3 other calls in file

9
10
11
12
13
14
15
16
17
18
19
20
const selector = { 'csgostatsData': {} }; // Empty data due to a tímeout




// This can be used to manually update fields int the database
const updateCsgoStats = async () => {
    const client = new MongoClient(process.env.DBURL);
    try {
        // Connect to the MongoDB cluster
        await client.connect();
        const collection = client.db("cache").collection("playerCache");
fork icon0
star icon1
watch icon1

+ 19 other calls in file

2
3
4
5
6
7
8
9
10
11
const needle = require("needle");
const tmi = require("tmi.js");
const LeagueJS = require("leaguejs");
const chalk = require("chalk");
const { MongoClient } = require("mongodb");
const MongoDBclient = new MongoClient(process.env.DATABASEURL);
const Bot = require("./auth/thebrightcandle.json");
const Dino = require("./auth/dinoosaaw.json");
const moment = require("moment");
const { EmbedBuilder, WebhookClient } = require("discord.js");
fork icon0
star icon1
watch icon1

+ 15 other calls in file

231
232
233
234
235
236
237
238
239
240


app.use((req, res) => res.status(404).redirect("/404"));


app.listen(port, async () => {
    console.log('Server running on port ' + port);
    try {const mongo = new MongoClient(process.env.MONGODB_URI); mongo.connect(); mongoClient = mongo.db("Website").collection('Users')}
    catch (error) {logging.error(error)}
}, );
fork icon0
star icon1
watch icon1

+ 7 other calls in file

11
12
13
14
15
16
17
18
19
20
21
22
23
24
app.use(express.json()); // আমরা যদি কখনো কিছু পাঠায় json ফরমেট এ তাহলে তা access করতে পারবো 




const uri = `mongodb+srv://${process.env.DB_USER}:${process.env.DB_PASS}@cluster0.zoj9s.mongodb.net/?retryWrites=true&w=majority`;
console.log(uri)
const client = new MongoClient(uri, { useNewUrlParser: true, useUnifiedTopology: true, serverApi: ServerApiVersion.v1 });




async function run(){
    try{
fork icon0
star icon1
watch icon0

9
10
11
12
13
14
15
16
17
18
19
20
21
  throw Error('Database not configured. Set environment variables');
}


const url = `mongodb+srv://${userName}:${password}@${hostname}`;


const client = new MongoClient(url);
const userCollection = client.db('darling').collection('user');
const dateIdeasCollection = client.db('darling').collection('dateIdeas');


function getUser(email) {
fork icon0
star icon1
watch icon0

1
2
3
4
5
6
7
8
9
10
11
12
13
const express = require('express');
const { UUID } = require('bson');


const uri = 'mongodb://127.0.0.1:27017';


const client = new MongoClient(uri, {
	pkFactory: { createPk: () => new UUID().toBinary() },
});


async function run() {
fork icon0
star icon1
watch icon0

-3
fork icon1
star icon0
watch icon1

+ 4 other calls in file

979
980
981
982
983
984
985
986
987
988
// Create a database variable outside of the
// database connection callback to reuse the connection pool in the app.
var db;
var client;
try {
  client = await mongodb.MongoClient.connect(mongouri, { useNewUrlParser: true, useUnifiedTopology: true })
}
catch(error) {
  logger.error("(Chat21-http) An error occurred during connection to MongoDB:", error);
  process.exit(1);
fork icon3
star icon3
watch icon3

+ 2 other calls in file