Skip to content
This repository was archived by the owner on Oct 8, 2020. It is now read-only.

Commit 2ad4eab

Browse files
committed
added sparqlify sparql server test case
1 parent a32e5b6 commit 2ad4eab

File tree

4 files changed

+52
-0
lines changed

4 files changed

+52
-0
lines changed

.gitignore

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,3 +19,6 @@ project/plugins/project/
1919
.worksheet
2020
.idea/
2121
*.iml
22+
23+
deptree.txt
24+

pom.xml

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -224,6 +224,14 @@
224224
<version>${sansa.version}</version>
225225
</dependency>
226226

227+
<dependency>
228+
<groupId>com.holdenkarau</groupId>
229+
<artifactId>spark-testing-base_${scala.binary.version}</artifactId>
230+
<version>2.3.0_0.9.0</version>
231+
<scope>test</scope>
232+
</dependency>
233+
234+
227235
</dependencies>
228236
</dependencyManagement>
229237

sansa-examples-spark/pom.xml

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -146,6 +146,13 @@
146146
<artifactId>scopt_${scala.binary.version}</artifactId>
147147
</dependency>
148148

149+
<!--
150+
<dependency>
151+
<groupId>com.holdenkarau</groupId>
152+
<artifactId>spark-testing-base_${scala.binary.version}</artifactId>
153+
</dependency>
154+
-->
155+
149156
</dependencies>
150157

151158
<build>
Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
package net.sansa_stack.examples.spark.query
2+
3+
import org.scalatest.FunSuite
4+
5+
import org.aksw.jena_sparql_api.server.utils.FactoryBeanSparqlServer
6+
import org.aksw.jena_sparql_api.core.FluentQueryExecutionFactory
7+
8+
import org.apache.jena.rdf.model.ModelFactory
9+
10+
import org.apache.jena.rdfconnection.{RDFConnectionFactory, RDFConnection}
11+
12+
class SparqlServerTests extends FunSuite {
13+
test("starting the default SPARQL server should succeed") {
14+
15+
val server = new FactoryBeanSparqlServer()
16+
.setSparqlServiceFactory(FluentQueryExecutionFactory
17+
.from(ModelFactory.createDefaultModel())
18+
.create())
19+
.create();
20+
21+
while(server.isStarting) {
22+
Thread.sleep(1000)
23+
}
24+
25+
val conn = RDFConnectionFactory.connect("http://localhost:7531");
26+
val model = conn.queryConstruct("CONSTRUCT WHERE { ?s ?p ?o }")
27+
28+
server.stop()
29+
server.join()
30+
31+
assert(true)
32+
}
33+
}
34+

0 commit comments

Comments
 (0)