Add java trigger samples (#793)

* add java trigger samples

* update test-java

* add SqlChangeProduct type

* add rest of tests

* fix polling interval test

Author: lucyzhang929

samples/samples-java/pom.xml

@@ -27,7 +27,7 @@
         <dependency>
             <groupId>com.microsoft.azure.functions</groupId>
             <artifactId>azure-functions-java-library-sql</artifactId>
-            <version>0.1.1</version>
+            <version>2.0.0-preview</version>
         </dependency>
 
         <dependency>
@@ -36,6 +36,12 @@
             <version>2.13.4.2</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.google.code.gson</groupId>
+            <artifactId>gson</artifactId>
+            <version>2.10.1</version>
+        </dependency>
+
         <!-- Test -->
         <dependency>
             <groupId>org.junit.jupiter</groupId>

samples/samples-java/src/main/java/com/function/Common/SqlChangeOperation.java

@@ -0,0 +1,18 @@
+/**
+ * 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.Common;
+
+import com.google.gson.annotations.SerializedName;
+
+public enum SqlChangeOperation {
+    @SerializedName("0")
+    Insert,
+    @SerializedName("1")
+    Update,
+    @SerializedName("2")
+    Delete
+}

samples/samples-java/src/main/java/com/function/Common/SqlChangeProduct.java

@@ -0,0 +1,36 @@
+/**
+ * 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.Common;
+
+public class SqlChangeProduct {
+    private SqlChangeOperation Operation;
+    private Product Item;
+
+    public SqlChangeProduct() {
+    }
+
+    public SqlChangeProduct(SqlChangeOperation operation, Product item) {
+        this.Operation = operation;
+        this.Item = item;
+    }
+
+    public SqlChangeOperation getOperation() {
+        return Operation;
+    }
+
+    public void setOperation(SqlChangeOperation operation) {
+        this.Operation = operation;
+    }
+
+    public Product getItem() {
+        return Item;
+    }
+
+    public void setItem(Product item) {
+        this.Item = item;
+    }
+}

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

@@ -16,6 +16,7 @@
 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.CommandType;
 import com.microsoft.azure.functions.sql.annotation.SQLOutput;
 
 import java.util.Optional;
@@ -36,7 +37,7 @@ public HttpResponseMessage run(
             @SQLInput(
                 name = "products",
                 commandText = "SELECT * FROM Products WHERE Cost = @Cost",
-                commandType = "Text",
+                commandType = CommandType.Text,
                 parameters = "@Cost={cost}",
                 connectionStringSetting = "SqlConnectionString")
                 Product[] products,

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

@@ -14,6 +14,7 @@
 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.CommandType;
 import com.microsoft.azure.functions.sql.annotation.SQLInput;
 
 import java.util.Optional;
@@ -30,7 +31,7 @@ public HttpResponseMessage run(
             @SQLInput(
                 name = "productNames",
                 commandText = "SELECT * FROM ProductNames",
-                commandType = "Text",
+                commandType = CommandType.Text,
                 connectionStringSetting = "SqlConnectionString")
                 ProductName[] products) {
 

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

@@ -14,6 +14,7 @@
 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.CommandType;
 import com.microsoft.azure.functions.sql.annotation.SQLInput;
 
 import java.util.Optional;
@@ -30,7 +31,7 @@ public HttpResponseMessage run(
             @SQLInput(
                 name = "products",
                 commandText = "SELECT * FROM Products WHERE Cost = @Cost",
-                commandType = "Text",
+                commandType = CommandType.Text,
                 parameters = "@Cost={cost}",
                 connectionStringSetting = "SqlConnectionString")
                 Product[] products) {

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

@@ -14,6 +14,7 @@
 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.CommandType;
 import com.microsoft.azure.functions.sql.annotation.SQLInput;
 
 import java.util.Optional;
@@ -34,14 +35,14 @@ public HttpResponseMessage run(
             @SQLInput(
                 name = "products",
                 commandText = "SELECT * FROM Products WHERE Cost = @Cost",
-                commandType = "Text",
+                commandType = CommandType.Text,
                 parameters = "@Cost={cost}",
                 connectionStringSetting = "SqlConnectionString")
                 Product[] products,
             @SQLInput(
                 name = "productsWithIdentity",
                 commandText = "SELECT * FROM ProductsWithIdentity WHERE Cost = @Cost",
-                commandType = "Text",
+                commandType = CommandType.Text,
                 parameters = "@Cost={cost}",
                 connectionStringSetting = "SqlConnectionString")
                 Product[] productsWithIdentity) {

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

@@ -14,6 +14,7 @@
 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.CommandType;
 import com.microsoft.azure.functions.sql.annotation.SQLInput;
 
 import java.util.Optional;
@@ -30,7 +31,7 @@ public HttpResponseMessage run(
             @SQLInput(
                 name = "products",
                 commandText = "SELECT * FROM Products WHERE Cost = @Cost and Name = @Name",
-                commandType = "Text",
+                commandType = CommandType.Text,
                 parameters = "@Cost={cost},@Name=",
                 connectionStringSetting = "SqlConnectionString")
                 Product[] products) {

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

@@ -14,6 +14,7 @@
 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.CommandType;
 import com.microsoft.azure.functions.sql.annotation.SQLInput;
 
 import java.util.Optional;
@@ -30,7 +31,7 @@ public HttpResponseMessage run(
             @SQLInput(
                 name = "products",
                 commandText = "SelectProductsCost",
-                commandType = "StoredProcedure",
+                commandType = CommandType.StoredProcedure,
                 parameters = "@Cost={cost}",
                 connectionStringSetting = "SqlConnectionString")
                 Product[] products) {

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

@@ -14,6 +14,7 @@
 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.CommandType;
 import com.microsoft.azure.functions.sql.annotation.SQLInput;
 
 import java.util.Optional;
@@ -30,7 +31,7 @@ public HttpResponseMessage run(
             @SQLInput(
                 name = "products",
                 commandText = "%Sp_SelectCost%",
-                commandType = "StoredProcedure",
+                commandType = CommandType.StoredProcedure,
                 parameters = "@Cost=%ProductCost%",
                 connectionStringSetting = "SqlConnectionString")
                 Product[] products) {