美文网首页
05-Node.js 操作 MongoDB 数据库

05-Node.js 操作 MongoDB 数据库

作者: Am3 | 来源:发表于2019-10-28 14:21 被阅读0次

Node 操作 MongoDB 数据库

MongoDB 相关概念

术语 解释说明
database 数据库:
collection 集合:一组数据的集合(理解为一张表)
document 文档:一条具体的数据(理解为一行)
field 字段:文档中的属性名

Node 操作 MongoDB 的第三方包 - mongoose

  • 使用 mongoose 操作 MongoDB 数据库
  • 安装:npm install mongoose

启动和停止数据库

  • 启动:在命令行输入 net start mongodb
  • 停止:在命令行输入 net stop mongodb

MongoDB 导入数据

使用 mongoimport 导入数据,使用之前要确保 mongoimport.exe 所在的路径添加到环境变量

mongoimport -d 数据库名称 -c 集合名称 --file 要导入的数据文件

连接数据库

在 mongodb 不需要显式的创建数据库,但数据库不存在,mongodb 会自动创建

const mongoose = require('mongoose');
// 连接数据库
// 在mongodb不需要显式的创建数据库,但数据库不存在,mongodb会自动创建
mongoose.connect('mongodb://localhost/playground', {
        useUnifiedTopology: true,
        useNewUrlParser: true
    }).then(() => console.log('数据库连接成功'))
    .catch((err) => console.log(err, '数据库连接错误'))

创建集合以及文档

要想创建集合需要先创建集合规则,然后使用集合规则来创建集合

// 创建集合以及文档
const mongoose = require('mongoose');

mongoose.connect('mongodb://localhost/playground', {
        useNewUrlParser: true,
        useUnifiedTopology: true
    })
    .then(() => {
        console.log('连接数据库成功');
    }).catch((err) => {
        console.log(err, '连接数据库错误');
    })

// 创建集合规则
const courseSchema = new mongoose.Schema({
    name: String,
    author: String,
    isPublished: Boolean
})

// 使用规则创建集合
// 1. 集合名称
// 2. 集合规则
// 返回一个构造函数, 这个构造函数就代表这个集合
const Course = mongoose.model('Course', courseSchema);

// 创建文档
// 创建一个集合构造函数的实列,
const course = new Course({
    name: 'node.js基础',
    author: '黑马',
    isPublished: true
})
// 调用实列对象的sava方法保存
course.save();

向集合中插入文档的另外一种方式

可以使用集合对象的 create 方法来插入文档

const mongoose = require('mongoose');

mongoose.connect('mongodb://localhost/playground', {
        useNewUrlParser: true,
        useUnifiedTopology: true
    })
    .then(() => {
        console.log('连接数据库成功');
    }).catch((err) => {
        console.log(err, '连接数据库错误');
    })

// 创建集合规格
const courseSchema = new mongoose.Schema({
    name: String,
    author: String,
    isPublished: Boolean
})

const Course = mongoose.model('Course', courseSchema);

Course.create({
        name: 'Java',
    }).then(result => console.log(result))
    .catch(err => console.log(err))

查询文档

const mongoose = require('mongoose');
// 连接数据库
mongoose.connect('mongodb://localhost/playground', {
        useNewUrlParser: true,
        useUnifiedTopology: true
    })
    .then(() => {
        console.log('导入数据成功');
    }).catch(err => {
        console.log(err, '数据库导入失败');
    })

// 创建集合规则
const userSchema = new mongoose.Schema({
    name: String,
    age: Number,
    email: String,
    password: String,
    hobbies: [String]
})

// 使用集合规则创建集合
const User = mongoose.model('User', userSchema);

// 查询用户集合中的所有文档
User.find().then(result => console.log(result));

// 通过 _id 字段查询
User.find({
    _id: '5c09f267aeb04b22f8460968'
}).then(result => console.log(result))

// findOne 方法返回一条文档,默认返回当前集合第一条文档
User.findOne({
    age: 10
}).then(result => console.log(result))

//  查找 age大于 20 小于 40的所有文档
User.find({
    age: {
        $gt: 20,
        $lt: 40
    }
}).then(result => console.log(result))

// 查找 hobbies 中包含 '足球' 文档
User.find({hobbies:{$in:['足球']}}).then(result=>console.log(result))

// 选择要查询的字段, 如果不想查询某个字段可以在字段的前面加上 -
User.find().select('name email -_id').then(result => console.log(result))

// 根据 age 字段进行升序排列
User.find().sort('age').then(result => console.log(result))
// 根据 age 字段进行降序排列
User.find().sort('-age').then(result => console.log(result))

// skip() 跳过多少条数据
// limit()  限制查询数量
User.find().skip(2).limit(3).then(result => console.log(result))

删除文档

