NodeJs中數據庫的使用

1.Node.js 鏈接 MySQL

$ cnpm install mysql

鏈接mysql:

var mysql      = require('mysql');

var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '123456',
  database : 'test'
});

connection.connect();
 
connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
  if (error) throw error;
  console.log('The solution is: ', results[0].solution);
});

數據庫鏈接參數說明

參數 描述
host 主機地址 （默認：localhost）

user 用戶名

password 密碼

port 端口號 （默認：3306）

database  數據庫名

charset  鏈接字符集（默認：'UTF8_GENERAL_CI'，注意字符集的字母都要大寫）

localAddress  此IP用於TCP鏈接（可選）

socketPath  鏈接到unix域路徑，當使用 host 和 port 時會被忽略

timezone  時區（默認：'local'）

connectTimeout 鏈接超時（默認：不限制；單位：毫秒）

stringifyObjects 是否序列化對象

typeCast  是否將列值轉化爲本地JavaScript類型值 （默認：true）

queryFormat  自定義query語句格式化方法

supportBigNumbers  數據庫支持bigint或decimal類型列時，須要設此option爲true （默認：false）bigNumberStrings supportBigNumbers和bigNumberStrings啓用 強制bigint或decimal列以JavaScript字符串類型返回（默認：false）

dateStrings  強制timestamp,datetime,data類型以字符串類型返回，而不是JavaScript Date類型（默認：false）

debug  開啓調試（默認：false）

multipleStatements 是否許一個query中有多個MySQL語句 （默認：false）

flags 用於修改鏈接標誌

ssl  使用ssl參數（與crypto.createCredenitals參數格式一至）或一個包含ssl配置文件名稱的字符串，目前只捆綁Amazon RDS的配置文件

---

2.Node.js 鏈接 MongoDB：

MongoDB是一種文檔導向數據庫管理系統，由C++撰寫而成。MongoDB 教程。 安裝驅動

$ cnpm install mongodb

增刪改查

---

要在 MongoDB 中建立一個數據庫，首先咱們須要建立一個 MongoClient 對象，而後配置好指定的 URL 和 端口號。
若是數據庫不存在，MongoDB 將建立數據庫並創建鏈接。

建立鏈接

var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/mydb";
 
MongoClient.connect(url, function(err, db) {
  if (err) throw err;
  console.log("數據庫已建立!");
  db.close();
});

---

建立集合

咱們能夠使用 createCollection() 方法來建立集合： 建立集合

var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/mydb';
MongoClient.connect(url, function (err, db) {
    if (err) throw err;
    console.log('數據庫已建立');
    var dbase = db.db("mydb");
    dbase.createCollection('runoob', function (err, res) {
        if (err) throw err;
        console.log("建立集合!");
        db.close();
    });
});

---

數據庫操做( CURD )

與 MySQL 不一樣的是 MongoDB 會自動建立數據庫和集合，因此使用前咱們不須要手動去建立。 插入數據 如下實例咱們鏈接數據庫

runoob 的 site 表，並插入兩條數據：

插入數據

var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/runoob'; # 數據庫爲 runoob
 
var insertData = function(db, callback) {  
    //鏈接到表 site
    var collection = db.collection('site');
    //插入數據
    var data = [{"name":"菜鳥教程","url":"www.runoob.com"},{"name":"菜鳥工具","url":"c.runoob.com"}];
    collection.insert(data, function(err, result) { 
        if(err)
        {
            console.log('Error:'+ err);
            return;
        }     
        callback(result);
    });
}
 
MongoClient.connect(DB_CONN_STR, function(err, db) {
    console.log("鏈接成功！");
    insertData(db, function(result) {
        console.log(result);
        db.close();
    });
});

執行如下命令輸出就結果爲：

$ node test.js //鏈接成功！

