[evolution-data-server/openismus-work-master: 2/3] EBookBackendSqliteDB: Added e_book_backend_sqlitedb_get/set_revision()

[Tristan Van Berkom <tvb src gnome org>]

commit 66238d703ced9be3a351f12ffb5bf92ce09ccdee
Author: Tristan Van Berkom <tristanvb openismus com>
Date:   Mon Oct 29 14:40:47 2012 +0900

    EBookBackendSqliteDB: Added e_book_backend_sqlitedb_get/set_revision()
    
    In preperation for the migration, there needs to be a way to persist the
    overall addressbook revision. This patch also increments the internal
    SQLite DB format version and adds the new revision column to for main
    folders table of an addressbook (and increments the stored DB version)
    if the DB version is out of date.

 .../libedata-book/e-book-backend-sqlitedb.c        |  158 +++++++++++++++++--
 .../libedata-book/e-book-backend-sqlitedb.h        |   11 ++
 2 files changed, 152 insertions(+), 17 deletions(-)
---
diff --git a/addressbook/libedata-book/e-book-backend-sqlitedb.c b/addressbook/libedata-book/e-book-backend-sqlitedb.c
index 89a7261..e674740 100644
--- a/addressbook/libedata-book/e-book-backend-sqlitedb.c
+++ b/addressbook/libedata-book/e-book-backend-sqlitedb.c
@@ -40,7 +40,7 @@
 #define d(x)
 
 #define DB_FILENAME "contacts.db"
-#define FOLDER_VERSION 1
+#define FOLDER_VERSION 2
 
 #define READER_LOCK(ebsdb) g_rw_lock_reader_lock (&ebsdb->priv->rwlock)
 #define READER_UNLOCK(ebsdb) g_rw_lock_reader_unlock (&ebsdb->priv->rwlock)
@@ -341,11 +341,27 @@ book_backend_sqlitedb_end_transaction (EBookBackendSqliteDB *ebsdb,
 	return res;
 }
 
