[tracker/wip/carlosg/sparql1.1: 48/56] libtracker-data: Handle ADD/MOVE/COPY/CLEAR
- From: Carlos Garnacho <carlosg src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [tracker/wip/carlosg/sparql1.1: 48/56] libtracker-data: Handle ADD/MOVE/COPY/CLEAR
- Date: Thu, 6 Jun 2019 11:20:12 +0000 (UTC)
commit 3d9658d3d999368fa5472adbfad11160d05a8948
Author: Carlos Garnacho <carlosg gnome org>
Date: Mon Jun 3 23:48:41 2019 +0200
libtracker-data: Handle ADD/MOVE/COPY/CLEAR
This allows management of graphs
src/libtracker-data/tracker-data-manager.c | 134 +++++++++++++++++++++++
src/libtracker-data/tracker-data-manager.h | 8 ++
src/libtracker-data/tracker-sparql.c | 170 +++++++++++++++++++++++++----
3 files changed, 289 insertions(+), 23 deletions(-)
---
diff --git a/src/libtracker-data/tracker-data-manager.c b/src/libtracker-data/tracker-data-manager.c
index 3362b5e31..9810ef4d3 100644
--- a/src/libtracker-data/tracker-data-manager.c
+++ b/src/libtracker-data/tracker-data-manager.c
@@ -5099,3 +5099,137 @@ tracker_data_manager_find_graph_by_id (TrackerDataManager *manager,
return NULL;
}
+
+gboolean
+tracker_data_manager_clear_graph (TrackerDataManager *manager,
+ const gchar *graph,
+ GError **error)
+{
+ TrackerOntologies *ontologies = manager->ontologies;
+ TrackerClass **classes;
+ TrackerProperty **properties;
+ TrackerDBStatement *stmt;
+ guint i, n_classes, n_properties;
+ GError *inner_error = NULL;
+ TrackerDBInterface *iface;
+
+ if (!graph)
+ graph = "main";
+
+ iface = tracker_db_manager_get_writable_db_interface (manager->db_manager);
+ classes = tracker_ontologies_get_classes (ontologies, &n_classes);
+ properties = tracker_ontologies_get_properties (ontologies, &n_properties);
+
+ for (i = 0; !inner_error && i < n_classes; i++) {
+ if (g_str_has_prefix (tracker_class_get_name (classes[i]), "xsd:"))
+ continue;
+
+ stmt = tracker_db_interface_create_statement (iface, TRACKER_DB_STATEMENT_CACHE_TYPE_NONE,
&inner_error,
+ "DELETE FROM \"%s\".\"%s\" WHERE ID >= 100000",
+ graph,
+ tracker_class_get_name (classes[i]));
+ if (!stmt)
+ break;
+
+ tracker_db_statement_execute (stmt, &inner_error);
+ g_object_unref (stmt);
+ }
+
+ for (i = 0; !inner_error && i < n_properties; i++) {
+ TrackerClass *service;
+
+ if (!tracker_property_get_multiple_values (properties[i]))
+ continue;
+
+ service = tracker_property_get_domain (properties[i]);
+ stmt = tracker_db_interface_create_statement (iface, TRACKER_DB_STATEMENT_CACHE_TYPE_NONE,
&inner_error,
+ "DELETE FROM \"%s\".\"%s_%s\" WHERE ID >=
100000",
+ graph,
+ tracker_class_get_name (service),
+ tracker_property_get_name (properties[i]));
+ if (!stmt)
+ break;
+
+ tracker_db_statement_execute (stmt, &inner_error);
+ g_object_unref (stmt);
+ }
+
+ if (inner_error) {
+ g_propagate_error (error, inner_error);
+ return FALSE;
+ }
+
+ return TRUE;
+}
+
+gboolean
+tracker_data_manager_copy_graph (TrackerDataManager *manager,
+ const gchar *source,
+ const gchar *destination,
+ GError **error)
+{
+ TrackerOntologies *ontologies = manager->ontologies;
+ TrackerClass **classes;
+ TrackerProperty **properties;
+ TrackerDBStatement *stmt;
+ guint i, n_classes, n_properties;
+ GError *inner_error = NULL;
+ TrackerDBInterface *iface;
+
+ if (!source)
+ source = "main";
+ if (!destination)
+ destination = "main";
+
+ iface = tracker_db_manager_get_writable_db_interface (manager->db_manager);
+ classes = tracker_ontologies_get_classes (ontologies, &n_classes);
+ properties = tracker_ontologies_get_properties (ontologies, &n_properties);
+
+ for (i = 0; !inner_error && i < n_classes; i++) {
+ if (g_str_has_prefix (tracker_class_get_name (classes[i]), "xsd:"))
+ continue;
+
+ stmt = tracker_db_interface_create_statement (iface, TRACKER_DB_STATEMENT_CACHE_TYPE_NONE,
&inner_error,
+ "INSERT INTO \"%s\".\"%s\" "
+ "SELECT * from \"%s\".\"%s\" WHERE ID >=
100000",
+ source,
+ tracker_class_get_name (classes[i]),
+ destination,
+ tracker_class_get_name (classes[i]));
+ if (!stmt)
+ break;
+
+ tracker_db_statement_execute (stmt, &inner_error);
+ g_object_unref (stmt);
+ }
+
+ for (i = 0; !inner_error && i < n_properties; i++) {
+ TrackerClass *service;
+
+ if (!tracker_property_get_multiple_values (properties[i]))
+ continue;
+
+ service = tracker_property_get_domain (properties[i]);
+ stmt = tracker_db_interface_create_statement (iface, TRACKER_DB_STATEMENT_CACHE_TYPE_NONE,
&inner_error,
+ "INSERT INTO \"%s\".\"%s_%s\" "
+ "SELECT * from \"%s\".\"%s_%s\" WHERE ID >=
100000",
+ source,
+ tracker_class_get_name (service),
+ tracker_property_get_name (properties[i]),
+ destination,
+ tracker_class_get_name (service),
+ tracker_property_get_name (properties[i]));
+ if (!stmt)
+ break;
+
+ tracker_db_statement_execute (stmt, &inner_error);
+ g_object_unref (stmt);
+ }
+
+ if (inner_error) {
+ g_propagate_error (error, inner_error);
+ return FALSE;
+ }
+
+ return TRUE;
+}
diff --git a/src/libtracker-data/tracker-data-manager.h b/src/libtracker-data/tracker-data-manager.h
index ebb992753..d703b0ea6 100644
--- a/src/libtracker-data/tracker-data-manager.h
+++ b/src/libtracker-data/tracker-data-manager.h
@@ -88,6 +88,14 @@ gboolean tracker_data_manager_drop_graph (TrackerDataManager *manag
const gchar *name,
GError **error);
+gboolean tracker_data_manager_clear_graph (TrackerDataManager *manager,
+ const gchar *graph,
+ GError **error);
+gboolean tracker_data_manager_copy_graph (TrackerDataManager *manager,
+ const gchar *source,
+ const gchar *destination,
+ GError **error);
+
gint tracker_data_manager_find_graph (TrackerDataManager *manager,
const gchar *name);
const gchar * tracker_data_manager_find_graph_by_id (TrackerDataManager *manager,
diff --git a/src/libtracker-data/tracker-sparql.c b/src/libtracker-data/tracker-sparql.c
index 893530fd0..181631b0f 100644
--- a/src/libtracker-data/tracker-sparql.c
+++ b/src/libtracker-data/tracker-sparql.c
@@ -2526,11 +2526,49 @@ translate_Load (TrackerSparql *sparql,
return TRUE;
}
+static gboolean
+handle_silent (gboolean silent,
+ GError *error_in,
+ GError **error)
+{
+ if (silent) {
+ g_error_free (error_in);
+ return TRUE;
+ } else {
+ g_propagate_error (error, error_in);
+ return FALSE;
+ }
+}
+
static gboolean
translate_Clear (TrackerSparql *sparql,
GError **error)
{
- _unimplemented ("CLEAR");
+ gboolean silent = FALSE;
+ GError *inner_error = NULL;
+
+ _expect (sparql, RULE_TYPE_LITERAL, LITERAL_CLEAR);
+
+ if (_accept (sparql, RULE_TYPE_LITERAL, LITERAL_SILENT))
+ silent = TRUE;
+
+ _call_rule (sparql, NAMED_RULE_GraphRefAll, error);
+
+ if (!tracker_token_is_empty (&sparql->current_state.graph)) {
+ const gchar *graph;
+
+ /* FIXME: check that graph exists */
+ graph = tracker_token_get_idstring (&sparql->current_state.graph);
+
+ if (!tracker_data_manager_clear_graph (sparql->data_manager,
+ graph, &inner_error)) {
+ return handle_silent (silent, inner_error, error);
+ }
+ } else {
+ g_assert_not_reached ();
+ }
+
+ return TRUE;
}
static gboolean
@@ -2548,19 +2586,13 @@ translate_Drop (TrackerSparql *sparql,
_call_rule (sparql, NAMED_RULE_GraphRefAll, error);
if (!tracker_token_is_empty (&sparql->current_state.graph)) {
- const gchar *graph_name;
+ const gchar *graph;
+
+ graph = tracker_token_get_idstring (&sparql->current_state.graph);
- graph_name = tracker_token_get_idstring (&sparql->current_state.graph);
if (!tracker_data_manager_drop_graph (sparql->data_manager,
- graph_name,
- &inner_error)) {
- if (silent) {
- g_error_free (inner_error);
- return TRUE;
- } else {
- g_propagate_error (error, inner_error);
- return FALSE;
- }
+ graph, &inner_error)) {
+ return handle_silent (silent, inner_error, error);
}
}
@@ -2601,34 +2633,124 @@ translate_Create (TrackerSparql *sparql,
return TRUE;
error:
- if (silent) {
- g_error_free (inner_error);
- return TRUE;
- } else {
- g_propagate_error (error, inner_error);
- return FALSE;
- }
+ return handle_silent (silent, inner_error, error);
}
static gboolean
translate_Add (TrackerSparql *sparql,
GError **error)
{
- _unimplemented ("ADD");
+ gboolean silent = FALSE;
+ gchar *source, *destination;
+ GError *inner_error = NULL;
+
+ _expect (sparql, RULE_TYPE_LITERAL, LITERAL_ADD);
+
+ if (_accept (sparql, RULE_TYPE_LITERAL, LITERAL_SILENT))
+ silent = TRUE;
+
+ /* FIXME: check that graphs exist */
+ _call_rule (sparql, NAMED_RULE_GraphOrDefault, error);
+ g_assert (!tracker_token_is_empty (&sparql->current_state.graph));
+ source = g_strdup (tracker_token_get_idstring (&sparql->current_state.graph));
+
+ _expect (sparql, RULE_TYPE_LITERAL, LITERAL_TO);
+
+ _call_rule (sparql, NAMED_RULE_GraphOrDefault, error);
+ g_assert (!tracker_token_is_empty (&sparql->current_state.graph));
+ destination = g_strdup (tracker_token_get_idstring (&sparql->current_state.graph));
+
+ if (!tracker_data_manager_copy_graph (sparql->data_manager,
+ source, destination,
+ &inner_error)) {
+ return handle_silent (silent, inner_error, error);
+ }
+
+ return TRUE;
}
static gboolean
translate_Move (TrackerSparql *sparql,
GError **error)
{
- _unimplemented ("MOVE");
+ gboolean silent = FALSE;
+ gchar *source, *destination;
+ GError *inner_error = NULL;
+
+ _expect (sparql, RULE_TYPE_LITERAL, LITERAL_MOVE);
+
+ if (_accept (sparql, RULE_TYPE_LITERAL, LITERAL_SILENT))
+ silent = TRUE;
+
+ /* FIXME: check that source exist, and destination doesn't */
+ _call_rule (sparql, NAMED_RULE_GraphOrDefault, error);
+ g_assert (!tracker_token_is_empty (&sparql->current_state.graph));
+ source = g_strdup (tracker_token_get_idstring (&sparql->current_state.graph));
+
+ _expect (sparql, RULE_TYPE_LITERAL, LITERAL_TO);
+
+ _call_rule (sparql, NAMED_RULE_GraphOrDefault, error);
+ g_assert (!tracker_token_is_empty (&sparql->current_state.graph));
+ destination = g_strdup (tracker_token_get_idstring (&sparql->current_state.graph));
+
+ if (!tracker_data_manager_create_graph (sparql->data_manager,
+ destination, &inner_error))
+ goto error;
+
+ if (!tracker_data_manager_copy_graph (sparql->data_manager,
+ source, destination,
+ &inner_error))
+ goto error;
+
+ if (!tracker_data_manager_drop_graph (sparql->data_manager,
+ source,
+ &inner_error))
+ goto error;
+
+ return TRUE;
+
+error:
+ return handle_silent (silent, inner_error, error);
}
static gboolean
translate_Copy (TrackerSparql *sparql,
GError **error)
{
- _unimplemented ("COPY");
+ gboolean silent = FALSE;
+ gchar *source, *destination;
+ GError *inner_error = NULL;
+
+ _expect (sparql, RULE_TYPE_LITERAL, LITERAL_COPY);
+
+ if (_accept (sparql, RULE_TYPE_LITERAL, LITERAL_SILENT))
+ silent = TRUE;
+
+ /* FIXME: check that source exist, and destination doesn't */
+ _call_rule (sparql, NAMED_RULE_GraphOrDefault, error);
+ g_assert (!tracker_token_is_empty (&sparql->current_state.graph));
+ source = g_strdup (tracker_token_get_idstring (&sparql->current_state.graph));
+
+ _expect (sparql, RULE_TYPE_LITERAL, LITERAL_TO);
+
+ _call_rule (sparql, NAMED_RULE_GraphOrDefault, error);
+ g_assert (!tracker_token_is_empty (&sparql->current_state.graph));
+ destination = g_strdup (tracker_token_get_idstring (&sparql->current_state.graph));
+
+ /* FIXME: check that source exists, dest may be already there or not */
+ if (!tracker_data_manager_clear_graph (sparql->data_manager,
+ destination, &inner_error))
+ goto error;
+
+ if (!tracker_data_manager_copy_graph (sparql->data_manager,
+ source, destination,
+ &inner_error))
+ goto error;
+
+ return TRUE;
+
+error:
+ return handle_silent (silent, inner_error, error);
}
static gboolean
@@ -3044,10 +3166,12 @@ translate_GraphOrDefault (TrackerSparql *sparql,
/* GraphOrDefault ::= 'DEFAULT' | 'GRAPH'? iri
*/
if (_accept (sparql, RULE_TYPE_LITERAL, LITERAL_DEFAULT)) {
-
+ tracker_token_unset (&sparql->current_state.graph);
} else {
_accept (sparql, RULE_TYPE_LITERAL, LITERAL_GRAPH);
_call_rule (sparql, NAMED_RULE_iri, error);
+ _init_token (&sparql->current_state.graph,
+ sparql->current_state.prev_node, sparql);
}
return TRUE;
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]
