• 思路。就是在nodejs中，因为我们的目的是客户端发出请求，nodejs服务端需要根据这个请求，返回json数据。也就是说，我们要在服务器端完成连接数据库的任务，获取数据库中的json类型的数据。所以首先处理nodejs连接mysql数据库的问题，接着是对数据库中的数据进行数据处理的问题，最后返回数据给客户端。

1. 安装mysql驱动（模块）

npm install mysql

2. nodejs连接mysql数据库

database.js中的代码

let mysql = require('mysql');

//创建连接
let connection = mysql.createConnection({
    host:'localhost',
    user:'root',
    password:'自己数据库的密码',
    database:'自己创建数据库的名称',
});

//连接数据库
connection.connect(function(err){
    if(err) {
        return console.log('err:'+err.message);
    }
    console.log('success!connect to local mysql');
});

• 问题：err:ER_NOT_SUPPORTED_AUTH_MODE: Client does not support authentication protocol requested by server; consider upgrading MySQL client
• 解决方案：
  1. 因为之前使用alter user 'root'@'localhost' identified by '用户密码';修改密码，这种加密方式是mysql8.X版本支持的默认方式，称为“caching_sha2_password”。但是nodejs中的mysql模块并不支持这种加密方式。
  2. 使用mysql模块支持“mysql_native_password”的加密方式，重新修改密码。
     alter user 'root'@'localhost' identified with mysql_native_password by '用户密码';

3. 将json类型的数据存储到数据库中，以及获取存储到数据库中的数据

processdata.js中的代码

let connect=require('./database');
//console.log(connect);
let fs =require('fs');
let path = require('path');

//插入数据到mysql
exports.insertData=function(){
    var fileurl=path.join(__dirname,'../db/goodlist.json');
    fs.readFile(fileurl,'utf-8',function(err,data){
        if(err){
            res.send('文件读取失败');
        }
        var json_data=JSON.parse(data).message;
        for (let i=0;i<json_data.length;i++){
            var singlegood=json_data[i];
            console.log(singlegood);
            const sql = `insert into goodlist values(${JSON.stringify(singlegood)});`;
            connect.query(sql,(err,result,fields)=>{
                if(err){
                    throw err;
                }
                console.log(result);
            });
        }
    });    
};
//insertData();

//分页查询数据库
exports.selectData=function(page,callback){
    var fileurl=path.join(__dirname,'../db/from_sql_good.json');
    var size = 4;
    var skip = (page-1)*size;
    //模板字符串
    const sql = `select * from goodlist limit ${skip},${size};`;
    // const sql = `select * from goodlist;`;
    connect.query(sql,(err,result,fields)=>{
        if(err){
            throw err;
        }
        //result是一个数组，这个数组由RowDataPacket对象组成，每个RowDataPacket对象包含对象singlegood。
        // console.log(result);
        var newMessage=[];
        //遍历result
        for (const row of result) {
            const obj = JSON.parse(row.singlegood);
            // console.log(obj);
            newMessage.push(obj);
        }
        var newGoodlist=JSON.stringify({
            status:0,
            message:newMessage
        });
        // console.log('processdata===='+newGoodlist);//输出
        callback(newGoodlist);
        // fs.writeFile(fileurl,newGoodlist,function(err,data){
        //  if(err){
        //      console.log('err');
        //  }
        //  console.log('success!');
        // });
    });

};
//selectData();

4. get请求返回给客户端分页查询到的数据

//获取商品列表
router.get('/getgoodlist',function(req,res){
    //console.log(req.query);
    var pageNumber=req.query.pageNumber;
    //console.log(pageNumber);
    processdata.selectData(pageNumber,function(newGoodlist){
        // console.log('callback===='+newGoodlist);
        //使用回调函数获取分页查询到的数据！！！！！！
        var data=JSON.parse(newGoodlist);
        // console.log('data===='+newGoodlist);
        res.send(data);
    });   
});