---

fmapsimportmifmid.c

Go to the documentation of this file.

/* fmapsimportmifmid.c - Import/Export MIF/MID library of FMaps
 *
 * Copyright (C) 2000  Franck Martin <franck@sopac.org>
 *
 * 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
 * Library 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.
 */

/*
 * Modified by the FMaps Team and others 2000.  See the AUTHORS
 * file for a list of people on the FMaps Team.  See the ChangeLog
 * files for a list of changes.  These files are distributed with
 * FMaps at http://FMaps.sourceforge.net/.
 */

#include <math.h>
#include <stdio.h>
#include <stdlib.h>
#include <gnome.h>
#include "fmaps.h"

#define MAXLINE 8192  /* Maximum size to read a line in a file */

/* MIF/MID Objects */
#define MIF_NONE        0
#define MIF_POINT       1
#define MIF_LINE        2
#define MIF_PLINE       3
#define MIF_REGION      4
#define MIF_ARC         5
#define MIF_TEXT        6
#define MIF_RECT        7
#define MIF_ROUND_RECT  8
#define MIF_ELLIPSE     9

/* MIF/MID Types */
#define MID_UNKNOWN     0
#define MID_INTEGER     1
#define MID_SMALLINT    2
#define MID_FLOAT       3
#define MID_DATE        4
#define MID_LOGICAL     5
#define MID_CHAR        6
#define MID_DECIMAL     7

