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

JUnit-test запроса QUERY к транзакции #23 #62

Open
Defasium wants to merge 2 commits into
base: master
Choose a base branch
from
Open

JUnit-test запроса QUERY к транзакции #23 #62

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
298c4ad
JUnit-test запроса QUERY к транзакции #23
Defasium Jun 27, 2019
d83a15e
Исправил response
Defasium Jun 27, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
220 changes: 220 additions & 0 deletions ...clipse.rdf4j/org.eclipse.rdf4j.jaxrs/src/test/java/com/example/myproject/test/testik.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,220 @@
package com.example.myproject.test;

import static org.junit.Assert.*;
import static org.ops4j.pax.exam.CoreOptions.*;

import javax.inject.Inject;

import jdk.nashorn.internal.ir.annotations.Reference;
import org.eclipse.rdf4j.http.server.repository.RepositoryConfigController;
import org.eclipse.rdf4j.http.server.transaction.ActiveTransactionRegistry;
import org.eclipse.rdf4j.http.server.transaction.TransactionQuery;
import org.eclipse.rdf4j.query.Update;
import org.eclipse.rdf4j.repository.Repository;
import org.eclipse.rdf4j.repository.RepositoryConnection;
import org.eclipse.rdf4j.repository.RepositoryException;
import org.eclipse.rdf4j.repository.config.ConfigTemplate;
import org.eclipse.rdf4j.repository.config.RepositoryConfig;
import org.eclipse.rdf4j.repository.manager.RepositoryManager;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.ops4j.pax.exam.Configuration;
import org.ops4j.pax.exam.Option;
import org.ops4j.pax.exam.junit.PaxExam;
import org.ops4j.pax.exam.karaf.options.LogLevelOption;
import org.ops4j.pax.exam.options.MavenArtifactUrlReference;
import org.ops4j.pax.exam.spi.reactors.ExamReactorStrategy;
import org.ops4j.pax.exam.spi.reactors.PerClass;
import static org.ops4j.pax.exam.karaf.options.KarafDistributionOption.features;

import java.io.*;
import java.net.*;
import java.util.HashMap;
import java.util.Map;
import java.util.Vector;

import org.apache.karaf.itests.KarafTestSupport;
import static org.ops4j.pax.exam.karaf.options.KarafDistributionOption.*;


