node+express框架中连接使用mysql(经验总结)
程序员文章站
2023-01-29 15:15:22
最近在学习node.js,做了一个练手项目,使用node.js+express框架,配合mysql数据库和前端vue框架开发一个多人文档编辑系统。
首先是环境搭建:...
最近在学习node.js,做了一个练手项目,使用node.js+express框架,配合mysql数据库和前端vue框架开发一个多人文档编辑系统。
首先是环境搭建:
node环境下
$ npm install -g express-generator $ express -e project
进入项目文件根目录安装依赖模块
$ npm install $ debug=node-blog:* npm start
看看项目目录都有什么
看看生成的工程目录里面都有什么,
bin:存放可执行文件
node_modules:存放 package.json 中安装的模块,当你在 package.json 添加依赖的模块并安装后,存放在这个文件夹下
public:存放 image、css、js 等前端资源文件
routes:存放路由文件
views:存放视图文件或者说模版文件
app.js:启动文件,或者说入口文件
package.json:存储着工程的信息及模块依赖,当在 dependencies 中添加依赖的模块时,运行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方法,修改和删除通过传递参数模拟。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
上一篇: webpack中如何使用雪碧图的示例代码
推荐阅读
-
node+express框架中连接使用mysql(经验总结)
-
php中mysql连接方式PDO使用详解
-
php中mysql连接和基本操作代码(快速测试使用,简单方便)
-
基于Python3.6使用Django框架连接mysql数据库的驱动模块安装解决办法
-
Java开发中JDBC连接mysql数据库使用介绍
-
在VC2008中使用"MySQL Connector/C++ "连接My_MySQL
-
在现时中小型网站的实际开发中,连接MySQL数据库主要使用哪种计算
-
php中mysql连接和基本操作代码(快速测试使用,简单方便)_PHP教程
-
TP框架中mysql和mongo同时使用解决方案
-
php中mysql连接方式PDO使用详解,pdo浣跨敤璇﹁В