国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 開發 > JS > 正文

node鏈接mongodb數據庫的方法詳解【阿里云服務器環境ubuntu】

2024-05-06 16:48:49
字體:
來源:轉載
供稿:網友

本文實例講述了node鏈接mongodb數據庫的方法。分享給大家供大家參考,具體如下:

一、安裝2.6版本以上的mongodb在云服務器上(百度就能查到安裝方法,以及驗證是否安裝成功一般是mongodb –version);

二、因為mongodb的默認開啟端口是27017,所以要在Ubuntu上開啟這個端口:

ufw allow 27017
ufw enable
ufw reload
ufw status //這是查看這個端口是否開啟,iptables --list也可以查看

光在服務器開了端口還不行,還要在阿里云服務器控制臺的安全組中添加這個端口:

node,mongodb,數據庫

三、在node項目中利用npm安裝mongodb:

npm i mongodb --save

四、鏈接的具體代碼(前提是已經建立了簡單的http或者https服務),具體代碼:

const http = require('http')  , https = require('https');const express = require('express');const bodyParser = require('body-parser')const app = express();const fs = require('fs');const ejs = require('ejs');const path = require('path');const MongoClient = require('mongodb').MongoClient;// 返回信息const questions = {  code: 200,  msg: 'success',};// https證書,開https服務的自驗證證書const options = {  key: fs.readFileSync('./privatekey.pem'),  cert: fs.readFileSync('./certificate.pem')};let xltitle = '標題(初始化數據)',  xlcontent = '內容(初始化數據)',  xlfaceid = '1(初始化數據)';const url = 'mongodb://127.0.0.1/xlbase';// 默認端口27017,無需填寫// 也可以修改端口,vim /etc/mongodb.conf// 初始化數據庫MongoClient.connect(url, function (err, db) {  if (err) throw err;  let database = db.db('xlbase');  console.log('------------數據庫初始化成功------------');// 如果沒有face這個集合,會創建一個,所以可以用這個來初始化集合  database.createCollection('face', function (err, res) {    if (err) throw err;    console.log('------------集合初始化完畢------------');    db.close();  });});//設置跨域訪問app.all('*', function (req, res, next) {  res.header("Access-Control-Allow-Origin", "*");  res.header("Access-Control-Allow-Headers", "X-Requested-With");  res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS");  res.header("X-Powered-By", ' 3.2.1');  // res.header("Content-Type", "application/json;charset=utf-8");  next();});// parse application/x-www-form-urlencoded 解析app.use(bodyParser.urlencoded({extended: false}));// parse application/json 解析app.use(bodyParser.json());// view engine setup,視圖模版app.set('views', path.join(__dirname, './'));app.set('view engine', 'jade');// 靜態資源解析路徑(css,js,圖片等)app.use(express.static(path.join(__dirname, './static')));// 數據接收接口app.post('/info', function (req, res) {  res.header("Content-Type", "application/json;charset=utf-8");  res.status(200);  xltitle = req.body.title;  xlcontent = req.body.content;  xlfaceid = req.body.faceId;  let info = {    'faceid': xlfaceid,    'title': xltitle,    'content': xlcontent  };  let faceid = {    'faceid': xlfaceid  };  let updateInfo = {$set: info};// 組裝更新的信息  MongoClient.connect(url, function (err, db) {    let database = db.db('xlbase');    database.collection('face').find(faceid).toArray(function (err, result) {      if (err) throw err;      // 判斷集合中faceid和當前傳過來的faceid是否相同和存在      // 如果不存在就新插入這條數據      // 如果存在且相同,就更新數據      if (result.length !== 0 && result[0].faceid === xlfaceid) {        database.collection("face").updateOne(faceid, updateInfo, function (err, res) {          if (err) throw err;          console.log("------------數據更新成功------------");          db.close();        });      } else {        database.collection('face').insertOne(info, function (err, res) {          if (err) throw err;          console.log("------------數據添加成功------------");          db.close();        })      }    })  });  res.json(questions); // 返回信息  res.end(JSON.stringify(req.body, null, 2))});app.get('/index', function (req, res) {  res.status(200);  res.header("Content-Type", "text/html;charset=utf-8");// 根據faceId查詢數據  MongoClient.connect(url, function (err, db) {    if (err) throw err;    let dbo = db.db("xlbase");    let face = {"faceid": xlfaceid}; // 查詢條件    let xltitle1 = 404;    let xlcontent1 = '網頁出錯!';    dbo.collection("face").find(face).toArray(function (err, result) {      if (err) throw err;      console.log(result);      xltitle1 = result[0].title;      xlcontent1 = result[0].content;      db.close();      console.log('------------查詢完畢------------');      res.send('<h3 style="font-size: 35px">' + xltitle1 + '</h3>' +        '<pre style="white-space: pre-wrap;word-wrap: break-word;font-size: 30px">' + xlcontent1 + '</pre>');      res.end();    });  });})// 配置服務端口// http.createServer(app).listen(3001, function () {//   console.log('3001')// });process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0"; // 繞過證書驗證https.createServer(options, app).listen(8009, function () {  console.log('port: 8009');});// var server = app.listen(3001, function () {////   var host = server.address().address;////   var port = server.address().port;////   console.log('Example app listening at http://%s:%s', host, port);// })

希望本文所述對大家nodejs程序設計有所幫助。


注:相關教程知識閱讀請移步到JavaScript/Ajax教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 沭阳县| 句容市| 莱州市| 罗江县| 甘谷县| 上虞市| 青州市| 巧家县| 饶河县| 海盐县| 卫辉市| 象山县| 昌图县| 马关县| 南昌县| 洛川县| 丰城市| 金平| 梅河口市| 江阴市| 菏泽市| 沁源县| 丽江市| 青铜峡市| 溧阳市| 新密市| 拉萨市| 积石山| 元江| 石嘴山市| 曲水县| 江口县| 荆州市| 偃师市| 察隅县| 友谊县| 西城区| 武义县| 盖州市| 法库县| 微山县|