Changeset 19 for trunk/tmdmcreator/src

Timestamp:

02/22/13 14:37:37 (12 years ago)

Author:

lucsch

Message:

Exporting to SQL is now working

Location:

trunk/tmdmcreator/src

Files:

• tmdmcreator.cpp (modified) (1 diff)
• tmdmprocessor.cpp (modified) (2 diffs)
• tmdmprocessor.h (modified) (1 diff)

trunk/tmdmcreator/src/tmdmcreator.cpp

@@ -108 +108 @@
 
     // Process layers
-    TmDmProcessorSimple myLayerProc(m_FileNameUserContent, m_FileNameOutSQL);
-    int myThematicLayersStart = myLayerProc.FindBlock(_T("thematic_layers"));
+    TmDmProcessorSimple myProc(m_FileNameUserContent, m_FileNameOutSQL);
+    int myThematicLayersStart = myProc.FindBlock(_T("thematic_layers"));
     if (myThematicLayersStart == wxNOT_FOUND) {
         errorsmsg.Add(wxString::Format(_("'thematic_layers' field not found in %s"), m_FileNameUserContent.GetFullPath()));
         return false;
     }
-    if (myLayerProc.ProcessBlock(myThematicLayersStart, _T("thematic_layers"))==false) {
+    if (myProc.ProcessBlock(myThematicLayersStart, _T("thematic_layers"))==false) {
         errorsmsg.Add(wxString::Format(_("Processing 'thematic_layers' failed in %s"), m_FileNameUserContent.GetFullPath()));
         return false;
     }
+    
+    // Process objects
+    int myObjectStart = myProc.FindBlock(_T("dmn_layer_object"));
+    if (myObjectStart == wxNOT_FOUND) {
+        errorsmsg.Add(wxString::Format(_("'dmn_layer_object' field not found in %s"), m_FileNameUserContent.GetFullPath()));
+        return false;
+    }
+    if (myProc.ProcessBlock(myObjectStart, _T("dmn_layer_object"))==false) {
+        errorsmsg.Add(wxString::Format(_("Processing 'dmn_layer_object' failed in %s"), m_FileNameUserContent.GetFullPath()));
+        return false;
+    }
+    
+    // Process attributs
+    TmDmProcessorAttributs myProcAttributs (m_FileNameUserContent, m_FileNameOutSQL);
+    int myAttributStart = myProcAttributs.FindBlock(_T("attributs"));
+    if (myAttributStart == wxNOT_FOUND) {
+        errorsmsg.Add(wxString::Format(_("'attributs' field not found in %s"), m_FileNameUserContent.GetFullPath()));
+        return false;
+    }
+    if (myProcAttributs.ProcessBlock(myAttributStart, wxEmptyString)==false) {
+        errorsmsg.Add(wxString::Format(_("Processing 'attributs' failed in %s"), m_FileNameUserContent.GetFullPath()));
+        return false;
+    }
+    
+    
     return true;
 }

trunk/tmdmcreator/src/tmdmprocessor.cpp

@@ -64 +64 @@
     wxArrayString mySQLCols;
     TmDmCopier myCopier(m_FileDst);
+    myCopier.CopyFrom(wxString::Format(_T("\n-- %s --\n"), tablename));
+
     
     wxFileInputStream input(m_FileSrc.GetFullPath());
@@ -123 +125 @@
 }
 
+
+
 TmDmProcessorAttributs::~TmDmProcessorAttributs() {
 }
 
