comparison examples/runner-rdf/populate.c @ 553:ea341e68649f

Produce embryonic example of integration with runner ("sonic annotator")

There's much that is hardwired (though a bit less than in the example
sent by e-mail to Casey, Cannam and Raimond).  More needs to be done,
including thinking about how a typical user will actually be using the
combination of tools; this code is proof-of-concept more than anything
else.

+#include <sys/stat.h>
+#include <librdf.h>
+#include <fcntl.h>
+#include <string.h>
+#include <stdlib.h>
+
+#include <audioDB_API.h>
+
+const char * qstring = 
+" PREFIX af: <http://purl.org/ontology/af/>"
+" PREFIX dc: <http://purl.org/dc/elements/1.1/>"
+" PREFIX mo: <http://purl.org/ontology/mo/>"
+" PREFIX tl: <http://purl.org/NET/c4dm/timeline.owl#>"
+
+" SELECT ?key ?value ?sample_rate ?window_length ?hop_size"
+" FROM <file:///home/csr21/tmp/rdf/test.n3> "
+
+" WHERE { "
+
+"   ?signal mo:available_as ?key ."
+
+"   ?signal mo:time [ tl:onTimeLine ?signal_timeline ] . "
+
+"   ?timeline_map a tl:UniformSamplingWindowingMap ; "
+"     tl:rangeTimeLine ?feature_timeline ; "
+"     tl:domainTimeLine ?signal_timeline ; "
+"     tl:sampleRate ?sample_rate ; "
+"     tl:windowLength ?window_length ; "
+"     tl:hopSize ?hop_size . "
+
+"   ?signal af:signal_feature ?feature . "
+
+"   ?feature a ?feature_signal_type ; "
+"     mo:time [ tl:onTimeLine ?feature_timeline ] ; "
+"     af:value ?value . "
+
+"   ?feature_signal_type dc:title \"Key Strength Plot\""
+
+" } "
+;
+
+double *parse_value_string(const char *value_string, size_t *nelements) {
+  /* What error checking? */
+
+  *nelements = 0;
+
+  const char *current = value_string;
+  char *next = 0;
+
+  size_t size = 1;
+  double *buf = (double *) malloc(size * sizeof(double));
+  double value = strtod(current, &next);
+  while(next != current) {
+    buf[(*nelements)++] = value;
+    if((*nelements) == size) {
+      size *= 2;
+      buf = (double *) realloc(buf, 2 * size * sizeof(double));
+    }
+    current = next;
+    value = strtod(current, &next);
+  }
+  
+}
+
+int main() {
+  librdf_world *world = librdf_new_world();
+  if(world == NULL) return 1;
+
+  librdf_storage *storage = librdf_new_storage(world, "memory", NULL, NULL);
+  if(storage == NULL) return 1;
+
+  librdf_model *model = librdf_new_model(world, storage, NULL);
+  if(model == NULL) return 1;
+
+  librdf_uri *uri = librdf_new_uri(world, "file:data/test.n3");
+  if(uri == NULL) return 1;
+
+  librdf_parser *parser = librdf_new_parser(world, "guess", NULL, NULL);
+  if(parser == NULL) return 1;
+
+  if(librdf_parser_parse_into_model(parser, uri, NULL, model)) return 1;
+  
+  librdf_query *query = 
+    librdf_new_query(world, "sparql", NULL, qstring, NULL);
+  if(query == NULL) return 1;
+
+  librdf_query_results *results = librdf_query_execute(query, model);
+  if(results == NULL) return 1;
+  if(!librdf_query_results_is_bindings(results)) return 1;
+
+  adb_t *adb = audiodb_open("keyplot.adb", O_RDWR);
+  if(!adb) {
+    fprintf(stderr, "keyplot.adb not opened\n");
+    return 1;
+  }
+  while(!librdf_query_results_finished(results)) {
+    int count = librdf_query_results_get_bindings_count(results);
+    adb_datum_t datum = {0};
+    datum.dim = 25;
+    for (int i = 0; i < count; i++) {
+      const char *name = librdf_query_results_get_binding_name(results, i);
+      librdf_node *node = librdf_query_results_get_binding_value(results, i);
+      if(!node) return 2;
+
+      if(!strcmp(name, "key")) {
+        datum.key = librdf_uri_as_string(librdf_node_get_uri(node));
+      } else if(!strcmp(name, "value")) {
+        size_t nelements = 0;
+        datum.data = parse_value_string(librdf_node_get_literal_value(node), &nelements);
+        if(nelements % 25) return 4;
+        datum.nvectors = nelements / 25;
+      } else {
+        printf("%s: %s\n", name, librdf_node_get_literal_value(node));
+      }
+      librdf_free_node(node);
+    }
+    if(audiodb_insert_datum(adb, &datum)) {
+      return 17;
+    }
+    librdf_query_results_next(results);
+  }
+
+  audiodb_close(adb);
+  librdf_free_query_results(results);
+  librdf_free_query(query);
+  librdf_free_uri(uri);
+  librdf_free_model(model);
+  librdf_free_storage(storage);
+  librdf_free_world(world);
+}