Node.js+Express+Mysql 实现增删改查

cnpm install express //express框架安装

cnpm install mysql //mysql驱动安装

 brew install mysql //数据库的安装，根据命令行提示初始化配置
 mysql.server start//启动mysql服务
 mysql.server stop//停止mysql服务
 mysql -u用户名 -p用户密码//登录mysql

mysql -uroot -p

mysql> ALTER USER 'root'@'localhost' IDENTIFIED BY 'password' PASSWORD EXPIRE NEVER;

mysql> ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY '123456';

mysql> FLUSH PRIVILEGES;

var mysql = require('mysql');//引入数据库驱动模块
//console.log(mysql)
// 连接数据库的配置
var connection = mysql.createConnection({
 // 主机名称，一般是本机
 host: 'localhost',
 // 数据库的端口号，如果不设置，默认是3306
 port: '3306',
 // 创建数据库时设置用户名
 user: 'root',
 // 创建数据库时设置的密码
 password: '*******',
 // 创建的数据库
 database: 'express'
});
// 与数据库建立连接
connection.connect();
// 查询数据库
connection.query('select * from userinfo', function (error, results, fields) {
 if (error) throw error;
 console.log(results);
});

// 关闭连接
connection.end();

var express = require("express");
var app = express();
var query = require('./db')
//var router =require('router')
var mysql = require('mysql');
var querystring = require("querystring");
//console.log(mysql)
// 连接数据库的配置
var connection = mysql.createConnection({
 // 主机名称，一般是本机
 host: 'localhost',
 // 数据库的端口号，如果不设置，默认是3306
 port: '3306',
 // 创建数据库时设置用户名
 user: 'root',
 // 创建数据库时设置的密码
 password: '1234567',
 // 创建的数据库
 database: 'express'
});
// 与数据库建立连接
connection.connect();
//根据参数，查询数据
app.get('/index', function (req, res) {
 // 处理 get 请求，获取 get 请求参数
 //处理 /:xxx 形式的 get 或 post 请求，获取请求参数 这里没有使用到
 var params = req.query
 //查询语句
 var sql = 'select * from userinfo where name= "color: #ff0000">http客户端

这里把node http模块来搭建客户端，发起请求。
get请求


const http = require("http");
// 发送请求的配置
let config = {
 host: "localhost",
 port: 8080,
 //get请求参数
 path:'/index"GET",
 headers: {
 a: 1
 }
};
// 创建客户端
let client = http.request(config, function(res) {
 // 接收服务端返回的数据
 let repData='';
 res.on("data", function(data) {
 repData=data.toString()
 console.log(repData)
 });
 res.on("end", function() {
 // console.log(Buffer.concat(arr).toString());
 });
});
// 发送请求
client.end();


客户端发起参数name=bill&age=21的查询请求，服务端根据条件操作数据库，响应数据为：

post请求


var http = require('http');
var querystring = require("querystring");
//查询参数拼接
//增加的数据
var contents = querystring.stringify({
 id:5,
 age:'23',
 name: "艾利斯提",
 address: "dongbei",
});
var options = {
 host: "localhost",
 port: 8080,
 path:"/add",
 method: "POST",
 headers: {
 "Content-Type": "application/x-www-form-urlencoded",
 "Content-Length": contents.length
 }
};
var req = http.request(options, function (res) {
 res.setEncoding("utf8");
 res.on("data", function (data) {
 console.log(data);
 })
})
//发送数据
req.write(contents);
req.end(); //结束请求，否则服务器将不会收到信息


post请求发送增加数据，服务端根据请求，向数据库追加一条数据，响应客户端：增加数据成功。增加后的数据表：

put请求


const http = require("http");
var querystring = require("querystring");
//查询参数拼接
// 发送请求的配置
var contents = querystring.stringify({
 id:1,
 age:'25',
 name: "Sarah",
 address: "qingdao",
});
let config = {
 host: "localhost",
 port: 8080,
 path:'/update',
 method: "PUT",
 headers: {
 a: 1
 }
};
// 创建客户端
let client = http.request(config, function(res) {
 // 接收服务端返回的数据
 let repData='';
 res.on("data", function(data) {
 repData=data.toString()
 console.log(repData)
 });
 
});
 client.write(contents);
// 发送请求
client.end();


这里请求和post方法类似，服务端根据sql语句('update userinfo set name="text-align: center">
delete请求


const http = require("http");
// 发送请求的配置
let config = {
 host: "localhost",
 port: 8080,
 //删除数据的参数
 path:'/delete"DELETE",
 headers: {
 a: 1
 }
};
// 创建客户端
let client = http.request(config, function(res) {
 // 接收服务端返回的数据
 let repData='';
 res.on("data", function(data) {
 repData=data.toString()
 console.log(repData)
 });
 res.on("end", function() {
 // console.log(Buffer.concat(arr).toString());
 });
});
// 发送请求
client.end();


客户端发送删除数据的参数，客户端拿到参数，根据条件，操作数据库删除相应数据，响应客户端：删除成功。删除后的数据表：

总结


接触后端的内容后，从后端的角度重新理解了前端数据的传输和操作。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。