zoukankan      html  css  js  c++  java
  • Mongoose多数据库连接及实用样例

    使用环境:

    MongoDB 3.6

    插件版本:

    "mongodb": "^3.1.10",
    "mongoose": "^5.4.2",

    直接上代码

    let mongoose = require('mongoose');
    mongoose.Promise = global.Promise;
    mongoose.set('debug', true);
    let dbname1 = 'datab1';
    let dbname2 = 'datab2';
    const options = {
        useNewUrlParser: true,
        useCreateIndex: true,
        reconnectTries: Number.MAX_VALUE
    };
    let uri_1 = 'mongodb://username:pwd@192.168.1.1:27017/'+dbname1;
    let uri_2 = 'mongodb://192.168.0.2:27017/'+dbname2;
    let db1  = mongoose.createConnection(uri_1, options);
    db1.on('error', () => {
        console.log(uri_1+"
    数据库[" + dbname1 + "]连接错误!" + error);
    }).on('connected', () => {
        console.log(uri_1+"
    数据库[" + dbname1 + "]连接成功!");
    });
    let db2  = mongoose.createConnection(uri_2, options);
    db2.on('error', () => {
        console.log(uri_2+"
    数据库[" + dbname2 + "]连接错误!" + error);
    }).on('connected', () => {
        console.log(uri_2+"
    数据库[" + dbname2 + "]连接成功!");
    });

    定义好后接下来上Model测试

    let InfoC_Schema = new mongoose.Schema({
        status: {type:Number, default: 0},                 
        desc: String,                                       
        url: String,                                        
        readtime: Date,                                     
        createdate: {type:Date, default: Date.now}
    }, {
        versionKey: false,
        collection: "cx_infoc"
    });
    let InfoC = db1.model("InfoC", InfoC_Schema);
    
    let Logs_Schema = new mongoose.Schema({
        objname: String,                                
        objid: String,                                  
        desc: String,                                   
        level:{type:Number, default: 1},                
        createdate: {type:Date, default: Date.now}
    }, {
        versionKey: false,
        collection: "cx_logs"
    });
    let Logs = db2.model("Logs", Logs_Schema);
    
    
    InfoC.find({}, function(err, list){
        console.log("db1.>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
       console.log(list);
    });
    
    Logs.find({}, function(err, list){
        console.log("db2.>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
        console.log(list);
    });
  • 相关阅读:
    编译安装centos6.9 php7.0 mysql5.6 nginx1.8
    mysql小细节随笔
    mpdf中文开发使用文档附demo实例
    svn和NetBeans一起使用造成svn老是死锁, database is locked
    Mastering MariaDB 神秘的MariaDB 中文翻译版
    Laravel开发采坑系列问题
    phpspider php爬虫框架
    ajaxFileUpload只能上传一次,和上传同名图片不能上传等bug问题
    bootstrap-treeview 中文开发手册
    phpredis Redis阵列 Redis Arrays
  • 原文地址:https://www.cnblogs.com/visionsl/p/10299981.html
Copyright © 2011-2022 走看看