--- /dev/null
+# -*- 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
--- /dev/null
+/*
+ * Copyright (C) 2012 Andrea Zagli <azagli@libero.it>
+ *
+ * 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 <config.h>
+#endif
+
+#include <libgda/libgda.h>
+
+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;
+}
projects / gdadbcopy / commitdiff