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

转自：http://blog.csdn.net/zzwwjjdj1/article/details/51995536 --安装模块 npm install m
2023-11-24 技术
转自：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方法开始,所有的程序错误都要手动处理,如果发生错误,而又没处理到,是不会回滚的.

版权声明

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处。如若内容有涉嫌抄袭侵权/违法违规/事实不符，请点击 举报 进行投诉反馈！

推荐阅读