nodejs连接sqlserver数据库支持事物封装-mssql模块

2024-04-05 06:58
文章标签 模块 封装 连接 数据库 支持 nodejs sqlserver database mssql 事物

本文主要是介绍nodejs连接sqlserver数据库支持事物封装-mssql模块，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

转自：http://blog.csdn.net/zzwwjjdj1/article/details/51995536

--安装模块

npm install mssql  --连接数据库模块 ,基本封装看这里:http://blog.csdn.net/zzwwjjdj1/article/details/51911270
npm install async  --异步流程控制模块 ,async模块介绍:http://blog.csdn.net/zzwwjjdj1/article/details/51857959

--创建测试数据库和表

数据库 : nodetest,表 : test

--封装代码

dbTransaction.js:
[javascript]  view plain copy
在CODE上查看代码片 派生到我的代码片
  1. /* 
  2. nodejs连接sqlserver数据库支持事物封装 
  3. 2016年7月22日15:46:22 
  4. QQ : 452076103 意外金喜 
  5.  */  
  6. var dbTransaction = {};  
  7. var sql = require('mssql');  
  8. var config = {  
  9.   user: 'sa',  
  10.   password: '123456',  
  11.   server: '10.81.36.167',   
  12.   database: 'nodetest',  
  13.   port:1433,  
  14.   options: {  
  15.     encrypt: true // Use this if you're on Windows Azure  
  16.   },  
  17.   pool: {  
  18.     min: 0,  
  19.     max: 10,  
  20.     idleTimeoutMillis: 3000  
  21.   }  
  22. };  
  23.   
  24. dbTransaction.getTransaction = function(callback){  
  25.   
  26.   var connection = new sql.Connection(config, function (err) {  
  27.   
  28.     var transaction = new sql.Transaction(connection);  
  29.       
  30.     callback(sql, transaction);  
  31.   })  
  32. };  
  33.   
  34. module.exports = dbTransaction;  

--测试-sql语句错误

错误位置:

age是int类型的,故意写成string

testTransaction.js
[javascript]  view plain copy
在CODE上查看代码片 派生到我的代码片
  1. /* 
  2. 测试连接sqlserver的事物机制 
  3. 2016年7月22日15:51:52 
  4.  */  
  5. var async  = require('async');  
  6. var dbTransaction = require('./dbTransaction.js');  
  7.   
  8. dbTransaction.getTransaction(function(sql, transaction){  
  9.     //开启事物  
  10.     transaction.begin(function(err) {  
  11.   
  12.         if (err) {  
  13.             console.log(err);  
  14.             return;  
  15.         }  
  16.         //定义一个变量,如果自动回滚,则监听回滚事件并修改为true,无须手动回滚  
  17.     var rolledBack = false;  
  18.   
  19.     //监听回滚事件  
  20.     transaction.on('rollback', function(aborted) {  
  21.         console.log('监听回滚');  
  22.         console.log('aborted值 :', aborted);  
  23.         rolledBack = true;  
  24.     });  
  25.   
  26.     //监听提交事件  
  27.     transaction.on('commit', function() {  
  28.         console.log('监听提交');  
  29.         rolledBack = true;  
  30.     });  
  31.   
  32.     var request = new sql.Request(transaction);  
  33.     var task1 = function(callback){  
  34.         request.query("insert into test (name, age) values ('a1', 20)", function(err, result) {  
  35.             if (err) {  
  36.                 console.log(err);  
  37.                 callback(err, null);  
  38.                 return;  
  39.             }  
  40.             console.log('第一条语句成功');  
  41.             callback(null, result)  
  42.         })  
  43.   
  44.     };  
  45.     var task2 = function(callback){  
  46.         request.query("insert into test (name, age) values ('a2', 22)", function(err, result) {  
  47.             if (err) {  
  48.                 console.log(err);  
  49.                 callback(err, null);  
  50.                 return;  
  51.             }  
  52.             console.log('第二条语句成功');  
  53.             callback(null, result)  
  54.         })  
  55.   
  56.     };  
  57.     var task3 = function(callback){  
  58.         request.query("insert into test (name, age) values ('a3', 'a')", function(err, result) {  
  59.             if (err) {  
  60.                 console.log(err);  
  61.                 callback(err, null);  
  62.                 return;  
  63.             }  
  64.             console.log('第三条语句成功');  
  65.             callback(null, result)  
  66.         })  
  67.   
  68.     }  
  69.     async.series([task1, task2, task3],function(err,result){  
  70.         var err = "11";  
  71.             if (err) {  
  72.                 console.log('出现错误,执行回滚');  
  73.                 if (!rolledBack) {  
  74.   
  75.                     //如果sql语句错误会自动回滚,如果程序错误手动执行回滚,不然事物会一致挂起.  
  76.             transaction.rollback(function(err) {  
  77.                 if (err) {  
  78.   
  79.               console.log('rollback err :',err);  
  80.               return;  
  81.                 }  
  82.                 console.log('回滚成功');  
  83.             });  
  84.               }  
  85.             } else {  
  86.                 console.log('无错误,执行提交');  
  87.                 //执行提交  
  88.                 transaction.commit(function(err) {  
  89.                     if (err) {  
  90.   
  91.             console.log('commit err :',err);  
  92.             return;  
  93.                     }  
  94.                     console.log('提交成功');  
  95.           });  
  96.             }  
  97.     })  
  98.     });  
  99. })  
