Tests for mysql extensions

Author: guptaheena

azure-pipelines-e2e-integration-tests.yml

@@ -149,6 +149,7 @@ jobs:
         JAVA_HOME: $(JavaHome)
         AzureWebJobsStorage: $(AzureWebJobsStorage)
         AzureWebJobsCosmosDBConnectionString: $(AzureWebJobsCosmosDBConnectionString)
+        AzureWebJobsMySqlConnectionString: $(AzureWebJobsMySqlConnectionString)
         AzureWebJobsSqlConnectionString: $(AzureWebJobsSqlConnectionString)
         AzureWebJobsServiceBus: $(AzureWebJobsServiceBus)
         AzureWebJobsEventHubSender_2: $(AzureWebJobsEventHubSender_2)

azure-pipelines.yml

@@ -215,6 +215,7 @@ jobs:
           JAVA_HOME: $(JavaHome)
           AzureWebJobsStorage: $(AzureWebJobsStorage)
           AzureWebJobsCosmosDBConnectionString: $(AzureWebJobsCosmosDBConnectionString)
+          AzureWebJobsMySqlConnectionString: $(AzureWebJobsMySqlConnectionString)
           AzureWebJobsSqlConnectionString: $(AzureWebJobsSqlConnectionString)
           AzureWebJobsServiceBus: $(AzureWebJobsServiceBus)
           AzureWebJobsEventHubReceiver: $(AzureWebJobsEventHubReceiver)

endtoendtests/Azure.Functions.Java.Tests.E2E/Azure.Functions.Java.Tests.E2E/Constants.cs

@@ -96,5 +96,8 @@ public static class Constants
 
         // SQL Binding tests
         public static string SqlConnectionStringSetting = Environment.GetEnvironmentVariable("AzureWebJobsSqlConnectionString");
+		
+		// MySql tests
+		public static string MySqlConnectionStringSetting = Environment.GetEnvironmentVariable("AzureWebJobsMySqlConnectionString");
     }
 }

endtoendtests/Azure.Functions.Java.Tests.E2E/Azure.Functions.Java.Tests.E2E/MySqlEndToEndTests.cs

@@ -0,0 +1,44 @@
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using Newtonsoft.Json;
+using System;
+using System.Collections.Generic;
+using System.Net;
+using System.Threading;
+using System.Threading.Tasks;
+using Xunit;
+
+namespace Azure.Functions.Java.Tests.E2E
+{
+    [Collection(Constants.FunctionAppCollectionName)]
+    public class MySqlEndToEndTests
+    {
+        private readonly FunctionAppFixture _fixture;
+
+        public MySqlEndToEndTests(FunctionAppFixture fixture)
+        {
+            this._fixture = fixture;
+        }
+
+        [Fact]
+        public async Task MySqlInput_Output_Succeeds()
+        {
+            TimeSpan t = DateTime.UtcNow - new DateTime(1970, 1, 1);
+            int id  = (int) t.TotalSeconds;
+            var product = new Dictionary<string, object>()
+            {
+                { "ProductId", id },
+                { "Name", "test" },
+                { "Cost", 100 }
+            };
+
+            var productString = JsonConvert.SerializeObject(product);
+            // Insert row into Products table using MySqlOutput
+            Assert.True(await Utilities.InvokeHttpTriggerPost("AddProduct", productString, HttpStatusCode.OK));
+
+            // Read row from Products table using MySqlInput
+            Assert.True(await Utilities.InvokeHttpTrigger("GetProducts", "/" + id.ToString(), HttpStatusCode.OK, productString));
+        }
+    }
+}

endtoendtests/local.settings.json

@@ -18,6 +18,7 @@
     "AzureWebJobsEventGridOutputBindingTopicUriString": "",
     "AzureWebJobsEventGridOutputBindingTopicKeyString": "",
     "AzureWebJobsSqlConnectionString": "",
+	"AzureWebJobsMySqlConnectionString": "",
     "FUNCTIONS_WORKER_RUNTIME": "java"
   }
 }

endtoendtests/pom.xml

