Nodejs下mongoose简单操作实例

Nodejs下mongoose简单操作实例

Mongoose API : http://mongoosejs.com/docs/api.html

// mongoose 链接
var mongoose = require('mongoose');
var db       = mongoose.createConnection('mongodb://127.0.0.1:27017/NodeJS'); 
// 链接错误

db.on(‘error’, function(error) { console.log(error); });

// Schema 结构
var mongooseSchema = new mongoose.Schema({
username : {type : String, default : ‘匿名用户’},
title    : {type : String},
content  : {type : String},
time     : {type : Date, default: Date.now},
age      : {type : Number}
});
// 添加 mongoose 实例方法
mongooseSchema.methods.findbyusername = function(username, callback) {
return this.model(‘mongoose’).find({username: username}, callback);
}
// 添加 mongoose 静态方法,静态方法在Model层就能使用
mongooseSchema.statics.findbytitle = function(title, callback) {
return this.model(‘mongoose’).find({title: title}, callback);
}
// model
var mongooseModel = db.model(‘mongoose’, mongooseSchema);
// 增加记录 基于 entity 操作
var doc = {username : ‘emtity_demo_username’, title : ‘emtity_demo_title’, content : ‘emtity_demo_content’};
var mongooseEntity = new mongooseModel(doc);
mongooseEntity.save(function(error) {
if(error) {
console.log(error);
} else {
console.log(‘saved OK!’);
}
// 关闭数据库链接
db.close();
});
// 增加记录 基于model操作
var doc = {username : ‘model_demo_username’, title : ‘model_demo_title’, content : ‘model_demo_content’};
mongooseModel.create(doc, function(error){
if(error) {
console.log(error);
} else {
console.log(‘save ok’);
}
// 关闭数据库链接
db.close();
});
// 修改记录
mongooseModel.update(conditions, update, options, callback);
var conditions = {username : ‘model_demo_username’};
var update     = {$set : {age : 27, title : ‘model_demo_title_update’}};
var options    = {upsert : true};
mongooseModel.update(conditions, update, options, function(error){
if(error) {
console.log(error);
} else {
console.log(‘update ok!’);
}
//关闭数据库链接
db.close();
});
// 查询
// 基于实例方法的查询
var mongooseEntity = new mongooseModel({});
mongooseEntity.findbyusername(‘model_demo_username’, function(error, result){
if(error) {
console.log(error);
} else {
console.log(result);
}
//关闭数据库链接
db.close();
});
// 基于静态方法的查询
mongooseModel.findbytitle(‘emtity_demo_title’, function(error, result){
if(error) {
console.log(error);
} else {
console.log(result);
}
//关闭数据库链接
db.close();
});
// mongoose find
var criteria = {title : ‘emtity_demo_title’}; // 查询条件
var fields   = {title : 1, content : 1, time : 1}; // 待返回的字段
var options  = {};
mongooseModel.find(criteria, fields, options, function(error, result){
if(error) {
console.log(error);
} else {
console.log(result);
}
//关闭数据库链接
db.close();
});
// 删除记录
var conditions = {username: ‘emtity_demo_username’};
mongooseModel.remove(conditions, function(error){
if(error) {
console.log(error);
} else {
console.log(‘delete ok!’);
}

//关闭数据库链接
db.close();

});


25 回复

Nodejs下mongoose简单操作实例

Mongoose 是一个对象模型工具,它封装了 MongoDB 操作,使得在 Node.js 中操作 MongoDB 更加方便。以下是 Mongoose 的一些基本操作示例。

安装 Mongoose

首先,你需要安装 Mongoose 库。可以通过 npm 安装:

npm install mongoose

连接到 MongoDB 数据库

// mongoose 链接
var mongoose = require('mongoose');
var db = mongoose.createConnection('mongodb://127.0.0.1:27017/NodeJS');

// 链接错误
db.on('error', function(error) {
    console.log(error);
});

定义 Schema 和 Model

// Schema 结构
var mongooseSchema = new mongoose.Schema({
    username : {type : String, default : '匿名用户'},
    title    : {type : String},
    content  : {type : String},
    time     : {type : Date, default: Date.now},
    age      : {type : Number}
});

// 添加 mongoose 实例方法
mongooseSchema.methods.findbyusername = function(username, callback) {
    return this.model('mongoose').find({username: username}, callback);
}

// 添加 mongoose 静态方法,静态方法在Model层就能使用
mongooseSchema.statics.findbytitle = function(title, callback) {
    return this.model('mongoose').find({title: title}, callback);
}

// model
var mongooseModel = db.model('mongoose', mongooseSchema);

增加记录

// 增加记录 基于 entity 操作
var doc = {username : 'emtity_demo_username', title : 'emtity_demo_title', content : 'emtity_demo_content'};
var mongooseEntity = new mongooseModel(doc);
mongooseEntity.save(function(error) {
    if(error) {
        console.log(error);
    } else {
        console.log('saved OK!');
    }
    // 关闭数据库链接
    db.close();
});

// 增加记录 基于model操作
var doc = {username : 'model_demo_username', title : 'model_demo_title', content : 'model_demo_content'};
mongooseModel.create(doc, function(error){
    if(error) {
        console.log(error);
    } else {
        console.log('save ok');
    }
    // 关闭数据库链接
    db.close();
});

