developments for v3.9 (#325)

* Add support for SPARQL SERVICE for pattern groups
mdesalvo · Nov 29, 2023 · 9819f21 · 9819f21
1 parent 58d444d
commit 9819f21
Show file tree

Hide file tree

Showing 19 changed files with 1,920 additions and 103 deletions.
diff --git a/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFClearOperationTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFClearOperationTest.cs
@@ -36,9 +36,6 @@ public class RDFClearOperationTest
         [TestInitialize]
         public void Initialize() { server = WireMockServer.Start(); }
 
-        [TestCleanup]
-        public void Cleanup()  { server.Stop(); server.Dispose(); }
-
         #region Tests
         [TestMethod]
         public void ShouldCreateClearNamedOperation()

diff --git a/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFDeleteDataOperationTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFDeleteDataOperationTest.cs
@@ -36,9 +36,6 @@ public class RDFDeleteDataOperationTest
         [TestInitialize]
         public void Initialize() { server = WireMockServer.Start(); }
 
-        [TestCleanup]
-        public void Cleanup()  { server.Stop(); server.Dispose(); }
-
         #region Tests
         [TestMethod]
         public void ShouldCreateDeleteDataOperation()

diff --git a/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFDeleteInsertWhereOperationTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFDeleteInsertWhereOperationTest.cs
@@ -37,9 +37,6 @@ public class RDFDeleteInsertWhereOperationTest
         [TestInitialize]
         public void Initialize() { server = WireMockServer.Start(); }
 
-        [TestCleanup]
-        public void Cleanup()  { server.Stop(); server.Dispose(); }
-
         #region Tests
         [TestMethod]
         public void ShouldCreateDeleteInsertWhereOperation()

diff --git a/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFDeleteWhereOperationTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFDeleteWhereOperationTest.cs
@@ -37,9 +37,6 @@ public class RDFDeleteWhereOperationTest
         [TestInitialize]
         public void Initialize() { server = WireMockServer.Start(); }
 
-        [TestCleanup]
-        public void Cleanup()  { server.Stop(); server.Dispose(); }
-
         #region Tests
         [TestMethod]
         public void ShouldCreateDeleteWhereOperation()

diff --git a/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFInsertDataOperationTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFInsertDataOperationTest.cs
@@ -36,9 +36,6 @@ public class RDFInsertDataOperationTest
         [TestInitialize]
         public void Initialize() { server = WireMockServer.Start(); }
 
-        [TestCleanup]
-        public void Cleanup()  { server.Stop(); server.Dispose(); }
-
         #region Tests
         [TestMethod]
         public void ShouldCreateInsertDataOperation()

diff --git a/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFInsertWhereOperationTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFInsertWhereOperationTest.cs
@@ -37,9 +37,6 @@ public class RDFInsertWhereOperationTest
         [TestInitialize]
         public void Initialize() { server = WireMockServer.Start(); }
 
-        [TestCleanup]
-        public void Cleanup()  { server.Stop(); server.Dispose(); }
-
         #region Tests
         [TestMethod]
         public void ShouldCreateInsertWhereOperation()

diff --git a/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFLoadOperationTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/Operations/RDFLoadOperationTest.cs
@@ -36,9 +36,6 @@ public class RDFLoadOperationTest
         [TestInitialize]
         public void Initialize() { server = WireMockServer.Start(); }
 
-        [TestCleanup]
-        public void Cleanup()  { server.Stop(); server.Dispose(); }
-
         #region Tests
         [TestMethod]
         public void ShouldCreateLoadOperation()

diff --git a/RDFSharp.Test/Query/Mirella/Algebra/Queries/RDFAskQueryTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/Queries/RDFAskQueryTest.cs
@@ -37,9 +37,6 @@ public class RDFAskQueryTest
 
         [TestInitialize]
         public void Initialize() { server = WireMockServer.Start(); }
-
-        [TestCleanup]
-        public void Cleanup()  { server.Stop(); server.Dispose(); }
 
         #region Tests
         [TestMethod]

diff --git a/RDFSharp.Test/Query/Mirella/Algebra/Queries/RDFConstructQueryTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/Queries/RDFConstructQueryTest.cs
@@ -37,9 +37,6 @@ public class RDFConstructQueryTest
 
         [TestInitialize]
         public void Initialize() { server = WireMockServer.Start(); }
-
-        [TestCleanup]
-        public void Cleanup()  { server.Stop(); server.Dispose(); }
 
         #region Tests
         [TestMethod]

diff --git a/RDFSharp.Test/Query/Mirella/Algebra/Queries/RDFDescribeQueryTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/Queries/RDFDescribeQueryTest.cs
@@ -37,9 +37,6 @@ public class RDFDescribeQueryTest
 
         [TestInitialize]
         public void Initialize() { server = WireMockServer.Start(); }
-
-        [TestCleanup]
-        public void Cleanup()  { server.Stop(); server.Dispose(); }
 
         #region Tests
         [TestMethod]

diff --git a/RDFSharp.Test/Query/Mirella/Algebra/Queries/RDFSelectQueryTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/Queries/RDFSelectQueryTest.cs
@@ -15,6 +15,9 @@ limitations under the License.
 */
 
 using Microsoft.VisualStudio.TestTools.UnitTesting;
+using RDFSharp.Model;
+using RDFSharp.Query;
+using RDFSharp.Store;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -24,9 +27,8 @@ limitations under the License.
 using WireMock.RequestBuilders;
 using WireMock.ResponseBuilders;
 using WireMock.Server;
-using RDFSharp.Model;
-using RDFSharp.Query;
-using RDFSharp.Store;
+using WireMock.Types;
+using WireMock.Util;
 
 namespace RDFSharp.Test.Query
 {
@@ -38,9 +40,6 @@ public class RDFSelectQueryTest
         [TestInitialize]
         public void Initialize() { server = WireMockServer.Start(); }
 
-        [TestCleanup]
-        public void Cleanup()  { server.Stop(); server.Dispose(); }
-
         #region Tests
         [TestMethod]
         public void ShouldCreateSelectQuery()
@@ -408,6 +407,131 @@ public void ShouldApplySelectQueryToNullGraphAndNotHaveResults()
             Assert.IsTrue(result.SelectResults.Columns.Count == 0);
         }
 
+        [TestMethod]
+        public void ShouldApplySelectQueryOnGraphWithServicePatternGroupAndThrowExceptionAccordingToTimingAndBehavior()
+        {
+            string receivedQuery = null;
+            string mockedResponseXml =
+@"<?xml version=""1.0"" encoding=""utf-8""?>
+<sparql xmlns=""http://www.w3.org/2005/sparql-results#"">
+  <head>
+    <variable name=""?S"" />
+  </head>
+  <results>
+    <result>
+      <binding name=""?S"">
+        <uri>ex:flower</uri>
+      </binding>
+    </result>
+  </results>
+</sparql>";
+            server
+                .Given(
+                    Request.Create()
+                           .WithPath("/RDFSelectQueryTest/ShouldApplySelectQueryOnGraphWithServicePatternGroupAndThrowExceptionAccordingToTimingAndBehavior/sparql")
+                           .UsingGet()
+                           .WithParam(queryParams => queryParams.ContainsKey("query")))
+                .RespondWith(
+                    Response.Create()
+                            .WithHeader("Content-Type", "application/sparql-results+xml")
+                            .WithCallback(req =>
+                            {
+                                receivedQuery = req.RawQuery;
+                                return new WireMock.ResponseMessage()
+                                {
+                                    BodyData = new BodyData()
+                                    {
+                                        BodyAsString = mockedResponseXml,
+                                        Encoding = Encoding.UTF8,
+                                        DetectedBodyType = BodyType.String
+                                    }
+                                };
+                            })
+                            .WithStatusCode(HttpStatusCode.OK)
+                            .WithDelay(750));
+
+
+            RDFSPARQLEndpoint endpoint = new RDFSPARQLEndpoint(new Uri(server.Url + "/RDFSelectQueryTest/ShouldApplySelectQueryOnGraphWithServicePatternGroupAndThrowExceptionAccordingToTimingAndBehavior/sparql"));
+            RDFSelectQuery query = new RDFSelectQuery()
+                .AddPatternGroup(new RDFPatternGroup()
+                    .AddBind(new RDFBind(new RDFConstantExpression(new RDFResource("ex:topolino")), new RDFVariable("?X")))
+                    .UnionWithNext())
+                .AddPatternGroup(new RDFPatternGroup()
+                    .AddPattern(new RDFPattern(new RDFVariable("?Y"), new RDFResource("ex:dogOf"), new RDFVariable("?X")))
+                    .AsService(endpoint, new RDFSPARQLEndpointQueryOptions(250, RDFQueryEnums.RDFSPARQLEndpointQueryErrorBehaviors.ThrowException)));
+
+            try
+            {
+                RDFSelectQueryResult result = query.ApplyToGraph(new RDFGraph());
+            }
+            catch (RDFQueryException qex) 
+            {
+                Assert.IsTrue(string.Equals(qex.Message, "SELECT query on SPARQL endpoint failed because: The operation has timed out."));
+            }
+        }
+
+        [TestMethod]
+        public void ShouldApplySelectQueryOnGraphWithServicePatternGroupAndGiveEmptyResultAccordingToTimingAndBehavior()
+        {
+            string receivedQuery = null;
+            string mockedResponseXml =
+@"<?xml version=""1.0"" encoding=""utf-8""?>
+<sparql xmlns=""http://www.w3.org/2005/sparql-results#"">
+  <head>
+    <variable name=""?S"" />
+  </head>
+  <results>
+    <result>
+      <binding name=""?S"">
+        <uri>ex:flower</uri>
+      </binding>
+    </result>
+  </results>
+</sparql>";
+            server
+                .Given(
+                    Request.Create()
+                           .WithPath("/RDFSelectQueryTest/ShouldApplySelectQueryOnGraphWithServicePatternGroupAndGiveEmptyResultAccordingToTimingAndBehavior/sparql")
+                           .UsingGet()
+                           .WithParam(queryParams => queryParams.ContainsKey("query")))
+                .RespondWith(
+                    Response.Create()
+                            .WithHeader("Content-Type", "application/sparql-results+xml")
+                            .WithCallback(req =>
+                            {
+                                receivedQuery = req.RawQuery;
+                                return new WireMock.ResponseMessage()
+                                {
+                                    BodyData = new BodyData()
+                                    {
+                                        BodyAsString = mockedResponseXml,
+                                        Encoding = Encoding.UTF8,
+                                        DetectedBodyType = BodyType.String
+                                    }
+                                };
+                            })
+                            .WithStatusCode(HttpStatusCode.OK)
+                            .WithDelay(750));
+
+
+            RDFSPARQLEndpoint endpoint = new RDFSPARQLEndpoint(new Uri(server.Url + "/RDFSelectQueryTest/ShouldApplySelectQueryOnGraphWithServicePatternGroupAndGiveEmptyResultAccordingToTimingAndBehavior/sparql"));
+            RDFSelectQuery query = new RDFSelectQuery()
+                .AddPatternGroup(new RDFPatternGroup()
+                    .AddBind(new RDFBind(new RDFConstantExpression(new RDFResource("ex:topolino")), new RDFVariable("?X")))
+                    .UnionWithNext())
+                .AddPatternGroup(new RDFPatternGroup()
+                    .AddPattern(new RDFPattern(new RDFVariable("?Y"), new RDFResource("ex:dogOf"), new RDFVariable("?X")))
+                    .AsService(endpoint, new RDFSPARQLEndpointQueryOptions(250, RDFQueryEnums.RDFSPARQLEndpointQueryErrorBehaviors.GiveEmptyResult)));
+            RDFSelectQueryResult result = query.ApplyToGraph(new RDFGraph());
+
+            Assert.IsNotNull(result);
+            Assert.IsNotNull(result.SelectResults);
+            Assert.IsTrue(result.SelectResultsCount == 1);
+            Assert.IsTrue(result.SelectResults.Columns.Count == 1);
+            Assert.IsTrue(result.SelectResults.Columns[0].ColumnName.Equals("?X"));
+            Assert.IsTrue(result.SelectResults.Rows[0]["?X"].Equals("ex:topolino"));
+        }
+
         [TestMethod]
         public void ShouldApplySelectQueryToStoreAndHaveResults()
         {

diff --git a/RDFSharp.Test/Query/Mirella/Algebra/RDFPatternGroupTest.cs b/RDFSharp.Test/Query/Mirella/Algebra/RDFPatternGroupTest.cs
@@ -36,6 +36,7 @@ public void ShouldCreatePatternGroup()
             Assert.IsTrue(pGroup.IsEvaluable);
             Assert.IsFalse(pGroup.IsOptional);
             Assert.IsFalse(pGroup.JoinAsUnion);
+            Assert.IsNull(pGroup.EvaluateAsService);
             Assert.IsNotNull(pGroup.GroupMembers);
             Assert.IsTrue(pGroup.GroupMembers.Count == 0);
             Assert.IsNotNull(pGroup.Variables);
@@ -58,6 +59,7 @@ public void ShouldCreateOptionalPatternGroup()
             Assert.IsTrue(pGroup.IsEvaluable);
             Assert.IsTrue(pGroup.IsOptional);
             Assert.IsFalse(pGroup.JoinAsUnion);
+            Assert.IsFalse(pGroup.EvaluateAsService.HasValue);
             Assert.IsNotNull(pGroup.GroupMembers);
             Assert.IsTrue(pGroup.GroupMembers.Count == 0);
             Assert.IsNotNull(pGroup.Variables);
@@ -80,6 +82,7 @@ public void ShouldCreateUnionWithNextPatternGroup()
             Assert.IsTrue(pGroup.IsEvaluable);
             Assert.IsFalse(pGroup.IsOptional);
             Assert.IsTrue(pGroup.JoinAsUnion);
+            Assert.IsFalse(pGroup.EvaluateAsService.HasValue);
             Assert.IsNotNull(pGroup.GroupMembers);
             Assert.IsTrue(pGroup.GroupMembers.Count == 0);
             Assert.IsNotNull(pGroup.Variables);
@@ -94,6 +97,31 @@ public void ShouldCreateUnionWithNextPatternGroup()
             Assert.IsTrue(pGroup.GetEvaluablePatternGroupMembers().Count() == 0);
         }
 
+        [TestMethod]
+        public void ShouldCreateServicePatternGroup()
+        {
+            RDFPatternGroup pGroup = new RDFPatternGroup().AsService(new RDFSPARQLEndpoint(new Uri("ex:org")));
+
+            Assert.IsNotNull(pGroup);
+            Assert.IsTrue(pGroup.IsEvaluable);
+            Assert.IsFalse(pGroup.IsOptional);
+            Assert.IsFalse(pGroup.JoinAsUnion);
+            Assert.IsTrue(pGroup.EvaluateAsService.HasValue);
+            Assert.IsTrue(string.Equals(pGroup.EvaluateAsService.Value.Item1.ToString(), "ex:org"));
+            Assert.IsNotNull(pGroup.GroupMembers);
+            Assert.IsTrue(pGroup.GroupMembers.Count == 0);
+            Assert.IsNotNull(pGroup.Variables);
+            Assert.IsTrue(pGroup.Variables.Count == 0);
+            Assert.IsTrue(pGroup.ToString().Equals(string.Concat("  SERVICE <ex:org> {", Environment.NewLine, "    {", Environment.NewLine, "    }", Environment.NewLine, "  }", Environment.NewLine)));
+            Assert.IsTrue(pGroup.QueryMemberID.Equals(RDFModelUtilities.CreateHash(pGroup.QueryMemberStringID)));
+            Assert.IsTrue(pGroup.GetPatterns().Count() == 0);
+            Assert.IsTrue(pGroup.GetFilters().Count() == 0);
+            Assert.IsTrue(pGroup.GetPropertyPaths().Count() == 0);
+            Assert.IsTrue(pGroup.GetValues().Count() == 0);
+            Assert.IsTrue(pGroup.GetBinds().Count() == 0);
+            Assert.IsTrue(pGroup.GetEvaluablePatternGroupMembers().Count() == 0);
+        }
+
         [TestMethod]
         public void ShouldCreatePatternGroupWithPatterns()
         {