Como faço a conexão com a database mongo com nodejs? Já consultei vários sitios mas não estou conseguindo fazer da maneira correta! Agradeço a quem ajudar!
2 Respostas
Utilize o mongoose.
Segue um exemplo de como abrir a conexão
var mongoose = require('mongoose');
global.db = mongoose.connect('mongodb://localhost:27017/neventos');
mongoose.connection.on('connected', function () {
console.log('=====Conexão estabelecida com sucesso=====');
});
mongoose.connection.on('error', function (err) {
console.log('=====Ocorreu um erro: ' + err);
});
mongoose.connection.on('disconnected', function () {
console.log('=====Conexão finalizada=====');
});
Nesse link tem um projeto completo que utilizei mongoose para fazer a conexão.
-
Preciso de mais alguma coisa além de instalar o mongodb e o nodejs? É que ele dá erro na consola a dizer "require is not defined" Commented 29/06/2018 às 16:43
-
O Node.js é uma linguagem utilizada para server side, pelo erro que você disse que está ocorrendo, provavelmente está chamando esse arquivo js em um navegador, daí a implementação é diferente, terá que utilizar algo como o requirejs no seu projeto.– echojnCommented 29/06/2018 às 16:52
-
-
Mas é necessariamente o mongoose para estabelecer a ligação a db? Commented 1/07/2018 às 22:26
Você pode realizar da seguinte maneira:
require('dotenv').config();
const { MongoClient } = require('mongodb');
class MyConnect extends MongoClient {
constructor(url, options) {
super(url, options);
this.client = null;
this.on('insert-value', this.insertValue)
}
async insertValue(data) {
try {
this.client = await this.connect()
const collection = this.client.db('testando').collection('olhaai');
const response = await collection.insertOne(data);
console.log(response);
this.client.close();
} catch (error) {
console.log(error);
}
}
}
(new MyConnect(
process.env.MONGOURL,
{
useNewUrlParser: true,
useUnifiedTopology: true
})
).emit('insert-value', { ola: 'fion', tudo: 'bom'});
Lembrando que a classe MongoCliente herda da classe EventEmitter então você pode usar o:
module.exports = MyConnect;
com isto você pode usar a sua estância da classe e chamar os ouvintes evento que estão dentro dela com o .emit('EventName', opções);
bom uso.
fiz o teste 4 vezes, você pode manipular as querys pelo ouvinte de evento, ou chamando a própria função.