Skip to content

Commit 0a8235a

Browse files
committed
elasticstore and lmdb fixes
1 parent 4f69381 commit 0a8235a

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

core/sail/elasticsearch-store/src/main/java/org/eclipse/rdf4j/sail/elasticsearchstore/ElasticsearchDataStructure.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -243,6 +243,8 @@ private QueryBuilder getQueryBuilder(Resource subject, IRI predicate, Value obje
243243
if (((Literal) object).getLanguage().isPresent()) {
244244
boolQueryBuilder
245245
.must(QueryBuilders.termQuery("object_Lang", ((Literal) object).getLanguage().get()));
246+
boolQueryBuilder
247+
.must(QueryBuilders.termQuery("object_LangDir", ((Literal) object).getBaseDirection().toString()));
246248
}
247249
}
248250
}
@@ -450,7 +452,7 @@ private Map<String, Object> statementToJsonMap(ExtensibleStatement statement) {
450452
((Literal) statement.getObject()).getDatatype().stringValue());
451453
if (((Literal) statement.getObject()).getLanguage().isPresent()) {
452454
jsonMap.put("object_Lang", ((Literal) statement.getObject()).getLanguage().get());
453-
455+
jsonMap.put("object_LangDir", ((Literal) statement.getObject()).getBaseDirection().toString());
454456
}
455457
}
456458
return jsonMap;
@@ -673,8 +675,8 @@ private static ExtensibleStatement sourceToStatement(Map<String, Object> sourceA
673675
objectRes = vf.createBNode(objectString);
674676
} else {
675677
if (sourceAsMap.containsKey("object_Lang")) {
676-
objectRes = vf.createLiteral(objectString, (String) sourceAsMap.get("object_Lang"));
677-
678+
objectRes = vf.createLiteral(objectString, (String) sourceAsMap.get("object_Lang"),
679+
Literal.BaseDirection.fromString((String) sourceAsMap.get("object_LangDir")));
678680
} else {
679681
objectRes = vf.createLiteral(objectString,
680682
vf.createIRI((String) sourceAsMap.get("object_Datatype")));

core/sail/lmdb/src/main/java/org/eclipse/rdf4j/sail/lmdb/model/LmdbLiteral.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ public LmdbLiteral(ValueStoreRevision revision, String label, String language, B
9898
} else {
9999
setDatatype(CoreDatatype.RDF.LANGSTRING);
100100
}
101-
setInternalID(UNKNOWN_ID, revision);
101+
setInternalID(internalID, revision);
102102
this.initialized = true;
103103
}
104104

0 commit comments

Comments
 (0)