本文概要

讲述了"如何回家取酱油瓶"跟连接数据库的关联.

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 , ,不过有点偏离主题,先挖个坑吧,看看什么时候填.