node.js 连接 mssql 代码

ゝ一世哀愁。 2022-06-07 00:24 414阅读 0赞

首先要安装 mssql 包： npm install mssql

第一种：

var sql = require('mssql');
    	//连接方式2："mssql://用户名:密码@ip地址:1433(默认端口号)/数据库名称"
    	sql.connect("mssql://sa:*******@localhost:1433/Test").then(function() {
    	//sql.connect("mssql://sa:123@localhost:1433/test").then(function() {
    	    // Query
    	    new sql.Request().query('INSERT INTO [dbo].[T1]([fName]) VALUES(77777)').then(function(recordset) {
    	        console.log(recordset);
    	    });
    	    // Stored Procedure
    	});

第二种：

dbHelper.js

var mssql = require('mssql');  
    var db = {};  
    var config = {  
      user: 'sa',  
      password: '*******',  
      server: '127.0.0.1',   
      database: 'Test',  
      port:1433,  
      options: {  
        encrypt: true // windows on
      },  
      pool: {  
        min: 0,  
        max: 10,  
        idleTimeoutMillis: 3000  
      }  
    };  
      
    //执行sql,返回数据.  
    db.sql = function (sql, callBack) {  
      var connection = new mssql.ConnectionPool(config, function (err) {  
        if (err) {  
          console.log(err);  
          return;  
        }  
        var ps = new mssql.PreparedStatement(connection);  
        ps.prepare(sql, function (err) {  
          if (err){  
            console.log(err);  
            return;  
          }  
          ps.execute('', function (err, result) {  
            if (err){  
              console.log(err);  
              return;  
            }  
      
            ps.unprepare(function (err) {  
              if (err){  
                console.log(err);  
                callback(err,null);  
                return;  
              }  
                callBack(err, result);  
            });  
          });  
        });  
      });  
    };  
      
    module.exports = db;

使用：同目录下

var db = require('./dbHelper.js');  
    	db.sql('select * from T1',function(err,result){  
    	    if (err) {  
    	        console.log(err);  
    	        return;  
    	    }  
    	    console.log('===',result);  
    	});

数据库：

![Image 1][]

脚本：

CREATE TABLE [dbo].[T1](
    	[fId] [int] IDENTITY(1,1) NOT NULL,
    	[fName] [nvarchar](50) NULL,
     CONSTRAINT [PK_T1] PRIMARY KEY CLUSTERED 
    (
    	[fId] ASC
    )WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
    ) ON [PRIMARY]

数据库事务：dbTransaction.js

var dbTransaction = {};  
    var sql = require('mssql');  
    var config = {  
      user: 'sa',  
      password: 'xinfu978',  
      server: '127.0.0.1',   
      database: 'Test',  
      port:1433,  
      options: {  
        encrypt: true // Use this if you're on Windows Azure  
      },  
      pool: {  
        min: 0,  
        max: 10,  
        idleTimeoutMillis: 3000  
      }  
    };  
      
    dbTransaction.getTransaction = function(callback){  
      
      var connection = new sql.ConnectionPool(config, function (err) {  
      
        var transaction = new sql.Transaction(connection);  
          
        callback(sql, transaction);  
      })  ;
    };  
      
    module.exports = dbTransaction;

使用： 需要安装 async 包， npm install async

