2

我已成功连接我的数据库并运行查询。我可以在终端中看到我的查询结果。但是我仍然看不到语句体的响应输出。它应该给我“无法建立连接”。如果我无法连接，如果我已成功执行查询，则“连接到数据库成功”，如果无法执行查询，则“连接到数据库失败”。

我可以就我在这里实际缺少的东西请求一些帮助吗？以下是我的 function.js 和 index.js 文件。

我的function.js

  "bindings": [
    {
      "authLevel": "function",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": [
        "get",
        "post"
      ]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "res"
    }
  ]
}

我的 index.js：

var Request = require('tedious').Request;

//const { Connection, req } = require("tedious");
var sql = require("mssql");

// config for your database
var config = {
    user: '<userName>',
    password: '<password>'',
    server: '<SQLDBName>.database.windows.net',
    database: '<DB name',
    port: 1433
};

var connection = new Connection(config);
module.exports =  async function(context) {
    context.log('JavaScript HTTP trigger function processed a request.');

    var conn = new sql.ConnectionPool(config);
    var request = new sql.Request(conn);

    //conn.connect(function (err){
    connection.on('connect', function(err) {
        if (err) {
            context.log(err);

            context.res = {
                status: 500,
                body: "Unable to establish a connection."
            };
            context.done();
        }else {
            exStatement();
        }
    });

    function exStatement() {

        request = new Request.query("SELECT * FROM dbo.dbTable", function (err, recordset) {
            if (err) {
                context.log(err);
                context.res ={
                    status : 400,
                    body : "Failed to connect to Database"
                };
                context.done();
                console.log(err);
            }
            else {
                //queryDatabase();
                context.log(recordset);
                context.res ={
                    status : 200,
                    body : "Connected to Database Successfully",
                };
                context.done();
                console.log(recordset);
            }
            conn.close();
        });
        connection.execSql(request);
    }
};
4

0 回答 0