[tracker/gdbus: 17/22] libtracker-sparql: Do not hide DBusError

[Jürg Billeter <juergbi src gnome org>]

commit aec4c55ec86b2c9e1774c50991688df2ddceac96
Author: Jürg Billeter <j bitron ch>
Date:   Mon Oct 25 14:19:39 2010 +0200

    libtracker-sparql: Do not hide DBusError

 src/libtracker-bus/tracker-bus.vala           |  366 +++++++++++--------------
 src/libtracker-direct/tracker-direct.vala     |    4 +-
 src/libtracker-sparql/tracker-backend.vala    |   22 +-
 src/libtracker-sparql/tracker-connection.vala |   22 +-
 4 files changed, 191 insertions(+), 223 deletions(-)
---
diff --git a/src/libtracker-bus/tracker-bus.vala b/src/libtracker-bus/tracker-bus.vala
index f7fb0ce..2b0dc97 100644
--- a/src/libtracker-bus/tracker-bus.vala
+++ b/src/libtracker-bus/tracker-bus.vala
@@ -97,7 +97,7 @@ public class Tracker.Bus.Connection : Tracker.Sparql.Connection {
 		output = new UnixOutputStream (pipefd[1], true);
 	}
 
-	public override Sparql.Cursor query (string sparql, Cancellable? cancellable) throws Sparql.Error, IOError {
+	public override Sparql.Cursor query (string sparql, Cancellable? cancellable) throws Sparql.Error, IOError, DBusError {
 		// use separate main context for sync operation
 		var context = new MainContext ();
 		var loop = new MainLoop (context, false);
@@ -112,42 +112,38 @@ public class Tracker.Bus.Connection : Tracker.Sparql.Connection {
 		return query_async.end (async_res);
 	}
 
-	public async override Sparql.Cursor query_async (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError {
-		try {
-			UnixInputStream input;
-			UnixOutputStream output;
-			pipe (out input, out output);
-
-			// send D-Bus request
-			AsyncResult dbus_res = null;
-			bool received_result = false;
-			steroids_object.query.begin (sparql, output, cancellable, (o, res) => {
-				dbus_res = res;
-				if (received_result) {
-					query_async.callback ();
-				}
-			});
+	public async override Sparql.Cursor query_async (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
+		UnixInputStream input;
+		UnixOutputStream output;
+		pipe (out input, out output);
+
+		// send D-Bus request
+		AsyncResult dbus_res = null;
+		bool received_result = false;
+		steroids_object.query.begin (sparql, output, cancellable, (o, res) => {
+			dbus_res = res;
+			if (received_result) {
+				query_async.callback ();
+			}
+		});
 
-			output = null;
+		output = null;
 
-			// receive query results via FD
-			var mem_stream = new MemoryOutputStream (null, GLib.realloc, GLib.free);
-			yield mem_stream.splice_async (input, OutputStreamSpliceFlags.CLOSE_SOURCE | OutputStreamSpliceFlags.CLOSE_TARGET, Priority.DEFAULT, cancellable);
+		// receive query results via FD
+		var mem_stream = new MemoryOutputStream (null, GLib.realloc, GLib.free);
+		yield mem_stream.splice_async (input, OutputStreamSpliceFlags.CLOSE_SOURCE | OutputStreamSpliceFlags.CLOSE_TARGET, Priority.DEFAULT, cancellable);
 
-			// wait for D-Bus reply
-			received_result = true;
-			if (dbus_res == null) {
-				yield;
-			}
-			string[] variable_names = steroids_object.query.end (dbus_res);
-			mem_stream.close ();
-			return new FDCursor (mem_stream.steal_data (), mem_stream.data_size, variable_names);
-		} catch (DBusError e) {
-			throw new Sparql.Error.INTERNAL (e.message);
+		// wait for D-Bus reply
+		received_result = true;
+		if (dbus_res == null) {
+			yield;
 		}
+		string[] variable_names = steroids_object.query.end (dbus_res);
+		mem_stream.close ();
+		return new FDCursor (mem_stream.steal_data (), mem_stream.data_size, variable_names);
 	}
 
-	public override void update (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public override void update (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		// use separate main context for sync operation
 		var context = new MainContext ();
 		var loop = new MainLoop (context, false);
@@ -162,103 +158,95 @@ public class Tracker.Bus.Connection : Tracker.Sparql.Connection {
 		update_async.end (async_res);
 	}
 
-	public async override void update_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError {
-		try {
-			UnixInputStream input;
-			UnixOutputStream output;
-			pipe (out input, out output);
-
-			// send D-Bus request
-			AsyncResult dbus_res = null;
-			bool sent_update = false;
-			steroids_object.update_begin (input, priority, cancellable, (o, res) => {
-				dbus_res = res;
-				if (sent_update) {
-					update_async.callback ();
-				}
-			});
-
-			// send sparql string via fd
-			var data_stream = new DataOutputStream (output);
-			data_stream.set_byte_order (DataStreamByteOrder.HOST_ENDIAN);
-			data_stream.put_int32 ((int32) sparql.length);
-			data_stream.put_string (sparql);
-			data_stream = null;
-
-			// wait for D-Bus reply
-			sent_update = true;
-			if (dbus_res == null) {
-				yield;
+	public async override void update_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
+		UnixInputStream input;
+		UnixOutputStream output;
+		pipe (out input, out output);
+
+		// send D-Bus request
+		AsyncResult dbus_res = null;
+		bool sent_update = false;
+		steroids_object.update_begin (input, priority, cancellable, (o, res) => {
+			dbus_res = res;
+			if (sent_update) {
+				update_async.callback ();
 			}
+		});
 
-			if (priority >= GLib.Priority.DEFAULT) {
-				steroids_object.update.end (dbus_res);
-			} else {
-				steroids_object.batch_update.end (dbus_res);
-			}
-		} catch (DBusError e) {
-			throw new Sparql.Error.INTERNAL (e.message);
+		// send sparql string via fd
+		var data_stream = new DataOutputStream (output);
+		data_stream.set_byte_order (DataStreamByteOrder.HOST_ENDIAN);
+		data_stream.put_int32 ((int32) sparql.length);
+		data_stream.put_string (sparql);
+		data_stream = null;
+
+		// wait for D-Bus reply
+		sent_update = true;
+		if (dbus_res == null) {
+			yield;
+		}
+
+		if (priority >= GLib.Priority.DEFAULT) {
+			steroids_object.update.end (dbus_res);
+		} else {
+			steroids_object.batch_update.end (dbus_res);
 		}
 	}
 
-	public async override GenericArray<Error?> update_array_async (string[] sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError {
-		try {
-			UnixInputStream input;
-			UnixOutputStream output;
-			pipe (out input, out output);
-
-			// send D-Bus request
-			AsyncResult dbus_res = null;
-			bool sent_update = false;
-			steroids_object.update_array_begin (input, priority, cancellable, (o, res) => {
-				dbus_res = res;
-				if (sent_update) {
-					update_array_async.callback ();
-				}
-			});
-
-			// send sparql strings via fd
-			var data_stream = new DataOutputStream (output);
-			data_stream.set_byte_order (DataStreamByteOrder.HOST_ENDIAN);
-			data_stream.put_int32 ((int32) sparql.length);
-			for (int i = 0; i < sparql.length; i++) {
-				data_stream.put_int32 ((int32) sparql[i].length);
-				data_stream.put_string (sparql[i]);
+	public async override GenericArray<Error?> update_array_async (string[] sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
+		UnixInputStream input;
+		UnixOutputStream output;
+		pipe (out input, out output);
+
+		// send D-Bus request
+		AsyncResult dbus_res = null;
+		bool sent_update = false;
+		steroids_object.update_array_begin (input, priority, cancellable, (o, res) => {
+			dbus_res = res;
+			if (sent_update) {
+				update_array_async.callback ();
 			}
-			data_stream = null;
+		});
 
-			// wait for D-Bus reply
-			sent_update = true;
-			if (dbus_res == null) {
-				yield;
-			}
+		// send sparql strings via fd
+		var data_stream = new DataOutputStream (output);
+		data_stream.set_byte_order (DataStreamByteOrder.HOST_ENDIAN);
+		data_stream.put_int32 ((int32) sparql.length);
+		for (int i = 0; i < sparql.length; i++) {
+			data_stream.put_int32 ((int32) sparql[i].length);
+			data_stream.put_string (sparql[i]);
+		}
+		data_stream = null;
 
-			// process results (errors)
-			var result = new GenericArray<Error?> ();
-			Variant resultv;
-			if (priority >= GLib.Priority.DEFAULT) {
-				resultv = steroids_object.update_array.end (dbus_res);
-			} else {
-				resultv = steroids_object.batch_update_array.end (dbus_res);
-			}
-			var iter = resultv.iterator ();
-			string code, message;
-			while (iter.next ("s", out code)) {
-				if (iter.next ("s", out message)) {
-					if (code != "" && message != "") {
-						result.add (new Sparql.Error.INTERNAL (message));
-					} else {
-						result.add (null);
-					}
+		// wait for D-Bus reply
+		sent_update = true;
+		if (dbus_res == null) {
+			yield;
+		}
+
+		// process results (errors)
+		var result = new GenericArray<Error?> ();
+		Variant resultv;
+		if (priority >= GLib.Priority.DEFAULT) {
+			resultv = steroids_object.update_array.end (dbus_res);
+		} else {
+			resultv = steroids_object.batch_update_array.end (dbus_res);
+		}
+		var iter = resultv.iterator ();
+		string code, message;
+		while (iter.next ("s", out code)) {
+			if (iter.next ("s", out message)) {
+				if (code != "" && message != "") {
+					result.add (new Sparql.Error.INTERNAL (message));
+				} else {
+					result.add (null);
 				}
 			}
-			return result;
-		} catch (DBusError e) {
-			throw new Sparql.Error.INTERNAL (e.message);
 		}
+		return result;
 	}
 
-	public override GLib.Variant? update_blank (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public override GLib.Variant? update_blank (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		// use separate main context for sync operation
 		var context = new MainContext ();
 		var loop = new MainLoop (context, false);
@@ -273,104 +261,84 @@ public class Tracker.Bus.Connection : Tracker.Sparql.Connection {
 		return update_blank_async.end (async_res);
 	}
 
-	public async override GLib.Variant? update_blank_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError {
-		try {
-			UnixInputStream input;
-			UnixOutputStream output;
-			pipe (out input, out output);
-
-			// send D-Bus request
-			AsyncResult dbus_res = null;
-			bool sent_update = false;
-			steroids_object.update_blank.begin (input, cancellable, (o, res) => {
-				dbus_res = res;
-				if (sent_update) {
-					update_blank_async.callback ();
-				}
-			});
-
-			// send sparql strings via fd
-			var data_stream = new DataOutputStream (output);
-			data_stream.set_byte_order (DataStreamByteOrder.HOST_ENDIAN);
-			data_stream.put_int32 ((int32) sparql.length);
-			data_stream.put_string (sparql);
-			data_stream = null;
-
-			// wait for D-Bus reply
-			sent_update = true;
-			if (dbus_res == null) {
-				yield;
+	public async override GLib.Variant? update_blank_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
+		UnixInputStream input;
+		UnixOutputStream output;
+		pipe (out input, out output);
+
+		// send D-Bus request
+		AsyncResult dbus_res = null;
+		bool sent_update = false;
+		steroids_object.update_blank.begin (input, cancellable, (o, res) => {
+			dbus_res = res;
+			if (sent_update) {
+				update_blank_async.callback ();
 			}
+		});
 
-			return steroids_object.update_blank.end (dbus_res);
-		} catch (DBusError e) {
-			throw new Sparql.Error.INTERNAL (e.message);
+		// send sparql strings via fd
+		var data_stream = new DataOutputStream (output);
+		data_stream.set_byte_order (DataStreamByteOrder.HOST_ENDIAN);
+		data_stream.put_int32 ((int32) sparql.length);
+		data_stream.put_string (sparql);
+		data_stream = null;
+
+		// wait for D-Bus reply
+		sent_update = true;
+		if (dbus_res == null) {
+			yield;
 		}
+
+		return steroids_object.update_blank.end (dbus_res);
 	}
 
-	public override void load (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError {
-		try {
-			resources_object.load (file.get_uri (), cancellable);
+	public override void load (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
+		resources_object.load (file.get_uri (), cancellable);
 
-			if (cancellable != null && cancellable.is_cancelled ()) {
-				throw new IOError.CANCELLED ("Operation was cancelled");
-			}
-		} catch (DBusError e) {
-			throw new Sparql.Error.INTERNAL (e.message);
+		if (cancellable != null && cancellable.is_cancelled ()) {
+			throw new IOError.CANCELLED ("Operation was cancelled");
 		}
 	}
-	public async override void load_async (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError {
-		try {
-			yield resources_object.load_async (file.get_uri (), cancellable);
+	public async override void load_async (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
+		yield resources_object.load_async (file.get_uri (), cancellable);
 
-			if (cancellable != null && cancellable.is_cancelled ()) {
-				throw new IOError.CANCELLED ("Operation was cancelled");
-			}
-		} catch (DBusError e) {
-			throw new Sparql.Error.INTERNAL (e.message);
+		if (cancellable != null && cancellable.is_cancelled ()) {
+			throw new IOError.CANCELLED ("Operation was cancelled");
 		}
 	}
 
-	public override Sparql.Cursor? statistics (Cancellable? cancellable = null) throws Sparql.Error, IOError {
-		try {
-			string[,] results = statistics_object.Get (cancellable);
-			Sparql.ValueType[] types = new Sparql.ValueType[2];
-			string[] var_names = new string[2];
-
-			var_names[0] = "class";
-			var_names[1] = "count";
-			types[0] = Sparql.ValueType.STRING;
-			types[1] = Sparql.ValueType.INTEGER;
-
-			return new Tracker.Bus.ArrayCursor ((owned) results,
-			                                    results.length[0],
-			                                    results.length[1],
-			                                    var_names,
-			                                    types);
-		} catch (DBusError e) {
-			throw new Sparql.Error.INTERNAL (e.message);
-		}
+	public override Sparql.Cursor? statistics (Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
+		string[,] results = statistics_object.Get (cancellable);
+		Sparql.ValueType[] types = new Sparql.ValueType[2];
+		string[] var_names = new string[2];
+
+		var_names[0] = "class";
+		var_names[1] = "count";
+		types[0] = Sparql.ValueType.STRING;
+		types[1] = Sparql.ValueType.INTEGER;
+
+		return new Tracker.Bus.ArrayCursor ((owned) results,
+		                                    results.length[0],
+		                                    results.length[1],
+		                                    var_names,
+		                                    types);
 	}
 
-	public async override Sparql.Cursor? statistics_async (Cancellable? cancellable = null) throws Sparql.Error, IOError {
-		try {
-			string[,] results = yield statistics_object.Get_async (cancellable);
-			Sparql.ValueType[] types = new Sparql.ValueType[2];
-			string[] var_names = new string[2];
-
-			var_names[0] = "class";
-			var_names[1] = "count";
-			types[0] = Sparql.ValueType.STRING;
-			types[1] = Sparql.ValueType.INTEGER;
-
-			return new Tracker.Bus.ArrayCursor ((owned) results,
-			                                    results.length[0],
-			                                    results.length[1],
-			                                    var_names,
-			                                    types);
-		} catch (DBusError e) {
-			throw new Sparql.Error.INTERNAL (e.message);
-		}
+	public async override Sparql.Cursor? statistics_async (Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
+		string[,] results = yield statistics_object.Get_async (cancellable);
+		Sparql.ValueType[] types = new Sparql.ValueType[2];
+		string[] var_names = new string[2];
+
+		var_names[0] = "class";
+		var_names[1] = "count";
+		types[0] = Sparql.ValueType.STRING;
+		types[1] = Sparql.ValueType.INTEGER;
+
+		return new Tracker.Bus.ArrayCursor ((owned) results,
+		                                    results.length[0],
+		                                    results.length[1],
+		                                    var_names,
+		                                    types);
 	}
 }
 
diff --git a/src/libtracker-direct/tracker-direct.vala b/src/libtracker-direct/tracker-direct.vala
index 4efcf97..5bf37b8 100644
--- a/src/libtracker-direct/tracker-direct.vala
+++ b/src/libtracker-direct/tracker-direct.vala
@@ -45,7 +45,7 @@ public class Tracker.Direct.Connection : Tracker.Sparql.Connection {
 		}
 	}
 
-	public override Sparql.Cursor query (string sparql, Cancellable? cancellable) throws Sparql.Error, IOError {
+	public override Sparql.Cursor query (string sparql, Cancellable? cancellable) throws Sparql.Error, IOError, DBusError {
 		try {
 			var query_object = new Sparql.Query (sparql);
 			var cursor = query_object.execute_cursor ();
@@ -58,7 +58,7 @@ public class Tracker.Direct.Connection : Tracker.Sparql.Connection {
 		}
 	}
 
-	public async override Sparql.Cursor query_async (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public async override Sparql.Cursor query_async (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		// just creating the cursor won't block
 		return query (sparql, cancellable);
 	}
diff --git a/src/libtracker-sparql/tracker-backend.vala b/src/libtracker-sparql/tracker-backend.vala
index 832d34b..37be78a 100644
--- a/src/libtracker-sparql/tracker-backend.vala
+++ b/src/libtracker-sparql/tracker-backend.vala
@@ -87,7 +87,7 @@ class Tracker.Sparql.Backend : Connection {
 		is_initialized = true;
 	}
 
-	public override Cursor query (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError
+	public override Cursor query (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError
 	requires (bus != null || direct != null) {
 		debug ("%s(): '%s'", Log.METHOD, sparql);
 		if (direct != null) {
@@ -97,7 +97,7 @@ class Tracker.Sparql.Backend : Connection {
 		}
 	}
 
-	public async override Cursor query_async (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError
+	public async override Cursor query_async (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError
 	requires (bus != null || direct != null) {
 		debug ("%s(): '%s'", Log.METHOD, sparql);
 		if (direct != null) {
@@ -107,56 +107,56 @@ class Tracker.Sparql.Backend : Connection {
 		}
 	}
 
-	public override void update (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError
+	public override void update (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError
 	requires (bus != null) {
 		debug ("%s(priority:%d): '%s'", Log.METHOD, priority, sparql);
 		bus.update (sparql, priority, cancellable);
 	}
 
-	public override GLib.Variant? update_blank (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError
+	public override GLib.Variant? update_blank (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError
 	requires (bus != null) {
 		debug ("%s(priority:%d): '%s'", Log.METHOD, priority, sparql);
 		return bus.update_blank (sparql, priority, cancellable);
 	}
 
-	public async override void update_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError
+	public async override void update_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError
 	requires (bus != null) {
 		debug ("%s(priority:%d): '%s'", Log.METHOD, priority, sparql);
 		yield bus.update_async (sparql, priority, cancellable);
 	}
 
-	public async override GenericArray<Error?> update_array_async (string[] sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError
+	public async override GenericArray<Error?> update_array_async (string[] sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError
 	requires (bus != null) {
 		return yield bus.update_array_async (sparql, priority, cancellable);
 	}
 
-	public async override GLib.Variant? update_blank_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError
+	public async override GLib.Variant? update_blank_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError
 	requires (bus != null) {
 		debug ("%s(priority:%d): '%s'", Log.METHOD, priority, sparql);
 		return yield bus.update_blank_async (sparql, priority, cancellable);
 	}
 
-	public override void load (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError
+	public override void load (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError
 	requires (bus != null) {
 		var uri = file.get_uri ();
 		debug ("%s(): '%s'", Log.METHOD, uri);
 		bus.load (file, cancellable);
 	}
 
-	public async override void load_async (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError
+	public async override void load_async (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError
 	requires (bus != null) {
 		var uri = file.get_uri ();
 		debug ("%s(): '%s'", Log.METHOD, uri);
 		yield bus.load_async (file, cancellable);
 	}
 
-	public override Cursor? statistics (Cancellable? cancellable = null) throws Sparql.Error, IOError
+	public override Cursor? statistics (Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError
 	requires (bus != null) {
 		debug ("%s()", Log.METHOD);
 		return bus.statistics (cancellable);
 	}
 
-	public async override Cursor? statistics_async (Cancellable? cancellable = null) throws Sparql.Error, IOError
+	public async override Cursor? statistics_async (Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError
 	requires (bus != null) {
 		debug ("%s()", Log.METHOD);
 		return yield bus.statistics_async (cancellable);
diff --git a/src/libtracker-sparql/tracker-connection.vala b/src/libtracker-sparql/tracker-connection.vala
index 72f6bfd..e22780c 100644
--- a/src/libtracker-sparql/tracker-connection.vala
+++ b/src/libtracker-sparql/tracker-connection.vala
@@ -348,7 +348,7 @@ public abstract class Tracker.Sparql.Connection : Object {
 	 *
 	 * Since 0.10
 	 */
-	public abstract Cursor query (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError;
+	public abstract Cursor query (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError;
 
 	/**
 	 * tracker_sparql_connection_query_finish:
@@ -378,7 +378,7 @@ public abstract class Tracker.Sparql.Connection : Object {
 	 *
 	 * Since: 0.10
 	 */
-	public async abstract Cursor query_async (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError;
+	public async abstract Cursor query_async (string sparql, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError;
 
 	/**
 	 * tracker_sparql_connection_update:
@@ -393,7 +393,7 @@ public abstract class Tracker.Sparql.Connection : Object {
 	 *
 	 * Since: 0.10
 	 */
-	public virtual void update (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public virtual void update (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		warning ("Interface 'update' not implemented");
 	}
 
@@ -422,7 +422,7 @@ public abstract class Tracker.Sparql.Connection : Object {
 	 *
 	 * Since: 0.10
 	 */
-	public async virtual void update_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public async virtual void update_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		warning ("Interface 'update_async' not implemented");
 	}
 
@@ -487,7 +487,7 @@ public abstract class Tracker.Sparql.Connection : Object {
 	 *
 	 * Since: 0.10
 	 */
-	public async virtual GenericArray<Error?> update_array_async (string[] sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public async virtual GenericArray<Error?> update_array_async (string[] sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		warning ("Interface 'update_array_async' not implemented");
 		return null;
 	}
@@ -508,7 +508,7 @@ public abstract class Tracker.Sparql.Connection : Object {
 	 *
 	 * Since: 0.10
 	 */
-	public virtual GLib.Variant? update_blank (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public virtual GLib.Variant? update_blank (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		warning ("Interface 'update_blank' not implemented");
 		return null;
 	}
@@ -542,7 +542,7 @@ public abstract class Tracker.Sparql.Connection : Object {
 	 *
 	 * Since: 0.10
 	 */
-	public async virtual GLib.Variant? update_blank_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public async virtual GLib.Variant? update_blank_async (string sparql, int priority = GLib.Priority.DEFAULT, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		warning ("Interface 'update_blank_async' not implemented");
 		return null;
 	}
@@ -559,7 +559,7 @@ public abstract class Tracker.Sparql.Connection : Object {
 	 *
 	 * Since: 0.10
 	 */
-	public virtual void load (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public virtual void load (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		warning ("Interface 'load' not implemented");
 	}
 
@@ -587,7 +587,7 @@ public abstract class Tracker.Sparql.Connection : Object {
 	 *
 	 * Since: 0.10
 	 */
-	public async virtual void load_async (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public async virtual void load_async (File file, Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		warning ("Interface 'load_async' not implemented");
 	}
 
@@ -606,7 +606,7 @@ public abstract class Tracker.Sparql.Connection : Object {
 	 *
 	 * Since: 0.10
 	 */
-	public virtual Cursor? statistics (Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public virtual Cursor? statistics (Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		warning ("Interface 'statistics' not implemented");
 		return null;
 	}
@@ -638,7 +638,7 @@ public abstract class Tracker.Sparql.Connection : Object {
 	 *
 	 * Since: 0.10
 	 */
-	public async virtual Cursor? statistics_async (Cancellable? cancellable = null) throws Sparql.Error, IOError {
+	public async virtual Cursor? statistics_async (Cancellable? cancellable = null) throws Sparql.Error, IOError, DBusError {
 		warning ("Interface 'statistics_async' not implemented");
 		return null;
 	}