另一遍通用的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" }