runtime/nongui/IBBufferedCursors.pas

(*
 *  IBX For Lazarus (Firebird Express)
 *
 *  The contents of this file are subject to the Initial Developer's
 *  Public License Version 1.0 (the "License"); you may not use this
 *  file except in compliance with the License. You may obtain a copy
 *  of the License here:
 *
 *    http://www.firebirdsql.org/index.php?op=doc&id=idpl
 *
 *  Software distributed under the License is distributed on an "AS
 *  IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
 *  implied. See the License for the specific language governing rights
 *  and limitations under the License.
 *
 *  The Initial Developer of the Original Code is Tony Whyman.
 *
 *  The Original Code is (C) 2023 Tony Whyman, MWA Software
 *  (http://www.mwasoftware.co.uk).
 *
 *  All Rights Reserved.
 *
 *  Contributor(s): ______________________________________.
 *
*)
unit IBBufferedCursors;

{$mode Delphi}
{$codepage UTF8}

{ $define PrintBuf}

interface

uses
  Classes, SysUtils, DB, IB, IBBlob, IBExternals, FmtBCD;

type
  { The TIBSimpleBufferPool provides basic buffer management for IBX. The pool consists
    of one or more memory blocks organised as a bi-directional linked list. The blocks do
    not have to be the same size and the first is typically a small block with
    subsequent blocks larger in size. This allows for efficient memory allocation
    for small datasets whilst efficiently extending the pool for larger datasets.

    Each block comprises a "start header", one or more fixed size "buffers" and a trailing end
    header. Each type is distinguished by the first byte value. Additionally, the
    first byte of the first buffer in a block is separately identified. This
    allows for a block to be parsed in either direction with the end header terminating
    forward parsing while the first buffer identifier terminates parsing in the
    backwards direction.

    The end header consists of no more than a pointer back to the start header, while
    the start header includes the previous and next block pointers, the number of buffers
    in the block and the number of buffers in use.

    Each buffer is allocated a sequential record number starting from one. A simple
    TList based index allows for random access to the block containing a buffer
    identifies by record number with the requested buffer then located as an
    offset from the start header.
  }

  PIBRecordNumber = ^TIBRecordNumber;

  TIBRecordNumber = cardinal;

  { TIBSimpleBufferPool }

  TIBSimpleBufferPool = class
  private type
    THeaderTypes = (htEmptySlot=0, htStart, htEnd, htFirstBuffer, htBuffer);
    PStartHeader = ^TStartHeader;
    TStartHeader = record
      HeaderType: THeaderTypes;
      PreviousBlock: PByte;
      NextBlock: PByte;
      MaxBuffers: integer;
      BuffersInUse: integer;
      FirstRecNo: TIBRecordNumber;  {1- based}
    end;

    PEndHeader = ^TEndHeader;
    TEndHeader = record
      HeaderType: THeaderTypes;
      StartHeader: PByte;
    end;

    PBufferHeader = ^TBufferHeader;
    TBufferHeader = record
      HeaderType: THeaderTypes;
      RecNo: TIBRecordNumber;
    end;

  strict private
    FFirstBlock: PByte;
    FLastBlock: PByte;
    FBufferSize: integer;  {user buffer size i.e. not including header}
    FBuffersPerBlock: integer;
    FFirstBlockBuffers: integer;
    FBufferIndex: TList;
    FLastBuffer: PByte;
    FCurrent: PByte;
    FName: string;
    FRecordCount: TIBRecordNumber;
    function AllocBlock(buffers: integer): PByte;
    procedure CheckBuffersAvailable;
    procedure InternalCheckValidBuffer(P:PByte); inline;
  protected
    procedure CheckValidBuffer(P:PByte); virtual;
    function AddBuffer: PByte; virtual;
    procedure Clear; virtual;
    function GetFirst: PByte; virtual;
    function GetLast: PByte; virtual;
    function GetBuffer(RecNo: TIBRecordNumber): PByte; virtual;
    function GetNextBuffer(aBuffer: PByte): PByte; virtual;
    function GetPriorBuffer(aBuffer: PByte): PByte; virtual;
  public
    constructor Create(aName: string; bufSize, aBuffersPerBlock, firstBlockBuffers: integer);
    destructor Destroy; override;
    function Append: PByte;
    function GetRecNo(aBuffer: PByte): TIBRecordNumber; virtual;
    function GetRecordCount: TIBRecordNumber;
    function Empty: boolean;
    property BuffersPerBlock: integer read FBuffersPerBlock write FBuffersPerBlock;
    property Name: string read FName;
    property RecordCount: TIBRecordNumber read FRecordCount;
    property BufferSize: integer read FBufferSize;
  end;

  PIBDBKey = ^TIBDBKey;
  TIBDBKey = record
    DBKey: array[0..7] of Byte;
    end;


  {
    The TIBBufferPool builds on TIBSimpleBufferPool and adds the ability to
    insert buffers before and after a given buffer and to mark a buffer as
    deleted.

    In order to avoid large memory to memory copies, a previousBuffer pointer
    is added to each buffer header. InsertBefore is thus simply achieved by
    adding a buffer to the pool and inserting it into the backwards chain.
    GetPriorBuffer is then amended to follow the previous pointer.

    InsertAfter is implemented similarly. However, those appended to the pool
    have to be identified as appended instead of simply inserted. This is because
    GetNextBuffer is implemented using the inherited method while skipping
    inserted and deleted buffers. That is the inherited method is called repeatedly
    until an appended buffer is returned or EOF is reached.

    Deletion is implemetned by marking a buffer as deleted and adjusting the previous
    pointer of the next buffer in sequence
  }
  { TIBBufferPool }

  TIBBufferPool = class(TIBSimpleBufferPool)
  private type
    TRecordStatus = (rsAppended,rsInserted,rsInsertDeleted,rsAppendDeleted);
    PRecordData = ^TRecordData;
    TRecordData = record
      rdStatus: TRecordStatus;
      rdPreviousBuffer: PByte;
    end;
  strict private
    FFirstRecord: PByte;
    FLastRecord: PByte;
    FInsertedRecords: integer;
    FDeletedRecords: integer;
    function InternalGetNextBuffer(aBuffer: PByte; IncludeDeleted: boolean): PByte;
  public
    constructor Create(aName: string; bufSize, aBuffersPerBlock, firstBlockBuffers: integer);
    procedure Clear; override;
    function GetFirst: PByte; override;
    function GetLast: PByte; override;
    function GetBuffer(RecNo: TIBRecordNumber): PByte; override;
    function GetNextBuffer(aBuffer: PByte): PByte; override; overload;
    function GetNextBuffer(aBuffer: PByte; IncludeDeleted: boolean): PByte; overload;
    function GetPriorBuffer(aBuffer: PByte): PByte; override;
    function GetRecNo(aBuffer: PByte): TIBRecordNumber; override;
    function InsertBefore(aBuffer: PByte): PByte; virtual;
    function InsertAfter(aBuffer: PByte): PByte; virtual;
    function LocatePreviousBuffer(aBuffer: PByte): PByte;
    function Append: PByte;
    function Delete(aBuffer: PByte): PByte;
    procedure UnDelete(aBuffer: PByte);
    function GetUpdateStatus(aBuffer: PByte): TUpdateStatus;
    function GetRecordStatus(aBuffer: PByte): TRecordStatus;
    property InsertedRecords: integer read FInsertedRecords;
    property DeletedRecords: integer read FDeletedRecords;
  {$ifdef PrintBuf}
  public
    procedure PrintBufferList;
  {$endif}
  end;

  {
    TIIBOldBufferPool is used to support cached updates. When a record is updated
    a new buffer is allocated from this pool. The caller may then copy the
    record data into this buffer. The buffer header includes the cached update
    status and a pointer back to the buffer containing the updated data.

    Insertions and Deletions do not need a data copy. This only applies to updated
    records.

    Forward and backwards iterators are provided. The Forward iterator may be used
    to apply updates while the backwards iterator may be used to cancel updates. In
    each case the update status is used to determine the actual and the pointer to
    the data buffer is used to access the updated data.
  }

  TCachedUpdateStatus = (
                     cusUnmodified=0, cusModified, cusInserted,
                     cusDeleted, cusUninserted
                    );

  TIBUpdateRecordTypes = set of TCachedUpdateStatus;

  { TIBOldBufferPool }

  TIBOldBufferPool = class(TIBSimpleBufferPool)
   private type
     PRecordData = ^TRecordData;
     TRecordData = record
       rdStatus: TCachedUpdateStatus;
       rdRecordNumber: TIBRecordNumber;
       rdDataBuffer: PByte;
     end;

   private
     FModifiedRecords: integer;

   protected
     procedure CheckValidBuffer(P:PByte); override;

   public type
     TIterator = procedure(status: TCachedUpdateStatus; DataBuffer, OldBuffer: PByte) of object;

   public
    constructor Create(aName: string; bufSize, aBuffersPerBlock, firstBlockBuffers: integer);
    function Append(RecNo: TIBRecordNumber; DataBuffer: PByte): PByte;
    procedure Clear; override;
    function FindOldBufferFor(RecNo: TIBRecordNumber): PByte;
    function GetBuffer(RecNo: TIBRecordNumber): PByte; override;
    function GetRecNo(aBuffer: PByte): TIBRecordNumber; override;
    function GetStatus(aBuffer: PByte): TCachedUpdateStatus; overload;
    function GetStatus(RecNo: TIBRecordNumber): TCachedUpdateStatus; overload;
    procedure SetStatus(aBuffer: PByte; status: TCachedUpdateStatus);
    procedure SetDataBuffer(aBuffer: PByte; aDataBuffer: PByte);
    procedure ForwardIterator(iterator: TIterator);
    procedure BackwardsIterator(iterator: TIterator);
    property ModifiedRecords: integer read FModifiedRecords;
  end;

    PIBBufferedDateTimeWithTimeZone = ^TIBBufferedDateTimeWithTimeZone;
    TIBBufferedDateTimeWithTimeZone = packed record
      Timestamp: TDateTime;
      dstOffset: smallint;
      TimeZoneID: ISC_USHORT;
    end;

  { TIBDSBlobStream }

  TIBDSBlobStream = class(TStream)
  private
    FHasWritten: boolean;
    procedure FieldChanged;
  protected
    FField: TField;
    FBlobStream: TIBBlobStream;
    function  GetSize: Int64; override;
  public
    constructor Create(AField: TField; ABlobStream: TIBBlobStream;
                       Mode: TBlobStreamMode);
    destructor Destroy; override;
    function Read(var Buffer; Count: Longint): Longint; override;
    function Seek(Offset: Longint; Origin: Word): Longint; override;
    procedure SetSize(NewSize: Longint); override;
    function Write(const Buffer; Count: Longint): Longint; override;
    property BlobStream: TIBBlobStream read FBlobStream;
  end;

    TUpdatesIterator = procedure(status: TCachedUpdateStatus; aBufID: TRecordBuffer;
                       var RecordSkipped: boolean) of object;

    TOnValuesReturned = procedure(qryResults: IResults) of object;

    TRegisteredQueryTypes = (rqInsert,rqModify,rqDelete,rqRefresh);

    IIBCursor = interface
    ['{909621f7-e7fe-4b39-a8c5-f25c40a71c12}']
      function AllocRecordBuffer: TRecordBuffer;
      procedure FreeRecordBuffer(var Buffer: TRecordBuffer);
      function CreateBlobStream(aBufID: TRecordBuffer; Field: TField; Mode: TBlobStreamMode): TStream;
      function GetArray(aBufID: TRecordBuffer; Field: TField): IArray;
      procedure SetArrayIntf(aBufID: TRecordBuffer; AnArray: IArray; Field: TField);
      function GetRecDBkey(aBufID: TRecordBuffer): TIBDBKey;
      function GetFieldData(aBufID: TRecordBuffer; field: TField; outBuffer: PByte): boolean;
      procedure SetFieldData(aBufID: TRecordBuffer; field: TField; inBuffer: PByte);
      procedure SetSQLParams(aBufID: TRecordBuffer; params: ISQLParams);
      procedure UpdateRecordFromQuery(aBufID: TRecordBuffer; QryResults: IResults);
      function NeedRefresh(aBufID: TRecordBuffer): boolean;
      function GetBookmarkFlag(aBufID: TRecordBuffer): TBookmarkFlag;
      procedure SetBookmarkFlag(aBufID: TRecordBuffer; aBookmarkFlag: TBookmarkFlag);
      procedure GetBookmarkData(Buffer: TRecordBuffer; Data: Pointer);
      procedure SetBookmarkData(Buffer: TRecordBuffer; Data: Pointer);
      function GetBookmarkSize: integer;
      function GetRecord(aBufID: TRecordBuffer; GetMode: TGetMode;
                         DoCheck: Boolean): TGetResult;
      procedure GotoFirst;
      procedure GotoLast;
      function GotoRecordNumber(RecNo: TIBRecordNumber): boolean;
      function GetRecNo(aBufID: TRecordBuffer): TIBRecordNumber;
      function GetCurrentRecNo: TIBRecordNumber;
      function GetRecordCount: TIBRecordNumber;
      function GetRecordSize: word;
      procedure SetCurrentRecord(aBufID: TRecordBuffer);
      procedure EditBuffer(aBufID: TRecordBuffer);
      procedure CancelChanges(aBufID: TRecordBuffer);
      procedure EditingDone(aBufID: TRecordBuffer; UpdateStatus: TCachedUpdateStatus);
      procedure InsertBefore(aBufID: TRecordBuffer);
      procedure Append(aBufID: TRecordBuffer);
      procedure Delete(aBufID: TRecordBuffer);
      procedure UnDelete(aBufID: TRecordBuffer);
      function GetCachedUpdateStatus(aBufID: TRecordBuffer): TCachedUpdateStatus;
      function GetUpdateStatus(aBufID: TRecordBuffer): TUpdateStatus;

      function GetInsertedRecords: integer;
      function GetDeletedRecords: integer;
      procedure ApplyUpdates(iterator: TUpdatesIterator);
      procedure CancelUpdates;
      function UpdatesPending: boolean;
      function GetCachedUpdatesEnabled:boolean;
      procedure SwapDataBuffer(buf1, buf2: TRecordBuffer);
      function GetAliasName(FieldNo: integer): AnsiString;
      procedure InitRecord(aBufID: TRecordBuffer);
      function AtBOF: boolean;
      function AtEOF: boolean;
      procedure ClearCalcFields(aBufID: TRecordBuffer);
      procedure SetCursor(aCursor: IResultSet);
      procedure RegisterQuery(qryType : TRegisteredQueryTypes; qry : IStatement;
         OnValuesReturnedProc : TOnValuesReturned);
      procedure ExecRegisteredQuery(qryType : TRegisteredQueryTypes; aBufID: TRecordBuffer;
         var SelectCount, InsertCount, UpdateCount, DeleteCount: integer);

      function HasRegisteredQuery(qryType : TRegisteredQueryTypes): boolean;
    end;

    {
    TIBSelectCursor provides common functions for uni-directional, bi-directional
    and bi-directional with cached updates cursors.

    The IB Cursor classes support a common interface that is used to satisfy the
    TDataset abstract methods used in buffer management including AllocRecordBuffer
    and GetRecord.

    The opaque pointer to a buffer returned to TDataset is a pointer to an internal
    data structure including a pointer to the actual buffer and a pointer to a separate
    buffer for cached updates. This approach is used to avoid in memory copies every
    time the dataset is scolled. It also avoids the cached rows buffers having to
    include space for the calculated fields.
  }

  TIBSelectCursor = class(TInterfacedObject)
  private type
    type
      { TIBArray }

      TIBArray = class   {Wrapper class to support array cache and event handling}
      private
        FArray: IArray;
        FRecNo: integer;
        FField: TField;
        procedure EventHandler(Sender: IArray; Reason: TArrayEventReason);
      public
        constructor Create(aField: TField; anArray: IArray);
        destructor Destroy; override;
        property ArrayIntf: IArray read FArray;
      end;

      PIBArray = ^TIBArray;
      PIBBlobStream = ^TIBBlobStream;

      TColumnMetadata = record
        fdSQLColIndex: Integer;  {Corresponding element index in ISQLData}
        fdDataType: Short;
        fdDataScale: Short;
        fdNullable: Boolean;
        fdDataSize: Short;
        fdDataOfs: Integer;
        fdCodePage: TSystemCodePage;
        fdRefreshOnInsert: boolean;
        fdRefreshOnUpdate: boolean;
        fdObjOffset: Integer; {used for Blob and Array columns}
        fdAliasName: AnsiString;
      end;

      PDisplayBuffer = ^TDisplaybuffer;
      TDisplayBuffer = record
        dbBookmarkFlag: TBookmarkFlag;
        dbBookmarkData: array [1..sizeof(TIBRecordNumber)] of Byte;
        dbBuffer: PByte;
        dbCalcFields: PByte;
      end;

      PRecordHeader = ^TRecordHeader;
      TRecordHeader = record
        rhUpdateStatus: TUpdateStatus;
      end;

      TColumnMetadataArray = array of TColumnMetadata;

      TRegisteredQuery = record
        stmt: IStatement;
        ParamMap: array of integer;
        UseOldValue: array of boolean;
        ColMap: array of integer;  {return values}
        OnValuesReturned: TOnValuesReturned;
      end;

  strict private
    FRecordBufferSize: Integer;            {Calculated size in bytes for each record buffer}
    FRecordCount: Integer;                 {No. of records held in buffer pool. Total in dataset with Cursor.IsEof}
    FColumnMetaData: TColumnMetadataArray; {Metadata extracted from cursor + per column info.
                                                Note: only includes columns required i.e. there is
                                                a corresponding field for the column or is the DBKey}
    FColumnCount: integer;                 {size of metadata array}
    FCalcFieldsSize: integer;              {size in bytes of calculated fields buffer}
    FBlobFieldCount: Longint;              {Number of blob fields in each record}
    FBlobStreamList: TList;                {Keeps track of TIBBlobStream objects created}
    FArrayList: TList;                     {Keeps track of TIBArry objects created}
    FArrayFieldCount: integer;             {Number of array fields in each record}
    FDBKeyFieldColumn: integer;            {FColumnMetadata index of DBKey with alias sDBKeyAIias}
    FFieldNo2ColumnMap: array of integer;  {TField.FieldNo to FColumnMetadata index map}
    FNullColBitmapOffset: integer;         {start of NullColumn Bitmap in each record buffer}
    FRefreshRequiredBitmapOffset: integer; {start of Refresh Requried Bitmap in each record buffer}
    FRefreshRequiredSize: integer;         {number of bytes in RefreshRequired bitmap}
    FCursor: IResultSet;                   {The Cursor}
    FDefaultTZDate: TDateTime;             {Default Time Zone time}
    FName: string;                         {Local cursor name - set by creator}
    FRegisteredQueries: array[TRegisteredQueryTypes] of TRegisteredQuery; {cached query info}
    FDataset: TDataSet;

    function GetSQLParams : ISQLParams;
    procedure SetupBufferStructure(metadata: IMetadata; aFields: TFields);
    procedure ClearBlobCache;
    procedure ClearArrayCache;
    procedure CopyCursorDataToBuffer(QryResults: IResults; QryIndex, ColIndex: integer;
      destBuff: PByte);
    function InternalGetIsNull(Buff: PByte; ColIndex: integer): boolean;
    procedure InternalSetIsNull(Buff: PByte; ColIndex: integer; IsNull: boolean);
    procedure SaveBlobsAndArrays(Buff: PByte);
    function NormaliseParamName(aName: AnsiString; var UseOldValue: boolean): AnsiString;
    procedure ClearRegisteredQueries;
    procedure SetParamValue(Buff: PByte; colIndex: integer; Param: ISQLParam);
  protected
    FCurrentRecord: PByte;
    FCurrentRecordStatus: (csBOF, csRowBuffer, csEOF);
    FSaveBufferSize: integer;
    FEditState: (esBrowse, esEdit, esInsert);
    function CalcRecordHdrSize: integer; virtual;
    procedure ClearRowCache(aBuffer: PByte);
    function ColIndexByName(aName: AnsiString; caseSensitive: boolean=false): integer;
    procedure FetchCurrentRecord(destBuffer: PByte);
    procedure FieldChanged(aBuffer: PByte; aField: TField); virtual;
    function GetBuffer(aBufID: TRecordBuffer): PByte; inline;
    procedure SetBuffer(aBufID: TRecordBuffer; aBuffer: PByte); inline;
    function GetCalcFields(aBufID: TRecordBuffer): PByte; inline;
    function GetOldBufferFor(aBuffer: PByte): PByte; virtual; abstract;
    function FieldNo2ColumnIndex(aField: TField): integer; inline;
    function InternalAllocRecordBuffer: PByte; virtual; abstract;
    procedure InternalFreeRecordBuffer(aBuffer: PByte); virtual; abstract;
    function InternalGetRecNo(aBuffer: PByte): TIBRecordNumber; virtual; abstract;
    procedure InternalDelete(aBufID: TRecordBuffer); virtual; abstract;
    procedure InternalUnDelete(aBuffer: PByte); virtual; abstract;
    function InternalGetUpdateStatus(aBuffer: PByte): TUpdateStatus; inline;
    procedure InternalSetUpdateStatus(aBuffer: PByte; status: TUpdateStatus); inline;
    procedure SetRefreshRequired(Buff: PByte; ColIndex: integer; RefreshRequired: boolean);
    procedure SetUpdateStatus(aBufID: TRecordBuffer; status: TUpdateStatus);
    procedure Reset; virtual;
    function FetchNext: boolean;
  protected
    property Buffers[index: TRecordBuffer]:PByte read GetBuffer;
    property Cursor: IResultSet read FCursor;
    property ColumnMetaData: TColumnMetadataArray read FColumnMetaData;
  public
    constructor Create(aDataset: TDataset; aName: string; aCursor: IResultSet; aFields: TFields;
        aCalcFieldsSize: integer; aDefaultTZDate: TDateTime);
    destructor Destroy; override;

    {TDataset Interface}
    function AllocRecordBuffer: TRecordBuffer;
    procedure FreeRecordBuffer(var Buffer: TRecordBuffer);
    procedure SetCurrentRecord(aBufID: TRecordBuffer);
    function CreateBlobStream(aBufID: TRecordBuffer; Field: TField; Mode: TBlobStreamMode): TStream;  virtual;
    function GetArray(aBufID: TRecordBuffer; Field: TField): IArray;
    procedure SetArrayIntf(aBufID: TRecordBuffer; AnArray: IArray; Field: TField);
    function GetRecDBkey(aBufID: TRecordBuffer): TIBDBKey;
    function GetFieldData(aBufID: TRecordBuffer; field: TField; outBuffer: PByte): boolean;
    procedure SetFieldData(aBufID: TRecordBuffer; field: TField; inBuffer: PByte);
    procedure SetSQLParams(aBufID: TRecordBuffer; params: ISQLParams);
    procedure UpdateRecordFromQuery(aBufID: TRecordBuffer; QryResults: IResults);
    function NeedRefresh(aBufID: TRecordBuffer): boolean;
    function GetBookmarkFlag(aBufID: TRecordBuffer): TBookmarkFlag;
    procedure SetBookmarkFlag(aBufID: TRecordBuffer; aBookmarkFlag: TBookmarkFlag);
    procedure SetBookmarkData(aBufID: TRecordBuffer; RecNo: TIBRecordNumber); overload;
    procedure GetBookmarkData(Buffer: TRecordBuffer; Data: Pointer);
    procedure SetBookmarkData(Buffer: TRecordBuffer; Data: Pointer); overload;
    function GetBookmarkSize: integer;
    function GetRecordSize: word;
    function GetCurrentRecNo: TIBRecordNumber;
    procedure SwapDataBuffer(buf1, buf2: TRecordBuffer);
    function GetAliasName(FieldNo: integer): AnsiString;
    procedure InitRecord(aBufID: TRecordBuffer); virtual;
    function AtBOF: boolean;
    function AtEOF: boolean;
    function CursorAtEOF: boolean;
    procedure Delete(aBufID: TRecordBuffer);
    procedure UnDelete(aBufID: TRecordBuffer);
    function GetUpdateStatus(aBufID: TRecordBuffer): TUpdateStatus;
    procedure ClearCalcFields(aBufID: TRecordBuffer);
    procedure SetCursor(aCursor: IResultSet);
    procedure RegisterQuery(qryType : TRegisteredQueryTypes; qry : IStatement;
       OnValuesReturnedProc : TOnValuesReturned);
    procedure ExecRegisteredQuery(qryType : TRegisteredQueryTypes; aBufID: TRecordBuffer;
       var SelectCount, InsertCount, UpdateCount, DeleteCount: integer);
    function HasRegisteredQuery(qryType : TRegisteredQueryTypes): boolean;
  public
    property RecordBufferSize: integer read FRecordBufferSize;
    property ColumnCount: integer read FColumnCount;
    property RecordCount: integer read FRecordCount;
    property CalcFieldsSize: integer read FCalcFieldsSize;
    property BlobFieldCount: integer read FBlobFieldCount;
    property ArrayFieldCount: integer read FArrayFieldCount;
    property Name: string read FName;
    property Dataset: TDataset read FDataset;
    property Params: ISQLParams read GetSQLParams;
  end;

  { TIBEditableCursor adds the means the save a copy of the current buffer during
    a row edit and to restore it later. This may either be a single save buffer
    or, if cached updates are enabled, a save buffer allocated from the old buffer pool.}

  TIBEditableCursor = class(TIBSelectCursor)
  private
    const OldBuffersPerBlock = 1024;
    type
      PLocalHeader = ^TLocalHeader;
      TLocalHeader = record
        lhOldBuffer: PByte;
      end;
  strict private
    FApplyUpdates: TUpdatesIterator;
    FSaveBuffer: PByte;
    FOldBufferCache: TIBOldBufferPool;
    FCachedUpdatesEnabled: boolean;
    FLocalHdrOffset: integer;
    procedure ApplyUpdatesIterator(status: TCachedUpdateStatus; DataBuffer, OldBuffer: PByte);
  protected
    FSavedRecNo: TIBRecordNumber; {record number of saved buffer if any}
    function CalcRecordHdrSize: integer override;
    procedure CancelBlobAndArrayChanges(aBuffer: PByte);
    procedure CopyBuffers(src, dest: PByte); inline;
    procedure DoCancelUpdates; virtual; abstract;
    procedure DoOnInserted(aBuffer: PByte);
    procedure FieldChanged(aBuffer: PByte; aField: TField); override;
    function GetOldBufferFor(aBuffer: PByte): PByte; override;
    procedure InitCachedUpdates; virtual;
    procedure ReleaseSaveBuffer(aBufID: TRecordBuffer; UpdateStatus: TCachedUpdateStatus);
    property OldBufferCache: TIBOldBufferPool read FOldBufferCache;
    procedure InternalDelete(aBufID: TRecordBuffer); override;
    procedure InternalUnDelete(aBuffer: PByte); override;
    procedure InternalSetOldBuffer(aBuffer, OldBuffer: PByte); inline;
    procedure Reset; override;
  public
    constructor Create(aDataset: TDataset; aName: string; aCursor: IResultSet; aFields: TFields;
      aCalcFieldsSize: integer; aDefaultTZDate: TDateTime; CachedUpdates: boolean);
    destructor Destroy; override;
    procedure EditingDone(aBufID: TRecordBuffer; UpdateStatus: TCachedUpdateStatus); virtual;
    procedure EditBuffer(aBufID: TRecordBuffer);
    function GetRecNo(aBufID: TRecordBuffer): TIBRecordNumber; virtual; abstract;
    procedure CancelChanges(aBufID: TRecordBuffer);
    procedure ApplyUpdates(iterator: TUpdatesIterator);
    procedure CancelUpdates;
    function UpdatesPending: boolean;
    function GetCachedUpdatesEnabled:boolean;
    function GetCachedUpdateStatus(aBufID: TRecordBuffer): TCachedUpdateStatus;
  end;

  {
    TIBUniDirectionalCursor provides a simple forwards only cursor with edit support.

  }

  TIBUniDirectionalCursor = class(TIBEditableCursor, IIBCursor)
  private const
    DataBuffersPerBlock = 1024;
  private type
    PUniDirRecordHdr = ^TUniDirRecordHdr;
    TUniDirRecordHdr = record
      rdRecNo: TIBRecordNumber;
    end;

  private
    FRecordCount: TIBRecordNumber;
    FInserting: boolean;
    FInsertedRecords: integer;
    FDeletedRecords: integer;
    FDataBufferCache: TIBSimpleBufferPool;
    FUniDirHdrOffset: integer;
    procedure InternalSetRecNo(aBuffer: PByte; recno: TIBRecordNumber); inline;
  protected
    function CalcRecordHdrSize: integer; override;
    procedure DoCancelUpdates; override;
    function InternalAllocRecordBuffer: PByte; override;
    procedure InternalFreeRecordBuffer(aBuffer: PByte); override;
    function InternalGetRecNo(aBuffer : PByte) : TIBRecordNumber; override;
    procedure InitCachedUpdates; override;
    procedure InternalDelete(aBufID: TRecordBuffer); override;
    procedure InternalUnDelete(aBuffer: PByte); override;
    procedure Reset; override;
 public
    destructor Destroy; override;
    function GetRecord(aBufID: TRecordBuffer; GetMode: TGetMode;
                       DoCheck: Boolean): TGetResult;
    function GetRecNo(aBufID: TRecordBuffer): TIBRecordNumber; override;
    function GetRecordCount: TIBRecordNumber;
    procedure GotoFirst;
    procedure GotoLast;
    function GotoRecordNumber(RecNo: TIBRecordNumber): boolean;
    procedure EditingDone(aBufID: TRecordBuffer; UpdateStatus: TCachedUpdateStatus); override;
    procedure InsertBefore(aBufID: TRecordBuffer);
    procedure Append(aBufID: TRecordBuffer);
     function GetInsertedRecords: integer;
    function GetDeletedRecords: integer;
    procedure InitRecord(aBufID: TRecordBuffer); override;
  end;

  {TIBBiDirectionalCursor provides a buffered dataset that can be scrolled in either direction}

  TIBBiDirectionalCursor = class(TIBEditableCursor,IIBCursor)
  private
    FBufferPool: TIBBufferPool;
    procedure CancelUpdatesIterator(status: TCachedUpdateStatus; DataBuffer, OldBuffer: PByte);
    function NewBuffer: PByte; inline;
  protected
    procedure DoCancelUpdates; override;
    function InternalAllocRecordBuffer: PByte; override;
    procedure InternalFreeRecordBuffer(aBuffer: PByte); override;
    function InternalGetRecNo(aBuffer: PByte): TIBRecordNumber; override;
    procedure InternalDelete(aBufID: TRecordBuffer); override;
    procedure InternalUnDelete(aBuffer: PByte); override;
    procedure Reset; override;
  public
    constructor Create(aDataset: TDataset; aName: string; aCursor: IResultSet; aFields: TFields;
      aCalcFieldsSize: integer;
      aDefaultTZDate: TDateTime;  CachedUpdates: boolean;
      aBuffersPerBlock, aFirstBlockBuffers: integer);
    destructor Destroy; override;
    function GetRecord(aBufID: TRecordBuffer; GetMode: TGetMode;
                     DoCheck: Boolean): TGetResult;
    function GetRecNo(aBufID: TRecordBuffer): TIBRecordNumber; override;
    procedure GotoFirst;
    procedure GotoLast;
    function GotoRecordNumber(RecNo: TIBRecordNumber): boolean;
    function GetRecordCount: TIBRecordNumber;
    procedure InsertBefore(aBufID: TRecordBuffer);
    procedure Append(aBufID: TRecordBuffer);
    function GetInsertedRecords: integer;
    function GetDeletedRecords: integer;
    procedure InitRecord(aBufID: TRecordBuffer);  override;
  end;

implementation

uses IBMessages, IBCustomDataSet, IBInternals, IBSQLMonitor;

type
  THackedField = class(TField); {Used to access to protected method TField.DataChange}

{ TIBEditableCursor }

procedure TIBEditableCursor.ApplyUpdatesIterator(status: TCachedUpdateStatus;
  DataBuffer, OldBuffer: PByte);
var DisplayBuffer: TDisplayBuffer;
    RecordSkipped: boolean;
    curOldBuffer: PByte;
begin
  FSavedRecNo :=  InternalGetRecNo(DataBuffer);
  DisplayBuffer.dbBookmarkFlag := bfCurrent;
  DisplayBuffer.dbBuffer := DataBuffer;
  DisplayBuffer.dbCalcFields := nil;
  curOldBuffer := GetOldBufferFor(DataBuffer);
  InternalSetOldBuffer(DataBuffer,OldBuffer); {May be different if more than one edit}
  try
    RecordSkipped := false;
    FApplyUpdates(status,TRecordBuffer(@DisplayBuffer),RecordSkipped);
    if not RecordSkipped then
      FOldBufferCache.SetStatus(OldBuffer,cusUnModified);
  finally
    FSavedRecNo := 0;
    InternalSetOldBuffer(DataBuffer,curOldBuffer);
  end;
end;

function TIBEditableCursor.CalcRecordHdrSize: integer;
begin
  Result := inherited CalcRecordHdrSize;
  if FCachedUpdatesEnabled then
  begin
    FLocalHdrOffset := Result;
    Inc(Result,sizeof(TLocalHeader));
  end;
end;

procedure TIBEditableCursor.CancelBlobAndArrayChanges(aBuffer: PByte);
var i: integer;
    pda: PIBArray;
begin
  for i := 0 to ColumnCount - 1 do
  with ColumnMetaData[i] do
    case fdDataType of
      SQL_BLOB:
        PIBBlobStream(aBuffer + fdObjOffset)^ := nil;
      SQL_ARRAY:
        begin
          pda := PIBArray(aBuffer + fdObjOffset);
          if pda^ <> nil then
          begin
            pda^.ArrayIntf.CancelChanges;
            pda^ := nil;
          end;
        end;
    end;
 end;

procedure TIBEditableCursor.CopyBuffers(src, dest: PByte);
begin
  Move(src^,dest^,FSaveBufferSize);
end;

procedure TIBEditableCursor.DoOnInserted(aBuffer: PByte);
var OldBuffer: PByte;
    i: integer;
begin
  if FCachedUpdatesEnabled then
  begin
    OldBuffer := FOldBufferCache.Append(InternalGetRecNo(aBuffer),aBuffer);
    FOldBufferCache.SetStatus(OldBuffer,cusInserted);
  end;
  FEditState := esInsert;
  for i := 0 to ColumnCount - 1 do
    with ColumnMetaData[i] do
     if fdRefreshOnInsert then
       SetRefreshRequired(aBuffer,i,true);
end;

procedure TIBEditableCursor.FieldChanged(aBuffer : PByte; aField : TField);
var I: integer;
begin
  inherited FieldChanged(aBuffer, aField);

  if InternalGetUpdateStatus(aBuffer) = usUnModified then
    InternalSetUpdateStatus(aBuffer,usModified);
end;

function TIBEditableCursor.GetOldBufferFor(aBuffer: PByte): PByte;
begin
  if InternalGetRecNo(aBuffer) = FSavedRecNo then
    if FCachedUpdatesEnabled then
      Result := PLocalHeader(aBuffer + FLocalHdrOffset)^.lhOldBuffer
    else
      Result := FSaveBuffer
  else
    Result := nil;
end;

procedure TIBEditableCursor.InitCachedUpdates;
begin
  if FOldBufferCache = nil then
    FOldBufferCache := TIBOldBufferPool.Create(Name + ': Old Buffer Cache', FSaveBufferSize,
                                               OldBuffersPerBlock, OldBuffersPerBlock);
end;

  constructor TIBEditableCursor.Create(aDataset : TDataset; aName : string;
   aCursor : IResultSet; aFields : TFields; aCalcFieldsSize : integer;
   aDefaultTZDate : TDateTime; CachedUpdates : boolean);
begin
  FCachedUpdatesEnabled := CachedUpdates;
  inherited Create(aDataset, aName, aCursor,aFields, aCalcFieldsSize, aDefaultTZDate);
  if FCachedUpdatesEnabled then
    InitCachedUpdates
  else
  begin
    FSaveBuffer := GetMem(FSaveBufferSize);
    if FSaveBuffer = nil then
       OutOfMemoryError;
  end;
  FEditState := esBrowse;
end;

destructor TIBEditableCursor.Destroy;
begin
  if FSaveBuffer <> nil then
    FreeMem(FSaveBuffer);
  if FOldBufferCache <> nil then
    FOldBufferCache.Free;
 inherited Destroy;
end;

procedure TIBEditableCursor.EditingDone(aBufID: TRecordBuffer;
  UpdateStatus: TCachedUpdateStatus);
begin
  if FSavedRecNo <> 0 then
    ReleaseSaveBuffer(aBufID, UpdateStatus);
  FEditState := esBrowse;
end;

procedure TIBEditableCursor.EditBuffer(aBufID: TRecordBuffer);
var Buff: PByte;
    OldBuffer: PByte;
    i: integer;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);

  if FSavedRecNo <> 0 then
    IBError(ibxeSaveBufferNotReleased,[InternalGetRecNo(Buff),FSavedRecNo]);

  if FCachedUpdatesEnabled then
    OldBuffer := FOldBufferCache.Append(InternalGetRecNo(Buff),Buff)
  else
    OldBuffer := FSaveBuffer;

  InternalSetOldBuffer(Buff,OldBuffer);
  CopyBuffers(Buff,OldBuffer);
  FSavedRecNo := InternalGetRecNo(Buff);
  FEditState := esEdit;
  for i := 0 to ColumnCount - 1 do
    with ColumnMetaData[i] do
      if fdRefreshOnUpdate then
        SetRefreshRequired(Buff,i,true);
