node.js:怎样同时执行多条SQLs,且只有一个回调
2016-06-24 22:42
393 查看
node.js很大的特点就是事件驱动、非阻塞和异步执行,很多地方都需要回调处理。在一些复杂业务中,会出现由于回调处理引起的代码多层嵌套,其可读性和感观,对一些开发者来说,显得不适应,甚至恶心。 从而引起口水战, 甚至于否定node.js。多层嵌套的代码组织方式,显然是不可取的, 但并不是说事件驱动、非阻塞、异步执行和回调处理等不好,这些恰恰是编程的核心思想,在编码上对开发者有一定的要求和约束,需要对业务开发进行分析解耦,从而更好的组织代码让其看起来更加简练。所以,观念上需要改变和适应。言归正传,下面聊一聊mysql-queries。
顾名思义,mysql-queries就是为mysql简单地执行多条SQLs的node.js库。其特点在于无需多层嵌套,且只有一个回调,从而使代码更加简洁。下面通过实例演示一下,比较传统的方式和mysql-queries在编码上的差异。
实例
例如同时执行下面三条SQLs:var sqls = ['SELECT * FROM prod_unit WHERE NAME=? limit 1', 'INSERT INTO prod_unit(name) values(?)', 'INSERT INTO product(name, unit_id, price) VALUES(?, ?, ?)'];
传统的做法
var mysql = require('mysql'), conf = { host: 'localhost', user: 'nodejs', password: 'nodejs', database: 'nodejs', port: 3306 }, conn = mysql.createConnection(conf); conn.connect(); conn.query(sqls[0], [params.unit_name], function (err0, res0) { if (err0) { console.log(err0); } else { conn.query(sqls[1], [params.unit_name], function (err1, res1) { if (err1) { console.log(err1); } else { conn.query(sqls[2], [params.name,params.type_id,params.unit_id,params.price], function (err2, res2) { if (err2) { console.log(err2); } else { //TODO something } }); } }); } });
使用mysql-queries
//实际使用中可以在应用启动时进行初始化(只需执行一次) require('mysql-queries').init(conf); //执行多条SQLs var mq = require('mysql-queries'); mq.queries(sqls, [[params.unit_name],[params.unit_name],[params.name,params.type_id,params.unit_id,params.price]], function(err, results){ if(err) { console.log(err); } else { //"results"为数组,其为多条SQL的执行结果. console.log(results); } });
进阶用法--根据前面SQL的执行结果,判断是否执行当前SQL
例如上述SQLs,在新增商品时允许自定义单位,如果单位不存在,新建商品单位。否则,直接新增商品。
mq.queries(sqls, [[params.unit_name],[params.unit_name],[params.name,params.type_id,params.unit_id,params.price]], { skip:function(i, arg, results) {//skip判断是否忽略当前SQL的执行,返回true忽略,false不忽略 var skip = false; //i为SQLs的索引号 switch(i) { case 1: //根据第1条SQL的结果,判断是否忽略执行第2条SQL skip = results[0].length!==0; break; case 2: //如果第二条被执行,其结果中的"insertId"将作为第3条SQL的参数 if(results[0].length===0) { arg[2]=results[1].insertId; } break; } return skip; } }, function(err, results){ if(err) { console.log(err); } else { //"results"为数组,其为多条SQL的执行结果. console.log(results); } });
另外
mysql-queries除了上述对代码的简化外, 其还采用了数据源和事务处理, 从而提高了开发效率和实用性,给数据库操作带来了很大的便利。最后
本文除了介绍mysql-queries, 希望可以抛砖引玉, 从另一个角度看待node.js开发. 通过类似的方式对异步操作进行处理, 实现例如oracle-queries, ajax-queries等等, 也即此跟大家交流node.js开发心得.更多内容,源码和加星访问:
https://github.com/zzzhan/nodejs-mysql-queries
相关文章推荐
- MySQL 一致性读 深入研究 digdeep博客学习
- mysql-触发器
- mongodb用户安全认证详解
- SQL Server Extended Events 进阶 1:从SQL Trace 到Extended Events
- mybatis-generator-1.3.2生成数据库的中文注释
- MicroSoft_SQLServer用法全笔记
- MySQL(一)
- 一对多的分页查询
- Ubuntu安装mysql5.7
- 从“如何设计用户超过1亿的应用”说起—数据库调优实战
- Mysql数据库调优和性能优化的21条最佳实践
- 初窥Python(一)——使用pymongo连接MongoDB
- MariaDB集群配置
- 基于SQL求集合的交、并、补
- ubuntu下MySQL中文乱码(新版本Mysql修改方法)
- SQL Server性能调优系列
- Redis - 快速入门
- jdbc使用 Statement 接口实现添加数据操作(使用面向对象和数据库连接工具类)
- 数据库索引工作原理
- 一周乱弹(0624 1,maven 添加依赖包.2,sqlserver 删除语句.3..OutOfMemoryError: PermGen space。4,SQL datediff (时间差)