ViewVC Help

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

root/public/ibx/branches/journaling/fbintf/client/FBStatement.pas

Comparing ibx/trunk/fbintf/client/FBStatement.pas (file contents):
Revision 315 by tony, Thu Feb 25 11:56:36 2021 UTC vs.
Revision 345 by tony, Mon Aug 23 14:22:29 2021 UTC

#	Line 44 | Line 44 | uses
44		Classes, SysUtils,  IB,  FBClientAPI, FBSQLData, FBOutputBlock, FBActivityMonitor,
45		FBTransaction;
46
47	+	const
48	+	DefaultBatchRowLimit = 1000;
49	+
50		type
51		TPerfStatistics = array[psCurrentMemory..psFetches] of Int64;
52
#	Line 74 | Line 77 | type
77		FBeforeStats: TPerfStatistics;
78		FAfterStats: TPerfStatistics;
79		FCaseSensitiveParams: boolean;
80	+	FBatchRowLimit: integer;
81	+	procedure CheckChangeBatchRowLimit; virtual;
82		procedure CheckHandle; virtual; abstract;
83		procedure CheckTransaction(aTransaction: ITransaction);
84		procedure GetDsqlInfo(info_request: byte; buffer: ISQLInfoResults); overload; virtual; abstract;
85		procedure InternalPrepare;  virtual; abstract;
86	<	function InternalExecute(aTransaction: ITransaction): IResults;  virtual; abstract;
86	>	function InternalExecute(Transaction: ITransaction): IResults;  virtual; abstract;
87		function InternalOpenCursor(aTransaction: ITransaction): IResultSet;   virtual; abstract;
88		procedure ProcessSQL(sql: AnsiString; GenerateParamNames: boolean; var processedSQL: AnsiString); virtual; abstract;
89		procedure FreeHandle;  virtual; abstract;
#	Line 102 | Line 107 | type
107		function GetRowsAffected(var SelectCount, InsertCount, UpdateCount,
108		DeleteCount: integer): boolean;
109		function GetSQLStatementType: TIBSQLStatementTypes;
110	+	function GetSQLStatementTypeName: AnsiString;
111		function GetSQLText: AnsiString;
112		function GetProcessedSQLText: AnsiString;
113		function GetSQLDialect: integer;
#	Line 122 | Line 128 | type
128		procedure SetRetainInterfaces(aValue: boolean); virtual;
129		procedure EnableStatistics(aValue: boolean);
130		function GetPerfStatistics(var stats: TPerfCounters): boolean;
131	+	function IsInBatchMode: boolean; virtual;
132	+	function HasBatchMode: boolean; virtual;
133	+	public
134	+	{IBatch support}
135	+	procedure AddToBatch; virtual;
136	+	function ExecuteBatch(aTransaction: ITransaction): IBatchCompletion; virtual;
137	+	procedure CancelBatch; virtual;
138	+	function GetBatchCompletion: IBatchCompletion; virtual;
139	+	function GetBatchRowLimit: integer;
140	+	procedure SetBatchRowLimit(aLimit: integer);
141	+	public
142		property ChangeSeqNo: integer read FChangeSeqNo;
143		property SQLParams: ISQLParams read GetSQLParams;
144		property SQLStatementType: TIBSQLStatementTypes read GetSQLStatementType;
#	Line 133 | Line 150 | uses FBMessages;
150
151		{ TFBStatement }
152
153	+	procedure TFBStatement.CheckChangeBatchRowLimit;
154	+	begin
155	+	//Do Nothing
156	+	end;
157	+
158		procedure TFBStatement.CheckTransaction(aTransaction: ITransaction);
159		begin
160		if (aTransaction = nil) then
#	Line 156 | Line 178 | begin
178		FFirebirdClientAPI := Attachment.getFirebirdAPI as TFBClientAPI;
179		FSQLDialect := SQLDialect;
180		FSQL := sql;
181	+	FBatchRowLimit := DefaultBatchRowLimit;
182		end;
183
184		constructor TFBStatement.CreateWithParameterNames(Attachment: IAttachment;
#	Line 231 | Line 254 | begin
254		Result := FSQLStatementType;
255		end;
256
257	+	function TFBStatement.GetSQLStatementTypeName: AnsiString;
258	+	begin
259	+	case FSQLStatementType of
260	+	SQLUnknown: Result := 'SQL_Unknown';
261	+	SQLSelect: Result := 'SQL_Select';
262	+	SQLInsert: Result := 'SQL_Insert';
263	+	SQLUpdate: Result := 'SQL_Update';
264	+	SQLDelete: Result := 'SQL_Delete';
265	+	SQLDDL: Result := 'SQL_DDL';
266	+	SQLGetSegment: Result := 'SQL_GetSegment';
267	+	SQLPutSegment: Result := 'SQL_PutSegment';
268	+	SQLExecProcedure: Result := 'SQL_ExecProcedure';
269	+	SQLStartTransaction: Result := 'SQL_StartTransaction';
270	+	SQLCommit: Result := 'SQL_Commit';
271	+	SQLRollback: Result := 'SQL_Rollback';
272	+	SQLSelectForUpdate: Result := 'SQL_SelectForUpdate';
273	+	SQLSetGenerator: Result := 'SQL_SetGenerator';
274	+	SQLSavePoint: Result := 'SQL_SavePoint';
275	+	end;
276	+	end;
277	+
278		function TFBStatement.GetSQLText: AnsiString;
279		begin
280		Result := FSQL;
#	Line 268 | Line 312 | begin
312		Result := InternalExecute(aTransaction);
313		end;
314
315	+	procedure TFBStatement.AddToBatch;
316	+	begin
317	+	IBError(ibxeBatchModeNotSupported,[]);
318	+	end;
319	+
320	+	function TFBStatement.ExecuteBatch(aTransaction: ITransaction
321	+	): IBatchCompletion;
322	+	begin
323	+	IBError(ibxeBatchModeNotSupported,[]);
324	+	end;
325	+
326	+	procedure TFBStatement.CancelBatch;
327	+	begin
328	+	IBError(ibxeBatchModeNotSupported,[]);
329	+	end;
330	+
331	+	function TFBStatement.GetBatchCompletion: IBatchCompletion;
332	+	begin
333	+	IBError(ibxeBatchModeNotSupported,[]);
334	+	end;
335	+
336	+	function TFBStatement.GetBatchRowLimit: integer;
337	+	begin
338	+	Result := FBatchRowLimit;
339	+	end;
340	+
341	+	procedure TFBStatement.SetBatchRowLimit(aLimit: integer);
342	+	begin
343	+	CheckChangeBatchRowLimit;
344	+	FBatchRowLimit := aLimit;
345	+	end;
346	+
347		function TFBStatement.OpenCursor(aTransaction: ITransaction): IResultSet;
348		begin
349		Close;
#	Line 356 | Line 432 | begin
432		end;
433		end;
434
435	+	function TFBStatement.IsInBatchMode: boolean;
436	+	begin
437	+	Result := false;
438	+	end;
439	+
440	+	function TFBStatement.HasBatchMode: boolean;
441	+	begin
442	+	Result := false;
443	+	end;
444	+
445		end.
446

Diff Legend

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