Skip to content

Commit 62d1f25

Browse files
author
Sumit Kumar
committed
E2E Tests of "MySql Extensions for Azure Function" on java platform
1 parent 1e1f7be commit 62d1f25

File tree

7 files changed

+118
-0
lines changed

7 files changed

+118
-0
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -96,5 +96,8 @@ public static class Constants
9696

9797
// SQL Binding tests
9898
public static string SqlConnectionStringSetting = Environment.GetEnvironmentVariable("AzureWebJobsSqlConnectionString");
99+
100+
// MySql tests
101+
public static string MySqlConnectionStringSetting = Environment.GetEnvironmentVariable("AzureWebJobsMySqlConnectionString");
99102
}
100103
}

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

Lines changed: 44 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,44 @@
1+
// Copyright (c) .NET Foundation. All rights reserved.
2+
// Licensed under the MIT License. See License.txt in the project root for license information.
3+
4+
using Newtonsoft.Json;
5+
using System;
6+
using System.Collections.Generic;
7+
using System.Net;
8+
using System.Threading;
9+
using System.Threading.Tasks;
10+
using Xunit;
11+
12+
namespace Azure.Functions.Java.Tests.E2E
13+
{
14+
[Collection(Constants.FunctionAppCollectionName)]
15+
public class MySqlEndToEndTests
16+
{
17+
private readonly FunctionAppFixture _fixture;
18+
19+
public MySqlEndToEndTests(FunctionAppFixture fixture)
20+
{
21+
this._fixture = fixture;
22+
}
23+
24+
[Fact]
25+
public async Task MySqlInput_Output_Succeeds()
26+
{
27+
TimeSpan t = DateTime.UtcNow - new DateTime(1970, 1, 1);
28+
int id = (int) t.TotalSeconds;
29+
var product = new Dictionary<string, object>()
30+
{
31+
{ "ProductId", id },
32+
{ "Name", "test" },
33+
{ "Cost", 100 }
34+
};
35+
36+
var productString = JsonConvert.SerializeObject(product);
37+
// Insert a row into Products table using MySqlOutput
38+
Assert.True(await Utilities.InvokeHttpTriggerPost("AddProduct", productString, HttpStatusCode.OK));
39+
40+
// Read row from Products table using MySqlInput
41+
Assert.True(await Utilities.InvokeHttpTrigger("GetProducts", "/" + id.ToString(), HttpStatusCode.OK, productString));
42+
}
43+
}
44+
}

‎endtoendtests/local.settings.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
"AzureWebJobsEventGridOutputBindingTopicUriString": "",
1919
"AzureWebJobsEventGridOutputBindingTopicKeyString": "",
2020
"AzureWebJobsSqlConnectionString": "",
21+
"AzureWebJobsMySqlConnectionString": "",
2122
"FUNCTIONS_WORKER_RUNTIME": "java"
2223
}
2324
}

‎endtoendtests/pom.xml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
<azure.functions.maven.plugin.version>1.18.0</azure.functions.maven.plugin.version>
2525
<azure.functions.java.library.version>3.1.0</azure.functions.java.library.version>
2626
<azure.functions.java.library.sql.version>2.1.0</azure.functions.java.library.sql.version>
27+
<azure.functions.java.library.mysql.version>1.0.2</azure.functions.java.library.mysql.version>
2728
<durabletask.azure.functions>1.0.0-beta.1</durabletask.azure.functions>
2829
<functionAppName>azure-functions-java-endtoendtests</functionAppName>
2930
<functionAppRegion>westus</functionAppRegion>
@@ -69,6 +70,11 @@
6970
<groupId>com.microsoft.azure.functions</groupId>
7071
<artifactId>azure-functions-java-library-sql</artifactId>
7172
<version>${azure.functions.java.library.sql.version}</version>
73+
</dependency>
74+
<dependency>
75+
<groupId>com.microsoft.azure.functions</groupId>
76+
<artifactId>azure-functions-java-library-mysql</artifactId>
77+
<version>${azure.functions.java.library.mysql.version}</version>
7278
</dependency>
7379
<dependency>
7480
<groupId>com.microsoft</groupId>

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

