Revision 49083
Added by Alessia Bardi about 7 years ago
| modules/dnet-parthenos-publisher/trunk/src/main/java/eu/dnetlib/parthenos/virtuoso/VirtuosoClient.java | ||
|---|---|---|
| 1 | 1 |
package eu.dnetlib.parthenos.virtuoso; |
| 2 | 2 |
|
| 3 |
import java.io.IOException; |
|
| 4 | 3 |
import java.util.Map; |
| 5 | 4 |
|
| 6 | 5 |
import eu.dnetlib.parthenos.publisher.ParthenosPublisherException; |
| ... | ... | |
| 68 | 67 |
} |
| 69 | 68 |
|
| 70 | 69 |
public long feed(final String record) throws ParthenosPublisherException{
|
| 71 |
log.debug("Feeding one record");
|
|
| 72 | 70 |
try {
|
| 73 | 71 |
if (StringUtils.isBlank(record)) {
|
| 74 | 72 |
log.warn("Got empty record");
|
| ... | ... | |
| 89 | 87 |
String dsInterface = extractFromRecord(record, xpathSelectorDatasourceApi); |
| 90 | 88 |
|
| 91 | 89 |
String namedGraph = getRecordDefaultURI(objIdentifier, dsInterface); |
| 90 |
log.debug("Trying to open the database model " + namedGraph+", connection string "+getConnectionString());
|
|
| 92 | 91 |
Model md = VirtModel.openDatabaseModel(namedGraph, getConnectionString(), getUsername(), getPassword()); |
| 93 | 92 |
log.debug("Opened virtuoso model for graph " + namedGraph);
|
| 94 | 93 |
md.removeAll(); |
| ... | ... | |
| 101 | 100 |
log.debug("provenance graph for " + namedGraph + " updated with " + ntriples + " triples");
|
| 102 | 101 |
|
| 103 | 102 |
return size; |
| 104 |
}catch(IOException e){
|
|
| 103 |
}catch(Throwable e){
|
|
| 104 |
log.error(e.getMessage()); |
|
| 105 | 105 |
throw new ParthenosPublisherException(e); |
| 106 | 106 |
} |
| 107 | 107 |
} |
Also available in: Unified diff
Log errors