@@ -24,6 +24,7 @@
 		<azure.functions.maven.plugin.version>1.18.0</azure.functions.maven.plugin.version>
 		<azure.functions.java.library.version>3.1.0</azure.functions.java.library.version>
 		<azure.functions.java.library.sql.version>2.1.0</azure.functions.java.library.sql.version>
+		<azure.functions.java.library.mysql.version>1.0.0</azure.functions.java.library.mysql.version>
 		<durabletask.azure.functions>1.0.0-beta.1</durabletask.azure.functions>
 		<functionAppName>azure-functions-java-endtoendtests</functionAppName>
 		<functionAppRegion>westus</functionAppRegion>
@@ -69,6 +70,11 @@
             <groupId>com.microsoft.azure.functions</groupId>
             <artifactId>azure-functions-java-library-sql</artifactId>
             <version>${azure.functions.java.library.sql.version}</version>
+        </dependency>
+		<dependency>
+            <groupId>com.microsoft.azure.functions</groupId>
+            <artifactId>azure-functions-java-library-mysql</artifactId>
+            <version>${azure.functions.java.library.mysql.version}</version>
         </dependency>
 		<dependency>
 			<groupId>com.microsoft</groupId>

endtoendtests/src/main/java/com/microsoft/azure/functions/endtoend/MySqlTriggerTests.java

@@ -0,0 +1,61 @@
+package com.microsoft.azure.functions.endtoend;
+
+import com.microsoft.azure.functions.annotation.*;
+import com.google.gson.Gson;
+import com.microsoft.azure.functions.*;
+import com.microsoft.azure.functions.HttpMethod;
+import com.microsoft.azure.functions.mysql.annotation.CommandType;
+import com.microsoft.azure.functions.mysql.annotation.MySqlInput;
+import com.microsoft.azure.functions.mysql.annotation.MySqlOutput;
+
+import java.io.IOException;
+import java.lang.reflect.Array;
+import java.util.*;
+
+/**
+ * Azure Functions with Azure MySql Database.
+ */
+public class MySqlTriggerTests {
+
+    @FunctionName("GetProducts")
+    public HttpResponseMessage GetProducts(@HttpTrigger(name = "req", methods = { HttpMethod.GET,
+            HttpMethod.POST }, route = "getproducts/{productid}", authLevel = AuthorizationLevel.ANONYMOUS)
+            HttpRequestMessage<Optional<String>> request,
+            @MySqlInput(name = "products", commandText = "SELECT TOP 1 * FROM Products WHERE ProductId = @ProductId",
+            commandType = CommandType.Text, parameters = "@ProductId={productid}",
+            connectionStringSetting = "AzureWebJobsMySqlConnectionString") Product[] products,
+            final ExecutionContext context) {
+
+        context.getLogger().info("Java HTTP trigger processed a MySql Input Binding request.");
+
+        if (products.length != 0) {
+            return request.createResponseBuilder(HttpStatus.OK).body(products[0].toString()).build();
+        } else {
+            return request.createResponseBuilder(HttpStatus.INTERNAL_SERVER_ERROR)
+                    .body("Did not find expected product in table Products").build();
+        }
+    }
+
+    @FunctionName("AddProduct")
+    public HttpResponseMessage AddProduct(@HttpTrigger(name = "req", methods = { HttpMethod.GET,
+            HttpMethod.POST }, authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
+            @MySqlOutput(name = "product", tableName = "Products", connectionStringSetting = "AzureWebJobsMySqlConnectionString") OutputBinding<Product> product,
+            final ExecutionContext context) {
+        context.getLogger().info("Java HTTP trigger processed a MySql Output Binding request.");
+
+        String json = request.getBody().get();
+        product.setValue(new Gson().fromJson(json, Product.class));
+
+        return request.createResponseBuilder(HttpStatus.OK).body(product).build();
+    }
+
+    public class Product {
+        public int ProductId;
+        public String Name;
+        public int Cost;
+
+        public String toString() {
+            return "{\"ProductId\":" + ProductId + ",\"Name\":\"" + Name + "\",\"Cost\":" + Cost + "}";
+        }
+    }
+}