end;

procedure TIBEditableCursor.CancelChanges(aBufID: TRecordBuffer);
var Buff: PByte;
    OldBuffer: PByte;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);

  case FEditState of
  esInsert:
    InternalDelete(aBufID);

  esEdit:
    begin
      if InternalGetRecNo(Buff) <> FSavedRecNo then
        IBError(ibxeUnableToRestore,[InternalGetRecNo(Buff),FSavedRecNo]);

      CancelBlobAndArrayChanges(Buff);
      OldBuffer := GetOldBufferFor(Buff);
      CopyBuffers(OldBuffer,Buff);
      if FCachedUpdatesEnabled then
        FOldBufferCache.SetStatus(OldBuffer,cusUnModified);
      InternalSetOldBuffer(Buff,nil);
      FSavedRecNo := 0;
    end;
  end;
  FEditState := esBrowse;
end;

procedure TIBEditableCursor.ReleaseSaveBuffer(aBufID: TRecordBuffer;
  UpdateStatus: TCachedUpdateStatus);
var Buff: PByte;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);

  if FSavedRecNo <> InternalGetRecNo(Buff) then
    IBError(ibxeUnableToReleaseSaveBuffer,[InternalGetRecNo(Buff),FSavedRecNo]);

  if FCachedUpdatesEnabled then
    FOldBufferCache.SetStatus(GetOldBufferFor(Buff),UpdateStatus);
  InternalSetOldBuffer(Buff,nil);
  FSavedRecNo := 0;