var async  = require('async');  
    	var dbTransaction = require('./dbTransaction.js');  
    	  
    	dbTransaction.getTransaction(function(sql, transaction){  
    	    //开启事物  
    	    transaction.begin(function(err) {  
    	  
    	        if (err) {  
    	            console.log(err);  
    	            return;  
    	        }  
    	        //定义一个变量,如果自动回滚,则监听回滚事件并修改为true,无须手动回滚  
    	    var rolledBack = false;  
    	  
    	    //监听回滚事件  
    	    transaction.on('rollback', function(aborted) {  
    	        console.log('监听回滚');  
    	        console.log('aborted值 :', aborted);  
    	        rolledBack = true;  
    	    });  
    	  
    	    //监听提交事件  
    	    transaction.on('commit', function() {  
    	        console.log('监听提交');  
    	        rolledBack = true;  
    	    });  
    	  
    	    var request = new sql.Request(transaction);  
    	    var task1 = function(callback){  
    	        request.query("INSERT INTO [dbo].[T1]([fName]) VALUES(1111)", function(err, result) {  
    	            if (err) {  
    	                console.log(err);  
    	                callback(err, null);  
    	                return;  
    	            }  
    	            console.log('第一条语句成功');  
    	            callback(null, result)  ;
    	        }) ; 
    	  
    	    };  
    	    var task2 = function(callback){  
    	        request.query("INSERT INTO [dbo].[T1]([fName]) VALUES(22222)", function(err, result) {  
    	            if (err) {  
    	                console.log(err);  
    	                callback(err, null);  
    	                return;  
    	            }  
    	            console.log('第二条语句成功');  
    	            callback(null, result)  ;
    	        }) ;
    	  
    	    };  
    	    var task3 = function(callback){  
    	        request.query("INSERT INTO [dbo].[T12]([fName]) VALUES(3333)", function(err, result) {  
    	            if (err) {  
    	                console.log(err);  
    	                callback(err, null);  
    	                return;  
    	            }  
    	            console.log('第三条语句成功');  
    	            callback(null, result)  ;
    	        })  ;
    	  
    	    }  ;
    	    async.series([task1, task2, task3],function(err,result){  
    	      //  var err = "11";  
    	            if (err) {  
    	                console.log('出现错误,执行回滚');  
    	                if (!rolledBack) {  
    	  
    	                    //如果sql语句错误会自动回滚,如果程序错误手动执行回滚,不然事物会一致挂起.  
    	            transaction.rollback(function(err) {  
    	                if (err) {  
    	  
    	              console.log('rollback err :',err);  
    	              return;  
    	                }  
    	                console.log('回滚成功');  
    	            });  
    	              }  
    	            } else {  
    	                console.log('无错误,执行提交');  
    	                //执行提交  
    	                transaction.commit(function(err) {  
    	                    if (err) {  
    	  
    	            console.log('commit err :',err);  
    	            return;  
    	                    }  
    	                    console.log('提交成功');  
    	          });  
    	            }  
    	    })  ;
    	    });  
    	})  ;

[Image 1]:

发表评论取消回复

表情：

评论列表（有 0 条评论，414人围观）

还没有评论，来说两句吧...

相关阅读

相关 C#连接MSSQL数据库

一、ADO.NET的主要组件 ![Center][] 二、ADO.NET结构图 ![Center 1][] 三、Connection连接对象的属性及方法 ![Cent

迈不过友情╰/ 2024年02月17日 16:53/ 0 赞/ 25 阅读

相关 php drive mssql,php 连接sqlserver2008 mssql 官方 windows

1、下载 https://www.microsoft.com/en-us/download/confirmation.aspx?id=20098 先看下自己的php版本号，

谁践踏了优雅/ 2022年11月17日 03:51/ 0 赞/ 269 阅读

相关 mssql连接mysql数据库文件_在本地怎么远程连接MSSQL数据库

hp连接mssql数据库有几个注意事项，尤其mssql的多个版本、32位、64位都有区别。首先，php.ini文件中;extension=php\_pdo\_mssql.d

女爷i/ 2022年10月25日 00:48/ 0 赞/ 271 阅读

相关 php连接mssql

链接：http://blog.csdn.net/silentbalanceyh/article/details/4349790 相关下载：http://download.cs

桃扇骨/ 2022年08月06日 06:23/ 0 赞/ 250 阅读

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

转自：http://blog.csdn.net/zzwwjjdj1/article/details/51995536 \--安装模块 npm install mss

男娘i/ 2022年07月19日 01:26/ 0 赞/ 862 阅读

相关 JDBC连接MSSQL2014

1.首先下载`sqljdbc_4.0.2206.100_chs.exe` [这里给出第三方下载地址][Link 1] 双击解压文件到指定目录,我的指定目录是: D:

我不是女神ヾ/ 2022年06月14日 11:44/ 0 赞/ 262 阅读

相关 node.js 连接 mssql 代码

首先要安装 mssql 包： npm install mssql 第一种： var sql = require('mssql'); //连接方式

ゝ一世哀愁。/ 2022年06月07日 00:24/ 0 赞/ 415 阅读

相关 .net core 连接 mssql数据库

跟在 .net 里面一样的连接方法，只是不能自动添加引用 dll 1、管理 nuget ，添加以下两个引用(重要) PM> Install-Packa

悠悠/ 2022年06月06日 13:56/ 0 赞/ 345 阅读

相关 NodeJS连接MongoDB

实现nodejs连接mongdo,增删改查各个功能独立 var MongoClient = require('mongodb').MongoClient;

今天药忘吃喽~/ 2022年05月09日 02:24/ 0 赞/ 310 阅读

相关 PHP配置连接MSSql数据库

如果实现了PHP和MySQL链接了，PHP和MSSQL的链接其实很简单；支持MSSQL的本地链接和远程链接，以本地链接为例：机器上安装了MS SQLServe

怼烎@/ 2021年12月13日 14:43/ 0 赞/ 490 阅读