+static gint
+collect_versions_cb (gpointer ref,
+		     gint col,
+		     gchar **cols,
+		     gchar **name)
+{
+	gint *ret = ref;
+
+	/* Just collect the first result, all folders should always have the same DB version */
+	*ret = cols [0] ? strtoul (cols [0], NULL, 10) : 0;
+
+	return 0;
+}
+
 static void
 create_folders_table (EBookBackendSqliteDB *ebsdb,
                       GError **error)
 {
 	GError *err = NULL;
+	gint    version = 0;
+
 	/* sync_data points to syncronization data, it could be last_modified time
 	 * or a sequence number or some text depending on the backend.
 	 *
@@ -361,7 +377,8 @@ create_folders_table (EBookBackendSqliteDB *ebsdb,
 			     "  sync_data TEXT,"
 			     " is_populated INTEGER,"
 			     "  partial_content INTEGER,"
-			     " version INTEGER)";
+			     " version INTEGER,"
+		             "  revision TEXT)";
 
 	book_backend_sqlitedb_start_transaction (ebsdb, &err);
 
@@ -381,6 +398,26 @@ create_folders_table (EBookBackendSqliteDB *ebsdb,
 		book_backend_sql_exec (ebsdb->priv->db, stmt, NULL, NULL, &err);
 	}
 
+	/* Fetch the version, it should be the same for all folders (hence the LIMIT) */
+	if (!err) {
+		stmt = "SELECT version FROM folders LIMIT 1";
+		book_backend_sql_exec (ebsdb->priv->db, stmt, collect_versions_cb, &version, &err);
+	}
+
+	/* Upgrade DB to version 2, add the 'revision' column
+	 *
+	 * (version = 0 indicates that it did not exist and we just created the table)
+	 */
+	if (!err && version >= 1 && version < 2) {
+		stmt = "ALTER TABLE folders ADD COLUMN revision TEXT";
+		book_backend_sql_exec (ebsdb->priv->db, stmt, NULL, NULL, &err);
+	}
+
+	if (!err && version >= 1 && version < 2) {
+		stmt = "UPDATE TABLE folders SET version = 2";
+		book_backend_sql_exec (ebsdb->priv->db, stmt, NULL, NULL, &err);
+	}
+
 	book_backend_sqlitedb_end_transaction (ebsdb, !err, err ? NULL : &err);
 
 	if (err)
@@ -402,8 +439,8 @@ add_folder_into_db (EBookBackendSqliteDB *ebsdb,
 
 	if (!err) {
 		stmt = sqlite3_mprintf (
-			"INSERT OR IGNORE INTO folders VALUES ( %Q, %Q, %Q, %d, %d, %d ) ",
-			folderid, folder_name, NULL, 0, 0, FOLDER_VERSION);
+			"INSERT OR IGNORE INTO folders VALUES ( %Q, %Q, %Q, %d, %d, %d, %Q ) ",
+			folderid, folder_name, NULL, 0, 0, FOLDER_VERSION, NULL);
 
 		book_backend_sql_exec (ebsdb->priv->db, stmt, NULL, NULL, &err);
 
@@ -1983,6 +2020,106 @@ e_book_backend_sqlitedb_set_is_populated (EBookBackendSqliteDB *ebsdb,
 	return !err;
 }
 
+static gint
+get_string_cb (gpointer ref,
+	       gint col,
+	       gchar **cols,
+	       gchar **name)
+{
+	gchar **ret = ref;
+
+	*ret = g_strdup (cols [0]);
+
+	return 0;
+}
+
+/**
+ * e_book_backend_sqlitedb_get_revision:
+ * @ebsdb: An #EBookBackendSqliteDB
+ * @folderid: folder id of the address-book
+ * @revision_out: (out) (transfer full): The location to return the current revision
+ * @error: A location to store any error that may have occurred
+ *
+ * Fetches the current revision for the address-book indicated by @folderid.
+ *
+ * Upon success, @revision_out will hold the returned revision, otherwise
+ * %FALSE will be returned and @error will be updated accordingly.
+ *
+ * Returns: Whether the revision was successfully fetched.
+ *
+ * Since: 3.8
+ */
+gboolean
+e_book_backend_sqlitedb_get_revision (EBookBackendSqliteDB *ebsdb,
+				      const gchar *folderid,
+				      gchar **revision_out,
+				      GError **error)
+{
+	gchar *stmt;
+	GError *err = NULL;
+
+	g_return_val_if_fail (E_IS_BOOK_BACKEND_SQLITEDB (ebsdb), FALSE);
+	g_return_val_if_fail (folderid && folderid[0], FALSE);
+	g_return_val_if_fail (revision_out != NULL && *revision_out == NULL, FALSE);
+
+	READER_LOCK (ebsdb);
+
+	stmt = sqlite3_mprintf ("SELECT revision FROM folders WHERE folder_id = %Q", folderid);
+	book_backend_sql_exec (ebsdb->priv->db, stmt, get_string_cb, &revision_out, &err);
+	sqlite3_free (stmt);
+
+	READER_UNLOCK (ebsdb);
+
+	if (err)
+		g_propagate_error (error, err);
+
+	return !err;
+}
+
+/**
+ * e_book_backend_sqlitedb_set_revision:
+ * @ebsdb: An #EBookBackendSqliteDB
+ * @folderid: folder id of the address-book
+ * @revision: The new revision
+ * @error: A location to store any error that may have occurred
+ *
+ * Sets the current revision for the address-book indicated by @folderid to be @revision.
+ *
+ * Returns: Whether the revision was successfully set.
+ *
+ * Since: 3.8
+ */
+gboolean
+e_book_backend_sqlitedb_set_revision (EBookBackendSqliteDB *ebsdb,
+				      const gchar *folderid,
+				      const gchar *revision,
+				      GError **error)
+{
+	gchar *stmt = NULL;
+	GError *err = NULL;
+
+	g_return_val_if_fail (E_IS_BOOK_BACKEND_SQLITEDB (ebsdb), FALSE);
+	g_return_val_if_fail (folderid && folderid[0], FALSE);
+
+	book_backend_sqlitedb_start_transaction (ebsdb, &err);
+
+	if (!err) {
+		stmt = sqlite3_mprintf ("UPDATE folders SET revision = %Q WHERE folder_id = %Q",
+					revision, folderid);
+		book_backend_sql_exec (ebsdb->priv->db, stmt, NULL, NULL, &err);
+		sqlite3_free (stmt);
+	}
+
+	book_backend_sqlitedb_end_transaction (ebsdb, !err, err ? NULL : &err);
+
+	if (err)
+		g_propagate_error (error, err);
+
+	return !err;
+
+}
+
+
 /**
  * e_book_backend_sqlitedb_get_has_partial_content 
  * @ebsdb: 
@@ -2054,19 +2191,6 @@ e_book_backend_sqlitedb_set_has_partial_content (EBookBackendSqliteDB *ebsdb,
 	return !err;
 }
 
-static gint
-get_string_cb (gpointer ref,
-               gint col,
-               gchar **cols,
-               gchar **name)
-{
-	gchar **ret = ref;
-
-	*ret = g_strdup (cols [0]);
-
-	return 0;
-}
-
 /**
  * e_book_backend_sqlitedb_get_contact_bdata:
  *
diff --git a/addressbook/libedata-book/e-book-backend-sqlitedb.h b/addressbook/libedata-book/e-book-backend-sqlitedb.h
index d46edc3..7dd0114 100644
--- a/addressbook/libedata-book/e-book-backend-sqlitedb.h
+++ b/addressbook/libedata-book/e-book-backend-sqlitedb.h
@@ -166,6 +166,17 @@ gboolean	e_book_backend_sqlitedb_set_is_populated
 							 const gchar *folderid,
 							 gboolean populated,
 							 GError **error);
+
+gboolean        e_book_backend_sqlitedb_get_revision    (EBookBackendSqliteDB *ebsdb,
+							 const gchar *folderid,
+							 gchar **revision_out,
+							 GError **error);
+
+gboolean	e_book_backend_sqlitedb_set_revision    (EBookBackendSqliteDB *ebsdb,
+							 const gchar *folderid,
+							 const gchar *revision,
+							 GError **error);
+
 gchar *		e_book_backend_sqlitedb_get_sync_data
 							(EBookBackendSqliteDB *ebsdb,
 							 const gchar *folderid,