summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCarlos Garnacho <carlosg@gnome.org>2018-08-06 19:26:28 +0200
committerCarlos Garnacho <carlosg@gnome.org>2018-11-13 11:17:31 +0100
commita46f5e29503dbd6feceedefd545433bebd32751d (patch)
tree47a6f778129aa11f0e78a60c2a3819ae4706df27
parentf046b2bf47ad3f1720c0f95eb33c2e80177417e3 (diff)
downloadtracker-a46f5e29503dbd6feceedefd545433bebd32751d.tar.gz
libtracker-data: Flip the TrackerSparql switch
From now on, TrackerSparql will be used for handling SPARQL queries.
-rw-r--r--src/libtracker-data/tracker-data-query.c12
-rw-r--r--src/libtracker-data/tracker-data-update.c7
-rw-r--r--src/libtracker-direct/tracker-direct.c8
3 files changed, 15 insertions, 12 deletions
diff --git a/src/libtracker-data/tracker-data-query.c b/src/libtracker-data/tracker-data-query.c
index b6f553fbb..aebfacf61 100644
--- a/src/libtracker-data/tracker-data-query.c
+++ b/src/libtracker-data/tracker-data-query.c
@@ -31,7 +31,7 @@
#include "tracker-db-interface-sqlite.h"
#include "tracker-db-manager.h"
#include "tracker-ontologies.h"
-#include "tracker-sparql-query.h"
+#include "tracker-sparql.h"
GPtrArray*
tracker_data_query_rdf_type (TrackerDataManager *manager,
@@ -169,17 +169,17 @@ tracker_data_query_sparql_cursor (TrackerDataManager *manager,
const gchar *query,
GError **error)
{
- TrackerSparqlQuery *sparql_query;
- TrackerDBCursor *cursor;
+ TrackerSparql *sparql_query;
+ TrackerSparqlCursor *cursor;
g_return_val_if_fail (query != NULL, NULL);
- sparql_query = tracker_sparql_query_new (manager, query);
+ sparql_query = tracker_sparql_new (manager, query);
- cursor = tracker_sparql_query_execute_cursor (sparql_query, error);
+ cursor = tracker_sparql_execute_cursor (sparql_query, error);
g_object_unref (sparql_query);
- return cursor;
+ return TRACKER_DB_CURSOR (cursor);
}
diff --git a/src/libtracker-data/tracker-data-update.c b/src/libtracker-data/tracker-data-update.c
index 444e5efee..e687505bf 100644
--- a/src/libtracker-data/tracker-data-update.c
+++ b/src/libtracker-data/tracker-data-update.c
@@ -38,6 +38,7 @@
#include "tracker-ontologies.h"
#include "tracker-property.h"
#include "tracker-sparql-query.h"
+#include "tracker-sparql.h"
typedef struct _TrackerDataUpdateBuffer TrackerDataUpdateBuffer;
typedef struct _TrackerDataUpdateBufferResource TrackerDataUpdateBufferResource;
@@ -3687,7 +3688,7 @@ update_sparql (TrackerData *data,
GError **error)
{
GError *actual_error = NULL;
- TrackerSparqlQuery *sparql_query;
+ TrackerSparql *sparql_query;
GVariant *blank_nodes;
g_return_val_if_fail (update != NULL, NULL);
@@ -3698,8 +3699,8 @@ update_sparql (TrackerData *data,
return NULL;
}
- sparql_query = tracker_sparql_query_new_update (data->manager, update);
- blank_nodes = tracker_sparql_query_execute_update (sparql_query, blank, &actual_error);
+ sparql_query = tracker_sparql_new_update (data->manager, update);
+ blank_nodes = tracker_sparql_execute_update (sparql_query, blank, &actual_error);
g_object_unref (sparql_query);
if (actual_error) {
diff --git a/src/libtracker-direct/tracker-direct.c b/src/libtracker-direct/tracker-direct.c
index 3c54c7929..b7e2a8449 100644
--- a/src/libtracker-direct/tracker-direct.c
+++ b/src/libtracker-direct/tracker-direct.c
@@ -22,6 +22,7 @@
#include "tracker-direct.h"
#include <libtracker-data/tracker-data.h>
+#include <libtracker-data/tracker-sparql.h>
static TrackerDBManagerFlags default_flags = 0;
@@ -429,16 +430,17 @@ tracker_direct_connection_query (TrackerSparqlConnection *self,
{
TrackerDirectConnectionPrivate *priv;
TrackerDirectConnection *conn;
- TrackerSparqlQuery *query;
+ TrackerSparql *query;
TrackerSparqlCursor *cursor;
conn = TRACKER_DIRECT_CONNECTION (self);
priv = tracker_direct_connection_get_instance_private (conn);
g_mutex_lock (&priv->mutex);
- query = tracker_sparql_query_new (priv->data_manager, sparql);
- cursor = TRACKER_SPARQL_CURSOR (tracker_sparql_query_execute_cursor (query, error));
+ query = tracker_sparql_new (priv->data_manager, sparql);
+ cursor = tracker_sparql_execute_cursor (query, error);
g_object_unref (query);
+
if (cursor)
tracker_sparql_cursor_set_connection (cursor, self);
g_mutex_unlock (&priv->mutex);