Недавно я изучал node.js и выполнил практический проект, используя фреймворк node.js+express для разработки многопользовательской системы редактирования документов с базой данных mysql и интерфейсом vue framework.
Пример серверного проекта express+mysql в среде node.js
Первый — создать окружение:
В среде узла
$ npm install -g express-generator
$ express -e project
Войдите в корневой каталог файла проекта, чтобы установить зависимые модули.
$ npm install
$ DEBUG=node-blog:* npm start
Посмотрите, что находится в каталоге проекта
Взгляните на то, что находится в сгенерированном каталоге проекта,
bin: хранить исполняемые файлы
node_modules: Сохраняйте модули, установленные в package.json. Когда вы добавляете зависимые модули в package.json и устанавливаете их, сохраняйте их в этой папке.
общедоступные: храните файлы ресурсов внешнего интерфейса, такие как изображения, css, js и т. д.
маршруты: хранить файлы маршрутизации
представления: хранить файлы представлений или файлы шаблонов
app.js: файл запуска или файл входа
package.json: хранит информацию о проекте и зависимости модулей.При добавлении зависимых модулей в зависимости запустите npm install, npm проверит текущий каталог
package.json и автоматически устанавливает все указанные модули
Приступим к установке базы данных, здесь я выбираю mysql.
npm install mysql --save-dev
После завершения установки приступайте к настройке базы данных.
//mysql配置文件
mysql = {
host: "xx.xxx.xx.xxx", //这是数据库的地址
user: "xxx", //需要用户的名字
password: "xxx", //用户密码 ，如果你没有密码，直接双引号就是
database: "xxx" //数据库名字
} //好了，这样我们就能连接数据库了
module.exports = mysql; //用module.exports暴露出这个接口，
Конфигурация пула соединений mysql:
//mysql连接池配置文件
var mysql = require('mysql');
var $dbConfig = require('../config/mysql');//注意改成自己项目中mysql配置文件的路径
// 使用连接池，避免开太多的线程，提升性能
var pool = mysql.createPool($dbConfig);
/**
* 对query执行的结果自定义返回JSON结果
*/
function responseDoReturn(res, result, resultJSON) {
if (typeof result === 'undefined') {
res.json({
code: '201',
msg: 'failed to do'
});
} else {
res.json(result);
}
};
/**
* 封装query之sql带不占位符func
*/
function query(sql, callback) {
pool.getConnection(function(err, connection) {
connection.query(sql, function(err, rows) {
callback(err, rows);
//释放链接
connection.release();
});
});
}
/**
* 封装query之sql带占位符func
*/
function queryArgs(sql, args, callback) {
pool.getConnection(function(err, connection) {
connection.query(sql, args, function(err, rows) {
callback(err, rows);
//释放链接
connection.release();
});
});
}
//exports
module.exports = {
query: query,
queryArgs: queryArgs,
doReturn: responseDoReturn
}
Процесс работы с базой данных относительно гибкий. Я использую идею модульности, чтобы инкапсулировать таблицу данных в модуль и выставить ее. Через этот модуль я могу получить операторы добавления, удаления, изменения и запроса SQL этого Таблица. Вставьте пример кода ниже:
let express = require('express');
let mysql = require('../common/basicConnection');
let qibu_task = {
index: '',
value: '',
list: `SELECT * from qibu_task;`, //列表查询
insert(args) {
qibu_task.index = '';
qibu_task.value = '';
args = filter(['id', 'task', 'name', 'created_at'], args)
for (let key in args) {
qibu_task.index = `${qibu_task.index}${key},`
let re = /^[0-9]+.?[0-9]*/;
if (re.test(args[key])) {
qibu_task.value = `${qibu_task.value}${args[key]},`
} else {
qibu_task.value = `${qibu_task.value}'${args[key]}',`
}
}
qibu_task.index = qibu_task.index.substr(0, qibu_task.index.length - 1);
qibu_task.value = qibu_task.value.substr(0, qibu_task.value.length - 1);
return `INSERT INTO qibu_task (${qibu_task.index}) VALUES(${qibu_task.value})`;
}, //按需增加
select(index, value) {
return `SELECT * from qibu_task where ${index}=${value};` //按需查询
},
delete(index, value) {
return `DELETE from qibu_task where ${index}=${value};` //按需删除
},
update(index, args) { //提交修改
if (index in args) {
qibu_task.value = '';
args = filter(['id', 'task', 'name', 'created_at'], args)
for (let key in args) {
let re = /^[0-9]+.?[0-9]*/;
if (re.test(args[key])) {
qibu_task.value = `${qibu_task.value}${key}=${args[key]},`
} else {
qibu_task.value = `${qibu_task.value}${key}='${args[key]}',`
}
}
qibu_task.value = qibu_task.value.substr(0, qibu_task.value.length - 1)
return `UPDATE qibu_task SET ${qibu_task.value} WHERE ${index}=${args[index]};`
}
},
};
//参数过滤
function filter(arguments, obj) {
let newObj = {}
arguments.forEach(every => {
if (every in obj) {
newObj[every] = obj[every]
}
});
return newObj;
};
module.exports = qibu_task;
Затем вы можете выполнять операции с базой данных, когда маршрут возвращается. Конкретный код не будет опубликован. Маршруты могут распознавать методы get, post, изменять и удалять, передавая моделирование параметров.
возобновить
Я считаю, что в проекте слишком неэффективно писать операторы CRUD для каждой таблицы данных отдельно, поэтому в процесс генерации операторов SQL для таблиц данных вносятся некоторые изменения, а класс DBSQL создается с помощью конструктора для генерации Операторы SQL нужных таблиц данных Просто создайте новый экземпляр DBSQL в маршрутизации, и конкретный код будет загружен на github.
На данный момент вся конфигурация сервера практически одинакова. Кроме того, в проекте также используется socket.io, о нем поговорим отдельно. Адрес github размещен ниже, и джентльмены из аудитории пройдут мимо и вознаградят их стартом ^.^