end;

procedure TIBEditableCursor.InternalDelete(aBufID: TRecordBuffer);
begin
  SetUpdateStatus(aBufID,usDeleted);
  if FCachedUpdatesEnabled then
  begin
    if FSavedRecNo = 0 then
      EditBuffer(aBufID);
    if GetUpdateStatus(aBufID) = usInserted then
      EditingDone(aBufID,cusUninserted)
    else
      EditingDone(aBufID,cusDeleted);
  end;
end;

procedure TIBEditableCursor.InternalUnDelete(aBuffer: PByte);
var OldBuffer: PByte;
begin
  if not FCachedUpdatesEnabled then
    IBError(ibxeCannotUnDelete,[]);

  OldBuffer := GetOldBufferFor(aBuffer);

  case FOldBufferCache.GetStatus(OldBuffer) of
  cusUninserted:
     FOldBufferCache.SetStatus(OldBuffer,cusInserted);

   cusDeleted:
   if InternalGetUpdateStatus(aBuffer) = usDeleted then
   begin
     FOldBufferCache.SetStatus(OldBuffer,cusUnmodified);
     InternalSetUpdateStatus(aBuffer,usUnmodified);
   end;
  end;
end;

procedure TIBEditableCursor.InternalSetOldBuffer(aBuffer, OldBuffer: PByte);
begin
  if FCachedUpdatesEnabled then
    PLocalHeader(aBuffer + FLocalHdrOffset)^.lhOldBuffer := OldBuffer;
end;

procedure TIBEditableCursor.Reset;
begin
  inherited Reset;
  if FOldBufferCache <> nil then
    FOldBufferCache.Clear;
  FSavedRecNo := 0;
end;

procedure TIBEditableCursor.ApplyUpdates(iterator: TUpdatesIterator);
begin
  if FSavedRecNo <> 0 then
    IBError(ibxeSaveBufferNotReleased,[0,FSavedRecNo]);

  if not FCachedUpdatesEnabled or not UpdatesPending then  Exit;

  FCachedUpdatesEnabled := false;
  try
    FApplyUpdates := iterator;
    FSavedRecNo := 0;
    FOldBufferCache.ForwardIterator(ApplyUpdatesIterator);
    if FOldBufferCache.ModifiedRecords = 0 then
       FOldBufferCache.Clear;
  finally
    FCachedUpdatesEnabled := true;
  end;
end;

procedure TIBEditableCursor.CancelUpdates;
begin
  if FSavedRecNo <> 0 then
    IBError(ibxeSaveBufferNotReleased,[0,FSavedRecNo]);

  if not FCachedUpdatesEnabled or not UpdatesPending then  Exit;

  FCachedUpdatesEnabled := false;
  try
    FSavedRecNo := 0;
    DoCancelUpdates;
    FOldBufferCache.Clear;
  finally
    FCachedUpdatesEnabled := true;
  end;
end;

function TIBEditableCursor.UpdatesPending: boolean;
begin
  Result := FOldBufferCache.RecordCount > 0;
end;

function TIBEditableCursor.GetCachedUpdatesEnabled: boolean;
begin
  Result := FCachedUpdatesEnabled;
end;

function TIBEditableCursor.GetCachedUpdateStatus(aBufID: TRecordBuffer
  ): TCachedUpdateStatus;
begin
  if GetCachedUpdatesEnabled then
    Result := FOldBufferCache.GetStatus(GetRecNo(aBufID))
  else
    Result := cusUnModified;
end;

{ TIBBiDirectionalCursor }

procedure TIBBiDirectionalCursor.CancelUpdatesIterator(
  status: TCachedUpdateStatus; DataBuffer, OldBuffer: PByte);
var curOldBuffer: PByte;
begin
  curOldBuffer := GetOldBufferFor(DataBuffer);
  InternalSetOldBuffer(DataBuffer,OldBuffer);
  FSavedRecNo :=  InternalGetRecNo(DataBuffer);
  try
    case status of
      cusInserted:
        FBufferPool.Delete(DataBuffer);

      cusDeleted:
        FBufferPool.UnDelete(DataBuffer);

      cusModified:
        CopyBuffers(OldBuffer,DataBuffer);
    end;
  finally
    InternalSetOldBuffer(DataBuffer,curOldBuffer);
    FSavedRecNo := 0;
  end;
end;

function TIBBiDirectionalCursor.NewBuffer: PByte;
begin
  Result := FBufferPool.Append;
end;

procedure TIBBiDirectionalCursor.DoCancelUpdates;
begin
  OldBufferCache.BackwardsIterator(CancelUpdatesIterator);
  GotoLast;
end;

function TIBBiDirectionalCursor.InternalGetRecNo(aBuffer: PByte): TIBRecordNumber;
begin
  Result := FBufferPool.GetRecNo(aBuffer);
end;

procedure TIBBiDirectionalCursor.InternalDelete(aBufID: TRecordBuffer);
begin
  inherited InternalDelete(aBufID);
  SetCurrentRecord(aBufID);
  case FCurrentRecordStatus of
  csBOF:
    IBError(ibxeDeleteAtBOF,[]);
  csEOF:
    IBError(ibxeDeleteBeyondEOF,[]);
  csRowBuffer:
    begin
      {$ifdef PrintBuf}
      writeln('Delete RecNo ',GetRecNo(aBufID));
      {$endif}
      FCurrentRecord := FBufferPool.Delete(FCurrentRecord);
      {$ifdef PrintBuf}
      FBufferPool.PrintBufferList;
      {$endif}
      if FCurrentRecord = nil then
        FCurrentRecordStatus := csBOF;
    end;
  end;
end;

procedure TIBBiDirectionalCursor.InternalUnDelete(aBuffer: PByte);
begin
  inherited InternalUnDelete(aBuffer);
  FBufferPool.UnDelete(aBuffer);
end;

procedure TIBBiDirectionalCursor.Reset;
begin
  inherited Reset;
  if FBufferPool <> nil then
    FBufferPool.Clear;
end;

function TIBBiDirectionalCursor.InternalAllocRecordBuffer: PByte;
begin
  Result := nil; {see GetRecord}
end;

procedure TIBBiDirectionalCursor.InternalFreeRecordBuffer(aBuffer: PByte);
begin
  // Do nothing
end;

  constructor TIBBiDirectionalCursor.Create(aDataset : TDataset; aName : string;
   aCursor : IResultSet; aFields : TFields; aCalcFieldsSize : integer;
   aDefaultTZDate : TDateTime; CachedUpdates : boolean; aBuffersPerBlock,
   aFirstBlockBuffers : integer);
begin
  inherited Create(aDataset,aName,aCursor,aFields, aCalcFieldsSize, aDefaultTZDate,CachedUpdates);
  FBufferPool := TIBBufferPool.Create(aName+ ': BiDirectional record cache',
                      RecordBufferSize,aBuffersPerBlock, aFirstBlockBuffers);
end;

destructor TIBBiDirectionalCursor.Destroy;
begin
  if FBufferPool <> nil then
    FBufferPool.Free;
  inherited Destroy;
end;

function TIBBiDirectionalCursor.GetRecord(aBufID: TRecordBuffer;
  GetMode: TGetMode; DoCheck: Boolean): TGetResult;

  function ReadNext: TGetResult;
  begin
    if not Cursor.IsEof and FetchNext then
    begin
      FCurrentRecord :=  NewBuffer;
      FetchCurrentRecord(FCurrentRecord);
      FCurrentRecordStatus := csRowBuffer;
      Result := grOK;
    end
    else
    begin
      FCurrentRecordStatus := csEOF;
      Result := grEOF;
    end;
  end;

begin
  Result := grError;
  case GetMode of
  gmPrior:
    case FCurrentRecordStatus of
    csBOF:
      Result := grBOF;
    csRowBuffer:
      begin
        FCurrentRecord := FBufferPool.GetPriorBuffer(FCurrentRecord);
        if FCurrentRecord = nil then
        begin
          FCurrentRecordStatus := csBOF;
          Result := grBOF
        end
        else
          Result := grOK;
      end;
    csEOF:
      begin
        FCurrentRecord := FBufferPool.GetLast;
        if FCurrentRecord = nil then
          Result := grEOF
        else
        begin
          FCurrentRecordStatus := csRowBuffer;
          Result := grOK;
        end;
      end;
    end;

  gmCurrent:
    case FCurrentRecordStatus of
    csBOF:
      Result := grBOF;
    csRowBuffer:
      Result := grOK;
    csEOF:
      Result := grEOF;
    end;

  gmNext:
    case FCurrentRecordStatus of
    csBOF:
      begin
        FCurrentRecord := FBufferPool.GetFirst;
        if (FCurrentRecord = nil) then
          Result := ReadNext
        else
        begin
          FCurrentRecordStatus := csRowBuffer;
          Result := grOK;
        end;
      end;
    csRowBuffer:
      begin
        FCurrentRecord := FBufferPool.GetNextBuffer(FCurrentRecord);
        if (FCurrentRecord = nil) then
          Result := ReadNext
        else
          Result := grOK;
      end;
    csEOF:
      Result := grEOF;
    end;
  end;

  case Result of
  grOK:
    begin
      SetBuffer(aBufID,FCurrentRecord);
      SetBookmarkFlag(aBufID,bfCurrent);
    end;
  grBOF:
    begin
      SetBuffer(aBufID,nil);
      SetBookmarkFlag(aBufID,bfBOF);
    end;
  grEOF:
    begin
      SetBuffer(aBufID,nil);
      SetBookmarkFlag(aBufID,bfEOF);
    end;
  end;
{  if FCurrentRecord <> nil then
    writeln('Get Record request ',GetMode,' Returns Rec No ',InternalGetRecNo(FCurrentRecord),' Status = ',
      FBufferPool.GetRecordStatus(FCurrentRecord))
  else
    writeln('Get Record request ',GetMode,' Returns ',Result); }
  SetBookmarkData(aBufID,InternalGetRecNo(FCurrentRecord));
end;

function TIBBiDirectionalCursor.GetRecNo(aBufID: TRecordBuffer): TIBRecordNumber;
var Buff: PByte;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    Result := 0
  else
    Result := InternalGetRecNo(Buff);
