insert_records()

static int insert_records ( const char *  schema, const char *  table, const char *  column, const char *  filename, const char *  file_column_name, int  copy_statements, int  out_srid, STRINGBUFFER *  tileset, STRINGBUFFER *  buffer  )

static

Definition at line 877 of file raster2pgsql.c.

References _, append_sql_to_buffer(), copy_from(), copy_from_end(), stringbuffer_t::length, stringbuffer_t::line, rtalloc(), rtdealloc(), rterror(), rtgdalraster::sql, SRID_UNKNOWN, strreplace(), and pixval::x.

Referenced by build_overview(), convert_raster(), and process_rasters().

  {
        char *fn = NULL;
        uint32_t len = 0;
        char *sql = NULL;
        uint32_t x = 0;

        assert(table != NULL);
        assert(column != NULL);

        /* COPY statements */
        if (copy_statements) {

    if (!copy_from(
      schema, table, column,
      (file_column_name ? filename : NULL), file_column_name,
      buffer
    )) {
      rterror(_("insert_records: Could not add COPY statement to string buffer"));
      return 0;
    }


                /* escape tabs in filename */
                if (filename != NULL)
                        fn = strreplace(filename, "\t", "\\t", NULL);

                /* rows */
                for (x = 0; x < tileset->length; x++) {
                        len = strlen(tileset->line[x]) + 1;

                        if (filename != NULL)
                                len += strlen(fn) + 1;

                        sql = rtalloc(sizeof(char) * len);
                        if (sql == NULL) {
                                rterror(_("insert_records: Could not allocate memory for COPY statement"));
                                return 0;
                        }
                        sprintf(sql, "%s%s%s",
                                tileset->line[x],
                                (filename != NULL ? "\t" : ""),
                                (filename != NULL ? fn : "")
                        );

                        append_sql_to_buffer(buffer, sql);
                        sql = NULL;
                }

    if (!copy_from_end(buffer)) {
      rterror(_("process_rasters: Could not add COPY end statement to string buffer"));
      return 0;
    }

        }
        /* INSERT statements */
        else {
                len = strlen("INSERT INTO  () VALUES (ST_Transform(''::raster,xxxxxxxxx));") + 1;
                if (schema != NULL)
                        len += strlen(schema);
                len += strlen(table);
                len += strlen(column);
                if (filename != NULL)
                        len += strlen(",") + strlen(file_column_name);

                /* escape single-quotes in filename */
                if (filename != NULL)
                        fn = strreplace(filename, "'", "''", NULL);

                for (x = 0; x < tileset->length; x++) {
                        char *ptr;
                        int sqllen = len;

                        sqllen += strlen(tileset->line[x]);
                        if (filename != NULL)
                                sqllen += strlen(",''") + strlen(fn);

                        sql = rtalloc(sizeof(char) * sqllen);
                        if (sql == NULL) {
                                rterror(_("insert_records: Could not allocate memory for INSERT statement"));
                                return 0;
                        }
                        ptr = sql;
                        ptr += sprintf(sql, "INSERT INTO %s%s (%s%s%s) VALUES (",
                                        (schema != NULL ? schema : ""),
                                        table,
                                        column,
                                        (filename != NULL ? "," : ""),
                                        (filename != NULL ? file_column_name : "")
                                );
                        if (out_srid != SRID_UNKNOWN) {
                                ptr += sprintf(ptr, "ST_Transform(");
                        }
                        ptr += sprintf(ptr, "'%s'::raster",
                                        tileset->line[x]
                                );
                        if (out_srid != SRID_UNKNOWN) {
                                ptr += sprintf(ptr, ", %d)", out_srid);
                        }
                        if (filename != NULL) {
                                ptr += sprintf(ptr, ",'%s'", fn);
                        }
                        ptr += sprintf(ptr, ");");

                        append_sql_to_buffer(buffer, sql);
                        sql = NULL;
                }
        }

        if (fn != NULL) rtdealloc(fn);
        return 1;
}

Here is the call graph for this function:

Here is the caller graph for this function: