Merge pull request #486 from Azure/luczhan/multiplebindingsjava

Add Java samples with multiple bindings

Author: lucyzhang929

.gitignore

@@ -360,5 +360,9 @@ __azurite_db*__.json
 # Python virtual environment
 .venv
 
-# Mac OS X 
-.DS_Store
+# Mac OS X
+.DS_Store
+
+# Java build files
+repo/
+target/

samples/samples-java/.gitignore

@@ -1,6 +1,4 @@
 # Build output
-target/
-repo/
 *.class
 
 # Log file

samples/samples-java/src/main/java/com/function/AddProductToTwoTables.java

@@ -23,6 +23,10 @@
 import java.io.IOException;
 import java.util.Optional;
 
+/**
+ * This function uses two SQL output bindings to upsert the product in the request body to the
+ * Products and ProductsWithIdentity tables.
+ */
 public class AddProductToTwoTables {
     @FunctionName("AddProductToTwoTables")
     public HttpResponseMessage run(

samples/samples-java/src/main/java/com/function/GetAndAddProducts.java

@@ -0,0 +1,53 @@
+/**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ */
+
+package com.function;
+
+import com.function.Common.Product;
+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.OutputBinding;
+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 com.microsoft.azure.functions.sql.annotation.SQLOutput;
+
+import java.util.Optional;
+
+/**
+ * This function uses a SQL input binding to get products from the Products table
+ * and upsert those products to the ProductsWithIdentity table.
+ */
+public class GetAndAddProducts {
+    @FunctionName("GetAndAddProducts")
+    public HttpResponseMessage run(
+            @HttpTrigger(
+                name = "req",
+                methods = {HttpMethod.GET},
+                authLevel = AuthorizationLevel.ANONYMOUS,
+                route = "getandaddproducts/{cost}")
+                HttpRequestMessage<Optional<String>> request,
+            @SQLInput(
+                name = "products",
+                commandText = "SELECT * FROM Products WHERE Cost = @Cost",
+                commandType = "Text",
+                parameters = "@Cost={cost}",
+                connectionStringSetting = "SqlConnectionString")
+                Product[] products,
+            @SQLOutput(
+                name = "productsWithIdentity",
+                commandText = "ProductsWithIdentity",
+                connectionStringSetting = "SqlConnectionString")
+                OutputBinding<Product[]> productsWithIdentity) {
+
+        productsWithIdentity.setValue(products);
+
+        return request.createResponseBuilder(HttpStatus.OK).header("Content-Type", "application/json").body(products).build();
+    }
+}

samples/samples-java/src/main/java/com/function/GetProductsFromTwoTables.java

@@ -0,0 +1,55 @@
+/**
+ * Copyright (c) Microsoft Corporation. All rights reserved.
+ * Licensed under the MIT License. See License.txt in the project root for
+ * license information.
+ */
+
+package com.function;
+
+import com.function.Common.Product;
+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;
+
+/**
+ * This function uses two SQL input bindings to get products from the Products and ProductsWithIdentity tables
+ * and returns the combined results as a JSON array in the body of the HttpResponseMessage.
+ */
+public class GetProductsFromTwoTables {
+    @FunctionName("GetProductsFromTwoTables")
+    public HttpResponseMessage run(
+            @HttpTrigger(
+                name = "req",
+                methods = {HttpMethod.GET},
+                authLevel = AuthorizationLevel.ANONYMOUS,
+                route = "getproductsfromtwotables/{cost}")
+                HttpRequestMessage<Optional<String>> request,
+            @SQLInput(
+                name = "products",
+                commandText = "SELECT * FROM Products WHERE Cost = @Cost",
+                commandType = "Text",
+                parameters = "@Cost={cost}",
+                connectionStringSetting = "SqlConnectionString")
+                Product[] products,
+            @SQLInput(
+                name = "productsWithIdentity",
+                commandText = "SELECT * FROM ProductsWithIdentity WHERE Cost = @Cost",
+                commandType = "Text",
+                parameters = "@Cost={cost}",
+                connectionStringSetting = "SqlConnectionString")
+                Product[] productsWithIdentity) {
+
+        Product[] allProducts = new Product[products.length + productsWithIdentity.length];
+        System.arraycopy(products, 0, allProducts, 0, products.length);
+        System.arraycopy(productsWithIdentity, 0, allProducts, products.length, productsWithIdentity.length);
+
+        return request.createResponseBuilder(HttpStatus.OK).header("Content-Type", "application/json").body(allProducts).build();
+    }
+}