首页 / MYSQL / node封装mysql模块
node封装mysql模块
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了node封装mysql模块,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含2269字,纯文字阅读大概需要4分钟。
内容图文
![node封装mysql模块](/upload/InfoBanner/zyjiaocheng/493/671f62b923f6401294a6f1b6d9cbc9a9.jpg)
‘use strict‘; const mysql = require(‘mysql‘); var local = true var pool // 创建连接池 if (local) { pool = mysql.createPool({ connectionLimit: 50, host: ‘localhost‘, user: ‘root‘, password: ‘root‘, database: ‘crawl‘, multipleStatements: true //是否允许执行多条sql语句 }); } //将结果已对象数组返回 var row = (sql, ...params) => { return new Promise(function (resolve, reject) { pool.getConnection(function (err, connection) { if (err) { reject(err); return; } connection.query(sql, params, function (error, res) { connection.release(); if (error) { reject(error); return; } resolve(res); }); }); }); }; //返回一个对象 var first = (sql, ...params) => { return new Promise(function (resolve, reject) { pool.getConnection(function (err, connection) { if (err) { reject(err); return; } connection.query(sql, params, function (error, res) { connection.release(); if (error) { reject(error); return; } resolve(res[0] || null); }); }); }); }; //返回单个查询结果 var single = (sql, ...params) => { return new Promise(function (resolve, reject) { pool.getConnection(function (err, connection) { if (err) { reject(err); return; } connection.query(sql, params, function (error, res) { connection.release(); if (error) { reject(error); return; } for (let i in res[0]) { resolve(res[0][i] || null); return; } resolve(null); }); }); }); } //执行代码,返回执行结果 var execute = (sql, ...params) => { return new Promise(function (resolve, reject) { // 获取连接 pool.getConnection(function (err, connection) { if (err) { reject(err); return; } // 操作数据库 connection.query(sql, params, function (error, res) { // 释放 connection.release(); if (error) { reject(error); return; } resolve(res); }); }); }); } //模块导出 module.exports = { ROW: row, FIRST: first, SINGLE: single, EXECUTE: execute } /*连接mysql*/ function connectToMysql() { var connection = mysql.createConnection({ host: ‘‘, user: ‘‘, password: ‘‘, database: ‘‘ }); connection.connect(); //查询 connection.query(‘SELECT * FROM user;‘, function (err, rows, fields) { if (err) throw err; console.log(‘The solution is: ‘, rows[0]); }); //关闭连接 connection.end(); }
node封装mysql模块
标签:导出 rom node UI nec null 实现 tip cat
本文系统来源:http://www.cnblogs.com/cosyer/p/7763602.html
内容总结
以上是互联网集市为您收集整理的node封装mysql模块全部内容,希望文章能够帮你解决node封装mysql模块所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。