@RunWith(PaxExam.class)
@ExamReactorStrategy(PerClass.class)
public class testik extends KarafTestSupport {

//@Inject
//private RepositoryManager manager;

@Override
@Configuration
public Option[] config() {
MavenArtifactUrlReference karafUrl = maven().groupId("org.apache.karaf").artifactId("apache-karaf").versionAsInProject().type("tar.gz");

String httpPort = "8181";
String rmiRegistryPort = Integer.toString(getAvailablePort(Integer.parseInt(MIN_RMI_REG_PORT), Integer.parseInt(MAX_RMI_REG_PORT)));
String rmiServerPort = Integer.toString(getAvailablePort(Integer.parseInt(MIN_RMI_SERVER_PORT), Integer.parseInt(MAX_RMI_SERVER_PORT)));
String sshPort = Integer.toString(getAvailablePort(Integer.parseInt(MIN_SSH_PORT), Integer.parseInt(MAX_SSH_PORT)));
String localRepository = System.getProperty("org.ops4j.pax.url.mvn.localRepository");
if (localRepository == null) {
localRepository = "";
}

return new Option[] {
//KarafDistributionOption.debugConfiguration("8889", true),
karafDistributionConfiguration().frameworkUrl(karafUrl).name("Apache Karaf").unpackDirectory(new File("target/exam")),
// enable JMX RBAC security, thanks to the KarafMBeanServerBuilder
configureSecurity().disableKarafMBeanServerBuilder(),
// configureConsole().ignoreLocalConsole(),
keepRuntimeFolder(),
logLevel(LogLevelOption.LogLevel.INFO),
mavenBundle().groupId("org.awaitility").artifactId("awaitility").versionAsInProject(),
mavenBundle().groupId("org.apache.servicemix.bundles").artifactId("org.apache.servicemix.bundles.hamcrest").versionAsInProject(),
mavenBundle().groupId("org.apache.karaf.itests").artifactId("common").versionAsInProject(),
// mavenBundle().groupId("org.mockito").artifactId("mockito-core").version("2.23.4"),
features(maven().groupId("ru.agentlab.rdf4j.server")
.artifactId("ru.agentlab.rdf4j.server.features").type("xml")
.version("0.0.1-SNAPSHOT"), "org.eclipse.rdf4j.jaxrs"),
junitBundles(),
editConfigurationFilePut("etc/org.ops4j.pax.web.cfg", "org.osgi.service.http.port", httpPort),
editConfigurationFilePut("etc/org.apache.karaf.management.cfg", "rmiRegistryPort", rmiRegistryPort),
editConfigurationFilePut("etc/org.apache.karaf.management.cfg", "rmiServerPort", rmiServerPort),
editConfigurationFilePut("etc/org.apache.karaf.shell.cfg", "sshPort", sshPort),
editConfigurationFilePut("etc/org.ops4j.pax.url.mvn.cfg", "org.ops4j.pax.url.mvn.localRepository", localRepository)
};
}


@Test
public void makequery() throws IOException {
executeCommand("bundle:dynamic-import 75");
executeCommand("bundle:dynamic-import 175");
RepositoryConfigController rcc = getOsgiService(TransactionQuery.class);
String repId = "id127";
ConfigTemplate ct = rcc.getConfigTemplate("memory");
System.out.println("ConfigTemplate: " + ct);

Map<String, String> queryParams = new HashMap<>();
queryParams.put("Repository ID", repId);
String strConfTemplate = ct.render(queryParams);
System.out.println("ConfigTemplate render: " + strConfTemplate);
System.out.println("------------------------------");
System.out.println(strConfTemplate);
RepositoryConfig rc = rcc.updateRepositoryConfig(strConfTemplate);

RepositoryManager manager = getOsgiService(RepositoryManager.class);
Repository repository = manager.getRepository("id127");
RepositoryConnection repositoryConnection = repository.getConnection();

repositoryConnection.begin();

//добавили транзакцию
ActiveTransactionRegistry.INSTANCE.register("4321",repositoryConnection);
TransactionQuery controller = new TransactionQuery();

String body = "<?xml version=\"1.0\"?>\n" +
"\n" +
"<rdf:RDF\n" +
"xmlns:rdf=\"http://www.w3.org/1999/02/22-rdf-syntax-ns#\"\n" +
"xmlns:dc=\"http://ld-r.org/config/facetproperty_creator_adms3\"\n" +
"\n" +
"<rdf:Description rdf:about=\"http://example/book1/\">\n" +
"<facetproperty_creator_adms3title xmlns=\"http://ld-r.org/config/\">103</facetproperty_creator_adms3title>\n" +
"</rdf:Description>" +
"\n" +
"</rdf:RDF>";

String restLocation = "http://localhost:8181/rdf4j2-server/repositories/rpo13/transactions/4321";
URL url = null;
try {
url = new URL(restLocation + "?action=ADD");
} catch (MalformedURLException e) {
e.printStackTrace();
fail("Транзакция не успешна");
}


//добавили данные
HttpURLConnection connectionAdd = (HttpURLConnection) url.openConnection();
try {
connectionAdd.setRequestMethod("PUT");
connectionAdd.setDoOutput(true);
OutputStream os = connectionAdd.getOutputStream();
OutputStreamWriter osw = new OutputStreamWriter(os, "UTF-8");
osw.write(body);
osw.flush();
osw.close();
os.close(); //don't forget to close the OutputStream
connectionAdd.connect();
if (connectionAdd.getResponseCode() != 200) {
repositoryConnection.close();
fail("Транзакция не успешна");
}
connectionAdd.disconnect();

} catch (Exception e) {
e.printStackTrace();
connectionAdd.disconnect();
repositoryConnection.close();
fail("Транзакция не успешна");
}


//query
//SELECT ?s ?p ?o WHERE {<http://example/book1/> <http://ld-r.org/config> 103 . ?s ?p ?o . }
String query = URLEncoder.encode("queryLn=SPARQL&query="+
"PREFIX dc: <http://ld-r.org/config/facetproperty_creator_adms3>\n"+
"SELECT ?o ?s ?p WHERE { <http://example/book1/> <http://ld-r.org/config> 103 . ?o ?s ?p . }\n" +
"&infer=true", enc="UTF-8");
String loc = restLocation + "?action=GET&" + query;
URL url2 = null;
try {
url2 = new URL(loc);
} catch (MalformedURLException e) {
e.printStackTrace();
repositoryConnection.close();
fail("Транзакция не успешна");
}


HttpURLConnection connection2 = (HttpURLConnection) url2.openConnection();
HttpURLConnection response2 = (HttpURLConnection) url2.openConnection();
try {
connection2.setRequestMethod("PUT");
controller.handleRequestInternal(connection2, response2, "rpo13", "4321");
connection2.disconnect();
if (connectionAdd.getResponseCode() != 200) {
repositoryConnection.close();
fail("Транзакция не успешна");
}
//read the inputstream and print it
String result;
BufferedInputStream bis = new BufferedInputStream(response2.getInputStream());
ByteArrayOutputStream buf = new ByteArrayOutputStream();
int result2 = bis.read();
while(result2 != -1) {
buf.write((byte) result2);
result2 = bis.read();
}
String data = buf.toString();
assertTrue(data.contains("<rdf:Description rdf:about=\"http://example/book1/\">\n" +
"<facetproperty_creator_adms3title xmlns=\"http://ld-r.org/config/\">103</facetproperty_creator_adms3title>\n" +
"</rdf:Description>"));

} catch (Exception e) {
e.printStackTrace();
repositoryConnection.close();
fail("Транзакция не успешна");
}
try {
ActiveTransactionRegistry.INSTANCE.deregister("4321");
} catch (Exception e){
assertEquals(e, new RepositoryException());
repositoryConnection.close();
fail("Транзакция не успешна");
}

connection2.close();
response2.disconnect();
repositoryConnection.close();
}
}