这个测试就是向test表插入3条数据,按照预期,如果这个过程出现任何错误,3条数据都不会插入成功.
看看是不是这样的
执行结果:


数据库

总结:sql错误,并没有触发我们写的回滚事件,但程序监听到了回滚事件,数据库插入失败,这是因为mssql模块自己写了回滚.

--测试-非sql语句错误

也就是程序错误
错误位置:


testTransaction.js
[javascript]  view plain copy
在CODE上查看代码片 派生到我的代码片
  1. /* 
  2. 测试连接sqlserver的事物机制 
  3. 2016年7月22日15:51:52 
  4.  */  
  5. var async  = require('async');  
  6. var dbTransaction = require('./dbTransaction.js');  
  7.   
  8. dbTransaction.getTransaction(function(sql, transaction){  
  9.     //开启事物  
  10.     transaction.begin(function(err) {  
  11.   
  12.         if (err) {  
  13.             console.log(err);  
  14.             return;  
  15.         }  
  16.         //定义一个变量,如果自动回滚,则监听回滚事件并修改为true,无须手动回滚  
  17.     var rolledBack = false;  
  18.   
  19.     //监听回滚事件  
  20.     transaction.on('rollback', function(aborted) {  
  21.         console.log('监听回滚');  
  22.         console.log('aborted值 :', aborted);  
  23.         rolledBack = true;  
  24.     });  
  25.   
  26.     //监听提交事件  
  27.     transaction.on('commit', function() {  
  28.         console.log('监听提交');  
  29.         rolledBack = true;  
  30.     });  
  31.   
  32.     var request = new sql.Request(transaction);  
  33.     var task1 = function(callback){  
  34.         request.query("insert into test (name, age) values ('a1', 20)", function(err, result) {  
  35.             if (err) {  
  36.                 console.log(err);  
  37.                 callback(err, null);  
  38.                 return;  
  39.             }  
  40.             console.log('第一条语句成功');  
  41.             callback(null, result)  
  42.         })  
  43.   
  44.     };  
  45.     var task2 = function(callback){  
  46.         request.query("insert into test (name, age) values ('a2', 22)", function(err, result) {  
  47.             if (err) {  
  48.                 console.log(err);  
  49.                 callback(err, null);  
  50.                 return;  
  51.             }  
  52.             console.log('第二条语句成功');  
  53.             callback(null, result)  
  54.         })  
  55.   
  56.     };  
  57.     var task3 = function(callback){  
  58.         request.query("insert into test (name, age) values ('a3', 24)", function(err, result) {  
  59.             if (err) {  
  60.                 console.log(err);  
  61.                 callback(err, null);  
  62.                 return;  
  63.             }  
  64.             console.log('第三条语句成功');  
  65.             callback(null, result)  
  66.         })  
  67.   
  68.     }  
  69.     async.series([task1, task2, task3],function(err,result){  
  70.         var err = "11";  
  71.             if (err) {  
  72.                 console.log('出现错误,执行回滚');  
  73.                 if (!rolledBack) {  
  74.   
  75.                     //如果sql语句错误会自动回滚,如果程序错误手动执行回滚,不然事物会一致挂起.  
  76.             transaction.rollback(function(err) {  
  77.                 if (err) {  
  78.   
  79.               console.log('rollback err :',err);  
  80.               return;  
  81.                 }  
  82.                 console.log('回滚成功');  
  83.             });  
  84.               }  
  85.             } else {  
  86.                 console.log('无错误,执行提交');  
  87.                 //执行提交  
  88.                 transaction.commit(function(err) {  
  89.                     if (err) {  
  90.   
  91.             console.log('commit err :',err);  
  92.             return;  
  93.                     }  
  94.                     console.log('提交成功');  
  95.           });  
  96.             }  
  97.     })  
  98.     });  
  99. })  

执行结果:

数据库也为空,就不截图了.
总结:非sql错误,也就是程序错误,执行了我们写的回滚事件,程序监听到了回滚事件,数据库插入失败

--测试-无错误

无错误的情况,当然是皆大欢喜,程序不报错,数据插入成功.
去掉我们添加的错误,执行

数据库:
微笑终于成功了.......