修改记录

// 修改记录
mongooseModel.update(conditions, update, options, callback);
var conditions = {username : 'model_demo_username'};
var update     = {$set : {age : 27, title : 'model_demo_title_update'}};
var options    = {upsert : true};
mongooseModel.update(conditions, update, options, function(error){
    if(error) {
        console.log(error);
    } else {
        console.log('update ok!');
    }
    //关闭数据库链接
    db.close();
});

查询记录

// 基于实例方法的查询
var mongooseEntity = new mongooseModel({});
mongooseEntity.findbyusername('model_demo_username', function(error, result){
    if(error) {
        console.log(error);
    } else {
        console.log(result);
    }
    //关闭数据库链接
    db.close();
});

// 基于静态方法的查询
mongooseModel.findbytitle('emtity_demo_title', function(error, result){
    if(error) {
        console.log(error);
    } else {
        console.log(result);
    }
    //关闭数据库链接
    db.close();
});

// mongoose find
var criteria = {title : 'emtity_demo_title'}; // 查询条件
var fields   = {title : 1, content : 1, time : 1}; // 待返回的字段
var options  = {};
mongooseModel.find(criteria, fields, options, function(error, result){
    if(error) {
        console.log(error);
    } else {
        console.log(result);
    }
    //关闭数据库链接
    db.close();
});

删除记录

// 删除记录
var conditions = {username: 'emtity_demo_username'};
mongooseModel.remove(conditions, function(error){
    if(error) {
        console.log(error);
    } else {
        console.log('delete ok!');
    }

    //关闭数据库链接
    db.close();
});

以上就是 Mongoose 在 Node.js 中的一些基本操作示例。希望这些示例能够帮助你更好地理解和使用 Mongoose。


非常感谢 ,正在学习很需要这个

支持一下 :)

有时候JS 为什么要加$…原谅我 问这么小白的问题

感谢楼主,提供这样精悍的代码,快速了解诶代码机制

mark是什么

楼主麻烦问一下,基于model操作和静态操作对程序有什么影响吗?对于操作是肯定都能完成的,其他方面呢?

同步代码怎么写?

mark一下

分页呢?

基于实例方法的查询和基于静态方法的查询有问题吧 Entity 必须实例之后才可以查询吧 statics 不需要model之后查询吧

schema.methods.findByUserName = function(callback) {
    return this.model('users').find({user: this.user}, callback)
}

schema.statics.findByUserName = function(username, callback) { return this.find({user: username}, callback) }

var mongooseModel = db.model(‘users’, schema);

// entity find var mongooseEntity = new mongooseModel({user: ‘user_100’}); mongooseEntity.findByUserName(function(err, docs) { if (err) return console.log(err); console.log(docs); db.close(); })

// statics find mongooseModel.findByUserName(‘user_100’, function(err, docs) { if (err) return console.log(err); console.log(docs); db.close() })

2年前。

2018年占个坑,感谢楼主

为了帮助你更好地理解和使用Mongoose进行基本的操作,以下是一个简单的Node.js与Mongoose结合使用的实例。这将涵盖连接数据库、定义模式(Schema)、创建文档、读取数据、更新数据以及删除数据的基本操作。

首先确保已安装了mongoose

npm install mongoose

接下来是具体的实现代码:

1. 连接到MongoDB

var mongoose = require('mongoose');

// 连接到本地MongoDB服务
mongoose.connect('mongodb://127.0.0.1:27017/test', { useNewUrlParser: true, useUnifiedTopology: true });

// 监听连接错误
mongoose.connection.on('error', function(err) {
    console.error('MongoDB connection error: ' + err);
});

// 监听连接成功事件
mongoose.connection.once('open', function() {
    console.log('Connected to MongoDB');
});

2. 定义模式(Schema)

var mongooseSchema = new mongoose.Schema({
    username: { type: String, default: '匿名用户' },
    title: { type: String },
    content: { type: String },
    time: { type: Date, default: Date.now },
    age: { type: Number }
});

3. 创建模型(Model)

var User = mongoose.model('User', mongooseSchema);

4. 增加记录

var newUser = new User({
    username: 'test_user',
    title: 'Sample Title',
    content: 'This is a sample document.',
    age: 25
});

newUser.save(function(error) {
    if (error) {
        console.error('Failed to save user: ', error);
    } else {
        console.log('User saved successfully');
    }
});

5. 查询记录

User.findOne({ username: 'test_user' }, function(error, user) {
    if (error) {
        console.error('Failed to find user: ', error);
    } else {
        console.log('Found user: ', user);
    }
});

6. 更新记录

User.updateOne(
    { username: 'test_user' },
    { $set: { title: 'Updated Title' } },
    function(error) {
        if (error) {
            console.error('Failed to update user: ', error);
        } else {
            console.log('User updated successfully');
        }
    }
);

7. 删除记录

User.deleteOne({ username: 'test_user' }, function(error) {
    if (error) {
        console.error('Failed to delete user: ', error);
    } else {
        console.log('User deleted successfully');
    }
});

以上就是使用Mongoose进行数据库操作的一个简单示例。希望对你有所帮助!

回到顶部