From: Andrea Zagli <azagli@libero.it>
Date: Sun, 16 Sep 2012 09:12:32 +0000 (+0200)
Subject: Comparing tables list.
X-Git-Url: https://saetta.ns0.it/gitweb?a=commitdiff_plain;h=19767887d2ccdded21a7c774790a85df536010f0;p=gdadbdiff

Comparing tables list.
---

diff --git a/.anjuta_sym_db.db b/.anjuta_sym_db.db
index 4750224..4966033 100644
Binary files a/.anjuta_sym_db.db and b/.anjuta_sym_db.db differ
diff --git a/src/main.c b/src/main.c
index 621cd1d..88f149c 100644
--- a/src/main.c
+++ b/src/main.c
@@ -25,8 +25,19 @@
 static gchar *ref_db_cnc = NULL;
 static gchar *db_cnc = NULL;
 
-GdaConnection *gda_conn_ref_db;
-GdaConnection *gda_conn_db;
+static GdaConnection *gda_conn_ref_db;
+static GdaConnection *gda_conn_db;
+
+typedef struct
+{
+	gchar *name;
+	GHashTable *ht_fields;
+} Table;
+
+typedef struct
+{
+	gchar *field_name;
+} Field;
 
 static GOptionEntry entries[] =
 {
@@ -60,7 +71,7 @@ update_metastore ()
 }
 
 static void
-read_tables (GdaConnection *gdacon)
+read_tables (GdaConnection *gdacon, GHashTable *ht)
 {
 	GError *error;
 
@@ -69,7 +80,7 @@ read_tables (GdaConnection *gdacon)
 	guint rows;
 	guint row;
 
-	gchar *table_name;
+	Table *table;
 
 	error = NULL;
 	dm_tables = gda_connection_get_meta_store_data (gdacon,
@@ -81,10 +92,44 @@ read_tables (GdaConnection *gdacon)
 			rows = gda_data_model_get_n_rows (dm_tables);
 			for (row = 0; row < rows; row++)
 				{
-					table_name = gda_value_stringify (gda_data_model_get_value_at (dm_tables, 0, row, NULL));
-					g_message ("Table: %s", table_name);
+					table = g_new0 (Table, 1);
+
+					table->name = gda_value_stringify (gda_data_model_get_value_at (dm_tables, 0, row, NULL));
+					g_message ("\tTable: %s", table->name);
+
+					g_hash_table_insert (ht, table->name, table);
+				}
+		}
+	if (dm_tables != NULL)
+		{
+			g_object_unref (dm_tables);
+		}
+}
+
+static gboolean
+comparing (GHashTable *ht_ref_db_tables, GHashTable *ht_db_tables)
+{
+	GHashTableIter iter;
+	gpointer key, value;
+
+	Table *table;
+
+	gboolean ret;
+
+	ret = TRUE;
+
+	g_hash_table_iter_init (&iter, ht_ref_db_tables);
+	while (g_hash_table_iter_next (&iter, &key, &value))
+		{
+			table = (Table *)value;
+			if (!g_hash_table_lookup (ht_db_tables, table->name))
+				{
+					g_message ("Table «%s» missing.", table->name);
+					ret = FALSE;
 				}
 		}
+
+	return ret;
 }
 
 int
@@ -93,6 +138,9 @@ main (int argc, char *argv[])
 	GError *error;
 	GOptionContext *context;
 
+	GHashTable *ht_ref_db_tables;
+	GHashTable *ht_db_tables;
+
 	g_type_init ();
 
 	error = NULL;
@@ -141,11 +189,23 @@ main (int argc, char *argv[])
 
 	update_metastore ();
 
-	g_message ("Reading tables of reference database.");
-	read_tables (gda_conn_ref_db);
+	g_message ("Reading tables of reference database (%s).", ref_db_cnc);
+	ht_ref_db_tables = g_hash_table_new (g_str_hash, g_str_equal);
+	read_tables (gda_conn_ref_db, ht_ref_db_tables);
+
+	g_message ("Reading tables of database (%s).", db_cnc);
+	ht_db_tables = g_hash_table_new (g_str_hash, g_str_equal);
+	read_tables (gda_conn_db, ht_db_tables);
 
-	g_message ("Reading tables of database.");
-	read_tables (gda_conn_db);
+	g_message ("Comparing databases.");
+	if (comparing (ht_ref_db_tables, ht_db_tables))
+		{
+			g_message ("Databases are equals.");
+		}
+	else
+		{
+			g_message ("Databases have one or more differences.");
+		}
 
 	g_object_unref (gda_conn_ref_db);
 	g_object_unref (gda_conn_db);