-- PostgreSQL database dump
--
--- Started on 2010-08-25 10:29:20
-
-SET statement_timeout = 0;
-SET client_encoding = 'UTF8';
-SET standard_conforming_strings = off;
-SET check_function_bodies = false;
-SET client_min_messages = warning;
-SET escape_string_warning = off;
-
---
--- TOC entry 1827 (class 1262 OID 59420)
--- Name: territorio; Type: DATABASE; Schema: -; Owner: -
---
-
-CREATE DATABASE territorio WITH TEMPLATE = template0 ENCODING = 'UTF8' LC_COLLATE = 'Italian, Italy' LC_CTYPE = 'Italian, Italy';
-
-
-\connect territorio
+-- Dumped from database version 8.4.4
+-- Dumped by pg_dump version 9.0.1
+-- Started on 2010-11-04 08:19:54
SET statement_timeout = 0;
SET client_encoding = 'UTF8';
-- Name: plpgsql; Type: PROCEDURAL LANGUAGE; Schema: -; Owner: -
--
-CREATE PROCEDURAL LANGUAGE plpgsql;
+CREATE OR REPLACE PROCEDURAL LANGUAGE plpgsql;
SET search_path = public, pg_catalog;
-SET default_tablespace = '';
-
SET default_with_oids = false;
--
--- TOC entry 1508 (class 1259 OID 59503)
--- Dependencies: 1802 1803 3
--- Name: aggregazioni_territoriali; Type: TABLE; Schema: public; Owner: -; Tablespace:
+-- TOC entry 1507 (class 1259 OID 59503)
+-- Dependencies: 1798 1799 3
+-- Name: aggregazioni_territoriali; Type: TABLE; Schema: public; Owner: -
--
CREATE TABLE aggregazioni_territoriali (
--
--- TOC entry 1506 (class 1259 OID 59481)
--- Dependencies: 1796 1797 1798 1799 3
--- Name: comuni; Type: TABLE; Schema: public; Owner: -; Tablespace:
+-- TOC entry 1510 (class 1259 OID 61495)
+-- Dependencies: 1807 1808 1809 1810 1811 3
+-- Name: comuni; Type: TABLE; Schema: public; Owner: -
--
CREATE TABLE comuni (
nome character varying(255) DEFAULT ''::character varying,
cod_istat character varying(5) DEFAULT ''::character varying,
cap character varying(5) DEFAULT ''::character varying,
- status character varying(1) DEFAULT ''::character varying,
- id_province integer
+ id_province integer,
+ capoluogo boolean DEFAULT false,
+ status character varying(1) DEFAULT ''::character varying
);
--
--- TOC entry 1510 (class 1259 OID 59532)
--- Dependencies: 1807 1808 1809 1810 3
--- Name: province; Type: TABLE; Schema: public; Owner: -; Tablespace:
+-- TOC entry 1509 (class 1259 OID 59532)
+-- Dependencies: 1803 1804 1805 1806 3
+-- Name: province; Type: TABLE; Schema: public; Owner: -
--
CREATE TABLE province (
--
-- TOC entry 1505 (class 1259 OID 59459)
-- Dependencies: 1793 1794 1795 3
--- Name: regioni; Type: TABLE; Schema: public; Owner: -; Tablespace:
+-- Name: regioni; Type: TABLE; Schema: public; Owner: -
--
CREATE TABLE regioni (
--
-- TOC entry 1504 (class 1259 OID 59446)
-- Dependencies: 1788 1789 1790 1791 1792 3
--- Name: stati; Type: TABLE; Schema: public; Owner: -; Tablespace:
+-- Name: stati; Type: TABLE; Schema: public; Owner: -
--
CREATE TABLE stati (
--
--- TOC entry 1507 (class 1259 OID 59496)
--- Dependencies: 1800 1801 3
--- Name: tipi_aggregazione_territoriale; Type: TABLE; Schema: public; Owner: -; Tablespace:
+-- TOC entry 1506 (class 1259 OID 59496)
+-- Dependencies: 1796 1797 3
+-- Name: tipi_aggregazione_territoriale; Type: TABLE; Schema: public; Owner: -
--
CREATE TABLE tipi_aggregazione_territoriale (
--
--- TOC entry 1509 (class 1259 OID 59524)
--- Dependencies: 1804 1805 1806 3
--- Name: vie; Type: TABLE; Schema: public; Owner: -; Tablespace:
+-- TOC entry 1508 (class 1259 OID 59524)
+-- Dependencies: 1800 1801 1802 3
+-- Name: vie; Type: TABLE; Schema: public; Owner: -
--
CREATE TABLE vie (
--
--- TOC entry 1820 (class 2606 OID 59509)
--- Dependencies: 1508 1508
--- Name: aggregazioni_territoriali_pkey; Type: CONSTRAINT; Schema: public; Owner: -; Tablespace:
+-- TOC entry 1819 (class 2606 OID 59509)
+-- Dependencies: 1507 1507
+-- Name: aggregazioni_territoriali_pkey; Type: CONSTRAINT; Schema: public; Owner: -
--
ALTER TABLE ONLY aggregazioni_territoriali
--
--- TOC entry 1816 (class 2606 OID 59489)
--- Dependencies: 1506 1506
--- Name: comuni_pkey; Type: CONSTRAINT; Schema: public; Owner: -; Tablespace:
+-- TOC entry 1825 (class 2606 OID 61504)
+-- Dependencies: 1510 1510
+-- Name: comuni_pkey; Type: CONSTRAINT; Schema: public; Owner: -
--
ALTER TABLE ONLY comuni
--
--- TOC entry 1824 (class 2606 OID 59540)
--- Dependencies: 1510 1510
--- Name: province_pkey; Type: CONSTRAINT; Schema: public; Owner: -; Tablespace:
+-- TOC entry 1823 (class 2606 OID 59540)
+-- Dependencies: 1509 1509
+-- Name: province_pkey; Type: CONSTRAINT; Schema: public; Owner: -
--
ALTER TABLE ONLY province
--
--- TOC entry 1814 (class 2606 OID 59466)
+-- TOC entry 1815 (class 2606 OID 59466)
-- Dependencies: 1505 1505
--- Name: regioni_pkey; Type: CONSTRAINT; Schema: public; Owner: -; Tablespace:
+-- Name: regioni_pkey; Type: CONSTRAINT; Schema: public; Owner: -
--
ALTER TABLE ONLY regioni
--
--- TOC entry 1812 (class 2606 OID 59458)
+-- TOC entry 1813 (class 2606 OID 59458)
-- Dependencies: 1504 1504
--- Name: stati_pkey; Type: CONSTRAINT; Schema: public; Owner: -; Tablespace:
+-- Name: stati_pkey; Type: CONSTRAINT; Schema: public; Owner: -
--
ALTER TABLE ONLY stati
--
--- TOC entry 1818 (class 2606 OID 59502)
--- Dependencies: 1507 1507
--- Name: tipi_aggregazioni_territoriali_pkey; Type: CONSTRAINT; Schema: public; Owner: -; Tablespace:
+-- TOC entry 1817 (class 2606 OID 59502)
+-- Dependencies: 1506 1506
+-- Name: tipi_aggregazioni_territoriali_pkey; Type: CONSTRAINT; Schema: public; Owner: -
--
ALTER TABLE ONLY tipi_aggregazione_territoriale
--
--- TOC entry 1822 (class 2606 OID 59531)
--- Dependencies: 1509 1509
--- Name: vie_pkey; Type: CONSTRAINT; Schema: public; Owner: -; Tablespace:
+-- TOC entry 1821 (class 2606 OID 59531)
+-- Dependencies: 1508 1508
+-- Name: vie_pkey; Type: CONSTRAINT; Schema: public; Owner: -
--
ALTER TABLE ONLY vie
ADD CONSTRAINT vie_pkey PRIMARY KEY (id);
---
--- TOC entry 1829 (class 0 OID 0)
--- Dependencies: 3
--- Name: public; Type: ACL; Schema: -; Owner: -
---
-
-REVOKE ALL ON SCHEMA public FROM PUBLIC;
-REVOKE ALL ON SCHEMA public FROM postgres;
-GRANT ALL ON SCHEMA public TO postgres;
-GRANT ALL ON SCHEMA public TO PUBLIC;
-
-
--- Completed on 2010-08-25 10:29:20
+-- Completed on 2010-11-04 08:19:54
--
-- PostgreSQL database dump complete
--- /dev/null
+/*
+ * Copyright (C) 2010 Andrea Zagli <azagli@libero.it>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library 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
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
+ *
+ */
+
+#include "importacomuniistat.h"
+
+static void territorio_importa_comuniistat_class_init (TerritorioImportaComuniIstatClass *klass);
+static void territorio_importa_comuniistat_init (TerritorioImportaComuniIstat *territorio_importa_comuniistat);
+
+static void territorio_importa_comuniistat_set_property (GObject *object,
+ guint property_id,
+ const GValue *value,
+ GParamSpec *pspec);
+static void territorio_importa_comuniistat_get_property (GObject *object,
+ guint property_id,
+ GValue *value,
+ GParamSpec *pspec);
+
+#define TERRITORIO_IMPORTA_COMUNIISTAT_GET_PRIVATE(obj) (G_TYPE_INSTANCE_GET_PRIVATE ((obj), TYPE_TERRITORIO_IMPORTA_COMUNIISTAT, TerritorioImportaComuniIstatPrivate))
+
+typedef struct _TerritorioImportaComuniIstatPrivate TerritorioImportaComuniIstatPrivate;
+struct _TerritorioImportaComuniIstatPrivate
+ {
+ TerritorioCommons *commons;
+ };
+
+G_DEFINE_TYPE (TerritorioImportaComuniIstat, territorio_importa_comuniistat, G_TYPE_OBJECT)
+
+static void
+territorio_importa_comuniistat_class_init (TerritorioImportaComuniIstatClass *klass)
+{
+ GObjectClass *object_class = G_OBJECT_CLASS (klass);
+
+ g_type_class_add_private (object_class, sizeof (TerritorioImportaComuniIstatPrivate));
+
+ object_class->set_property = territorio_importa_comuniistat_set_property;
+ object_class->get_property = territorio_importa_comuniistat_get_property;
+}
+
+static void
+territorio_importa_comuniistat_init (TerritorioImportaComuniIstat *territorio_importa_comuniistat)
+{
+ TerritorioImportaComuniIstatPrivate *priv = TERRITORIO_IMPORTA_COMUNIISTAT_GET_PRIVATE (territorio_importa_comuniistat);
+}
+
+/**
+ * territorio_importa_comuniistat_new:
+ * @commons:
+ *
+ * Returns: the newly created #TerritorioImportaComuniIstat object.
+ */
+TerritorioImportaComuniIstat
+*territorio_importa_comuniistat_new (TerritorioCommons *commons)
+{
+ GtkWidget *fchooser;
+
+ TerritorioImportaComuniIstat *a = TERRITORIO_IMPORTA_COMUNIISTAT (g_object_new (territorio_importa_comuniistat_get_type (), NULL));
+
+ TerritorioImportaComuniIstatPrivate *priv = TERRITORIO_IMPORTA_COMUNIISTAT_GET_PRIVATE (a);
+
+ priv->commons = commons;
+
+ GtkWindow *w_main = GTK_WINDOW (gtk_builder_get_object (priv->commons->gtkbuilder, "w_main"));
+
+ fchooser = gtk_file_chooser_dialog_new ("Scegli il file istat con i comuni",
+ w_main,
+ GTK_FILE_CHOOSER_ACTION_OPEN,
+ GTK_STOCK_CANCEL, GTK_RESPONSE_CANCEL,
+ GTK_STOCK_OPEN, GTK_RESPONSE_ACCEPT,
+ NULL);
+ if (gtk_dialog_run (GTK_DIALOG (fchooser)) == GTK_RESPONSE_ACCEPT)
+ {
+ char *filename;
+ GdaDataModel *dm;
+ GError *error;
+ GSList *errors;
+
+ GtkWidget *dialog;
+
+ gint row;
+ gint rows;
+
+ gchar *sql;
+
+ GdaDataModel *dm_province;
+ guint id_province;
+
+ GdaDataModel *dm_comuni;
+ guint id_comuni;
+
+ filename = gtk_file_chooser_get_filename (GTK_FILE_CHOOSER (fchooser));
+ gtk_widget_destroy (fchooser);
+ g_message (filename);
+
+ GdaSet *plist = gda_set_new_inline (23,
+ "SEPARATOR", G_TYPE_STRING, ";",
+ "ESCAPE_CHAR", G_TYPE_STRING, "",
+ "G_TYPE_0", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_1", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_2", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_3", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_4", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_5", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_6", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_7", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_8", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_9", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_10", G_TYPE_GTYPE, G_TYPE_INT,
+ "G_TYPE_11", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_12", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_13", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_14", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_15", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_16", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_17", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_18", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_19", G_TYPE_GTYPE, G_TYPE_STRING,
+ "G_TYPE_20", G_TYPE_GTYPE, G_TYPE_STRING);
+ dm = gda_data_model_import_new_file (filename, TRUE, plist);
+ if (dm == NULL)
+ {
+ dialog = gtk_message_dialog_new (w_main,
+ GTK_DIALOG_DESTROY_WITH_PARENT,
+ GTK_MESSAGE_WARNING,
+ GTK_BUTTONS_OK,
+ "Errore durante l'importazione del file: %s.", filename);
+ gtk_dialog_run (GTK_DIALOG (dialog));
+ gtk_widget_destroy (dialog);
+ return NULL;
+ }
+
+ errors = gda_data_model_import_get_errors (GDA_DATA_MODEL_IMPORT (dm));
+ if (errors != NULL)
+ {
+ while (errors != NULL)
+ {
+ error = (GError *)errors->data;
+ g_warning (error->message != NULL ? error->message : "");
+ errors = g_slist_next (errors);
+ }
+
+ dialog = gtk_message_dialog_new (w_main,
+ GTK_DIALOG_DESTROY_WITH_PARENT,
+ GTK_MESSAGE_WARNING,
+ GTK_BUTTONS_OK,
+ "Errore durante l'importazione del file.");
+ gtk_dialog_run (GTK_DIALOG (dialog));
+ gtk_widget_destroy (dialog);
+ return NULL;
+ }
+
+ rows = gda_data_model_get_n_rows (dm);
+ g_message ("Numero di record: %d.", rows);
+ if (rows < 1)
+ {
+ dialog = gtk_message_dialog_new (w_main,
+ GTK_DIALOG_DESTROY_WITH_PARENT,
+ GTK_MESSAGE_WARNING,
+ GTK_BUTTONS_OK,
+ "Nessuna informazione da importare nel file: %s.", filename);
+ gtk_dialog_run (GTK_DIALOG (dialog));
+ gtk_widget_destroy (dialog);
+ return NULL;
+ }
+
+ /* TODO
+ * segnarsi i record aggiornati, perché alla fine del ciclo quelli
+ * non aggiornati vanni segnati eliminati
+ */
+
+ for (row = 0; row < rows; row++)
+ {
+ sql = g_strdup_printf ("SELECT p.id"
+ " FROM province AS p INNER JOIN regioni AS r ON p.id_regioni = r.id"
+ " WHERE r.cod_istat = '%s' AND p.cod_istat = '%s'",
+ gdaex_data_model_get_value_stringify_at (dm, row, 0),
+ gdaex_data_model_get_value_stringify_at (dm, row, 1));
+ dm_province = gdaex_query (priv->commons->gdaex, sql);
+ if (dm_province != NULL && gda_data_model_get_n_rows (dm_province) > 0)
+ {
+ id_province = gdaex_data_model_get_value_integer_at (dm_province, 0, 0);
+ g_object_unref (dm_province);
+ }
+ else
+ {
+ g_object_unref (dm_province);
+ g_warning ("Provincia (%s - %s) non trovata.",
+ gdaex_data_model_get_value_stringify_at (dm, row, 0),
+ gdaex_data_model_get_value_stringify_at (dm, row, 1));
+ continue;
+ }
+
+ sql = g_strdup_printf ("SELECT id FROM comuni WHERE id_province = %d AND cod_istat = '%s'",
+ id_province,
+ g_strstrip (gdaex_data_model_get_value_stringify_at (dm, row, 2)));
+ dm_comuni = gdaex_query (priv->commons->gdaex, sql);
+ if (dm_comuni == NULL || gda_data_model_get_n_rows (dm_comuni) == 0)
+ {
+ id_comuni = 0;
+ sql = g_strdup_printf ("SELECT COALESCE (MAX (id), 0) FROM comuni");
+ dm_comuni = gdaex_query (priv->commons->gdaex, sql);
+ if (dm_comuni != NULL && gda_data_model_get_n_rows (dm_comuni) == 1)
+ {
+ id_comuni = gdaex_data_model_get_value_integer_at (dm_comuni, 0, 0);
+ }
+ id_comuni++;
+
+ sql = g_strdup_printf ("INSERT INTO comuni (id, nome, cod_istat, cap, id_province, capoluogo)"
+ " VALUES (%d, '%s', '%s', '%s', %d, '%d')",
+ id_comuni,
+ gdaex_strescape (gdaex_data_model_get_value_stringify_at (dm, row, 8), NULL),
+ gdaex_data_model_get_value_stringify_at (dm, row, 2),
+ "",
+ id_province,
+ gdaex_data_model_get_value_integer_at (dm, 0, 10));
+ }
+ else
+ {
+ id_comuni = gdaex_data_model_get_value_integer_at (dm_comuni, 0, 0);
+ sql = g_strdup_printf ("UPDATE comuni SET nome = '%s',"
+ " capoluogo = '%d'"
+ " WHERE id = %d",
+ gdaex_strescape (gdaex_data_model_get_value_stringify_at (dm, row, 8), NULL),
+ gdaex_data_model_get_value_integer_at (dm, row, 10),
+ id_comuni);
+ }
+ if (gdaex_execute (priv->commons->gdaex, sql) < 1)
+ {
+ g_warning ("Si è verificato un errore nell'importazione del comune: %s",
+ gdaex_data_model_get_value_stringify_at (dm, row, 8));
+ return NULL;
+ }
+ }
+
+ g_object_unref (dm);
+ g_free (filename);
+ }
+ else
+ {
+ gtk_widget_destroy (fchooser);
+ }
+ g_message ("Fine import.");
+
+ return a;
+}
+
+/* PRIVATE */
+static void
+territorio_importa_comuniistat_set_property (GObject *object, guint property_id, const GValue *value, GParamSpec *pspec)
+{
+ TerritorioImportaComuniIstat *territorio_importa_comuniistat = TERRITORIO_IMPORTA_COMUNIISTAT (object);
+
+ TerritorioImportaComuniIstatPrivate *priv = TERRITORIO_IMPORTA_COMUNIISTAT_GET_PRIVATE (territorio_importa_comuniistat);
+
+ switch (property_id)
+ {
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
+ break;
+ }
+}
+
+static void
+territorio_importa_comuniistat_get_property (GObject *object, guint property_id, GValue *value, GParamSpec *pspec)
+{
+ TerritorioImportaComuniIstat *territorio_importa_comuniistat = TERRITORIO_IMPORTA_COMUNIISTAT (object);
+
+ TerritorioImportaComuniIstatPrivate *priv = TERRITORIO_IMPORTA_COMUNIISTAT_GET_PRIVATE (territorio_importa_comuniistat);
+
+ switch (property_id)
+ {
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
+ break;
+ }
+}
+
+/* CALLBACK */
projects / solipa / territorio / commitdiff