void FM_Import_MIFMID(PGconn* conn,const char *name)
{
  gchar *buffer;
  gchar *buffer2;
  gchar *buffer3;
  gchar *buffer4;
  gchar **col;
  gint *coltype=NULL;
  gint colobj=0;
  PGresult *qryResult;
  FILE *miffile;
  FILE *midfile;
  gint i;
  gint j;
  gint nbtuples;

  gchar *fieldname;
  gchar *fieldtype;
  gchar *tablestruct=NULL;
  gchar *tablefield=NULL;
  gchar *tablename;

  gchar *mifVersion;
  gchar *mifCharset;
  gint nbColumns=0;
  gint charlen;
  gchar *delimiter=NULL;
  gchar *oid;

  gboolean nextline;
  gboolean found;

  gdouble dblx=0;
  gdouble dbly=0;

  Point *points=NULL;
  gint npoints=0;

  g_return_if_fail (conn!=NULL);
  g_return_if_fail (name!=NULL);

  gnome_app_flash (GNOME_APP(Fmaps), "Importing MIFMID");

  buffer=g_strndup(name,strlen(name)-4);
  buffer2=g_strconcat(buffer,".MID",NULL);

  tablename=g_strdup(g_basename(buffer));

  g_warning("%s",tablename);

  g_warning("%s %s",name,buffer2);
  miffile=fopen(name,"r");
  midfile=fopen(buffer2,"r");

  g_free(buffer);
  g_free(buffer2);

  buffer=g_malloc0(255);
  /* Analyse MIF */
  fscanf(miffile,"%s\n",buffer);
  /* wrong format */
  g_strup(buffer);
  if (g_str_equal(buffer,"VERSION"))
  {
        fscanf(miffile,"%s\n",buffer);
        g_strup(buffer);
        g_warning("%s",buffer);
        mifVersion=g_strstrip(buffer);  
  } else
  {
        g_warning("%s",buffer);
        FM_MessageBox("This is not a MIF file");
        return;
  }

  fscanf(miffile,"%s\n",buffer);
  g_strup(buffer);
  /* get Charset */
  if (g_str_equal(buffer,"CHARSET"))
  {
        fscanf(miffile,"%s\n",buffer);
        g_strup(buffer);
        mifCharset=g_strstrip(buffer);
        g_warning("CHARSET:%s",buffer);
        fscanf(miffile,"%s\n",buffer);
        g_strup(buffer);
  }
  /* get DELIMITER */
  if (g_str_equal(buffer,"DELIMITER"))
  {
        fscanf(miffile,"%s\n",buffer);
        g_warning("DELIMITER:%s",buffer);
        delimiter=g_strndup(buffer+1,1);
        fscanf(miffile,"%s\n",buffer);
        g_strup(buffer);
  }
  /* get UNIQUE */
  if (g_str_equal(buffer,"UNIQUE"))
  {
        fscanf(miffile,"%s\n",buffer);
        g_warning("UNIQUE:%s",buffer);
        fscanf(miffile,"%s\n",buffer);
        g_strup(buffer);
  }
  /* get INDEX */
  if (g_str_equal(buffer,"INDEX"))
  {
        fscanf(miffile,"%s\n",buffer);
        g_warning("INDEX:%s",buffer);
        fscanf(miffile,"%s\n",buffer);
        g_strup(buffer);
  }
  /* get COORDSYS */
  if (g_str_equal(buffer,"COORDSYS"))
  {
        fscanf(miffile,"%s\n",buffer);
        g_strup(buffer);
        g_warning("COORDSYS:%s",buffer);
        if (g_str_equal(buffer,"EARTH"))
        {
          buffer=fgets(buffer,255,miffile);
        } else
        {
          buffer=fgets(buffer,255,miffile);
        }
        fscanf(miffile,"%s\n",buffer);
        g_strup(buffer);
  }
  /* get TRANSFORM */
  if (g_str_equal(buffer,"TRANSFORM"))
  {
        fscanf(miffile,"%s\n",buffer);
        g_warning("TRANSFORM:%s",buffer);
        fscanf(miffile,"%s\n",buffer);
        g_strup(buffer);
  }
  /* get COLUMNS */
  if (g_str_equal(buffer,"COLUMNS"))
  {
        fscanf(miffile,"%s\n",buffer);
        nbColumns=atoi(buffer);
        g_warning("COLUMNS:%d",nbColumns);
        
        tablestruct=g_strdup_printf("CREATE TABLE %s ( ",tablename);
        tablefield=g_strdup(" (");
        
        coltype=g_malloc(sizeof(gint)*nbColumns);
        
        for(i=1;i<=nbColumns;i++)
        {
        
          fscanf(miffile,"%s\n",buffer);
          fieldname=g_strdup(buffer);
          fscanf(miffile,"%s\n",buffer);
          g_strup(buffer);
        
          if (g_str_equal(buffer,"INTEGER"))
          {
            fieldtype=g_strdup("INT4");
            coltype[i-1]=MID_INTEGER;
          } else if (g_str_equal(buffer,"SMALLINT"))
          {
            fieldtype=g_strdup("INT2");
            coltype[i-1]=MID_SMALLINT;
          } else if (g_str_equal(buffer,"FLOAT"))
          {
            fieldtype=g_strdup("FLOAT8");
            coltype[i-1]=MID_FLOAT;
          } else if (g_str_equal(buffer,"DATE"))
          {
            fieldtype=g_strdup("DATE");
            coltype[i-1]=MID_DATE;
          } else if (g_str_equal(buffer,"LOGICAL"))
          {
            fieldtype=g_strdup("BOOLEAN");
            coltype[i-1]=MID_LOGICAL;
          } else if (g_strncasecmp(buffer,"CHAR",4)==0)
          {
            charlen=1;
            for(j=0;j<strlen(buffer);j++)
            {
              if ((gchar)(buffer[j])=='(')
              {
                charlen=atoi(&buffer[j+1]);
                break;
              }
            }
            fieldtype=g_strdup_printf("VARCHAR(%d)",charlen);
            coltype[i-1]=MID_CHAR;
          } else if (g_strncasecmp(buffer,"DECIMAL",7)==0)
          {
            fieldtype=g_strdup("FLOAT8");
            buffer=fgets(buffer,255,miffile);
            coltype[i-1]=MID_DECIMAL;
          } else
          {
            fieldtype=g_strdup("INT2");
            coltype[i-1]=MID_UNKNOWN;
          }
        
          buffer2=g_strdup(tablestruct);
          buffer3=g_strdup(tablefield);
          g_free(tablestruct);
          g_free(tablefield);
          if (i==nbColumns)
          {
            tablestruct=g_strconcat(buffer2," ",fieldname, " ",fieldtype,") ",NULL);
            tablefield= g_strconcat(buffer3," ",fieldname, ") ",NULL);
          } else
          {
            tablestruct=g_strconcat(buffer2," ",fieldname, " ",fieldtype,", ",NULL);
            tablefield=g_strconcat(buffer3," ",fieldname, ", ",NULL);
          }
          g_free(buffer2);
          g_free(buffer3);
          g_free(fieldtype);
          g_free(fieldname);
        }
        
        g_warning("%s",tablestruct);
        g_warning("%s",tablefield);
                
        /* drop the table first*/
        buffer2=g_strdup_printf("DROP TABLE %s",tablename);
        qryResult = PQexec(conn,buffer2);
        g_free(buffer2);
        PQclear(qryResult);

        /* create the table */
        qryResult = PQexec(conn,tablestruct);
        PQclear(qryResult);

        /*remove the reference in the metadata it will be added at the end*/
                buffer2=g_strdup_printf("select OID FROM f_catalogue WHERE meta_file_id='%s'",tablename);
                qryResult = PQexec(conn,buffer2);
                nbtuples = PQntuples(qryResult);
    oid=NULL;
    if (nbtuples>0)
    {
                  oid = g_strdup(PQgetvalue(qryResult,0,0));
                 }
                g_free(buffer2);
                PQclear(qryResult);     
          
  
                buffer2=g_strdup_printf("DELETE FROM f_catalogue WHERE meta_file_id='%s'",tablename);
                qryResult = PQexec(conn,buffer2);
                g_free(buffer2);
                PQclear(qryResult);     

          if (!(oid==NULL))
          {
                buffer2=g_strdup_printf("DELETE FROM f_catalogue_spatial_rep_type_code WHERE CID=%s",oid);
                qryResult = PQexec(conn,buffer2);
                g_free(buffer2);
                PQclear(qryResult);             
          }
                        
        fscanf(miffile,"%s\n",buffer);
        g_strup(buffer);
  }
  /* get DATA */
  if (g_str_equal(buffer,"DATA"))
  {
        g_warning("DATA");
        fscanf(miffile,"%s\n",buffer);
        g_strup(buffer);
  }

  /* create the geographic table as it does not exists */
  /* drop it first for security */
  buffer2=g_strdup_printf("DROP TABLE f_geo_%s",tablename);
  qryResult = PQexec(conn,buffer2);
  PQclear(qryResult);
  g_free(buffer2);
        
  /* then create it */
  buffer2=g_strdup_printf("CREATE TABLE f_geo_%s %s",tablename,F_GEO_TABLE);
  qryResult = PQexec(conn,buffer2);
  g_warning("%s",buffer2);
  PQclear(qryResult);
  g_free(buffer2);

  while (!feof(miffile))
  {
    nextline=TRUE;
    found=FALSE;
    colobj=MIF_NONE;
    if (g_str_equal(buffer,"NONE"))
    {
      found=TRUE;
      colobj=MIF_NONE;
    } else if (g_str_equal(buffer,"POINT"))
    {
      found=TRUE;
      colobj=MIF_POINT;
      fscanf(miffile,"%s\n",buffer);
      dblx=strtod(buffer,NULL);

      fscanf(miffile,"%s\n",buffer);
      dbly=strtod(buffer,NULL);

      fscanf(miffile,"%s\n",buffer);
      if (g_str_equal(buffer,"SYMBOL"))
      {
        buffer=fgets(buffer,255,miffile);
      } else
      {
        nextline=FALSE;
      }
    } else if (g_str_equal(buffer,"LINE"))
    {
      found=TRUE;
      colobj=MIF_LINE;

      npoints=2;
      points=g_new(Point,npoints);
      for (i=0;i<npoints;i++)
      {
        fscanf(miffile,"%s\n",buffer);
        points[i].x=strtod(buffer,NULL);

        fscanf(miffile,"%s\n",buffer);
        points[i].y=strtod(buffer,NULL);
      }

      fscanf(miffile,"%s\n",buffer);
      if (g_str_equal(buffer,"PEN"))
      {
        buffer=fgets(buffer,255,miffile);
      } else
      {
        nextline=FALSE;
      }
    } else if (g_str_equal(buffer,"PLINE"))
    {
      found=TRUE;
      colobj=MIF_PLINE;

      fscanf(miffile,"%s\n",buffer);
      npoints=strtod(buffer,NULL);

      points=g_new(Point,npoints);

      for (i=0;i<npoints;i++)
      {
        fscanf(miffile,"%s\n",buffer);
        points[i].x=strtod(buffer,NULL);

        fscanf(miffile,"%s\n",buffer);
        points[i].y=strtod(buffer,NULL);
      }

      fscanf(miffile,"%s\n",buffer);
      if (g_str_equal(buffer,"PEN"))
      {
        buffer=fgets(buffer,255,miffile);
      }
      if (g_str_equal(buffer,"SMOOTH"))
      {
        buffer=fgets(buffer,255,miffile);
      }
      nextline=FALSE;
    } else if (g_str_equal(buffer,"REGION"))
    {
      found=TRUE;
    } else if (g_str_equal(buffer,"ARC"))
    {
      found=TRUE;
    } else if (g_str_equal(buffer,"TEXT"))
    {
      found=TRUE;
    } else if (g_str_equal(buffer,"RECT"))
    {
      found=TRUE;
    } else if (g_str_equal(buffer,"ROUNDRECT"))
    {
      found=TRUE;
    } else if (g_str_equal(buffer,"ELLIPSE"))
    {
      found=TRUE;
    }

    /* read the data in MID file and store it in the table */
    if (found)
    {
      buffer2=g_malloc0(MAXLINE);
      buffer2=fgets(buffer2,MAXLINE,midfile);
      buffer3=g_strndup(buffer2,strlen(buffer2)-1);

      col=g_strsplit(buffer3,delimiter,nbColumns);
      g_free(buffer3);
      g_free(buffer2);

      /* remove the "" of strings */
      for(i=0;i<nbColumns;i++)
      {
        if (col[i][0]=='"')
        {
          buffer2=g_strdup(col[i]);
          g_free(col[i]);
          col[i]=g_strndup(buffer2+1,strlen(buffer2)-2);
          g_free(buffer2);
        }
      }
      /* prepare the sql statement to enter tuple data*/
      buffer2=g_strdup_printf("INSERT INTO %s %s VALUES ( ",tablename,tablefield);
      for (i=0;i<nbColumns;i++)
      {
        /* format the data in postgres format */
        buffer4=NULL;
        if (coltype[i]==MID_DATE)
        {
          if (g_str_equal(col[i],""))
          {
            buffer4=g_strdup("NULL");
          } else
          {
            buffer4=g_strdup(col[i]);
          }
        } else if (coltype[i]==MID_LOGICAL)
        {
          if (g_str_equal(col[i],"F"))
          {
            buffer4=g_strdup("'0'");
          } else
          {
            buffer4=g_strdup("'1'");
          }
        } else
        {
          buffer4=g_strconcat("'",col[i],"'",NULL);
        }

        buffer3=g_strconcat(buffer2,buffer4,NULL);
        g_free(buffer4);
        g_free(buffer2);
        if (i<nbColumns-1)
        {
          buffer2=g_strconcat(buffer3,",",NULL);
        } else
        {
          buffer2=g_strdup(buffer3);
        }
        g_free(buffer3);
      }
      buffer3=g_strconcat(buffer2,")",NULL);
      g_free(buffer2);

      /* insert the data */
      qryResult = PQexec(conn,buffer3);
      oid=g_strdup(PQoidStatus(qryResult));
      
      /* debug */
      if (!(g_str_equal(PQresultErrorMessage(qryResult),"")))
      {
        g_warning("%s : %s",buffer3, PQresultErrorMessage(qryResult));
      }
      
      g_free(buffer3);
      PQclear(qryResult);



      /* now we have the oid and we insert the geodata depending of the object*/
      if (colobj==MIF_POINT)
      {
        /* insert point data */

        buffer2=g_strdup_printf("INSERT INTO f_geo_%s (%s) VALUES(%s, 1, 0, 0, 0, 0, 0, 0, NULL, NULL, 'POINT (%f, %f, 0)',NULL ,NULL )", tablename, F_GEO_TABLE_FIELD, oid, dblx, dbly);
        qryResult = PQexec(conn,buffer2);
        
        /* debug */
        if (!(g_str_equal(PQresultErrorMessage(qryResult),"")))
        {
          g_warning("%s : %s",buffer2, PQresultErrorMessage(qryResult));
        }
        PQclear(qryResult);
        g_free(buffer2);
        
      }
      if (colobj==MIF_LINE || colobj==MIF_PLINE)
      {
        /* insert line data */
        buffer4=g_strdup("");
        for (i=0;i<npoints;i++)
        {
          buffer3=g_strdup_printf("%s (%f, %f, 0)",buffer4,points[i].x,points[i].y);
          g_free(buffer4);
          buffer4=g_strdup(buffer3);
          g_free(buffer3);
        }

        buffer2=g_strdup_printf("INSERT INTO f_geo_%s (%s) VALUES(%s, 1, 0, 0, 0, 0, 0, 0, NULL, NULL, 'POLYLINE%s', NULL, NULL)",tablename,F_GEO_TABLE_FIELD,oid,buffer4);
        qryResult = PQexec(conn,buffer2);

        g_free(buffer4);
        g_free(points);
        
        /* debug */
        if (!(g_str_equal(PQresultErrorMessage(qryResult),"")))
        {
          g_warning("%s : %s",buffer2, PQresultErrorMessage(qryResult));
        }
        PQclear(qryResult);
        g_free(buffer2);
        
      }


      /* clean up */
      g_free(oid);
      for(i=0;i<=nbColumns;i++)
      {
        g_free(col[i]);
      }
     g_free(col);
     }

    /* read next string if needed */
    if (nextline)
    {
      fscanf(miffile,"%s\n",buffer);
      g_strup(buffer);
    }
  }

  /* reference the table in the metadata */

  buffer2=g_strdup_printf("INSERT INTO f_catalogue (meta_file_id,series) VALUES ('%s','coasts')",tablename);
  qryResult = PQexec(conn,buffer2);
  g_free(buffer2);
  PQclear(qryResult);

        oid=g_strdup(PQoidStatus(qryResult));
  
  buffer2=g_strdup_printf("INSERT INTO f_catalogue_spatial_rep_type_code (CID,spatial_rep_type_code) VALUES (%s,2)",oid);
  qryResult = PQexec(conn,buffer2);
  g_free(buffer2);
  PQclear(qryResult);
  
  g_free(oid);

  /* cleaning */

  g_free(buffer);
  g_free(delimiter);

  g_free(tablefield);
  g_free(tablestruct);

  g_free(tablename);

  g_free(coltype);

  fclose(midfile);
  fclose(miffile);



  gnome_app_flash (GNOME_APP(Fmaps), "Importing MIFMID Completed");

  return;
}

---