1 files changed, 148 insertions, 0 deletions
diff --git a/src/sql/xbdelete.cpp b/src/sql/xbdelete.cpp
new file mode 100755
index 0000000..157b281
--- /dev/null
+++ b/src/sql/xbdelete.cpp
@@ -0,0 +1,148 @@
+/* xbdelete.cpp
+
+XBase64 Software Library
+
+Copyright (c) 1997,2003,2014,2022 Gary A Kunkel
+
+The xb64 software library is covered under the terms of the GPL Version 3, 2007 license.
+
+Email Contact:
+
+    XDB-devel@lists.sourceforge.net
+    XDB-users@lists.sourceforge.net
+
+*/
+
+#include "xbase.h"
+
+#ifdef XB_SQL_SUPPORT
+
+namespace xb{
+
+
+/***********************************************************************/
+xbInt16 xbSql::SqlDelete( const xbString &sCmdLine ){
+
+  // expected format:
+  //  DELETE FROM tablename.DBF [WHERE expression]
+
+
+  xbInt16  iRc = 0;
+  xbInt16  iRc2 = 0;
+  xbInt16  iErrorStop = 0;
+  xbString sTableName = "";
+  xbUInt32 ulPos = 0;
+  xbString sCmd = sCmdLine;
+  xbString sNode = "";
+  xbString sFilter;
+  xbInt16  iDelOpt = 0;
+
+  xbString sTable;
+  xbDbf * dbf = NULL;
+
+  try{
+
+//    std::cout << "xbSql::SqlDelete( " << sCmdLine.Str() << " )\n";
+
+    sNode.ExtractElement( sCmd, ' ', 1, 0 );
+    sNode.Trim();
+    sNode.ToUpperCase();
+    if( sNode == "UNDELETE" )
+      iDelOpt = 1;
+
+    // pull off the action
+    sNode.ExtractElement( sCmd, ' ', 2, 0 );
+    sNode.Trim();
+    sNode.ToUpperCase();
+    if( sNode != "FROM" ){
+      iErrorStop = 100;
+      iRc = XB_SYNTAX_ERROR;
+      throw iRc;
+    }
+
+    // pull off the table name
+    sTable.ExtractElement( sCmd, ' ', 3, 0 );
+    sTable.Trim();
+
+    // pull off the "WHERE" statement if it exists
+    sNode.ExtractElement( sCmd, ' ', 4, 0 );
+    sNode.Trim();
+    sNode.ToUpperCase();
+    if( sNode == "WHERE" ){
+      ulPos = sCmd.Pos( "WHERE" );
+      sFilter = sCmd;
+      sFilter.Ltrunc( ulPos + 5 );
+    }
+
+    //  if not open, attempt to open it
+    dbf = xbase->GetDbfPtr( sTable );
+    if( !dbf ){
+      if(( iRc = xbase->OpenHighestVersion( sTable, "", &dbf )) != XB_NO_ERROR ){
+        iErrorStop = 110;
+        throw iRc;
+      }
+    }
+    if( !dbf ){
+      iErrorStop = 120;
+      iRc = XB_DBF_FILE_NOT_OPEN;
+      throw iRc;
+    }
+
+    if( sFilter == "" ){
+      if(( iRc = dbf->DeleteAll( iDelOpt )) != XB_NO_ERROR ){
+        iErrorStop = 130;
+        throw iRc;
+      }
+    } else {
+
+      xbFilter f( dbf->GetXbasePtr(), dbf );
+      if(( iRc = f.Set( sFilter )) != XB_NO_ERROR ){
+        iErrorStop = 150;
+        throw iRc;
+      }
+
+      iRc2 = f.GetFirstRecord( XB_ALL_RECS );
+      while( iRc2 == XB_NO_ERROR ){
+        if( iDelOpt == 0 ){
+          if( !dbf->RecordDeleted()){
+            if(( iRc = dbf->DeleteRecord()) != XB_NO_ERROR ){
+              iErrorStop = 160;
+              throw iRc;
+            }
+            if(( iRc = dbf->Commit()) != XB_NO_ERROR ){
+              iErrorStop = 170;
+              throw iRc;
+            }
+          }
+
+        } else { // undelete
+          if( dbf->RecordDeleted()){
+            if(( iRc = dbf->UndeleteRecord()) != XB_NO_ERROR ){
+              iErrorStop = 180;
+              throw iRc;
+            }
+            if(( iRc = dbf->Commit()) != XB_NO_ERROR ){
+              iErrorStop = 190;
+              throw iRc;
+            }
+          }
+        }
+        iRc2 = f.GetNextRecord();
+      }
+    }
+  }
+
+  catch (xbInt16 iRc ){
+    xbString sMsg;
+    sMsg.Sprintf( "xbSql::SqlDropTable() Exception Caught. Error Stop = [%d] rc = [%d] table = [%s]", iErrorStop, iRc, sTableName.Str() );
+    xbase->WriteLogMessage( sMsg.Str() );
+    xbase->WriteLogMessage( GetErrorMessage( iRc ));
+  }
+
+  return iRc;
+}
+
+/***********************************************************************/
+}              /* namespace       */
+#endif         /*  XB_SQL_SUPPORT */
+