// 导入 mongoose 模块
const mongoose = require('mongoose');
// 连接数据库
mongoose.connect('mongodb://localhost/playground', {
        useNewUrlParser: true,
        useUnifiedTopology: true
    })
    .then(() => {
        console.log('连接数据库成功');
    }).catch(err => {
        console.log(err, '数据库导入失败');
    })

// 创建集合规则
const userSchema = new mongoose.Schema({
    name: String,
    age: Number,
    email: String,
    password: String,
    hobbies: [String]
})

// 使用集合规则创建集合
const User = mongoose.model('User', userSchema);

// 删除单个
User.findOneAndDelete({
    name: '张三'
}).then(result => console.log(result))

// 删除多个文档, 如果没有查询条件,就会删除全部
User.deleteMany({}).then(result=>console.log(result))

更新文档

const mongoose = require('mongoose');
// 连接数据库
mongoose.connect('mongodb://localhost/playground', {
        useNewUrlParser: true,
        useUnifiedTopology: true
    })
    .then(() => {
        console.log('连接数据库成功');
    }).catch(err => {
        console.log(err, '数据库导入失败');
    })

// 创建集合规则
const userSchema = new mongoose.Schema({
    name: String,
    age: Number,
    email: String,
    password: String,
    hobbies: [String]
})

// 使用集合规则创建集合
const User = mongoose.model('User', userSchema);

// 更新集合中的单个文档 updateOne({查询条件}, {要求修改的值})
User.updateOne({name:'张三'}, {name:'张三updata'}).then(result=>console.log(result))

// 更新集合中的多个文档
User.updateMany({}, {
    age: 56
}).then(result => console.log(result))

mongoose 验证

/**
 * required: true 必传字段
 * minlength 最小长度
 * maxlength 最大长度
 * trim 去除首尾空格
 * min 数字的最小范围
 * max 数字的最大范围
 * default 默认值
 * enum 枚举,列出当前字段可以拥有的值
 */

const mongoose = require('mongoose');
// 连接数据库
mongoose.connect('mongodb://localhost/playground', {
        useNewUrlParser: true,
        useUnifiedTopology: true
    })
    .then(() => {
        console.log('连接数据库成功');
    }).catch(err => {
        console.log(err, '数据库导入失败');
    })

const postSchema = new mongoose.Schema({
    title: {
        type: String,
        // 属性值传入一个列表, 列表的第二项为错误提示
        required: [true, '请传入文章标题'],
        minlength: 2,
        maxlength: 6,
        trim: true,
    },
    age: {
        type: Number,
        min: 18,
        max: 100,
    },
    publishDate: {
        type: Date,
        default: Date.now,
    },
    category: {
        type: String,
        // enum 类型的设置方法
        enum: {
            values : ['html', 'css', 'js'],
            message : '分类名称要在范围内'
        }
    },
    author: {
        type: String,
        // 自定义验证器
        validate: {
            validator: (v) => {
                // 返回布尔值, 成功返回 true, 否则返回 false
                return v.trim.lenght > 4
            },
            // 自定义错误信息
            message: "不符合"
        }
    }
})

const Post = mongoose.model('Post', postSchema)

Post.create({
        title: '     111            ',
        age: 60,
        category: 'java',
        author: '   123      '
    }).then(result => console.log(result))
    .catch(error => {
        // 获取错误信息对象
        let errList = error.errors;
        // 循环错误信息对象
        for (let attr in errList) {
            // 将错误信息打印到控制台中
            console.log(errList[attr]['message']);
        }
    })

集合关联

const mongoose = require('mongoose');
// 连接数据库
mongoose.connect('mongodb://localhost/playground', {
        useNewUrlParser: true,
        useUnifiedTopology: true
    })
    .then(() => {
        console.log('连接数据库成功');
    }).catch(err => {
        console.log(err, '数据库导入失败');
    })

// 用户集合规则
const userSchema = new mongoose.Schema({
    name: {
        type: String,
        required: true
    }
});

// 文章集合规则
const postSchema = new mongoose.Schema({
    title: {
        type: String
    },
    author: {
        // 文章集合和用户集合关联 type:mongoose.Schema.Types.ObjectId, ref:'User'
        type: mongoose.Schema.Types.ObjectId,
        ref: 'User'
    }
})

// 创建用户集合
const User = mongoose.model('User', userSchema);

// 创建文章集合
const Post = mongoose.model('Post', postSchema);

// 创建用户
// User.create({
//     name: 'xiaowen1'
// }).then(result => console.log(result))

// 创建文章
// Post.create({
//     title : 'post1',
//     author:'5db4054eefe45d807c8b435e'
// }).then(result=>console.log(result))

// 关联查询 => populate
Post.find().populate('author').then(result => console.log(result))

相关文章

网友评论

      本文标题:05-Node.js 操作 MongoDB 数据库

      本文链接:https://www.haomeiwen.com/subject/mqkbvctx.html