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

男娘i 2022-07-19 01:26 821阅读 0赞

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

# \--安装模块 #

npm install mssql  --连接数据库模块 ,[基本封装看这里:http://blog.csdn.net/zzwwjjdj1/article/details/51911270][http_blog.csdn.net_zzwwjjdj1_article_details_51911270]

npm install async  --异步流程控制模块 ,[async模块介绍:http://blog.csdn.net/zzwwjjdj1/article/details/51857959][async_http_blog.csdn.net_zzwwjjdj1_article_details_51857959]

# \--创建测试数据库和表 #

数据库 : nodetest,表 : test

![Center][]

# \--封装代码 #

dbTransaction.js:

**\[javascript\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

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语句错误 #

错误位置:

![Center 1][]

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

testTransaction.js

**\[javascript\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

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条数据都不会插入成功.

看看是不是这样的

执行结果:

![Center 2][]

数据库

![Center 3][]

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

# \--测试-非sql语句错误 #

也就是程序错误

错误位置:

![Center 4][]

testTransaction.js

**\[javascript\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

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. \})

执行结果:

![Center 5][]

数据库也为空,就不截图了.

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

# \--测试-无错误 #

无错误的情况,当然是皆大欢喜,程序不报错,数据插入成功.

去掉我们添加的错误,执行

![Center 6][]

数据库:

![Center 7][]![微笑][smile.gif]终于成功了.......

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

[http_blog.csdn.net_zzwwjjdj1_article_details_51911270]: http://blog.csdn.net/zzwwjjdj1/article/details/51911270
[async_http_blog.csdn.net_zzwwjjdj1_article_details_51857959]: http://blog.csdn.net/zzwwjjdj1/article/details/51857959
[Center]: /images/20220718/2b045778106d4a62a2798a283dacb0ae.png
[view plain]: http://blog.csdn.net/zzwwjjdj1/article/details/51995536#
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/1778387
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/1778387/fork
[Center 1]: /images/20220718/28e73cbc5aac48218b39d26dc5189aea.png
[Center 2]: /images/20220718/c11152f4c92446e3bc0d7038d3056bf7.png
[Center 3]: /images/20220718/369f3af755764da39f0dd61367a24b69.png
[Center 4]: /images/20220718/beebef57075f45de857084d641dd3b9a.png
[Center 5]: /images/20220718/078f438a57c940afb1c531af0077364d.png
[Center 6]: /images/20220718/b9384d79cd0d4202aecb98b1ed7c67da.png
[Center 7]: https://img-blog.csdn.net/20160722170222738?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQv/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center
[smile.gif]: http://static.blog.csdn.net/xheditor/xheditor_emot/default/smile.gif