--- title: 07-Node.js操作MySQL数据库 publish: true --- ## 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://img.smyhvae.com/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)); } }); ```