最后说下,从begin方法开始,所有的程序错误都要手动处理,如果发生错误,而又没处理到,是不会回滚的.

这篇关于nodejs连接sqlserver数据库支持事物封装-mssql模块的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

原文地址:
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.chinasem.cn/article/877916。

相关文章

MySQL 分区与分库分表策略应用小结

MySQL 分区与分库分表策略应用小结

《MySQL分区与分库分表策略应用小结》在大数据量、复杂查询和高并发的应用场景下,单一数据库往往难以满足性能和扩展性的要求,本文将详细介绍这两种策略的基本概念、实现方法及优缺点,并通过实际案例展示如... 目录mysql 分区与分库分表策略1. 数据库水平拆分的背景2. MySQL 分区策略2.1 分区概念
阅读更多...
MySQL高级查询之JOIN、子查询、窗口函数实际案例

MySQL高级查询之JOIN、子查询、窗口函数实际案例

《MySQL高级查询之JOIN、子查询、窗口函数实际案例》：本文主要介绍MySQL高级查询之JOIN、子查询、窗口函数实际案例的相关资料,JOIN用于多表关联查询,子查询用于数据筛选和过滤,窗口函... 目录前言1. JOIN（连接查询）1.1 内连接（INNER JOIN）1.2 左连接（LEFT JOI
阅读更多...
MySQL 中查询 VARCHAR 类型 JSON 数据的问题记录

MySQL 中查询 VARCHAR 类型 JSON 数据的问题记录

《MySQL中查询VARCHAR类型JSON数据的问题记录》在数据库设计中,有时我们会将JSON数据存储在VARCHAR或TEXT类型字段中,本文将详细介绍如何在MySQL中有效查询存储为V... 目录一、问题背景二、mysql jsON 函数2.1 常用 JSON 函数三、查询示例3.1 基本查询3.2
阅读更多...
MySQL中动态生成SQL语句去掉所有字段的空格的操作方法

MySQL中动态生成SQL语句去掉所有字段的空格的操作方法

《MySQL中动态生成SQL语句去掉所有字段的空格的操作方法》在数据库管理过程中,我们常常会遇到需要对表中字段进行清洗和整理的情况,本文将详细介绍如何在MySQL中动态生成SQL语句来去掉所有字段的空... 目录在mysql中动态生成SQL语句去掉所有字段的空格准备工作原理分析动态生成SQL语句在MySQL
阅读更多...
Qt spdlog日志模块的使用详解

Qt spdlog日志模块的使用详解

《Qtspdlog日志模块的使用详解》在Qt应用程序开发中,良好的日志系统至关重要,本文将介绍如何使用spdlog1.5.0创建满足以下要求的日志系统,感兴趣的朋友一起看看吧... 目录版本摘要例子logmanager.cpp文件main.cpp文件版本spdlog版本：1.5.0采用1.5.0版本主要
阅读更多...
MySQL中FIND_IN_SET函数与INSTR函数用法解析

MySQL中FIND_IN_SET函数与INSTR函数用法解析

《MySQL中FIND_IN_SET函数与INSTR函数用法解析》：本文主要介绍MySQL中FIND_IN_SET函数与INSTR函数用法解析,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友一... 目录一、功能定义与语法1、FIND_IN_SET函数2、INSTR函数二、本质区别对比三、实际场景案例分
阅读更多...
MySQL中的交叉连接、自然连接和内连接查询详解

MySQL中的交叉连接、自然连接和内连接查询详解

《MySQL中的交叉连接、自然连接和内连接查询详解》：本文主要介绍MySQL中的交叉连接、自然连接和内连接查询,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、引入二、交php叉连接（cross join）三、自然连接（naturalandroid join）四
阅读更多...
Mysql如何将数据按照年月分组的统计

Mysql如何将数据按照年月分组的统计

《Mysql如何将数据按照年月分组的统计》：本文主要介绍Mysql如何将数据按照年月分组的统计方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录mysql将数据按照年月分组的统计要的效果方案总结Mysql将数据按照年月分组的统计要的效果方案① 使用 DA
阅读更多...
Mysql表如何按照日期字段的年月分区

Mysql表如何按照日期字段的年月分区

《Mysql表如何按照日期字段的年月分区》：本文主要介绍Mysql表如何按照日期字段的年月分区的实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、创键表时直接设置分区二、已有表分区1、分区的前置条件2、分区操作三、验证四、注意总结一、创键表时直接设置分区
阅读更多...
mysql的基础语句和外键查询及其语句详解(推荐)

mysql的基础语句和外键查询及其语句详解(推荐)

《mysql的基础语句和外键查询及其语句详解(推荐)》：本文主要介绍mysql的基础语句和外键查询及其语句详解(推荐),本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋... 目录一、mysql 基础语句1. 数据库操作 创建数据库2. 表操作 创建表3. CRUD 操作二、外键
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2