предисловие
На этот раз nodejs+express+mysql используется для использования http в качестве клиента, а экспресс-инфраструктура создает сервер, чтобы реализовать добавление, удаление, изменение и проверку данных. Эту статью можно рассматривать как апгрейд предыдущей статьи, добавляющий взаимодействие с базой данных.
Установить
узел Перейдите непосредственно на официальный сайт для загрузки и выберите загрузку.узел будет .org/en/download…
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
Найденный вывод: метод шифрования MySQL 8.0 отличается от метода шифрования MySQL 5.0, и соединение сообщит об ошибке.
Обходной путь выглядит следующим образом:
Введите разархивированный корневой каталог mysql через командную строку.
база данных входа
mysql -uroot -p
Введите корневой пароль
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 — это минималистичная и гибкая среда разработки веб-приложений, основанная на платформе Node.js.Здесь нет проекта по созданию экспресс-среды, а просто создается сервер для реализации и добавления, удаления, изменения и проверки базы данных.
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-клиент
Здесь модуль http узла используется для создания клиента и инициирования запроса.
получить запрос
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, сервер управляет базой данных в соответствии с условиями, и данные ответа:
отправить запрос
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(); //结束请求，否则服务器将不会收到信息
Пост-запрос отправляет дополнительные данные, сервер дописывает часть данных в БД по запросу и отвечает клиенту: добавление данных прошло успешно. Добавлена таблица данных:
поставить запрос
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=?, где id=?') и отвечает на клиент: модификация данных прошла успешно. Пересмотренное техническое описание:
удалить запрос
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();
Клиент отправляет параметры для удаления данных, клиент получает параметры, оперирует базой данных для удаления соответствующих данных согласно условиям и отвечает клиенту: удаление прошло успешно. Удалена таблица данных:
Суммировать
Коснувшись содержимого серверной части, я заново понял передачу и работу внешних данных с точки зрения серверной части.