1 files changed, 168 insertions, 0 deletions
diff --git a/src/tests/xb_test_blockread.cpp b/src/tests/xb_test_blockread.cpp
new file mode 100755
index 0000000..ff55d23
--- /dev/null
+++ b/src/tests/xb_test_blockread.cpp
@@ -0,0 +1,168 @@
+/*  xb_test_blockread.cpp
+
+XBase64 Software Library
+
+Copyright (c) 1997,2003,2014,2022,2023 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
+
+*/
+
+// This program tests the class xbBlockRead
+// usage:   xb_test_blockread QUITE|NORMAL|VERBOSE
+
+
+#include "xbase.h"
+
+using namespace xb;
+
+#include "tstfuncs.cpp"
+
+  xbSchema MyDbfRec[] = 
+  {
+    { "NFLD",       XB_NUMERIC_FLD,   10, 0 },
+    { "CFLD",       XB_CHAR_FLD,      89, 0 },
+    { "",0,0,0 }
+  };
+
+
+int main( int argCnt, char **av )
+{
+  xbInt16 iRc  = 0;
+  xbInt16 iRc2 = 0;
+  int iPo = 1;         /* print option */
+                       /* 0 - QUIET    */
+                       /* 1 - NORMAL   */
+                       /* 2 - VERBOSE  */
+
+  if( argCnt > 1 ) {
+    if( av[1][0] == 'Q' )
+      iPo = 0;
+    else if( av[1][0] == 'V' )
+      iPo = 2;
+  }
+
+  xbXBase x;
+  x.SetDataDirectory( PROJECT_DATA_DIR );
+
+  xbDbf4 dbf( &x );
+
+  #ifdef XB_LOGGING_SUPPORT
+  x.SetLogDirectory( PROJECT_LOG_DIR );
+  x.EnableMsgLogging();
+  if( iPo ){
+    std::cout << "Logfile is [" << x.GetLogFqFileName().Str() << "]" << std::endl;
+  }
+  xbString sMsg;
+  sMsg.Sprintf( "Program [%s] initializing...", av[0] );
+  x.WriteLogMessage( sMsg );
+  #endif
+
+
+  InitTime();
+
+
+  iRc2 = dbf.CreateTable( "BLOCKRD.DBF", "BlockRead", MyDbfRec, XB_OVERLAY, XB_MULTI_USER );
+  iRc += TestMethod( iPo, "CreateTable()", (xbInt32) iRc2, XB_NO_ERROR );
+  if( iRc2 )
+    x.DisplayError( iRc2 );
+
+
+  // fill the file with several blocks of data
+  for( xbInt32 i = 0; i < 50; i++ ){
+    iRc2 = dbf.BlankRecord();
+    if( iRc2 != XB_NO_ERROR )
+      iRc += TestMethod( iPo, "BlankRecord()", (xbInt32) iRc2, XB_NO_ERROR );
+
+    iRc2 = dbf.PutLongField( 0, i+1 );
+    if( iRc2 != XB_NO_ERROR )
+      iRc += TestMethod( iPo, "PutLongField()", (xbInt32) iRc2, XB_NO_ERROR );
+
+    iRc2 = dbf.AppendRecord();
+    if( iRc2 != XB_NO_ERROR )
+      iRc += TestMethod( iPo, "AppendRecord()", (xbInt32) iRc2, XB_NO_ERROR );
+
+    iRc2 = dbf.Commit();
+    if( iRc2 != XB_NO_ERROR )
+      iRc += TestMethod( iPo, "Commit()", (xbInt32) iRc2, XB_NO_ERROR );
+  }
+
+
+  dbf.SetDefaultBlockReadSize( 2000 );
+
+  // enable block read for this table
+  iRc += TestMethod( iPo, "EnableBlockReadProcessing()", dbf.EnableBlockReadProcessing(), XB_NO_ERROR );
+
+  xbUInt32 ulFld = 0;
+  xbUInt32 ulCtr = 1;
+
+  iRc2 = XB_NO_ERROR;
+  while( iRc2 == XB_NO_ERROR ){
+    //    std::cout << ulCtr << "\n";
+    iRc2 += dbf.GetRecord( ulCtr );
+    if( iRc2 != XB_NO_ERROR && iRc != XB_INVALID_RECORD )
+      TestMethod( iPo, "GetRecord()", iRc, XB_NO_ERROR );
+
+    if( iRc2 == XB_NO_ERROR ){
+      dbf.GetULongField( "NFLD", ulFld );
+      if( ulFld != ulCtr ){
+        std::cout << "ulFld = " << ulFld << " ulCtr = " << ulCtr << "\n";
+        iRc += TestMethod( iPo, "Field Compare", (xbDouble) ulFld, (xbDouble) ulCtr );
+      }
+    }
+    ulCtr++;
+  }
+
+  // std::cout << "**********Delete every other record\n";
+  iRc2 = dbf.GetFirstRecord();
+  while( iRc2 == XB_NO_ERROR ){
+    if( (dbf.GetCurRecNo() % 2) != 0 ){
+      dbf.DeleteRecord();
+      dbf.Commit();
+    }
+    iRc2 = dbf.GetNextRecord();
+  }
+
+
+  // test filter for deleted records
+  #ifdef XB_FILTER_SUPPORT
+  xbFilter f( &dbf );
+  xbString sFilt = ".NOT. DELETED()";
+  f.Set( sFilt );
+  iRc2 = f.GetFirstRecord();
+  while( iRc2 == XB_NO_ERROR ){
+    dbf.GetULongField( "NFLD", ulFld );
+    if( (ulFld % 2) != 0 ){
+      iRc += TestMethod( iPo, "Filter GetNextRecord()", ulFld % 2, 0 );
+    }
+    iRc2 = f.GetNextRecord();
+  }
+  #endif  // XB_FILTER_SUPPORT
+
+
+  iRc += TestMethod( iPo, "DisableBlockReadProcessing()", dbf.DisableBlockReadProcessing(), XB_NO_ERROR );
+  //iRc2 = dbf.DeleteTable();
+
+  iRc2 = dbf.Close();
+  iRc += TestMethod( iPo, "Close()", (xbInt32) iRc2, XB_NO_ERROR );
+  if( iRc2 )
+    x.DisplayError( iRc2 );
+
+
+  #ifdef XB_LOGGING_SUPPORT
+  sMsg.Sprintf( "Program [%s] terminating with [%d] errors...", av[0], iRc * -1 );
+  x.WriteLogMessage( sMsg );
+  #endif
+
+
+  if( iPo > 0 || iRc < 0 )
+    fprintf( stdout, "Total Errors = %d\n", iRc * -1 );
+
+  return iRc;
+}
+