end;

procedure TIBBiDirectionalCursor.GotoFirst;
begin
  FCurrentRecord := nil;
  FCurrentRecordStatus := csBOF;
end;

procedure TIBBiDirectionalCursor.GotoLast;
begin
  FCurrentRecord := FBufferPool.GetLast;
  if (FCurrentRecord <> nil) or not Cursor.IsEOF then
  begin
    FCurrentRecordStatus := csRowBuffer;
    if not Cursor.IsEof then
    while FetchNext do
    begin
      FCurrentRecord := NewBuffer;
      FetchCurrentRecord(FCurrentRecord);
    end;
  end;
  FCurrentRecord := nil;
  FCurrentRecordStatus := csEOF;
end;

function TIBBiDirectionalCursor.GotoRecordNumber(RecNo: TIBRecordNumber): boolean;
begin
  if FBufferPool.GetRecordCount >= RecNo then
    FCurrentRecord := FBufferPool.GetBuffer(RecNo)
  else
  begin
    FCurrentRecord := FBufferPool.GetLast;
    if not Cursor.IsEOF then
    while (FBufferPool.GetRecNo(FCurrentRecord) < RecNo) and FetchNext do
    begin
      FCurrentRecord := NewBuffer;
      FetchCurrentRecord(FCurrentRecord);
    end;
  end;
  Result :=  (FBufferPool.GetRecNo(FCurrentRecord) = RecNo);
end;

function TIBBiDirectionalCursor.GetRecordCount: TIBRecordNumber;
begin
  Result := FBufferPool.GetRecordCount - FBufferPool.DeletedRecords;
end;


procedure TIBBiDirectionalCursor.InsertBefore(aBufID: TRecordBuffer);
var RecNo: TIBRecordNumber;
begin
  GetBookmarkData(aBufID,@RecNo);
  if RecNo = 0 then
    GotoFirst
  else
    GotoRecordNumber(RecNo);
  {$ifdef PrintBuf}
  writeln('Insert Before Record = ',RecNo);
  {$endif}
  case FCurrentRecordStatus of
  csBOF:
    FCurrentRecord := FBufferPool.InsertBefore(FBufferPool.GetFirst);
  csRowBuffer:
    FCurrentRecord := FBufferPool.InsertBefore(FCurrentRecord);
  csEOF:
    FCurrentRecord := NewBuffer;
  end;
  InternalSetUpdateStatus(FCurrentRecord,usInserted);
  DoOnInserted(FCurrentRecord);
  SetBuffer(aBufID, FCurrentRecord);
  FCurrentRecordStatus := csRowBuffer;
  {$ifdef PrintBuf}
  FBufferPool.PrintBufferList;
  {$endif}
end;

procedure TIBBiDirectionalCursor.Append(aBufID: TRecordBuffer);
begin
  GotoLast;
  {$ifdef PrintBuf}
  writeln('Append After Record = ',GetRecNo(aBufID));
  {$endif}
  if FCurrentRecordStatus = csEOF then
    FCurrentRecord := FBufferPool.Append
  else
    FCurrentRecord := FBufferPool.InsertAfter(FCurrentRecord);
  InternalSetUpdateStatus(FCurrentRecord,usInserted);
  DoOnInserted(FCurrentRecord);
  SetBuffer(aBufID,FCurrentRecord);
  FCurrentRecordStatus := csRowBuffer;
  {$ifdef PrintBuf}
  FBufferPool.PrintBufferList;
  {$endif}
end;

function TIBBiDirectionalCursor.GetInsertedRecords: integer;
begin
  Result := FBufferPool.InsertedRecords;
end;

function TIBBiDirectionalCursor.GetDeletedRecords: integer;
begin
  Result := FBufferPool.DeletedRecords;
end;

procedure TIBBiDirectionalCursor.InitRecord(aBufID: TRecordBuffer);
begin
  inherited InitRecord(aBufID);
  if aBufID <> nil then
    PDisplayBuffer(aBufID)^.dbBuffer := nil;
end;

{ TIBUniDirectionalCursor }

function TIBUniDirectionalCursor.InternalGetRecNo(aBuffer: PByte) : TIBRecordNumber;
begin
  if aBuffer = nil then
    Result := 0
  else
    Result := PUniDirRecordHdr(aBuffer+ FUniDirHdrOffset)^.rdRecNo;
 end;

procedure TIBUniDirectionalCursor.InitCachedUpdates;
begin
  inherited InitCachedUpdates;
  if FDataBufferCache = nil then
    FDataBufferCache := TIBSimpleBufferPool.Create(Name + ': Data Buffer Cacne',
           FSaveBufferSize,
           DataBuffersPerBlock,DataBuffersPerBlock);
end;

destructor TIBUniDirectionalCursor.Destroy;
begin
  if FDataBufferCache <> nil then
    FDataBufferCache.Free;
  inherited Destroy;
end;

procedure TIBUniDirectionalCursor.InternalSetRecNo(aBuffer: PByte;
  recno: TIBRecordNumber);
begin
  PUniDirRecordHdr(aBuffer + FUniDirHdrOffset)^.rdRecNo := recno;
end;

function TIBUniDirectionalCursor.CalcRecordHdrSize: integer;
begin
  Result := inherited CalcRecordHdrSize;
  FUniDirHdrOffset := Result;
  Inc(Result,sizeof(TUniDirRecordHdr));
end;

procedure TIBUniDirectionalCursor.DoCancelUpdates;
begin
  if FDataBufferCache <> nil then
    FDataBufferCache.Clear;
end;

function TIBUniDirectionalCursor.InternalAllocRecordBuffer: PByte;
begin
  Result :=  GetMem(RecordBufferSize);
  if Result = nil then
    OutOfMemoryError;
  FillChar(Result^,RecordBufferSize,0);
end;

procedure TIBUniDirectionalCursor.InternalFreeRecordBuffer(aBuffer: PByte);
begin
  if aBuffer <> nil then
    FreeMem(aBuffer);
end;

function TIBUniDirectionalCursor.GetRecord(aBufID: TRecordBuffer;
  GetMode: TGetMode; DoCheck: Boolean): TGetResult;
var Buff: PByte;

  function GetNext: TGetResult;
  begin
    if Cursor.IsEOF or not FetchNext then
       Result := grEOF
     else
     begin
       FetchCurrentRecord(Buff);
       Inc(FRecordCount);
       InternalSetRecNo(Buff,FRecordCount);
       FCurrentRecord := Buff;
       FCurrentRecordStatus := csRowBuffer;
       Result := grOK;
     end;
  end;

begin
  Result := grError;
  Buff := GetBuffer(aBufID);
  if Buff = nil then Exit;

  ClearRowCache(Buff);
  case GetMode of
  gmCurrent:
    begin
      case FCurrentRecordStatus of
      csBOF: ; {do nothing - returns grError}
      csEOF:
        Result := grEOF;
      csRowBuffer:
        begin
  {        if InternalGetDeleted(FCurrentRecord) then
            Result := GetNext
          else}
          if Buff <> FCurrentRecord then
          begin
            FetchCurrentRecord(Buff);
            InternalSetRecNo(Buff,FRecordCount);
            FCurrentRecord := Buff;
          end;
          Result := grOK;
        end;
      end;
    end;

    gmNext:
      begin
        case FCurrentRecordStatus of
        csEOF:
          Result := grEOF;
        csBOF, csRowBuffer:
          Result := GetNext;
        end;
      end;
   end;

  case Result of
  grOK:
      SetBookmarkFlag(aBufID,bfCurrent);
  grBOF:
      SetBookmarkFlag(aBufID,bfBOF);
  grEOF:
      SetBookmarkFlag(aBufID,bfEOF);
  end;

  SetBookmarkData(aBufID,InternalGetRecNo(FCurrentRecord));
end;

function TIBUniDirectionalCursor.GetRecNo(aBufID : TRecordBuffer) : TIBRecordNumber;
var Buff: PByte;
begin
  Result := 0;
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);
  Result := InternalGetRecNo(Buff);
end ;

function TIBUniDirectionalCursor.GetRecordCount: TIBRecordNumber;
begin
  Result := FRecordCount - FDeletedRecords;
end;

procedure TIBUniDirectionalCursor.GotoFirst;
begin
  if FCurrentRecordStatus <> csBOF then
    IBError(ibxeDataSetUniDirectional,[]);
end;

procedure TIBUniDirectionalCursor.GotoLast;
begin
  if not Cursor.IsEOF then
    while FetchNext do
      Inc(FRecordCount);
  FCurrentRecord := nil;
  FCurrentRecordStatus := csRowBuffer;
end;

function TIBUniDirectionalCursor.GotoRecordNumber(RecNo: TIBRecordNumber
  ): boolean;
begin
  if not Cursor.IsEOF then
  begin
    while (FRecordCount < RecNo) and FetchNext do
      Inc(FRecordCount);
    FCurrentRecord := nil;
    FCurrentRecordStatus := csRowBuffer;
  end;
  Result := FRecordCount = RecNo;
end;

procedure TIBUniDirectionalCursor.EditingDone(aBufID: TRecordBuffer;
  UpdateStatus: TCachedUpdateStatus);
var Buff: PByte;
    DataBuffer: PByte;
    OldBuffer: PByte;
begin
  if GetCachedUpdatesEnabled and (FSavedRecNo <> 0) then
  begin
    Buff := GetBuffer(aBufID);
    if Buff = nil then
      IBError(ibxeBufferNotSet, [nil]);

    OldBuffer := GetOldBufferFor(Buff);
    DataBuffer := FDataBufferCache.Append;
    CopyBuffers(Buff,DataBuffer); {cache current data buffer}
    OldBufferCache.SetDataBuffer(OldBuffer,DataBuffer);
  end;
  inherited EditingDone(aBufID, UpdateStatus);
  FInserting := false;
end;

procedure TIBUniDirectionalCursor.InsertBefore(aBufID: TRecordBuffer);
var Buff: PByte;
begin
  SetCurrentRecord(aBufID);

  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);
  Inc(FRecordCount);
  InternalSetRecNo(Buff,FRecordCount);
  FCurrentRecord := Buff;
  FCurrentRecordStatus := csRowBuffer;
  FInserting := true;
  Inc(FInsertedRecords);
  InternalSetUpdateStatus(FCurrentRecord,usInserted);
  DoOnInserted(FCurrentRecord);
end;

procedure TIBUniDirectionalCursor.Append(aBufID: TRecordBuffer);
var Buff: PByte;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);

  GotoLast;
  Inc(FRecordCount);
  InternalSetRecNo(Buff,FRecordCount);
  FCurrentRecord := Buff;
  FCurrentRecordStatus := csRowBuffer;
  FInserting := true;
  Inc(FInsertedRecords);
  InternalSetUpdateStatus(FCurrentRecord,usInserted);
  DoOnInserted(FCurrentRecord);
end;

procedure TIBUniDirectionalCursor.InternalDelete(aBufID: TRecordBuffer);
begin
  inherited InternalDelete(aBufID);
  SetCurrentRecord(aBufID);

  GetRecord(aBufID,gmNext,false);
  Inc(FDeletedRecords);
end;

procedure TIBUniDirectionalCursor.InternalUnDelete(aBuffer: PByte);
begin
  inherited InternalUnDelete(aBuffer);
  Dec(FDeletedRecords);
end;

procedure TIBUniDirectionalCursor.Reset;
begin
  inherited Reset;
  FRecordCount := 0;
  FInserting := false;
  FInsertedRecords := 0;
  FDeletedRecords := 0;
  if FDataBufferCache <> nil then
    FDataBufferCache.Clear;
end;

function TIBUniDirectionalCursor.GetInsertedRecords: integer;
begin
  Result := FInsertedRecords
end;

function TIBUniDirectionalCursor.GetDeletedRecords: integer;
begin
  Result := FDeletedRecords;
end;

procedure TIBUniDirectionalCursor.InitRecord(aBufID: TRecordBuffer);
var Buff: PByte;
begin
  inherited InitRecord(aBufID);
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);
  ClearRowCache(Buff);
  Fillchar(Buff^,RecordBufferSize,0);
  InternalSetUpdateStatus(Buff,usInserted);
end;


{ TIBSelectCursor.TIBArray }

procedure TIBSelectCursor.TIBArray.EventHandler(Sender: IArray;
  Reason: TArrayEventReason);
begin
  case Reason of
  arChanging:
    if FRecNo <> FField.Dataset.RecNo then
      IBError(ibxeNotCurrentArray,[nil]);

  arChanged:
    THackedField(FField).DataChanged;
  end;
end;

constructor TIBSelectCursor.TIBArray.Create(aField: TField; anArray: IArray);
begin
  inherited Create;
  FField := aField;
  FArray := anArray;
  FRecNo := FField.Dataset.RecNo;
  FArray.AddEventHandler(EventHandler);
end;

destructor TIBSelectCursor.TIBArray.Destroy;
begin
  FArray.RemoveEventHandler(EventHandler);
  inherited Destroy;
end;

{ TIBSelectCursor }

