这次选用nodejs+express+mysql 使用http作为客户端，express框架搭建服务端，从而实现数据的增删改查。这篇文章可以算作上篇文章的升级篇，加入了和数据库的交互。

安装

node 直接去官网下载选择下载即可https://nodejs.org/en/download/current/

cnpm install express //express框架安装

cnpm install mysql //mysql驱动安装

brew install mysql //数据库的安装，根据命令行提示初始化配置

mysql.server start//启动mysql服务

mysql.server stop//停止mysql服务

mysql -u用户名 -p用户密码//登录mysql

nodejs连接数据库时报错

Error: ER_NOT_SUPPORTED_AUTH_MODE: Client does not support

authentication protocol requested by server; consider upgrading MySQL client

查到的结论是： MySQL8.0版本的加密方式和MySQL5.0的不一样，连接会报错。

解决方法如下： 通过命令行进入解压的mysql根目录下。

登陆数据库

mysql -uroot -p

输入root的密码

Enter password: ******

更改加密方式

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

更改密码：该例子中 123456为新密码

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();

新建一张表格在数据库中为：

express服务端

Express 是一个基于 Node.js 平台的极简、灵活的 web 应用开发框架，这里没有搭建express框架的项目，只是简单搭建一个服务端，实现和数据库的增删改查。

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= ? and age=?'

var where_value = [params.name, params.age];

// console.log(sql)

connection.query(sql, where_value, function (err, result) {

if (err) {

console.log('[SELECT ERROR]:', err.message);

}

res.send(result) //数据库查询结果返回到result中,把查询数据发送到客户端

});

})

//增加数据

app.post('/add', function (req, res) {

//获取及处理增加的数据

var post = '';

req.on('data', function (chunk) {

post += chunk;

console.log(post)

});

req.on('end', function () {

//查询参数解析

post = querystring.parse(post);

var sql = 'insert into userinfo set id=? , name=? , age=?, address=?'

var add_value = [post.id, post.name, post.age, post.address]

connection.query(sql, add_value, function (err, result) {

if (err) {

console.log('新增数据失败');

}

res.send('增加数据成功') // 响应内容 增加数据成功

});

});

})

//修改数据

app.put('/update', function (req, res) {

//处理请求修改的数据和条件

var update = '';

req.on('data', function (chunk) {

update += chunk;

console.log(update)

});

req.on('end', function () {

//查询参数解析

update = querystring.parse(update);

var sql = 'update userinfo set name=? , age=?, address=? where id=?'

var update_value = [update.name, update.age, update.address,update.id]

connection.query(sql, update_value, function (err, result) {

if (err) {

console.log('修改数据失败', err.message);

}

res.send('修改数据成功') // 响应内容 修改数据成功

});

});

})

//删除数据

app.delete('/delete', function (req, res) {

var params = req.query

var sql = 'delete from userinfo where name= ?'

var where_value = [params.name];

// console.log(sql)

connection.query(sql, where_value, function (err, result) {

if (err) {

console.log('删除失败', err.message);

}

res.send('删除成功')

});

})

//关闭连接

//connection.end();

//监听8080端口

var server = app.listen(8080, function () {

console.log('server running at 3000 port')

})

http客户端

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

get请求

const http = require("http");

// 发送请求的配置

let config = {

host: "localhost",

port: 8080,

//get请求参数

path:'/index?name=bill&age=21',

method: "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=? , age=?, address=? where id=?')修改数据库的内容，响应客户端：修改数据成功。修改后的数据表：

delete请求

const http = require("http");

// 发送请求的配置

let config = {

host: "localhost",

port: 8080,

//删除数据的参数

path:'/delete?name=bill',

method: "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();

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

总结

接触后端的内容后，从后端的角度重新理解了前端数据的传输和操作。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。