26

该问题重复了一些较旧的问题,但从那时起情况可能已经改变。

是否有一些官方支持从 Node.js 连接到 SQL Server(例如来自 MS 的官方库)?或者至少是一些适用于生产级应用程序的维护良好的第三方库?

我们通常使用 ASP.NET MVC/SQL Server 组合,但目前我有一个任务,express/Node.js 似乎更合适(我想玩一些新的东西),所以问题是我们是否可以依赖于 Node.js 和 SQL Server 的交互。

UPD:微软似乎终于发布了官方驱动:https ://github.com/WindowsAzure/node-sqlserver

4

6 回答 6

28

这主要是为未来的读者准备的。由于问题(至少是标题)集中在“从节点 js 连接到 sql server 数据库”,我想介绍一下“mssql”节点模块。

目前,我们有一个稳定版本的用于 NodeJs 的 Microsoft SQL Server 驱动程序(“msnodesql”),可在此处获取:https ://www.npmjs.com/package/msnodesql 。虽然它在与 Microsoft SQL Server 数据库的本机集成方面做得很好(比任何其他节点模块),但有几件事需要注意。

“msnodesql”需要在主机上安装一些先决条件(如 python、VC++、SQL 本机客户端等)。这使您的“节点”应用程序“Windows”依赖。如果您对基于“Windows”的部署感到满意,那么使用“msnodesql”是最好的。

另一方面,还有另一个名为“mssql”的模块(可在此处获得https://www.npmjs.com/package/mssql),它可以根据配置与“乏味”或“msnodesql”一起使用。虽然这个模块可能没有“msnodesql”那么全面,但它几乎解决了大部分需求。

如果您想从“mssql”开始,我看到了一个简单直接的视频,它解释了如何在此处使用 NodeJs 连接到 Microsoft SQL Server 数据库:https ://www.youtube.com/watch?v=MLcXfRH1YzE

上述视频的源代码可在此处获得:http: //techcbt.com/Post/341/Node-js-basic-programming-tutorials-videos/how-to-connect-to-microsoft-sql-server-using-节点js

以防万一,如果上面的链接不起作用,我在这里包括源代码:

var sql = require("mssql");

var dbConfig = {
    server: "localhost\\SQL2K14",
    database: "SampleDb",
    user: "sa",
    password: "sql2014",
    port: 1433
};

function getEmp() {
    var conn = new sql.Connection(dbConfig);
    
    conn.connect().then(function () {
        var req = new sql.Request(conn);
        req.query("SELECT * FROM emp").then(function (recordset) {
            console.log(recordset);
            conn.close();
        })
        .catch(function (err) {
            console.log(err);
            conn.close();
        });        
    })
    .catch(function (err) {
        console.log(err);
    });

    //--> another way
    //var req = new sql.Request(conn);
    //conn.connect(function (err) {
    //    if (err) {
    //        console.log(err);
    //        return;
    //    }
    //    req.query("SELECT * FROM emp", function (err, recordset) {
    //        if (err) {
    //            console.log(err);
    //        }
    //        else { 
    //            console.log(recordset);
    //        }
    //        conn.close();
    //    });
    //});

}

getEmp();

上面的代码很容易解释。我们定义了 db 连接参数(在“dbConfig”JS 对象中),然后使用“Connection”对象连接到 SQL Server。为了执行“SELECT”语句,在这种情况下,它使用“Request”对象,该对象在内部与“Connection”对象一起使用。该代码解释了使用基于“承诺”和“回调”的执行的两种风格。

上面的源代码只解释了连接到 sql server 数据库和执行 SELECT 查询。您可以通过以下“mssql”节点的文档轻松将其提升到一个新的水平:https ://www.npmjs.com/package/mssql

更新: 这里有一个使用纯 Node.js REST 标准(使用 Microsoft SQL Server)进行 CRUD 操作的新视频:https ://www.youtube.com/watch?v=xT2AvjQ7q9E 。这是一个很棒的视频,它从头开始解释一切(它有很多代码,在这里解释/复制整个代码不会那么令人愉快)

于 2015-08-13T13:15:33.353 回答
14

我不确定您是否看到此Node JS 的 MS SQL 模块列表

如果可能,请在使用后分享您的经验。

祝你好运

于 2012-04-25T10:07:36.680 回答
7

我们刚刚发布了用于 SQL Server 连接的 Node.JS 预览驱动程序。您可以在此处找到它: Introducing the Microsoft Driver for Node.JS for SQL Server

驱动程序支持回调(这里,我们连接到本地 SQL Server 实例):

// Query with explicit connection
var sql = require('node-sqlserver');
var conn_str = "Driver={SQL Server Native Client 11.0};Server=(local);Database=AdventureWorks2012;Trusted_Connection={Yes}";

sql.open(conn_str, function (err, conn) {
    if (err) {
        console.log("Error opening the connection!");
        return;
    }
    conn.queryRaw("SELECT TOP 10 FirstName, LastName FROM Person.Person", function (err, results) {
        if (err) {
            console.log("Error running query!");
            return;
        }
        for (var i = 0; i < results.rows.length; i++) {
            console.log("FirstName: " + results.rows[i][0] + " LastName: " + results.rows[i][1]);
        }
    });
});

或者,您可以使用事件(这里,我们连接到 SQL Azure aka Windows Azure SQL 数据库):

// Query with streaming
var sql = require('node-sqlserver');
var conn_str = "Driver={SQL Server Native Client 11.0};Server={tcp:servername.database.windows.net,1433};UID={username};PWD={Password1};Encrypt={Yes};Database={databasename}";

var stmt = sql.query(conn_str, "SELECT FirstName, LastName FROM Person.Person ORDER BY LastName OFFSET 0 ROWS FETCH NEXT 10 ROWS ONLY");
stmt.on('meta', function (meta) { console.log("We've received the metadata"); });
stmt.on('row', function (idx) { console.log("We've started receiving a row"); });
stmt.on('column', function (idx, data, more) { console.log(idx + ":" + data);});
stmt.on('done', function () { console.log("All done!"); });
stmt.on('error', function (err) { console.log("We had an error :-( " + err); });

如果遇到任何问题,请在 Github 上提出问题:https ://github.com/windowsazure/node-sqlserver/issues

于 2012-06-08T00:16:21.393 回答
2

npm 上有一个模块叫做mssqlhelper

您可以通过以下方式将其安装到您的项目中npm i mssqlhelper

连接和执行查询的示例:

var db = require('./index');

db.config({
    host: '192.168.1.100'
    ,port: 1433
    ,userName: 'sa'
    ,password: '123'
    ,database:'testdb'
});

db.query(
    'select @Param1 Param1,@Param2 Param2'
    ,{
         Param1: { type : 'NVarChar', size: 7,value : 'myvalue' }
         ,Param2: { type : 'Int',value : 321 }
    }
    ,function(res){
        if(res.err)throw new Error('database error:'+res.err.msg);
        var rows = res.tables[0].rows;
        for (var i = 0; i < rows.length; i++) {
            console.log(rows[i].getValue(0),rows[i].getValue('Param2'));
        }
    }
);

你可以在这里阅读更多关于它的信息:https ://github.com/play175/mssqlhelper

:o)