{
  A record buffer is structured into

  1. Space for each field's column data determined from the metadate datasize.
     Note: for VarChar the column data is sizeof(short) longer to allow for a length
     indicator.
  2. Buffer Header for per record local data
  3. a little endian bitmap giving each column's null status. 0 => null, 1 => not null
  4. Another bitmap to keep track of each colmn's refresh required status.
  5. Additional space for the blob and array caches,

  The Column Metadata and Field No. mapping is also established. The interesting
  metadata is copied from the IStatement into the FColumnMetadata dynamic array, and which
  also includes the SQL Column Index. This latter mapping is necessary because an
  IStatement column is ignored if it is not reference from the list of fields, or
  it's aliasname is not the IBX specical field sDBkeyAlias (used by TIBTable).

  Likewise a mapping between the Field.FieldNo (a 1 -based sequence nu. and the
  corresponding index into the 0 -based FColumnMetadata dynamic array. This is
  not just because of the different base, but because the use of IBX special field can
  result in and FColumnMetadata that is not linked to a TField.
}

procedure TIBSelectCursor.SetupBufferStructure(metadata : IMetadata;
  aFields : TFields);
var i: integer;
    colMetadata: IColumnMetaData;
    field: TField;
    ColUsed: boolean;
    ColMetaDataIndex: integer;
    RecordSize: integer;
begin
  FArrayFieldCount := 0;
  FBlobFieldCount := 0;
  FDBKeyFieldColumn := -1;
  ColMetaDataIndex := 0;
  SetLength(FFieldNo2ColumnMap,aFields.Count+1); {Note: FieldNos are 1-based - index 0 is not used}

  { Initialize offsets, buffer sizes, etc... }
  FColumnCount := metadata.Count;
  SetLength(FColumnMetadata,FColumnCount);
  RecordSize := CalcRecordHdrSize;

  {Now determine how much space needs to be reserved for each column and column metadata}
  for i := 0 to FColumnCount - 1 do
  with FColumnMetadata[ColMetaDataIndex] do
  begin
    fdSQLColIndex := i;
    colMetadata := metadata[i];
    ColUsed := false;

    if colMetadata.GetAliasName = sDBkeyAlias then {special case for TIBTable support}
    begin
      FDBKeyFieldColumn := ColMetaDataIndex;
      ColUsed := true;
    end;

    field := aFields.FindField(colMetadata.GetAliasName);
    if field <> nil then
    begin
      FFieldNo2ColumnMap[field.FieldNo] := ColMetaDataIndex;
      Colused := true;
      fdRefreshOnInsert := (pfRefreshOnInsert in field.ProviderFlags) or
                           (TIBFieldDef(field.FieldDef).IdentityColumn) or
                            field.FieldDef.InternalCalcField;
      fdRefreshOnUpdate := (pfRefreshOnUpdate in field.ProviderFlags) or
                            field.FieldDef.InternalCalcField;
    end;

    if not Colused then continue;

    fdDataType := colMetadata.GetSQLType;
    if fdDataType = SQL_BLOB then
      fdDataScale := 0
    else
      fdDataScale := colMetadata.getScale;
    fdNullable := colMetadata.getIsNullable;
    fdDataSize := colMetadata.GetSize;
    fdCodePage := CP_NONE;
    fdAliasName := colMetadata.GetAliasName;

    case fdDataType of
    SQL_TIMESTAMP,
    SQL_TYPE_DATE,
    SQL_TYPE_TIME:
      fdDataSize := SizeOf(TDateTime);
    SQL_TIMESTAMP_TZ,
    SQL_TIMESTAMP_TZ_EX,
    SQL_TIME_TZ,
    SQL_TIME_TZ_EX:
      fdDataSize := SizeOf(TIBBufferedDateTimeWithTimeZone);
    SQL_SHORT:
    begin
      if (fdDataScale = 0) then
        fdDataSize := SizeOf(short)
      else
      if (fdDataScale >= (-4)) then
        fdDataSize := SizeOf(Currency)
      else
        fdDataSize := SizeOf(Double);
    end;
    SQL_LONG:
    begin
      if (fdDataScale = 0) then
        fdDataSize := SizeOf(Integer)
      else
      if (fdDataScale >= (-4)) then
        fdDataSize := SizeOf(Currency)
      else
        fdDataSize := SizeOf(Double);
    end;
    SQL_INT64:
    begin
      if (fdDataScale = 0) then
        fdDataSize := SizeOf(Int64)
      else
      if (fdDataScale >= (-4)) then
        fdDataSize := SizeOf(Currency)
      else
        fdDataSize := SizeOf(Double);
    end;
    SQL_DOUBLE, SQL_FLOAT, SQL_D_FLOAT:
      fdDataSize := SizeOf(Double);
    SQL_BOOLEAN:
      fdDataSize := SizeOf(wordBool);
    SQL_VARYING,
    SQL_TEXT:
      fdCodePage := colMetadata.getCodePage;
    SQL_BLOB:
      begin
        Inc(FBlobFieldCount);
        fdCodePage := colMetadata.getCodePage;
      end;
    SQL_DEC16,
    SQL_DEC34,
    SQL_DEC_FIXED,
    SQL_INT128:
      fdDataSize := sizeof(tBCD);
    SQL_Array:
        Inc(FArrayFieldCount);
    end;
    fdDataOfs := RecordSize;
    if fdDataType = SQL_VARYING then
      Inc(RecordSize, fdDataSize + sizeof(short))
    else
      Inc(RecordSize, fdDataSize);
    Inc(ColMetaDataIndex);
  end;

  FColumnCount := ColMetaDataIndex; {set to number of columns in use}

  {Reserve space for null column bitmap}
  FNullColBitmapOffset := RecordSize;
  Inc(RecordSize, ((FColumnCount - 1) div 8) + 1);

  {Reserve space for Refresh Required bit map}
  FRefreshRequiredBitmapOffset := RecordSize;
  FRefreshRequiredSize := ((FColumnCount - 1) div 8) + 1;
  Inc(RecordSize, FRefreshRequiredSize);
  FSaveBufferSize := RecordSize;

  {Reserve space for Blob Objects}
  if FBlobFieldCount > 0 then
  for i := 0 to FColumnCount - 1 do
  with FColumnMetadata[i] do
  begin
    if fdDataType = SQL_BLOB then
    begin
      fdObjOffset := RecordSize;
      Inc(RecordSize,sizeof(TIBBlobStream));
    end;
  end;

  {Reserve space for array objects}
  if FArrayFieldCount > 0 then
  for i := 0 to FColumnCount - 1 do
  with FColumnMetadata[i] do
  begin
    if fdDataType = SQL_ARRAY then
    begin
      fdObjOffset := RecordSize;
      Inc(RecordSize,sizeof(TIBArray));
    end;
  end;

  {FRecordBufferSize is how much space needs to be reserved}
  FRecordBufferSize := RecordSize;
end;

function TIBSelectCursor.GetSQLParams : ISQLParams;
begin
  Result := FCursor.GetStatement.SQLParams;
end;

function TIBSelectCursor.GetBuffer(aBufID: TRecordBuffer): PByte;
begin
  Result := PDisplayBuffer(aBufID)^.dbBuffer;
end;

procedure TIBSelectCursor.SetBuffer(aBufID: TRecordBuffer; aBuffer: PByte);
begin
  PDisplayBuffer(aBufID)^.dbBuffer := aBuffer;
end;

function TIBSelectCursor.GetCalcFields(aBufID: TRecordBuffer): PByte;
begin
  Result := PDisplayBuffer(aBufID)^.dbCalcFields;
end;

function TIBSelectCursor.FieldNo2ColumnIndex(aField: TField): integer;
begin
  if (aField.FieldNo < 1) or (aField.FieldNo > Length(FFieldNo2ColumnMap)) then
    IBError(ibxeBadFieldNo,[aField.FieldNo, Length(FFieldNo2ColumnMap)-1]);

  Result  := FFieldNo2ColumnMap[aField.FieldNo];
end;

function TIBSelectCursor.InternalGetUpdateStatus(aBuffer: PByte): TUpdateStatus;
begin
  Result := PRecordHeader(aBuffer)^.rhUpdateStatus;
end;

procedure TIBSelectCursor.InternalSetUpdateStatus(aBuffer: PByte;
  status: TUpdateStatus);
begin
  PRecordHeader(aBuffer)^.rhUpdateStatus:= status;
end;

procedure TIBSelectCursor.SetUpdateStatus(aBufID: TRecordBuffer;
  status: TUpdateStatus);
var Buff: PByte;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);

  InternalSetUpdateStatus(Buff,status);
end;

procedure TIBSelectCursor.Reset;
begin
  FRecordCount := 0;
  ClearBlobCache;
  ClearArrayCache;
  FCursor := nil;
  FCurrentRecord := nil;
  FCurrentRecordStatus := csBOF;
end;

function TIBSelectCursor.FetchNext: boolean;
begin
  Result := Cursor.FetchNext;
  if not (csDesigning in Dataset.ComponentState) then
    MonitorHook.SQLFetch(self,Cursor.GetStatement.GetSQLText);
end;

function TIBSelectCursor.NormaliseParamName(aName : AnsiString;
   var UseOldValue : boolean) : AnsiString;
const
  sOldPrefix = 'OLD_';
  sNewPrefix = 'NEW';
begin
  UseOldValue := false;
  Result := aName;
  if pos(sOldPrefix,Result) = 1 then
  begin
    system.Delete(Result,1,length(sOldPrefix));
    UseOldValue := true;
  end
  else
  begin
    if pos(sNewPrefix,Result) = 1 then
      system.Delete(Result,1,length(sNewPrefix));
  end;
end ;

procedure TIBSelectCursor.ClearRegisteredQueries;
var i: TRegisteredQueryTypes;
begin
  for i := low(FRegisteredQueries) to high(FRegisteredQueries) do
  with FRegisteredQueries[i] do
  begin
    stmt := nil;
    SetLength(ParamMap,0);
    SetLength(UseOldValue,0);
    SetLength(ColMap,0);
  end;
end ;

procedure TIBSelectCursor.ClearBlobCache;
var  i: Integer;
begin
  for i := 0 to FBlobStreamList.Count - 1 do
  begin
    TIBBlobStream(FBlobStreamList[i]).Free;
    FBlobStreamList[i] := nil;
  end;
  FBlobStreamList.Pack;
end;

procedure TIBSelectCursor.ClearArrayCache;
var  i: Integer;
begin
  for i := 0 to FArrayList.Count - 1 do
  begin
    TIBArray(FArrayList[i]).Free;
    FArrayList[i] := nil;
  end;
  FArrayList.Pack;
end;

procedure TIBSelectCursor.ClearRowCache(aBuffer: PByte);
var i: Integer;
begin
  for i := 0 to FColumnCount - 1 do
  with FColumnMetaData[i] do
    case fdDataType of
      SQL_BLOB:
        PIBBlobStream(aBuffer + fdObjOffset)^ := nil;
      SQL_ARRAY:
        PIBArray(aBuffer + fdObjOffset)^ := nil;
    end;
end;

procedure TIBSelectCursor.CopyCursorDataToBuffer(QryResults: IResults; QryIndex,
  ColIndex: integer; destBuff: PByte);
var LocalData: PByte;
    ColData: ISQLData;
    IsNull: boolean;
    DataLength: Short;
    BufPtr: PByte;
begin
  QryResults.GetData(QryIndex,IsNull,DataLength,LocalData);
  with FColumnMetaData[ColIndex] do
  begin
    InternalSetIsNull(destBuff,ColIndex,IsNull);
    BufPtr := destBuff + fdDataOfs;
    if IsNull then
      FillChar(BufPtr^,fdDataSize,0)
    else
    begin
      ColData := QryResults[QryIndex];
      case fdDataType of  {Get Formatted data for column types that need formatting}
        SQL_TYPE_DATE,
        SQL_TYPE_TIME,
        SQL_TIMESTAMP:
          {This is an IBX native format and not the TDataset approach. See also GetFieldData}
          PDateTime(BufPtr)^ := ColData.AsDateTime;

        SQL_TIMESTAMP_TZ,
        SQL_TIMESTAMP_TZ_EX:
        begin
          with PIBBufferedDateTimeWithTimeZone(Bufptr)^ do
            ColData.GetAsDateTime(Timestamp,dstOffset,TimeZoneID);
        end;

        SQL_TIME_TZ,
        SQL_TIME_TZ_EX:
        begin
          with PIBBufferedDateTimeWithTimeZone(Bufptr)^ do
            ColData.GetAsTime(Timestamp, dstOffset,TimeZoneID, FDefaultTZDate);
        end;
        SQL_SHORT:
        begin
          if (fdDataScale = 0) then
            PShort(BufPtr)^ := ColData.AsShort
          else
          if (fdDataScale >= (-4)) then
            PCurrency(BufPtr)^ := ColData.AsCurrency
          else
           PDouble(BufPtr)^ := ColData.AsDouble;
        end;
        SQL_LONG:
        begin
          if (fdDataScale = 0) then
            PLong(BufPtr)^ := ColData.AsLong
          else
          if (fdDataScale >= (-4)) then
            PCurrency(BufPtr)^ := ColData.AsCurrency
          else
           PDouble(BufPtr)^ := ColData.AsDouble;
        end;
        SQL_INT64:
        begin
          if (fdDataScale = 0) then
            PInt64(BufPtr)^ := ColData.AsInt64
          else
          if (fdDataScale >= (-4)) then
            PCurrency(BufPtr)^ := ColData.AsCurrency
          else
            PDouble(BufPtr)^ := ColData.AsDouble;
        end;

        SQL_DOUBLE, SQL_FLOAT, SQL_D_FLOAT:
          PDouble(BufPtr)^ := ColData.AsDouble;

        SQL_BOOLEAN:
          system.PBoolean(BufPtr)^ := ColData.AsBoolean;

        SQL_DEC16,
        SQL_DEC34,
        SQL_DEC_FIXED,
        SQL_INT128:
          pBCD(BufPtr)^ := ColData.GetAsBCD;

      else
        begin
          if fdDataType = SQL_VARYING then
          begin
            PShort(BufPtr)^ := DataLength;
            Move(LocalData^, (BufPtr + sizeof(Short))^, DataLength);
          end
          else
            Move(LocalData^, BufPtr^, fdDataSize)
        end;
      end; {case}
    end;
  end;
end;

function TIBSelectCursor.InternalGetIsNull(Buff: PByte; ColIndex: integer
  ): boolean;
var pBitmap: PByte;
    mask: byte;
begin
  pBitmap := Buff + FNullColBitmapOffset + ColIndex div 8;
  mask := $01 shl (ColIndex mod 8);
  Result := (pBitmap^ and mask) = 0; {bit is 0 => null}
end;

procedure TIBSelectCursor.InternalSetIsNull(Buff: PByte; ColIndex: integer;
  IsNull: boolean);
var pBitmap: PByte;
    mask: byte;
begin
  pBitmap := Buff + FNullColBitmapOffset + ColIndex div 8;
  mask := $01 shl (ColIndex mod 8);
  if IsNull then
    pBitmap^ := pBitmap^ and not mask {unset bit}
  else
    pBitmap^ := pBitmap^ or mask;     {set bit}
end;

procedure TIBSelectCursor.SetRefreshRequired(Buff: PByte; ColIndex: integer;
  RefreshRequired: boolean);
var pBitmap: PByte;
    mask: byte;
begin
  pBitmap := Buff + FRefreshRequiredBitmapOffset + ColIndex div 8;
  mask := $01 shl (ColIndex mod 8);
  if RefreshRequired then
    pBitmap^ := pBitmap^ or mask           {set bit}
  else
    pBitmap^ := pBitmap^ and not mask;     {unset bit}
end;

procedure TIBSelectCursor.SaveBlobsAndArrays(Buff: PByte);
var  pdb: PIBBlobStream;
     pda: PIBArray;
     i: integer;
begin
  for i := 0 to FColumnCount - 1 do
  with FColumnMetadata[i] do
  begin
    case fdDataType of
    SQL_BLOB:
      begin
        pdb := PIBBlobStream(Buff + fdObjOffset);
        if pdb^ <> nil then
        begin
          pdb^.Finalize;
          PISC_QUAD(Buff + fdDataOfs)^ := pdb^.BlobID;
          InternalSetIsNull(Buff,i, pdb^.Size = 0);
          SetRefreshRequired(Buff,i,true);
        end
      end;

    SQL_ARRAY:
      begin
        pda := PIBArray(Buff + fdObjOffset);
        if pda^ <> nil then
        begin
          PISC_QUAD(Buff + fdDataOfs)^ := pda^.ArrayIntf.GetArrayID;
          InternalSetIsNull(Buff,i, pda^.ArrayIntf.IsEmpty);
          SetRefreshRequired(Buff,i,true);
        end
      end;
    end;
  end;
end;

function TIBSelectCursor.CalcRecordHdrSize: integer;
begin
  Result := sizeof(TRecordHeader);
end;

function TIBSelectCursor.ColIndexByName(aName: AnsiString; caseSensitive: boolean
  ): integer;
var i: integer;
begin
  Result := -1;
  if caseSensitive then
  for i := 0 to FColumnCount - 1 do
  begin
    if FColumnMetaData[i].fdAliasName = aName then
    begin
      Result := i;
      Exit;
    end
  end
  else
  begin
    aName := AnsiUpperCase(aName);
    for i := 0 to FColumnCount - 1 do
      if AnsiUpperCase(FColumnMetaData[i].fdAliasName) = aName then
      begin
        Result := i;
        Exit;
      end
  end;
end;

procedure TIBSelectCursor.FetchCurrentRecord(destBuffer: PByte);
var  i: Integer;
begin
   { Make sure blob and array caches are empty }
  ClearRowCache(destBuffer);

  if Cursor.IsEOF then
    IBError(ibxeCursorAtEOF,[]);

  for i := 0 to FColumnCount - 1 do
    CopyCursorDataToBuffer(FCursor,FColumnMetaData[i].fdSQLColIndex,i,destBuffer);
  InternalSetUpdateStatus(destBuffer,usUnModified);
end;

procedure TIBSelectCursor.FieldChanged(aBuffer: PByte; aField: TField);
begin
  THackedField(aField).DataChanged;
end;

constructor TIBSelectCursor.Create(aDataset : TDataset; aName : string;
    aCursor : IResultSet; aFields : TFields; aCalcFieldsSize : integer;
    aDefaultTZDate : TDateTime);
begin
  inherited Create;
  FBlobStreamList := TList.Create;
  FArrayList := TList.Create;
  FDataset := aDataset;
  FName := aName;
  FCursor := aCursor;
  FCalcFieldsSize := aCalcFieldsSize;
  FDefaultTZDate := aDefaultTZDate;
  SetupBufferStructure(cursor.GetStatement.MetaData,aFields);
  FCurrentRecord := nil;
  FCurrentRecordStatus := csBOF;
  ClearRegisteredQueries;
end;

destructor TIBSelectCursor.Destroy;
begin
  ClearBlobCache;
  ClearArrayCache;
  FBlobStreamList.Free;
  FArrayList.Free;
  SetLength(FColumnMetadata,0);
  ClearRegisteredQueries;
  inherited Destroy;
end;

{Note bufferindex starts at one to avoid confusion with a nil pointer.
 The "buffer" is an opaque pointer - actually an integer index to the
 FBuffers array.}

function TIBSelectCursor.AllocRecordBuffer: TRecordBuffer;
begin
  Result := GetMem(sizeof(TDisplayBuffer));;
  if Result = nil then
    OutofMemoryError;
  with PDisplayBuffer(Result)^ do
  begin
    dbBookmarkFlag := bfCurrent;
    FillChar(dbBookmarkData,sizeof(dbBookmarkData),0);
    dbBuffer := InternalAllocRecordBuffer;
    dbCalcFields := GetMem(FCalcFieldsSize);
    if dbCalcFields = nil then
      OutOfMemoryError;
  end;
end;

