From dcefdc78c796f94b56593d2f02e14877f280b0ad Mon Sep 17 00:00:00 2001
From: Andrea Zagli <azagli@libero.it>
Date: Sun, 16 Sep 2012 11:42:06 +0200
Subject: [PATCH] Reading tables fields.

---
 .anjuta_sym_db.db | Bin 36864 -> 36864 bytes
 src/main.c        |  64 +++++++++++++++++++++++++++++++++++++++++++++-
 tests/db.db       | Bin 2048 -> 2048 bytes
 3 files changed, 63 insertions(+), 1 deletion(-)

diff --git a/.anjuta_sym_db.db b/.anjuta_sym_db.db
index 4966033fcbef8e4b68722743916d1060c36bc1dd..a563dbd9affdb16c7eb542b859f2d79ab90710d2 100644
GIT binary patch
delta 1300
zcmZuwZA@EL7=F+Dw9q>WrLY!S+woCI%Qoi*3rypWF%nG{m&J^PA0(@#Ezm(*1V%s|
zQU@bbC^kpK{wx8F(U_4?>b5K{&L3kDjdALXnZ}uDVm9YuvKXCl2G4DSfrNW=pL_3n
z-jDM<=Y7ZKcx;Yee?&~DTrFZc{oGpx<<q2LlyD!v;3lr)3@+d*-o|J;5rQ1GSXzjv
zKt1}U8Brz%g7Lnv#cG0A`2B;?K7W5W8XpRWO3it2i-D1-zb6t48Moxaq5pNnd+RdS
zEj!G{hWaP!8<t$6yotXgJ9mKJ<U7d6Ely(=d+;vy<3k+bKlwDj!$0s4jwz>md<CO$
zz`>uV6K2+Un4F{%I8x2FmrIQvjYWSr5b_TOI(owcG~p~!Hj%S+M#8<JfrH)xqfKKi
z8i>T`n%P*UmY>pBd>-b1^fe)3foQm@w$SKM-=PkFFcx%{T8&lNM4kSe#ZiK<$(&O{
zX`<rx<pRCFT+&v33!ds?V}*+A9`xtRSG%psz#<rr_67PQu`W7SBY$l4X7)E--MKX%
zbA-R}6TZSH_y~)b!)qC<VF=Z>wMzfLi;6&=EZJOUx!BcOl#hAB6|5kQ2bj+kcc0iS
z)B?|XNs2P*o+IYHcA6D5ON;a^7I+>F;ybkQA&l{Hu?u%Z88?cf{Jj{*3SS0`_w_rK
z@XOiZdZxeSXT!S;;xM^W%?@cFd9vO@;$PaG+iq>1M{{qe*?Bw`9E`+c>j-$|_{d9J
z9$zE4JC)d3X3w)}j<W25M8naJaDP{@JJ9dT9D3orvGF0<F$G-2l4{ZSuz<@-yZg9@
z+xQu`R0E%ZL=tDQj2rkAAL9#5;%qw60{P;}!e<|nkpKfsVyh0NI+W;OQ$`XV9cp#(
z=}@hM8!&0QON|cYIyiOk>fn$!PwptUi)A7H!0-GF4saOlJj#!<i@%Z1aaTGqE#&e<
zttgOpCn~MnLe@35*|&6^@>N|VjW5tPDmN&_HkB!Ss+DP5s@Z8RHYjn{3nRs(b7}Ge
z7S}T8PakGi0j-p9Az$LVv?4Bv6!&6A+!l5GG#!(bQwI&=Rr042?G;Cz#iV&yYqtrL
zTOS$IhB=bIC7WICUfoA%Z5w^E?I(XtI`?E-zH)nZ`09q@kx<bl`(ItfUIM>C`9w09
ztdlF#kI9~yTDd*h<WpvkPgSuAjYyDUrwNljj^5REG!3h=Wk#LKKB`S6s^o*|dO4Lm
y;J_>D%x?e-1SMx15jx3-3_YJp_(V-AQR$A?sN5B-op39b`dpgU&7nLu)A}Dprb|r#

delta 1132
zcmY*YYiL_l96$f_%k6U4lr~w@JiH-G(%9_bT-VKx;fJ*WKNQB46$C|M9=Ba>l9see
z>mxR<>*h#e!}*YYsm%F791fbs)z?rztYW9rVh2)%2@a$(hA@OpQ1sk}y7pe~@1EcJ
zKhFPkCeHJT^L+Xta+kC)xhv0KsCUjV6<LP6_zkOAMga@Big%H%<Ps3s#>TL!z(FJN
zp<&&^7^|0`@mS4hqex^lH5|$4siBwjM3bcs9vT@>MFt1b31#~>xC|B>N(QUTje9Ig
zd;5|0L-QIrJF&v-Jj?kxbij|Bu%XQF@iN}SQGA9I{C%E99bVwy;tu~5S^f)O<=6T3
zO3uPx=VQ!W3qhhJ4G#zyb8RrJNVXBIJkKVXVpqAEiVmdNS&QOOiJlnHlZjBks`w=7
zGe{&IP3djkCdDgvPL4*_H%I)Qno36R(;|sjB%Y4DY&InzbuxN15gCoflKM!GTev#g
zju^)f8Gd}h2E`@UH4FC+tknF*hf>4Q%s{$7-CB#I*RT)xt4BMp?zPonj^Q4D#Si!z
zpJNUet5#DP2r(w+`g^6k!te!_P{Dnf<t^Nj@|kscwK90Za?sAo#L8@r{fJBa9dyu7
z>@Pgck70tpNc-?RIrz^si6wpooG#YhQZ6FOV+S}L7vGHS^JsNG)#cb!l9Zl`>6!lc
z$!NwaTE-uzL!~a4iT+{EQdhH>9DkLbEaif<yOevldhF%P%474)jy!M)7i3p&;3Hg-
zIo-t_tjUOP%2AtvKoPU}9@nslFQv{bW-GZc#4D#7p1Q^q2AE)`W&?H@U^BpO0wb>h
zeko?;!QWEVSOo#IYN)gt;5NWzfYT5L#OkR%Ep}RD^e6s6H`np3oWMtTJ=cUbsc~qP
zT!F;m=^%y0?bAE0O(t1@Eop00A>RV?Z%o+wpD!@$mJOj#_0s-QmxI<TLucIcXFlX~
zwtD%^<6PTLQ#QVv?(;nVj+W?co<JDW7^E0=h@JVK()5gzo?&~pxRiv>vEfoK*^Ps;
zDu-F~|8n|@Ju1mAZxd5}q)JUD!&b?>X`27tl!ZxrT-Yx@DIO3F#ZHdHV!E(P+%9%+
zd(JIA1V}9BTc}5@<-1z&hV0S}*+M37l5v&L$3jdbiy^UA2x{q8Y2YRGH4m9R#%(b_
L7;EvtTfP4Qgh&u_

diff --git a/src/main.c b/src/main.c
index 88f149c..1bad39b 100644
--- a/src/main.c
+++ b/src/main.c
@@ -36,7 +36,7 @@ typedef struct
 
 typedef struct
 {
-	gchar *field_name;
+	gchar *name;
 } Field;
 
 static GOptionEntry entries[] =
@@ -70,6 +70,65 @@ update_metastore ()
 		}
 }
 
+static void
+read_fields (GdaConnection *gdacon, Table *table)
+{
+	GError *error;
+
+	GdaMetaContext mcontext = {"_columns", 1, NULL, NULL};
+
+	GValue *gval;
+
+	GdaDataModel *dm_fields;
+
+	guint rows;
+	guint row;
+
+	Field *field;
+
+	error = NULL;
+
+	mcontext.column_names = g_new (gchar *, 1);
+	mcontext.column_names[0] = "table_name";
+	mcontext.column_values = g_new (GValue *, 1);
+	mcontext.column_values[0] = gda_value_new (G_TYPE_STRING);
+
+	g_value_take_string (mcontext.column_values[0],
+	                     gda_sql_identifier_quote (table->name, gdacon, NULL, FALSE, FALSE));
+
+	if (!gda_connection_update_meta_store (gdacon, &mcontext, &error))
+		{
+			g_warning ("Unable to update database metastore: %s",
+			           (error != NULL && error->message != NULL ? error->message : "no details."));
+			return;
+		}
+
+	error = NULL;
+	gval = gda_value_new (G_TYPE_STRING);
+	g_value_take_string (gval, table->name);
+	dm_fields = gda_connection_get_meta_store_data (gdacon,
+	                                                GDA_CONNECTION_META_FIELDS,
+	                                                &error,
+	                                                1,
+	                                                "name", gval);
+	if (dm_fields != NULL && error == NULL)
+		{
+			rows = gda_data_model_get_n_rows (dm_fields);
+			for (row = 0; row < rows; row++)
+				{
+					field = g_new0 (Field, 1);
+					field->name = gda_value_stringify (gda_data_model_get_value_at (dm_fields, 0, row, NULL));
+					g_message ("\t\tField: %s", field->name);
+
+					g_hash_table_insert (table->ht_fields, field->name, field);
+				}
+		}
+	if (dm_fields != NULL)
+		{
+			g_object_unref (dm_fields);
+		}
+}
+
 static void
 read_tables (GdaConnection *gdacon, GHashTable *ht)
 {
@@ -93,11 +152,14 @@ read_tables (GdaConnection *gdacon, GHashTable *ht)
 			for (row = 0; row < rows; row++)
 				{
 					table = g_new0 (Table, 1);
+					table->ht_fields = g_hash_table_new (g_str_hash, g_str_equal);
 
 					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);
+
+					read_fields (gdacon, table);
 				}
 		}
 	if (dm_tables != NULL)
diff --git a/tests/db.db b/tests/db.db
index 9831ee9ed9ac7c1e57b3a448a1750eb81d7c9e3d..2cb8c26c7f360cf3cf22a212e991a2b5ed61715e 100644
GIT binary patch
delta 83
zcmZn=Xb_knEy&Ekz`z8=Fu*)f$C#g)LHCg=FHne)Ihlbud9xtPGbYLPFeMPWQHqgW
TTw0p3iF<N1v-jp5%pNQNxTXu?

delta 67
zcmZn=Xb_knEy&2gz`z8=Fu*ub$C#gyLHCg=FHne)Igo)laAV<PCay*uMs{&&X~rh~
O$+^tlo0l<1u>b%&a|@UN

-- 
2.49.0