于 2012-04-25T06:37:14.107 回答
0

msnodesql对我来说效果很好。这是一个示例:

var mssql = require('msnodesql'), 
    express = require('express'),
    app = express(),
    nconf = require('nconf')

nconf.env()
     .file({ file: 'config.json' });

var conn = nconf.get("SQL_CONN");   
var conn_str = "Driver={SQL Server Native Client 11.0};Server=server.name.here;Database=Product;Trusted_Connection={Yes}";

app.get('/api/brands', function(req, res){
    var data = [];
    var jsonObject = {};    

    mssql.open(conn_str, function (err, conn) {
        if (err) {
            console.log("Error opening the connection!");
            return;
        }
        conn.queryRaw("dbo.storedproc", function (err, results) {
        if(err) {
                   console.log(err);
                   res.send(500, "Cannot retrieve records.");
                }
       else {
             //res.json(results);

             for (var i = 0; i < results.rows.length; i++) {
                 var jsonObject = new Object()
                 for (var j = 0; j < results.meta.length; j++) { 

                    paramName = results.meta[j].name;
                    paramValue = results.rows[i][j]; 
                    jsonObject[paramName] = paramValue;

                    }
                    data.push(jsonObject);  //This is a js object we are jsonizing not real json until res.send             
            } 

                res.send(data);

            }       
        });
    });
});
于 2014-08-16T22:43:18.320 回答
-2
//start the program
var express = require('express');
var app = express();

app.get('/', function (req, res) {

    var sql = require("mssql");

    // config for your database
    var config = {
        user: 'datapullman',
        password: 'system',
        server: 'localhost', 
        database: 'chat6' 
    };

    // connect to your database
    sql.connect(config, function (err) {

        if (err) console.log(err);

        // create Request object
        var request = new sql.Request();

        // query to the database and get the records

        request.query("select * From emp", function (err, recordset) {            
            if  (err) console.log(err)

            // send records as a response
            res.send(recordset);

        });
    });
});

var server = app.listen(5000, function () {
    console.log('Server is running..');
});

//在数据库中创建一个表作为emp(我已经创建为chat6)

// programs ends here

//将其保存为 app.js 并作为节点 app.js 运行 //在浏览器中打开为 localhost:5000

于 2018-04-27T10:41:53.547 回答