procedure TIBSelectCursor.FreeRecordBuffer(var Buffer: TRecordBuffer);
begin
  if Buffer <> nil then
  begin
    with PDisplayBuffer(Buffer)^ do
    begin
      InternalFreeRecordBuffer(dbBuffer);
      FreeMem(dbCalcFields);
    end;
    FreeMem(Buffer);
  end;
  Buffer := nil;
end;

procedure TIBSelectCursor.SetCurrentRecord(aBufID: TRecordBuffer);
var Buff: PByte;

  procedure SetBuffer;
  begin
    Buff := GetBuffer(aBufID);
    if Buff = nil then
      IBError(ibxeBufferNotSet, [nil]);
    FCurrentRecord := Buff;
    FCurrentRecordStatus := csRowBuffer;
  end;

begin
  case GetBookmarkFlag(aBufID) of
  bfBOF:
    FCurrentRecordStatus := csBOF;
  bfEOF:
    if FEditState = esInsert then
      SetBuffer
    else
      FCurrentRecordStatus := csEOF;
  else
    SetBuffer;
  end;
end;

{Field.offset is a zero based integer indexing the blob field
 Field.FieldNo is a one based field index accross all of a record's fields}

function TIBSelectCursor.CreateBlobStream(aBufID: TRecordBuffer; Field: TField;
  Mode: TBlobStreamMode): TStream;
var pdb: PIBBlobStream;
    fs: TIBBlobStream;
    Buff: PByte;
    ColMetadata: TColumnMetadata;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
  begin
    fs := TIBBlobStream.Create;
    fs.Mode := bmReadWrite;
    fs.Database := (Field.Dataset as TIBCustomDataset).Database;
    fs.Transaction := (Field.Dataset as TIBCustomDataset).Transaction;
    fs.SetField(Field);
    FBlobStreamList.Add(Pointer(fs));
  end
  else
  begin
    ColMetadata := FColumnMetaData[FieldNo2ColumnIndex(Field)];
    pdb := PIBBlobStream(Buff + ColMetaData.fdObjOffset);
    if pdb^ = nil then {not yet assigned}
    begin
      fs := TIBBlobStream.Create;;
      fs.Mode := bmReadWrite;
      fs.Database :=  (Field.Dataset as TIBCustomDataset).Database;
      fs.Transaction :=  (Field.Dataset as TIBCustomDataset).Transaction;
      fs.SetField(Field);
      fs.BlobID := PISC_QUAD(Buff + ColMetaData.fdDataOfs)^;
      pdb^ := fs;
      FBlobStreamList.Add(Pointer(fs));
     end
    else
      fs := pdb^;
  end;
  Result := TIBDSBlobStream.Create(Field, fs, Mode);
end;

function TIBSelectCursor.GetArray(aBufID: TRecordBuffer; Field: TField
  ): IArray;
var Buff: PByte;
    pda: PIBArray;
    ColIndex: integer;
    ColMetadata: TColumnMetadata;
    ar: TIBArray;
begin
  Buff := GetBuffer(aBufID);
  with Field.Dataset as TIBCustomDataset do
  begin
    if Buff = nil then
      Result := Database.Attachment.CreateArray(Transaction.TransactionIntf,
                                (Field as TIBArrayField).RelationName,Field.FieldName)
    else
    begin
      ColIndex := FieldNo2ColumnIndex(Field);
      ColMetadata := FColumnMetaData[ColIndex];
      pda := PIBArray(Buff + ColMetadata.fdObjOffset);
      if pda^ = nil then
      begin
        if InternalGetIsNull(Buff,ColIndex) then
          Result := Database.Attachment.CreateArray(Transaction.TransactionIntf,
                                  (Field as TIBArrayField).RelationName,Field.FieldName)
        else
          Result := Database.Attachment.OpenArray(Transaction.TransactionIntf,
                              (Field as TIBArrayField).RelationName,Field.FieldName,
                              PISC_QUAD(Buff + ColMetaData.fdDataOfs)^);
        ar := TIBArray.Create(Field,Result);
        pda^ := ar;
        FArrayList.Add(ar);
      end
      else
        Result := pda^.ArrayIntf;
    end;
  end;
end;

procedure TIBSelectCursor.SetArrayIntf(aBufID: TRecordBuffer; AnArray: IArray;
  Field: TField);
var Buff: PByte;
    pda: PIBArray;
    ColIndex: integer;
    ColMetadata: TColumnMetadata;
    ar: TIBArray;
    IsNull: boolean;
begin
  Buff := GetBuffer(aBufID);
  if Buff <> nil then
  begin
    ColIndex := FieldNo2ColumnIndex(Field);
    ColMetadata := FColumnMetaData[ColIndex];
    IsNull := AnArray = nil;
    InternalSetIsNull(Buff,ColIndex,IsNull);
    pda := PIBArray(Buff + ColMetaData.fdObjOffset);
    if pda^ = nil then
    begin
      if not IsNull then
      begin
        ar := TIBArray.Create(Field,AnArray);
        pda^ := ar;
        FArrayList.Add(ar);
      end
      else
        pda^.FArray := AnArray;
    end;
    FieldChanged(Buff,Field);
  end;
end;

function TIBSelectCursor.GetRecDBkey(aBufID: TRecordBuffer): TIBDBKey;
var Buff: PByte;
begin
  FillChar(Result,sizeof(TIBDBKey),0);
  if FDBKeyFieldColumn >= 0 then
  with FColumnMetaData[FDBKeyFieldColumn] do
  begin
    Buff := GetBuffer(aBufID);
    if (Buff <> nil) and (fdDataSize <= 8) then
      Result := PIBDBKEY(Buff + fdDataOfs)^;
  end;
end;

function TIBSelectCursor.GetFieldData(aBufID: TRecordBuffer; field: TField;
  outBuffer: PByte): boolean;
var Buff: PByte;
    ColIndex: integer;
    Data: PByte;
    len: Short;
begin
  Result := false;
  if aBufID = nil then Exit;
  if field.FieldNo < 0 then  {Calculated Field}
  begin
    Buff := GetCalcFields(aBufID);
    if Buff = nil then Exit;

    Inc(Buff, field.Offset); {For CalcFields, TField.offset is the buffer offset}
    Result := not Boolean(Buff[0]);

    if Result and (outBuffer <> nil) then
      Move(Buff[1], outBuffer^, field.DataSize);
  end
  else
  begin
    Buff := GetBuffer(aBufID);
    if Buff = nil then Exit;

    ColIndex := FieldNo2ColumnIndex(field);
    Result := not InternalGetIsNull(Buff,ColIndex);
    if Result and (outBuffer <> nil) then
    with FColumnMetaData[ColIndex] do
    begin
      Data := Buff + fdDataOfs;
      if fdDataType = SQL_VARYING then
      begin
        len := PShort(Data)^;
        if len <= field.DataSize then
        begin
          Inc(Data,sizeof(short));
          Move(Data^, outBuffer^, len);
          PAnsiChar(outBuffer)[len] := #0;
        end
        else
          IBError(ibxeFieldSizeError,[field.FieldName,field.DataSize,len])
      end
      else
      if fdDataSize <= Field.DataSize then
        Move(Data^, outBuffer^, fdDataSize)
      else
        IBError(ibxeFieldSizeError,[field.FieldName,field.DataSize,fdDataSize])
    end;
  end;
end;

procedure TIBSelectCursor.SetFieldData(aBufID: TRecordBuffer; field: TField;
  inBuffer: PByte);
var Buff: PByte;
    ColIndex: integer;
    Data: PByte;
    DataSize: Short;
    len: Short;
    IsNull: boolean;
begin
  if field.FieldNo < 0 then {calaculated field}
  begin
    Buff := GetCalcFields(aBufID);
    if Buff = nil then Exit;

    Inc(Buff, field.Offset); {For CalcFields, TField.offset is the buffer offset}
    IsNull := inBuffer = nil;
    Boolean(Buff[0]) := IsNull;
    if not IsNull then
      Move(inBuffer^, Buff[1], Field.DataSize);
  end
  else
  begin
    Buff := GetBuffer(aBufID);
    if Buff = nil then Exit;

    ColIndex := FieldNo2ColumnIndex(field);
    Field.Validate(inBuffer);
    IsNull := (inBuffer = nil) or
              (Field is TStringField) and (PAnsiChar(inBuffer)^ = #0);
    InternalSetIsNull(Buff,Colindex,IsNull);
    if not IsNull then
    with FColumnMetadata[ColIndex] do
    begin
      Data := Buff + fdDataOfs;
      DataSize := fdDataSize;
      FillChar(Data^,DataSize,0);
      if fdDataType = SQL_VARYING then
      begin
        len := StrLen(PAnsiChar(inBuffer));
        PShort(Data)^ := len;
        Inc(Data,sizeof(Short));
      end;

      if DataSize >= field.DataSize then
         Move(inBuffer^, Data^,DataSize)
       else
         IBError(ibxeDBBufferTooSmall,[DataSize,field.FieldName,field.DataSize]);

      FieldChanged(Buff,field);
    end;
  end;
end;

procedure TIBSelectCursor.SetSQLParams(aBufID: TRecordBuffer; params: ISQLParams);
var Buff: PByte;
    OldBuffer: PByte;
    i: integer;
    Param: ISQLParam;
    ParamName: AnsiString;
    srcBuffer: PByte;
    ColIndex: integer;
    UseOldValue: boolean;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);

  SaveBlobsAndArrays(Buff);

  OldBuffer := GetOldBufferFor(Buff);
  for i := 0 to Params.GetCount - 1 do
  begin
     Param := params[i];
     ParamName := NormaliseParamName(Param.Name,UseOldValue);

     {Determine source buffer}
     if UseOldValue and (OldBuffer <> nil) then
       srcBuffer := OldBuffer
     else
       srcBuffer := Buff;

     ColIndex := ColIndexByName(ParamName,params.GetHasCaseSensitiveParams);
     if ColIndex = -1 then
       continue;

     SetParamValue(srcBuffer,ColIndex,Param);
  end;
end;

{This method is called either using a Row Refresh query or an update/insert query
 with a returning clause}

procedure TIBSelectCursor.UpdateRecordFromQuery(aBufID: TRecordBuffer;
  QryResults: IResults);
var Buff: PByte;
    ColIndex: integer;
    i: integer;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);
  ClearRowCache(Buff);

  for i := 0 to QryResults.Count - 1  do
  begin
    ColIndex := ColIndexByName(QryResults[i].GetAliasName);
    if ColIndex >= 0 then
    begin
      CopyCursorDataToBuffer(QryResults,i,ColIndex,Buff);
      SetRefreshRequired(Buff,ColIndex,false);
    end ;
  end;
end;

function TIBSelectCursor.NeedRefresh(aBufID : TRecordBuffer) : boolean;
var i: integer;
    Buff: PByte;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);

  Result := false;
  for i := 0 to FRefreshRequiredSize - 1 do
    if PByte(Buff + FRefreshRequiredBitmapOffset + i)^ <> 0 then
    begin
      Result := true;
      Exit;
    end;
end;

function TIBSelectCursor.GetBookmarkFlag(aBufID: TRecordBuffer): TBookmarkFlag;
begin
  Result := PDisplayBuffer(aBufID)^.dbBookmarkFlag;;
end;

procedure TIBSelectCursor.SetBookmarkFlag(aBufID: TRecordBuffer;
  aBookmarkFlag: TBookmarkFlag);
begin
  PDisplayBuffer(aBufID)^.dbBookmarkFlag := aBookmarkFlag;
end;

procedure TIBSelectCursor.SetBookmarkData(aBufID: TRecordBuffer;
  RecNo: TIBRecordNumber);
begin
  Move(RecNo,PDisplayBuffer(aBufID)^.dbBookmarkData,GetBookmarkSize);
end;

procedure TIBSelectCursor.GetBookmarkData(Buffer: TRecordBuffer; Data: Pointer);
begin
  Move(PDisplayBuffer(Buffer)^.dbBookmarkData,Data^,GetBookmarkSize);
end;

procedure TIBSelectCursor.SetBookmarkData(Buffer: TRecordBuffer; Data: Pointer);
begin
  if Data <> nil then
    Move(Data^,PDisplayBuffer(Buffer)^.dbBookmarkData, GetBookmarkSize);
end;

function TIBSelectCursor.GetBookmarkSize: integer;
begin
  Result := sizeof(TIBRecordNumber);
end;

function TIBSelectCursor.GetRecordSize: word;
begin
  Result := sizeof(TDisplayBuffer);
end;

function TIBSelectCursor.GetCurrentRecNo: TIBRecordNumber;
begin
  case FCurrentRecordStatus of
  csBOF:
    Result := 0;
  csEOF:
    Result := FRecordCount;
  csRowBuffer:
    Result := InternalGetRecNo(FCurrentRecord);
  end;
end;

procedure TIBSelectCursor.SwapDataBuffer(buf1, buf2: TRecordBuffer);
var TmpBuf: PByte;
    TmpBookmarkFlag: TBookmarkFlag;
    TmpBookmarkData1: TBytes;
    TmpBookmarkData2: TBytes;
begin
  TmpBuf := PDisplayBuffer(Buf1)^.dbBuffer;
  TmpBookmarkFlag :=  GetBookmarkFlag(buf1);
  SetLength(TmpBookmarkData1,GetBookmarkSize);
  GetBookmarkData(buf1,pointer(TmpBookmarkData1));
  SetLength(TmpBookmarkData2,GetBookmarkSize);
  GetBookmarkData(buf1,pointer(TmpBookmarkData2));
  PDisplayBuffer(Buf1)^.dbBuffer := PDisplayBuffer(Buf2)^.dbBuffer;
  SetBookmarkFlag(buf1,GetBookmarkFlag(buf2));
  SetBookmarkData(buf1,pointer(TmpBookmarkData2));
  PDisplayBuffer(buf2)^.dbBuffer := TmpBuf;
  SetBookmarkFlag(buf2,TmpBookmarkFlag);
  SetBookmarkData(buf2,pointer(TmpBookmarkData1));
end;

function TIBSelectCursor.GetAliasName(FieldNo: integer): AnsiString;
begin
  if (FieldNo < 1) or (FieldNo > Length(FFieldNo2ColumnMap)) then
    IBError(ibxeBadFieldNo,[FieldNo, Length(FFieldNo2ColumnMap)-1]);

  Result  := FColumnMetaData[ FFieldNo2ColumnMap[FieldNo] ].fdAliasName;
end;

procedure TIBSelectCursor.InitRecord(aBufID: TRecordBuffer);
begin
  with PDisplayBuffer(aBufID)^ do
  begin
    dbBookmarkFlag := bfInserted;
    Fillchar(dbCalcFields^,CalcFieldsSize,0);
    FillChar(dbBookmarkData,GetBookmarkSize,0);
    if dbBuffer <> nil then
      InternalSetUpdateStatus(dbBuffer,usInserted);
  end;
end;

function TIBSelectCursor.AtBOF: boolean;
begin
  Result := FCurrentRecordStatus = csBOF;
end;

function TIBSelectCursor.AtEOF: boolean;
begin
  Result := (FCurrentRecordStatus = csEOF) and Cursor.IsEof;
end;

function TIBSelectCursor.CursorAtEOF : boolean;
begin
  Result := FCursor.IsEof;
end;

procedure TIBSelectCursor.Delete(aBufID: TRecordBuffer);
var Buff: PByte;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);

  InternalDelete(aBufID);
end;

procedure TIBSelectCursor.UnDelete(aBufID: TRecordBuffer);
var Buff: PByte;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);

  InternalUnDelete(Buff);
end;

function TIBSelectCursor.GetUpdateStatus(aBufID: TRecordBuffer): TUpdateStatus;
var Buff: PByte;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);
  Result := InternalGetUpdateStatus(Buff);
end;

procedure TIBSelectCursor.ClearCalcFields(aBufID: TRecordBuffer);
var Buff: PByte;
begin
  Buff := GetCalcFields(aBufID);
  FillChar(Buff^,FCalcFieldsSize,0);
end;

procedure TIBSelectCursor.SetCursor(aCursor: IResultSet);
begin
  if (FCursor <> nil) and (FCursor.GetStatement <> aCursor.GetStatement) then
    IBError(ibxeDifferentStatement,[]);
  Reset;
  FCursor := aCursor;
end;

 procedure TIBSelectCursor.RegisterQuery(qryType : TRegisteredQueryTypes;
   qry : IStatement; OnValuesReturnedProc : TOnValuesReturned);
var i: integer;
    ParamName: AnsiString;
