- 思路鹃锈。就是在nodejs中,因為我們的目的是客戶端發(fā)出請求瞧预,nodejs服務(wù)端需要根據(jù)這個請求屎债,返回json數(shù)據(jù)。也就是說垢油,我們要在服務(wù)器端完成連接數(shù)據(jù)庫的任務(wù)盆驹,獲取數(shù)據(jù)庫中的json類型的數(shù)據(jù)。所以首先處理nodejs連接mysql數(shù)據(jù)庫的問題秸苗,接著是對數(shù)據(jù)庫中的數(shù)據(jù)進(jìn)行數(shù)據(jù)處理的問題召娜,最后返回數(shù)據(jù)給客戶端。
1. 安裝mysql驅(qū)動(模塊)
npm install mysql
2. nodejs連接mysql數(shù)據(jù)庫
database.js中的代碼
let mysql = require('mysql');
//創(chuàng)建連接
let connection = mysql.createConnection({
host:'localhost',
user:'root',
password:'自己數(shù)據(jù)庫的密碼',
database:'自己創(chuàng)建數(shù)據(jù)庫的名稱',
});
//連接數(shù)據(jù)庫
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
- 解決方案:
- 因為之前使用
alter user 'root'@'localhost' identified by '用戶密碼';
修改密碼惊楼,這種加密方式是mysql8.X版本支持的默認(rèn)方式玖瘸,稱為“caching_sha2_password”。但是nodejs中的mysql模塊并不支持這種加密方式檀咙。 - 使用mysql模塊支持“mysql_native_password”的加密方式雅倒,重新修改密碼。
alter user 'root'@'localhost' identified with mysql_native_password by '用戶密碼';
- 因為之前使用
3. 將json類型的數(shù)據(jù)存儲到數(shù)據(jù)庫中弧可,以及獲取存儲到數(shù)據(jù)庫中的數(shù)據(jù)
processdata.js中的代碼
let connect=require('./database');
//console.log(connect);
let fs =require('fs');
let path = require('path');
//插入數(shù)據(jù)到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();
//分頁查詢數(shù)據(jù)庫
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是一個數(shù)組蔑匣,這個數(shù)組由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請求返回給客戶端分頁查詢到的數(shù)據(jù)
//獲取商品列表
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);
//使用回調(diào)函數(shù)獲取分頁查詢到的數(shù)據(jù)2昧肌T浣!<燮ⅰD恋帧!
var data=JSON.parse(newGoodlist);
// console.log('data===='+newGoodlist);
res.send(data);
});
});