Azure Functions 的 Azure SQL 输入绑定
函数运行时,Azure SQL 输入绑定将从数据库检索数据,并将其传递给函数的输入参数。
有关设置和配置详细信息,请参阅概述。
重要
本文使用选项卡来支持多个版本的 Node.js 编程模型。 v4 模型目前处于预览状态,旨在为 JavaScript 和 TypeScript 开发人员提供更为灵活和直观的体验。 在升级指南中详细了解 v3 和 v4 之间的差异。
示例
可使用以下 C# 模式之一来创建 C# 函数:
- 进程内类库:编译的 C# 函数,该函数在与 Functions 运行时相同的进程中运行。
- 独立工作进程类库:编译的 C# 函数,该函数在独立于运行时的工作进程中运行。 需要独立工作进程才能支持在 LTS 和非 LTS 版 .NET 和 .NET Framework 上运行的 C# 函数。
- C# 脚本:主要在 Azure 门户中创建 C# 函数时使用。
重要
对进程内模型的支持将于 2026 年 11 月 10 日结束。 为获得完全支持,强烈建议将应用迁移到独立工作模型。
GitHub 存储库中提供了更多有关 Azure SQL 输入绑定的示例。
本部分包含以下示例:
这些示例引用 ToDoItem
类和相应的数据库表:
namespace AzureSQL.ToDo
{
public class ToDoItem
{
public Guid Id { get; set; }
public int? order { get; set; }
public string title { get; set; }
public string url { get; set; }
public bool? completed { get; set; }
}
}
CREATE TABLE dbo.ToDo (
[Id] UNIQUEIDENTIFIER PRIMARY KEY,
[order] INT NULL,
[title] NVARCHAR(200) NOT NULL,
[url] NVARCHAR(200) NOT NULL,
[completed] BIT NOT NULL
);
HTTP 触发器,从查询字符串中按 ID 获取行
以下示例演示检索单个记录的 C# 函数。 此函数由 HTTP 请求触发,该请求使用查询字符串来指定 ID。 该 ID 用于使用指定的查询检索 ToDoItem
记录。
注意
HTTP 查询字符串参数区分大小写。
using System.Collections.Generic;
using System.Linq;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Extensions.Sql;
using Microsoft.Azure.Functions.Worker.Http;
namespace AzureSQLSamples
{
public static class GetToDoItem
{
[FunctionName("GetToDoItem")]
public static IActionResult Run(
[HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "gettodoitem")]
HttpRequest req,
[SqlInput(commandText: "select [Id], [order], [title], [url], [completed] from dbo.ToDo where Id = @Id",
commandType: System.Data.CommandType.Text,
parameters: "@Id={Query.id}",
connectionStringSetting: "SqlConnectionString")]
IEnumerable<ToDoItem> toDoItem)
{
return new OkObjectResult(toDoItem.FirstOrDefault());
}
}
}
HTTP 触发器,从路由参数中获取多行
以下示例演示检索查询返回的文档的 C# 函数。 此函数由 HTTP 请求触发,该请求使用路由数据来指定查询参数的值。 该参数在指定的查询中用于筛选 ToDoItem
记录。
using System.Collections.Generic;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Extensions.Sql;
using Microsoft.Azure.Functions.Worker.Http;
namespace AzureSQLSamples
{
public static class GetToDoItems
{
[FunctionName("GetToDoItems")]
public static IActionResult Run(
[HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "gettodoitems/{priority}")]
HttpRequest req,
[SqlInput(commandText: "select [Id], [order], [title], [url], [completed] from dbo.ToDo where [Priority] > @Priority",
commandType: System.Data.CommandType.Text,
parameters: "@Priority={priority}",
connectionStringSetting: "SqlConnectionString")]
IEnumerable<ToDoItem> toDoItems)
{
return new OkObjectResult(toDoItems);
}
}
}
HTTP 触发器,删除行
以下示例演示了一个 C# 函数,该函数使用 HTTP 请求查询参数中的输入执行某个存储过程。
必须在 SQL 数据库上创建存储过程 dbo.DeleteToDo
。 此示例中的存储过程根据参数值删除单个记录或所有记录。
CREATE PROCEDURE [dbo].[DeleteToDo]
@Id NVARCHAR(100)
AS
DECLARE @UID UNIQUEIDENTIFIER = TRY_CAST(@ID AS UNIQUEIDENTIFIER)
IF @UId IS NOT NULL AND @Id != ''
BEGIN
DELETE FROM dbo.ToDo WHERE Id = @UID
END
ELSE
BEGIN
DELETE FROM dbo.ToDo WHERE @ID = ''
END
SELECT [Id], [order], [title], [url], [completed] FROM dbo.ToDo
GO
namespace AzureSQL.ToDo
{
public static class DeleteToDo
{
// delete all items or a specific item from querystring
// returns remaining items
// uses input binding with a stored procedure DeleteToDo to delete items and return remaining items
[FunctionName("DeleteToDo")]
public static IActionResult Run(
[HttpTrigger(AuthorizationLevel.Anonymous, "delete", Route = "DeleteFunction")] HttpRequest req,
ILogger log,
[SqlInput(commandText: "DeleteToDo", commandType: System.Data.CommandType.StoredProcedure,
parameters: "@Id={Query.id}", connectionStringSetting: "SqlConnectionString")]
IEnumerable<ToDoItem> toDoItems)
{
return new OkObjectResult(toDoItems);
}
}
}
GitHub 存储库中提供了更多有关 Azure SQL 输入绑定的示例。
本部分包含以下示例:
这些示例引用了 ToDoItem
类(在单独的文件 ToDoItem.java
中)和相应的数据库表:
package com.function;
import java.util.UUID;
public class ToDoItem {
public UUID Id;
public int order;
public String title;
public String url;
public boolean completed;
public ToDoItem() {
}
public ToDoItem(UUID Id, int order, String title, String url, boolean completed) {
this.Id = Id;
this.order = order;
this.title = title;
this.url = url;
this.completed = completed;
}
}
CREATE TABLE dbo.ToDo (
[Id] UNIQUEIDENTIFIER PRIMARY KEY,
[order] INT NULL,
[title] NVARCHAR(200) NOT NULL,
[url] NVARCHAR(200) NOT NULL,
[completed] BIT NOT NULL
);
HTTP 触发器,获取多行
以下示例演示了由 HTTP 请求触发的 Java 函数中的 SQL 输入绑定,并从查询中读取,然后在 HTTP 响应中返回结果。
package com.function;
import com.microsoft.azure.functions.HttpMethod;
import com.microsoft.azure.functions.HttpRequestMessage;
import com.microsoft.azure.functions.HttpResponseMessage;
import com.microsoft.azure.functions.HttpStatus;
import com.microsoft.azure.functions.annotation.AuthorizationLevel;
import com.microsoft.azure.functions.annotation.FunctionName;
import com.microsoft.azure.functions.annotation.HttpTrigger;
import com.microsoft.azure.functions.sql.annotation.SQLInput;
import java.util.Optional;
public class GetToDoItems {
@FunctionName("GetToDoItems")
public HttpResponseMessage run(
@HttpTrigger(
name = "req",
methods = {HttpMethod.GET},
authLevel = AuthorizationLevel.ANONYMOUS)
HttpRequestMessage<Optional<String>> request,
@SQLInput(
name = "toDoItems",
commandText = "SELECT * FROM dbo.ToDo",
commandType = "Text",
connectionStringSetting = "SqlConnectionString")
ToDoItem[] toDoItems) {
return request.createResponseBuilder(HttpStatus.OK).header("Content-Type", "application/json").body(toDoItems).build();
}
}
HTTP 触发器,从查询字符串中按 ID 获取行
以下示例演示了由 HTTP 请求触发的 Java 函数中的 SQL 输入绑定,并从由查询字符串中的参数筛选的查询中读取,然后在 HTTP 响应中返回行。
public class GetToDoItem {
@FunctionName("GetToDoItem")
public HttpResponseMessage run(
@HttpTrigger(
name = "req",
methods = {HttpMethod.GET},
authLevel = AuthorizationLevel.ANONYMOUS)
HttpRequestMessage<Optional<String>> request,
@SQLInput(
name = "toDoItems",
commandText = "SELECT * FROM dbo.ToDo",
commandType = "Text",
parameters = "@Id={Query.id}",
connectionStringSetting = "SqlConnectionString")
ToDoItem[] toDoItems) {
ToDoItem toDoItem = toDoItems[0];
return request.createResponseBuilder(HttpStatus.OK).header("Content-Type", "application/json").body(toDoItem).build();
}
}
HTTP 触发器,删除行
以下示例演示了由 HTTP 请求触发的 Java 函数中的 SQL 输入绑定,并使用 HTTP 请求查询参数中的输入执行了存储过程。
必须在数据库上创建存储过程 dbo.DeleteToDo
。 此示例中的存储过程根据参数值删除单个记录或所有记录。
CREATE PROCEDURE [dbo].[DeleteToDo]
@Id NVARCHAR(100)
AS
DECLARE @UID UNIQUEIDENTIFIER = TRY_CAST(@ID AS UNIQUEIDENTIFIER)
IF @UId IS NOT NULL AND @Id != ''
BEGIN
DELETE FROM dbo.ToDo WHERE Id = @UID
END
ELSE
BEGIN
DELETE FROM dbo.ToDo WHERE @ID = ''
END
SELECT [Id], [order], [title], [url], [completed] FROM dbo.ToDo
GO
public class DeleteToDo {
@FunctionName("DeleteToDo")
public HttpResponseMessage run(
@HttpTrigger(
name = "req",
methods = {HttpMethod.GET},
authLevel = AuthorizationLevel.ANONYMOUS)
HttpRequestMessage<Optional<String>> request,
@SQLInput(
name = "toDoItems",
commandText = "dbo.DeleteToDo",
commandType = "StoredProcedure",
parameters = "@Id={Query.id}",
connectionStringSetting = "SqlConnectionString")
ToDoItem[] toDoItems) {
return request.createResponseBuilder(HttpStatus.OK).header("Content-Type", "application/json").body(toDoItems).build();
}
}
GitHub 存储库中提供了更多有关 Azure SQL 输入绑定的示例。
本部分包含以下示例:
以下示例引用数据库表:
CREATE TABLE dbo.ToDo (
[Id] UNIQUEIDENTIFIER PRIMARY KEY,
[order] INT NULL,
[title] NVARCHAR(200) NOT NULL,
[url] NVARCHAR(200) NOT NULL,
[completed] BIT NOT NULL
);
HTTP 触发器,获取多行
以下示例演示了由 HTTP 请求触发的 SQL 输入绑定,并从查询中读取,然后在 HTTP 响应中返回结果。
import { app, HttpRequest, HttpResponseInit, input, InvocationContext } from '@azure/functions';
const sqlInput = input.sql({
commandText: 'select [Id], [order], [title], [url], [completed] from dbo.ToDo',
commandType: 'Text',
connectionStringSetting: 'SqlConnectionString',
});
export async function httpTrigger1(request: HttpRequest, context: InvocationContext): Promise<HttpResponseInit> {
context.log('HTTP trigger and SQL input binding function processed a request.');
const toDoItems = context.extraInputs.get(sqlInput);
return {
jsonBody: toDoItems,
};
}
app.http('httpTrigger1', {
methods: ['GET'],
authLevel: 'anonymous',
extraInputs: [sqlInput],
handler: httpTrigger1,
});
const { app, input } = require('@azure/functions');
const sqlInput = input.sql({
commandText: 'select [Id], [order], [title], [url], [completed] from dbo.ToDo',
commandType: 'Text',
connectionStringSetting: 'SqlConnectionString',
});
app.http('httpTrigger1', {
methods: ['GET'],
authLevel: 'anonymous',
extraInputs: [sqlInput],
handler: (request, context) => {
context.log('HTTP trigger and SQL input binding function processed a request.');
const toDoItems = context.extraInputs.get(sqlInput);
return {
jsonBody: toDoItems,
};
},
});
import { app, HttpRequest, HttpResponseInit, input, InvocationContext } from '@azure/functions';
const sqlInput = input.sql({
commandText: 'select [Id], [order], [title], [url], [completed] from dbo.ToDo where Id = @Id',
commandType: 'Text',
parameters: '@Id={Query.id}',
connectionStringSetting: 'SqlConnectionString',
});
export async function httpTrigger1(request: HttpRequest, context: InvocationContext): Promise<HttpResponseInit> {
context.log('HTTP trigger and SQL input binding function processed a request.');
const toDoItem = context.extraInputs.get(sqlInput);
return {
jsonBody: toDoItem,
};
}
app.http('httpTrigger1', {
methods: ['GET'],
authLevel: 'anonymous',
extraInputs: [sqlInput],
handler: httpTrigger1,
});
const { app, input } = require('@azure/functions');
const sqlInput = input.sql({
commandText: 'select [Id], [order], [title], [url], [completed] from dbo.ToDo where Id = @Id',
commandType: 'Text',
parameters: '@Id={Query.id}',
connectionStringSetting: 'SqlConnectionString',
});
app.http('httpTrigger1', {
methods: ['GET'],
authLevel: 'anonymous',
extraInputs: [sqlInput],
handler: (request, context) => {
context.log('HTTP trigger and SQL input binding function processed a request.');
const toDoItem = context.extraInputs.get(sqlInput);
return {
jsonBody: toDoItem,
};
},
});
HTTP 触发器,删除行
以下示例演示了由 HTTP 请求触发的 SQL 输入绑定,并使用 HTTP 请求查询参数中的输入执行了存储过程。
必须在数据库上创建存储过程 dbo.DeleteToDo
。 此示例中的存储过程根据参数值删除单个记录或所有记录。
CREATE PROCEDURE [dbo].[DeleteToDo]
@Id NVARCHAR(100)
AS
DECLARE @UID UNIQUEIDENTIFIER = TRY_CAST(@ID AS UNIQUEIDENTIFIER)
IF @UId IS NOT NULL AND @Id != ''
BEGIN
DELETE FROM dbo.ToDo WHERE Id = @UID
END
ELSE
BEGIN
DELETE FROM dbo.ToDo WHERE @ID = ''
END
SELECT [Id], [order], [title], [url], [completed] FROM dbo.ToDo
GO
import { app, HttpRequest, HttpResponseInit, input, InvocationContext } from '@azure/functions';
const sqlInput = input.sql({
commandText: 'DeleteToDo',
commandType: 'StoredProcedure',
parameters: '@Id={Query.id}',
connectionStringSetting: 'SqlConnectionString',
});
export async function httpTrigger1(request: HttpRequest, context: InvocationContext): Promise<HttpResponseInit> {
context.log('HTTP trigger and SQL input binding function processed a request.');
const toDoItems = context.extraInputs.get(sqlInput);
return {
jsonBody: toDoItems,
};
}
app.http('httpTrigger1', {
methods: ['GET'],
authLevel: 'anonymous',
extraInputs: [sqlInput],
handler: httpTrigger1,
});
const { app, input } = require('@azure/functions');
const sqlInput = input.sql({
commandText: 'DeleteToDo',
commandType: 'StoredProcedure',
parameters: '@Id={Query.id}',
connectionStringSetting: 'SqlConnectionString',
});
app.http('httpTrigger1', {
methods: ['GET'],
authLevel: 'anonymous',
extraInputs: [sqlInput],
handler: (request, context) => {
context.log('HTTP trigger and SQL input binding function processed a request.');
const toDoItems = context.extraInputs.get(sqlInput);
return {
jsonBody: toDoItems,
};
},
});
GitHub 存储库中提供了更多有关 Azure SQL 输入绑定的示例。
本部分包含以下示例:
以下示例引用数据库表:
CREATE TABLE dbo.ToDo (
[Id] UNIQUEIDENTIFIER PRIMARY KEY,
[order] INT NULL,
[title] NVARCHAR(200) NOT NULL,
[url] NVARCHAR(200) NOT NULL,
[completed] BIT NOT NULL
);
HTTP 触发器,获取多行
以下示例演示了由 HTTP 请求触发的 function.json 文件和 PowerShell 函数中的 SQL 输入绑定,并从查询中读取,然后在 HTTP 响应中返回结果。
下面是 function.json 文件中的绑定数据:
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
},
{
"name": "todoItems",
"type": "sql",
"direction": "in",
"commandText": "select [Id], [order], [title], [url], [completed] from dbo.ToDo",
"commandType": "Text",
"connectionStringSetting": "SqlConnectionString"
}
配置部分解释了这些属性。
下面是 run.ps1
文件中的函数的示例 PowerShell 代码:
using namespace System.Net
param($Request, $todoItems)
Write-Host "PowerShell function with SQL Input Binding processed a request."
Push-OutputBinding -Name res -Value ([HttpResponseContext]@{
StatusCode = [System.Net.HttpStatusCode]::OK
Body = $todoItems
})
HTTP 触发器,从查询字符串中按 ID 获取行
以下示例演示了由 HTTP 请求触发的 PowerShell 函数中的 SQL 输入绑定,并从由查询字符串中的参数筛选的查询中读取,然后在 HTTP 响应中返回行。
下面是 function.json 文件中的绑定数据:
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
},
{
"name": "todoItem",
"type": "sql",
"direction": "in",
"commandText": "select [Id], [order], [title], [url], [completed] from dbo.ToDo where Id = @Id",
"commandType": "Text",
"parameters": "@Id = {Query.id}",
"connectionStringSetting": "SqlConnectionString"
}
配置部分解释了这些属性。
下面是 run.ps1
文件中的函数的示例 PowerShell 代码:
using namespace System.Net
param($Request, $todoItem)
Write-Host "PowerShell function with SQL Input Binding processed a request."
Push-OutputBinding -Name res -Value ([HttpResponseContext]@{
StatusCode = [System.Net.HttpStatusCode]::OK
Body = $todoItem
})
HTTP 触发器,删除行
以下示例演示了由 HTTP 请求触发的 function.json 文件和 PowerShell 函数中的 SQL 输入绑定,并使用 HTTP 请求查询参数中的输入执行了存储过程。
必须在数据库上创建存储过程 dbo.DeleteToDo
。 此示例中的存储过程根据参数值删除单个记录或所有记录。
CREATE PROCEDURE [dbo].[DeleteToDo]
@Id NVARCHAR(100)
AS
DECLARE @UID UNIQUEIDENTIFIER = TRY_CAST(@ID AS UNIQUEIDENTIFIER)
IF @UId IS NOT NULL AND @Id != ''
BEGIN
DELETE FROM dbo.ToDo WHERE Id = @UID
END
ELSE
BEGIN
DELETE FROM dbo.ToDo WHERE @ID = ''
END
SELECT [Id], [order], [title], [url], [completed] FROM dbo.ToDo
GO
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name": "req",
"methods": [
"get"
]
},
{
"type": "http",
"direction": "out",
"name": "res"
},
{
"name": "todoItems",
"type": "sql",
"direction": "in",
"commandText": "DeleteToDo",
"commandType": "StoredProcedure",
"parameters": "@Id = {Query.id}",
"connectionStringSetting": "SqlConnectionString"
}
配置部分解释了这些属性。
下面是 run.ps1
文件中的函数的示例 PowerShell 代码:
using namespace System.Net
param($Request, $todoItems)
Write-Host "PowerShell function with SQL Input Binding processed a request."
Push-OutputBinding -Name res -Value ([HttpResponseContext]@{
StatusCode = [System.Net.HttpStatusCode]::OK
Body = $todoItems
})
GitHub 存储库中提供了更多有关 Azure SQL 输入绑定的示例。
本部分包含以下示例:
以下示例引用数据库表:
CREATE TABLE dbo.ToDo (
[Id] UNIQUEIDENTIFIER PRIMARY KEY,
[order] INT NULL,
[title] NVARCHAR(200) NOT NULL,
[url] NVARCHAR(200) NOT NULL,
[completed] BIT NOT NULL
);
HTTP 触发器,获取多行
以下示例演示了由 HTTP 请求触发的 function.json 文件和 Python 函数中的 SQL 输入绑定,并从查询中读取,然后在 HTTP 响应中返回结果。
以下是 function_app.py 文件的示例 python 代码:
import json
import logging
import azure.functions as func
from azure.functions.decorators.core import DataType
app = func.FunctionApp()
@app.function_name(name="GetToDo")
@app.route(route="gettodo")
@app.sql_input(arg_name="todo",
command_text="select [Id], [order], [title], [url], [completed] from dbo.ToDo",
command_type="Text",
connection_string_setting="SqlConnectionString")
def get_todo(req: func.HttpRequest, todo: func.SqlRowList) -> func.HttpResponse:
rows = list(map(lambda r: json.loads(r.to_json()), todo))
return func.HttpResponse(
json.dumps(rows),
status_code=200,
mimetype="application/json"
)
HTTP 触发器,从查询字符串中按 ID 获取行
以下示例演示了由 HTTP 请求触发的 Python 函数中的 SQL 输入绑定,并从由查询字符串中的参数筛选的查询中读取,然后在 HTTP 响应中返回行。
以下是 function_app.py 文件的示例 python 代码:
import json
import logging
import azure.functions as func
from azure.functions.decorators.core import DataType
app = func.FunctionApp()
@app.function_name(name="GetToDo")
@app.route(route="gettodo/{id}")
@app.sql_input(arg_name="todo",
command_text="select [Id], [order], [title], [url], [completed] from dbo.ToDo where Id = @Id",
command_type="Text",
parameters="@Id={id}",
connection_string_setting="SqlConnectionString")
def get_todo(req: func.HttpRequest, todo: func.SqlRowList) -> func.HttpResponse:
rows = list(map(lambda r: json.loads(r.to_json()), todo))
return func.HttpResponse(
json.dumps(rows),
status_code=200,
mimetype="application/json"
)
HTTP 触发器,删除行
以下示例演示了由 HTTP 请求触发的 function.json 文件和 Python 函数中的 SQL 输入绑定,并使用 HTTP 请求查询参数中的输入执行了存储过程。
必须在数据库上创建存储过程 dbo.DeleteToDo
。 此示例中的存储过程根据参数值删除单个记录或所有记录。
CREATE PROCEDURE [dbo].[DeleteToDo]
@Id NVARCHAR(100)
AS
DECLARE @UID UNIQUEIDENTIFIER = TRY_CAST(@ID AS UNIQUEIDENTIFIER)
IF @UId IS NOT NULL AND @Id != ''
BEGIN
DELETE FROM dbo.ToDo WHERE Id = @UID
END
ELSE
BEGIN
DELETE FROM dbo.ToDo WHERE @ID = ''
END
SELECT [Id], [order], [title], [url], [completed] FROM dbo.ToDo
GO
以下是 function_app.py 文件的示例 python 代码:
import json
import logging
import azure.functions as func
from azure.functions.decorators.core import DataType
app = func.FunctionApp()
@app.function_name(name="DeleteToDo")
@app.route(route="deletetodo/{id}")
@app.sql_input(arg_name="todo",
command_text="DeleteToDo",
command_type="StoredProcedure",
parameters="@Id={id}",
connection_string_setting="SqlConnectionString")
def get_todo(req: func.HttpRequest, todo: func.SqlRowList) -> func.HttpResponse:
rows = list(map(lambda r: json.loads(r.to_json()), todo))
return func.HttpResponse(
json.dumps(rows),
status_code=200,
mimetype="application/json"
)
属性
C# 库使用 SqlAttribute 属性来声明函数中的 SQL 绑定,该函数具有以下属性:
Attribute 属性 | 说明 |
---|---|
CommandText | 必需。 由绑定执行的存储过程的 Transact-SQL 查询命令或名称。 |
ConnectionStringSetting | 必需。 应用设置的名称,其中包含要对其执行查询或存储过程的数据库的连接字符串。 该值不是实际的连接字符串,必须解析为环境变量名称。 |
CommandType | 必需。 CommandType 值,对于查询为 Text,对于存储过程为 StoredProcedure。 |
参数 | 可选。 在执行期间作为单个字符串传递给命令的零个或多个参数值。 必须遵循格式 @param1=param1,@param2=param2 。 参数名和参数值都不能包含逗号 (, ) 或等号 (= )。 |
批注
在 Java 函数运行时库中,对其值来自 Azure SQL 的参数使用 @SQLInput
注释 (com.microsoft.azure.functions.sql.annotation.SQLInput
)。 此批注支持以下元素:
元素 | 说明 |
---|---|
commandText | 必需。 由绑定执行的存储过程的 Transact-SQL 查询命令或名称。 |
connectionStringSetting | 必需。 应用设置的名称,其中包含要对其执行查询或存储过程的数据库的连接字符串。 该值不是实际的连接字符串,必须解析为环境变量名称。 |
commandType | 必需。 CommandType 值,对于查询为 Text,对于存储过程为 StoredProcedure。 |
name | 必需。 函数绑定的唯一名称。 |
parameters | 可选。 在执行期间作为单个字符串传递给命令的零个或多个参数值。 必须遵循格式 @param1=param1,@param2=param2 。 参数名和参数值都不能包含逗号 (, ) 或等号 (= )。 |
配置
下表说明了可以在传递给 input.sql()
方法的 options
对象上设置的属性。
properties | 说明 |
---|---|
commandText | 必需。 由绑定执行的存储过程的 Transact-SQL 查询命令或名称。 |
connectionStringSetting | 必需。 应用设置的名称,其中包含要对其执行查询或存储过程的数据库的连接字符串。 该值不是实际的连接字符串,必须解析为环境变量名称。 连接字符串值中的可选关键字可用于优化 SQL 绑定连接。 |
commandType | 必需。 CommandType 值,对于查询为 Text,对于存储过程为 StoredProcedure。 |
parameters | 可选。 在执行期间作为单个字符串传递给命令的零个或多个参数值。 必须遵循格式 @param1=param1,@param2=param2 。 参数名和参数值都不能包含逗号 (, ) 或等号 (= )。 |
配置
下表解释了在 function.json 文件中设置的绑定配置属性。
“function.json”属性 | 说明 |
---|---|
type | 必需。 必须设置为 sql 。 |
direction | 必需。 必须设置为 in 。 |
name | 必需。 表示函数代码中的查询结果的变量的名称。 |
commandText | 必需。 由绑定执行的存储过程的 Transact-SQL 查询命令或名称。 |
connectionStringSetting | 必需。 应用设置的名称,其中包含要对其执行查询或存储过程的数据库的连接字符串。 该值不是实际的连接字符串,必须解析为环境变量名称。 连接字符串值中的可选关键字可用于优化 SQL 绑定连接。 |
commandType | 必需。 CommandType 值,对于查询为 Text,对于存储过程为 StoredProcedure。 |
parameters | 可选。 在执行期间作为单个字符串传递给命令的零个或多个参数值。 必须遵循格式 @param1=param1,@param2=param2 。 参数名和参数值都不能包含逗号 (, ) 或等号 (= )。 |
在本地开发时,需要将应用程序设置添加到 Values
集合中的 local.settings.json 文件中。
使用情况
属性的构造函数采用 SQL 命令文本、命令类型、参数和连接字符串设置名称。 命令可以是命令类型为 System.Data.CommandType.Text
的 Transact-SQL (T-SQL) 查询,也可以是命令类型为 System.Data.CommandType.StoredProcedure
的存储过程名称。 连接字符串设置名称对应于应用程序设置(本地开发为 local.settings.json
),其中包含 Azure SQL 或 SQL Server 实例的连接字符串。
输入绑定所执行的查询在 Microsoft.Data.SqlClient 中参数化,以减少传入绑定的参数值中的 SQL 注入风险。
如果在执行 SQL 输入绑定时发生异常,则不会执行函数代码。 这可能会导致返回错误代码,例如 HTTP 触发器返回 500 错误代码。