begin
  with FRegisteredQueries[qryType] do
  begin
    stmt :=  qry;
    OnValuesReturned := OnValuesReturnedProc;
    SetLength(ParamMap,Qry.SQLParams.count);
    SetLength(UseOldValue, Qry.SQLParams.count);
    for i := 0 to Qry.SQLParams.Count - 1 do
    begin
      ParamName := NormaliseParamName(Qry.SQLParams[i].Name,UseOldValue[i]);
      ParamMap[i] := ColIndexByName(ParamName,Qry.SQLParams.GetHasCaseSensitiveParams);
    end;

    SetLength(ColMap,qry.MetaData.Count);
    for i := 0 to qry.MetaData.Count - 1 do
      ColMap[i] := ColIndexByName(qry.MetaData[i].getAliasName);
  end;
end;

 procedure TIBSelectCursor.ExecRegisteredQuery(qryType : TRegisteredQueryTypes;
   aBufID : TRecordBuffer; var SelectCount, InsertCount, UpdateCount,
   DeleteCount : integer);
var Buff: PByte;
    i: integer;
    OldBuffer: PByte;
    qryResults: IResults;
    qryResultSet: IResultSet;
begin
  Buff := GetBuffer(aBufID);
  if Buff = nil then
    IBError(ibxeBufferNotSet, [nil]);

  SaveBlobsAndArrays(Buff);
  OldBuffer := GetOldBufferFor(Buff);

  with FRegisteredQueries[qryType] do
  begin
    {set param values}
    for i := 0 to Length(ParamMap) - 1 do
      if ParamMap[i] <> -1 then
      begin
         if UseOldValue[i] and (OldBuffer <> nil) then
           SetParamValue(OldBuffer,ParamMap[i],stmt.SQLParams[i])
         else
           SetParamValue(Buff,ParamMap[i],stmt.SQLParams[i]);
      end;

    {execute query}
    if stmt.SQLStatementType =  SQLSelect then
    begin
      qryResultSet := stmt.OpenCursor;
      qryResultSet.FetchNext;
      qryResults := qryResultSet;  {Only single results expected}
    end
    else
      qryResults := stmt.Execute;
    stmt.GetRowsAffected(SelectCount, InsertCount, UpdateCount, DeleteCount);
    if not (csDesigning in Dataset.ComponentState) then
      MonitorHook.SQLExecute(self,stmt.GetSQLText);

    {process any return values}
    if qryType = rqDelete then
      InternalDelete(aBufID)
    else
    begin
      ClearRowCache(Buff);
      for i := 0 to Length(ColMap) - 1 do
        if ColMap[i] <> -1 then
        begin
          CopyCursorDataToBuffer(qryResults,i,ColMap[i],Buff);
          SetRefreshRequired(Buff,ColMap[i],false);
        end;
    end;
    if (qryResults <> nil) and assigned(OnValuesReturned) then
      OnValuesReturned(qryResults);
  end;
end;

function TIBSelectCursor.HasRegisteredQuery(qryType : TRegisteredQueryTypes
   ) : boolean;
begin
  Result := FRegisteredQueries[qryType].stmt <> nil;
end;

procedure TIBSelectCursor.SetParamValue(Buff : PByte; colIndex : integer;
   Param : ISQLParam);
var Data: PByte;
    DataLength: Short;
    st: RawByteString;
    pda: PIBArray;
begin
  if InternalGetIsNull(Buff,ColIndex) then
    Param.IsNull := true
  else
  with FColumnMetaData[ColIndex] do
  begin
    Data := Buff + fdDataOfs;
    case fdDataType of
      SQL_TEXT:
        if Param.getColMetadata.getCharSetID <= 1 {NONE or OCTETS} then
          Param.SetAsPointer(Data)
        else
        begin
          DataLength := strlen(PAnsiChar(Data));
          if DataLength > fdDataSize then
            DataLength := fdDataSize;
          SetString(st, PAnsiChar(Data), DataLength);
          SetCodePage(st,fdCodePage,false);
          Param.AsString := st;
        end;
      SQL_VARYING:
      begin
        DataLength := PShort(Data)^;
        Inc(Data,sizeof(Short));
        SetString(st, PAnsiChar(Data), DataLength);
        SetCodePage(st,fdCodePage,false);
        Param.AsString := st;
      end;
    SQL_FLOAT, SQL_DOUBLE, SQL_D_FLOAT:
      Param.AsDouble := PDouble(Data)^;
    SQL_SHORT:
    begin
      if fdDataScale = 0 then
        Param.AsShort := PShort(Data)^
      else
      if fdDataScale >= (-4) then
        Param.AsCurrency := PCurrency(Data)^
      else
        Param.AsDouble := PDouble(Data)^;
    end;
    SQL_LONG:
    begin
      if fdDataScale = 0 then
        Param.AsLong := PLong(Data)^
      else
      if fdDataScale >= (-4) then
        Param.AsCurrency := PCurrency(Data)^
      else
        Param.AsDouble := PDouble(Data)^;
    end;
    SQL_INT64:
    begin
      if fdDataScale = 0 then
        Param.AsInt64 := PInt64(Data)^
      else
      if fdDataScale >= (-4) then
        Param.AsCurrency := PCurrency(Data)^
      else
        Param.AsDouble := PDouble(Data)^;
    end;
    SQL_BLOB, SQL_QUAD:
      Param.AsQuad := PISC_QUAD(Data)^;
    SQL_ARRAY:
      begin
        pda := PIBArray(Buff + fdObjOffset);
        if pda^ = nil then
          Param.AsQuad := PISC_QUAD(Data)^
        else
          Param.AsArray := pda^.ArrayIntf;
      end;
    SQL_TYPE_DATE,
    SQL_TYPE_TIME,
    SQL_TIMESTAMP:
    {This is an IBX native format and not the TDataset approach. See also SetFieldData}
      Param.AsDateTime := PDateTime(Data)^;
    SQL_TIMESTAMP_TZ_EX,
    SQL_TIMESTAMP_TZ:
      with PIBBufferedDateTimeWithTimeZone(Data)^ do
        Param.SetAsDateTime(Timestamp,TimeZoneID);
    SQL_TIME_TZ_EX,
    SQL_TIME_TZ:
      with PIBBufferedDateTimeWithTimeZone(Data)^ do
        Param.SetAsTime(Timestamp,FDefaultTZDate,TimeZoneID);
    SQL_BOOLEAN:
      Param.AsBoolean := PWordBool(Data)^;
    SQL_DEC16,
    SQL_DEC34,
    SQL_DEC_FIXED,
    SQL_INT128:
      Param.AsBCD := pBCD(Data)^;
    else
      IBError(ibxeUnknownSQLType,[fdDataType]);
    end;
  end;
end;

{ TIBSimpleBufferPool }

function TIBSimpleBufferPool.AllocBlock(buffers: integer): PByte;
var blockSize: integer;
    userBufferAreaSize: integer;
begin
  userBufferAreaSize := buffers * (BufferSize + sizeof(TBufferHeader));
  blockSize := sizeof(TStartHeader) + userBufferAreaSize + sizeof(TEndHeader);
  Result := GetMem(blockSize);
  if Result <> nil then
  begin
    FillChar(Result^,blockSize,0);
    with PStartHeader(Result)^ do
    begin
      HeaderType := htStart;
      {add to end of list}
      PreviousBlock := FLastBlock;
      NextBlock := nil;
      MaxBuffers := buffers;
      BuffersInUse := 0;
      FirstRecNo := 1;
      if PreviousBlock <> nil then
      begin
        FirstRecNo := PStartHeader(PreviousBlock)^.FirstRecNo + PStartHeader(PreviousBlock)^.BuffersInUse;
        PStartHeader(PreviousBlock)^.NextBlock := Result;
      end;
    end;
    with PEndHeader(Result + sizeof(TStartHeader) + userBufferAreaSize)^ do
    begin
      HeaderType := htEnd;
      StartHeader := Result;
    end;
    FLastBlock := Result;
    FBufferIndex.Add(Result);
  end
  else
    OutofMemoryError;
end;

procedure TIBSimpleBufferPool.CheckValidBuffer(P: PByte);
begin
  Dec(P,sizeof(TBufferHeader));
  InternalCheckValidBuffer(P);
end;

procedure TIBSimpleBufferPool.CheckBuffersAvailable;
begin
  if Empty then
     IBError(ibxeEmptyBufferPool,[FName]);
end;

procedure TIBSimpleBufferPool.InternalCheckValidBuffer(P: PByte);
begin
  if not (PBufferHeader(P)^.HeaderType in [htFirstBuffer,htBuffer]) then
   IBError(ibxeNotABuffer,[FName]);
end;

constructor TIBSimpleBufferPool.Create(aName: string; bufSize,
  aBuffersPerBlock, firstBlockBuffers: integer);
begin
  inherited Create;
  FName := aName;
  FBufferSize := bufSize;
  if (aBuffersPerBlock <= 1) or (firstBlockBuffers <= 1) then
     IBError(ibxeNotEnoughBuffers,[FName]);
  FBuffersPerBlock := aBuffersPerBlock;
  FFirstBlockBuffers := firstBlockBuffers;
  FBufferIndex := TList.Create;
end;

destructor TIBSimpleBufferPool.Destroy;
begin
  Clear;
  if FBufferIndex <> nil then FBufferIndex.Free;
  inherited Destroy;
end;

function TIBSimpleBufferPool.Append: PByte;
begin
  Result := AddBuffer;
end;

function TIBSimpleBufferPool.AddBuffer: PByte;
begin
  Result := nil;
  if FFirstBlock = nil then
    FFirstBlock := AllocBlock(FFirstBlockBuffers);

  with PStartHeader(FLastBlock)^ do
    if BuffersInUse >= MaxBuffers then
       AllocBlock(FBuffersPerBlock); {Add a Block and set FLastBlock to newly added block}

  with PStartHeader(FLastBlock)^ do
  begin
    Result := FLastBlock + sizeof(TStartHeader) + BuffersInUse * (FBufferSize + sizeof(TBufferHeader));
    with PBufferHeader(Result)^ do
    begin
      if BuffersInUse = 0 then
         HeaderType := htFirstBuffer
      else
        HeaderType := htBuffer;
      RecNo := FirstRecNo + BuffersInUse;
      Inc(BuffersInUse);
    end;
  end;
  FLastBuffer := Result;
  Inc(Result,sizeof(TBufferHeader)); {start of user data}
  Inc(FRecordCount);
end;

procedure TIBSimpleBufferPool.Clear;
var P, P1: PByte;
begin
  P := FFirstBlock;
  while P <> nil do
  begin
    P1 := PStartHeader(P)^.NextBlock;
    FreeMem(P);
    P := P1;
  end;
  FFirstBlock := nil;
  FLastBlock := nil;
  FLastBuffer := nil;
  FCurrent := nil;
  FBufferIndex.Clear;
  FRecordCount := 0;
end;

function TIBSimpleBufferPool.GetFirst: PByte;
begin
  CheckBuffersAvailable;
  Result := FFirstBlock + sizeof(TStartHeader);
  InternalCheckValidBuffer(Result);
  FCurrent := Result;
  Inc(Result,sizeof(TBufferHeader))
end;

function TIBSimpleBufferPool.GetLast: PByte;
begin
  CheckBuffersAvailable;
  Result := FLastBuffer;
  InternalCheckValidBuffer(Result);
  FCurrent := Result;
  Inc(Result,sizeof(TBufferHeader))
end;

function TIBSimpleBufferPool.GetBuffer(RecNo: TIBRecordNumber): PByte;
var  i: integer;
begin
  Result := nil;
  CheckBuffersAvailable;

  for i := 0 to FBufferIndex.Count - 1 do
  begin
    with PStartHeader(FBufferIndex[i]) ^ do
      if (BuffersInUse > 0 ) and (RecNo < FirstRecNo + BuffersInUse) then
      begin
        Result := FBufferIndex[i] + sizeof(TStartHeader) +
           (RecNo - FirstRecNo) * (sizeof(TBufferHeader) + FBufferSize);
        break;
      end;
  end;

  if Result <> nil then
  begin
    InternalCheckValidBuffer(Result);
    FCurrent := Result;
    Inc(Result, sizeof(TBufferHeader));
  end;
end;

{Returns either pointer to next user buffer or nil if EOF}

function TIBSimpleBufferPool.GetNextBuffer(aBuffer: PByte): PByte;
var P: PByte;
begin
  Result := nil;
  CheckBuffersAvailable;

  if aBuffer = nil then {Implicit request for current buffer}
    Result := FCurrent
  else
  begin
    P := aBuffer - sizeof(TBufferHeader);
    InternalCheckValidBuffer(P);
    Inc(P,sizeof(TBufferHeader)+FBufferSize);
    case PBufferHeader(P)^.HeaderType of
    htFirstBuffer,htBuffer:
      Result := P ;

    htEmptyslot:
      ; {No more buffers}

    htEnd:
      {get first buffer in next block if available}
      begin
        P := PStartHeader(PEndHeader(P)^.StartHeader)^.NextBlock;
        if (P <> nil) and (PStartHeader(P)^.BuffersInUse <> 0) then
          Result := P + sizeof(TStartHeader);
      end;

    else
      IBError(ibxeUnrecognisedHeaderType,[ord(PBufferHeader(P)^.HeaderType)]);
    end;
  end;
  if Result <> nil then
  begin
    InternalCheckValidBuffer(Result);
    FCurrent := Result;
    Inc(Result, sizeof(TBufferHeader));
  end;
end;

{returns either pointer to previous user buffer or nil if BOF}

function TIBSimpleBufferPool.GetPriorBuffer(aBuffer: PByte): PByte;
var P: PByte;
begin
  Result := nil;
  CheckBuffersAvailable;

  if aBuffer = nil then   {Implicit request for current buffer}
    Result := FCurrent
  else
  begin
    P := aBuffer - sizeof(TBufferHeader);
    InternalCheckValidBuffer(P);
    if PBufferHeader(P)^.HeaderType = htFirstBuffer then
    begin
      P := PStartHeader(P- sizeof(TStartHeader))^.PreviousBlock;
      if (P <> nil) and (PStartHeader(P)^.BuffersInUse <> 0) then
        Result :=  P + sizeof(TStartHeader) +
                  (PStartHeader(P)^.BuffersInUse - 1)*(sizeof(TBufferHeader) + FBufferSize);
    end
    else
      Result := P - FBufferSize - sizeof(TBufferHeader);
  end;

  if Result <> nil then
  begin
    InternalCheckValidBuffer(Result);
    FCurrent := Result;
    Inc(Result, sizeof(TBufferHeader));
  end;
end;

function TIBSimpleBufferPool.GetRecNo(aBuffer: PByte): TIBRecordNumber;
var P: PByte;
begin
  P := aBuffer - sizeof(TBufferHeader);
  InternalCheckValidBuffer(P);
  Result := PBufferHeader(P)^.RecNo;
end;

function TIBSimpleBufferPool.GetRecordCount: TIBRecordNumber;
begin
  Result := FRecordCount;
end;

function TIBSimpleBufferPool.Empty: boolean;
begin
  Result := FFirstBlock = nil;
end;

{ TIBBufferPool }

constructor TIBBufferPool.Create(aName: string; bufSize, aBuffersPerBlock,
  firstBlockBuffers: integer);
begin
  inherited Create(aName,bufSize + sizeof(TRecordData), aBuffersPerBlock, firstBlockBuffers);
end;

procedure TIBBufferPool.Clear;
begin
  inherited Clear;
  FFirstRecord := nil;
  FLastRecord := nil;
  FInsertedRecords := 0;
  FDeletedRecords := 0;
end;

function TIBBufferPool.GetFirst: PByte;
begin
  Result := FFirstRecord;
  if (Result <> nil) and (PRecordData(Result)^.rdStatus in [rsAppendDeleted,rsInsertDeleted]) then
    Result := InternalGetNextBuffer(Result,false);
  if Result <> nil then
    Inc(Result,sizeof(TRecordData));
end;

function TIBBufferPool.GetLast: PByte;
begin
  Result := FLastRecord;
  while (Result <> nil) and (PRecordData(Result)^.rdStatus in [rsAppendDeleted,rsInsertDeleted]) do
    Result := PRecordData(Result)^.rdPreviousBuffer;
  if Result <> nil then
    Inc(Result,sizeof(TRecordData));
end;

{InternalGetNextBuffer skips over deleted records and tries to find the next
 record that points back to aBuffer}

function TIBBufferPool.InternalGetNextBuffer(aBuffer: PByte;
  IncludeDeleted: boolean): PByte;
{aBuffer points to TRecordData}
var CurBuffer:PByte;
    temp: PByte;
