ViewVC Help

View File | Revision Log | Show Annotations | Download File | View Changeset | Root Listing

root/public/ibx/trunk/runtime/IBCustomDataSet.pas

Comparing ibx/trunk/runtime/IBCustomDataSet.pas (file contents):
Revision 35 by tony, Tue Jan 26 14:38:47 2016 UTC vs.
Revision 105 by tony, Thu Jan 18 14:37:32 2018 UTC

#	Line 35 | Line 35 | unit IBCustomDataSet;
35
36		{$R-}
37
38	+	{$IFDEF FPC}
39		{$Mode Delphi}
40	+	{$codepage UTF8}
41	+	{$ENDIF}
42
43		{$IFDEF DELPHI}
44		{$DEFINE TDBDFIELD_IS_BCD}
#	Line 49 | Line 52 | uses
52		{$ELSE}
53		unix,
54		{$ENDIF}
55	<	SysUtils, Classes, IBDatabase, IBExternals, IB, IBHeader,  IBSQL, Db,
56	<	IBUtils, IBBlob, IBSQLParser;
55	>	SysUtils, Classes, IBDatabase, IBExternals, IB,  IBSQL, Db,
56	>	IBUtils, IBBlob, IBSQLParser, IBDatabaseInfo;
57
58		const
59		BufferCacheSize    =  1000;  { Allocate cache in this many record chunks}
#	Line 71 | Line 74 | type
74		procedure SetDataSet(ADataSet: TIBCustomDataSet); virtual; abstract;
75		procedure Apply(UpdateKind: TUpdateKind; buff: PChar); virtual; abstract;
76		function GetSQL(UpdateKind: TUpdateKind): TStrings; virtual; abstract;
77	<	procedure InternalSetParams(Query: TIBSQL; buff: PChar);
77	>	procedure InternalSetParams(Params: ISQLParams; buff: PChar); overload;
78	>	procedure InternalSetParams(Query: TIBSQL; buff: PChar); overload;
79	>	procedure UpdateRecordFromQuery(QryResults: IResults; Buffer: PChar);
80		property DataSet: TIBCustomDataSet read GetDataSet write SetDataSet;
81		public
82		constructor Create(AOwner: TComponent); override;
#	Line 82 | Line 87 | type
87
88		TBlobDataArray = array[0..0] of TIBBlobStream;
89		PBlobDataArray = ^TBlobDataArray;
90	+	TIBArrayField = class;
91
92	<	{ TIBCustomDataSet }
93	<	TFieldData = record
94	<	fdDataType: Short;
95	<	fdDataScale: Short;
96	<	fdNullable: Boolean;
97	<	fdIsNull: Boolean;
98	<	fdDataSize: Short;
99	<	fdDataLength: Short;
100	<	fdDataOfs: Integer;
92	>	{ TIBArray }
93	>
94	>	{Wrapper class to support array cache in TIBCustomDataset and event handling}
95	>
96	>	TIBArray = class
97	>	private
98	>	FArray: IArray;
99	>	FRecNo: integer;
100	>	FField: TIBArrayField;
101	>	procedure EventHandler(Sender: IArray; Reason: TArrayEventReason);
102	>	public
103	>	constructor Create(aField: TIBArrayField; anArray: IArray);
104	>	destructor Destroy; override;
105	>	property ArrayIntf: IArray read FArray;
106		end;
107	<	PFieldData = ^TFieldData;
107	>
108	>	TArrayDataArray = array [0..0] of TIBArray;
109	>	PArrayDataArray = ^TArrayDataArray;
110	>
111	>	{ TIBCustomDataSet }
112
113		TCachedUpdateStatus = (
114		cusUnmodified, cusModified, cusInserted,
#	Line 104 | Line 119 | type
119		end;
120		PIBDBKey = ^TIBDBKey;
121
122	+	PFieldData = ^TFieldData;
123	+	TFieldData = record
124	+	fdIsNull: Boolean;
125	+	fdDataLength: Short;
126	+	end;
127	+
128	+	PColumnData = ^TColumnData;
129	+	TColumnData = record
130	+	fdDataType: Short;
131	+	fdDataScale: Short;
132	+	fdNullable: Boolean;
133	+	fdDataSize: Short;
134	+	fdDataOfs: Integer;
135	+	fdCodePage: TSystemCodePage;
136	+	end;
137	+
138	+	PFieldColumns = ^TFieldColumns;
139	+	TFieldColumns =  array[1..1] of TColumnData;
140	+
141		TRecordData = record
142		rdBookmarkFlag: TBookmarkFlag;
143		rdFieldCount: Short;
#	Line 116 | Line 150 | type
150		end;
151		PRecordData = ^TRecordData;
152
153	+	{ TIBArrayField }
154	+
155	+	TIBArrayField = class(TField)
156	+	private
157	+	FArrayBounds: TArrayBounds;
158	+	FArrayDimensions: integer;
159	+	FRelationName: string;
160	+	FCacheOffset: word;
161	+	function GetArrayID: TISC_QUAD;
162	+	function GetArrayIntf: IArray;
163	+	procedure SetArrayIntf(AValue: IArray);
164	+	protected
165	+	class procedure CheckTypeSize(AValue: Longint); override;
166	+	function GetAsString: string; override;
167	+	function GetDataSize: Integer; override;
168	+	procedure Bind(Binding: Boolean); override;
169	+	public
170	+	constructor Create(AOwner: TComponent); override;
171	+	function CreateArray: IArray;
172	+	property ArrayID: TISC_QUAD read GetArrayID;
173	+	property ArrayIntf: IArray read GetArrayIntf write SetArrayIntf;
174	+	property ArrayDimensions: integer read FArrayDimensions write FArrayDimensions;
175	+	property ArrayBounds: TArrayBounds read FArrayBounds write FArrayBounds;
176	+	end;
177	+
178		{ TIBStringField allows us to have strings longer than 8196 }
179
180		TIBStringField = class(TStringField)
181		private
182	<	FCharacterSetName: string;
182	>	FCharacterSetName: RawByteString;
183		FCharacterSetSize: integer;
184	+	FAutoFieldSize: boolean;
185	+	FCodePage: TSystemCodePage;
186	+	FDataSize: integer;
187		protected
188	<	function GetDefaultWidth: Longint; override;
188	>	procedure Bind(Binding: Boolean); override;
189	>	function GetDataSize: Integer; override;
190		public
191		constructor Create(aOwner: TComponent); override;
192		class procedure CheckTypeSize(Value: Integer); override;
#	Line 131 | Line 194 | type
194		function GetAsVariant: Variant; override;
195		function GetValue(var Value: string): Boolean;
196		procedure SetAsString(const Value: string); override;
197	<	property CharacterSetName: string read FCharacterSetName write FCharacterSetName;
135	<	property CharacterSetSize: integer read FCharacterSetSize write FCharacterSetSize;
136	<	end;
137	<
138	<	{ TIBWideStringField }
139	<
140	<	TIBWideStringField = class(TWideStringField)
141	<	private
142	<	FCharacterSetName: string;
143	<	FCharacterSetSize: integer;
144	<	public
145	<	property CharacterSetName: string read FCharacterSetName write FCharacterSetName;
197	>	property CharacterSetName: RawByteString read FCharacterSetName write FCharacterSetName;
198		property CharacterSetSize: integer read FCharacterSetSize write FCharacterSetSize;
199	+	property CodePage: TSystemCodePage read FCodePage write FCodePage;
200	+	published
201	+	property AutoFieldSize: boolean read FAutoFieldSize write FAutoFieldSize default true;
202		end;
203
204		{ TIBBCDField }
#	Line 154 | Line 209 | type
209		Note: y > 4 will default to Floats
210		}
211		TIBBCDField = class(TBCDField)
212	+	private
213	+	FIdentityColumn: boolean;
214		protected
215	+	procedure Bind(Binding: Boolean); override;
216		class procedure CheckTypeSize(Value: Integer); override;
217		function GetAsCurrency: Currency; override;
218		function GetAsString: string; override;
#	Line 162 | Line 220 | type
220		function GetDataSize: Integer; override;
221		public
222		constructor Create(AOwner: TComponent); override;
223	+	property IdentityColumn: boolean read FIdentityColumn;
224		published
225		property Size default 8;
226		end;
227
228	+	{The following integer field types extend the built in versions to enable IBX appplications
229	+	to check for an Identity column}
230	+
231	+	{ TIBSmallintField }
232	+
233	+	TIBSmallintField = class(TSmallintField)
234	+	private
235	+	FIdentityColumn: boolean;
236	+	protected
237	+	procedure Bind(Binding: Boolean); override;
238	+	public
239	+	property IdentityColumn: boolean read FIdentityColumn;
240	+	end;
241	+
242	+	{ TIBIntegerField }
243	+
244	+	TIBIntegerField = class(TIntegerField)
245	+	private
246	+	FIdentityColumn: boolean;
247	+	protected
248	+	procedure Bind(Binding: Boolean); override;
249	+	public
250	+	property IdentityColumn: boolean read FIdentityColumn;
251	+	end;
252	+
253	+	{ TIBLargeIntField }
254	+
255	+	TIBLargeIntField = class(TLargeIntField)
256	+	private
257	+	FIdentityColumn: boolean;
258	+	protected
259	+	procedure Bind(Binding: Boolean); override;
260	+	public
261	+	property IdentityColumn: boolean read FIdentityColumn;
262	+	end;
263	+
264		{TIBMemoField}
265		{Allows us to show truncated text in DBGrids and anything else that uses
266		DisplayText}
267
268		TIBMemoField = class(TMemoField)
269		private
270	<	FCharacterSetName: string;
270	>	FCharacterSetName: RawByteString;
271		FCharacterSetSize: integer;
272		FDisplayTextAsClassName: boolean;
273		function GetTruncatedText: string;
274		protected
275	+	procedure Bind(Binding: Boolean); override;
276	+	function GetAsString: string; override;
277		function GetDefaultWidth: Longint; override;
278		procedure GetText(var AText: string; ADisplayText: Boolean); override;
279	+	procedure SetAsString(const AValue: string); override;
280		public
281		constructor Create(AOwner: TComponent); override;
282	<	property CharacterSetName: string read FCharacterSetName write FCharacterSetName;
282	>	property CharacterSetName: RawByteString read FCharacterSetName write FCharacterSetName;
283		property CharacterSetSize: integer read FCharacterSetSize write FCharacterSetSize;
284	<	published
284	>	published
285		property DisplayTextAsClassName: boolean read FDisplayTextAsClassName
286		write FDisplayTextAsClassName;
189	–	end;
190	–
191	–	{ TIBWideMemoField }
192	–
193	–	TIBWideMemoField = class(TWideMemoField)
287		private
288	<	FCharacterSetName: string;
289	<	FCharacterSetSize: integer;
197	<	FDisplayTextAsClassName: boolean;
198	<	function GetTruncatedText: string;
199	<	protected
200	<	function GetDefaultWidth: Longint; override;
201	<	procedure GetText(var AText: string; ADisplayText: Boolean); override;
288	>	FCodePage: TSystemCodePage;
289	>	FFCodePage: TSystemCodePage;
290		public
291	<	constructor Create(AOwner: TComponent); override;
204	<	property CharacterSetName: string read FCharacterSetName write FCharacterSetName;
205	<	property CharacterSetSize: integer read FCharacterSetSize write FCharacterSetSize;
206	<	published
207	<	property DisplayTextAsClassName: boolean read FDisplayTextAsClassName
208	<	write FDisplayTextAsClassName;
291	>	property CodePage: TSystemCodePage read FFCodePage write FFCodePage;
292		end;
293
294		TIBDataLink = class(TDetailDataLink)
#	Line 232 | Line 315 | type
315		FFieldName: string;
316		FGeneratorName: string;
317		FIncrement: integer;
318	+	FQuery: TIBSQL;
319	+	function GetDatabase: TIBDatabase;
320	+	function GetTransaction: TIBTransaction;
321	+	procedure SetDatabase(AValue: TIBDatabase);
322	+	procedure SetGeneratorName(AValue: string);
323		procedure SetIncrement(const AValue: integer);
324	+	procedure SetTransaction(AValue: TIBTransaction);
325	+	procedure SetQuerySQL;
326		protected
327	<	function GetNextValue(ADatabase: TIBDatabase; ATransaction: TIBTransaction): integer;
327	>	function GetNextValue: integer;
328		public
329		constructor Create(Owner: TIBCustomDataSet);
330	+	destructor Destroy; override;
331		procedure Apply;
332		property Owner: TIBCustomDataSet read FOwner;
333	+	property Database: TIBDatabase read GetDatabase write SetDatabase;
334	+	property Transaction: TIBTransaction read GetTransaction write SetTransaction;
335		published
336	<	property Generator: string read FGeneratorName write FGeneratorName;
336	>	property Generator: string read FGeneratorName write SetGeneratorName;
337		property Field: string read FFieldName write FFieldName;
338		property Increment: integer read FIncrement write SetIncrement default 1;
339		property ApplyOnEvent: TIBGeneratorApplyOnEvent read FApplyOnEvent write FApplyOnEvent;
#	Line 263 | Line 356 | type
356		TIBAutoCommit = (acDisabled, acCommitRetaining);
357
358		{ TIBCustomDataSet }
359	+
360		TIBUpdateAction = (uaFail, uaAbort, uaSkip, uaRetry, uaApply, uaApplied);
361
362		TIBUpdateErrorEvent = procedure(DataSet: TDataSet; E: EDatabaseError;
#	Line 279 | Line 373 | type
373
374		TIBCustomDataSet = class(TDataset)
375		private
376	+	FAllowAutoActivateTransaction: Boolean;
377	+	FArrayFieldCount: integer;
378	+	FArrayCacheOffset: integer;
379		FAutoCommit: TIBAutoCommit;
380		FGenerateParamNames: Boolean;
381		FGeneratorField: TIBGenerator;
382		FNeedsRefresh: Boolean;
383		FForcedRefresh: Boolean;
384		FDidActivate: Boolean;
288	–	FIBLoaded: Boolean;
385		FBase: TIBBase;
386		FBlobCacheOffset: Integer;
387		FBlobStreamList: TList;
388	+	FArrayList: TList;
389		FBufferChunks: Integer;
390		FBufferCache,
391		FOldBufferCache: PChar;
#	Line 314 | Line 411 | type
411		FQRefresh,
412		FQSelect,
413		FQModify: TIBSQL;
414	+	FDatabaseInfo: TIBDatabaseInfo;
415		FRecordBufferSize: Integer;
416		FRecordCount: Integer;
417		FRecordSize: Integer;
#	Line 342 | Line 440 | type
440		FCloseAction: TTransactionAction;
441		FInTransactionEnd: boolean;
442		FIBLinks: TList;
443	<	function GetSelectStmtHandle: TISC_STMT_HANDLE;
443	>	FFieldColumns: PFieldColumns;
444	>	procedure ColumnDataToBuffer(QryResults: IResults; ColumnIndex,
445	>	FieldIndex: integer; Buffer: PChar);
446	>	procedure InitModelBuffer(Qry: TIBSQL; Buffer: PChar);
447	>	function GetSelectStmtIntf: IStatement;
448		procedure SetUpdateMode(const Value: TUpdateMode);
449		procedure SetUpdateObject(Value: TIBDataSetUpdateObject);
450
#	Line 354 | Line 456 | type
456		function CanRefresh: Boolean;
457		procedure CheckEditState;
458		procedure ClearBlobCache;
459	+	procedure ClearArrayCache;
460		procedure ClearIBLinks;
461		procedure CopyRecordBuffer(Source, Dest: Pointer);
462		procedure DoBeforeDatabaseDisconnect(Sender: TObject);
#	Line 365 | Line 468 | type
468		procedure FetchCurrentRecordToBuffer(Qry: TIBSQL; RecordNumber: Integer;
469		Buffer: PChar);
470		function GetDatabase: TIBDatabase;
368	–	function GetDBHandle: PISC_DB_HANDLE;
471		function GetDeleteSQL: TStrings;
472		function GetInsertSQL: TStrings;
473	<	function GetSQLParams: TIBXSQLDA;
473	>	function GetSQLParams: ISQLParams;
474		function GetRefreshSQL: TStrings;
475		function GetSelectSQL: TStrings;
476	<	function GetStatementType: TIBSQLTypes;
476	>	function GetStatementType: TIBSQLStatementTypes;
477		function GetModifySQL: TStrings;
478		function GetTransaction: TIBTransaction;
377	–	function GetTRHandle: PISC_TR_HANDLE;
479		function GetParser: TSelectSQLParser;
480		procedure InternalDeleteRecord(Qry: TIBSQL; Buff: Pointer); virtual;
481		function InternalLocate(const KeyFields: string; const KeyValues: Variant;
#	Line 389 | Line 490 | type
490		procedure SetDatabase(Value: TIBDatabase);
491		procedure SetDeleteSQL(Value: TStrings);
492		procedure SetInsertSQL(Value: TStrings);
493	<	procedure SetInternalSQLParams(Qry: TIBSQL; Buffer: Pointer);
493	>	procedure SetInternalSQLParams(Params: ISQLParams; Buffer: Pointer);
494		procedure SetRefreshSQL(Value: TStrings);
495		procedure SetSelectSQL(Value: TStrings);
496		procedure SetModifySQL(Value: TStrings);
497		procedure SetTransaction(Value: TIBTransaction);
498		procedure SetUpdateRecordTypes(Value: TIBUpdateRecordTypes);
499		procedure SetUniDirectional(Value: Boolean);
500	+	procedure UpdateRecordFromQuery(QryResults: IResults; Buffer: PChar);
501		procedure RefreshParams;
502		function AdjustPosition(FCache: PChar; Offset: DWORD;
503		Origin: Integer): DWORD;
#	Line 429 | Line 531 | type
531		procedure SQLChanging(Sender: TObject); virtual;
532		procedure SQLChanged(Sender: TObject); virtual;
533
534	<	(*    { IProviderSupport }
534	>	{ IProviderSupport }
535		procedure PSEndTransaction(Commit: Boolean); override;
536		function PSExecuteStatement(const ASQL: string; AParams: TParams;
537		ResultSet: Pointer = nil): Integer; override;
#	Line 442 | Line 544 | type
544		procedure PSStartTransaction; override;
545		procedure PSReset; override;
546		function PSUpdateRecord(UpdateKind: TUpdateKind; Delta: TDataSet): Boolean; override;
547	<	*)
547	>
548		{ TDataSet support }
549		procedure InternalInsert; override;
550		procedure InitRecord(Buffer: PChar); override;
#	Line 506 | Line 608 | type
608		protected
609		{Likely to be made public by descendant classes}
610		property AutoCommit: TIBAutoCommit read FAutoCommit write FAutoCommit default acDisabled;
611	<	property SQLParams: TIBXSQLDA read GetSQLParams;
612	<	property Params: TIBXSQLDA read GetSQLParams;
611	>	property SQLParams: ISQLParams read GetSQLParams;
612	>	property Params: ISQLParams read GetSQLParams;
613		property InternalPrepared: Boolean read FInternalPrepared;
614		property QDelete: TIBSQL read FQDelete;
615		property QInsert: TIBSQL read FQInsert;
616		property QRefresh: TIBSQL read FQRefresh;
617		property QSelect: TIBSQL read FQSelect;
618		property QModify: TIBSQL read FQModify;
619	<	property StatementType: TIBSQLTypes read GetStatementType;
620	<	property SelectStmtHandle: TISC_STMT_HANDLE read GetSelectStmtHandle;
619	>	property StatementType: TIBSQLStatementTypes read GetStatementType;
620	>	property SelectStmtHandle: IStatement read GetSelectStmtIntf;
621
622		{Likely to be made published by descendant classes}
623		property BufferChunks: Integer read FBufferChunks write SetBufferChunks;
#	Line 566 | Line 668 | type
668		function BookmarkValid(Bookmark: TBookmark): Boolean; override;
669		function CompareBookmarks(Bookmark1, Bookmark2: TBookmark): Integer; override;
670		function CreateBlobStream(Field: TField; Mode: TBlobStreamMode): TStream; override;
671	+	function GetArray(Field: TIBArrayField): IArray;
672	+	procedure SetArrayIntf(AnArray: IArray; Field: TIBArrayField);
673		function GetCurrentRecord(Buffer: PChar): Boolean; override;
674		function GetFieldData(Field : TField; Buffer : Pointer) : Boolean; overload; override;
675		function GetFieldData(FieldNo: Integer; Buffer: Pointer): Boolean; overload; (*override;*)
#	Line 579 | Line 683 | type
683		function UpdateStatus: TUpdateStatus; override;
684		function IsSequenced: Boolean; override;
685		procedure Post; override;
686	<	function ParamByName(ParamName: String): TIBXSQLVAR;
687	<	property DBHandle: PISC_DB_HANDLE read GetDBHandle;
584	<	property TRHandle: PISC_TR_HANDLE read GetTRHandle;
686	>	function ParamByName(ParamName: String): ISQLParam;
687	>	property ArrayFieldCount: integer read FArrayFieldCount;
688		property UpdateObject: TIBDataSetUpdateObject read FUpdateObject write SetUpdateObject;
689		property UpdatesPending: Boolean read FUpdatesPending;
690		property UpdateRecordTypes: TIBUpdateRecordTypes read FUpdateRecordTypes
#	Line 590 | Line 693 | type
693		read FDataSetCloseAction write FDataSetCloseAction;
694
695		published
696	+	property AllowAutoActivateTransaction: Boolean read FAllowAutoActivateTransaction
697	+	write FAllowAutoActivateTransaction;
698		property Database: TIBDatabase read GetDatabase write SetDatabase;
699		property Transaction: TIBTransaction read GetTransaction
700		write SetTransaction;
#	Line 719 | Line 824 | type
824		protected
825		FField: TField;
826		FBlobStream: TIBBlobStream;
827	+	function  GetSize: Int64; override;
828		public
829		constructor Create(AField: TField; ABlobStream: TIBBlobStream;
830		Mode: TBlobStreamMode);
#	Line 729 | Line 835 | type
835		function Write(const Buffer; Count: Longint): Longint; override;
836		end;
837
838	+	{Extended Field Def for character set info}
839	+
840	+	{ TIBFieldDef }
841	+
842	+	TIBFieldDef = class(TFieldDef)
843	+	private
844	+	FArrayBounds: TArrayBounds;
845	+	FArrayDimensions: integer;
846	+	FCharacterSetName: RawByteString;
847	+	FCharacterSetSize: integer;
848	+	FCodePage: TSystemCodePage;
849	+	FIdentityColumn: boolean;
850	+	FRelationName: string;
851	+	FDataSize: integer;
852	+	published
853	+	property CharacterSetName: RawByteString read FCharacterSetName write FCharacterSetName;
854	+	property CharacterSetSize: integer read FCharacterSetSize write FCharacterSetSize;
855	+	property CodePage: TSystemCodePage read FCodePage write FCodePage;
856	+	property DataSize: integer read FDataSize write FDataSize;
857	+	property RelationName: string read FRelationName write FRelationName;
858	+	property ArrayDimensions: integer read FArrayDimensions write FArrayDimensions;
859	+	property ArrayBounds: TArrayBounds read FArrayBounds write FArrayBounds;
860	+	property IdentityColumn: boolean read FIdentityColumn write FIdentityColumn default false;
861	+	end;
862	+
863		const
864		DefaultFieldClasses: array[TFieldType] of TFieldClass = (
865		nil,                { ftUnknown }
866		TIBStringField,     { ftString }
867	<	TSmallintField,     { ftSmallint }
868	<	TIntegerField,      { ftInteger }
867	>	TIBSmallintField,   { ftSmallint }
868	>	TIBIntegerField,      { ftInteger }
869		TWordField,         { ftWord }
870		TBooleanField,      { ftBoolean }
871		TFloatField,        { ftFloat }
#	Line 755 | Line 886 | DefaultFieldClasses: array[TFieldType] o
886		TBlobField,         { ftTypedBinary }
887		nil,                { ftCursor }
888		TStringField,       { ftFixedChar }
889	<	TIBWideStringField,    { ftWideString }
890	<	TLargeIntField,     { ftLargeInt }
889	>	nil,    { ftWideString }
890	>	TIBLargeIntField,     { ftLargeInt }
891		nil,          { ftADT }
892	<	nil,        { ftArray }
892	>	TIBArrayField,        { ftArray }
893		nil,    { ftReference }
894		nil,     { ftDataSet }
895		TBlobField,         { ftOraBlob }
#	Line 770 | Line 901 | DefaultFieldClasses: array[TFieldType] o
901		TDateTimeField,    {ftTimestamp}
902		TIBBCDField,       {ftFMTBcd}
903		nil,  {ftFixedWideChar}
904	<	TIBWideMemoField);   {ftWideMemo}
904	>	nil);   {ftWideMemo}
905		(*
906		TADTField,          { ftADT }
907		TArrayField,        { ftArray }
#	Line 787 | Line 918 | DefaultFieldClasses: array[TFieldType] o
918
919		implementation
920
921	<	uses IBIntf, Variants, FmtBCD, LCLProc, LazUTF8;
921	>	uses Variants, FmtBCD, LazUTF8, FBMessages, IBQuery;
922
923		const FILE_BEGIN = 0;
924		FILE_CURRENT = 1;
#	Line 800 | Line 931 | type
931		FieldName : String;
932		COMPUTED_BLR : Boolean;
933		DEFAULT_VALUE : boolean;
934	+	IDENTITY_COLUMN : boolean;
935		NextField : TFieldNode;
936		end;
937
#	Line 810 | Line 942 | type
942		NextRelation : TRelationNode;
943		end;
944
813	–	{Extended Field Def for character set info}
945
946	<	{ TIBFieldDef }
946	>	{  Copied from LCLProc in order to avoid LCL dependency
947
948	<	TIBFieldDef = class(TFieldDef)
949	<	private
950	<	FCharacterSetName: string;
951	<	FCharacterSetSize: integer;
952	<	published
953	<	property CharacterSetName: string read FCharacterSetName write FCharacterSetName;
954	<	property CharacterSetSize: integer read FCharacterSetSize write FCharacterSetSize;
948	>	Ensures the covenient look of multiline string
949	>	when displaying it in the single line
950	>	* Replaces CR and LF with spaces
951	>	* Removes duplicate spaces
952	>	}
953	>	function TextToSingleLine(const AText: string): string;
954	>	var
955	>	str: string;
956	>	i, wstart, wlen: Integer;
957	>	begin
958	>	str := Trim(AText);
959	>	wstart := 0;
960	>	wlen := 0;
961	>	i := 1;
962	>	while i < Length(str) - 1 do
963	>	begin
964	>	if (str[i] in [' ', #13, #10]) then
965	>	begin
966	>	if (wstart = 0) then
967	>	begin
968	>	wstart := i;
969	>	wlen := 1;
970	>	end else
971	>	Inc(wlen);
972	>	end else
973	>	begin
974	>	if wstart > 0 then
975	>	begin
976	>	str[wstart] := ' ';
977	>	Delete(str, wstart+1, wlen-1);
978	>	Dec(i, wlen-1);
979	>	wstart := 0;
980	>	end;
981	>	end;
982	>	Inc(i);
983	>	end;
984	>	Result := str;
985		end;
986
987	<	{ TIBWideMemoField }
987	>	{ TIBLargeIntField }
988
989	<	function TIBWideMemoField.GetTruncatedText: string;
989	>	procedure TIBLargeIntField.Bind(Binding: Boolean);
990		begin
991	<	Result := GetAsString;
991	>	inherited Bind(Binding);
992	>	if Binding and (FieldDef <> nil) then
993	>	FIdentityColumn := (FieldDef as TIBFieldDef).IdentityColumn;
994	>	end;
995
996	<	if Result <> '' then
997	<	if DisplayWidth = 0 then
998	<	Result := TextToSingleLine(Result)
999	<	else
1000	<	if Length(Result) > DisplayWidth then {Show truncation with elipses}
1001	<	Result := TextToSingleLine(system.copy(Result,1,DisplayWidth-3)) + '...';
996	>	{ TIBIntegerField }
997	>
998	>	procedure TIBIntegerField.Bind(Binding: Boolean);
999	>	begin
1000	>	inherited Bind(Binding);
1001	>	if Binding and (FieldDef <> nil) then
1002	>	FIdentityColumn := (FieldDef as TIBFieldDef).IdentityColumn;
1003		end;
1004
1005	<	function TIBWideMemoField.GetDefaultWidth: Longint;
1005	>	{ TIBSmallintField }
1006	>
1007	>	procedure TIBSmallintField.Bind(Binding: Boolean);
1008		begin
1009	<	Result := 128;
1009	>	inherited Bind(Binding);
1010	>	if Binding and (FieldDef <> nil) then
1011	>	FIdentityColumn := (FieldDef as TIBFieldDef).IdentityColumn;
1012		end;
1013
1014	<	procedure TIBWideMemoField.GetText(var AText: string; ADisplayText: Boolean);
1014	>	{ TIBArray }
1015	>
1016	>	procedure TIBArray.EventHandler(Sender: IArray; Reason: TArrayEventReason);
1017		begin
1018	<	if ADisplayText then
1018	>	case Reason of
1019	>	arChanging:
1020	>	if FRecNo <> FField.Dataset.RecNo then
1021	>	IBError(ibxeNotCurrentArray,[nil]);
1022	>
1023	>	arChanged:
1024	>	FField.DataChanged;
1025	>	end;
1026	>	end;
1027	>
1028	>	constructor TIBArray.Create(aField: TIBArrayField; anArray: IArray);
1029	>	begin
1030	>	inherited Create;
1031	>	FField := aField;
1032	>	FArray := anArray;
1033	>	FRecNo := FField.Dataset.RecNo;
1034	>	FArray.AddEventHandler(EventHandler);
1035	>	end;
1036	>
1037	>	destructor TIBArray.Destroy;
1038	>	begin
1039	>	FArray.RemoveEventHandler(EventHandler);
1040	>	inherited Destroy;
1041	>	end;
1042	>
1043	>	{ TIBArrayField }
1044	>
1045	>	function TIBArrayField.GetArrayIntf: IArray;
1046	>	begin
1047	>	Result := TIBCustomDataSet(DataSet).GetArray(self);
1048	>	end;
1049	>
1050	>	function TIBArrayField.GetArrayID: TISC_QUAD;
1051	>	begin
1052	>	GetData(@Result);
1053	>	end;
1054	>
1055	>	procedure TIBArrayField.SetArrayIntf(AValue: IArray);
1056	>	begin
1057	>	TIBCustomDataSet(DataSet).SetArrayIntf(AValue,self);
1058	>	DataChanged;
1059	>	end;
1060	>
1061	>	class procedure TIBArrayField.CheckTypeSize(AValue: Longint);
1062	>	begin
1063	>	//Ignore
1064	>	end;
1065	>
1066	>	function TIBArrayField.GetAsString: string;
1067	>	begin
1068	>	Result := '(Array)';
1069	>	end;
1070	>
1071	>	function TIBArrayField.GetDataSize: Integer;
1072	>	begin
1073	>	Result := sizeof(TISC_QUAD);
1074	>	end;
1075	>
1076	>	procedure TIBArrayField.Bind(Binding: Boolean);
1077	>	begin
1078	>	inherited Bind(Binding);
1079	>	if Binding then
1080		begin
1081	<	if not DisplayTextAsClassName then
1082	<	AText := GetTruncatedText
1083	<	else
1084	<	inherited GetText(AText, ADisplayText);
1085	<	end
1086	<	else
1087	<	AText := GetAsString;
1081	>	FCacheOffset := TIBCustomDataSet(DataSet).ArrayFieldCount;
1082	>	Inc(TIBCustomDataSet(DataSet).FArrayFieldCount);
1083	>	if FieldDef <> nil then
1084	>	begin
1085	>	FRelationName := TIBFieldDef(FieldDef).FRelationName;
1086	>	FArrayDimensions := TIBFieldDef(FieldDef).ArrayDimensions;
1087	>	FArrayBounds :=  TIBFieldDef(FieldDef).ArrayBounds;
1088	>	end;
1089	>	end;
1090		end;
1091
1092	<	constructor TIBWideMemoField.Create(AOwner: TComponent);
1092	>	constructor TIBArrayField.Create(AOwner: TComponent);
1093		begin
1094		inherited Create(AOwner);
1095	<	BlobType := ftWideMemo;
1095	>	SetDataType(ftArray);
1096	>	end;
1097	>
1098	>	function TIBArrayField.CreateArray: IArray;
1099	>	begin
1100	>	with DataSet as TIBCustomDataSet do
1101	>	Result := Database.Attachment.CreateArray(Transaction.TransactionIntf,FRelationName,FieldName);
1102		end;
1103
1104		{ TIBMemoField }
#	Line 880 | Line 1120 | begin
1120		{2: case 2 ignored. This should be handled by TIBWideMemo}
1121
1122		3, {Assume UNICODE_FSS is really UTF8}
1123	<	4: {Include GB18030 - assuming UTF8 routine work for this codeset}
1123	>	4: {Include GB18030 - assuming UTF8 routines work for this codeset}
1124		if DisplayWidth = 0 then
1125		Result := ValidUTF8String(TextToSingleLine(Result))
1126		else
#	Line 890 | Line 1130 | begin
1130		end
1131		end;
1132
1133	+	procedure TIBMemoField.Bind(Binding: Boolean);
1134	+	var IBFieldDef: TIBFieldDef;
1135	+	begin
1136	+	inherited Bind(Binding);
1137	+	if Binding and (FieldDef <> nil) then
1138	+	begin
1139	+	IBFieldDef := FieldDef as TIBFieldDef;
1140	+	CharacterSetSize := IBFieldDef.CharacterSetSize;
1141	+	CharacterSetName := IBFieldDef.CharacterSetName;
1142	+	CodePage := IBFieldDef.CodePage;
1143	+	end;
1144	+	end;
1145	+
1146	+	function TIBMemoField.GetAsString: string;
1147	+	var s: RawByteString;
1148	+	begin
1149	+	s := inherited GetAsString;
1150	+	SetCodePage(s,CodePage,false);
1151	+	if (CodePage <> CP_NONE) and (CodePage <> CP_UTF8) then
1152	+	SetCodePage(s,CP_UTF8,true);  {LCL only accepts UTF8}
1153	+	Result := s;
1154	+	end;
1155	+
1156		function TIBMemoField.GetDefaultWidth: Longint;
1157		begin
1158	<	Result := 128;
1158	>	if DisplayTextAsClassName then
1159	>	Result := inherited
1160	>	else
1161	>	Result := 128;
1162		end;
1163
1164		procedure TIBMemoField.GetText(var AText: string; ADisplayText: Boolean);
1165		begin
1166		if ADisplayText then
1167		begin
1168	<	if not DisplayTextAsClassName then
1168	>	if not DisplayTextAsClassName and (CharacterSetName <> '') then
1169		AText := GetTruncatedText
1170		else
1171		inherited GetText(AText, ADisplayText);
#	Line 908 | Line 1174 | begin
1174		AText := GetAsString;
1175		end;
1176
1177	+	procedure TIBMemoField.SetAsString(const AValue: string);
1178	+	var s: RawByteString;
1179	+	begin
1180	+	s := AValue;
1181	+	if StringCodePage(s) <> CodePage then
1182	+	SetCodePage(s,CodePage,CodePage<>CP_NONE);
1183	+	inherited SetAsString(s);
1184	+	end;
1185	+
1186		constructor TIBMemoField.Create(AOwner: TComponent);
1187		begin
1188		inherited Create(AOwner);
1189		BlobType := ftMemo;
1190	+	FCodePage := CP_NONE;
1191		end;
1192
1193		{ TIBControlLink }
#	Line 945 | Line 1221 | end;
1221
1222		{ TIBStringField}
1223
1224	<	function TIBStringField.GetDefaultWidth: Longint;
1224	>	procedure TIBStringField.Bind(Binding: Boolean);
1225	>	var IBFieldDef: TIBFieldDef;
1226		begin
1227	<	Result := Size div CharacterSetSize;
1227	>	inherited Bind(Binding);
1228	>	if Binding and (FieldDef <> nil) then
1229	>	begin
1230	>	IBFieldDef := FieldDef as TIBFieldDef;
1231	>	CharacterSetSize := IBFieldDef.CharacterSetSize;
1232	>	CharacterSetName := IBFieldDef.CharacterSetName;
1233	>	FDataSize := IBFieldDef.DataSize + 1;
1234	>	if AutoFieldSize then
1235	>	Size := IBFieldDef.Size;
1236	>	CodePage := IBFieldDef.CodePage;
1237	>	end;
1238	>	end;
1239	>
1240	>	function TIBStringField.GetDataSize: Integer;
1241	>	begin
1242	>	Result := FDataSize;
1243		end;
1244
1245		constructor TIBStringField.Create(aOwner: TComponent);
1246		begin
1247		inherited Create(aOwner);
1248		FCharacterSetSize := 1;
1249	+	FCodePage := CP_NONE;
1250	+	FAutoFieldSize := true;
1251		end;
1252
1253		class procedure TIBStringField.CheckTypeSize(Value: Integer);
#	Line 976 | Line 1270 | end;
1270		function TIBStringField.GetValue(var Value: string): Boolean;
1271		var
1272		Buffer: PChar;
1273	+	s: RawByteString;
1274		begin
1275		Buffer := nil;
1276	<	IBAlloc(Buffer, 0, Size + 1);
1276	>	IBAlloc(Buffer, 0, DataSize);
1277		try
1278		Result := GetData(Buffer);
1279		if Result then
1280		begin
1281	<	Value := string(Buffer);
1281	>	s := strpas(Buffer);
1282	>	SetCodePage(s,CodePage,false);
1283	>	if (CodePage <> CP_NONE) and (CodePage <> CP_UTF8) then
1284	>	SetCodePage(s,CP_UTF8,true);  {LCL only accepts UTF8}
1285	>	Value := s;
1286	>	//      writeln(FieldName,': ', StringCodePage(Value),', ',Value);
1287		if Transliterate and (Value <> '') then
1288		DataSet.Translate(PChar(Value), PChar(Value), False);
1289		end
#	Line 995 | Line 1295 | end;
1295		procedure TIBStringField.SetAsString(const Value: string);
1296		var
1297		Buffer: PChar;
1298	+	s: RawByteString;
1299		begin
1300		Buffer := nil;
1301	<	IBAlloc(Buffer, 0, Size + 1);
1301	>	IBAlloc(Buffer, 0, DataSize);
1302		try
1303	<	StrLCopy(Buffer, PChar(Value), Size);
1303	>	s := Value;
1304	>	if StringCodePage(s) <> CodePage then
1305	>	SetCodePage(s,CodePage,CodePage<>CP_NONE);
1306	>	StrLCopy(Buffer, PChar(s), DataSize-1);
1307		if Transliterate then
1308		DataSet.Translate(Buffer, Buffer, True);
1309		SetData(Buffer);
#	Line 1018 | Line 1322 | begin
1322		Size := 8;
1323		end;
1324
1325	+	procedure TIBBCDField.Bind(Binding: Boolean);
1326	+	begin
1327	+	inherited Bind(Binding);
1328	+	if Binding and (FieldDef <> nil) then
1329	+	FIdentityColumn := (FieldDef as TIBFieldDef).IdentityColumn;
1330	+	end;
1331	+
1332		class procedure TIBBCDField.CheckTypeSize(Value: Integer);
1333		begin
1334		{ No need to check as the base type is currency, not BCD }
#	Line 1102 | Line 1413 | end;
1413		constructor TIBCustomDataSet.Create(AOwner: TComponent);
1414		begin
1415		inherited Create(AOwner);
1105	–	FIBLoaded := False;
1106	–	CheckIBLoaded;
1107	–	FIBLoaded := True;
1416		FBase := TIBBase.Create(Self);
1417	+	FDatabaseInfo := TIBDatabaseInfo.Create(self);
1418		FIBLinks := TList.Create;
1419		FCurrentRecord := -1;
1420		FDeletedRecords := 0;
1421		FUniDirectional := False;
1422		FBufferChunks := BufferCacheSize;
1423		FBlobStreamList := TList.Create;
1424	+	FArrayList := TList.Create;
1425		FGeneratorField := TIBGenerator.Create(self);
1426		FDataLink := TIBDataLink.Create(Self);
1427		FQDelete := TIBSQL.Create(Self);
#	Line 1155 | Line 1465 | end;
1465		destructor TIBCustomDataSet.Destroy;
1466		begin
1467		if Active then Active := false;
1468	<	if FIBLoaded then
1469	<	begin
1470	<	if assigned(FGeneratorField) then FGeneratorField.Free;
1471	<	FDataLink.Free;
1472	<	FBase.Free;
1473	<	ClearBlobCache;
1474	<	ClearIBLinks;
1475	<	FIBLinks.Free;
1476	<	FBlobStreamList.Free;
1477	<	FreeMem(FBufferCache);
1478	<	FBufferCache := nil;
1479	<	FreeMem(FOldBufferCache);
1480	<	FOldBufferCache := nil;
1481	<	FCacheSize := 0;
1482	<	FOldCacheSize := 0;
1173	<	FMappedFieldPosition := nil;
1174	<	end;
1468	>	if assigned(FGeneratorField) then FGeneratorField.Free;
1469	>	FDataLink.Free;
1470	>	FBase.Free;
1471	>	ClearBlobCache;
1472	>	ClearIBLinks;
1473	>	FIBLinks.Free;
1474	>	FBlobStreamList.Free;
1475	>	FArrayList.Free;
1476	>	FreeMem(FBufferCache);
1477	>	FBufferCache := nil;
1478	>	FreeMem(FOldBufferCache);
1479	>	FOldBufferCache := nil;
1480	>	FCacheSize := 0;
1481	>	FOldCacheSize := 0;
1482	>	FMappedFieldPosition := nil;
1483		if assigned(FBaseSQLSelect) then FBaseSQLSelect.Free;
1484		if assigned(FParser) then FParser.Free;
1485		inherited Destroy;
#	Line 1196 | Line 1504 | begin
1504		Inc(FCurrentRecord);
1505		if (FCurrentRecord = FRecordCount) then
1506		begin
1507	<	if (not FQSelect.EOF) and (FQSelect.Next <> nil) then
1507	>	if (not FQSelect.EOF) and FQSelect.Next  then
1508		begin
1509		FetchCurrentRecordToBuffer(FQSelect, FCurrentRecord, Buffer);
1510		Inc(FRecordCount);
#	Line 1215 | Line 1523 | end;
1523
1524		procedure TIBCustomDataSet.ApplyUpdates;
1525		var
1218	–	{$IF FPC_FULLVERSION >= 20700 }
1526		CurBookmark: TBookmark;
1220	–	{$ELSE}
1221	–	CurBookmark: string;
1222	–	{$ENDIF}
1527		Buffer: PRecordData;
1528		CurUpdateTypes: TIBUpdateRecordTypes;
1529		UpdateAction: TIBUpdateAction;
#	Line 1450 | Line 1754 | end;
1754		function TIBCustomDataSet.ActivateTransaction: Boolean;
1755		begin
1756		Result := False;
1757	<	if not Assigned(Transaction) then
1454	<	IBError(ibxeTransactionNotAssigned, [nil]);
1455	<	if not Transaction.Active then
1757	>	if AllowAutoActivateTransaction or (csDesigning in ComponentState) then
1758		begin
1759	<	Result := True;
1760	<	Transaction.StartTransaction;
1761	<	FDidActivate := True;
1759	>	if not Assigned(Transaction) then
1760	>	IBError(ibxeTransactionNotAssigned, [nil]);
1761	>	if not Transaction.Active then
1762	>	begin
1763	>	Result := True;
1764	>	Transaction.StartTransaction;
1765	>	FDidActivate := True;
1766	>	end;
1767		end;
1768		end;
1769
#	Line 1581 | Line 1888 | begin
1888		FBlobStreamList.Pack;
1889		end;
1890
1891	+	procedure TIBCustomDataSet.ClearArrayCache;
1892	+	var
1893	+	i: Integer;
1894	+	begin
1895	+	for i := 0 to FArrayList.Count - 1 do
1896	+	begin
1897	+	TIBArray(FArrayList[i]).Free;
1898	+	FArrayList[i] := nil;
1899	+	end;
1900	+	FArrayList.Pack;
1901	+	end;
1902	+
1903		procedure TIBCustomDataSet.CopyRecordBuffer(Source, Dest: Pointer);
1904		begin
1905		Move(Source^, Dest^, FRecordBufferSize);
#	Line 1590 | Line 1909 | procedure TIBCustomDataSet.DoBeforeDatab
1909		begin
1910		if Active then
1911		Active := False;
1912	<	FInternalPrepared := False;
1912	>	InternalUnPrepare;
1913		if Assigned(FBeforeDatabaseDisconnect) then
1914		FBeforeDatabaseDisconnect(Sender);
1915		end;
#	Line 1628 | Line 1947 | begin
1947		FQModify.FreeHandle;
1948		if FQRefresh <> nil then
1949		FQRefresh.FreeHandle;
1950	+	InternalUnPrepare;
1951		if Assigned(FBeforeTransactionEnd) then
1952		FBeforeTransactionEnd(Sender);
1953		end;
#	Line 1644 | Line 1964 | begin
1964		FTransactionFree(Sender);
1965		end;
1966
1967	<	{ Read the record from FQSelect.Current into the record buffer
1968	<	Then write the buffer to in memory cache }
1969	<	procedure TIBCustomDataSet.FetchCurrentRecordToBuffer(Qry: TIBSQL;
1970	<	RecordNumber: Integer; Buffer: PChar);
1971	<	var
1652	<	p: PRecordData;
1653	<	pbd: PBlobDataArray;
1654	<	i, j: Integer;
1655	<	LocalData: Pointer;
1656	<	LocalDate, LocalDouble: Double;
1657	<	LocalInt: Integer;
1658	<	LocalBool: wordBool;
1659	<	LocalInt64: Int64;
1660	<	LocalCurrency: Currency;
1661	<	FieldsLoaded: Integer;
1662	<	temp: TIBXSQLVAR;
1967	>	procedure TIBCustomDataSet.InitModelBuffer(Qry: TIBSQL; Buffer: PChar);
1968	>	var i, j: Integer;
1969	>	FieldsLoaded: integer;
1970	>	p: PRecordData;
1971	>	colMetadata: IColumnMetaData;
1972		begin
1973		p := PRecordData(Buffer);
1665	–	{ Make sure blob cache is empty }
1666	–	pbd := PBlobDataArray(Buffer + FBlobCacheOffset);
1667	–	if RecordNumber > -1 then
1668	–	for i := 0 to BlobFieldCount - 1 do
1669	–	pbd^[i] := nil;
1974		{ Get record information }
1975		p^.rdBookmarkFlag := bfCurrent;
1976	<	p^.rdFieldCount := Qry.Current.Count;
1977	<	p^.rdRecordNumber := RecordNumber;
1976	>	p^.rdFieldCount := Qry.FieldCount;
1977	>	p^.rdRecordNumber := -1;
1978		p^.rdUpdateStatus := usUnmodified;
1979		p^.rdCachedUpdateStatus := cusUnmodified;
1980		p^.rdSavedOffset := $FFFFFFFF;
1981
1982		{ Load up the fields }
1983	<	FieldsLoaded := FQSelect.Current.Count;
1983	>	FieldsLoaded := FQSelect.MetaData.Count;
1984		j := 1;
1985	<	for i := 0 to Qry.Current.Count - 1 do
1985	>	for i := 0 to Qry.MetaData.Count - 1 do
1986		begin
1987		if (Qry = FQSelect) then
1988		j := i + 1
1989	<	else begin
1989	>	else
1990	>	begin
1991		if FieldsLoaded = 0 then
1992		break;
1993	<	j := FQSelect.FieldIndex[Qry.Current[i].Name] + 1;
1993	>	j := FQSelect.FieldIndex[Qry[i].Name] + 1;
1994		if j < 1 then
1995		continue
1996		else
1997		Dec(FieldsLoaded);
1998		end;
1999	<	with FQSelect.Current[j - 1].Data^ do
2000	<	if aliasname = 'IBX_INTERNAL_DBKEY' then {do not localize}
1999	>	if j > 0 then
2000	>	begin
2001	>	colMetadata := Qry.MetaData[i];
2002	>	with p^.rdFields[j], FFieldColumns^[j] do
2003		begin
2004	<	if sqllen <= 8 then
2005	<	p^.rdDBKey := PIBDBKEY(Qry.Current[i].AsPointer)^;
2006	<	continue;
2004	>	fdDataType := colMetadata.GetSQLType;
2005	>	if fdDataType = SQL_BLOB then
2006	>	fdDataScale := 0
2007	>	else
2008	>	fdDataScale := colMetadata.getScale;
2009	>	fdNullable := colMetadata.getIsNullable;
2010	>	fdIsNull := true;
2011	>	fdDataSize := colMetadata.GetSize;
2012	>	fdDataLength := 0;
2013	>	fdCodePage := CP_NONE;
2014	>
2015	>	case fdDataType of
2016	>	SQL_TIMESTAMP,
2017	>	SQL_TYPE_DATE,
2018	>	SQL_TYPE_TIME:
2019	>	fdDataSize := SizeOf(TDateTime);
2020	>	SQL_SHORT, SQL_LONG:
2021	>	begin
2022	>	if (fdDataScale = 0) then
2023	>	fdDataSize := SizeOf(Integer)
2024	>	else
2025	>	if (fdDataScale >= (-4)) then
2026	>	fdDataSize := SizeOf(Currency)
2027	>	else
2028	>	fdDataSize := SizeOf(Double);
2029	>	end;
2030	>	SQL_INT64:
2031	>	begin
2032	>	if (fdDataScale = 0) then
2033	>	fdDataSize := SizeOf(Int64)
2034	>	else
2035	>	if (fdDataScale >= (-4)) then
2036	>	fdDataSize := SizeOf(Currency)
2037	>	else
2038	>	fdDataSize := SizeOf(Double);
2039	>	end;
2040	>	SQL_DOUBLE, SQL_FLOAT, SQL_D_FLOAT:
2041	>	fdDataSize := SizeOf(Double);
2042	>	SQL_BOOLEAN:
2043	>	fdDataSize := SizeOf(wordBool);
2044	>	SQL_VARYING,
2045	>	SQL_TEXT,
2046	>	SQL_BLOB:
2047	>	fdCodePage := Qry.Metadata[i].getCodePage;
2048	>	end;
2049	>	fdDataOfs := FRecordSize;
2050	>	Inc(FRecordSize, fdDataSize);
2051		end;
2052	<	if j > 0 then with p^ do
2052	>	end;
2053	>	end;
2054	>	end;
2055	>
2056	>	{Update Buffer Fields from Query Results}
2057	>
2058	>	procedure TIBCustomDataSet.UpdateRecordFromQuery(QryResults: IResults;
2059	>	Buffer: PChar);
2060	>	var i, j: integer;
2061	>	begin
2062	>	for i := 0 to QryResults.Count - 1 do
2063	>	begin
2064	>	j := GetFieldPosition(QryResults[i].GetAliasName);
2065	>	if j > 0 then
2066	>	ColumnDataToBuffer(QryResults,i,j,Buffer);
2067	>	end;
2068	>	end;
2069	>
2070	>
2071	>	{Move column data returned from query to row buffer}
2072	>
2073	>	procedure TIBCustomDataSet.ColumnDataToBuffer(QryResults: IResults;
2074	>	ColumnIndex, FieldIndex: integer; Buffer: PChar);
2075	>	var
2076	>	LocalData: PByte;
2077	>	LocalDate, LocalDouble: Double;
2078	>	LocalInt: Integer;
2079	>	LocalBool: wordBool;
2080	>	LocalInt64: Int64;
2081	>	LocalCurrency: Currency;
2082	>	ColData: ISQLData;
2083	>	begin
2084	>	LocalData := nil;
2085	>	with PRecordData(Buffer)^.rdFields[FieldIndex], FFieldColumns^[FieldIndex] do
2086	>	begin
2087	>	QryResults.GetData(ColumnIndex,fdIsNull,fdDataLength,LocalData);
2088	>	if not fdIsNull then
2089		begin
2090	<	rdFields[j].fdDataType :=
2091	<	Qry.Current[i].Data^.sqltype and (not 1);
1705	<	rdFields[j].fdDataScale :=
1706	<	Qry.Current[i].Data^.sqlscale;
1707	<	rdFields[j].fdNullable :=
1708	<	(Qry.Current[i].Data^.sqltype and 1 = 1);
1709	<	rdFields[j].fdIsNull :=
1710	<	(rdFields[j].fdNullable and (Qry.Current[i].Data^.sqlind^ = -1));
1711	<	LocalData := Qry.Current[i].Data^.sqldata;
1712	<	case rdFields[j].fdDataType of
2090	>	ColData := QryResults[ColumnIndex];
2091	>	case fdDataType of  {Get Formatted data for column types that need formatting}
2092		SQL_TIMESTAMP:
2093		begin
2094	<	rdFields[j].fdDataSize := SizeOf(TDateTime);
2095	<	if RecordNumber >= 0 then
1717	<	LocalDate := TimeStampToMSecs(DateTimeToTimeStamp(Qry.Current[i].AsDateTime));
1718	<	LocalData := PChar(@LocalDate);
2094	>	LocalDate := TimeStampToMSecs(DateTimeToTimeStamp(ColData.AsDateTime));
2095	>	LocalData := PByte(@LocalDate);
2096		end;
2097		SQL_TYPE_DATE:
2098		begin
2099	<	rdFields[j].fdDataSize := SizeOf(TDateTime);
2100	<	if RecordNumber >= 0 then
1724	<	LocalInt := DateTimeToTimeStamp(Qry.Current[i].AsDateTime).Date;
1725	<	LocalData := PChar(@LocalInt);
2099	>	LocalInt := DateTimeToTimeStamp(ColData.AsDateTime).Date;
2100	>	LocalData := PByte(@LocalInt);
2101		end;
2102		SQL_TYPE_TIME:
2103		begin
2104	<	rdFields[j].fdDataSize := SizeOf(TDateTime);
2105	<	if RecordNumber >= 0 then
1731	<	LocalInt := DateTimeToTimeStamp(Qry.Current[i].AsDateTime).Time;
1732	<	LocalData := PChar(@LocalInt);
2104	>	LocalInt := DateTimeToTimeStamp(ColData.AsDateTime).Time;
2105	>	LocalData := PByte(@LocalInt);
2106		end;
2107		SQL_SHORT, SQL_LONG:
2108		begin
2109	<	if (rdFields[j].fdDataScale = 0) then
2109	>	if (fdDataScale = 0) then
2110		begin
2111	<	rdFields[j].fdDataSize := SizeOf(Integer);
2112	<	if RecordNumber >= 0 then
1740	<	LocalInt := Qry.Current[i].AsLong;
1741	<	LocalData := PChar(@LocalInt);
2111	>	LocalInt := ColData.AsLong;
2112	>	LocalData := PByte(@LocalInt);
2113		end
2114	<	else if (rdFields[j].fdDataScale >= (-4)) then
2115	<	begin
2116	<	rdFields[j].fdDataSize := SizeOf(Currency);
2117	<	if RecordNumber >= 0 then
2118	<	LocalCurrency := Qry.Current[i].AsCurrency;
2119	<	LocalData := PChar(@LocalCurrency);
2120	<	end
2121	<	else begin
2122	<	rdFields[j].fdDataSize := SizeOf(Double);
2123	<	if RecordNumber >= 0 then
2124	<	LocalDouble := Qry.Current[i].AsDouble;
1754	<	LocalData := PChar(@LocalDouble);
1755	<	end;
2114	>	else
2115	>	if (fdDataScale >= (-4)) then
2116	>	begin
2117	>	LocalCurrency := ColData.AsCurrency;
2118	>	LocalData := PByte(@LocalCurrency);
2119	>	end
2120	>	else
2121	>	begin
2122	>	LocalDouble := ColData.AsDouble;
2123	>	LocalData := PByte(@LocalDouble);
2124	>	end;
2125		end;
2126		SQL_INT64:
2127		begin
2128	<	if (rdFields[j].fdDataScale = 0) then
2128	>	if (fdDataScale = 0) then
2129		begin
2130	<	rdFields[j].fdDataSize := SizeOf(Int64);
2131	<	if RecordNumber >= 0 then
1763	<	LocalInt64 := Qry.Current[i].AsInt64;
1764	<	LocalData := PChar(@LocalInt64);
2130	>	LocalInt64 := ColData.AsInt64;
2131	>	LocalData := PByte(@LocalInt64);
2132		end
2133	<	else if (rdFields[j].fdDataScale >= (-4)) then
2134	<	begin
1768	<	rdFields[j].fdDataSize := SizeOf(Currency);
1769	<	if RecordNumber >= 0 then
1770	<	LocalCurrency := Qry.Current[i].AsCurrency;
1771	<	LocalData := PChar(@LocalCurrency);
1772	<	end
1773	<	else begin
1774	<	rdFields[j].fdDataSize := SizeOf(Double);
1775	<	if RecordNumber >= 0 then
1776	<	LocalDouble := Qry.Current[i].AsDouble;
1777	<	LocalData := PChar(@LocalDouble);
1778	<	end
1779	<	end;
1780	<	SQL_DOUBLE, SQL_FLOAT, SQL_D_FLOAT:
1781	<	begin
1782	<	rdFields[j].fdDataSize := SizeOf(Double);
1783	<	if RecordNumber >= 0 then
1784	<	LocalDouble := Qry.Current[i].AsDouble;
1785	<	LocalData := PChar(@LocalDouble);
1786	<	end;
1787	<	SQL_VARYING:
1788	<	begin
1789	<	rdFields[j].fdDataSize := Qry.Current[i].Data^.sqllen;
1790	<	rdFields[j].fdDataLength := isc_vax_integer(Qry.Current[i].Data^.sqldata, 2);
1791	<	if RecordNumber >= 0 then
2133	>	else
2134	>	if (fdDataScale >= (-4)) then
2135		begin
2136	<	if (rdFields[j].fdDataLength = 0) then
2137	<	LocalData := nil
2136	>	LocalCurrency := ColData.AsCurrency;
2137	>	LocalData := PByte(@LocalCurrency);
2138	>	end
2139		else
2140		begin
2141	<	temp :=  Qry.Current[i];
2142	<	LocalData := @temp.Data^.sqldata[2];
2143	<	(*              LocalData := @Qry.Current[i].Data^.sqldata[2];*)
1800	<	end;
1801	<	end;
2141	>	LocalDouble := ColData.AsDouble;
2142	>	LocalData := PByte(@LocalDouble);
2143	>	end
2144		end;
2145	<	SQL_BOOLEAN:
2145	>	SQL_DOUBLE, SQL_FLOAT, SQL_D_FLOAT:
2146		begin
2147	<	LocalBool:= false;
2148	<	rdFields[j].fdDataSize := SizeOf(wordBool);
1807	<	if RecordNumber >= 0 then
1808	<	LocalBool := Qry.Current[i].AsBoolean;
1809	<	LocalData := PChar(@LocalBool);
2147	>	LocalDouble := ColData.AsDouble;
2148	>	LocalData := PByte(@LocalDouble);
2149		end;
2150	<	else { SQL_TEXT, SQL_BLOB, SQL_ARRAY, SQL_QUAD }
2150	>	SQL_BOOLEAN:
2151		begin
2152	<	rdFields[j].fdDataSize := Qry.Current[i].Data^.sqllen;
2153	<	if (rdFields[j].fdDataType = SQL_TEXT) then
1815	<	rdFields[j].fdDataLength := rdFields[j].fdDataSize;
2152	>	LocalBool := ColData.AsBoolean;
2153	>	LocalData := PByte(@LocalBool);
2154		end;
2155		end;
2156	<	if RecordNumber < 0 then
2156	>
2157	>	if fdDataType = SQL_VARYING then
2158	>	Move(LocalData^, Buffer[fdDataOfs], fdDataLength)
2159	>	else
2160	>	Move(LocalData^, Buffer[fdDataOfs], fdDataSize)
2161	>	end
2162	>	else {Null column}
2163	>	if fdDataType = SQL_VARYING then
2164	>	FillChar(Buffer[fdDataOfs],fdDataLength,0)
2165	>	else
2166	>	FillChar(Buffer[fdDataOfs],fdDataSize,0);
2167	>	end;
2168	>	end;
2169	>
2170	>	{ Read the record from FQSelect.Current into the record buffer
2171	>	Then write the buffer to in memory cache }
2172	>	procedure TIBCustomDataSet.FetchCurrentRecordToBuffer(Qry: TIBSQL;
2173	>	RecordNumber: Integer; Buffer: PChar);
2174	>	var
2175	>	pbd: PBlobDataArray;
2176	>	pda: PArrayDataArray;
2177	>	i, j: Integer;
2178	>	FieldsLoaded: Integer;
2179	>	p: PRecordData;
2180	>	begin
2181	>	if RecordNumber = -1 then
2182	>	begin
2183	>	InitModelBuffer(Qry,Buffer);
2184	>	Exit;
2185	>	end;
2186	>	p := PRecordData(Buffer);
2187	>	{ Make sure blob cache is empty }
2188	>	pbd := PBlobDataArray(Buffer + FBlobCacheOffset);
2189	>	pda := PArrayDataArray(Buffer + FArrayCacheOffset);
2190	>	for i := 0 to BlobFieldCount - 1 do
2191	>	pbd^[i] := nil;
2192	>	for i := 0 to ArrayFieldCount - 1 do
2193	>	pda^[i] := nil;
2194	>
2195	>	{ Get record information }
2196	>	p^.rdBookmarkFlag := bfCurrent;
2197	>	p^.rdFieldCount := Qry.FieldCount;
2198	>	p^.rdRecordNumber := RecordNumber;
2199	>	p^.rdUpdateStatus := usUnmodified;
2200	>	p^.rdCachedUpdateStatus := cusUnmodified;
2201	>	p^.rdSavedOffset := $FFFFFFFF;
2202	>
2203	>	{ Load up the fields }
2204	>	FieldsLoaded := FQSelect.MetaData.Count;
2205	>	j := 1;
2206	>	for i := 0 to Qry.FieldCount - 1 do
2207	>	begin
2208	>	if (Qry = FQSelect) then
2209	>	j := i + 1
2210	>	else
2211	>	begin
2212	>	if FieldsLoaded = 0 then
2213	>	break;
2214	>	j := FQSelect.FieldIndex[Qry[i].Name] + 1;
2215	>	if j < 1 then
2216	>	continue
2217	>	else
2218	>	Dec(FieldsLoaded);
2219	>	end;
2220	>	with FQSelect.MetaData[j - 1] do
2221	>	if GetAliasname = 'IBX_INTERNAL_DBKEY' then {do not localize}
2222		begin
2223	<	rdFields[j].fdIsNull := True;
2224	<	rdFields[j].fdDataOfs := FRecordSize;
2225	<	Inc(FRecordSize, rdFields[j].fdDataSize);
1823	<	end
1824	<	else begin
1825	<	if rdFields[j].fdDataType = SQL_VARYING then
1826	<	begin
1827	<	if LocalData <> nil then
1828	<	Move(LocalData^, Buffer[rdFields[j].fdDataOfs], rdFields[j].fdDataLength)
1829	<	end
1830	<	else
1831	<	Move(LocalData^, Buffer[rdFields[j].fdDataOfs], rdFields[j].fdDataSize)
2223	>	if (GetSize <= 8) then
2224	>	p^.rdDBKey := PIBDBKEY(Qry[i].AsPointer)^;
2225	>	continue;
2226		end;
2227	<	end;
2227	>	if j > 0 then
2228	>	ColumnDataToBuffer(Qry.Current,i,j,Buffer);
2229		end;
2230	<	WriteRecordCache(RecordNumber, PChar(p));
2230	>	WriteRecordCache(RecordNumber, Buffer);
2231		end;
2232
2233		function TIBCustomDataSet.GetActiveBuf: PChar;
#	Line 1877 | Line 2272 | begin
2272		result := FBase.Database;
2273		end;
2274
1880	–	function TIBCustomDataSet.GetDBHandle: PISC_DB_HANDLE;
1881	–	begin
1882	–	result := FBase.DBHandle;
1883	–	end;
1884	–
2275		function TIBCustomDataSet.GetDeleteSQL: TStrings;
2276		begin
2277		result := FQDelete.SQL;
#	Line 1892 | Line 2282 | begin
2282		result := FQInsert.SQL;
2283		end;
2284
2285	<	function TIBCustomDataSet.GetSQLParams: TIBXSQLDA;
2285	>	function TIBCustomDataSet.GetSQLParams: ISQLParams;
2286		begin
2287		if not FInternalPrepared then
2288		InternalPrepare;
#	Line 1909 | Line 2299 | begin
2299		result := FQSelect.SQL;
2300		end;
2301
2302	<	function TIBCustomDataSet.GetStatementType: TIBSQLTypes;
2302	>	function TIBCustomDataSet.GetStatementType: TIBSQLStatementTypes;
2303		begin
2304	<	result := FQSelect.SQLType;
2304	>	result := FQSelect.SQLStatementType;
2305		end;
2306
2307		function TIBCustomDataSet.GetModifySQL: TStrings;
#	Line 1924 | Line 2314 | begin
2314		result := FBase.Transaction;
2315		end;
2316
1927	–	function TIBCustomDataSet.GetTRHandle: PISC_TR_HANDLE;
1928	–	begin
1929	–	result := FBase.TRHandle;
1930	–	end;
1931	–
2317		procedure TIBCustomDataSet.InternalDeleteRecord(Qry: TIBSQL; Buff: Pointer);
2318		begin
2319		if (Assigned(FUpdateObject) and (FUpdateObject.GetSQL(ukDelete).Text <> '')) then
2320		FUpdateObject.Apply(ukDelete,Buff)
2321		else
2322		begin
2323	<	SetInternalSQLParams(FQDelete, Buff);
2323	>	SetInternalSQLParams(FQDelete.Params, Buff);
2324		FQDelete.ExecQuery;
2325		end;
2326		with PRecordData(Buff)^ do
#	Line 1950 | Line 2335 | function TIBCustomDataSet.InternalLocate
2335		const KeyValues: Variant; Options: TLocateOptions): Boolean;
2336		var
2337		keyFieldList: TList;
1953	–	{$IF FPC_FULLVERSION >= 20700 }
2338		CurBookmark: TBookmark;
1955	–	{$ELSE}
1956	–	CurBookmark: string;
1957	–	{$ENDIF}
2339		fieldValue: Variant;
2340		lookupValues: array of variant;
2341		i, fieldCount: Integer;
#	Line 2036 | Line 2417 | end;
2417
2418		procedure TIBCustomDataSet.InternalPostRecord(Qry: TIBSQL; Buff: Pointer);
2419		var
2420	<	i, j, k: Integer;
2420	>	i, j, k, arr: Integer;
2421		pbd: PBlobDataArray;
2422	+	pda: PArrayDataArray;
2423		begin
2424		pbd := PBlobDataArray(PChar(Buff) + FBlobCacheOffset);
2425	<	j := 0;
2425	>	pda := PArrayDataArray(PChar(Buff) + FArrayCacheOffset);
2426	>	j := 0; arr := 0;
2427		for i := 0 to FieldCount - 1 do
2428		if Fields[i].IsBlob then
2429		begin
#	Line 2049 | Line 2432 | begin
2432		begin
2433		pbd^[j].Finalize;
2434		PISC_QUAD(
2435	<	PChar(Buff) + PRecordData(Buff)^.rdFields[k].fdDataOfs)^ :=
2435	>	PChar(Buff) + FFieldColumns^[k].fdDataOfs)^ :=
2436		pbd^[j].BlobID;
2437		PRecordData(Buff)^.rdFields[k].fdIsNull := pbd^[j].Size = 0;
2438	+	end
2439	+	else
2440	+	begin
2441	+	PRecordData(Buff)^.rdFields[k].fdIsNull := true;
2442	+	with PISC_QUAD(PChar(Buff) + FFieldColumns^[k].fdDataOfs)^ do
2443	+	begin
2444	+	gds_quad_high := 0;
2445	+	gds_quad_low := 0;
2446	+	end;
2447		end;
2448		Inc(j);
2449	+	end
2450	+	else
2451	+	if Fields[i] is TIBArrayField then
2452	+	begin
2453	+	if pda^[arr] <> nil then
2454	+	begin
2455	+	k := FMappedFieldPosition[Fields[i].FieldNo -1];
2456	+	PISC_QUAD(
2457	+	PChar(Buff) + FFieldColumns^[k].fdDataOfs)^ :=  pda^[arr].ArrayIntf.GetArrayID;
2458	+	PRecordData(Buff)^.rdFields[k].fdIsNull := pda^[arr].ArrayIntf.IsEmpty;
2459	+	end;
2460	+	Inc(arr);
2461		end;
2462		if Assigned(FUpdateObject) then
2463		begin
#	Line 2065 | Line 2469 | begin
2469		FUpdateObject.Apply(ukModify,Buff);
2470		end
2471		else begin
2472	<	SetInternalSQLParams(Qry, Buff);
2472	>	SetInternalSQLParams(Qry.Params, Buff);
2473		Qry.ExecQuery;
2474		end;
2475	+	if Qry.FieldCount > 0 then {Has RETURNING Clause}
2476	+	UpdateRecordFromQuery(Qry.Current,Buff);
2477		PRecordData(Buff)^.rdUpdateStatus := usUnmodified;
2478		PRecordData(Buff)^.rdCachedUpdateStatus := cusUnmodified;
2479		SetModified(False);
#	Line 2099 | Line 2505 | begin
2505		end
2506		else
2507		Qry := FQRefresh;
2508	<	SetInternalSQLParams(Qry, Buff);
2508	>	SetInternalSQLParams(Qry.Params, Buff);
2509		Qry.ExecQuery;
2510		try
2511	<	if (Qry.SQLType = SQLExecProcedure) or
2106	<	(Qry.Next <> nil) then
2511	>	if (Qry.SQLStatementType = SQLExecProcedure) or Qry.Next then
2512		begin
2513		ofs := PRecordData(Buff)^.rdSavedOffset;
2514		FetchCurrentRecordToBuffer(Qry,
#	Line 2196 | Line 2601 | begin
2601		end;
2602
2603		procedure TIBCustomDataSet.InternalPrepare;
2199	–	var
2200	–	DidActivate: Boolean;
2604		begin
2605		if FInternalPrepared then
2606		Exit;
2204	–	DidActivate := False;
2607		FBase.SetCursor;
2608		try
2609		ActivateConnection;
2610	<	DidActivate := ActivateTransaction;
2610	>	ActivateTransaction;
2611		FBase.CheckDatabase;
2612		FBase.CheckTransaction;
2613		if HasParser and (FParser.SQLText <> FQSelect.SQL.Text) then
#	Line 2243 | Line 2645 | begin
2645		end else
2646		IBError(ibxeEmptyQuery, [nil]);
2647		finally
2246	–	if DidActivate then
2247	–	DeactivateTransaction;
2648		FBase.RestoreCursor;
2649		end;
2650		end;
#	Line 2274 | Line 2674 | var
2674		begin
2675		CopyRecordBuffer(Buffer, OldBuffer);
2676		if BlobFieldCount > 0 then
2677	<	FillChar(PChar(OldBuffer)[FBlobCacheOffset], BlobFieldCount * SizeOf(TIBBlobStream),
2677	>	FillChar(PChar(OldBuffer)[FBlobCacheOffset],
2678	>	BlobFieldCount * SizeOf(TIBBlobStream) + ArrayFieldCount * SizeOf(IArray),
2679		0);
2680		end;
2681
#	Line 2316 | Line 2717 | begin
2717		if (FBase.Database <> Value) then
2718		begin
2719		CheckDatasetClosed;
2720	+	InternalUnPrepare;
2721		FBase.Database := Value;
2722		FQDelete.Database := Value;
2723		FQInsert.Database := Value;
2724		FQRefresh.Database := Value;
2725		FQSelect.Database := Value;
2726		FQModify.Database := Value;
2727	+	FDatabaseInfo.Database := Value;
2728	+	FGeneratorField.Database := Value;
2729		end;
2730		end;
2731
#	Line 2343 | Line 2747 | begin
2747		end;
2748		end;
2749
2750	<	procedure TIBCustomDataSet.SetInternalSQLParams(Qry: TIBSQL; Buffer: Pointer);
2750	>	procedure TIBCustomDataSet.SetInternalSQLParams(Params: ISQLParams; Buffer: Pointer);
2751		var
2752		i, j: Integer;
2753		cr, data: PChar;
2754	<	fn, st: string;
2754	>	fn: string;
2755	>	st: RawByteString;
2756		OldBuffer: Pointer;
2757		ts: TTimeStamp;
2758	+	Param: ISQLParam;
2759		begin
2760		if (Buffer = nil) then
2761		IBError(ibxeBufferNotSet, [nil]);
#	Line 2357 | Line 2763 | begin
2763		InternalPrepare;
2764		OldBuffer := nil;
2765		try
2766	<	for i := 0 to Qry.Params.Count - 1 do
2766	>	for i := 0 to Params.GetCount - 1 do
2767		begin
2768	<	fn := Qry.Params[i].Name;
2768	>	Param := Params[i];
2769	>	fn := Param.Name;
2770		if (Pos('OLD_', fn) = 1) then {mbcs ok}
2771		begin
2772		fn := Copy(fn, 5, Length(fn));
#	Line 2379 | Line 2786 | begin
2786		cr := Buffer;
2787		j := FQSelect.FieldIndex[fn] + 1;
2788		if (j > 0) then
2789	<	with PRecordData(cr)^ do
2789	>	with PRecordData(cr)^,rdFields[j], FFieldColumns^[j] do
2790		begin
2791	<	if Qry.Params[i].name = 'IBX_INTERNAL_DBKEY' then {do not localize}
2791	>	if Param.name = 'IBX_INTERNAL_DBKEY' then {do not localize}
2792		begin
2793	<	PIBDBKey(Qry.Params[i].AsPointer)^ := rdDBKey;
2793	>	PIBDBKey(Param.AsPointer)^ := rdDBKey;
2794		continue;
2795		end;
2796	<	if rdFields[j].fdIsNull then
2797	<	Qry.Params[i].IsNull := True
2796	>	if fdIsNull then
2797	>	Param.IsNull := True
2798		else begin
2799	<	Qry.Params[i].IsNull := False;
2800	<	data := cr + rdFields[j].fdDataOfs;
2801	<	case rdFields[j].fdDataType of
2799	>	Param.IsNull := False;
2800	>	data := cr + fdDataOfs;
2801	>	case fdDataType of
2802		SQL_TEXT, SQL_VARYING:
2803		begin
2804	<	SetString(st, data, rdFields[j].fdDataLength);
2805	<	Qry.Params[i].AsString := st;
2804	>	SetString(st, data, fdDataLength);
2805	>	SetCodePage(st,fdCodePage,false);
2806	>	Param.AsString := st;
2807		end;
2808		SQL_FLOAT, SQL_DOUBLE, SQL_D_FLOAT:
2809	<	Qry.Params[i].AsDouble := PDouble(data)^;
2809	>	Param.AsDouble := PDouble(data)^;
2810		SQL_SHORT, SQL_LONG:
2811		begin
2812	<	if rdFields[j].fdDataScale = 0 then
2813	<	Qry.Params[i].AsLong := PLong(data)^
2406	<	else if rdFields[j].fdDataScale >= (-4) then
2407	<	Qry.Params[i].AsCurrency := PCurrency(data)^
2812	>	if fdDataScale = 0 then
2813	>	Param.AsLong := PLong(data)^
2814		else
2815	<	Qry.Params[i].AsDouble := PDouble(data)^;
2815	>	if fdDataScale >= (-4) then
2816	>	Param.AsCurrency := PCurrency(data)^
2817	>	else
2818	>	Param.AsDouble := PDouble(data)^;
2819		end;
2820		SQL_INT64:
2821		begin
2822	<	if rdFields[j].fdDataScale = 0 then
2823	<	Qry.Params[i].AsInt64 := PInt64(data)^
2824	<	else if rdFields[j].fdDataScale >= (-4) then
2825	<	Qry.Params[i].AsCurrency := PCurrency(data)^
2822	>	if fdDataScale = 0 then
2823	>	Param.AsInt64 := PInt64(data)^
2824	>	else
2825	>	if fdDataScale >= (-4) then
2826	>	Param.AsCurrency := PCurrency(data)^
2827		else
2828	<	Qry.Params[i].AsDouble := PDouble(data)^;
2828	>	Param.AsDouble := PDouble(data)^;
2829		end;
2830		SQL_BLOB, SQL_ARRAY, SQL_QUAD:
2831	<	Qry.Params[i].AsQuad := PISC_QUAD(data)^;
2831	>	Param.AsQuad := PISC_QUAD(data)^;
2832		SQL_TYPE_DATE:
2833		begin
2834		ts.Date := PInt(data)^;
2835		ts.Time := 0;
2836	<	Qry.Params[i].AsDate :=
2427	<	TimeStampToDateTime(ts);
2836	>	Param.AsDate := TimeStampToDateTime(ts);
2837		end;
2838		SQL_TYPE_TIME:
2839		begin
2840		ts.Date := 0;
2841		ts.Time := PInt(data)^;
2842	<	Qry.Params[i].AsTime :=
2434	<	TimeStampToDateTime(ts);
2842	>	Param.AsTime := TimeStampToDateTime(ts);
2843		end;
2844		SQL_TIMESTAMP:
2845	<	Qry.Params[i].AsDateTime :=
2845	>	Param.AsDateTime :=
2846		TimeStampToDateTime(MSecsToTimeStamp(trunc(PDouble(data)^)));
2847		SQL_BOOLEAN:
2848	<	Qry.Params[i].AsBoolean := PWordBool(data)^;
2848	>	Param.AsBoolean := PWordBool(data)^;
2849		end;
2850		end;
2851		end;
#	Line 2486 | Line 2894 | begin
2894		FQRefresh.Transaction := Value;
2895		FQSelect.Transaction := Value;
2896		FQModify.Transaction := Value;
2897	+	FGeneratorField.Transaction := Value;
2898		end;
2899		end;
2900
#	Line 2593 | Line 3002 | begin
3002		Result := Assigned( FQSelect ) and FQSelect.EOF;
3003		end;
3004
3005	<	function TIBCustomDataSet.ParamByName(ParamName: String): TIBXSQLVAR;
3005	>	function TIBCustomDataSet.ParamByName(ParamName: String): ISQLParam;
3006		begin
3007		ActivateConnection;
3008		ActivateTransaction;
#	Line 2730 | Line 3139 | var
3139		Buff: PChar;
3140		bTr, bDB: Boolean;
3141		begin
3142	+	if (Field = nil) or (Field.DataSet <> self) then
3143	+	IBError(ibxFieldNotinDataSet,[Field.Name,Name]);
3144		Buff := GetActiveBuf;
3145		if Buff = nil then
3146		begin
3147		fs := TIBBlobStream.Create;
3148		fs.Mode := bmReadWrite;
3149	+	fs.Database := Database;
3150	+	fs.Transaction := Transaction;
3151	+	fs.SetField(Field);
3152		FBlobStreamList.Add(Pointer(fs));
3153		result := TIBDSBlobStream.Create(Field, fs, Mode);
3154		exit;
#	Line 2749 | Line 3163 | begin
3163		fs.Mode := bmReadWrite;
3164		fs.Database := Database;
3165		fs.Transaction := Transaction;
3166	+	fs.SetField(Field);
3167		fs.BlobID :=
3168	<	PISC_QUAD(@Buff[PRecordData(Buff)^.rdFields[FMappedFieldPosition[Field.FieldNo - 1]].fdDataOfs])^;
3168	>	PISC_QUAD(@Buff[FFieldColumns^[FMappedFieldPosition[Field.FieldNo - 1]].fdDataOfs])^;
3169		if (CachedUpdates) then
3170		begin
3171		bTr := not Transaction.InTransaction;
#	Line 2771 | Line 3186 | begin
3186		result := TIBDSBlobStream.Create(Field, fs, Mode);
3187		end;
3188
3189	+	function TIBCustomDataSet.GetArray(Field: TIBArrayField): IArray;
3190	+	var Buff: PChar;
3191	+	pda: PArrayDataArray;
3192	+	bTr, bDB: Boolean;
3193	+	begin
3194	+	if (Field = nil) or (Field.DataSet <> self) then
3195	+	IBError(ibxFieldNotinDataSet,[Field.Name,Name]);
3196	+	Buff := GetActiveBuf;
3197	+	if Buff = nil then
3198	+	Result := Database.Attachment.CreateArray(Transaction.TransactionIntf,
3199	+	Field.FRelationName,Field.FieldName)
3200	+	else
3201	+	begin
3202	+	pda := PArrayDataArray(Buff + FArrayCacheOffset);
3203	+	if pda^[Field.FCacheOffset] = nil then
3204	+	begin
3205	+	AdjustRecordOnInsert(Buff);
3206	+	if Field.IsNull then
3207	+	Result := Database.Attachment.CreateArray(Transaction.TransactionIntf,
3208	+	Field.FRelationName,Field.FieldName)
3209	+	else
3210	+	Result := Database.Attachment.OpenArray(Transaction.TransactionIntf,
3211	+	Field.FRelationName,Field.FieldName,Field.ArrayID);
3212	+	pda^[Field.FCacheOffset] := TIBArray.Create(Field,Result);
3213	+	FArrayList.Add(pda^[Field.FCacheOffset]);
3214	+	if (CachedUpdates) then
3215	+	begin
3216	+	bTr := not Transaction.InTransaction;
3217	+	bDB := not Database.Connected;
3218	+	if bDB then
3219	+	Database.Open;
3220	+	if bTr then
3221	+	Transaction.StartTransaction;
3222	+	pda^[Field.FCacheOffset].ArrayIntf.PreLoad;
3223	+	if bTr then
3224	+	Transaction.Commit;
3225	+	if bDB then
3226	+	Database.Close;
3227	+	end;
3228	+	WriteRecordCache(PRecordData(Buff)^.rdRecordNumber, Pointer(Buff));
3229	+	end
3230	+	else
3231	+	Result := pda^[Field.FCacheOffset].ArrayIntf;
3232	+	end;
3233	+	end;
3234	+
3235	+	procedure TIBCustomDataSet.SetArrayIntf(AnArray: IArray; Field: TIBArrayField);
3236	+	var Buff: PChar;
3237	+	pda: PArrayDataArray;
3238	+	begin
3239	+	if (Field = nil) or (Field.DataSet <> self) then
3240	+	IBError(ibxFieldNotinDataSet,[Field.Name,Name]);
3241	+	Buff := GetActiveBuf;
3242	+	if Buff <> nil then
3243	+	begin
3244	+	AdjustRecordOnInsert(Buff);
3245	+	pda := PArrayDataArray(Buff + FArrayCacheOffset);
3246	+	pda^[Field.FCacheOffset].FArray := AnArray;
3247	+	WriteRecordCache(PRecordData(Buff)^.rdRecordNumber, Pointer(Buff));
3248	+	end;
3249	+	end;
3250	+
3251		function TIBCustomDataSet.CompareBookmarks(Bookmark1, Bookmark2: TBookmark): Integer;
3252		const
3253		CMPLess = -1;
#	Line 2851 | Line 3328 | end;
3328		procedure TIBCustomDataSet.DoBeforeClose;
3329		begin
3330		inherited DoBeforeClose;
3331	+	if FInTransactionEnd and (FCloseAction = TARollback) then
3332	+	Exit;
3333		if State in [dsInsert,dsEdit] then
3334		begin
2856	–	if FInTransactionEnd and (FCloseAction = TARollback) then
2857	–	Exit;
2858	–
3335		if DataSetCloseAction = dcSaveChanges then
3336		Post;
3337		{Note this can fail with an exception e.g. due to
3338		database validation error. In which case the dataset remains open }
3339		end;
3340	+	if FCachedUpdates and FUpdatesPending and (DataSetCloseAction = dcSaveChanges) then
3341	+	ApplyUpdates;
3342		end;
3343
3344		procedure TIBCustomDataSet.DoBeforeOpen;
#	Line 2892 | Line 3370 | end;
3370
3371		procedure TIBCustomDataSet.FetchAll;
3372		var
2895	–	{$IF FPC_FULLVERSION >= 20700 }
3373		CurBookmark: TBookmark;
2897	–	{$ELSE}
2898	–	CurBookmark: string;
2899	–	{$ENDIF}
3374		begin
3375		FBase.SetCursor;
3376		try
#	Line 3007 | Line 3481 | begin
3481		if result and (Buffer <> nil) then
3482		Move(Buff[1], Buffer^, Field.DataSize);
3483		end
3484	<	else if (FMappedFieldPosition[Field.FieldNo - 1] > 0) and
3484	>	else
3485	>	if (FMappedFieldPosition[Field.FieldNo - 1] > 0) and
3486		(FMappedFieldPosition[Field.FieldNo - 1] <= CurrentRecord^.rdFieldCount) then
3487	+	with CurrentRecord^.rdFields[FMappedFieldPosition[Field.FieldNo - 1]],
3488	+	FFieldColumns^[FMappedFieldPosition[Field.FieldNo - 1]] do
3489		begin
3490	<	result := not CurrentRecord^.rdFields[FMappedFieldPosition[Field.FieldNo - 1]].fdIsNull;
3490	>	result := not fdIsNull;
3491		if result and (Buffer <> nil) then
3015	–	with CurrentRecord^.rdFields[FMappedFieldPosition[Field.FieldNo - 1]] do
3492		begin
3493	<	Data := Buff + CurrentRecord^.rdFields[FMappedFieldPosition[Field.FieldNo - 1]].fdDataOfs;
3493	>	Data := Buff + fdDataOfs;
3494		if (fdDataType = SQL_VARYING) or (fdDataType = SQL_TEXT) then
3495		begin
3496		if fdDataLength < Field.DataSize then
#	Line 3085 | Line 3561 | begin
3561		if FCurrentRecord < FRecordCount then
3562		ReadRecordCache(FCurrentRecord, Buffer, False)
3563		else begin
3564	<	while (not FQSelect.EOF) and
3089	<	(FQSelect.Next <> nil) and
3564	>	while (not FQSelect.EOF) and FQSelect.Next  and
3565		(FCurrentRecord >= FRecordCount) do begin
3566		FetchCurrentRecordToBuffer(FQSelect, FRecordCount, Buffer);
3567		Inc(FRecordCount);
#	Line 3197 | Line 3672 | procedure TIBCustomDataSet.InternalCance
3672		var
3673		Buff: PChar;
3674		CurRec: Integer;
3675	+	pda: PArrayDataArray;
3676	+	i: integer;
3677		begin
3678		inherited InternalCancel;
3679		Buff := GetActiveBuf;
3680	<	if Buff <> nil then begin
3680	>	if Buff <> nil then
3681	>	begin
3682	>	pda := PArrayDataArray(Buff + FArrayCacheOffset);
3683	>	for i := 0 to ArrayFieldCount - 1 do
3684	>	pda^[i].ArrayIntf.CancelChanges;
3685		CurRec := FCurrentRecord;
3686		AdjustRecordOnInsert(Buff);
3687		if (State = dsEdit) then begin
#	Line 3223 | Line 3704 | begin
3704		DeactivateTransaction;
3705		FQSelect.Close;
3706		ClearBlobCache;
3707	+	ClearArrayCache;
3708		FreeRecordBuffer(FModelBuffer);
3709		FreeRecordBuffer(FOldBuffer);
3710		FCurrentRecord := -1;
#	Line 3238 | Line 3720 | begin
3720		FOBEnd := 0;
3721		FreeMem(FBufferCache);
3722		FBufferCache := nil;
3723	+	FreeMem(FFieldColumns);
3724	+	FFieldColumns := nil;
3725		FreeMem(FOldBufferCache);
3726		FOldBufferCache := nil;
3727		BindFields(False);
#	Line 3312 | Line 3796 | const
3796		'and R.RDB$FIELD_SOURCE = F.RDB$FIELD_NAME '+ {do not localize}
3797		'and ((not F.RDB$COMPUTED_BLR is NULL) or ' + {do not localize}
3798		'     (not F.RDB$DEFAULT_VALUE is NULL)) '; {do not localize}
3799	+
3800	+	DefaultSQLODS12 = 'Select F.RDB$COMPUTED_BLR, ' + {do not localize}
3801	+	'F.RDB$DEFAULT_VALUE, R.RDB$FIELD_NAME, R.RDB$IDENTITY_TYPE ' + {do not localize}
3802	+	'from RDB$RELATION_FIELDS R, RDB$FIELDS F ' + {do not localize}
3803	+	'where R.RDB$RELATION_NAME = :RELATION ' +  {do not localize}
3804	+	'and R.RDB$FIELD_SOURCE = F.RDB$FIELD_NAME '+ {do not localize}
3805	+	'and ((not F.RDB$COMPUTED_BLR is NULL) or ' + {do not localize}
3806	+	'     (not F.RDB$DEFAULT_VALUE is NULL) or ' + {do not localize}
3807	+	'     ( not R.RDB$IDENTITY_TYPE is NULL))' ; {do not localize}
3808	+
3809		var
3810		FieldType: TFieldType;
3811		FieldSize: Word;
3812	+	FieldDataSize: integer;
3813		charSetID: short;
3814		CharSetSize: integer;
3815	<	CharSetName: string;
3815	>	CharSetName: RawByteString;
3816	>	FieldCodePage: TSystemCodePage;
3817		FieldNullable : Boolean;
3818		i, FieldPosition, FieldPrecision: Integer;
3819		FieldAliasName, DBAliasName: string;
3820	<	RelationName, FieldName: string;
3820	>	aRelationName, FieldName: string;
3821		Query : TIBSQL;
3822		FieldIndex: Integer;
3823		FRelationNodes : TRelationNode;
3824	+	aArrayDimensions: integer;
3825	+	aArrayBounds: TArrayBounds;
3826	+	ArrayMetaData: IArrayMetaData;
3827
3828		function Add_Node(Relation, Field : String) : TRelationNode;
3829		var
#	Line 3347 | Line 3846 | var
3846		FField.FieldName := Query.Fields[2].AsString;
3847		FField.DEFAULT_VALUE := not Query.Fields[1].IsNull;
3848		FField.COMPUTED_BLR := not Query.Fields[0].IsNull;
3849	+	FField.IDENTITY_COLUMN := (Query.FieldCount > 3) and not Query.Fields[3].IsNull;
3850		FField.NextField := Result.FieldNodes;
3851		Result.FieldNodes := FField;
3852		Query.Next;
#	Line 3400 | Line 3900 | var
3900		FField := Ffield.NextField;
3901		end;
3902
3903	+	function Is_IDENTITY_COLUMN(Relation, Field : String) : Boolean;
3904	+	var
3905	+	FRelation : TRelationNode;
3906	+	FField : TFieldNode;
3907	+	begin
3908	+	FRelation := FRelationNodes;
3909	+	while Assigned(FRelation) and
3910	+	(FRelation.RelationName <> Relation) do
3911	+	FRelation := FRelation.NextRelation;
3912	+	if not Assigned(FRelation) then
3913	+	FRelation := Add_Node(Relation, Field);
3914	+	Result := false;
3915	+	FField := FRelation.FieldNodes;
3916	+	while Assigned(FField) do
3917	+	if FField.FieldName = Field then
3918	+	begin
3919	+	Result := Ffield.IDENTITY_COLUMN;
3920	+	Exit;
3921	+	end
3922	+	else
3923	+	FField := Ffield.NextField;
3924	+	end;
3925	+
3926		Procedure FreeNodes;
3927		var
3928		FRelation : TRelationNode;
#	Line 3422 | Line 3945 | var
3945		begin
3946		FRelationNodes := TRelationNode.Create;
3947		FNeedsRefresh := False;
3948	<	Database.InternalTransaction.StartTransaction;
3948	>	if not Database.InternalTransaction.InTransaction then
3949	>	Database.InternalTransaction.StartTransaction;
3950		Query := TIBSQL.Create(self);
3951		try
3952		Query.Database := DataBase;
#	Line 3430 | Line 3954 | begin
3954		FieldDefs.BeginUpdate;
3955		FieldDefs.Clear;
3956		FieldIndex := 0;
3957	<	if (Length(FMappedFieldPosition) < SourceQuery.Current.Count) then
3958	<	SetLength(FMappedFieldPosition, SourceQuery.Current.Count);
3959	<	Query.SQL.Text := DefaultSQL;
3957	>	if (Length(FMappedFieldPosition) < SourceQuery.MetaData.Count) then
3958	>	SetLength(FMappedFieldPosition, SourceQuery.MetaData.Count);
3959	>	if FDatabaseInfo.ODSMajorVersion >= 12 then
3960	>	Query.SQL.Text := DefaultSQLODS12
3961	>	else
3962	>	Query.SQL.Text := DefaultSQL;
3963		Query.Prepare;
3964	<	SetLength(FAliasNameMap, SourceQuery.Current.Count);
3965	<	SetLength(FAliasNameList, SourceQuery.Current.Count);
3966	<	for i := 0 to SourceQuery.Current.Count - 1 do
3967	<	with SourceQuery.Current[i].Data^ do
3964	>	SetLength(FAliasNameMap, SourceQuery.MetaData.Count);
3965	>	SetLength(FAliasNameList, SourceQuery.MetaData.Count);
3966	>	for i := 0 to SourceQuery.MetaData.GetCount - 1 do
3967	>	with SourceQuery.MetaData[i] do
3968		begin
3969		{ Get the field name }
3970	<	FieldAliasName := SourceQuery.Current[i].Name;
3971	<	SetString(DBAliasName, aliasname, aliasname_length);
3972	<	SetString(RelationName, relname, relname_length);
3973	<	SetString(FieldName, sqlname, sqlname_length);
3970	>	FieldAliasName := GetName;
3971	>	DBAliasName := GetAliasname;
3972	>	aRelationName := getRelationName;
3973	>	FieldName := getSQLName;
3974		FAliasNameList[i] := DBAliasName;
3975		FieldSize := 0;
3976	+	FieldDataSize := GetSize;
3977		FieldPrecision := 0;
3978	<	FieldNullable := SourceQuery.Current[i].IsNullable;
3978	>	FieldNullable := IsNullable;
3979		CharSetSize := 0;
3980		CharSetName := '';
3981	<	case sqltype and not 1 of
3981	>	FieldCodePage := CP_NONE;
3982	>	aArrayDimensions := 0;
3983	>	SetLength(aArrayBounds,0);
3984	>	case SQLType of
3985		{ All VARCHAR's must be converted to strings before recording
3986		their values }
3987		SQL_VARYING, SQL_TEXT:
3988		begin
3989	<	CharSetSize := FBase.GetCharSetSize(sqlsubtype and $FF);
3990	<	CharSetName := FBase.GetCharSetName(sqlsubtype and $FF);
3991	<	{FieldSize is encoded for strings - see TIBStringField.SetSize for decode}
3992	<	FieldSize := sqllen;
3993	<	if CharSetSize = 2 then
3994	<	FieldType := ftWideString
3464	<	else
3465	<	FieldType := ftString;
3989	>	if not Database.Attachment.CharSetWidth(getCharSetID,CharSetSize) then
3990	>	CharSetSize := 1;
3991	>	CharSetName := Database.Attachment.GetCharsetName(getCharSetID);
3992	>	Database.Attachment.CharSetID2CodePage(getCharSetID,FieldCodePage);
3993	>	FieldSize := FieldDataSize div CharSetSize;
3994	>	FieldType := ftString;
3995		end;
3996		{ All Doubles/Floats should be cast to doubles }
3997		SQL_DOUBLE, SQL_FLOAT:
3998		FieldType := ftFloat;
3999		SQL_SHORT:
4000		begin
4001	<	if (sqlscale = 0) then
4001	>	if (getScale = 0) then
4002		FieldType := ftSmallInt
4003		else begin
4004		FieldType := ftBCD;
4005		FieldPrecision := 4;
4006	<	FieldSize := -sqlscale;
4006	>	FieldSize := -getScale;
4007		end;
4008		end;
4009		SQL_LONG:
4010		begin
4011	<	if (sqlscale = 0) then
4011	>	if (getScale = 0) then
4012		FieldType := ftInteger
4013	<	else if (sqlscale >= (-4)) then
4013	>	else if (getScale >= (-4)) then
4014		begin
4015		FieldType := ftBCD;
4016		FieldPrecision := 9;
4017	<	FieldSize := -sqlscale;
4017	>	FieldSize := -getScale;
4018		end
4019		else
4020		if Database.SQLDialect = 1 then
#	Line 3497 | Line 4026 | begin
4026		begin
4027		FieldType := ftFMTBCD;
4028		FieldPrecision := 9;
4029	<	FieldSize := -sqlscale;
4029	>	FieldSize := -getScale;
4030		end;
4031		end;
4032
4033		SQL_INT64:
4034		begin
4035	<	if (sqlscale = 0) then
4035	>	if (getScale = 0) then
4036		FieldType := ftLargeInt
4037	<	else if (sqlscale >= (-4)) then
4037	>	else if (getScale >= (-4)) then
4038		begin
4039		FieldType := ftBCD;
4040		FieldPrecision := 18;
4041	<	FieldSize := -sqlscale;
4041	>	FieldSize := -getScale;
4042		end
4043		else
4044	<	FieldType := ftFloat
4044	>	FieldType := ftFloat;
4045		end;
4046		SQL_TIMESTAMP: FieldType := ftDateTime;
4047		SQL_TYPE_TIME: FieldType := ftTime;
#	Line 3520 | Line 4049 | begin
4049		SQL_BLOB:
4050		begin
4051		FieldSize := sizeof (TISC_QUAD);
4052	<	if (sqlsubtype = 1) then
4052	>	if (getSubtype = 1) then
4053		begin
4054	<	if strpas(sqlname) = '' then {Complex SQL with no identifiable column - use connection default}
4055	<	begin
4056	<	CharSetSize := FBase.GetDefaultCharSetSize;
4057	<	CharSetName := FBase.GetDefaultCharSetName;
4058	<	end
3530	<	else
3531	<	begin
3532	<	charSetID := GetBlobCharSetID(Database.Handle,Database.InternalTransaction.Handle,
3533	<	@relname,@sqlname);
3534	<	CharSetSize := FBase.GetCharSetSize(charSetID);
3535	<	CharSetName := FBase.GetCharSetName(charSetID);
3536	<	end;
3537	<	if CharSetSize = 2 then
3538	<	FieldType := ftWideMemo
3539	<	else
3540	<	FieldType := ftMemo;
4054	>	if not Database.Attachment.CharSetWidth(getCharSetID,CharSetSize) then
4055	>	CharSetSize := 1;
4056	>	CharSetName := Database.Attachment.GetCharsetName(getCharSetID);
4057	>	Database.Attachment.CharSetID2CodePage(getCharSetID,FieldCodePage);
4058	>	FieldType := ftMemo;
4059		end
4060		else
4061		FieldType := ftBlob;
#	Line 3545 | Line 4063 | begin
4063		SQL_ARRAY:
4064		begin
4065		FieldSize := sizeof (TISC_QUAD);
4066	<	FieldType := ftUnknown;
4066	>	FieldType := ftArray;
4067	>	ArrayMetaData := GetArrayMetaData;
4068	>	if ArrayMetaData <> nil then
4069	>	begin
4070	>	aArrayDimensions := ArrayMetaData.GetDimensions;
4071	>	aArrayBounds := ArrayMetaData.GetBounds;
4072	>	end;
4073		end;
4074		SQL_BOOLEAN:
4075		FieldType:= ftBoolean;
#	Line 3562 | Line 4086 | begin
4086		Name := FieldAliasName;
4087		FAliasNameMap[FieldNo-1] := DBAliasName;
4088		Size := FieldSize;
4089	+	DataSize := FieldDataSize;
4090		Precision := FieldPrecision;
4091		Required := not FieldNullable;
4092	+	RelationName := aRelationName;
4093		InternalCalcField := False;
4094		CharacterSetSize := CharSetSize;
4095		CharacterSetName := CharSetName;
4096	+	CodePage := FieldCodePage;
4097	+	ArrayDimensions := aArrayDimensions;
4098	+	ArrayBounds := aArrayBounds;
4099		if (FieldName <> '') and (RelationName <> '') then
4100		begin
4101	+	IdentityColumn := Is_IDENTITY_COLUMN(RelationName, FieldName);
4102		if Has_COMPUTED_BLR(RelationName, FieldName) then
4103		begin
4104		Attributes := [faReadOnly];
#	Line 3594 | Line 4124 | begin
4124		FreeNodes;
4125		Database.InternalTransaction.Commit;
4126		FieldDefs.EndUpdate;
4127	+	FieldDefs.Updated := true;
4128		end;
4129		end;
4130
#	Line 3611 | Line 4142 | begin
4142		else begin
4143		Buffer := AllocRecordBuffer;
4144		try
4145	<	while FQSelect.Next <> nil do
4145	>	while FQSelect.Next do
4146		begin
4147		FetchCurrentRecordToBuffer(FQSelect, FRecordCount, Buffer);
4148		Inc(FRecordCount);
#	Line 3626 | Line 4157 | end;
4157		procedure TIBCustomDataSet.InternalSetParamsFromCursor;
4158		var
4159		i: Integer;
4160	<	cur_param: TIBXSQLVAR;
4160	>	cur_param: ISQLParam;
4161		cur_field: TField;
4162		s: TStream;
4163		begin
#	Line 3634 | Line 4165 | begin
4165		IBError(ibxeEmptyQuery, [nil]);
4166		if not FInternalPrepared then
4167		InternalPrepare;
4168	<	if (SQLParams.Count > 0) and (DataSource <> nil) and (DataSource.DataSet <> nil) then
4168	>	if (SQLParams.GetCount > 0) and (DataSource <> nil) and (DataSource.DataSet <> nil) then
4169		begin
4170	<	for i := 0 to SQLParams.Count - 1 do
4170	>	for i := 0 to SQLParams.GetCount - 1 do
4171		begin
4172		cur_field := DataSource.DataSet.FindField(SQLParams[i].Name);
4173		cur_param := SQLParams[i];
#	Line 3670 | Line 4201 | begin
4201		try
4202		s := DataSource.DataSet.
4203		CreateBlobStream(cur_field, bmRead);
4204	<	cur_param.LoadFromStream(s);
4204	>	cur_param.AsBlob := TIBDSBlobStream(s).FBlobStream.Blob;
4205		finally
4206		s.free;
4207		end;
4208		end;
4209	+	ftArray:
4210	+	cur_param.AsArray := TIBArrayField(cur_field).ArrayIntf;
4211		else
4212		IBError(ibxeNotSupported, [nil]);
4213		end;
#	Line 3707 | Line 4240 | procedure TIBCustomDataSet.InternalOpen;
4240		result := SizeOf(TRecordData) + ((n - 1) * SizeOf(TFieldData));
4241		end;
4242
3710	–	function GetFieldDef(aFieldNo: integer): TIBFieldDef;
3711	–	var i: integer;
3712	–	begin
3713	–	Result := nil;
3714	–	for i := 0 to FieldDefs.Count - 1 do
3715	–	if FieldDefs[i].FieldNo = aFieldNo then
3716	–	begin
3717	–	Result := TIBFieldDef(FieldDefs[i]);
3718	–	break;
3719	–	end;
3720	–	end;
3721	–
3722	–	procedure SetExtendedProperties;
3723	–	var i: integer;
3724	–	IBFieldDef: TIBFieldDef;
3725	–	begin
3726	–	for i := 0 to Fields.Count - 1 do
3727	–	if Fields[i].FieldNo > 0 then
3728	–	begin
3729	–	if(Fields[i] is TIBStringField) then
3730	–	with TIBStringField(Fields[i]) do
3731	–	begin
3732	–	IBFieldDef := GetFieldDef(FieldNo);
3733	–	if IBFieldDef <> nil then
3734	–	begin
3735	–	CharacterSetSize := IBFieldDef.CharacterSetSize;
3736	–	CharacterSetName := IBFieldDef.CharacterSetName;
3737	–	end;
3738	–	end
3739	–	else
3740	–	if(Fields[i] is TIBWideStringField) then
3741	–	with TIBWideStringField(Fields[i]) do
3742	–	begin
3743	–	IBFieldDef := GetFieldDef(FieldNo);
3744	–	if IBFieldDef <> nil then
3745	–	begin
3746	–	CharacterSetSize := IBFieldDef.CharacterSetSize;
3747	–	CharacterSetName := IBFieldDef.CharacterSetName;
3748	–	end;
3749	–	end
3750	–	else
3751	–	if(Fields[i] is TIBMemoField) then
3752	–	with TIBMemoField(Fields[i]) do
3753	–	begin
3754	–	IBFieldDef := GetFieldDef(FieldNo);
3755	–	if IBFieldDef <> nil then
3756	–	begin
3757	–	CharacterSetSize := IBFieldDef.CharacterSetSize;
3758	–	CharacterSetName := IBFieldDef.CharacterSetName;
3759	–	end;
3760	–	end
3761	–	else
3762	–	if(Fields[i] is TIBWideMemoField) then
3763	–	with TIBWideMemoField(Fields[i]) do
3764	–	begin
3765	–	IBFieldDef := GetFieldDef(FieldNo);
3766	–	if IBFieldDef <> nil then
3767	–	begin
3768	–	CharacterSetSize := IBFieldDef.CharacterSetSize;
3769	–	CharacterSetName := IBFieldDef.CharacterSetName;
3770	–	end;
3771	–	end
3772	–	end
3773	–	end;
3774	–
4243		begin
4244		FBase.SetCursor;
4245		try
#	Line 3781 | Line 4249 | begin
4249		IBError(ibxeEmptyQuery, [nil]);
4250		if not FInternalPrepared then
4251		InternalPrepare;
4252	<	if FQSelect.SQLType = SQLSelect then
4252	>	if FQSelect.SQLStatementType = SQLSelect then
4253		begin
4254		if DefaultFields then
4255		CreateFields;
4256	+	FArrayFieldCount := 0;
4257		BindFields(True);
3789	–	SetExtendedProperties;
4258		FCurrentRecord := -1;
4259		FQSelect.ExecQuery;
4260		FOpen := FQSelect.Open;
#	Line 3797 | Line 4265 | begin
4265		3. After the dummy fetch, FRecordSize will be appropriately
4266		adjusted to reflect the additional "weight" of the field
4267		data.
4268	<	4. Set up the FCalcFieldsOffset, FBlobCacheOffset and FRecordBufferSize.
4268	>	4. Set up the FCalcFieldsOffset, FBlobCacheOffset, FArrayCacheOffset and FRecordBufferSize.
4269		5. Now, with the BufferSize available, allocate memory for chunks of records
4270		6. Re-allocate the model buffer, accounting for the new
4271		FRecordBufferSize.
4272		7. Finally, calls to AllocRecordBuffer will work!.
4273		}
4274		{Step 1}
4275	<	FRecordSize := RecordDataLength(FQSelect.Current.Count);
4275	>	FRecordSize := RecordDataLength(FQSelect.FieldCount);
4276		{Step 2, 3}
4277	+	GetMem(FFieldColumns,sizeof(TFieldColumns) * (FQSelect.FieldCount));
4278		IBAlloc(FModelBuffer, 0, FRecordSize);
4279	<	FetchCurrentRecordToBuffer(FQSelect, -1, FModelBuffer);
4279	>	InitModelBuffer(FQSelect, FModelBuffer);
4280		{Step 4}
4281		FCalcFieldsOffset := FRecordSize;
4282		FBlobCacheOffset := FCalcFieldsOffset + CalcFieldsSize;
4283	<	FRecordBufferSize := (FBlobCacheOffset + (BlobFieldCount * SizeOf(TIBBlobStream)));
4283	>	FArrayCacheOffset := (FBlobCacheOffset + (BlobFieldCount * SizeOf(TIBBlobStream)));
4284	>	FRecordBufferSize := FArrayCacheOffset + (ArrayFieldCount * sizeof(IArray));
4285		{Step 5}
4286		if UniDirectional then
4287		FBufferChunkSize := FRecordBufferSize * UniCache
#	Line 3827 | Line 4297 | begin
4297		FCacheSize := FBufferChunkSize;
4298		FOldCacheSize := FBufferChunkSize;
4299		{Step 6}
4300	<	IBAlloc(FModelBuffer, RecordDataLength(FQSelect.Current.Count),
4300	>	IBAlloc(FModelBuffer, RecordDataLength(FQSelect.FieldCount),
4301		FRecordBufferSize);
4302		{Step 7}
4303		FOldBuffer := AllocRecordBuffer;
#	Line 3925 | Line 4395 | end;
4395		function TIBCustomDataSet.Locate(const KeyFields: string; const KeyValues: Variant;
4396		Options: TLocateOptions): Boolean;
4397		var
3928	–	{$IF FPC_FULLVERSION >= 20700 }
4398		CurBookmark: TBookmark;
3930	–	{$ELSE}
3931	–	CurBookmark: string;
3932	–	{$ENDIF}
4399		begin
4400		DisableControls;
4401		try
#	Line 3947 | Line 4413 | function TIBCustomDataSet.Lookup(const K
4413		const ResultFields: string): Variant;
4414		var
4415		fl: TList;
3950	–	{$IF FPC_FULLVERSION >= 20700 }
4416		CurBookmark: TBookmark;
3952	–	{$ELSE}
3953	–	CurBookmark: string;
3954	–	{$ENDIF}
4417		begin
4418		DisableControls;
4419		fl := TList.Create;
#	Line 4024 | Line 4486 | begin
4486		MappedFieldPos := FMappedFieldPosition[Field.FieldNo - 1];
4487		if (MappedFieldPos > 0) and
4488		(MappedFieldPos <= rdFieldCount) then
4489	+	with rdFields[MappedFieldPos], FFieldColumns^[MappedFieldPos] do
4490		begin
4491		Field.Validate(Buffer);
4492		if (Buffer = nil) or
4493		(Field is TIBStringField) and (PChar(Buffer)[0] = #0) then
4494	<	rdFields[MappedFieldPos].fdIsNull := True
4495	<	else begin
4496	<	Move(Buffer^, Buff[rdFields[MappedFieldPos].fdDataOfs],
4497	<	rdFields[MappedFieldPos].fdDataSize);
4498	<	if (rdFields[MappedFieldPos].fdDataType = SQL_TEXT) or
4499	<	(rdFields[MappedFieldPos].fdDataType = SQL_VARYING) then
4500	<	rdFields[MappedFieldPos].fdDataLength := StrLen(PChar(Buffer));
4038	<	rdFields[MappedFieldPos].fdIsNull := False;
4494	>	fdIsNull := True
4495	>	else
4496	>	begin
4497	>	Move(Buffer^, Buff[fdDataOfs],fdDataSize);
4498	>	if (fdDataType = SQL_TEXT) or (fdDataType = SQL_VARYING) then
4499	>	fdDataLength := StrLen(PChar(Buffer));
4500	>	fdIsNull := False;
4501		if rdUpdateStatus = usUnmodified then
4502		begin
4503		if CachedUpdates then
#	Line 4136 | Line 4598 | begin
4598		if FInternalPrepared then
4599		begin
4600		CheckDatasetClosed;
4601	+	if FDidActivate then
4602	+	DeactivateTransaction;
4603		FieldDefs.Clear;
4604		FieldDefs.Updated := false;
4605		FInternalPrepared := False;
#	Line 4156 | Line 4620 | begin
4620		IBError(ibxeEmptyQuery, [nil]);
4621		if not FInternalPrepared then
4622		InternalPrepare;
4623	<	if FQSelect.SQLType = SQLSelect then
4623	>	if FQSelect.SQLStatementType = SQLSelect then
4624		begin
4625		IBError(ibxeIsASelectStatement, [nil]);
4626		end
#	Line 4169 | Line 4633 | begin
4633		end;
4634		end;
4635
4636	<	function TIBCustomDataSet.GetSelectStmtHandle: TISC_STMT_HANDLE;
4636	>	function TIBCustomDataSet.GetSelectStmtIntf: IStatement;
4637		begin
4638	<	Result := FQSelect.Handle;
4638	>	Result := FQSelect.Statement;
4639		end;
4640
4641		function TIBCustomDataSet.GetParser: TSelectSQLParser;
#	Line 4226 | Line 4690 | end;
4690
4691		{ TIBDataSet IProviderSupport }
4692
4693	<	(*procedure TIBCustomDataSet.PSEndTransaction(Commit: Boolean);
4693	>	procedure TIBCustomDataSet.PSEndTransaction(Commit: Boolean);
4694		begin
4695		if Commit then
4696		Transaction.Commit else
#	Line 4379 | Line 4843 | begin
4843		Transaction.StartTransaction;
4844		end;
4845
4846	<	function TIBCustomDataSet.PSGetTableName: string;
4846	>	function TIBCustomDataSet.PsGetTableName: string;
4847		begin
4848		//  if not FInternalPrepared then
4849		//    InternalPrepare;
#	Line 4389 | Line 4853 | begin
4853		if not FQSelect.Prepared then
4854		FQSelect.Prepare;
4855		Result := FQSelect.UniqueRelationName;
4856	<	end;*)
4856	>	end;
4857
4858		procedure TIBDataSet.BatchInput(InputObject: TIBBatchInput);
4859		begin
#	Line 4520 | Line 4984 | begin
4984		inherited Destroy;
4985		end;
4986
4987	<	procedure TIBDataSetUpdateObject.SetRefreshSQL(Value: TStrings);
4987	>	procedure TIBDataSetUpdateObject.SetRefreshSQL(value: TStrings);
4988		begin
4989		FRefreshSQL.Assign(Value);
4990		end;
4991
4992	+	procedure TIBDataSetUpdateObject.InternalSetParams(Params: ISQLParams;
4993	+	buff: PChar);
4994	+	begin
4995	+	if not Assigned(DataSet) then Exit;
4996	+	DataSet.SetInternalSQLParams(Params, buff);
4997	+	end;
4998	+
4999		procedure TIBDataSetUpdateObject.InternalSetParams(Query: TIBSQL; buff: PChar);
5000		begin
5001	+	InternalSetParams(Query.Params,buff);
5002	+	end;
5003	+
5004	+	procedure TIBDataSetUpdateObject.UpdateRecordFromQuery(QryResults: IResults;
5005	+	Buffer: PChar);
5006	+	begin
5007		if not Assigned(DataSet) then Exit;
5008	<	DataSet.SetInternalSQLParams(Query, buff);
5008	>	DataSet.UpdateRecordFromQuery(QryResults, Buffer);
5009	>	end;
5010	>
5011	>	function TIBDSBlobStream.GetSize: Int64;
5012	>	begin
5013	>	Result := FBlobStream.BlobSize;
5014		end;
5015
5016		{ TIBDSBlobStream }
#	Line 4539 | Line 5021 | begin
5021		FBlobStream := ABlobStream;
5022		FBlobStream.Seek(0, soFromBeginning);
5023		if (Mode = bmWrite) then
5024	+	begin
5025		FBlobStream.Truncate;
5026	+	TIBCustomDataSet(FField.DataSet).RecordModified(True);
5027	+	TBlobField(FField).Modified := true;
5028	+	FHasWritten := true;
5029	+	end;
5030		end;
5031
5032		destructor TIBDSBlobStream.Destroy;
#	Line 4581 | Line 5068 | end;
5068
5069		procedure TIBGenerator.SetIncrement(const AValue: integer);
5070		begin
5071	+	if FIncrement = AValue then Exit;
5072		if AValue < 0 then
5073	<	raise Exception.Create('A Generator Increment cannot be negative');
5074	<	FIncrement := AValue
5073	>	IBError(ibxeNegativeGenerator,[]);
5074	>	FIncrement := AValue;
5075	>	SetQuerySQL;
5076		end;
5077
5078	<	function TIBGenerator.GetNextValue(ADatabase: TIBDatabase;
4590	<	ATransaction: TIBTransaction): integer;
5078	>	procedure TIBGenerator.SetTransaction(AValue: TIBTransaction);
5079		begin
5080	<	with TIBSQL.Create(nil) do
5081	<	try
5082	<	Database := ADatabase;
5083	<	Transaction := ATransaction;
5084	<	if not assigned(Database) then
5085	<	IBError(ibxeCannotSetDatabase,[]);
5086	<	if not assigned(Transaction) then
5087	<	IBError(ibxeCannotSetTransaction,[]);
5088	<	with Transaction do
5089	<	if not InTransaction then StartTransaction;
5090	<	SQL.Text := Format('Select Gen_ID(%s,%d) as ID From RDB$Database',[FGeneratorName,Increment]);
5091	<	Prepare;
5080	>	FQuery.Transaction := AValue;
5081	>	end;
5082	>
5083	>	procedure TIBGenerator.SetQuerySQL;
5084	>	begin
5085	>	FQuery.SQL.Text := Format('Select Gen_ID(%s,%d) From RDB$Database',[FGeneratorName,Increment]);
5086	>	end;
5087	>
5088	>	function TIBGenerator.GetDatabase: TIBDatabase;
5089	>	begin
5090	>	Result := FQuery.Database;
5091	>	end;
5092	>
5093	>	function TIBGenerator.GetTransaction: TIBTransaction;
5094	>	begin
5095	>	Result := FQuery.Transaction;
5096	>	end;
5097	>
5098	>	procedure TIBGenerator.SetDatabase(AValue: TIBDatabase);
5099	>	begin
5100	>	FQuery.Database := AValue;
5101	>	end;
5102	>
5103	>	procedure TIBGenerator.SetGeneratorName(AValue: string);
5104	>	begin
5105	>	if FGeneratorName = AValue then Exit;
5106	>	FGeneratorName := AValue;
5107	>	SetQuerySQL;
5108	>	end;
5109	>
5110	>	function TIBGenerator.GetNextValue: integer;
5111	>	begin
5112	>	with FQuery do
5113	>	begin
5114	>	Transaction.Active := true;
5115		ExecQuery;
5116		try
5117	<	Result := FieldByName('ID').AsInteger
5117	>	Result := Fields[0].AsInteger
5118		finally
5119		Close
5120		end;
4610	–	finally
4611	–	Free
5121		end;
5122		end;
5123
#	Line 4616 | Line 5125 | constructor TIBGenerator.Create(Owner: T
5125		begin
5126		FOwner := Owner;
5127		FIncrement := 1;
5128	+	FQuery := TIBSQL.Create(nil);
5129	+	end;
5130	+
5131	+	destructor TIBGenerator.Destroy;
5132	+	begin
5133	+	if assigned(FQuery) then FQuery.Free;
5134	+	inherited Destroy;
5135		end;
5136
5137
5138		procedure TIBGenerator.Apply;
5139		begin
5140	<	if (FGeneratorName <> '') and (FFieldName <> '') and Owner.FieldByName(FFieldName).IsNull then
5141	<	Owner.FieldByName(FFieldName).AsInteger := GetNextValue(Owner.Database,Owner.Transaction);
5140	>	if assigned(Database) and assigned(Transaction) and
5141	>	(FGeneratorName <> '') and (FFieldName <> '') and Owner.FieldByName(FFieldName).IsNull then
5142	>	Owner.FieldByName(FFieldName).AsInteger := GetNextValue;
5143		end;
5144
5145

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines