Web/11-Node.js和模块化/06-Node.js操作MySQL数据库.md
2020-04-18 20:45:41 +08:00

328 lines
7.8 KiB
Markdown
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

## Node.js 连接 MySQL
1安装 mysql 包:
```bash
$ npm install mysql
```
2引入 mysql 包:
```js
const mysql = require("mysql");
```
3建立连接
```js
let mysql = require("mysql");
let options = {
host: "localhost",
//port:"3306", //可选默认3306
user: "root",
password: 'xxx', // 这里改成你自己的数据库连接密码
database: "qiangu_database",
};
//创建与数据库进行连接的连接对象
let connection = mysql.createConnection(options);
//建立连接
connection.connect((err) => {
if (err) {
// 数据库连接成功
console.log(err);
} else {
// 数据库连接失败
console.log("数据库连接成功");
}
});
```
正常来说,运行程序后,应该会提示`数据库连接成功`。
如果在运行时提示错误`Client does not support authentication protocol requested by server`,解决办法如下:(在终端进入 sql 之后,输入如下命令)
```sql
# 注意,这里的 'root' 请填你的user账号 'localhost' 请填 你的 host 'password' 请填你的密码
ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY 'password';
# 然后执行如下命令
flush privileges;
```
## Node.js 增删改查 MySQL
针对下面这张表:
![](https://github.com/qianguyihao/Web/blob/master/img/20200418_1728.png)
通过 Node.js可以对其进行一些增删改查操作。代码举例如下。
### 1、查询表
```js
let mysql = require('mysql');
let options = {
host: 'localhost',
//port:"3306",//可选默认3306
user: 'root',
password: 'xxx', // 这里改成你自己的数据库密码
database: 'qiangu_database'
}
//创建与数据库进行连接的连接对象
let connection = mysql.createConnection(options);
//建立连接
connection.connect((err) => {
if (err) {
// 数据库连接成功
console.log(err)
} else {
// 数据库连接失败
console.log('数据库连接成功')
}
});
// 1、查询表
let strSql1 = 'select * from qiangu_student_table';
connection.query(strSql1, (err, result, fields) => {
if (err) {
// 表查询失败
console.log(err);
} else {
// 表查询成功
console.log('qiangu_student_table 表查询结果:' + JSON.stringify(result));
console.log('fields:' + JSON.stringify(fields));
}
})
```
打印结果如下:
```bash
qiangu_student_table 表查询结果:
[{"id":1,"name":"千古壹号","age":28},{"id":2,"name":"许嵩","age":34},{"id":3,"name":"邓紫棋","age":28}]
fields:[
{"catalog":"def","db":"qiangu_database","table":"qiangu_student_table","orgTable":"qiangu_student_table","name":"id","orgName":"id","charsetNr":63,"length":11,"type":3,"flags":0,"decimals":0,"zeroFill":false,"protocol41":true},
{"catalog":"def","db":"qiangu_database","table":"qiangu_student_table","orgTable":"qiangu_student_table","name":"name","orgName":"name","charsetNr":33,"length":765,"type":253,"flags":0,"decimals":0,"zeroFill":false,"protocol41":true},
{"catalog":"def","db":"qiangu_database","table":"qiangu_student_table","orgTable":"qiangu_student_table","name":"age","orgName":"age","charsetNr":63,"length":11,"type":3,"flags":0,"decimals":0,"zeroFill":false,"protocol41":true}
]
```
### 删除表
```js
// 2、删除表
let strSql2 = 'drop table test2_table';
connection.query(strSql2, (err, result) => {
if (err) {
// 表删除失败
console.log(err);
} else {
// 表删除成功
console.log('表删除成功:' + result);
}
});
```
打印结果:
```bash
表删除成功:
OkPacket {
fieldCount: 0,
affectedRows: 0,
insertId: 0,
serverStatus: 2,
warningCount: 0,
message: '',
protocol41: true,
changedRows: 0
}
```
### 删除数据库
将上方的sql语句换一下即可
```sql
let strSql3 = 'drop database qiangu_database';
```
### 2、新建数据库
```js
let mysql = require('mysql');
let options = {
host: 'localhost',
//port:"3306",//可选默认3306
user: 'root',
password: 'smyhvae001',
// database: 'qiangu_database' // 注意,因为代码里是创建新的数据库,所以这里不需要填其他的数据库名
}
//创建与数据库进行连接的连接对象
let connection = mysql.createConnection(options);
//建立连接
connection.connect((err) => {
if (err) {
// 数据库连接成功
console.log(err);
} else {
// 数据库连接失败
console.log('数据库连接成功')
}
});
// 创建新的数据库
const strSql4 = 'create database qiangu_database3';
connection.query(strSql4, (err, result) => {
if (err) {
console.log(err);
} else {
console.log('新建数据库成功:' + JSON.stringify(result));
}
});
```
打印结果:
```bash
数据库连接成功
新建数据库成功:{
"fieldCount":0,"affectedRows":1,"insertId":0,"serverStatus":2,"warningCount":0,"message":"","protocol41":true,"changedRows":0
}
```
### 3、新建表
新建表的sql语句举例
```sql
CREATE TABLE `qiangu_table5` (
`id` int NOT NULL AUTO_INCREMENT,
`name` varchar(255) DEFAULT NULL,
`age` int DEFAULT NULL,
PRIMARY KEY (`id`)
);
```
如果是在 js 代码中执行上面这样命令的话,要记得把 sql 语句存放在字符串里的同一行。
代码举例如下:
```js
let mysql = require('mysql');
let options = {
host: 'localhost',
//port:"3306",//可选默认3306
user: 'root',
password: 'smyhvae001',
database: 'qiangu_database'
}
//创建与数据库进行连接的连接对象
let connection = mysql.createConnection(options);
//建立连接
connection.connect((err) => {
if (err) {
// 数据库连接成功
console.log(err);
} else {
// 数据库连接失败
console.log('数据库连接成功')
}
});
// 新建表
// 注意,在 js 代码中sql 语句要存放在字符串里的同一行。
const strSql5 = 'CREATE TABLE `qianguyihao_table5` (`id` int NOT NULL AUTO_INCREMENT,`name` varchar(255) DEFAULT NULL,`age` int DEFAULT NULL,PRIMARY KEY (`id`));';
connection.query(strSql5, (err, result) => {
if (err) {
// 新建表失败
console.log(err);
} else {
// 新建表成功
console.log('qianguyihao 新建表成功:' + JSON.stringify(result));
}
})
```
打印结果:
```bash
数据库连接成功
qianguyihao 新建表成功:
{
"fieldCount":0,"affectedRows":0,"insertId":0,"serverStatus":2,"warningCount":0,"message":"","protocol41":true,"changedRows":0
}
```
### 在指定的表中插入数据
在指定的表中插入数据:
```js
// 在指定的表中插入数据
const strSql6 = "insert into qianguyihao_table5 (name, age) values ('千古壹号', '28')";
connection.query(strSql6, (err, result) => {
if (err) {
// 插入数据失败
console.log(err);
} else {
// 在指定的表中插入数据成功
console.log('qianguyihao 在指定的表中插入数据成功:' + JSON.stringify(result));
}
});
```
打印结果:
```bash
qianguyihao 在指定的表中插入数据成功:
{
"fieldCount":0,"affectedRows":1,"insertId":1,"serverStatus":2,"warningCount":0,"message":"","protocol41":true,"changedRows":0
}
```
如果插入的数据是变量比如是用户提交上来的数据那么sql 语句可以这样写:
```js
// 在指定的表中插入数据(数据作为变量)
const strSql7 = "insert into qianguyihao_table5 (name, age) values (?, ?)";
connection.query(strSql7, ['许嵩', '34'], (err, result) => {
if (err) {
// 插入数据失败
console.log(err);
} else {
// 在指定的表中插入数据成功
console.log('qiangauyihao 在指定的表中插入数据成功:' + JSON.stringify(result));
}
});
```