{ result: { ok: 1, n: 2 },
  ops: 
   [ { name: '菜鳥教程',
       url: 'www.runoob.com',
       _id: 58c25e13a08de70d3b9d4116 },
     { name: '菜鳥工具',
       url: 'c.runoob.com',
       _id: 58c25e13a08de70d3b9d4117 } ],
  insertedCount: 2,
  insertedIds: [58c25e13a08de70d3b9d4116, 58c25e13a08de70d3b9d4117]
}

從輸出結果來看，數據已插入成功。

咱們也能夠打開 MongoDB 的客戶端查看數據，如：

show dbs

admin   0.000GB
local   0.000GB
runoob  0.000GB          # 自動建立了 runoob 數據庫

show tables
site                     # 自動建立了 site 集合（數據表）

db.site.find()         # 查看集合中的數據
{ "_id" : ObjectId("58c25f300cd56e0d7ddfc0c8"), "name" : "菜鳥教程", "url" : "www.runoob.com" }
{ "_id" : ObjectId("58c25f300cd56e0d7ddfc0c9"), "name" : "菜鳥工具", "url" : "c.runoob.com" }

查詢數據

如下實例檢索 name 爲 "菜鳥教程" 的實例：

var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/runoob';    
 
var selectData = function(db, callback) {  
  //鏈接到表  
  var collection = db.collection('site');
  //查詢數據
  var whereStr = {"name":'菜鳥教程'};
  collection.find(whereStr).toArray(function(err, result) {
    if(err)
    {
      console.log('Error:'+ err);
      return;
    }     
    callback(result);
  });
}
 
MongoClient.connect(DB_CONN_STR, function(err, db) {
  console.log("鏈接成功！");
  selectData(db, function(result) {
    console.log(result);
    db.close();
  });
});

執行如下命令輸出就結果爲：

鏈接成功！

[ { _id: 58c25f300cd56e0d7ddfc0c8,
    name: '菜鳥教程',
    url: 'www.runoob.com' } ]

更新數據

咱們也能夠對數據庫的數據進行修改，如下實例將 name 爲 "菜鳥教程" 的 url 改成 https://www.runoob.com：

var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/runoob';    
 
var updateData = function(db, callback) {  
    //鏈接到表  
    var collection = db.collection('site');
    //更新數據
    var whereStr = {"name":'菜鳥教程'};
    var updateStr = {$set: { "url" : "https://www.runoob.com" }};
    collection.update(whereStr,updateStr, function(err, result) {
        if(err)
        {
            console.log('Error:'+ err);
            return;
        }     
        callback(result);
    });
}
 
MongoClient.connect(DB_CONN_STR, function(err, db) {
    console.log("鏈接成功！");
    updateData(db, function(result) {
        console.log(result);
        db.close();
    });
});

執行成功後，進入 mongo 管理工具查看數據已修改：

db.site.find()
{ "_id" : ObjectId("58c25f300cd56e0d7ddfc0c8"), "name" : "菜鳥教程", "url" : "https://www.runoob.com" }
{ "_id" : ObjectId("58c25f300cd56e0d7ddfc0c9"), "name" : "菜鳥工具", "url" : "c.runoob.com" }

刪除數據

如下實例將 name 爲 "菜鳥工具" 的數據刪除 :

var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/runoob';    
 
var delData = function(db, callback) {  
  //鏈接到表  
  var collection = db.collection('site');
  //刪除數據
  var whereStr = {"name":'菜鳥工具'};
  collection.remove(whereStr, function(err, result) {
    if(err)
    {
      console.log('Error:'+ err);
      return;
    }     
    callback(result);
  });
}
 
MongoClient.connect(DB_CONN_STR, function(err, db) {
  console.log("鏈接成功！");
  delData(db, function(result) {
    console.log(result);
    db.close();
  });
});

執行成功後，進入 mongo 管理工具查看數據已刪除：

db.site.find()
{ "_id" : ObjectId("58c25f300cd56e0d7ddfc0c8"), "name" : "菜鳥教程", "url" : "https://www.runoob.com" }