From ed09215fd899f69aa64d56d3c676200c209da481 Mon Sep 17 00:00:00 2001 From: Andrea Zagli Date: Wed, 21 Nov 2012 21:12:52 +0100 Subject: [PATCH] Initial import. --- .gitignore | 26 +++++ AUTHORS | 1 + Makefile.am | 22 +++++ NEWS | 0 README | 0 autogen.sh | 23 +++++ configure.ac | 67 +++++++++++++ src/Makefile.am | 9 ++ src/main.c | 240 ++++++++++++++++++++++++++++++++++++++++++++++ tests/Makefile.am | 2 + tests/db.db | Bin 0 -> 2048 bytes tests/refdb.db | Bin 0 -> 3072 bytes 12 files changed, 390 insertions(+) create mode 100644 .gitignore create mode 100644 AUTHORS create mode 100644 Makefile.am create mode 100644 NEWS create mode 100644 README create mode 100755 autogen.sh create mode 100644 configure.ac create mode 100644 src/Makefile.am create mode 100644 src/main.c create mode 100644 tests/Makefile.am create mode 100644 tests/db.db create mode 100644 tests/refdb.db diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..89abdab --- /dev/null +++ b/.gitignore @@ -0,0 +1,26 @@ +*.o +*~ +*.in +src/gdadbcopy +COPYING +INSTALL +Makefile +Makefile.in +aclocal.m4 +autom4te.cache/ +config.guess +config.h +config.log +config.status +config.sub +configure +depcomp +install-sh +missing +src/.deps/ +stamp-h1 +*exe +src/share +*.csv +*.rc +mkinstalldirs diff --git a/AUTHORS b/AUTHORS new file mode 100644 index 0000000..ad1de0f --- /dev/null +++ b/AUTHORS @@ -0,0 +1 @@ +Andrea Zagli diff --git a/Makefile.am b/Makefile.am new file mode 100644 index 0000000..45bd618 --- /dev/null +++ b/Makefile.am @@ -0,0 +1,22 @@ +SUBDIRS = src tests + +distclean-local: + if test "$(srcdir)" = "."; then :; else \ + rm -f ChangeLog; \ + fi + +ChangeLog: + @echo Creating $@ + @if test -d "$(srcdir)/.git"; then \ + (GIT_DIR=$(top_srcdir)/.git ./missing --run git log --stat -M -C --name-status --date=short --no-color) | fmt --split-only > $@.tmp \ + && mv -f $@.tmp $@ \ + || ($(RM) $@.tmp; \ + echo Failed to generate ChangeLog, your ChangeLog may be outdated >&2; \ + (test -f $@ || echo git-log is required to generate this file >> $@)); \ + else \ + test -f $@ || \ + (echo A git checkout and git-log is required to generate ChangeLog >&2 && \ + echo A git checkout and git-log is required to generate this file >> $@); \ + fi + +.PHONY: ChangeLog diff --git a/NEWS b/NEWS new file mode 100644 index 0000000..e69de29 diff --git a/README b/README new file mode 100644 index 0000000..e69de29 diff --git a/autogen.sh b/autogen.sh new file mode 100755 index 0000000..c72e23a --- /dev/null +++ b/autogen.sh @@ -0,0 +1,23 @@ +#!/bin/bash +# Run this to generate all the initial makefiles, etc. + +srcdir=`dirname $0` +test -z "$srcdir" && srcdir=. + +PKG_NAME="gdadbcopy" + +(test -f $srcdir/configure.ac \ + && test -d $srcdir/src \ + && test -f $srcdir/src/main.c) || { + echo -n "**Error**: Directory "\`$srcdir\'" does not look like the" + echo " top-level "\`$PKG_NAME\'" directory" + exit 1 +} + +which gnome-autogen.sh || { + echo "You need to install gnome-common from GNOME and make" + echo "sure the gnome-autogen.sh script is in your \$PATH." + exit 1 +} + +USE_GNOME2_MACROS=1 . gnome-autogen.sh diff --git a/configure.ac b/configure.ac new file mode 100644 index 0000000..6202ecf --- /dev/null +++ b/configure.ac @@ -0,0 +1,67 @@ +# -*- Autoconf -*- +# Process this file with autoconf to produce a configure script. + +AC_PREREQ([2.65]) +AC_INIT([gdadbcopy], [0.0.1], [azagli@libero.it]) +AC_CONFIG_SRCDIR([src/main.c]) +AC_CONFIG_HEADER([config.h]) + +AM_INIT_AUTOMAKE(-Wall) + +m4_ifdef([AM_SILENT_RULES],[AM_SILENT_RULES([yes])]) + +AM_MAINTAINER_MODE + +AC_CANONICAL_SYSTEM + +# Checks for programs. +AC_PROG_CC +AC_PROG_INSTALL +AC_PROG_MAKE_SET + +dnl ****************************** +dnl Translations +dnl ****************************** +GETTEXT_PACKAGE=gdadbcopy +AC_SUBST(GETTEXT_PACKAGE) +AC_DEFINE_UNQUOTED(GETTEXT_PACKAGE, "$GETTEXT_PACKAGE", + [The prefix for our gettext translation domains.]) +AM_GLIB_GNU_GETTEXT + +# Checks for libraries. +PKG_CHECK_MODULES(GDADBCOPY, [libgda-4.0 >= 4.0.0]) + +AC_SUBST(GDADBCOPY_CFLAGS) +AC_SUBST(GDADBCOPY_LIBS) + +# Checks for header files. +AC_CHECK_HEADERS([locale.h]) + +# Checks for typedefs, structures, and compiler characteristics. + +# Checks for library functions. +AC_FUNC_MKTIME +AC_CHECK_FUNCS([setlocale]) + +dnl ****************************** +dnl Check for Operating System +dnl ****************************** + +platform_win32=no + +case "$host" in +*-mingw*) + platform_win32=yes + AC_CHECK_TOOL(WINDRES, windres, windres) + AC_SUBST(WINDRES) + ;; +esac + +AM_CONDITIONAL(PLATFORM_WIN32, [test $platform_win32 = yes]) + +AC_CONFIG_FILES([ + Makefile + src/Makefile + tests/Makefile +]) +AC_OUTPUT diff --git a/src/Makefile.am b/src/Makefile.am new file mode 100644 index 0000000..b5bdde1 --- /dev/null +++ b/src/Makefile.am @@ -0,0 +1,9 @@ +AM_CPPFLAGS = $(GDADBCOPY_CFLAGS) + +LIBS = $(GDADBCOPY_LIBS) \ + -export-dynamic + +bin_PROGRAMS = gdadbcopy + +gdadbcopy_SOURCES = \ + main.c diff --git a/src/main.c b/src/main.c new file mode 100644 index 0000000..5faac4e --- /dev/null +++ b/src/main.c @@ -0,0 +1,240 @@ +/* + * Copyright (C) 2012 Andrea Zagli + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. + */ + +#ifdef HAVE_CONFIG_H + #include +#endif + +#include + +static gchar *ref_db_cnc = NULL; +static gchar *db_cnc = NULL; + +static GdaConnection *gda_conn_ref_db; +static GdaConnection *gda_conn_db; + +typedef struct +{ + gchar *name; + GHashTable *ht_fields; +} Table; + +typedef struct +{ + gchar *name; +} Field; + +static GOptionEntry entries[] = +{ + { "ref-db-cnc", 0, 0, G_OPTION_ARG_STRING, &ref_db_cnc, "Reference database connection string", "CNC_STRING" }, + { "db-cnc", 0, 0, G_OPTION_ARG_STRING, &db_cnc, "Database connection string", "CNC_STRING" }, + { NULL } +}; + +static void +update_metastore () +{ + GError *error; + + GdaMetaContext mcontext = {"_tables", 0, NULL, NULL}; + + g_message ("Updating metastores."); + + error = NULL; + if (!gda_connection_update_meta_store (gda_conn_ref_db, &mcontext, &error)) + { + g_warning ("Unable to update reference database metastore: %s", + (error != NULL && error->message != NULL ? error->message : "no details.")); + } + + error = NULL; + if (!gda_connection_update_meta_store (gda_conn_db, &mcontext, &error)) + { + g_warning ("Unable to update database metastore: %s", + (error != NULL && error->message != NULL ? error->message : "no details.")); + } +} + +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) +{ + GError *error; + + GdaDataModel *dm_tables; + + guint rows; + guint row; + + Table *table; + + error = NULL; + dm_tables = gda_connection_get_meta_store_data (gdacon, + GDA_CONNECTION_META_TABLES, + &error, + 0); + if (dm_tables != NULL && error == NULL) + { + rows = gda_data_model_get_n_rows (dm_tables); + 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) + { + g_object_unref (dm_tables); + } +} + +int +main (int argc, char *argv[]) +{ + GError *error; + GOptionContext *context; + + GHashTable *ht_ref_db_tables; + GHashTable *ht_db_tables; + + g_type_init (); + + error = NULL; + context = g_option_context_new ("- copy from a database to another one"); + g_option_context_add_main_entries (context, entries, GETTEXT_PACKAGE); + if (!g_option_context_parse (context, &argc, &argv, &error)) + { + g_error ("Option parsing failed: %s.", error->message); + return 1; + } + + if (ref_db_cnc == NULL) + { + g_error ("You must enter on command line the reference database connection string."); + return 1; + } + if (db_cnc == NULL) + { + g_error ("You must enter on command line the database connection string."); + return 1; + } + + g_message ("Connecting to databases."); + + error = NULL; + gda_conn_ref_db = gda_connection_open_from_string (NULL, ref_db_cnc, NULL, + GDA_CONNECTION_OPTIONS_NONE, + &error); + if (gda_conn_ref_db == NULL || error != NULL) + { + g_warning ("Could not open connection to reference database: %s.\n", + error != NULL && error->message != NULL ? error->message : "no detail"); + return; + } + + error = NULL; + gda_conn_db = gda_connection_open_from_string (NULL, db_cnc, NULL, + GDA_CONNECTION_OPTIONS_NONE, + &error); + if (gda_conn_db == NULL || error != NULL) + { + g_warning ("Could not open connection to database: %s.\n", + error != NULL && error->message != NULL ? error->message : "no detail"); + return; + } + + update_metastore (); + + 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_object_unref (gda_conn_ref_db); + g_object_unref (gda_conn_db); + + return 0; +} diff --git a/tests/Makefile.am b/tests/Makefile.am new file mode 100644 index 0000000..d3e7a06 --- /dev/null +++ b/tests/Makefile.am @@ -0,0 +1,2 @@ +EXTRA_DIST = refdb.db \ + db.db diff --git a/tests/db.db b/tests/db.db new file mode 100644 index 0000000000000000000000000000000000000000..2cb8c26c7f360cf3cf22a212e991a2b5ed61715e GIT binary patch literal 2048 zcmWFz^vNtqRY=P(%1ta$FlJz3U}R))P*7lCU|;s5{u literal 0 HcmV?d00001 diff --git a/tests/refdb.db b/tests/refdb.db new file mode 100644 index 0000000000000000000000000000000000000000..81a6e21fec7986cb58e9e4f99691f8c2ac396241 GIT binary patch literal 3072 zcmWFz^vNtqRY=P(%1ta$FlJz3U}R))P*7lC05TaEn1L7uKztB}0Y(@D56!}$`$&}+ zsDO!S76Wr2kQfD{AwX0JG@3B6i_6P1Hkp?sCgr3imll`g=cX1F!x_xZL9UJ=t_mTJ zPCl**aA5_F%oGJrzYte<*B~8*;?knL#N1ScFvlQg562)4Qv*#M1x%5o%%YNvl*CE} z7odqiT_uSnrNszSoc;ZRLxLQErXuW#FUU@gknNdE$M)Uu0h{aJq KjD`StApig%0(U+D literal 0 HcmV?d00001 -- 2.49.0