+
+
+bool TmDmProcessorAttributs::_ProcessAttributesName(int blockstart) {
+    wxArrayString mySQLCols;
+    TmDmCopier myCopier(m_FileDst);
+    myCopier.CopyFrom(wxString::Format(_T("\n-- %s --\n"), _T("dmn_layer_attribut")));
+    int NUM_COLS = 3;
+    wxArrayString myPreviousRow;
+    
+    wxFileInputStream input(m_FileSrc.GetFullPath());
+    wxTextInputStream text(input);
+    long myLineIndex = 0;
+    while(input.IsOk() && !input.Eof() ){
+        wxString myRow = text.ReadLine();
+        if (myLineIndex <= blockstart) {
+            myLineIndex++;
+            continue;
+        }
+        
+        if (myLineIndex == blockstart+1) {
+            mySQLCols = wxStringTokenize(myRow, _T("\t"), wxTOKEN_RET_EMPTY);
+            myLineIndex++;
+            continue;
+        }
+        
+        wxArrayString myValues = wxStringTokenize(myRow, _T("\t"), wxTOKEN_RET_EMPTY_ALL);
+        bool bEmpty = true;
+        for (unsigned int i = 0; i< myValues.GetCount(); i++) {
+            if (myValues[i] != wxEmptyString) {
+                bEmpty = false;
+                break;
+            }
+        }
+        if (bEmpty == true) {
+            // ok empty line found
+            return true;
+        }
+        
+        // check that this row differs from previous
+        wxArrayString myAttributRow;
+        for (unsigned int i = 0; i< NUM_COLS; i++) {
+            myAttributRow.Add(myValues.Item(i));
+        }
+        if (myAttributRow == myPreviousRow) {
+            continue;
+        }
+        myPreviousRow = myAttributRow;
+        
+        
+        wxString myInsert = _T("INSERT INTO `dmn_layer_attribut` VALUES (");
+        for (unsigned int i = 0; i< myAttributRow.GetCount(); i++) {
+            myInsert.Append(wxString::Format(_T("\"%s\","), myAttributRow.Item(i)));
+        }
+        myInsert.RemoveLast();
+        myInsert.Append(_T(");\n"));
+        myCopier.CopyFrom(myInsert);
+        myLineIndex++;
+    }
+    return true;
+}
+
+
+
+bool TmDmProcessorAttributs::_ProcessAttributesValues(int blockstart) {
+    wxArrayString mySQLCols;
+    TmDmCopier myCopier(m_FileDst);
+    myCopier.CopyFrom(wxString::Format(_T("\n-- %s --\n"), _T("attribut values")));
+    int START_COL = 3;
+    
+    wxFileInputStream input(m_FileSrc.GetFullPath());
+    wxTextInputStream text(input);
+    long myLineIndex = 0;
+    while(input.IsOk() && !input.Eof() ){
+        wxString myRow = text.ReadLine();
+        if (myLineIndex <= blockstart) {
+            myLineIndex++;
+            continue;
+        }
+        
+        if (myLineIndex == blockstart+1) {
+            mySQLCols = wxStringTokenize(myRow, _T("\t"), wxTOKEN_RET_EMPTY);
+            myLineIndex++;
+            continue;
+        }
+        
+        
+        wxArrayString myValues = wxStringTokenize(myRow, _T("\t"), wxTOKEN_RET_EMPTY_ALL);
+        bool bEmpty = true;
+        for (unsigned int i = 0; i< myValues.GetCount(); i++) {
+            if (myValues[i] != wxEmptyString) {
+                bEmpty = false;
+                break;
+            }
+        }
+        if (bEmpty == true) {
+            // ok empty line found
+            return true;
+        }
+        
+        // query to dmn_catalog
+        wxString myInsert = _T("INSERT INTO `dmn_catalog` VALUES (");
+        for (unsigned int i = START_COL; i< mySQLCols.GetCount(); i++) {
+            myInsert.Append(wxString::Format(_T("\"%s\","), myValues.Item(i)));
+        }
+        myInsert.RemoveLast();
+        myInsert.Append(_T(");\n"));
+        
+        
+        // query to dmn_attribut_value
+        myInsert.Append(wxString::Format(_T("INSERT INTO `dmn_attribut_value` VALUES (%s, %s);\n"),
+                                         myValues.Item(0), myValues.Item(START_COL)));
+        
+        myCopier.CopyFrom(myInsert);
+        myLineIndex++;
+    }
+    return true;
+}
+
+
+
 bool TmDmProcessorAttributs::ProcessBlock(int blockstart, const wxString & tablename) {
-    return false;
-}
-
+    if (_ProcessAttributesName(blockstart) == false) {
+        return false;
+    }
+    
+    if (_ProcessAttributesValues(blockstart) == false) {
+        return false;
+    }
+    return true;
+}
+
+
+

trunk/tmdmcreator/src/tmdmprocessor.h

@@ -62 +62 @@
 
 class TmDmProcessorAttributs : public TmDmProcessor {
+private:
+    bool _ProcessAttributesName(int blockstart);
+    bool _ProcessAttributesValues(int blockstart);
+    
 public:
     TmDmProcessorAttributs(const wxFileName & src, const wxFileName & dest);