使用 Javascript 将 SQL Server 数据库连接与 Azure Functions 重用

Question

我找不到有关如何通过用 Javascript 编写的 Azure 函数管理 SQL 服务器数据库连接的明确信息。

我正在使用连接池代码 -

const pool = new sql.ConnectionPool(config);
const poolConnect = pool.connect();

pool.on('error', err => {
    // ... error handler
})

我正在使用执行查询的函数中的 poolConnect 对象

export const selectQuery = function() {
  const connectionPool = await mssqlDBPoolConnect;
  const request = connectionPool.request();
  await request.query('select query');
}

那么如何在所有 azure 函数中使用相同的连接池。

Answer 1

在根路径下创建两个名为 config 和 toolkit 的文件夹。将您的db.js 放入config 文件夹中，并创建一个sql 帮助类以将名为sqltools.js 的函数导出到工具包文件夹中。

因此，您可以通过在函数代码中调用sqltools 来使用相同的连接池。此步骤可帮助您减少在每个函数中使用相同的代码。

尝试使用下面的db.js 代码：

const sql = require('mssql')
const config = {
    user: 'yourusername',
    password: 'yourpassword',
    server: 'yoursqlserver.database.windows.net', // You can use 'localhost\\instance' to connect to named instance. Do not use TCP.
    database: 'yourdb',
    "options": {
        "encrypt": true,
        "enableArithAbort": true
    }
}

const poolPromise = new sql.ConnectionPool(config)
  .connect()
  .then(pool => {
    console.log('Connected to MSSQL')
    return pool
  })
  .catch(err => console.log('Database Connection Failed! Bad Config: ', err))

module.exports = {
  sql, poolPromise
}

sqltools.js 类：

const { poolPromise } = require('../config/db')

module.exports.sqltools = {
    ExecSqlQuery : async function(arg){
        const pool = await poolPromise
        //SELECT *FROM SYSOBJECTS WHERE xtype = \'U\'
        var result=null;
        try {
            result = await pool.request()
            .query(arg)
        } catch (error) {
            console.log(error.message);
        } 
        return result;
    },
    ExecProce : function (arg2, arg3, arg4){
        console.log(arg2,arg3,arg4);
    }
}

这是我的 HttpTrigger1 index.js 代码，调用 ExecSqlQuery 执行 sqlstrings：

const { sqltools } = require('../toolkit/sqltools');

module.exports = async function (context, req) {
    context.log('JavaScript HTTP trigger function processed a request.');
    var result=null;
    try {
        // call ExecSqlQuery func
        result = await sqltools.ExecSqlQuery('SELECT *FROM SYSOBJECTS WHERE xtype = \'U\'');
    } catch (error) {
        console.log(error.message);
    } 
    
    const responseMessage ="Func 1 Result : TableName= " + result.recordset[0].name;

    context.res = {
        // status: 200, /* Defaults to 200 */
        body: responseMessage
    };
}