NodeJs中數據庫的使用


另一遍通用的NODEJS數據庫方法koa,express,node 通用方法連接MySQL

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" }

原文地址:https://segmentfault.com/a/1190000014999527


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM