Merge pull request Azure#9 from Azure/triggerbinding

Preliminary Design of Trigger Binding

Author: sophiatev

samples/SqlExtensionSamples/InputBindingSamples/GetProducts.cs

@@ -1,4 +1,7 @@
-using Microsoft.AspNetCore.Http;
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.WebJobs;
 using Microsoft.Azure.WebJobs.Extensions.Http;
@@ -17,7 +20,7 @@ public static IActionResult Run(
             [Sql("select * from Products where Cost = @Cost",
                 CommandType = System.Data.CommandType.Text,
                 Parameters = "@Cost={cost}",
-                ConnectionStringSetting = "SQLServerAuthentication")]
+                ConnectionStringSetting = "SqlConnectionString")]
             IEnumerable<Product> products)
         {
             return (ActionResult)new OkObjectResult(products);

samples/SqlExtensionSamples/InputBindingSamples/GetProductsAsyncEnumerable.cs

@@ -1,4 +1,7 @@
-using Microsoft.AspNetCore.Http;
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.WebJobs;
 using Microsoft.Azure.WebJobs.Extensions.Http;
@@ -13,14 +16,14 @@ public static class GetProductsAsyncEnumerable
         [FunctionName("GetProductsAsyncEnumerable")]
         public static async Task<IActionResult> Run(
             [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "getproducts-async/{cost}")]
-             HttpRequest req,
+            HttpRequest req,
             [Sql("select * from Products where cost = @Cost",
                  CommandType = System.Data.CommandType.Text,
                  Parameters = "@Cost={cost}",
-                 ConnectionStringSetting = "SQLServerAuthentication")]
+                 ConnectionStringSetting = "SqlConnectionString")]
              IAsyncEnumerable<Product> products)
         {
-            var enumerator = products.GetAsyncEnumerator();
+            IAsyncEnumerator<Product> enumerator = products.GetAsyncEnumerator();
             var productList = new List<Product>();
             while (await enumerator.MoveNextAsync())
             {

samples/SqlExtensionSamples/InputBindingSamples/GetProductsNameEmpty.cs

@@ -1,4 +1,7 @@
-using Microsoft.AspNetCore.Http;
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.WebJobs;
 using Microsoft.Azure.WebJobs.Extensions.Http;
@@ -17,7 +20,7 @@ public static IActionResult Run(
             [Sql("select * from Products where Cost = @Cost and Name = @Name",
                 CommandType = System.Data.CommandType.Text,
                 Parameters = "@Cost={cost},@Name=",
-                ConnectionStringSetting = "SQLServerAuthentication")]
+                ConnectionStringSetting = "SqlConnectionString")]
             IEnumerable<Product> products)
         {
             return (ActionResult)new OkObjectResult(products);

samples/SqlExtensionSamples/InputBindingSamples/GetProductsNameNull.cs

@@ -1,4 +1,7 @@
-using Microsoft.AspNetCore.Http;
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.WebJobs;
 using Microsoft.Azure.WebJobs.Extensions.Http;
@@ -20,7 +23,7 @@ public static IActionResult Run(
             [Sql("if @Name is null select * from Products where Name is null else select * from Products where @Name = name",
                 CommandType = System.Data.CommandType.Text,
                 Parameters = "@Name={name}",
-                ConnectionStringSetting = "SQLServerAuthentication")]
+                ConnectionStringSetting = "SqlConnectionString")]
             IEnumerable<Product> products)
         {
             return (ActionResult)new OkObjectResult(products);

samples/SqlExtensionSamples/InputBindingSamples/GetProductsSqlCommand.cs

@@ -1,4 +1,7 @@
-using Microsoft.AspNetCore.Http;
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.WebJobs;
 using Microsoft.Azure.WebJobs.Extensions.Http;
@@ -17,7 +20,7 @@ public static IActionResult Run(
             [Sql("select * from Products where cost = @Cost",
                 CommandType = System.Data.CommandType.Text,
                 Parameters = "@Cost={cost}",
-                ConnectionStringSetting = "SQLServerAuthentication")]
+                ConnectionStringSetting = "SqlConnectionString")]
             SqlCommand command)
         {
             string result = string.Empty;
@@ -28,7 +31,7 @@ public static IActionResult Run(
                 {
                     while (reader.Read())
                     {
-                        result += String.Format("ProductID: {0}, Cost: {1}, Name: {2}\n", reader[0], reader[1], reader[2]);
+                        result += $"ProductID: {reader["ProductID"]},  Name: {reader["Name"]}, Cost: {reader["Cost"]}\n";
                     }
                 }
             }

samples/SqlExtensionSamples/InputBindingSamples/GetProductsStoredProcedure.cs

@@ -1,4 +1,7 @@
-using Microsoft.AspNetCore.Http;
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.WebJobs;
 using Microsoft.Azure.WebJobs.Extensions.Http;
@@ -17,7 +20,7 @@ public static IActionResult Run(
             [Sql("SelectProductsCost",
                 CommandType = System.Data.CommandType.StoredProcedure,
                 Parameters = "@Cost={cost}",
-                ConnectionStringSetting = "SQLServerAuthentication")]
+                ConnectionStringSetting = "SqlConnectionString")]
             IEnumerable<Product> products)
         {
             return (ActionResult)new OkObjectResult(products);

samples/SqlExtensionSamples/InputBindingSamples/GetProductsString.cs

@@ -1,4 +1,7 @@
-using Microsoft.AspNetCore.Http;
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.WebJobs;
 using Microsoft.Azure.WebJobs.Extensions.Http;
@@ -14,7 +17,7 @@ public static IActionResult Run(
             [Sql("select * from Products where cost = @Cost",
                 CommandType = System.Data.CommandType.Text,
                 Parameters = "@Cost={cost}",
-                ConnectionStringSetting = "SQLServerAuthentication")]
+                ConnectionStringSetting = "SqlConnectionString")]
             string products)
         {
             // Products is a JSON representation of the returned rows. For example, if there are two returned rows,

samples/SqlExtensionSamples/OutputBindingSamples/AddProduct.cs

@@ -1,3 +1,6 @@
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.WebJobs;
 using Microsoft.Azure.WebJobs.Extensions.Http;
@@ -11,9 +14,9 @@ public static class AddProduct
     {
         [FunctionName("AddProduct")]
         public static IActionResult Run(
-        [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "addproduct")]
+            [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "addproduct")]
             HttpRequest req,
-        [Sql("Products", ConnectionStringSetting = "SQLServerAuthentication")] out Product product)
+            [Sql("Products", ConnectionStringSetting = "SqlConnectionString")] out Product product)
         {
             product = new Product
             {

samples/SqlExtensionSamples/OutputBindingSamples/AddProductsArray.cs

@@ -1,4 +1,7 @@
-using Microsoft.AspNetCore.Mvc;
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.WebJobs;
 using Microsoft.Azure.WebJobs.Extensions.Http;
 using Microsoft.AspNetCore.Http;
@@ -10,24 +13,28 @@ public static class AddProductsArray
     {
         [FunctionName("AddProductsArray")]
         public static IActionResult Run(
-        [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "addproducts-array")]
+            [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "addproducts-array")]
             HttpRequest req,
-        [Sql("dbo.Products", ConnectionStringSetting = "SQLServerAuthentication")] out Product[] output)
+            [Sql("dbo.Products", ConnectionStringSetting = "SqlConnectionString")] out Product[] output)
         {
             // Suppose that the ProductID column is the primary key in the Products table, and the 
             // table already contains a row with ProductID = 1. In that case, the row will be updated
             // instead of inserted to have values Name = "Cup" and Cost = 2. 
-            output = new Product[2];
-            var product = new Product();
-            product.ProductID = 1;
-            product.Name = "Cup";
-            product.Cost = 2;
-            output[0] = product;
-            product = new Product();
-            product.ProductID = 2;
-            product.Name = "Glasses";
-            product.Cost = 12;
-            output[1] = product;
+            output = new[]
+            {
+                new Product
+                {
+                    ProductID = 1,
+                    Name = "Cup",
+                    Cost = 2
+                },
+                new Product
+                {
+                    ProductID = 2,
+                    Name = "Glasses",
+                    Cost = 12
+                }
+            };
             return new CreatedResult($"/api/addproducts-array", output);
         }
     }

samples/SqlExtensionSamples/OutputBindingSamples/AddProductsAsyncCollector.cs

@@ -0,0 +1,38 @@
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Azure.WebJobs;
+using Microsoft.Azure.WebJobs.Extensions.Http;
+using Microsoft.AspNetCore.Http;
+using static SqlExtensionSamples.ProductUtilities;
+using System.Threading.Tasks;
+using System.Collections.Generic;
+
+namespace SqlExtensionSamples
+{
+    public static class AddProductsAsyncCollector
+    {
+        [FunctionName("AddProductsAsyncCollector")]
+        public static async Task<IActionResult> Run(
+            [HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = "addproducts-asynccollector")]
+            HttpRequest req,
+            [Sql("Products", ConnectionStringSetting = "SqlConnectionString")] IAsyncCollector<Product> products)
+        {
+            List<Product> newProducts = GetNewProducts(5000);
+            foreach (var product in newProducts)
+            {
+                await products.AddAsync(product);
+            }
+            // Rows are upserted here
+            await products.FlushAsync();
+
+            newProducts = GetNewProducts(5000);
+            foreach (var product in newProducts)
+            {
+                await products.AddAsync(product);
+            }
+            return new CreatedResult($"/api/addproducts-collector", "done");
+        }
+    }
+}