validate_remote_loader_columns()

static int validate_remote_loader_columns ( SHPLOADERCONFIG *  config, PGresult *  result  )

static

Definition at line 1153 of file shp2pgsql-gui.c.

{
        ExecStatusType status;
        SHPLOADERSTATE *state;
        int ntuples;
        char *pg_fieldname, *pg_fieldtype;
        int ret, i, j, found, response = SHPLOADEROK;
 
        /* Check the status of the result set */
        status = PQresultStatus(result);
        if (status == PGRES_TUPLES_OK)
        {
                ntuples = PQntuples(result);
 
                switch (config->opt)
                {
                        case 'c':
                                /* If we have a row matching the table given in the config, then it already exists */
                                if (ntuples > 0)
                                {
                                        pgui_seterr(_("ERROR: Create mode selected for existing table: %s.%s"), config->schema, config->table);
                                        response = SHPLOADERERR;
                                }
                                break;
 
                        case 'p':
                                /* If we have a row matching the table given in the config, then it already exists */
                                if (ntuples > 0)
                                {
                                        pgui_seterr(_("ERROR: Prepare mode selected for existing table: %s.%s"), config->schema, config->table);
                                        response = SHPLOADERERR;
                                }
                                break;
 
                        case 'a':
                                /* If we are trying to append to a table but it doesn't exist, emit a warning */
                                if (ntuples == 0)
                                {
                                        pgui_seterr(_("ERROR: Destination table %s.%s could not be found for appending"), config->schema, config->table);
                                        response = SHPLOADERERR;
                                }
                                else
                                {
                                        /* If we have a row then lets do some simple column validation... */
                                        state = ShpLoaderCreate(config);
                                        ret = ShpLoaderOpenShape(state);
                                        if (ret != SHPLOADEROK)
                                        {
                                                pgui_logf(_("Warning: Could not load shapefile %s"), config->shp_file);
                                                ShpLoaderDestroy(state);
                                        }
 
                                        /* Find each column based upon its name and then validate type separately... */
                                        for (i = 0; i < state->num_fields; i++)
                                        {
                                                /* Make sure we find a column */
                                                found = 0;
                                                for (j = 0; j < ntuples; j++)
                                                {
                                                        pg_fieldname = PQgetvalue(result, j, PQfnumber(result, "field"));
                                                        pg_fieldtype = PQgetvalue(result, j, PQfnumber(result, "type"));
 
                                                        if (!strcmp(state->field_names[i], pg_fieldname))
                                                        {
                                                                found = -1;
 
                                                                ret = validate_shape_column_against_pg_column(state->types[i], pg_fieldtype);
                                                                if (!ret)
                                                                {
                                                                        pgui_logf(_("Warning: DBF Field '%s' is not compatible with PostgreSQL column '%s' in %s.%s"), state->field_names[i], pg_fieldname, config->schema, config->table);
                                                                        response = SHPLOADERWARN;
                                                                }
                                                        }
                                                }
 
                                                /* Flag a warning if we can't find a match */
                                                if (!found)
                                                {
                                                        pgui_logf(_("Warning: DBF Field '%s' within file %s could not be matched to a column within table %s.%s"),
                                                                  state->field_names[i], config->shp_file, config->schema, config->table);
                                                        response = SHPLOADERWARN;
                                                }
                                        }
 
                                        ShpLoaderDestroy(state);
                                }
 
                                break;
                }
        }
        else
        {
                pgui_seterr(_("ERROR: unable to process validation response from remote server"));
                response = SHPLOADERERR;
        }
 
        return response;
}

References _, shp_loader_state::field_names, shp_loader_state::num_fields, shp_loader_config::opt, pgui_logf(), pgui_seterr(), shp_loader_config::schema, shp_loader_config::shp_file, ShpLoaderCreate(), ShpLoaderDestroy(), SHPLOADERERR, SHPLOADEROK, ShpLoaderOpenShape(), SHPLOADERWARN, shp_loader_config::table, shp_loader_state::types, and validate_shape_column_against_pg_column().

Referenced by pgui_action_import().

Here is the call graph for this function:

Here is the caller graph for this function: