43 |
|
{$ELSE} |
44 |
|
unix, |
45 |
|
{$ENDIF} |
46 |
< |
Dialogs, Controls, StdCtrls, SysUtils, Classes, Forms, ExtCtrls, IBHeader, IBExternals, DB, |
47 |
< |
IB, DBLoginDlg; |
46 |
> |
SysUtils, Classes, FPTimer, IBHeader, IBExternals, DB, |
47 |
> |
IB, CustApp; |
48 |
|
|
49 |
|
const |
50 |
|
DPBPrefix = 'isc_dpb_'; |
159 |
|
FHiddenPassword: string; |
160 |
|
FIBLoaded: Boolean; |
161 |
|
FOnLogin: TIBDatabaseLoginEvent; |
162 |
+ |
FSQLHourGlass: Boolean; |
163 |
|
FTraceFlags: TTraceFlags; |
164 |
|
FDBSQLDialect: Integer; |
165 |
|
FSQLDialect: Integer; |
178 |
|
FDefaultTransaction: TIBTransaction; |
179 |
|
FInternalTransaction: TIBTransaction; |
180 |
|
FStreamedConnected: Boolean; |
181 |
< |
FTimer: TTimer; |
181 |
> |
FTimer: TFPTimer; |
182 |
|
FUserNames: TStringList; |
183 |
|
FDataSets: TList; |
184 |
|
FLoginCalled: boolean; |
185 |
+ |
FCharSetSizes: array of integer; |
186 |
|
procedure EnsureInactive; |
187 |
|
function GetDBSQLDialect: Integer; |
188 |
|
function GetSQLDialect: Integer; |
197 |
|
function GetTransaction(Index: Integer): TIBTransaction; |
198 |
|
function GetTransactionCount: Integer; |
199 |
|
function Login: Boolean; |
200 |
+ |
procedure LoadCharSetInfo; |
201 |
|
procedure SetDatabaseName(const Value: TIBFileName); |
202 |
|
procedure SetDBParamByDPB(const Idx: Integer; Value: String); |
203 |
|
procedure SetDBParams(Value: TStrings); |
215 |
|
procedure DoDisconnect; override; |
216 |
|
function GetConnected: Boolean; override; |
217 |
|
procedure CheckStreamConnect; |
218 |
+ |
procedure HandleException(Sender: TObject); |
219 |
|
procedure Notification( AComponent: TComponent; Operation: TOperation); override; |
220 |
|
function GetDataset(Index : longint) : TDataset; override; |
221 |
|
function GetDataSetCount : Longint; override; |
266 |
|
write SetDefaultTransaction; |
267 |
|
property IdleTimer: Integer read GetIdleTimer write SetIdleTimer; |
268 |
|
property SQLDialect : Integer read GetSQLDialect write SetSQLDialect default 3; |
269 |
+ |
property SQLHourGlass: Boolean read FSQLHourGlass write FSQLHourGlass default true; |
270 |
|
property DBSQLDialect : Integer read FDBSQLDialect; |
271 |
|
property TraceFlags: TTraceFlags read FTraceFlags write FTraceFlags; |
272 |
|
property AfterConnect; |
284 |
|
|
285 |
|
TIBTransaction = class(TComponent) |
286 |
|
private |
287 |
+ |
FAfterDelete: TNotifyEvent; |
288 |
+ |
FAfterEdit: TNotifyEvent; |
289 |
+ |
FAfterExecQuery: TNotifyEvent; |
290 |
+ |
FAfterInsert: TNotifyEvent; |
291 |
+ |
FAfterPost: TNotifyEvent; |
292 |
+ |
FAfterTransactionEnd: TNotifyEvent; |
293 |
+ |
FBeforeTransactionEnd: TNotifyEvent; |
294 |
|
FIBLoaded: Boolean; |
295 |
|
FCanTimeout : Boolean; |
296 |
|
FDatabases : TList; |
297 |
+ |
FOnStartTransaction: TNotifyEvent; |
298 |
|
FSQLObjects : TList; |
299 |
|
FDefaultDatabase : TIBDatabase; |
300 |
|
FHandle : TISC_TR_HANDLE; |
303 |
|
FStreamedActive : Boolean; |
304 |
|
FTPB : PChar; |
305 |
|
FTPBLength : Short; |
306 |
< |
FTimer : TTimer; |
306 |
> |
FTimer : TFPTimer; |
307 |
|
FDefaultAction : TTransactionAction; |
308 |
|
FTRParams : TStrings; |
309 |
|
FTRParamsChanged : Boolean; |
310 |
|
FInEndTransaction : boolean; |
311 |
+ |
FEndAction : TTransactionAction; |
312 |
+ |
procedure DoBeforeTransactionEnd; |
313 |
+ |
procedure DoAfterTransactionEnd; |
314 |
+ |
procedure DoOnStartTransaction; |
315 |
+ |
procedure DoAfterExecQuery(Sender: TObject); |
316 |
+ |
procedure DoAfterEdit(Sender: TObject); |
317 |
+ |
procedure DoAfterDelete(Sender: TObject); |
318 |
+ |
procedure DoAfterInsert(Sender: TObject); |
319 |
+ |
procedure DoAfterPost(Sender: TObject); |
320 |
|
procedure EnsureNotInTransaction; |
321 |
|
procedure EndTransaction(Action: TTransactionAction; Force: Boolean); |
322 |
|
function GetDatabase(Index: Integer): TIBDatabase; |
358 |
|
function AddDatabase(db: TIBDatabase): Integer; |
359 |
|
function FindDatabase(db: TIBDatabase): Integer; |
360 |
|
function FindDefaultDatabase: TIBDatabase; |
361 |
+ |
function GetEndAction: TTransactionAction; |
362 |
|
procedure RemoveDatabase(Idx: Integer); |
363 |
|
procedure RemoveDatabases; |
364 |
|
procedure CheckDatabasesInList; |
380 |
|
property DefaultAction: TTransactionAction read FDefaultAction write SetDefaultAction default taCommit; |
381 |
|
property Params: TStrings read FTRParams write SetTRParams; |
382 |
|
property OnIdleTimer: TNotifyEvent read FOnIdleTimer write FOnIdleTimer; |
383 |
< |
end; |
383 |
> |
property BeforeTransactionEnd: TNotifyEvent read FBeforeTransactionEnd |
384 |
> |
write FBeforeTransactionEnd; |
385 |
> |
property AfterTransactionEnd: TNotifyEvent read FAfterTransactionEnd |
386 |
> |
write FAfterTransactionEnd; |
387 |
> |
property OnStartTransaction: TNotifyEvent read FOnStartTransaction |
388 |
> |
write FOnStartTransaction; |
389 |
> |
property AfterExecQuery: TNotifyEvent read FAfterExecQuery |
390 |
> |
write FAfterExecQuery; |
391 |
> |
property AfterEdit: TNotifyEvent read FAfterEdit write FAfterEdit; |
392 |
> |
property AfterDelete: TNotifyEvent read FAfterDelete write FAfterDelete; |
393 |
> |
property AfterInsert: TNotifyEvent read FAfterInsert write FAfterInsert; |
394 |
> |
property AfterPost: TNotifyEvent read FAfterPost write FAfterPost; |
395 |
> |
end; |
396 |
> |
|
397 |
> |
TTransactionEndEvent = procedure(Sender:TObject; Action: TTransactionAction) of object; |
398 |
> |
TBeforeDatabaseConnectEvent = procedure (Sender: TObject; DBParams: TStrings; |
399 |
> |
var DBName: string) of object; |
400 |
|
|
401 |
|
{ TIBBase } |
402 |
|
|
405 |
|
connections. } |
406 |
|
TIBBase = class(TObject) |
407 |
|
protected |
408 |
+ |
FBeforeDatabaseConnect: TBeforeDatabaseConnectEvent; |
409 |
|
FDatabase: TIBDatabase; |
410 |
|
FIndexInDatabase: Integer; |
411 |
|
FTransaction: TIBTransaction; |
415 |
|
FAfterDatabaseDisconnect: TNotifyEvent; |
416 |
|
FAfterDatabaseConnect: TNotifyEvent; |
417 |
|
FOnDatabaseFree: TNotifyEvent; |
418 |
< |
FBeforeTransactionEnd: TNotifyEvent; |
418 |
> |
FBeforeTransactionEnd: TTransactionEndEvent; |
419 |
|
FAfterTransactionEnd: TNotifyEvent; |
420 |
|
FOnTransactionFree: TNotifyEvent; |
421 |
|
|
422 |
+ |
procedure DoBeforeDatabaseConnect(DBParams: TStrings; |
423 |
+ |
var DBName: string); virtual; |
424 |
|
procedure DoAfterDatabaseConnect; virtual; |
425 |
|
procedure DoBeforeDatabaseDisconnect; virtual; |
426 |
|
procedure DoAfterDatabaseDisconnect; virtual; |
427 |
|
procedure DoDatabaseFree; virtual; |
428 |
< |
procedure DoBeforeTransactionEnd; virtual; |
428 |
> |
procedure DoBeforeTransactionEnd(Action: TTransactionAction); virtual; |
429 |
|
procedure DoAfterTransactionEnd; virtual; |
430 |
|
procedure DoTransactionFree; virtual; |
431 |
|
function GetDBHandle: PISC_DB_HANDLE; virtual; |
437 |
|
destructor Destroy; override; |
438 |
|
procedure CheckDatabase; virtual; |
439 |
|
procedure CheckTransaction; virtual; |
440 |
+ |
procedure DoAfterExecQuery(Sender: TObject); virtual; |
441 |
+ |
procedure DoAfterEdit(Sender: TObject); virtual; |
442 |
+ |
procedure DoAfterDelete(Sender: TObject); virtual; |
443 |
+ |
procedure DoAfterInsert(Sender: TObject); virtual; |
444 |
+ |
procedure DoAfterPost(Sender: TObject); virtual; |
445 |
+ |
function GetCharSetSize(CharSetID: integer): integer; |
446 |
+ |
procedure HandleException(Sender: TObject); |
447 |
+ |
procedure SetCursor; |
448 |
+ |
procedure RestoreCursor; |
449 |
|
public |
450 |
+ |
property BeforeDatabaseConnect: TBeforeDatabaseConnectEvent read FBeforeDatabaseConnect |
451 |
+ |
write FBeforeDatabaseConnect; |
452 |
|
property AfterDatabaseConnect: TNotifyEvent read FAfterDatabaseConnect |
453 |
|
write FAfterDatabaseConnect; |
454 |
|
property BeforeDatabaseDisconnect: TNotifyEvent read FBeforeDatabaseDisconnect |
456 |
|
property AfterDatabaseDisconnect: TNotifyEvent read FAfterDatabaseDisconnect |
457 |
|
write FAfterDatabaseDisconnect; |
458 |
|
property OnDatabaseFree: TNotifyEvent read FOnDatabaseFree write FOnDatabaseFree; |
459 |
< |
property BeforeTransactionEnd: TNotifyEvent read FBeforeTransactionEnd write FBeforeTransactionEnd; |
459 |
> |
property BeforeTransactionEnd: TTransactionEndEvent read FBeforeTransactionEnd write FBeforeTransactionEnd; |
460 |
|
property AfterTransactionEnd: TNotifyEvent read FAfterTransactionEnd write FAfterTransactionEnd; |
461 |
|
property OnTransactionFree: TNotifyEvent read FOnTransactionFree write FOnTransactionFree; |
462 |
|
property Database: TIBDatabase read FDatabase |
493 |
|
FTransactions := TList.Create; |
494 |
|
FDBName := ''; |
495 |
|
FDBParams := TStringList.Create; |
496 |
+ |
FSQLHourGlass := true; |
497 |
+ |
if (AOwner <> nil) and |
498 |
+ |
(AOwner is TCustomApplication) and |
499 |
+ |
TCustomApplication(AOWner).ConsoleApplication then |
500 |
+ |
LoginPrompt := false; |
501 |
|
{$ifdef UNIX} |
502 |
|
if csDesigning in ComponentState then |
503 |
|
FDBParams.Add('lc_ctype=UTF-8'); |
519 |
|
FUserNames := nil; |
520 |
|
FInternalTransaction := TIBTransaction.Create(self); |
521 |
|
FInternalTransaction.DefaultDatabase := Self; |
522 |
< |
FTimer := TTimer.Create(Self); |
522 |
> |
FTimer := TFPTimer.Create(Self); |
523 |
|
FTimer.Enabled := False; |
524 |
|
FTimer.Interval := 0; |
525 |
|
FTimer.OnTimer := TimeoutConnection; |
629 |
|
if Connected then |
630 |
|
InternalClose(False); |
631 |
|
FDBSQLDialect := 1; |
632 |
+ |
SetLength(FCharSetSizes,0); |
633 |
|
end; |
634 |
|
|
635 |
|
procedure TIBDataBase.CreateDatabase; |
824 |
|
SQLObjects[i].DoAfterDatabaseDisconnect; |
825 |
|
end; |
826 |
|
|
827 |
+ |
procedure TIBDataBase.LoadCharSetInfo; |
828 |
+ |
var Query: TIBSQL; |
829 |
+ |
i: integer; |
830 |
+ |
begin |
831 |
+ |
if not FInternalTransaction.Active then |
832 |
+ |
FInternalTransaction.StartTransaction; |
833 |
+ |
Query := TIBSQL.Create(self); |
834 |
+ |
try |
835 |
+ |
Query.Database := Self; |
836 |
+ |
Query.Transaction := FInternalTransaction; |
837 |
+ |
Query.SQL.Text := 'Select RDB$CHARACTER_SET_ID, RDB$BYTES_PER_CHARACTER ' + |
838 |
+ |
'From RDB$CHARACTER_SETS Order by 1 DESC'; {do not localize} |
839 |
+ |
Query.Prepare; |
840 |
+ |
Query.ExecQuery; |
841 |
+ |
if not Query.EOF then |
842 |
+ |
begin |
843 |
+ |
SetLength(FCharSetSizes,Query.FieldByName('RDB$CHARACTER_SET_ID').AsInteger + 1); |
844 |
+ |
for i := 0 to Length(FCharSetSizes) - 1 do FCharSetSizes[i] := 1; |
845 |
+ |
repeat |
846 |
+ |
FCharSetSizes[Query.FieldByName('RDB$CHARACTER_SET_ID').AsInteger] := |
847 |
+ |
Query.FieldByName('RDB$BYTES_PER_CHARACTER').AsInteger; |
848 |
+ |
Query.Next; |
849 |
+ |
until Query.EOF; |
850 |
+ |
end; |
851 |
+ |
finally |
852 |
+ |
Query.free; |
853 |
+ |
FInternalTransaction.Commit; |
854 |
+ |
end; |
855 |
+ |
end; |
856 |
+ |
|
857 |
|
procedure TIBDataBase.CheckStreamConnect; |
858 |
|
var |
859 |
|
i: integer; |
880 |
|
end; |
881 |
|
except |
882 |
|
if csDesigning in ComponentState then |
883 |
< |
Application.HandleException(Self) |
883 |
> |
HandleException(Self) |
884 |
|
else |
885 |
|
raise; |
886 |
|
end; |
887 |
|
end; |
888 |
|
|
889 |
+ |
procedure TIBDataBase.HandleException(Sender: TObject); |
890 |
+ |
var aParent: TComponent; |
891 |
+ |
begin |
892 |
+ |
aParent := Owner; |
893 |
+ |
while aParent <> nil do |
894 |
+ |
begin |
895 |
+ |
if aParent is TCustomApplication then |
896 |
+ |
begin |
897 |
+ |
TCustomApplication(aParent).HandleException(Sender); |
898 |
+ |
Exit; |
899 |
+ |
end; |
900 |
+ |
aParent := aParent.Owner; |
901 |
+ |
end; |
902 |
+ |
SysUtils.ShowException(ExceptObject,ExceptAddr); |
903 |
+ |
end; |
904 |
+ |
|
905 |
|
procedure TIBDataBase.Notification(AComponent: TComponent; |
906 |
|
Operation: TOperation); |
907 |
|
var |
959 |
|
end; |
960 |
|
end |
961 |
|
else |
962 |
+ |
if assigned(IBGUIInterface) then |
963 |
|
begin |
964 |
|
IndexOfUser := IndexOfDBConst(DPBConstantNames[isc_dpb_user_name]); |
965 |
|
if IndexOfUser <> -1 then |
974 |
|
Length(Params[IndexOfPassword])); |
975 |
|
OldPassword := password; |
976 |
|
end; |
977 |
< |
result := LoginDialogEx(DatabaseName, Username, Password, False); |
977 |
> |
result := IBGUIInterface.LoginDialogEx(DatabaseName, Username, Password, False); |
978 |
|
if result then |
979 |
|
begin |
980 |
|
if IndexOfUser = -1 then |
991 |
|
HidePassword; |
992 |
|
end; |
993 |
|
end; |
994 |
< |
end; |
994 |
> |
end |
995 |
> |
else |
996 |
> |
if LoginPrompt then |
997 |
> |
IBError(ibxeNoLoginDialog,[]); |
998 |
|
finally |
999 |
|
FLoginCalled := false |
1000 |
|
end; |
1005 |
|
DPB: String; |
1006 |
|
TempDBParams: TStrings; |
1007 |
|
I: integer; |
1008 |
< |
|
1008 |
> |
aDBName: string; |
1009 |
|
begin |
1010 |
|
CheckInactive; |
1011 |
|
CheckDatabaseName; |
1017 |
|
{ Use builtin login prompt if requested } |
1018 |
|
if (LoginPrompt or (csDesigning in ComponentState)) and not Login then |
1019 |
|
IBError(ibxeOperationCancelled, [nil]); |
1020 |
< |
{ Generate a new DPB if necessary } |
1021 |
< |
if (FDBParamsChanged) then |
1022 |
< |
begin |
1023 |
< |
FDBParamsChanged := False; |
1024 |
< |
if (not LoginPrompt and not (csDesigning in ComponentState)) or (FHiddenPassword = '') then |
1025 |
< |
GenerateDPB(FDBParams, DPB, FDPBLength) |
1026 |
< |
else |
1027 |
< |
begin |
1028 |
< |
TempDBParams := TStringList.Create; |
1029 |
< |
try |
1030 |
< |
TempDBParams.Assign(FDBParams); |
1031 |
< |
TempDBParams.Add('password=' + FHiddenPassword); |
1032 |
< |
GenerateDPB(TempDBParams, DPB, FDPBLength); |
1033 |
< |
finally |
1034 |
< |
TempDBParams.Free; |
1035 |
< |
end; |
1036 |
< |
end; |
1037 |
< |
IBAlloc(FDPB, 0, FDPBLength); |
1038 |
< |
Move(DPB[1], FDPB[0], FDPBLength); |
1020 |
> |
|
1021 |
> |
TempDBParams := TStringList.Create; |
1022 |
> |
try |
1023 |
> |
TempDBParams.Assign(FDBParams); |
1024 |
> |
aDBName := FDBName; |
1025 |
> |
{Opportuning to override defaults} |
1026 |
> |
for i := 0 to FSQLObjects.Count - 1 do |
1027 |
> |
begin |
1028 |
> |
if FSQLObjects[i] <> nil then |
1029 |
> |
SQLObjects[i].DoBeforeDatabaseConnect(TempDBParams,aDBName); |
1030 |
> |
end; |
1031 |
> |
|
1032 |
> |
{ Generate a new DPB if necessary } |
1033 |
> |
if (FDBParamsChanged or (TempDBParams.Text <> FDBParams.Text)) then |
1034 |
> |
begin |
1035 |
> |
FDBParamsChanged := False; |
1036 |
> |
if (not LoginPrompt and not (csDesigning in ComponentState)) or (FHiddenPassword = '') then |
1037 |
> |
GenerateDPB(TempDBParams, DPB, FDPBLength) |
1038 |
> |
else |
1039 |
> |
begin |
1040 |
> |
TempDBParams.Add('password=' + FHiddenPassword); |
1041 |
> |
GenerateDPB(TempDBParams, DPB, FDPBLength); |
1042 |
> |
end; |
1043 |
> |
IBAlloc(FDPB, 0, FDPBLength); |
1044 |
> |
Move(DPB[1], FDPB[0], FDPBLength); |
1045 |
> |
end; |
1046 |
> |
finally |
1047 |
> |
TempDBParams.Free; |
1048 |
|
end; |
1049 |
< |
if Call(isc_attach_database(StatusVector, Length(FDBName), |
1050 |
< |
PChar(FDBName), @FHandle, |
1049 |
> |
if Call(isc_attach_database(StatusVector, Length(aDBName), |
1050 |
> |
PChar(aDBName), @FHandle, |
1051 |
|
FDPBLength, FDPB), False) > 0 then |
1052 |
|
begin |
1053 |
|
FHandle := nil; |
1054 |
|
IBDataBaseError; |
1055 |
|
end; |
1056 |
+ |
if not (csDesigning in ComponentState) then |
1057 |
+ |
FDBName := aDBName; {Synchronise at run time} |
1058 |
|
FDBSQLDialect := GetDBSQLDialect; |
1059 |
|
ValidateClientSQLDialect; |
1060 |
|
for i := 0 to FSQLObjects.Count - 1 do |
1064 |
|
end; |
1065 |
|
if not (csDesigning in ComponentState) then |
1066 |
|
MonitorHook.DBConnect(Self); |
1067 |
+ |
LoadCharSetInfo; |
1068 |
|
end; |
1069 |
|
|
1070 |
|
procedure TIBDataBase.RemoveSQLObject(Idx: Integer); |
1449 |
|
FTRParamsChanged := True; |
1450 |
|
TStringList(FTRParams).OnChange := TRParamsChange; |
1451 |
|
TStringList(FTRParams).OnChanging := TRParamsChanging; |
1452 |
< |
FTimer := TTimer.Create(Self); |
1452 |
> |
FTimer := TFPTimer.Create(Self); |
1453 |
|
FTimer.Enabled := False; |
1454 |
|
FTimer.Interval := 0; |
1455 |
|
FTimer.OnTimer := TimeoutTransaction; |
1505 |
|
IBError(ibxeNotInTransaction, [nil]); |
1506 |
|
end; |
1507 |
|
|
1508 |
+ |
procedure TIBTransaction.DoBeforeTransactionEnd; |
1509 |
+ |
begin |
1510 |
+ |
if Assigned(FBeforeTransactionEnd) then |
1511 |
+ |
FBeforeTransactionEnd(self); |
1512 |
+ |
end; |
1513 |
+ |
|
1514 |
+ |
procedure TIBTransaction.DoAfterTransactionEnd; |
1515 |
+ |
begin |
1516 |
+ |
if Assigned(FAfterTransactionEnd) then |
1517 |
+ |
FAfterTransactionEnd(self); |
1518 |
+ |
end; |
1519 |
+ |
|
1520 |
+ |
procedure TIBTransaction.DoOnStartTransaction; |
1521 |
+ |
begin |
1522 |
+ |
if assigned(FOnStartTransaction) then |
1523 |
+ |
OnStartTransaction(self); |
1524 |
+ |
end; |
1525 |
+ |
|
1526 |
+ |
procedure TIBTransaction.DoAfterExecQuery(Sender: TObject); |
1527 |
+ |
begin |
1528 |
+ |
if assigned(FAfterExecQuery) then |
1529 |
+ |
AfterExecQuery(Sender); |
1530 |
+ |
end; |
1531 |
+ |
|
1532 |
+ |
procedure TIBTransaction.DoAfterEdit(Sender: TObject); |
1533 |
+ |
begin |
1534 |
+ |
if assigned(FAfterEdit) then |
1535 |
+ |
AfterEdit(Sender); |
1536 |
+ |
end; |
1537 |
+ |
|
1538 |
+ |
procedure TIBTransaction.DoAfterDelete(Sender: TObject); |
1539 |
+ |
begin |
1540 |
+ |
if assigned(FAfterDelete) then |
1541 |
+ |
AfterDelete(Sender); |
1542 |
+ |
end; |
1543 |
+ |
|
1544 |
+ |
procedure TIBTransaction.DoAfterInsert(Sender: TObject); |
1545 |
+ |
begin |
1546 |
+ |
if assigned(FAfterInsert) then |
1547 |
+ |
AfterInsert(Sender); |
1548 |
+ |
end; |
1549 |
+ |
|
1550 |
+ |
procedure TIBTransaction.DoAfterPost(Sender: TObject); |
1551 |
+ |
begin |
1552 |
+ |
if assigned(FAfterPost) then |
1553 |
+ |
AfterPost(Sender); |
1554 |
+ |
end; |
1555 |
+ |
|
1556 |
|
procedure TIBTransaction.EnsureNotInTransaction; |
1557 |
|
begin |
1558 |
|
if csDesigning in ComponentState then |
1629 |
|
CheckInTransaction; |
1630 |
|
if FInEndTransaction then Exit; |
1631 |
|
FInEndTransaction := true; |
1632 |
+ |
FEndAction := Action; |
1633 |
|
try |
1634 |
|
case Action of |
1635 |
|
TARollback, TACommit: |
1638 |
|
(Action <> FDefaultAction) and |
1639 |
|
(not Force) then |
1640 |
|
IBError(ibxeCantEndSharedTransaction, [nil]); |
1641 |
+ |
DoBeforeTransactionEnd; |
1642 |
|
for i := 0 to FSQLObjects.Count - 1 do if FSQLObjects[i] <> nil then |
1643 |
< |
SQLObjects[i].DoBeforeTransactionEnd; |
1643 |
> |
SQLObjects[i].DoBeforeTransactionEnd(Action); |
1644 |
|
if InTransaction then |
1645 |
|
begin |
1646 |
|
if HandleIsShared then |
1663 |
|
IBDataBaseError; |
1664 |
|
for i := 0 to FSQLObjects.Count - 1 do if FSQLObjects[i] <> nil then |
1665 |
|
SQLObjects[i].DoAfterTransactionEnd; |
1666 |
+ |
DoAfterTransactionEnd; |
1667 |
|
end; |
1668 |
|
end; |
1669 |
|
TACommitRetaining: |
1754 |
|
end; |
1755 |
|
end; |
1756 |
|
|
1757 |
+ |
function TIBTransaction.GetEndAction: TTransactionAction; |
1758 |
+ |
begin |
1759 |
+ |
if FInEndTransaction then |
1760 |
+ |
Result := FEndAction |
1761 |
+ |
else |
1762 |
+ |
IBError(ibxeIB60feature, [nil]) |
1763 |
+ |
end; |
1764 |
+ |
|
1765 |
|
|
1766 |
|
function TIBTransaction.GetIdleTimer: Integer; |
1767 |
|
begin |
1973 |
|
finally |
1974 |
|
FreeMem(pteb); |
1975 |
|
end; |
1976 |
+ |
DoOnStartTransaction; |
1977 |
|
end; |
1978 |
|
|
1979 |
|
procedure TIBTransaction.TimeoutTransaction(Sender: TObject); |
2015 |
|
inherited Destroy; |
2016 |
|
end; |
2017 |
|
|
2018 |
+ |
function TIBBase.GetCharSetSize(CharSetID: integer): integer; |
2019 |
+ |
begin |
2020 |
+ |
if (CharSetID >= 0) and (CharSetID < Length(Database.FCharSetSizes)) then |
2021 |
+ |
Result := Database.FCharSetSizes[CharSetID] |
2022 |
+ |
else |
2023 |
+ |
Result := 1; {Unknown character set} |
2024 |
+ |
end; |
2025 |
+ |
|
2026 |
+ |
procedure TIBBase.HandleException(Sender: TObject); |
2027 |
+ |
begin |
2028 |
+ |
if assigned(Database) then |
2029 |
+ |
Database.HandleException(Sender) |
2030 |
+ |
else |
2031 |
+ |
SysUtils.ShowException(ExceptObject,ExceptAddr); |
2032 |
+ |
end; |
2033 |
+ |
|
2034 |
+ |
procedure TIBBase.SetCursor; |
2035 |
+ |
begin |
2036 |
+ |
if Assigned(Database) and not Database.SQLHourGlass then |
2037 |
+ |
Exit; |
2038 |
+ |
if assigned(IBGUIInterface) then |
2039 |
+ |
IBGUIInterface.SetCursor; |
2040 |
+ |
end; |
2041 |
+ |
|
2042 |
+ |
procedure TIBBase.RestoreCursor; |
2043 |
+ |
begin |
2044 |
+ |
if Assigned(Database) and not Database.SQLHourGlass then |
2045 |
+ |
Exit; |
2046 |
+ |
if assigned(IBGUIInterface) then |
2047 |
+ |
IBGUIInterface.RestoreCursor; |
2048 |
+ |
end; |
2049 |
+ |
|
2050 |
|
procedure TIBBase.CheckDatabase; |
2051 |
|
begin |
2052 |
|
if (FDatabase = nil) then |
2073 |
|
result := @FTransaction.Handle; |
2074 |
|
end; |
2075 |
|
|
2076 |
+ |
procedure TIBBase.DoBeforeDatabaseConnect(DBParams: TStrings; var DBName: string |
2077 |
+ |
); |
2078 |
+ |
begin |
2079 |
+ |
if assigned(FBeforeDatabaseConnect) then |
2080 |
+ |
BeforeDatabaseConnect(self,DBParams,DBName); |
2081 |
+ |
end; |
2082 |
+ |
|
2083 |
|
procedure TIBBase.DoAfterDatabaseConnect; |
2084 |
|
begin |
2085 |
|
if assigned(FAfterDatabaseConnect) then |
2106 |
|
SetTransaction(nil); |
2107 |
|
end; |
2108 |
|
|
2109 |
< |
procedure TIBBase.DoBeforeTransactionEnd; |
2109 |
> |
procedure TIBBase.DoBeforeTransactionEnd(Action: TTransactionAction); |
2110 |
|
begin |
2111 |
|
if Assigned(BeforeTransactionEnd) then |
2112 |
< |
BeforeTransactionEnd(Self); |
2112 |
> |
BeforeTransactionEnd(Self,Action); |
2113 |
|
end; |
2114 |
|
|
2115 |
|
procedure TIBBase.DoAfterTransactionEnd; |
2125 |
|
FTransaction := nil; |
2126 |
|
end; |
2127 |
|
|
2128 |
+ |
procedure TIBBase.DoAfterExecQuery(Sender: TObject); |
2129 |
+ |
begin |
2130 |
+ |
if FTransaction <> nil then |
2131 |
+ |
FTransaction.DoAfterExecQuery(Sender); |
2132 |
+ |
end; |
2133 |
+ |
|
2134 |
+ |
procedure TIBBase.DoAfterEdit(Sender: TObject); |
2135 |
+ |
begin |
2136 |
+ |
if FTransaction <> nil then |
2137 |
+ |
FTransaction.DoAfterEdit(Sender); |
2138 |
+ |
end; |
2139 |
+ |
|
2140 |
+ |
procedure TIBBase.DoAfterDelete(Sender: TObject); |
2141 |
+ |
begin |
2142 |
+ |
if FTransaction <> nil then |
2143 |
+ |
FTransaction.DoAfterDelete(Sender); |
2144 |
+ |
end; |
2145 |
+ |
|
2146 |
+ |
procedure TIBBase.DoAfterInsert(Sender: TObject); |
2147 |
+ |
begin |
2148 |
+ |
if FTransaction <> nil then |
2149 |
+ |
FTransaction.DoAfterInsert(Sender); |
2150 |
+ |
end; |
2151 |
+ |
|
2152 |
+ |
procedure TIBBase.DoAfterPost(Sender: TObject); |
2153 |
+ |
begin |
2154 |
+ |
if FTransaction <> nil then |
2155 |
+ |
FTransaction.DoAfterPost(Sender); |
2156 |
+ |
end; |
2157 |
+ |
|
2158 |
|
procedure TIBBase.SetDatabase(Value: TIBDatabase); |
2159 |
|
begin |
2160 |
|
if (FDatabase <> nil) then |
2364 |
|
|
2365 |
|
|
2366 |
|
|
2367 |
< |
|
2367 |
> |
|