从零开始优雅的使用mongodb实例

Posted 2020-09-29 tinyphp

基本连接

一、创建express工程testmon

express testmon

 

二、精简app.js

var express = require("express");
var app = express();
app.get(\'/\', function(req, res) { 
    res.send(\'访问一次增加一条数据\'); 
});


var server = app.listen(3000,function(){
    console.log("请在浏览器访问：http://localhost:3000");
});

 

三：进入工程目录安装mongoose并引入依赖：

npm install --save mongoose

四、修改app.js

var express = require("express");
var app = express();
app.get(\'/\', function(req, res) { 
res.send(\'Hello, tinyphp\'); 
});
var server = app.listen(3000,function(){
    console.log("请在浏览器访问：http://localhost:3000");
});


//引入mongoose模块
var mongoose = require(\'mongoose\');
//创建数据库连接
var db=mongoose.connect(\'mongodb://localhost:27017/test\');

//检查是否连接成功
db.connection.on("error",function(error){
    console.log("数据库连接失败："+error);
});

db.connection.on("open",function(error){
    console.log("++++++数据库连成功++++++");
});


/*****Schema使用*****/

//定义kitty属性
var kittySchema = mongoose.Schema({
    name: String  
});
//将该Schema发布为Model，第一个参数为集合名
var kittyModel = mongoose.model(\'kitty\', kittySchema);

//用module创建kitty实体
var kittyEntity = new kittyModel({ name: \'tinyphp99\' });

//保存数据
kittyEntity.save(function (err) {
  if (err) {
    console.log(err);
  } else {
    console.log(\'成功插入数据\');
  }
});
/************/

打开另外一个cmd窗口，先查询一次数据，然后重新启动工程，再查询一次数据发现数据成功添加上了

 

分离改造

下面我们把它改装为一访问http://localhost:3000/add就自动添加数据，思路

 

 

config.js 数据库配置信息

module.exports={
    mongodb:"mongodb://localhost:27017/test"
}

 

mongoose.js 数据库连接文件

//引入mongoose模块
var mongoose = require(\'mongoose\');
var config=require(\'./config.js\');

module.exports=function(){
    //创建数据库连接
var db=mongoose.connect(config.mongodb);
//检查是否连接成功
db.connection.on("error",function(error){
    console.log("数据库连接失败："+error);
});

db.connection.on("open",function(error){
    console.log("++++++数据库连成功++++++");
});
require(\'../models/kitty.model.js\');
return db;
}

 

kitty.model.js 导出Model用于生成实体

var mongoose =require(\'mongoose\');
/*****Schema使用*****/

//定义kitty属性
var kittySchema = mongoose.Schema({
    name: String  
});

mongoose.model(\'kitty\',kittySchema);

 

app.js

var express = require("express");

var mongoose = require(\'./config/mongoose.js\'); 
var db=mongoose();

var app = express();


var add=require(\'./routes/add\');
app.use(\'/add\',add);


var server = app.listen(3000,function(){
    console.log("请在浏览器访问：http://localhost:3000");
});

add.js 控制访问一次http://localhost:3000/add插入一次数据

var express = require(\'express\');
var router = express.Router();

var mongoose =require(\'mongoose\');
//将该Schema发布为Model，第一个参数为集合名
var kittyModel=mongoose.model(\'kitty\');

/* GET home page. */
router.get(\'/\', function(req, res, next) {
  res.send(\'又添加一条数据\');

//用module创建kitty实体
var kittyEntity = new kittyModel({ name: \'tom\' });

//保存数据
kittyEntity.save(function (err) {
  if (err) {
    console.log(err);
  } else {
    console.log(\'成功插入数据\');
  }
});

});



module.exports = router;

 

路由里因为用到kittyModel所以引入要在mongoose初始化后，不然会提示出错“Schema hasn\'t been registered ...”， 自己把上面的顺序调换测试下更深刻噢~

温馨提示：测试多了，不妨使用db.table.drop() 把整个集合删除掉噢

相关文章：

安装express并创建工程

window平台安装MongoDB

 

下载地址