begin
  Result := aBuffer;
  repeat
    CurBuffer := Result;
    case  PRecordData(CurBuffer)^.rdStatus of

    {records are always appended in sequence but the sequence may be interrupted by
     inserted out of sequence records. These should generally be ignored but could
     be the next in sequence - so have to check them}

    rsAppended, rsAppendDeleted:
      repeat {look for the next undeleted buffer with a previous pointer to this buffer}
        Result := inherited GetNextBuffer(Result);
      until (Result = nil) or (PRecordData(Result)^.rdPreviousBuffer = CurBuffer);

    {Inserted records are typically out of sequence, but can be part of a local
     sequence of inserted buffers.

     1. lookahead until either the next in sequence is found or the local sequence
        breaks.
     2. If not found then work backwards to current sequence insertion point
     3. Then walk forwards to find the buffer
     }

    rsInserted, rsInsertDeleted:
      begin
        Result := inherited GetNextBuffer(CurBuffer);
        if Result = nil then
        begin
          {go back to insertion point and walk forwards}
          Result := CurBuffer;
          temp := PRecordData(Result)^.rdPreviousBuffer;
          while (temp <> nil) and
            (PRecordData(temp)^.rdStatus in [rsInsertDeleted, rsAppendDeleted]) do
          begin
              Result := PRecordData(temp)^.rdPreviousBuffer;
              temp := PRecordData(Result)^.rdPreviousBuffer;
          end;

          if PRecordData(Result)^.rdPreviousBuffer <> nil then
            Result := inherited GetNextBuffer(PRecordData(Result)^.rdPreviousBuffer)
          else
          {inserted at start. Have to walk the pool to find the next buffer}
            Result := LocatePreviousBuffer(CurBuffer);
        end
        else
        if (Result <> nil) and (PRecordData(Result)^.rdPreviousBuffer <> CurBuffer) then {otherwise found it}
        begin
          Result := CurBuffer;
          {Go back to insertion point}
          repeat
            Result := PRecordData(Result)^.rdPreviousBuffer;
          until (Result = nil) or (PRecordData(Result)^.rdStatus in [rsAppended, rsAppendDeleted]);

          if Result <> nil then {now back at the point where the buffer(s) were
                                 inserted.}
          begin
            {find the next appended buffer}
            repeat
              Result := inherited GetNextBuffer(Result);
            until (Result = nil) or (PRecordData(Result)^.rdStatus in [rsAppended, rsAppendDeleted]);

            {now work backwards to find the next buffer in the sequence}
            while (Result <> nil) and (PRecordData(Result)^.rdPreviousBuffer <> CurBuffer) do
              {look backwards for the next buffer with a previous pointer to this buffer}
              Result := PRecordData(Result)^.rdPreviousBuffer;
          end;
        end;
      end;
    end;
  until (Result = nil) or (PRecordData(Result)^.rdStatus in [rsAppended,rsInserted])
    or (IncludeDeleted and (PRecordData(Result)^.rdStatus in [rsAppendDeleted,rsInsertDeleted]));
end;

function TIBBufferPool.GetBuffer(RecNo: TIBRecordNumber): PByte;
begin
  Result := inherited GetBuffer(RecNo);
  if PRecordData(Result)^.rdStatus in [rsInsertDeleted, rsAppendDeleted] then
    IBError(ibxeRecordisDeleted,[RecNo]);
  if Result <> nil then
    Inc(Result,sizeof(TRecordData));
end;

function TIBBufferPool.GetNextBuffer(aBuffer: PByte): PByte;
begin
  Dec(aBuffer,sizeof(TRecordData));
  CheckValidBuffer(aBuffer);
  Result := InternalGetNextBuffer(aBuffer,false);
  if Result <> nil then
    Inc(Result,sizeof(TRecordData));
end;

function TIBBufferPool.GetNextBuffer(aBuffer : PByte; IncludeDeleted : boolean
  ) : PByte;
begin
  Dec(aBuffer,sizeof(TRecordData));
  CheckValidBuffer(aBuffer);
  Result := InternalGetNextBuffer(aBuffer,IncludeDeleted);
  if Result <> nil then
    Inc(Result,sizeof(TRecordData));
end;

function TIBBufferPool.GetPriorBuffer(aBuffer: PByte): PByte;
begin
  Dec(aBuffer,sizeof(TRecordData));
  CheckValidBuffer(aBuffer);
  Result := aBuffer;
  repeat
    Result := PRecordData(Result)^.rdPreviousBuffer
  until (Result = nil) or (PRecordData(Result)^.rdStatus in [rsAppended,rsInserted]);
  if Result <> nil then
    Inc(Result,sizeof(TRecordData));
end;

function TIBBufferPool.GetRecNo(aBuffer: PByte): TIBRecordNumber;
begin
  if aBuffer = nil then
    Result := 0
  else
  begin
    Dec(aBuffer,sizeof(TRecordData));
    CheckValidBuffer(aBuffer);
    if PRecordData(aBuffer)^.rdStatus in [rsInsertDeleted, rsAppendDeleted] then
      Result := 0;
    Result := inherited GetRecNo(aBuffer);
  end;
end;

{Locate by walking bufferpool from start to finish}

function TIBBufferPool.LocatePreviousBuffer(aBuffer : PByte) : PByte;
begin
  Result := inherited GetFirst;
  while (Result <> nil) and (PRecordData(Result)^.rdPreviousBuffer <> aBuffer) do
    Result := inherited GetNextBuffer(Result);
end;

function TIBBufferPool.InsertBefore(aBuffer: PByte): PByte;
begin
  if Empty then
    Result := Append
  else
  begin
    Dec(aBuffer,sizeof(TRecordData));
    CheckValidBuffer(aBuffer);
    Result := AddBuffer;
    with PRecordData(Result)^ do
    begin
      rdStatus := rsInserted;
      rdPreviousBuffer := PRecordData(aBuffer)^.rdPreviousBuffer;
    end;
    PRecordData(aBuffer)^.rdPreviousBuffer := Result;
    if aBuffer = FFirstRecord then
      FFirstRecord := Result;
  end;
  Inc(Result,sizeof(TRecordData));
  Inc(FInsertedRecords);
end;

function TIBBufferPool.InsertAfter(aBuffer: PByte): PByte;
begin
  if Empty then
     Result := Append
  else
  begin
    Dec(aBuffer,sizeof(TRecordData));
    CheckValidBuffer(aBuffer);
    Result := AddBuffer;
    with PRecordData(Result)^ do
    begin
      rdPreviousBuffer := aBuffer;
      if aBuffer = FLastRecord then
      begin
        rdStatus := rsAppended;
        FLastRecord := Result;
      end
      else
      begin
        rdStatus := rsInserted;
        {assumes InternalGetNextBuffer can never return nil given aBuffer is not last}
        PRecordData(InternalGetNextBuffer(aBuffer,true))^.rdPreviousBuffer := Result;
      end;
    end;
  end;
  Inc(Result,sizeof(TRecordData));
  Inc(FInsertedRecords);
end;

function TIBBufferPool.Append: PByte;
begin
  Result := AddBuffer;
  with PRecordData(Result)^ do
  begin
    rdPreviousBuffer := FLastRecord;
    rdStatus := rsAppended;
    FLastRecord := Result;
    if FFirstRecord = nil then
      FFirstRecord := Result;
  end;
  Inc(Result,sizeof(TRecordData));
  Inc(FInsertedRecords);
end;

function TIBBufferPool.Delete(aBuffer: PByte): PByte;
begin
  Result := GetPriorBuffer(aBuffer);
  Dec(aBuffer,sizeof(TRecordData));
  CheckValidBuffer(aBuffer);
  case PRecordData(aBuffer)^.rdStatus of
  rsInserted:
    begin
      if FFirstRecord = aBuffer then
      begin
        FFirstRecord := InternalGetNextBuffer(aBuffer,true);
        if FFirstRecord <> nil then
          PRecordData(FFirstRecord)^.rdPreviousBuffer := nil;
      end;
      PRecordData(aBuffer)^.rdStatus := rsInsertDeleted;
    end;
  rsAppended:
    PRecordData(aBuffer)^.rdStatus := rsAppendDeleted;
  end;
 // writeln('Rec No = ',inherited GetRecNo(aBuffer),' status = ', PRecordData(aBuffer)^.rdStatus);
  Inc(FDeletedRecords);
end;

procedure TIBBufferPool.UnDelete(aBuffer: PByte);
begin
  Dec(aBuffer,sizeof(TRecordData));
  CheckValidBuffer(aBuffer);
  case PRecordData(aBuffer)^.rdStatus of
  rsInsertDeleted:
    begin
      PRecordData(aBuffer)^.rdStatus := rsInserted;
      if PRecordData(aBuffer)^.rdPreviousBuffer = nil then
      {restore as first record}
      begin
        PrecordData(FFirstRecord)^.rdPreviousBuffer := aBuffer;
        FFirstRecord := aBuffer;
      end;
    end;
  rsAppendDeleted:
    PRecordData(aBuffer)^.rdStatus := rsAppended;
  end;
  Dec(FDeletedRecords);
end;

function TIBBufferPool.GetUpdateStatus(aBuffer: PByte): TUpdateStatus;
begin
  Dec(aBuffer,sizeof(TRecordData));
  CheckValidBuffer(aBuffer);
  case PRecordData(aBuffer)^.rdStatus of
   rsInsertDeleted,
   rsAppendDeleted:
     Result := usDeleted;

   rsInserted,
   rsAppended:
     Result := usInserted;

   else
     Result := usUnmodified;
  end;
end;

function TIBBufferPool.GetRecordStatus(aBuffer: PByte): TRecordStatus;
begin
  Dec(aBuffer,sizeof(TRecordData));
  CheckValidBuffer(aBuffer);
  Result := PRecordData(aBuffer)^.rdStatus;
end;

{$ifdef PrintBuf}
procedure TIBBufferPool.PrintBufferList;
var buff: PByte;
begin
  writeln('Print Buffer List for ',Name);
  writeln('Record Count = ',RecordCount);
  buff := GetFirst;
  while buff <> nil do
  begin
    writeln('Rec No = ',GetRecNo(buff),' status = ',GetRecordStatus(buff),' previous = ',
      GetRecNo(GetPriorBuffer(buff)));
    buff := GetNextBuffer(buff);
  end;
  writeln('Include Deleted');
  buff := GetFirst;
  while buff <> nil do
  begin
    writeln('Rec No = ',GetRecNo(buff),' status = ',GetRecordStatus(buff));
    buff := GetNextBuffer(buff,true);
  end;
end;
{$endif}

{ TIBOldBufferPool }

procedure TIBOldBufferPool.CheckValidBuffer(P: PByte);
begin
  Dec(P,sizeof(TRecordData));
  inherited CheckValidBuffer(P);
end;

constructor TIBOldBufferPool.Create(aName: string; bufSize, aBuffersPerBlock,
  firstBlockBuffers: integer);
begin
  inherited Create(aName,bufSize + sizeof(TRecordData),aBuffersPerBlock,
    firstBlockBuffers);
end;

function TIBOldBufferPool.Append(RecNo: TIBRecordNumber; DataBuffer: PByte
  ): PByte;
begin
  Result := AddBuffer;
  with PRecordData(Result)^ do
  begin
    rdStatus := cusUnModified;
    rdRecordNumber := RecNo;
    rdDataBuffer := DataBuffer;
  end;
  Inc(Result,sizeof(TRecordData));
end;

procedure TIBOldBufferPool.Clear;
begin
  inherited Clear;
  FModifiedRecords := 0;
end;

function TIBOldBufferPool.FindOldBufferFor(RecNo: TIBRecordNumber): PByte;
var buffer: PByte;
begin
  Result := nil;
  buffer := GetFirst;
  while (buffer <> nil) do
  begin
    if PRecordData(buffer)^.rdRecordNumber = RecNo then
    begin
      Result := buffer;
      break;
    end;
    buffer := GetNextBuffer(buffer);
  end;
end;

function TIBOldBufferPool.GetBuffer(RecNo: TIBRecordNumber): PByte;
begin
  Result := inherited GetBuffer(RecNo);
  if Result <> nil then
    Inc(Result,sizeof(TRecordData));
end;

function TIBOldBufferPool.GetRecNo(aBuffer: PByte): TIBRecordNumber;
begin
  Result := inherited GetRecNo(aBuffer - sizeof(TRecordData));
end;

function TIBOldBufferPool.GetStatus(aBuffer: PByte): TCachedUpdateStatus;
begin
  Dec(aBuffer,sizeof(TRecordData));
  CheckValidBuffer(aBuffer);
  Result := PRecordData(aBuffer)^.rdStatus;
end;

function TIBOldBufferPool.GetStatus(RecNo: TIBRecordNumber
  ): TCachedUpdateStatus;
var buffer: PByte;
begin
  buffer := GetFirst;
  while (buffer <> nil) do
  begin
    if PRecordData(buffer)^.rdRecordNumber = RecNo then
        break;
    buffer := GetNextBuffer(buffer);
  end;
  if Buffer = nil then
    Result := cusUnmodified
  else
    Result := PRecordData(buffer)^.rdStatus
end;

procedure TIBOldBufferPool.SetStatus(aBuffer: PByte;
  status: TCachedUpdateStatus);
begin
  CheckValidBuffer(aBuffer);
  Dec(aBuffer,sizeof(TRecordData));
  if PRecordData(aBuffer)^.rdStatus <> status then
  begin
    PRecordData(aBuffer)^.rdStatus := status;
    case status of
    cusUnmodified:
      Inc(FModifiedRecords);
    else
      Dec(FModifiedRecords);
    end;
  end;
end;

procedure TIBOldBufferPool.SetDataBuffer(aBuffer: PByte; aDataBuffer: PByte);
begin
  Dec(aBuffer,sizeof(TRecordData));
  CheckValidBuffer(aBuffer);
  PRecordData(aBuffer)^.rdDataBuffer := aDataBuffer;
end;

procedure TIBOldBufferPool.ForwardIterator(iterator: TIterator);
var buf: PByte;
begin
  buf := GetFirst;
  while (buf <> nil) do
    with PRecordData(buf)^ do
    begin
      if rdStatus <> cusUnModified then
        iterator(rdStatus,rdDataBuffer,buf + sizeof(TRecordData));
      buf := GetNextBuffer(buf);
    end;
end;

procedure TIBOldBufferPool.BackwardsIterator(iterator: TIterator);
var buf: PByte;
begin
  buf := GetLast;
  while (buf <> nil) do
    with PRecordData(buf)^ do
    begin
      if rdStatus <> cusUnModified then
        iterator(rdStatus,rdDataBuffer,buf + sizeof(TRecordData));
      buf := GetPriorBuffer(buf);
    end;
end;

{ TIBDSBlobStream }

procedure TIBDSBlobStream.FieldChanged;
begin
  TBlobField(FField).Modified := true;
  THackedField(FField).DataChanged;
end;

function TIBDSBlobStream.GetSize: Int64;
begin
  Result := FBlobStream.BlobSize;
end;

constructor TIBDSBlobStream.Create(AField: TField; ABlobStream: TIBBlobStream;
                                    Mode: TBlobStreamMode);
begin
  FField := AField;
  FBlobStream := ABlobStream;
  FBlobStream.Seek(0, soFromBeginning);
  if (Mode = bmWrite) then
  begin
    FBlobStream.Truncate;
    FieldChanged;
    FHasWritten := true;
  end;
end;

destructor TIBDSBlobStream.Destroy;
begin
  if FHasWritten then
    FieldChanged;
  inherited Destroy;
end;

function TIBDSBlobStream.Read(var Buffer; Count: Longint): Longint;
begin
  result := FBlobStream.Read(Buffer, Count);
end;

function TIBDSBlobStream.Seek(Offset: Longint; Origin: Word): Longint;
begin
  result := FBlobStream.Seek(Offset, Origin);
end;

procedure TIBDSBlobStream.SetSize(NewSize: Longint);
begin
  FBlobStream.SetSize(NewSize);
end;

function TIBDSBlobStream.Write(const Buffer; Count: Longint): Longint;
begin
  if not (FField.DataSet.State in [dsEdit, dsInsert]) then
    IBError(ibxeNotEditing, [nil]);
  FieldChanged;
  result := FBlobStream.Write(Buffer, Count);
  FHasWritten := true;
end;

end.

Revision:	410
Committed:	Thu Jun 22 13:52:39 2023 UTC (17 months ago) by tony
Content type:	text/x-pascal
File size:	110668 byte(s)
Log Message:	Release 2.6.0 beta