Azure SQL 数据库未更新数据

Question

我创建了一个 nodejs azure web 应用程序，它运行得非常好， 现在我想将我的帖子数据放到 azure MS SQL DB 中，我为此创建了一个代码，但是 sql db 没有用 POST 数据更新，谁能帮我解决这个问题。

var express = require('express');
var bodyParser = require('body-parser');
var sql = require('mssql');
var port = 8080;
var app = express();`enter code here`
var path = require('path');


//CORS Middleware
app.use(function(req,res,next){
    res.header("Access-Control-Allow-Origin","*");
    res.header("Access-Control-Allow-Methods","GET,HEAD,POST,PUT,OPTIONS");
    res.header("Access-Control-Allow-Headers","Origin,X-Requested-With,contentType,Content-Type,Accept,Authorization");
    next();
});


app.set('view engine', 'ejs');
app.set('views', path.join(__dirname, 'views'));

app.use(bodyParser());
app.use(bodyParser.urlencoded({extended: false}));
app.use(express.static(path.join(__dirname, 'public')));




//setup database connection
var dbconfig = {
    user:"username",
    password:"password",
    server : "server_name",
    database: "db_name"  
};


// ConnectionPool


//connect to the database 
var executeQuery = function(res,query){
    sql.connect(dbconfig,function(err){
        if(err){
            console.log("there is a database connection error -> "+err);
            res.send(err);
        }
        else{
            // create request object
            var request = new sql.Request();
            // query to the database
            request.query(query,function(err,result){
                if(err){
                    console.log("error while querying database -> "+err);
                    res.send(err);
                }
                else{
                    res.send(result);
                    sql.close();
                }
            });
        }
    });
}



app.get('/', function(req, res){
    res.render('index', {
        title: 'Hello World',
        showTitle:true,
        people: ['John', 'Steve', 'Jose']
    });
});



app.get('/index', function(req, res){
    res.render('index');
});

app.get('/contact', function(req, res){
    res.render('contact');
});




app.post('/my_user', function(req, res){
    //return res.send(req.body);

    console.log(req.body.email + ' and ' + req.body.mobile);

    var parameters = [
            { name: 'email', sqltype: sql.NVarChar, value: req.body.email},
            { name: 'mobile', sqltype: sql.NInt, value: req.body.mobile},
            { name: 'msg', sqltype: sql.NVarChar,  value: req.body.msg},
     ];

    var query = "insert into forMyCV values(@email, @mobile, @msg);";
        executeQuery (res, query, parameters);

    return res.redirect('/');   
});

app.listen(port);
console.log('Server started on port '+port);

谁能帮我解释一下。为什么会这样

Answer 1

恐怕我测试过你的代码有两个问题。

1. 根据下图 Azure 门户上 Azure SQL 数据库的标签Connection strings，连接字符串中也有一个必填参数encrypt=true，如JDBC等。

   因此，使用 mssql 的 Azure SQL 数据库的正确 config 应如下所示。

   const config = {
       user: '<your username>@<your sql server name>',
       password: '<your password>',
       server: '<your sql server name>.database.windows.net', // You can use 'localhost\\instance' to connect to named instance
       database: '<your database name>',
   
       options: {
           encrypt: true // Use this if you're on Windows Azure
       }
   }
   

   不能忽略必需的options: {encrypt: true} 属性。否则会报错。

   there is a database connection error -> ConnectionError: Server requires encryption, set 'encrypt' config option to true.
   (node:665784) UnhandledPromiseRejectionWarning: ReferenceError: res is not defined
   at D:\projects\node\express-demo\mssql-query-demo.js:43:13
   at _poolCreate.then.catch.err (D:\projects\node\express-demo\node_modules\mssql\lib\base.js:287:7)
   at process._tickCallback (internal/process/next_tick.js:68:7)
   (node:665784) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). (rejection id: 1)
   (node:665784) [DEP0018] DeprecationWarning: Unhandled promise rejections are deprecated. In the future, promise rejections that are not handled will terminate the Node.js process with a non-zero exit code.
   

2. executeQuery 函数定义了两个参数res 和query，但它在app.post('/my_user') 的回调function(req, res) 中与三个参数executeQuery (res, query, parameters); 一起使用。它不会导致任何错误，只是忽略不匹配的最后一个参数parameters。

希望对你有帮助。

---

更新：重新定义 executeQuery 函数如下。

var executeQuery = function(res,query, parameters){
    sql.connect(dbconfig,function(err){
        if(err){
            console.log("there is a database connection error -> "+err);
            res.send(err);
        }
        else{
            // create request object
            var request = new sql.Request();
            // query to the database
            parameters.map(item => {
                request.input(item.name, item.sqltype, item.value);
            })
            request.query(query,function(err,result){
                if(err){
                    console.log("error while querying database -> "+err);
                    res.send(err);
                }
                else{
                    res.send(result);
                    sql.close();
                }
            });
        }
    });
}