ViewVC Help

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

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

Comparing ibx/trunk/runtime/IBDatabase.pas (file contents):
Revision 39 by tony, Tue May 17 08:14:52 2016 UTC vs.
Revision 80 by tony, Mon Jan 1 11:31:07 2018 UTC

#	Line 35 | Line 35 | unit IBDatabase;
35
36		{$Mode Delphi}
37
38	–	{$IF FPC_FULLVERSION >= 20700 }
38		{$codepage UTF8}
40	–	{$DEFINE HAS_ANSISTRING_CODEPAGE}
41	–	{$ENDIF}
39
40		interface
41
#	Line 48 | Line 45 | uses
45		{$ELSE}
46		unix,
47		{$ENDIF}
48	<	SysUtils, Classes, FPTimer, IBHeader, IBExternals, DB,
52	<	IB, CustApp;
48	>	SysUtils, Classes, FPTimer, IBExternals, DB, IB, CustApp, IBTypes;
49
50		const
51		DPBPrefix = 'isc_dpb_';
#	Line 120 | Line 116 | const
116		'set_db_readonly',
117		'set_db_sql_dialect',
118		'gfix_attach',
119	<	'gstat_attach'
119	>	'gstat_attach',
120	>	'set_db_charset',
121	>	'gsec_attach',
122	>	'address_path' ,
123	>	'process_id',
124	>	'no_db_triggers',
125	>	'trusted_auth',
126	>	'process_name',
127	>	'trusted_role',
128	>	'org_filename',
129	>	'utf8_ilename',
130	>	'ext_call_depth'
131		);
132
133		TPBPrefix = 'isc_tpb_';
#	Line 144 | Line 151 | const
151		'rec_version',
152		'no_rec_version',
153		'restart_requests',
154	<	'no_auto_undo'
154	>	'no_auto_undo',
155	>	'lock_timeout'
156		);
157
158		type
#	Line 160 | Line 168 | type
168		{ TIBDatabase }
169		TIBDataBase = class(TCustomConnection)
170		private
171	+	FAttachment: IAttachment;
172	+	FCreateDatabase: boolean;
173	+	FCreateIfNotExists: boolean;
174	+	FDefaultCharSetID: integer;
175	+	FDefaultCharSetName: RawByteString;
176	+	FDefaultCodePage: TSystemCodePage;
177	+	FDPB: IDPB;
178		FAllowStreamedConnected: boolean;
179		FHiddenPassword: string;
180	<	FIBLoaded: Boolean;
180	>	FOnCreateDatabase: TNotifyEvent;
181		FOnLogin: TIBDatabaseLoginEvent;
182		FSQLHourGlass: Boolean;
183		FTraceFlags: TTraceFlags;
184		FDBSQLDialect: Integer;
185		FSQLDialect: Integer;
186		FOnDialectDowngradeWarning: TNotifyEvent;
172	–	FCanTimeout: Boolean;
187		FSQLObjects: TList;
188		FTransactions: TList;
189		FDBName: TIBFileName;
190		FDBParams: TStrings;
191		FDBParamsChanged: Boolean;
178	–	FDPB: PChar;
179	–	FDPBLength: Short;
180	–	FHandle: TISC_DB_HANDLE;
181	–	FHandleIsShared: Boolean;
192		FOnIdleTimer: TNotifyEvent;
193		FDefaultTransaction: TIBTransaction;
194		FInternalTransaction: TIBTransaction;
185	–	FStreamedConnected: Boolean;
195		FTimer: TFPTimer;
196		FUserNames: TStringList;
197		FDataSets: TList;
198		FLoginCalled: boolean;
190	–	FCharSetSizes: array of integer;
191	–	FCharSetNames: array of RawByteString;
192	–	FDefaultCharSetName: RawByteString;
193	–	{$IFDEF HAS_ANSISTRING_CODEPAGE}
194	–	FCodePages: array of TSystemCodePage;
195	–	FDefaultCodePage: TSystemCodePage;
196	–	{$ENDIF}
199		FUseDefaultSystemCodePage: boolean;
200		procedure EnsureInactive;
201		function GetDBSQLDialect: Integer;
#	Line 204 | Line 206 | type
206		procedure DBParamsChanging(Sender: TObject);
207		function GetSQLObject(Index: Integer): TIBBase;
208		function GetSQLObjectCount: Integer;
207	–	function GetDBParamByDPB(const Idx: Integer): String;
209		function GetIdleTimer: Integer;
210		function GetTransaction(Index: Integer): TIBTransaction;
211		function GetTransactionCount: Integer;
212		function Login(var aDatabaseName: string): Boolean;
212	–	procedure LoadCharSetInfo;
213		procedure SetDatabaseName(const Value: TIBFileName);
214		procedure SetDBParamByDPB(const Idx: Integer; Value: String);
215		procedure SetDBParams(Value: TStrings);
#	Line 240 | Line 240 | type
240		procedure CloseDataSets;
241		procedure CheckActive;
242		procedure CheckInactive;
243	<	procedure CreateDatabase;
243	>	procedure CreateDatabase; overload;
244	>	procedure CreateDatabase(createDatabaseSQL: string); overload;
245		procedure DropDatabase;
246		procedure ForceClose;
247		procedure GetFieldNames(const TableName: string; List: TStrings);
#	Line 248 | Line 249 | type
249		function IndexOfDBConst(st: String): Integer;
250		function TestConnected: Boolean;
251		procedure CheckDatabaseName;
251	–	function Call(ErrCode: ISC_STATUS; RaiseError: Boolean): ISC_STATUS;
252		function AddTransaction(TR: TIBTransaction): Integer;
253		function FindTransaction(TR: TIBTransaction): Integer;
254		function FindDefaultTransaction(): TIBTransaction;
255		procedure RemoveTransaction(Idx: Integer);
256		procedure RemoveTransactions;
257	–	procedure SetHandle(Value: TISC_DB_HANDLE);
257
258	<	property Handle: TISC_DB_HANDLE read FHandle;
258	>	property Attachment: IAttachment read FAttachment;
259	>	property DBSQLDialect : Integer read FDBSQLDialect;
260		property IsReadOnly: Boolean read GetIsReadOnly;
261	–	property DBParamByDPB[const Idx: Integer]: String read GetDBParamByDPB
262	–	write SetDBParamByDPB;
261		property SQLObjectCount: Integer read GetSQLObjectCount;
262		property SQLObjects[Index: Integer]: TIBBase read GetSQLObject;
265	–	property HandleIsShared: Boolean read FHandleIsShared;
263		property TransactionCount: Integer read GetTransactionCount;
264		property Transactions[Index: Integer]: TIBTransaction read GetTransaction;
265		property InternalTransaction: TIBTransaction read FInternalTransaction;
266		property DefaultCharSetName: RawByteString read FDefaultCharSetName;
267	<	{$IFDEF HAS_ANSISTRING_CODEPAGE}
267	>	property DefaultCharSetID: integer read FDefaultCharSetID;
268		property DefaultCodePage: TSystemCodePage read FDefaultCodePage;
272	–	{$ENDIF}
269
270		published
271		property Connected;
272	+	property CreateIfNotExists: boolean read FCreateIfNotExists write FCreateIfNotExists;
273		property AllowStreamedConnected: boolean read FAllowStreamedConnected
274		write FAllowStreamedConnected;
275		property DatabaseName: TIBFileName read FDBName write SetDatabaseName;
#	Line 283 | Line 280 | type
280		property IdleTimer: Integer read GetIdleTimer write SetIdleTimer;
281		property SQLDialect : Integer read GetSQLDialect write SetSQLDialect default 3;
282		property SQLHourGlass: Boolean read FSQLHourGlass write FSQLHourGlass default true;
286	–	property DBSQLDialect : Integer read FDBSQLDialect;
283		property TraceFlags: TTraceFlags read FTraceFlags write FTraceFlags;
284		property UseDefaultSystemCodePage: boolean read FUseDefaultSystemCodePage
285		write FUseDefaultSystemCodePage;
#	Line 291 | Line 287 | type
287		property AfterDisconnect;
288		property BeforeConnect;
289		property BeforeDisconnect;
290	+	property OnCreateDatabase: TNotifyEvent read FOnCreateDatabase write FOnCreateDatabase;
291		property OnLogin: TIBDatabaseLoginEvent read FOnLogin write FOnLogin;
292		property OnIdleTimer: TNotifyEvent read FOnIdleTimer write FOnIdleTimer;
293		property OnDialectDowngradeWarning: TNotifyEvent read FOnDialectDowngradeWarning write FOnDialectDowngradeWarning;
294		end;
295
296	<	{ TIBTransaction }
296	>	TDefaultEndAction = TARollback..TACommit;
297
298	<	TTransactionAction         = (TARollback, TACommit, TARollbackRetaining, TACommitRetaining);
298	>	{ TIBTransaction }
299
300		TIBTransaction = class(TComponent)
301		private
302	+	FTransactionIntf: ITransaction;
303		FAfterDelete: TNotifyEvent;
304		FAfterEdit: TNotifyEvent;
305		FAfterExecQuery: TNotifyEvent;
#	Line 309 | Line 307 | type
307		FAfterPost: TNotifyEvent;
308		FAfterTransactionEnd: TNotifyEvent;
309		FBeforeTransactionEnd: TNotifyEvent;
312	–	FIBLoaded: Boolean;
313	–	FCanTimeout         : Boolean;
310		FDatabases          : TList;
311		FOnStartTransaction: TNotifyEvent;
312		FSQLObjects         : TList;
313		FDefaultDatabase    : TIBDatabase;
318	–	FHandle             : TISC_TR_HANDLE;
319	–	FHandleIsShared     : Boolean;
314		FOnIdleTimer          : TNotifyEvent;
315		FStreamedActive     : Boolean;
316	<	FTPB                : PChar;
323	<	FTPBLength          : Short;
316	>	FTPB                : ITPB;
317		FTimer              : TFPTimer;
318	<	FDefaultAction      : TTransactionAction;
318	>	FDefaultAction      : TDefaultEndAction;
319		FTRParams           : TStrings;
320		FTRParamsChanged    : Boolean;
321		FInEndTransaction   : boolean;
#	Line 345 | Line 338 | type
338		function GetIdleTimer: Integer;
339		procedure BeforeDatabaseDisconnect(DB: TIBDatabase);
340		procedure SetActive(Value: Boolean);
348	–	procedure SetDefaultAction(Value: TTransactionAction);
341		procedure SetDefaultDatabase(Value: TIBDatabase);
342		procedure SetIdleTimer(Value: Integer);
343		procedure SetTRParams(Value: TStrings);
#	Line 358 | Line 350 | type
350
351		protected
352		procedure Loaded; override;
361	–	procedure SetHandle(Value: TISC_TR_HANDLE);
353		procedure Notification( AComponent: TComponent; Operation: TOperation); override;
354
355		public
356		constructor Create(AOwner: TComponent); override;
357		destructor Destroy; override;
367	–	function Call(ErrCode: ISC_STATUS; RaiseError: Boolean): ISC_STATUS;
358		procedure Commit;
359		procedure CommitRetaining;
360		procedure Rollback;
#	Line 385 | Line 375 | type
375		property Databases[Index: Integer]: TIBDatabase read GetDatabase;
376		property SQLObjectCount: Integer read GetSQLObjectCount;
377		property SQLObjects[Index: Integer]: TIBBase read GetSQLObject;
388	–	property Handle: TISC_TR_HANDLE read FHandle;
389	–	property HandleIsShared: Boolean read FHandleIsShared;
378		property InTransaction: Boolean read GetInTransaction;
379	<	property TPB: PChar read FTPB;
380	<	property TPBLength: Short read FTPBLength;
379	>	property TransactionIntf: ITransaction read FTransactionIntf;
380	>	property TPB: ITPB read FTPB;
381		published
382		property Active: Boolean read GetInTransaction write SetActive;
383		property DefaultDatabase: TIBDatabase read FDefaultDatabase
384		write SetDefaultDatabase;
385		property IdleTimer: Integer read GetIdleTimer write SetIdleTimer default 0;
386	<	property DefaultAction: TTransactionAction read FDefaultAction write SetDefaultAction default taCommit;
386	>	property DefaultAction: TDefaultEndAction read FDefaultAction write FDefaultAction default taCommit;
387		property Params: TStrings read FTRParams write SetTRParams;
388		property OnIdleTimer: TNotifyEvent read FOnIdleTimer write FOnIdleTimer;
389		property BeforeTransactionEnd: TNotifyEvent read FBeforeTransactionEnd
#	Line 446 | Line 434 | type
434		procedure DoBeforeTransactionEnd(Action: TTransactionAction); virtual;
435		procedure DoAfterTransactionEnd; virtual;
436		procedure DoTransactionFree; virtual;
449	–	function GetDBHandle: PISC_DB_HANDLE; virtual;
450	–	function GetTRHandle: PISC_TR_HANDLE; virtual;
437		procedure SetDatabase(Value: TIBDatabase); virtual;
438		procedure SetTransaction(Value: TIBTransaction); virtual;
439		public
#	Line 460 | Line 446 | type
446		procedure DoAfterDelete(Sender: TObject); virtual;
447		procedure DoAfterInsert(Sender: TObject); virtual;
448		procedure DoAfterPost(Sender: TObject); virtual;
463	–	function GetCharSetSize(CharSetID: integer): integer;
464	–	function GetDefaultCharSetSize: integer;
465	–	function GetCharSetName(CharSetID: integer): string;
466	–	function GetDefaultCharSetName: RawByteString;
467	–	{$IFDEF HAS_ANSISTRING_CODEPAGE}
468	–	function GetCodePage(CharSetID: integer): TSystemCodePage;
469	–	function GetDefaultCodePage: TSystemCodePage;
470	–	{$ENDIF}
449		procedure HandleException(Sender: TObject);
450		procedure SetCursor;
451		procedure RestoreCursor;
#	Line 486 | Line 464 | type
464		property OnTransactionFree: TNotifyEvent read FOnTransactionFree write FOnTransactionFree;
465		property Database: TIBDatabase read FDatabase
466		write SetDatabase;
489	–	property DBHandle: PISC_DB_HANDLE read GetDBHandle;
467		property Owner: TObject read FOwner;
491	–	property TRHandle: PISC_TR_HANDLE read GetTRHandle;
468		property Transaction: TIBTransaction read FTransaction
469		write SetTransaction;
470		end;
471
472	<	procedure GenerateDPB(sl: TStrings; var DPB: string; var DPBLength: Short);
473	<	procedure GenerateTPB(sl: TStrings; var TPB: string; var TPBLength: Short);
472	>	function GenerateDPB(sl: TStrings): IDPB;
473	>	function GenerateTPB(sl: TStrings): ITPB;
474
475
476		implementation
477
478	<	uses IBIntf, IBSQLMonitor, IBCustomDataSet, IBDatabaseInfo, IBSQL, IBUtils,
479	<	typInfo, IBCodePage;
478	>	uses  IBSQLMonitor, IBCustomDataSet, IBDatabaseInfo, IBSQL, IBUtils,
479	>	typInfo, FBMessages, IBErrorCodes, RegExpr;
480
481		{ TIBDatabase }
482
483		constructor TIBDataBase.Create(AOwner: TComponent);
484		begin
485		inherited Create(AOwner);
510	–	FIBLoaded := False;
511	–	CheckIBLoaded;
512	–	FIBLoaded := True;
486		LoginPrompt := True;
487		FSQLObjects := TList.Create;
488		FTransactions := TList.Create;
#	Line 520 | Line 493 | begin
493		(AOwner is TCustomApplication) and
494		TCustomApplication(AOWner).ConsoleApplication then
495		LoginPrompt := false;
523	–	{$IFDEF HAS_ANSISTRING_CODEPAGE}
524	–	FDefaultCodePage := CP_NONE;
525	–	{$ENDIF}
496		FDBParamsChanged := True;
497		TStringList(FDBParams).OnChange := DBParamsChange;
498		TStringList(FDBParams).OnChanging := DBParamsChanging;
499		FDPB := nil;
530	–	FHandle := nil;
500		FUserNames := nil;
501		FInternalTransaction := TIBTransaction.Create(self);
502		FInternalTransaction.DefaultDatabase := Self;
#	Line 542 | Line 511 | begin
511		CheckStreamConnect;
512		end;
513
514	<	destructor TIBDataBase.Destroy;
514	>	destructor TIBDataBase.Destroy;
515		var
516		i: Integer;
517		begin
518	<	if FIBLoaded then
519	<	begin
520	<	IdleTimer := 0;
521	<	if FHandle <> nil then
522	<	ForceClose;
523	<	for i := 0 to FSQLObjects.Count - 1 do
524	<	if FSQLObjects[i] <> nil then
525	<	SQLObjects[i].DoDatabaseFree;
526	<	RemoveSQLObjects;
527	<	RemoveTransactions;
528	<	FInternalTransaction.Free;
529	<	FreeMem(FDPB);
530	<	FDPB := nil;
531	<	FDBParams.Free;
563	<	FSQLObjects.Free;
564	<	FUserNames.Free;
565	<	FTransactions.Free;
566	<	end;
518	>	IdleTimer := 0;
519	>	if FAttachment <> nil then
520	>	ForceClose;
521	>	for i := 0 to FSQLObjects.Count - 1 do
522	>	if FSQLObjects[i] <> nil then
523	>	SQLObjects[i].DoDatabaseFree;
524	>	RemoveSQLObjects;
525	>	RemoveTransactions;
526	>	FInternalTransaction.Free;
527	>	FDPB := nil;
528	>	FDBParams.Free;
529	>	FSQLObjects.Free;
530	>	FUserNames.Free;
531	>	FTransactions.Free;
532		FDataSets.Free;
533		inherited Destroy;
534		end;
535
571	–	function TIBDataBase.Call(ErrCode: ISC_STATUS; RaiseError: Boolean
572	–	): ISC_STATUS;
573	–	begin
574	–	result := ErrCode;
575	–	FCanTimeout := False;
576	–	if RaiseError and (ErrCode > 0) then
577	–	IBDataBaseError;
578	–	end;
579	–
536		procedure TIBDataBase.CheckActive;
537		begin
538		if StreamedConnected and (not Connected) then
539		Loaded;
540	<	if FHandle = nil then
540	>	if FAttachment = nil then
541		IBError(ibxeDatabaseClosed, [nil]);
542		end;
543
#	Line 589 | Line 545 | end;
545		begin
546		if csDesigning in ComponentState then
547		begin
548	<	if FHandle <> nil then
548	>	if FAttachment <> nil then
549		Close;
550		end
551		end;
552
553		procedure TIBDataBase.CheckInactive;
554		begin
555	<	if FHandle <> nil then
555	>	if FAttachment <> nil then
556		IBError(ibxeDatabaseOpen, [nil]);
557		end;
558
#	Line 641 | Line 597 | begin
597		if Connected then
598		InternalClose(False);
599		FDBSQLDialect := 1;
644	–	SetLength(FCharSetSizes,0);
645	–	SetLength(FCharSetNames,0);
600		FDefaultCharSetName := '';
601	<	{$IFDEF HAS_ANSISTRING_CODEPAGE}
648	<	SetLength(FCodePages,0);
601	>	FDefaultCharSetID := 0;
602		FDefaultCodePage := CP_NONE;
650	–	{$ENDIF}
603		end;
604
605	<	procedure TIBDataBase.CreateDatabase;
654	<	var
655	<	tr_handle: TISC_TR_HANDLE;
605	>	procedure TIBDataBase.CreateDatabase;
606		begin
607		CheckInactive;
608	<	tr_handle := nil;
609	<	Call(
610	<	isc_dsql_execute_immediate(StatusVector, @FHandle, @tr_handle, 0,
611	<	PChar('CREATE DATABASE ''' + FDBName + ''' ' + {do not localize}
612	<	Params.Text), SQLDialect, nil),
613	<	True);
608	>	CheckDatabaseName;
609	>	FCreateDatabase := true;
610	>	Connected := true;
611	>	end;
612	>
613	>	procedure TIBDataBase.CreateDatabase(createDatabaseSQL: string);
614	>	var RegexObj: TRegExpr;
615	>	begin
616	>	CheckInactive;
617	>	FAttachment := FirebirdAPI.CreateDatabase(createDatabaseSQL,FSQLDialect);
618	>	RegexObj := TRegExpr.Create;
619	>	try
620	>	{extact database file spec}
621	>	RegexObj.ModifierG := false; {turn off greedy matches}
622	>	RegexObj.Expression := '^ *CREATE +(DATABASE|SCHEMA) +''(.*)''';
623	>	if RegexObj.Exec(AnsiUpperCase(createDatabaseSQL)) then
624	>	FDBName := system.copy(createDatabaseSQL,RegexObj.MatchPos[2],RegexObj.MatchLen[2]);
625	>	finally
626	>	RegexObj.Free;
627	>	end;
628	>	if assigned(FOnCreateDatabase) and (FAttachment <> nil) then
629	>	OnCreateDatabase(self);
630		end;
631
632		procedure TIBDataBase.DropDatabase;
633		begin
634		CheckActive;
635	<	Call(isc_drop_database(StatusVector, @FHandle), True);
635	>	FAttachment.DropDatabase;
636	>	FAttachment := nil;
637		end;
638
639		procedure TIBDataBase.DBParamsChange(Sender: TObject);
#	Line 719 | Line 686 | end;
686
687		function TIBDataBase.GetConnected: Boolean;
688		begin
689	<	result := FHandle <> nil;
689	>	result := (FAttachment <> nil) and FAttachment.IsConnected;
690		end;
691
692		function TIBDataBase.GetSQLObject(Index: Integer): TIBBase;
#	Line 736 | Line 703 | begin
703		Inc(result);
704		end;
705
706	<	function TIBDataBase.GetDBParamByDPB( const Idx: Integer): String;
740	<	var
741	<	ConstIdx, EqualsIdx: Integer;
742	<	begin
743	<	if (Idx > 0) and (Idx <= isc_dpb_last_dpb_constant) then
744	<	begin
745	<	ConstIdx := IndexOfDBConst(DPBConstantNames[Idx]);
746	<	if ConstIdx = -1 then
747	<	result := ''
748	<	else
749	<	begin
750	<	result := Params[ConstIdx];
751	<	EqualsIdx := Pos('=', result); {mbcs ok}
752	<	if EqualsIdx = 0 then
753	<	result := ''
754	<	else
755	<	result := Copy(result, EqualsIdx + 1, Length(result));
756	<	end;
757	<	end
758	<	else
759	<	result := '';
760	<	end;
761	<
762	<	function TIBDataBase.GetIdleTimer: Integer;
706	>	function TIBDataBase.GetIdleTimer: Integer;
707		begin
708		result := FTimer.Interval;
709		end;
#	Line 824 | Line 768 | begin
768		end;
769		end;
770
771	<	if (not HandleIsShared) and
772	<	(Call(isc_detach_database(StatusVector, @FHandle), False) > 0) and
829	<	(not Force) then
830	<	IBDataBaseError
831	<	else
832	<	begin
833	<	FHandle := nil;
834	<	FHandleIsShared := False;
835	<	end;
771	>	FAttachment.Disconnect(Force);
772	>	FAttachment := nil;
773
774		if not (csDesigning in ComponentState) then
775		MonitorHook.DBDisconnect(Self);
#	Line 842 | Line 779 | begin
779		SQLObjects[i].DoAfterDatabaseDisconnect;
780		end;
781
845	–	procedure TIBDataBase.LoadCharSetInfo;
846	–	var Query: TIBSQL;
847	–	i: integer;
848	–	begin
849	–	if not FInternalTransaction.Active then
850	–	FInternalTransaction.StartTransaction;
851	–	Query := TIBSQL.Create(self);
852	–	try
853	–	Query.Database := Self;
854	–	Query.Transaction := FInternalTransaction;
855	–	Query.SQL.Text := 'Select RDB$CHARACTER_SET_ID, RDB$BYTES_PER_CHARACTER, RDB$CHARACTER_SET_NAME ' +
856	–	'From RDB$CHARACTER_SETS Order by 1 DESC'; {do not localize}
857	–	Query.Prepare;
858	–	Query.ExecQuery;
859	–	if not Query.EOF then
860	–	begin
861	–	SetLength(FCharSetSizes,Query.FieldByName('RDB$CHARACTER_SET_ID').AsInteger + 1);
862	–	SetLength(FCharSetNames,Query.FieldByName('RDB$CHARACTER_SET_ID').AsInteger + 1);
863	–	{$IFDEF HAS_ANSISTRING_CODEPAGE}
864	–	SetLength(FCodePages, Query.FieldByName('RDB$CHARACTER_SET_ID').AsInteger + 1);
865	–	{$ENDIF}
866	–	for i := 0 to Length(FCharSetSizes) - 1 do FCharSetSizes[i] := 1;
867	–	repeat
868	–	FCharSetSizes[Query.FieldByName('RDB$CHARACTER_SET_ID').AsInteger] :=
869	–	Query.FieldByName('RDB$BYTES_PER_CHARACTER').AsInteger;
870	–	FCharSetNames[Query.FieldByName('RDB$CHARACTER_SET_ID').AsInteger] :=
871	–	Trim(Query.FieldByName('RDB$CHARACTER_SET_NAME').AsString);
872	–	{$IFDEF HAS_ANSISTRING_CODEPAGE}
873	–	FCodePages[Query.FieldByName('RDB$CHARACTER_SET_ID').AsInteger] :=
874	–	IBGetCodePage(Trim(Query.FieldByName('RDB$CHARACTER_SET_NAME').AsString));
875	–	{$ENDIF}
876	–	Query.Next;
877	–	until Query.EOF;
878	–	end;
879	–	finally
880	–	Query.free;
881	–	FInternalTransaction.Commit;
882	–	end;
883	–	end;
884	–
782		procedure TIBDataBase.CheckStreamConnect;
783		var
784		i: integer;
#	Line 904 | Line 801 | begin
801		(FDefaultTransaction.FStreamedActive) and
802		(not FDefaultTransaction.InTransaction) then
803		FDefaultTransaction.StartTransaction;
804	<	FStreamedConnected := False;
804	>	StreamedConnected := False;
805		end;
806		except
807		if csDesigning in ComponentState then
#	Line 945 | Line 842 | begin
842		end;
843		end;
844
845	<	function TIBDataBase.Login(var aDatabaseName: string): Boolean;
845	>	function TIBDataBase.Login(var aDatabaseName: string): Boolean;
846		var
847		IndexOfUser, IndexOfPassword: Integer;
848		Username, Password, OldPassword: String;
#	Line 1003 | Line 900 | begin
900		Length(Params[IndexOfPassword]));
901		OldPassword := password;
902		end;
903	+
904		result := IBGUIInterface.LoginDialogEx(aDatabaseName, Username, Password, False);
905		if result then
906		begin
907	<	if IndexOfUser = -1 then
908	<	Params.Add(DPBConstantNames[isc_dpb_user_name] + '=' + Username)
909	<	else
910	<	Params[IndexOfUser] := DPBConstantNames[isc_dpb_user_name] +
907	>	if Username <> '' then
908	>	begin
909	>	if IndexOfUser = -1 then
910	>	Params.Add(DPBConstantNames[isc_dpb_user_name] + '=' + Username)
911	>	else
912	>	Params[IndexOfUser] := DPBConstantNames[isc_dpb_user_name] +
913		'=' + Username;
914	+	end
915	+	else
916	+	if IndexOfUser <> -1 then
917	+	Params.Delete(IndexOfUser);
918		if (Password = OldPassword) then
919		FHiddenPassword := ''
920		else
#	Line 1031 | Line 935 | end;
935
936		procedure TIBDataBase.DoConnect;
937		var
1034	–	DPB: String;
938		TempDBParams: TStrings;
939		I: integer;
940		aDBName: string;
941	<
942	<	{Call error analysis}
1040	<	sqlcode: Long;
1041	<	IBErrorCode: Long;
1042	<	status_vector: PISC_STATUS;
1043	<	{$ifdef WINDOWS}
1044	<	acp: uint;
1045	<	{$endif}
941	>	Status: IStatus;
942	>	CharSetID: integer;
943		begin
944		CheckInactive;
945		CheckDatabaseName;
#	Line 1059 | Line 956 | begin
956		TempDBParams := TStringList.Create;
957		try
958		TempDBParams.Assign(FDBParams);
959	+	{$ifdef UNIX}
960	+	{See below for WINDOWS UseDefaultSystemCodePage}
961		if UseDefaultSystemCodePage then
1063	–	begin
1064	–	{$ifdef WINDOWS}
1065	–	acp := GetACP;
1066	–	{$IFDEF HAS_ANSISTRING_CODEPAGE}
1067	–	TempDBParams.Values['lc_ctype'] := IBGetCharacterSetName(acp);
1068	–	FDefaultCodePage := IBGetCodePage(AnsiUpperCase(TempDBParams.Values['lc_ctype']));
1069	–	{$ELSE}
1070	–	if (acp >= 1250) and (acp <= 1258) then
1071	–	TempDBParams.Values['lc_ctype'] := Format('WIN%d',[acp])
1072	–	else
1073	–	TempDBParams.Values['lc_ctype'] :='UTF8';
1074	–	{$ENDIF}
1075	–	{$else}
1076	–	{$IFDEF HAS_ANSISTRING_CODEPAGE}
1077	–	TempDBParams.Values['lc_ctype'] := IBGetCharacterSetName(DefaultSystemCodePage);
1078	–	FDefaultCodePage := IBGetCodePage(AnsiUpperCase(TempDBParams.Values['lc_ctype']));
1079	–	{$ELSE}
962		TempDBParams.Values['lc_ctype'] :='UTF8';
963	<	{$ENDIF}
1082	<	{$endif}
1083	<	end;
963	>	{$endif}
964		{Opportunity to override defaults}
965		for i := 0 to FSQLObjects.Count - 1 do
966		begin
967		if FSQLObjects[i] <> nil then
968		SQLObjects[i].DoBeforeDatabaseConnect(TempDBParams,aDBName);
969		end;
1090	–	FDefaultCharSetName := AnsiUpperCase(TempDBParams.Values['lc_ctype']);
970
971	<	{ Generate a new DPB if necessary }
972	<	if (FDBParamsChanged or (TempDBParams.Text <> FDBParams.Text)) then
973	<	begin
974	<	FDBParamsChanged := False;
975	<	if (not LoginPrompt and not (csDesigning in ComponentState)) or (FHiddenPassword = '') then
976	<	GenerateDPB(TempDBParams, DPB, FDPBLength)
971	>	repeat
972	>	{ Generate a new DPB if necessary }
973	>	if (FDPB = nil) or FDBParamsChanged or (TempDBParams.Text <> FDBParams.Text) then
974	>	begin
975	>	FDBParamsChanged := False;
976	>	if (not LoginPrompt and not (csDesigning in ComponentState)) or (FHiddenPassword = '') then
977	>	FDPB := GenerateDPB(TempDBParams)
978	>	else
979	>	begin
980	>	TempDBParams.Values['password'] := FHiddenPassword;
981	>	FDPB := GenerateDPB(TempDBParams);
982	>	end;
983	>	end;
984	>
985	>	if FCreateDatabase then
986	>	begin
987	>	FCreateDatabase := false;
988	>	FAttachment := FirebirdAPI.CreateDatabase(aDBName,FDPB, false);
989	>	if assigned(FOnCreateDatabase) and (FAttachment <> nil) then
990	>	OnCreateDatabase(self);
991	>	end
992		else
993	+	FAttachment := FirebirdAPI.OpenDatabase(aDBName,FDPB,false);
994	+
995	+	if FAttachment = nil then
996		begin
997	<	TempDBParams.Add('password=' + FHiddenPassword);
998	<	GenerateDPB(TempDBParams, DPB, FDPBLength);
997	>	Status := FirebirdAPI.GetStatus;
998	>	{$IFDEF UNIX}
999	>	if Pos(':',aDBName) = 0 then
1000	>	begin
1001	>	if ((Status.GetSQLCode = -901) and (Status.GetIBErrorCode = isc_random)) {Access permissions on firebird temp}
1002	>	or
1003	>	((Status.GetSQLCode = -902) and (Status.GetIBErrorCode = isc_sys_request)) {Security DB Problem}
1004	>	or
1005	>	((Status.GetSQLCode = -902) and (Status.GetIBErrorCode = isc_psw_attach)) {Security DB Problem}
1006	>	or
1007	>	((Status.GetSQLCode = -904) and (Status.GetIBErrorCode = isc_lock_dir_access)) {Lock File Problem}
1008	>	then
1009	>	begin
1010	>	aDBName := 'localhost:' + aDBName;
1011	>	Continue;
1012	>	end
1013	>	end;
1014	>	{$ENDIF}
1015	>	if ((Status.GetSQLCode = -902) and (Status.GetIBErrorCode = isc_io_error)) {Database not found}
1016	>	and CreateIfNotExists and not (csDesigning in ComponentState) then
1017	>	FCreateDatabase := true
1018	>	else
1019	>	raise EIBInterBaseError.Create(Status);
1020		end;
1021	<	IBAlloc(FDPB, 0, FDPBLength);
1022	<	Move(DPB[1], FDPB[0], FDPBLength);
1023	<	end;
1021	>
1022	>	if UseDefaultSystemCodePage and (FAttachment <> nil) then
1023	>	{Only now can we check the codepage in use by the Attachment.
1024	>	If not that required then re-open with required LCLType.}
1025	>	begin
1026	>	{$ifdef WINDOWS}
1027	>	if Attachment.CodePage2CharSetID(GetACP,CharSetID) then
1028	>	{$else}
1029	>	if Attachment.CodePage2CharSetID(DefaultSystemCodePage,CharSetID) then
1030	>	{$endif}
1031	>	begin
1032	>	FDefaultCharSetName := Attachment.GetCharsetName(CharSetID);
1033	>	if FDefaultCharSetName <> AnsiUpperCase(TempDBParams.Values['lc_ctype']) then
1034	>	begin
1035	>	TempDBParams.Values['lc_ctype'] := FDefaultCharSetName;
1036	>	FDBParamsChanged := True;
1037	>	FAttachment := nil;
1038	>	end
1039	>	end
1040	>	end;
1041	>
1042	>	until FAttachment <> nil;
1043	>
1044	>	FDefaultCharSetName := AnsiUpperCase(TempDBParams.Values['lc_ctype']);
1045		finally
1046		TempDBParams.Free;
1047		end;
1048	<	repeat
1049	<	if Call(isc_attach_database(StatusVector, Length(aDBName),
1050	<	PChar(aDBName), @FHandle,
1051	<	FDPBLength, FDPB), False) > 0 then
1113	<	begin
1114	<	{$IFDEF UNIX}
1115	<	if IsEmbeddedServer and (Pos(':',aDBName) = 0) then
1116	<	begin
1117	<	status_vector := StatusVector;
1118	<	IBErrorCode := StatusVectorArray[1];
1119	<	sqlcode := isc_sqlcode(StatusVector);
1120	<
1121	<	if ((sqlcode = -901) and (IBErrorCode = 335544382)) {Access permissions on firebird temp}
1122	<	or
1123	<	((sqlcode = -902) and (IBErrorCode = 335544373)) {Security DB Problem}
1124	<	then
1125	<	begin
1126	<	aDBName := 'localhost:' + aDBName;
1127	<	Continue;
1128	<	end;
1129	<	end;
1130	<	{$ENDIF}
1131	<	FHandle := nil;
1132	<	IBDataBaseError;
1133	<	end;
1134	<	until FHandle <> nil;
1048	>	if FDefaultCharSetName <> '' then
1049	>	Attachment.CharSetName2CharSetID(FDefaultCharSetName,FDefaultCharSetID);
1050	>	Attachment.CharSetID2CodePage(FDefaultCharSetID,FDefaultCodePage);
1051	>
1052		if not (csDesigning in ComponentState) then
1053		FDBName := aDBName; {Synchronise at run time}
1054		FDBSQLDialect := GetDBSQLDialect;
#	Line 1143 | Line 1060 | begin
1060		end;
1061		if not (csDesigning in ComponentState) then
1062		MonitorHook.DBConnect(Self);
1146	–	LoadCharSetInfo;
1063		end;
1064
1065		procedure TIBDataBase.RemoveSQLObject(Idx: Integer);
#	Line 1246 | Line 1162 | begin
1162		FDefaultTransaction := Value;
1163		end;
1164
1249	–	procedure TIBDataBase.SetHandle(Value: TISC_DB_HANDLE);
1250	–	begin
1251	–	if HandleIsShared then
1252	–	Close
1253	–	else
1254	–	CheckInactive;
1255	–	FHandle := Value;
1256	–	FHandleIsShared := (Value <> nil);
1257	–	end;
1258	–
1165		procedure TIBDataBase.SetIdleTimer(Value: Integer);
1166		begin
1167		if Value < 0 then
#	Line 1300 | Line 1206 | end;
1206		begin
1207		if Connected then
1208		begin
1209	<	if FCanTimeout then
1209	>	if not FAttachment.HasActivity then
1210		begin
1211		ForceClose;
1212		if Assigned(FOnIdleTimer) then
1213		FOnIdleTimer(Self);
1214		end
1309	–	else
1310	–	FCanTimeout := True;
1215		end;
1216		end;
1217
#	Line 1338 | Line 1242 | end;
1242		procedure TIBDataBase.SetSQLDialect( const Value: Integer);
1243		begin
1244		if (Value < 1) then IBError(ibxeSQLDialectInvalid, [nil]);
1245	<	if ((FHandle = nil) or (Value <= FDBSQLDialect))  then
1245	>	if ((FAttachment = nil) or (Value <= FDBSQLDialect))  then
1246		FSQLDialect := Value
1247		else
1248		IBError(ibxeSQLDialectInvalid, [nil]);
#	Line 1457 | Line 1361 | begin
1361		BeginUpdate;
1362		try
1363		Clear;
1364	<	while (not Query.EOF) and (Query.Next <> nil) do
1365	<	List.Add(TrimRight(Query.Current.ByName('RDB$FIELD_NAME').AsString)); {do not localize}
1364	>	while (not Query.EOF) and Query.Next  do
1365	>	List.Add(TrimRight(Query.FieldByName('RDB$FIELD_NAME').AsString)); {do not localize}
1366		finally
1367		EndUpdate;
1368		end;
#	Line 1497 | Line 1401 | begin
1401		BeginUpdate;
1402		try
1403		Clear;
1404	<	while (not Query.EOF) and (Query.Next <> nil) do
1405	<	List.Add(TrimRight(Query.Current[0].AsString));
1404	>	while (not Query.EOF) and Query.Next  do
1405	>	List.Add(TrimRight(Query.Fields[0].AsString));
1406		finally
1407		EndUpdate;
1408		end;
#	Line 1515 | Line 1419 | end;
1419		constructor TIBTransaction.Create(AOwner: TComponent);
1420		begin
1421		inherited Create(AOwner);
1518	–	FIBLoaded := False;
1519	–	CheckIBLoaded;
1520	–	FIBLoaded := True;
1521	–	CheckIBLoaded;
1422		FDatabases := TList.Create;
1423		FSQLObjects := TList.Create;
1524	–	FHandle := nil;
1424		FTPB := nil;
1526	–	FTPBLength := 0;
1425		FTRParams := TStringList.Create;
1426		FTRParamsChanged := True;
1427		TStringList(FTRParams).OnChange := TRParamsChange;
#	Line 1539 | Line 1437 | destructor TIBTransaction.Destroy;
1437		var
1438		i: Integer;
1439		begin
1440	<	if FIBLoaded then
1441	<	begin
1442	<	if InTransaction then
1443	<	EndTransaction(FDefaultAction, True);
1444	<	for i := 0 to FSQLObjects.Count - 1 do
1445	<	if FSQLObjects[i] <> nil then
1446	<	SQLObjects[i].DoTransactionFree;
1447	<	RemoveSQLObjects;
1448	<	RemoveDatabases;
1449	<	FreeMem(FTPB);
1450	<	FTPB := nil;
1553	<	FTRParams.Free;
1554	<	FSQLObjects.Free;
1555	<	FDatabases.Free;
1556	<	end;
1440	>	if InTransaction then
1441	>	EndTransaction(FDefaultAction, True);
1442	>	for i := 0 to FSQLObjects.Count - 1 do
1443	>	if FSQLObjects[i] <> nil then
1444	>	SQLObjects[i].DoTransactionFree;
1445	>	RemoveSQLObjects;
1446	>	RemoveDatabases;
1447	>	FTPB := nil;
1448	>	FTRParams.Free;
1449	>	FSQLObjects.Free;
1450	>	FDatabases.Free;
1451		inherited Destroy;
1452		end;
1453
1560	–	function TIBTransaction.Call(ErrCode: ISC_STATUS;
1561	–	RaiseError: Boolean): ISC_STATUS;
1562	–	var
1563	–	i: Integer;
1564	–	begin
1565	–	result := ErrCode;
1566	–	for i := 0 to FDatabases.Count - 1 do if FDatabases[i] <> nil then
1567	–	Databases[i].FCanTimeout := False;
1568	–	FCanTimeout := False;
1569	–	if RaiseError and (result > 0) then
1570	–	IBDataBaseError;
1571	–	end;
1572	–
1454		procedure TIBTransaction.CheckDatabasesInList;
1455		begin
1456		if GetDatabaseCount = 0 then
#	Line 1580 | Line 1461 | procedure TIBTransaction.CheckInTransact
1461		begin
1462		if FStreamedActive and (not InTransaction) then
1463		Loaded;
1464	<	if (FHandle = nil) then
1464	>	if (TransactionIntf = nil) then
1465		IBError(ibxeNotInTransaction, [nil]);
1466		end;
1467
#	Line 1636 | Line 1517 | procedure TIBTransaction.EnsureNotInTran
1517		begin
1518		if csDesigning in ComponentState then
1519		begin
1520	<	if FHandle <> nil then
1520	>	if TransactionIntf <> nil then
1521		Rollback;
1522		end;
1523		end;
1524
1525		procedure TIBTransaction.CheckNotInTransaction;
1526		begin
1527	<	if (FHandle <> nil) then
1527	>	if (TransactionIntf <> nil) and  TransactionIntf.InTransaction then
1528		IBError(ibxeInTransaction, [nil]);
1529		end;
1530
#	Line 1652 | Line 1533 | var
1533		i: Integer;
1534		NilFound: Boolean;
1535		begin
1536	+	EnsureNotInTransaction;
1537	+	CheckNotInTransaction;
1538	+	FTransactionIntf := nil;
1539	+
1540		i := FindDatabase(db);
1541		if i <> -1 then
1542		begin
#	Line 1702 | Line 1587 | end;
1587		procedure TIBTransaction.EndTransaction(Action: TTransactionAction;
1588		Force: Boolean);
1589		var
1705	–	status: ISC_STATUS;
1590		i: Integer;
1591		begin
1592		CheckInTransaction;
#	Line 1713 | Line 1597 | begin
1597		case Action of
1598		TARollback, TACommit:
1599		begin
1600	<	if (HandleIsShared) and
1601	<	(Action <> FDefaultAction) and
1602	<	(not Force) then
1603	<	IBError(ibxeCantEndSharedTransaction, [nil]);
1604	<	DoBeforeTransactionEnd;
1600	>	try
1601	>	DoBeforeTransactionEnd;
1602	>	except on E: EIBInterBaseError do
1603	>	begin
1604	>	if not Force then
1605	>	raise;
1606	>	end;
1607	>	end;
1608	>
1609		for i := 0 to FSQLObjects.Count - 1 do if FSQLObjects[i] <> nil then
1610	+	try
1611		SQLObjects[i].DoBeforeTransactionEnd(Action);
1612	+	except on E: EIBInterBaseError do
1613	+	begin
1614	+	if not Force then
1615	+	raise;
1616	+	end;
1617	+	end;
1618	+
1619		if InTransaction then
1620		begin
1621	<	if HandleIsShared then
1622	<	begin
1727	<	FHandle := nil;
1728	<	FHandleIsShared := False;
1729	<	status := 0;
1730	<	end
1621	>	if (Action = TARollback) then
1622	>	FTransactionIntf.Rollback(Force)
1623		else
1624	<	if (Action = TARollback) then
1625	<	status := Call(isc_rollback_transaction(StatusVector, @FHandle), False)
1626	<	else
1627	<	status := Call(isc_commit_transaction(StatusVector, @FHandle), False);
1628	<	if ((Force) and (status > 0)) then
1629	<	status := Call(isc_rollback_transaction(StatusVector, @FHandle), False);
1630	<	if Force then
1631	<	FHandle := nil
1632	<	else
1633	<	if (status > 0) then
1634	<	IBDataBaseError;
1635	<	for i := 0 to FSQLObjects.Count - 1 do if FSQLObjects[i] <> nil then
1636	<	SQLObjects[i].DoAfterTransactionEnd;
1637	<	DoAfterTransactionEnd;
1624	>	try
1625	>	FTransactionIntf.Commit;
1626	>	except on E: EIBInterBaseError do
1627	>	begin
1628	>	if Force then
1629	>	FTransactionIntf.Rollback(Force)
1630	>	else
1631	>	raise;
1632	>	end;
1633	>	end;
1634	>
1635	>	for i := 0 to FSQLObjects.Count - 1 do if FSQLObjects[i] <> nil then
1636	>	try
1637	>	SQLObjects[i].DoAfterTransactionEnd;
1638	>	except on E: EIBInterBaseError do
1639	>	begin
1640	>	if not Force then
1641	>	raise;
1642	>	end;
1643	>	end;
1644	>	try
1645	>	DoAfterTransactionEnd;
1646	>	except on E: EIBInterBaseError do
1647	>	begin
1648	>	if not Force then
1649	>	raise;
1650	>	end;
1651	>	end;
1652		end;
1653		end;
1654		TACommitRetaining:
1655	<	Call(isc_commit_retaining(StatusVector, @FHandle), True);
1655	>	FTransactionIntf.CommitRetaining;
1656	>
1657		TARollbackRetaining:
1658	<	Call(isc_rollback_retaining(StatusVector, @FHandle), True);
1658	>	FTransactionIntf.RollbackRetaining;
1659		end;
1660		if not (csDesigning in ComponentState) then
1661		begin
#	Line 1800 | Line 1707 | end;
1707
1708		function TIBTransaction.GetInTransaction: Boolean;
1709		begin
1710	<	result := (FHandle <> nil);
1710	>	result := (TransactionIntf <> nil) and TransactionIntf.InTransaction;
1711		end;
1712
1713		function TIBTransaction.FindDatabase(db: TIBDatabase): Integer;
#	Line 1856 | Line 1763 | procedure TIBTransaction.BeforeDatabaseD
1763		begin
1764		if InTransaction then
1765		EndTransaction(FDefaultAction, True);
1766	+	FTransactionIntf := nil;
1767		end;
1768
1769		procedure TIBTransaction.RemoveDatabase(Idx: Integer);
#	Line 1864 | Line 1772 | var
1772		begin
1773		if ((Idx >= 0) and (FDatabases[Idx] <> nil)) then
1774		begin
1775	+	EnsureNotInTransaction;
1776	+	CheckNotInTransaction;
1777	+	FTransactionIntf := nil;
1778	+
1779		DB := Databases[Idx];
1780		FDatabases[Idx] := nil;
1781		DB.RemoveTransaction(DB.FindTransaction(Self));
#	Line 1876 | Line 1788 | procedure TIBTransaction.RemoveDatabases
1788		var
1789		i: Integer;
1790		begin
1791	+	EnsureNotInTransaction;
1792	+	CheckNotInTransaction;
1793	+	FTransactionIntf := nil;
1794	+
1795		for i := 0 to FDatabases.Count - 1 do if FDatabases[i] <> nil then
1796		RemoveDatabase(i);
1797		end;
#	Line 1922 | Line 1838 | begin
1838		Rollback;
1839		end;
1840
1925	–	procedure TIBTransaction.SetDefaultAction(Value: TTransactionAction);
1926	–	begin
1927	–	(*  if (Value = taRollbackRetaining) and (GetIBClientVersion < 6) then
1928	–	IBError(ibxeIB60feature, [nil]);*)
1929	–	FDefaultAction := Value;
1930	–	end;
1931	–
1841		procedure TIBTransaction.SetDefaultDatabase(Value: TIBDatabase);
1842		var
1843		i: integer;
#	Line 1951 | Line 1860 | begin
1860		FDefaultDatabase := Value;
1861		end;
1862
1954	–	procedure TIBTransaction.SetHandle(Value: TISC_TR_HANDLE);
1955	–	begin
1956	–	if (HandleIsShared) then
1957	–	EndTransaction(DefaultAction, True)
1958	–	else
1959	–	CheckNotInTransaction;
1960	–	FHandle := Value;
1961	–	FHandleIsShared := (Value <> nil);
1962	–	end;
1963	–
1863		procedure TIBTransaction.Notification( AComponent: TComponent;
1864		Operation: TOperation);
1865		var
#	Line 2002 | Line 1901 | end;
1901
1902		procedure TIBTransaction.StartTransaction;
1903		var
2005	–	pteb: PISC_TEB_ARRAY;
2006	–	TPB: String;
1904		i: Integer;
1905	+	Attachments: array of IAttachment;
1906	+	ValidDatabaseCount: integer;
1907		begin
1908		CheckNotInTransaction;
1909		CheckDatabasesInList;
1910	+	if TransactionIntf <> nil then
1911	+	begin
1912	+	TransactionIntf.Start(DefaultAction);
1913	+	Exit;
1914	+	end;
1915	+
1916		for i := 0 to FDatabases.Count - 1 do
1917		if  FDatabases[i] <> nil then
1918		begin
1919		with TIBDatabase(FDatabases[i]) do
1920		if not Connected then
1921	<	if FStreamedConnected then
1921	>	if StreamedConnected then
1922		begin
1923		Open;
1924	<	FStreamedConnected := False;
1924	>	StreamedConnected := False;
1925		end
1926		else
1927		IBError(ibxeDatabaseClosed, [nil]);
#	Line 2024 | Line 1929 | begin
1929		if FTRParamsChanged then
1930		begin
1931		FTRParamsChanged := False;
1932	<	GenerateTPB(FTRParams, TPB, FTPBLength);
2028	<	if FTPBLength > 0 then
2029	<	begin
2030	<	IBAlloc(FTPB, 0, FTPBLength);
2031	<	Move(TPB[1], FTPB[0], FTPBLength);
2032	<	end;
1932	>	FTPB :=  GenerateTPB(FTRParams);
1933		end;
1934
1935	<	pteb := nil;
1936	<	IBAlloc(pteb, 0, DatabaseCount * SizeOf(TISC_TEB));
1937	<	try
1938	<	for i := 0 to DatabaseCount - 1 do if Databases[i] <> nil then
1939	<	begin
1940	<	pteb^[i].db_handle := @(Databases[i].Handle);
1941	<	pteb^[i].tpb_length := FTPBLength;
1942	<	pteb^[i].tpb_address := FTPB;
1943	<	end;
1944	<	if Call(isc_start_multiple(StatusVector, @FHandle,
1945	<	DatabaseCount, PISC_TEB(pteb)), False) > 0 then
1946	<	begin
1947	<	FHandle := nil;
1948	<	IBDataBaseError;
2049	<	end;
2050	<	if not (csDesigning in ComponentState) then
2051	<	MonitorHook.TRStart(Self);
2052	<	finally
2053	<	FreeMem(pteb);
1935	>	ValidDatabaseCount := 0;
1936	>	for i := 0 to DatabaseCount - 1 do
1937	>	if Databases[i] <> nil then Inc(ValidDatabaseCount);
1938	>
1939	>	if ValidDatabaseCount = 1 then
1940	>	FTransactionIntf := Databases[0].Attachment.StartTransaction(FTPB,DefaultAction)
1941	>	else
1942	>	begin
1943	>	SetLength(Attachments,ValidDatabaseCount);
1944	>	for i := 0 to DatabaseCount - 1 do
1945	>	if Databases[i] <> nil then
1946	>	Attachments[i] := Databases[i].Attachment;
1947	>
1948	>	FTransactionIntf := FirebirdAPI.StartTransaction(Attachments,FTPB,DefaultAction);
1949		end;
1950	+
1951	+	if not (csDesigning in ComponentState) then
1952	+	MonitorHook.TRStart(Self);
1953		DoOnStartTransaction;
1954		end;
1955
#	Line 2059 | Line 1957 | procedure TIBTransaction.TimeoutTransact
1957		begin
1958		if InTransaction then
1959		begin
1960	<	if FCanTimeout then
1960	>	if not TransactionIntf.HasActivity then
1961		begin
1962		EndTransaction(FDefaultAction, True);
1963		if Assigned(FOnIdleTimer) then
1964		FOnIdleTimer(Self);
1965		end
2068	–	else
2069	–	FCanTimeout := True;
1966		end;
1967		end;
1968
#	Line 2079 | Line 1975 | procedure TIBTransaction.TRParamsChangin
1975		begin
1976		EnsureNotInTransaction;
1977		CheckNotInTransaction;
1978	+	FTransactionIntf := nil;
1979		end;
1980
1981		{ TIBBase }
#	Line 2094 | Line 1991 | begin
1991		inherited Destroy;
1992		end;
1993
2097	–	function TIBBase.GetCharSetSize(CharSetID: integer): integer;
2098	–	begin
2099	–	if (CharSetID >= 0) and (CharSetID < Length(Database.FCharSetSizes)) then
2100	–	Result := Database.FCharSetSizes[CharSetID]
2101	–	else
2102	–	Result := 1; {Unknown character set}
2103	–	end;
2104	–
2105	–	function TIBBase.GetDefaultCharSetSize: integer;
2106	–	var DefaultCharSetName: string;
2107	–	i: integer;
2108	–	begin
2109	–	DefaultCharSetName := GetDefaultCharSetName;
2110	–	Result := 4; {worse case}
2111	–	for i := 0 to Length(Database.FCharSetSizes) - 1 do
2112	–	if Database.FCharSetNames[i] = DefaultCharSetName then
2113	–	begin
2114	–	Result := Database.FCharSetSizes[i];
2115	–	break;
2116	–	end;
2117	–	end;
2118	–
2119	–	function TIBBase.GetCharSetName(CharSetID: integer): string;
2120	–	begin
2121	–	if (CharSetID >= 0) and (CharSetID < Length(Database.FCharSetNames)) then
2122	–	Result := Database.FCharSetNames[CharSetID]
2123	–	else
2124	–	Result := ''; {Unknown character set}
2125	–	end;
2126	–
2127	–	function TIBBase.GetDefaultCharSetName: RawByteString;
2128	–	begin
2129	–	Result := Database.FDefaultCharSetName;
2130	–	end;
2131	–
2132	–	{$IFDEF HAS_ANSISTRING_CODEPAGE}
2133	–	function TIBBase.GetCodePage(CharSetID: integer): TSystemCodePage;
2134	–	begin
2135	–	if (CharSetID >= 0) and (CharSetID < Length(Database.FCodePages)) then
2136	–	Result := Database.FCodePages[CharSetID]
2137	–	else
2138	–	Result := CP_NONE; {Unknown character set}
2139	–	end;
2140	–
2141	–	function TIBBase.GetDefaultCodePage: TSystemCodePage;
2142	–	begin
2143	–	Result := Database.FDefaultCodePage;
2144	–	end;
2145	–
2146	–	{$ENDIF}
2147	–
1994		procedure TIBBase.HandleException(Sender: TObject);
1995		begin
1996		if assigned(Database) then
#	Line 2183 | Line 2029 | begin
2029		FTransaction.CheckInTransaction;
2030		end;
2031
2186	–	function TIBBase.GetDBHandle: PISC_DB_HANDLE;
2187	–	begin
2188	–	CheckDatabase;
2189	–	result := @FDatabase.Handle;
2190	–	end;
2191	–
2192	–	function TIBBase.GetTRHandle: PISC_TR_HANDLE;
2193	–	begin
2194	–	CheckTransaction;
2195	–	result := @FTransaction.Handle;
2196	–	end;
2197	–
2032		procedure TIBBase.DoBeforeDatabaseConnect(DBParams: TStrings; var DBName: string
2033		);
2034		begin
#	Line 2309 | Line 2143 | end;
2143		parameter buffer, and return it and its length
2144		in DPB and DPBLength, respectively. }
2145
2146	<	procedure GenerateDPB(sl: TStrings; var DPB: string; var DPBLength: Short);
2146	>	function GenerateDPB(sl: TStrings): IDPB;
2147		var
2148	<	i, j, pval: Integer;
2148	>	i, j: Integer;
2149		DPBVal: UShort;
2150		ParamName, ParamValue: string;
2151		begin
2152	<	{ The DPB is initially empty, with the exception that
2319	<	the DPB version must be the first byte of the string. }
2320	<	DPBLength := 1;
2321	<	DPB := Char(isc_dpb_version1);
2152	>	Result := FirebirdAPI.AllocateDPB;
2153
2154		{Iterate through the textual database parameters, constructing
2155		a DPB on-the-fly }
#	Line 2357 | Line 2188 | begin
2188		begin
2189		if DPBVal = isc_dpb_sql_dialect then
2190		ParamValue[1] := Char(Ord(ParamValue[1]) - 48);
2191	<	DPB := DPB +
2361	<	Char(DPBVal) +
2362	<	Char(Length(ParamValue)) +
2363	<	ParamValue;
2364	<	Inc(DPBLength, 2 + Length(ParamValue));
2191	>	Result.Add(DPBVal).SetAsString(ParamValue);
2192		end;
2193	+
2194		isc_dpb_num_buffers, isc_dpb_dbkey_scope, isc_dpb_force_write,
2195		isc_dpb_no_reserve, isc_dpb_damaged, isc_dpb_verify:
2196	<	begin
2197	<	DPB := DPB +
2370	<	Char(DPBVal) +
2371	<	#1 +
2372	<	Char(StrToInt(ParamValue));
2373	<	Inc(DPBLength, 3);
2374	<	end;
2196	>	Result.Add(DPBVal).SetAsByte(byte(ParamValue[1]));
2197	>
2198		isc_dpb_sweep:
2199	<	begin
2200	<	DPB := DPB +
2378	<	Char(DPBVal) +
2379	<	#1 +
2380	<	Char(isc_dpb_records);
2381	<	Inc(DPBLength, 3);
2382	<	end;
2199	>	Result.Add(DPBVal).SetAsByte(isc_dpb_records);
2200	>
2201		isc_dpb_sweep_interval:
2202	<	begin
2203	<	pval := StrToInt(ParamValue);
2386	<	DPB := DPB +
2387	<	Char(DPBVal) +
2388	<	#4 +
2389	<	PChar(@pval)[0] +
2390	<	PChar(@pval)[1] +
2391	<	PChar(@pval)[2] +
2392	<	PChar(@pval)[3];
2393	<	Inc(DPBLength, 6);
2394	<	end;
2202	>	Result.Add(DPBVal).SetAsInteger(StrToInt(ParamValue));
2203	>
2204		isc_dpb_activate_shadow, isc_dpb_delete_shadow, isc_dpb_begin_log,
2205		isc_dpb_quit_log:
2206	<	begin
2398	<	DPB := DPB +
2399	<	Char(DPBVal) +
2400	<	#1 + #0;
2401	<	Inc(DPBLength, 3);
2402	<	end;
2206	>	Result.Add(DPBVal).SetAsByte(0);
2207		else
2208		begin
2209		if (DPBVal > 0) and
#	Line 2417 | Line 2221 | end;
2221		of the transaction parameters, generate a transaction
2222		parameter buffer, and return it and its length in
2223		TPB and TPBLength, respectively. }
2224	<	procedure GenerateTPB(sl: TStrings; var TPB: string; var TPBLength: Short);
2224	>	function GenerateTPB(sl: TStrings): ITPB;
2225		var
2226	<	i, j, TPBVal, ParamLength: Integer;
2226	>	i, j, TPBVal: Integer;
2227		ParamName, ParamValue: string;
2228		begin
2229	<	TPB := '';
2426	<	if (sl.Count = 0) then
2427	<	TPBLength := 0
2428	<	else
2429	<	begin
2430	<	TPBLength := sl.Count + 1;
2431	<	TPB := TPB + Char(isc_tpb_version3);
2432	<	end;
2229	>	Result := FirebirdAPI.AllocateTPB;
2230		for i := 0 to sl.Count - 1 do
2231		begin
2232		if (Trim(sl[i]) =  '') then
2436	–	begin
2437	–	Dec(TPBLength);
2233		Continue;
2234	<	end;
2234	>
2235		if (Pos('=', sl[i]) = 0) then {mbcs ok}
2236		ParamName := LowerCase(sl[i]) {mbcs ok}
2237		else
#	Line 2460 | Line 2255 | begin
2255		isc_tpb_concurrency, isc_tpb_shared, isc_tpb_wait, isc_tpb_nowait,
2256		isc_tpb_read, isc_tpb_write, isc_tpb_ignore_limbo,
2257		isc_tpb_read_committed, isc_tpb_rec_version, isc_tpb_no_rec_version:
2258	<	TPB := TPB + Char(TPBVal);
2258	>	Result.Add(TPBVal);
2259	>
2260		isc_tpb_lock_read, isc_tpb_lock_write:
2261	<	begin
2262	<	TPB := TPB + Char(TPBVal);
2467	<	{ Now set the string parameter }
2468	<	ParamLength := Length(ParamValue);
2469	<	Inc(TPBLength, ParamLength + 1);
2470	<	TPB := TPB + Char(ParamLength) + ParamValue;
2471	<	end;
2261	>	Result.Add(TPBVal).SetAsString(ParamValue);
2262	>
2263		else
2264		begin
2265		if (TPBVal > 0) and

Diff Legend

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