nodejs mysql 耗硬盘_nodejs操作MySQL其实很简单
本文概要
講述了"如何回家取醬油瓶"跟連接數據庫的關聯.
2.使用sequelize.js (一個傳說中的ORM技術：Object-Relational Mapping，能把關系數據庫的表結構映射到對象上。) 對數據庫進行簡單的增刪減查.
如果你需要出去打醬油,但是忘記帶醬油瓶,想回家去取.
1-如何回家.jpg
那么粗略地描述一下流程就是 ,
1.買車票\機票\自駕\走路 ----->回到家門口 ( 找到目的地 )
2.掏出鑰匙\叫家里人----->開門 (通過身份驗證)
3.拿到醬油瓶 (取到數據)
2-連接數據庫.jpg
那么如何使用node.js來連接?
首先當然要導入相應的mysql提供的數據庫驅動包,然后按照連接所需要的參數進行連接.
3-js連接數據庫.jpg
那么這些參數有哪些呢?
host：主機地址 (默認：localhost)
user：用戶名
password：密碼
port：端口號 (默認：3306)
database：數據庫名
charset：連接字符集(默認：'UTF8_GENERAL_CI'，注意字符集的字母都要大寫)
localAddress：此IP用于TCP連接(可選)
socketPath：連接到unix域路徑，當使用 host 和 port 時會被忽略
timezone：時區(默認：'local')
connectTimeout：連接超時(默認：不限制；單位：毫秒)
stringifyObjects：是否序列化對象(默認：'false' ；與安全相關https://github.com/felixge/node-mysql/issues/501)
typeCast：是否將列值轉化為本地JavaScript類型值 (默認：true)
queryFormat：自定義query語句格式化方法 https://github.com/felixge/node-mysql#custom-format
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：用于修改連接標志，更多詳情：https://github.com/felixge/node-mysql#connection-flags
ssl：使用ssl參數(與crypto.createCredenitals參數格式一至)或一個包含ssl配置文件名稱的字符串，目前只捆綁Amazon RDS的配置文件
是不是又長又多??
淡定點,大多數情況下,我們只要設置幾個基礎的值就能夠進行連接了
// 'use strict';
var mysql = require('mysql');
var connection=mysql.createConnection({
//Options
host:'localhost',
user:'root',
password:'root',
database:'testapp'
});
connection.connect();
或者把設置的參數抽出來會更直觀一點:
var mysql = require('mysql');
var db_config={
//Options
host:'localhost',
user:'root',
password:'root',
database:'testapp'
};
var connection=mysql.createConnection(db_config);
利用connection.connect()的回調函數添加重連功能:
function handleDisconnect(){
connection.connect(function (err) {
// callback(err,result);
if(err){
console.log(err);
console.log("try to connect");
setTimeout(handleDisconnect,1000); //經過1秒后嘗試重新連接
return;
}
console.log("Success");
});
}
handleDisconnect();
查詢語句:
var userAddSql= "INSERT INTO user(id,name,sex,age) VALUES(?,?,?,?)";
var userAddSql_Params=['413','just','man','9'];
var showuser="SELECT * FROM user";
var deleteuserSql="DELETE FROM user WHERE name='hehe'"
//調用查詢方法
connection.query(userAddSql,userAddSql_Params,function(err,result){
if(err) throw err;
console.log('show result:',result);
console.log('show result:',result.affectedRows);
});
Tips: 為了防止SQL注入,經由用戶傳來的數值,一定要經過檢驗,并且慎重使用拼接此數值進行構造的查詢語句.
結束連接:
connection.end();
//另一個結束方法
//比較暴力，沒有回調函數，立刻執行
//connection.destory();
但是每次都要經過長長的一串SQL語句來控制,真的是心塞啊
接下來祭出神器 EX咖喱棒 Sequelize.js
它是什么 , 我們暫時先不管 , 它能干嘛才是我們最先關注的.
show time.
前提:
我們的數據庫在這里使用老牌的MySQL,
為了方便,我先使用MySQL 的Workbench先建立這樣的一個數據庫:
image.png
回到代碼,用sequelize建立對數據庫的連接:
①返璞歸真:
事無巨細,按部就班
const Sequelize = require('sequelize');
const config = {
database: 'webdb',
username: 'root',
password: 'root',
host: 'localhost',
port: 3306
};
var sequelize = new Sequelize(config.database, config.username, config.password, {
host: config.host,
dialect: 'mysql',
pool: {
max: 5,
min: 0,
idle: 30000
},
timestamps: false
//最好關掉timestamps , 框架自動幫你添加時間到UpdatedAt上邊
});
②一刀制敵:
簡單粗暴直接,很爽.
用uri的方式進行連接 :new Sequelize(uri, [options={}])
// 使用Uri連接
var sequelize = new Sequelize('mysql://root:root@localhost:3306/webdb');
驗證連接
sequelize
.authenticate()
.then(() => {
console.log('Connection has been established successfully.');
})
.catch(err => {
console.error('Unable to connect to the database:', err);
});
在進行增刪減查之前
你需要進行sequelize.define() - 模型定義
先來看看這個例子:
image.png
是不是跟之前定義的Table:Pets一樣?
有沒有注意到 , 代碼中定義的是pet , 表名 是 pets .
這里沒有寫錯,這是因為 sequelize 默認會給你定義的model后邊添加上s;
如果你覺得這樣很膩歪,就不能直接點?
答案是可以的,只要給添上 freezeTableName:true即可:
image.png
接下來,就是正主了
增加一只狗
var now = Date.now();
makedog = async() => {
var dog = await Pet.create({
id: now,
name: 'async大法好',
gender: false,
birth: '2001-01-01',
createdAt: now,
updatedAt: now,
version: 0
});
console.log('created:' + JSON.stringify(dog));
};
makedog();
刪掉version:0的狗
deletedog = async() => {
var deldog = await Pet.findAll({
where: {
version: 0
}
});
for (let o of deldog) {
await o.destroy();
}
}
deletedog();
修改version:0的狗
editdog = async() => {
var needEditdogs = await Pet.findAll({
where: {
version: 0
}
});
for (let needEditdog of needEditdogs) {
needEditdog.gender = true;
needEditdog.updatedAt = Date.now();
needEditdog.version++;
await needEditdog.save();
}
}
editdog();
找Id以15兩位數字開頭的狗:
//為了使用復雜一些的查詢,如模糊查詢等,需要引入Operator
const Op = Sequelize.Op;
finddogbyid = async(id) => {
var targetdogs = await Pet.findAll({
where: {
id: {
[Op.like]: id + '%'
}
}
});
for (let o of targetdogs) {
console.log('Target:' + JSON.stringify(o));
}
return targetdogs;
}
finddogbyid(15);
如果你覺得用不慣,或者覺得這種Operator太麻煩,也可以使用 sequelize.query(sql, [options={}]) -> Promise
來執行原始的SQL語句進行查詢.
默認情況下，返回值中有兩個參數：一個包含結果的數組，一個元數據對象。
可以通過.spread方法來查看結果。
關于async和await
談到這里還應該說到callback ,callback hell , Promise , async/await , ,不過有點偏離主題,先挖個坑吧,看看什么時候填.
總結
以上是生活随笔為你收集整理的nodejs mysql 耗硬盘_nodejs操作MySQL其实很简单的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 谈一谈游戏AI - 行为树
- 下一篇： linux cmake编译源码,linu