1，准备工作：
安装MySQL2 驱动（库名称为mysql2 ）：
npm install mysql2
2，编写js代码：
2-1，数据库 查询 数据js代码
const mysql = require(‘mysql2‘)
const connection = mysql.createConnection({
‘host‘: ‘127.0.0.1‘,
‘user‘: ‘mydb‘,
‘password‘: ‘mydb‘,
‘database‘: ‘testmydb‘
})
connection.connect()
//查询的SQL语句
var selSql = ‘SELECT * FROM bookinfo‘;
//查询操作
connection.query
(selSql, function (err, results, fields) {
if (err) throw err;
console.log(‘-------查询记录----------‘);
console.log(‘查询结果:‘, results);
// console.log(‘查询结果字段:‘, fields);
});
connection.end();
2-2，数据库 新增 数据js代码
// 数据 的插入；
const mysql = require(‘mysql2‘);
// 建立 连接
const connection = mysql.createConnection({
‘host‘: ‘127.0.0.1‘,
‘user‘: ‘mydb‘,
‘password‘: ‘mydb‘,
‘database‘: ‘testmydb‘
});
connection.connect();
//定义增加记录的SQL语句和参数
var addSql = ‘ INSERT INTO `bookinfo`(`isbn`, `name`, `author`, `press`, `price`, `pubdate`)VALUES(?,?,?,?,?,?)‘;
var addSql_Params = [‘9787115488488‘, ‘Node.js开发实战教程‘, ‘钟小平‘, ‘人民邮电出版社‘, 59.80, ‘2020-03-01‘];
//通过查询命令执行增加操作
connection.query(addSql, addSql_Params, function(err, results) {
if (err) throw err;
console.log(‘-------插入记录----------‘);
console.log(‘插入记录的ID:‘, results.insertId);
console.log(‘插入结果:‘, results);
});
connection.end();
2-3，数据库 更新 数据js代码
const mysql = require(‘mysql2‘)
const connection = mysql.createConnection({
‘host‘: ‘127.0.0.1‘,
‘user‘: ‘mydb‘,
‘password‘: ‘mydb‘,
‘database‘: ‘testmydb‘
})
connection.connect()
//定义修改记录的SQL语句和参数
var updateSql = ‘UPDATE bookinfo SET author = ?,price = ? WHERE id = ?‘;
var updateSql_Params = [‘向大大‘, 88.80, 13];
//通过查询命令执行修改操作
connection.query(updateSql, updateSql_Params, function(err, result) {
if (err) throw err;
console.log(‘-------修改记录----------‘);
console.log(‘修改所影响的行数:‘, result.affectedRows);
console.log(‘修改所改变的行数:‘, result.changedRows);
});
connection.end();
2-4，数据库 删除 数据js代码
const mysql = require(‘mysql2‘)
const connection = mysql.createConnection({
‘host‘: ‘127.0.0.1‘,
‘user‘: ‘mydb‘,
‘password‘: ‘mydb‘,
‘database‘: ‘testmydb‘
})
connection.connect()
//定义删除记录的SQL语句
var delSql = ‘DELETE FROM bookinfo WHERE id = 13‘;
//通过查询命令执行删除操作
connection.query(delSql, function(err, result) {
if (err) throw err;
console.log(‘-------删除记录----------‘);
console.log(‘删除的行数:‘, result.affectedRows);
});
connection.end();
3，运行结果截图
3-1，查询数据
3-2，新增数据
3-2-1，执行了查询操作
3-3，更新数据
3-3-1，执行了查询操作
3-4，删除数据
3-4-1，执行了查询操作
4，文件路径