Pair.make(Dependencies.FIELD_RESOURCE, "Long"),
Pair.make(Dependencies.FIELD_NAME, "String"),
Pair.make(Dependencies.FIELD_TYPES, "Text"),
- Pair.make(Dependencies.FIELD_GUID, "Text")
+ Pair.make(Dependencies.FIELD_GUID, "Text"),
+ Pair.make(Dependencies.FIELD_NAME_SEARCH, "Text"),
+ Pair.make(Dependencies.FIELD_TYPES_SEARCH, "Text")
};
final Resource resource;
long time2 = System.nanoTime();
if (PROFILE)
- System.out.println("Found " + entries.size() + " dependencies in " + 1e-6 * (time2 - time) + "ms for " + graph.getPossibleURI(subject) + ".");
+ LOGGER.info("Found " + entries.size() + " dependencies in " + 1e-6 * (time2 - time) + "ms for " + graph.getPossibleURI(subject) + ".");
ArrayList<Object[]> result = new ArrayList<Object[]>();
for (Entry entry : entries) {
if(entry.name == null) continue;
- result.add(new Object[] { ss.getRandomAccessId(entry.parent), ss.getRandomAccessId(entry.resource), entry.name, entry.types, entry.id });
+ result.add(new Object[] { ss.getRandomAccessId(entry.parent), ss.getRandomAccessId(entry.resource), entry.name, entry.types, entry.id, entry.name, entry.types });
}
return result;
@Override
public List<Map<String, Object>> query(RequestProcessor session, String search, String bindingPattern, Object[] constants, int maxResultCount) {
- if(!Dependencies.getBindingPattern().equals(bindingPattern)) throw new IllegalArgumentException("DependenciesRelation supports indexing only with 'bfffff'");
+ if(!Dependencies.getBindingPattern().equals(bindingPattern)) throw new IllegalArgumentException("DependenciesRelation supports indexing only with 'bfffffff'");
IndexedRelations indexer = session.getService(IndexedRelations.class);
return indexer.query(null, search, session, resource, (Resource)constants[0], maxResultCount);
}
@Override
public List<Resource> queryResources(RequestProcessor session, String search, String bindingPattern, Object[] constants, int maxResultCount) {
- if(!Dependencies.getBindingPattern().equals(bindingPattern)) throw new IllegalArgumentException("DependenciesRelation supports indexing only with 'bfffff'");
+ if(!Dependencies.getBindingPattern().equals(bindingPattern)) throw new IllegalArgumentException("DependenciesRelation supports indexing only with 'bfffffff'");
IndexedRelations indexer = session.getService(IndexedRelations.class);
return indexer.queryResources(null, search, session, resource, (Resource)constants[0], maxResultCount);
}
@Override
public List<Map<String, Object>> list(RequestProcessor session, String bindingPattern, Object[] constants, int maxResultCount) {
- if(!Dependencies.getBindingPattern().equals(bindingPattern)) throw new IllegalArgumentException("DependenciesRelation supports indexing only with 'bfffff'");
+ if(!Dependencies.getBindingPattern().equals(bindingPattern)) throw new IllegalArgumentException("DependenciesRelation supports indexing only with 'bfffffff'");
IndexedRelations indexer = session.getService(IndexedRelations.class);
return indexer.query(null, null, session, resource, (Resource)constants[0], maxResultCount);
}
if (modifiedComponent == null
|| modifiedComponent.getPredicate().equals(changeInformation))
continue;
- //System.err.println("+comp modi " + NameUtils.getSafeName(graph, renamedComponent, true));
+ if (DEBUG) {
+ LOGGER.info("+comp modi " + NameUtils.getSafeName(graph, modifiedComponent.getObject(), true));
+ LOGGER.info(" +value " + NameUtils.getSafeName(graph, value, true));
+ }
w.addComponentModification(modifiedComponent.getObject());
}
for (Resource value : parameter.changedResources()) {
w.addComponentModification(value);
}
for (StatementChange change : parameter.changedStatements()) {
- //System.err.println("-stm " + NameUtils.getSafeName(graph, change.getSubject(), true) + " " + NameUtils.getSafeName(graph, change.getPredicate(), true) + " " + NameUtils.getSafeName(graph, change.getObject(), true));
+ if (DEBUG)
+ LOGGER.info("-stm " + NameUtils.getSafeName(graph, change.getSubject(), true) + " " + NameUtils.getSafeName(graph, change.getPredicate(), true) + " " + NameUtils.getSafeName(graph, change.getObject(), true));
Resource subject = change.getSubject();
Resource predicate = change.getPredicate();
Resource object = change.getObject();
} else if (predicate.equals(l0.IsLinkedTo)) {
w.addLinkChange(subject);
} else /*if (graph.isSubrelationOf(predicate, l0.DependsOn))*/ {
- //System.err.println("-modi " + NameUtils.getSafeName(graph, subject, true));
+ if (DEBUG)
+ LOGGER.info("-modi " + NameUtils.getSafeName(graph, subject, true));
w.addComponentModification(subject);
}
}
TimeLogger.log(DependenciesRelation.class, "trackAndIndex.onEvent: starting index update processing");
if(DEBUG)
- System.err.println("Adding metadata " + event + " in revision " + graph.getService(ManagementSupport.class).getHeadRevisionId());
+ LOGGER.info("Adding metadata " + event + " in revision " + graph.getService(ManagementSupport.class).getHeadRevisionId());
WriteGraph w = (WriteGraph)graph;
if(!event.isEmpty())
Collection<Object[]> _replacementObjects = Collections.emptyList();
Collection<Pair<String, String>> _typeChanges = Collections.emptyList();
- if(DEBUG) System.out.println("MODEL: " + NameUtils.getSafeLabel(graph, model));
+ if(DEBUG) LOGGER.info("MODEL: " + NameUtils.getSafeLabel(graph, model));
// final Change[] changes = event.get(model);
- if(DEBUG) System.out.println(" CHANGES: " + Arrays.toString(changes));
+ if(DEBUG) LOGGER.info(" CHANGES: " + Arrays.toString(changes));
if (changes != null) {
_additions = new ArrayList<Object[]>();
_removals = new ArrayList<Object>();
if(!entry.isValid(graph)) continue;
Resource parent = graph.getPossibleObject(entry.component, L0.PartOf);
if (parent != null) {
- _additions.add(new Object[] { ss.getRandomAccessId(parent), ss.getRandomAccessId(entry.component), name, types, id != null ? id.indexString() : "" });
+ _additions.add(new Object[] { ss.getRandomAccessId(parent), ss.getRandomAccessId(entry.component), name, types, id != null ? id.indexString() : "", name, types});
} else {
- //System.err.println("resource " + entry.component + ": no parent for entry " + name + " " + types);
+ //LOGGER.info("resource " + entry.component + ": no parent for entry " + name + " " + types);
}
} else {
- //System.err.println("resource " + entry.component + ": " + name + " " + types);
+ //LOGGER.info("resource " + entry.component + ": " + name + " " + types);
}
} else if(_entry instanceof ComponentModification) {
ComponentModification entry = (ComponentModification)_entry;
if(part != null) {
_replacementKeys.add(ss.getRandomAccessId(entry.component));
_replacementObjects.add(new Object[] { ss.getRandomAccessId(part),
- ss.getRandomAccessId(entry.component), name, types, id != null ? id.indexString() : "" });
+ ss.getRandomAccessId(entry.component), name, types, id != null ? id.indexString() : "", name, types});
}
}
}
}
final boolean reset = linkChange || event.hasUnresolved;
- //System.err.println("dependencies(" + NameUtils.getSafeLabel(graph, model) + "): reset=" + reset + " linkChange=" + linkChange + " unresolved=" + event.hasUnresolved );
+ //LOGGER.info("dependencies(" + NameUtils.getSafeLabel(graph, model) + "): reset=" + reset + " linkChange=" + linkChange + " unresolved=" + event.hasUnresolved );
if (reset || !_additions.isEmpty() || !_removals.isEmpty() || !_replacementKeys.isEmpty() || !_typeChanges.isEmpty()) {
if (doReset) {
if(DEBUG) {
- System.err.println("resetIndex " + reset + " " + typeNameChanges);
+ LOGGER.info("resetIndex " + reset + " " + typeNameChanges);
}
indexer.removeAll(null, graph, DependenciesRelation.this, resource, model);
if (!replacementKeys.isEmpty() && (replacementKeys.size() == replacementObjects.size())) {
if(DEBUG) {
- System.out.println(replacementKeys.size() + " index replacements: " + replacementKeys);
+ LOGGER.info(replacementKeys.size() + " index replacements: " + replacementKeys);
}
didChange |= indexer.replace(null, graph, DependenciesRelation.this, resource, model, Dependencies.FIELD_RESOURCE, replacementKeys, replacementObjects);
}
if (!removals.isEmpty()) {
if(DEBUG) {
- System.out.println(removals.size() + " index removals: " + removals);
+ LOGGER.info(removals.size() + " index removals: " + removals);
}
indexer.remove(null, graph, DependenciesRelation.this, resource, model, Dependencies.FIELD_RESOURCE, removals);
didChange = true;
}
if (!additions.isEmpty()) {
if(DEBUG) {
- for(Object[] os : additions) System.err.println("Adding to index " + model + ": " + Arrays.toString(os));
+ for(Object[] os : additions) LOGGER.info("Adding to index " + model + ": " + Arrays.toString(os));
}
- //System.out.println(additions.size() + " index insertions");
+ //LOGGER.info(additions.size() + " index insertions");
indexer.insert(null, graph, DependenciesRelation.this, resource, model, additions);
didChange = true;
}
for (Pair<String, String> nr : typeChanges) {
String query = Dependencies.FIELD_RESOURCE + ":[" + nr.second + " TO " + nr.second + "]";
- //System.out.println("query: " + query);
+ //LOGGER.info("query: " + query);
List<Map<String, Object>> results = indexer.query(null, query, graph, resource, model, Integer.MAX_VALUE);
if (results.size() != 1) {
return true;
return true;
}
}
-// System.err.println("Type " + nr.first + " was unchanged.");
+// LOGGER.info("Type " + nr.first + " was unchanged.");
}
return false;
}
@Override
public void reset(RequestProcessor processor, Resource input) {
if (DEBUG) {
- System.out.println("DependenciesRelation.reset: " + input);
+ LOGGER.info("DependenciesRelation.reset: " + input);
new Exception("DependenciesRelation.reset(" + listener + ")").printStackTrace(System.out);
}
DependenciesListenerStore store = processor.getSession().getService(DependenciesListenerStore.class);
ArrayList<Object[]> result = new ArrayList<Object[]>(entries.size());
for (Entry entry : entries) {
- result.add(new Object[] { ss.getRandomAccessId(entry.parent), ss.getRandomAccessId(entry.resource), entry.name, entry.types, entry.id });
+ result.add(new Object[] { ss.getRandomAccessId(entry.parent), ss.getRandomAccessId(entry.resource), entry.name, entry.types, entry.id, entry.name, entry.types });
}
Layer0X L0X = Layer0X.getInstance(graph);