Lines changed: 62 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,62 @@
1+
package com.microsoft.azure.functions.endtoend;
2+
3+
import com.microsoft.azure.functions.annotation.*;
4+
import com.google.gson.Gson;
5+
import com.microsoft.azure.functions.*;
6+
import com.microsoft.azure.functions.HttpMethod;
7+
import com.microsoft.azure.functions.mysql.annotation.CommandType;
8+
import com.microsoft.azure.functions.mysql.annotation.MySqlInput;
9+
import com.microsoft.azure.functions.mysql.annotation.MySqlOutput;
10+
import com.microsoft.azure.functions.mysql.annotation.MySqlTrigger;
11+
12+
import java.io.IOException;
13+
import java.lang.reflect.Array;
14+
import java.util.*;
15+
16+
/**
17+
* Azure Functions with Azure MySql Database.
18+
*/
19+
public class MySqlTriggerTests {
20+
21+
@FunctionName("GetProducts")
22+
public HttpResponseMessage GetProducts(@HttpTrigger(name = "req", methods = { HttpMethod.GET,
23+
HttpMethod.POST }, route = "getproducts/{productid}", authLevel = AuthorizationLevel.ANONYMOUS)
24+
HttpRequestMessage<Optional<String>> request,
25+
@MySqlInput(name = "products", commandText = "SELECT TOP 1 * FROM Products WHERE ProductId = @ProductId",
26+
commandType = CommandType.Text, parameters = "@ProductId={productid}",
27+
connectionStringSetting = "AzureWebJobsMySqlConnectionString") Product[] products,
28+
final ExecutionContext context) {
29+
30+
context.getLogger().info("Java HTTP trigger processed a MySql Input Binding request.");
31+
32+
if (products.length != 0) {
33+
return request.createResponseBuilder(HttpStatus.OK).body(products[0].toString()).build();
34+
} else {
35+
return request.createResponseBuilder(HttpStatus.INTERNAL_SERVER_ERROR)
36+
.body("Did not find expected product in table Products").build();
37+
}
38+
}
39+
40+
@FunctionName("AddProduct")
41+
public HttpResponseMessage AddProduct(@HttpTrigger(name = "req", methods = { HttpMethod.GET,
42+
HttpMethod.POST }, authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
43+
@MySqlOutput(name = "product", commandText = "Products", connectionStringSetting = "AzureWebJobsMySqlConnectionString") OutputBinding<Product> product,
44+
final ExecutionContext context) {
45+
context.getLogger().info("Java HTTP trigger processed a MySql Output Binding request.");
46+
47+
String json = request.getBody().get();
48+
product.setValue(new Gson().fromJson(json, Product.class));
49+
50+
return request.createResponseBuilder(HttpStatus.OK).body(product).build();
51+
}
52+
53+
public class Product {
54+
public int ProductId;
55+
public String Name;
56+
public int Cost;
57+
58+
public String toString() {
59+
return "{\"ProductId\":" + ProductId + ",\"Name\":\"" + Name + "\",\"Cost\":" + Cost + "}";
60+
}
61+
}
62+
}

‎eng/ci/templates/official/jobs/run-e2e-tests-linux.yml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,7 @@ jobs:
109109
AzureWebJobsStorage: $(AzureWebJobsStorage)
110110
AzureWebJobsCosmosDBConnectionString: $(AzureWebJobsCosmosDBConnectionString)
111111
AzureWebJobsSqlConnectionString: $(AzureWebJobsSqlConnectionString)
112+
AzureWebJobsMySqlConnectionString: $(AzureWebJobsMySqlConnectionString)
112113
AzureWebJobsServiceBus: $(AzureWebJobsServiceBus)
113114
AzureWebJobsEventHubReceiver: $(AzureWebJobsEventHubReceiver)
114115
AzureWebJobsEventHubSender_2: $(AzureWebJobsEventHubSender_2)

‎eng/ci/templates/official/jobs/run-e2e-tests-windows.yml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,7 @@ jobs:
9494
AzureWebJobsStorage: $(AzureWebJobsStorage)
9595
AzureWebJobsCosmosDBConnectionString: $(AzureWebJobsCosmosDBConnectionString)
9696
AzureWebJobsSqlConnectionString: $(AzureWebJobsSqlConnectionString)
97+
AzureWebJobsMySqlConnectionString: $(AzureWebJobsMySqlConnectionString)
9798
AzureWebJobsServiceBus: $(AzureWebJobsServiceBus)
9899
AzureWebJobsEventHubReceiver: $(AzureWebJobsEventHubReceiver)
99100
AzureWebJobsEventHubSender_2: $(AzureWebJobsEventHubSender_2)

0 commit comments

Comments
 (0)