From: Andrea Zagli Date: Wed, 21 Nov 2012 20:12:52 +0000 (+0100) Subject: Initial import. X-Git-Tag: 0.0.1~19 X-Git-Url: https://saetta.ns0.it/gitweb?a=commitdiff_plain;h=ed09215fd899f69aa64d56d3c676200c209da481;p=gdadbcopy Initial import. --- ed09215fd899f69aa64d56d3c676200c209da481 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 0000000..2cb8c26 Binary files /dev/null and b/tests/db.db differ diff --git a/tests/refdb.db b/tests/refdb.db new file mode 100644 index 0000000..81a6e21 Binary files /dev/null and b/tests/refdb.db differ