我的代码：
var express = require('express');
var app = express();
var swig = require('swig'); //加载模版
var MongoClient = require('mongoose');
app.engine('html',swig.renderFile); //定义模版引擎，第一个参数是模版引擎名称，同时也是模版文件的后缀，使用swig.renderFile方法解析后缀威html的文件
app.set('views','./views'); //设置模版存放目录，第一个参数必须是views,第二个参数是目录
app.set('view engine','html'); //注册模版引擎,第一个参数必须是view engine,第二个参数和app.engine中定义的模版引擎的名称是一致的(第一个参数)
swig.setDefaults({cache: false}); //在开发过程中，需要取消模版默认缓存
app.get('/viewOne',function (req,res) { // /map.html表示在地址栏输入http://localhost:4000/map.html的意思，然后返回html文件夹下的map.html文件显示
/*
* 读取views文件夹下的指定文件，解析并返回给客户端
* 第一个参数：指定的文件，相对于views目录 views/viewOne.html ，第二个参数{name:'xiao'}传递给viewOne页面，在viewOne页面可以这样取{{name}} ，如果有第三个参数则res.sendFile(__dirname + '/views/viewTwo.html')或者res.render("文案");
* */
res.render('viewOne',{name: 'xiao'},function (err,html) {
//console.log(html); //html是viewOne文件里的内容
/*res.sendFile(__dirname + '/views/viewTwo.html');*/
res.send(html); //html是viewOne.html
});
})
app.get('/viewTwo',function (req,res) { // /map.html表示在地址栏输入http://localhost:4000/map.html的意思，然后返回html文件夹下的map.html文件显示
res.render('viewTwo');
})
//app.use('/admin',require('./routers/admin')); //app.use加载用于处理http請求的middleware（中间件），当一个请求来的时候，会依次被这些 middlewares处理,在这里middlewares就是admin.js
//app.use('/api',require('./routers/api'));
//app.use('/',require('./routers/main'));
MongoClient.connect('mongodb://localhost:27017/node数据库',{ useNewUrlParser: true },function (err,db) {
console.log('test')
});
var Schema = MongoClient.Schema; //创建一个Schema模型骨架，并且设置好user模版
var userSchema = new Schema({
firstName:{type:String},
lastName:{type:String}
});
var User = MongoClient.model("User",userSchema); //Schema发布一个User的Model
app.get('/regist',function (req,res) { //处理regist的get请求
console.log('请求成功')
//console.log(req.query.first_name)
var user_1 = new User({
firstName: req.query.first_name,
lastName: req.query.last_name
});
//存储数据
user_1.save(function (err) {
if(err){
res.end('Error');
return next();
}
});
//查询数据 find({})意为返回所有文档
User.find({"firstName":"rr"}, function (err, results) { //find({"firstName":"rr"} 查询指定条件的数据
if(err){
res.end('Error');
return next();
}
//console.log(results) //"9"
//res.json(results);//以json数据类型返回值 返回到进行请求的页面 results是数据库存储的所有数据
});
//插入数据
let data = {"firstName":'gg',"lastName":'gejin'};
User.create(data,function (err,res) {
if(err){
res.end('Error');
return next();
}
});
let whereStr = {"firstName":"方法f"};
let updateStr = {$set:{"lastName":"数据修改2"}};
User.updateOne(whereStr,updateStr,function (err,res) {
if (err) {
console.log('加入购物车失败：' + err);
return
} else {
// add
console.log("修改成功")
}
});
});
var db = MongoClient.connection;
db.on('open',function () {
console.log('MongoDB链接成功')
})
db.on('error',function () {
console.log('MongoDB连接失败');
})
app.listen(4000,function () {
console.log("连接上了")
})
转载的：https://segmentfault.com/a/1190000008387379
安装MongoDB
设置环境变量
将mongodb 的 安装目录的 E:\Program Files\MongoDB\Server\3.4\bin 写入环境变量
启动服务
控制台 输入 mongodb --dbpath E:\MongoDB\data 这后面的路径便是数据集合的路径
服务启动成功提示
[图片上传失败...(image-9e81d5-1539686012843)]
MongoDB监听的是27017端口，打开浏览器输入http://127.0.0.1:27017，则会看到如下提示：
It looks like you are trying to access MongoDB over HTTP on the native driver port.
如果嫌每次输入命令打开服务麻烦的话可以 写成一个批处理文件 .bat 文件， 写上代码
start mongod --dbpath E:\MongoDB\data
安装模块
npm install mongoose --save
使用MongoDB
连接
在app.js 文件中
// app.js
var mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/blog') //连接本地数据库blog
var db = mongoose.connection;
// 连接成功
db.on('open', function(){
console.log('MongoDB Connection Successed');
});
// 连接失败
db.on('error', function(){
console.log('MongoDB Connection Error');
});
连接成功后接下来写一个 登录注册
添加登录注册页面
在views模块下添加 login.html 和register.html
<!-- login.html -->
<h1>登录页面</h1>
<div>
<form action="/login" method="post">
<p>
<label for="username">用户名</label>
<input type="text" id="username" name="username" placeholder="用户名">
</p>
<p>
<label for="password">密码 : </label>
<input type="text" id="password" name="password" placeholder="密码">
</p>
<p>
<input type="submit" value="登录">
</p>
</form>
</div>
<!-- register.html -->
<h1>注册页面</h1>
<a href="/login"> 去登录 </a>
<div>
<form action="/register" method="post">
<p>
<label for="username">用户名</label>
<input type="text" id="username" name="username" placeholder="用户名">
</p>
<p>
<label for="password">密码 :</label>
<input type="text" id="password" name="password" placeholder="密码">
</p>
<p>
<label for="age">年龄 :</label>
<input type="text" id="age" name="age" placeholder="年龄">
</p>
<p>
<label for="address">地址 :</label>
<input type="text" id="address" name="address" placeholder="地址">
</p>
<p>
<input type="submit" value="注册">
</p>
</form>
</div>
新增Models 模块
在根路径下新建 Models 文件夹。 添加 users.js
// Models/users.js
var mongoose = require('mongoose');
var Schema = mongoose.Schema;
// 声明一个数据集 对象
var userSchema = new Schema({
username: {
type: String,
unique: true
},
password: {
type: String
},
age: Number,
address: String,
createAt: {
type: Date,
default : Date.now()
}
});
// 将数据模型暴露出去
module.exports = mongoose.model('users', userSchema);
编写路由
// routes/index.js
var express = require('express');
var router = express.Router();
var User = require('../models/users');
router.get('/login', function (req, res) {
res.render('login');
});
router.get('/register', function (req, res) {
res.render('register');
});
// 这里的业务逻辑将写在 两个post 路由里
router.post('/login', function (req, res) {
});
router.post('/register', function (req, res) {
});
这里我们需要安装一个模块 body-parser 用来解析post请求的参数
npm install body-parser --save
// app.js
var bodyParser = require('body-parser')
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false}));
这样我们就可以通过 request.body 来拿到post 请求过来的 数据了
先写一个注册的
// routes/index.js
router.post('/register', function (req, res) {
// 获取用户提交的信息
var postData = {
username: req.body.username,
password: req.body.password,
age: req.body.age,
address: req.body.address
};
// 查询是否被注册
User.findOne({username: postData.username}, function (err, data) {
if (data) {
res.send('用户名已被注册');
} else {
// 保存到数据库
User.create(postData, function (err, data) {
if (err) throw err;
console.log('注册成功');
res.redirect('/userList'); // 重定向到所用用户列表
})
}
});
});
// 获取所有用户列表
router.get('/userList', function (req, res) {
var userList = User.find({}, function (err, data) {
if (err) throw err;
res.send(data)
});
});
上面通过 mongoose 的 api 对数据库进行操作
Mongoose Api
然后就是验证登录的了
router.post('/login', function (req, res) {
var postData = {
username: req.body.username,
password: req.body.password
};
User.findOne({
username: postData.username,
password: postData.password
}, function (err, data) {
if(err) throw err;
if(data){
res.send('登录成功');
}else{
res.send('账号或密码错误')
}
} )
});
到这里就基本完成了 Express 对Mongodb 的连接，插入，查询。
ps : 参考文档 Mongoose Api
网友评论