——————————sql在nodejs中的使用——————————

一、安装nodejs ：

cmd 执行命令：npm i mysql -s

二、导入：

var mysql = require（"mysql"）

三、创建连接

var con =mysql .createConnection({
    host:"localhost",
    user:"root",
    password:"123456",
    database:"feedback"
})

四、链接

con.connect(function(err){
    if(!err){
        console.log("连接成功")
    }else{
        console.log("连接错误",err)
    }
})

五、执行sql

con.query(sql,function (err,result){
    if(!err){
        console.log(result)
    }else{
        console.error("数据操作错误")
    }
})

六、断开sql

con.end(function(err){
    if(!err){
        console.log("断开成功")
    }
})

番外server

// 导入 express
var express = require('express');
// 导入mysql
var mysql = require("mysql");
// 创建连接
var con = mysql.createConnection({
	host:"localhost",
	user:"root",
	password:"123456",
	database:"feedback"
})
// 连接数据库
con.connect(function(err){
	if(!err){
		console.log("数据库连接成功")
	}else{
		console.error("数据库连接失败",err);
	}
})

// 创建express 的实例
var app = express();

// 定义静态资源
app.use(express.static('./public'))

// 使用一个json中间件
app.use(express.json());

// 定义模板引擎,使用模板引擎
// 定义模板的位置
app.set("views","./views")
// 定义使用ejs模板引擎
app.set('view engine','ejs');

// 处理post请求地址是/adduser
app.post("/adduser",function(req,res){
	// req是请求的数据 req.body请求的body
	var sql = `insert into user (name,password,score) values('${req.body.name}','${req.body.password}',${req.body.score})`;
	// 执行sql
	con.query(sql,function(err,result){
		// 如果没有错误,显示添加用户成功
		if(!err){
			res.json({
				"errCode":0,
				"msg":'添加用户成功',
				"data":result,
			})
		}else{
			// 如果有错误,显示错误
			res.json({
				"errCode":1,
				"msg":'数据库失败',
				"err":err
			})
		}
	})
	
})


// 定义用户页面(路由)
app.get("/user",function(req,res){
	// 渲染user页面,传入的数据为空
	res.render('user',{
		title:"我是用户页面",
		list:["zeng8","zeng9","zeng11","木木"]
		})
})



// 前后端分离的项目
app.get("/list",function(req,res){
	// 定义sql
	var sql = `select name,score,id from user where 1 order by id desc limit 0,5`;
	// 查询sql
	con.query(sql,function(err,result){
		if(!err){
			// 没有错误返回数据
			res.json({
				"errCode":0,
				"msg":"请求成功",
				"list":result
				})
		}else{
			// 返回错误原因
			res.json({
				"errCode":1,
				"msg":"数据库错误"
			})
		}
	})
	
})


// 监听get方法的路径 /首页
// req请求,res响应
app.get("/",function(req,res){
	res.send(`<h1>我是首页</h1>`)
})

app.get("/about",function(req,res){
	res.send(`<h1>我是关于页面</h1>`)
})
// 监听端口,启动服务器
var server = app.listen(8888,function(){
	console.log("服务器在 localhost:8888 启动完毕")
})