Comparing tables list.

diff --git a/.anjuta_sym_db.db b/.anjuta_sym_db.db
index 47502246193c39b910552aac7b492894091fdb2f..4966033fcbef8e4b68722743916d1060c36bc1dd 100644 (file)
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 621cd1d591fa15d913cb405762689a493f41c8ae..88f149cd16f3aa5ef7ea0f274c4448a32dd8ee47 100644 (file)
--- 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);