Mungo mehrere verbindungen

Derzeit habe ich diesen code für meine Verbindung mongoose.js:

var mongoose = require('mongoose');
var uriUtil = require('mongodb-uri');
var mongodbUri = 'mongodb://localhost/db_name';
var mongooseUri = uriUtil.formatMongoose(mongodbUri);
mongoose.connect(mongooseUri);
module.exports = mongoose;

Datei, erfordert die Verbindung test.js:

var mongoose = require('../model/mongoose');
var schema = mongoose.Schema({...});

Wie kann ich ein update mongoose.js verwenden mehrere verbindungen mit Mungo.createConnection (...) - Funktion?

Starte ich die änderungen nur für eine Verbindung wenn ich das mache Veränderungen so:

var mongoose = require('mongoose');
mongoose.createConnection('mongodb://localhost/db_name');
mongoose.open('localhost');
module.exports = mongoose;

Bekomme ich "undefined" keine Funktion".
Wenn ich diesen code verwenden:

var mongoose = require('mongoose');
db = mongoose.createConnection('mongodb://localhost/db_name');
db.open('localhost');
module.exports = mongoose;

Bekomme ich "Fehler: Sie Versuchen zu öffnen, nicht geschlossene Verbindung"

Irgendwelche Ratschläge?

InformationsquelleAutor Pumych | 2015-10-02
  1. 24

    Mungo handling-verbindungen via verbindungen pool
    http://mongoosejs.com/docs/connections.html

    Können Sie server: {poolSize: 5} option für erhöhen/verringern-pool (Anzahl der parallelen verbindungen)

    Wenn Sie brauchen verbindungen zu verschiedenen Datenbanken sehen Sie hier
    Mungo und mehrere Datenbank in einzelnen node.js Projekt

    Beispiel für mehrere verbindungen:

    var mongoose = require('mongoose')
var conn = mongoose.createConnection('mongodb://localhost/db1');
var conn2 = mongoose.createConnection('mongodb://localhost/db2');
var Schema = new mongoose.Schema({})
var model1 = conn.model('User', Schema);
var model2 = conn2.model('Item', Schema);
model1.find({}, function() {
   console.log("this will print out last");
});
model2.find({}, function() {
   console.log("this will print out first");
});
    • Ja, ich brauche mehrere DB-Verbindung. Ich sah diese Antwort, aber es funktioniert immer noch nicht in meinem Fall. Beispiel mit conn und conn2 am besten aussieht, aber ich kann nicht nur trennen es in zwei Dateien. Können Sie bitte versuchen, ein Beispiel geben mit?
    • Hinzugefügt Beispiel arbeiten für Sie. Ist es das, was man benötigt?
    InformationsquelleAutor vmkcom
  2. 8

    OK. Mit deinem Beispiel habe ich eine Lösung gefunden, die zu meinen Anforderungen passen.

    mongoose.js

    var mongoose = require('mongoose');
mongoose.main_conn = mongoose.createConnection('mongodb://localhost/main');
mongoose.admin_conn = mongoose.createConnection('mongodb://localhost/admin');
module.exports = mongoose;

    content.js

    var mongoose = require('../model/mongoose');
var schema = mongoose.Schema({...});

///functions here
schema.statics.func_a(){...};
schema.statics.func_b(){...};

//And finaly updated only one line
//exports.Content = mongoose.model('Content', schema);
exports.Content = mongoose.main_conn.model('Content', schema);

    Die einzige Sache, ist es OK, um hinzufügen Verbindung, Objekte zu mongoose-Objekt oder vielleicht gibt es elegantere Lösung.

    • Und wie schließen wir diese verbindungen als parallel?Ich bekomme Fehler TypeError: client.s.dbCache[name].emit is not a function
    InformationsquelleAutor Pumych
  3. 2

    config.js

    module.exports = {
    default: 'main',
    main: 'mongodb://localhost/main',
    admin: 'mongodb://localhost/admin',
};

    connection.js

    const mongoose = require('mongoose');
const config = require('./config');

mongoose.Promise = global.Promise;

function createConnection(name) {
    return mongoose.createConnection(config[name]);
}

module.exports = createConnection(config[config.default]);

module.exports.on = createConnection;

    model.js (custom class)

    const connection = require('./connection');

class Model {
    constructor(name, data) {
        this.data = data;
        return this.connection().model(name, data.schema);
    }

    connection() {
        if (this.data.connection) {
            return connection.on(this.data.connection);
        }

        return connection;
    }
}

module.exports = Model;

    user.js

    const Schema = require('mongoose').Schema;
const conn = require('./connection');
const Model = require('./model');

const userSchema = new Schema({
    name: String,
    email: String,
    password: String
});

//USING MONGOOSE MODEL
//default connection
const UserM1 = conn.model('User', userSchema);

//admin connection
const UserM2 = conn.on('admin').model('User', userSchema);

//USING CUSTOM MODEL
//default connection
const UserC1 = new Model('User', { 
    schema: userSchema 
});

//admin connection
const UserC2 = new Model('User', { 
    schema: userSchema, 
    connection: 'admin' 
});
    InformationsquelleAutor Sergio Rodrigues
Schreibe einen Kommentar