//1:加載相應的模塊 http url fs mysql
const http = require("http");
const url = require("url");
const fs = require("fs");
const mysql = require("mysql");
//2:創建連接池
var pool = mysql.createPool({
host:'127.0.0.1',
user:'root',
password:'',
database:'jd',
connectionLimit:5 //連接池大小
});
//3:創建服務器
var server = http.createServer();
server.listen(80);
//4:為服務器注冊事件request
//參數 req 請求對象(客戶信息)
//參數 res 響應對象(服務器信息)
server.on('request',(req,res)=>{
//5:解析參數
var objUrl = url.parse(req.url,true);
//6:獲取請求地址
var path = objUrl.pathname;
//7:設置響應頭信息格式
res.setHeader('content-type','text/html;charset=utf-8');
//8:判斷路徑
if(path==='/register'){
//9:異步讀取文件
fs.readFile("./public/register.html",(err,data)=>{
if(err)throw err;
res.end(data);
});
}else if(path==='/register.do'){
var n = objUrl.query.uname;
var p = objUrl.query.upwd;
//10:從連接池中獲取一個連接
pool.getConnection((err,conn)=>{
if(err){
console.log("從連接池中獲取連接失敗");
}else{
//11:發送sql語句
conn.query("INSERT INTO jd_user VALUES(null,?,?)",
[n,p],(err,result)=>{
if(err){
console.log("sql語句執行失敗");
}else{
console.log("執行成功");
}
//12:釋放連接
conn.release();
});
}
});
}
});
//4:解析參數如果請求 register 返回register.html
//5: register 添加數據庫