ViewVC Help
View File | Revision Log | Show Annotations | Download File | View Changeset | Root Listing
root/public/ibx/branches/journaling/fbintf/client/FBClientAPI.pas
(Generate patch)

Comparing:
ibx/trunk/fbintf/client/FBClientAPI.pas (file contents), Revision 60 by tony, Mon Mar 27 15:21:02 2017 UTC vs.
ibx/branches/journaling/fbintf/client/FBClientAPI.pas (file contents), Revision 363 by tony, Tue Dec 7 13:30:05 2021 UTC

# Line 76 | Line 76 | uses
76    Classes,
77      {$IFDEF WINDOWS}Windows, {$ENDIF}
78      {$IFDEF FPC} Dynlibs, {$ENDIF}
79 <   IB, IBHeader, FBActivityMonitor, FBMessages, IBExternals;
79 >   IB, IBHeader, FBActivityMonitor, FBMessages, IBExternals, FmtBCD;
80  
81 < {For Linux see result of GetFirebirdLibList method}
81 > {For Linux see result of GetFirebirdLibListruntime/nongui/winipc.inc method}
82   {$IFDEF DARWIN}
83   const
84   FIREBIRD_SO2 = 'libfbclient.dylib';
# Line 90 | Line 90 | FIREBIRD_CLIENT = 'fbclient.dll'; {do no
90   FIREBIRD_EMBEDDED = 'fbembed.dll';
91   {$ENDIF}
92  
93 < {$IFNDEF FPC}
94 < type
95 <  TLibHandle = THandle;
93 > const
94 >  {fb_shutdown reasons}
95 >  fb_shutrsn_svc_stopped          = -1;
96 >  fb_shutrsn_no_connection        = -2;
97 >  fb_shutrsn_app_stopped          = -3;
98 >  fb_shutrsn_signal               = -5;
99 >  fb_shutrsn_services             = -6;
100 >  fb_shutrsn_exit_called          = -7;
101  
102   const
103 <  NilHandle = 0;
104 <  DirectorySeparator = '\';
105 < {$ENDIF}
103 >    DefaultTimeZoneFile = '/etc/timezone';
104 >
105 > const
106 >  IBLocalBufferLength = 512;
107 >  IBBigLocalBufferLength = IBLocalBufferLength * 2;
108 >  IBHugeLocalBufferLength = IBBigLocalBufferLength * 20;
109  
110   type
111    TStatusVector              = array[0..19] of NativeInt;
# Line 110 | Line 118 | type
118    TFBStatus = class(TFBInterfacedObject)
119    private
120      FIBDataBaseErrorMessages: TIBDataBaseErrorMessages;
121 +    FPrefix: AnsiString;
122    protected
123      FOwner: TFBClientAPI;
124    public
125 <    constructor Create(aOwner: TFBClientAPI);
125 >    constructor Create(aOwner: TFBClientAPI; prefix: AnsiString='');
126      function StatusVector: PStatusVector; virtual; abstract;
127  
128      {IStatus}
129 <    function GetIBErrorCode: Long;
130 <    function Getsqlcode: Long;
129 >    function GetIBErrorCode: TStatusCode;
130 >    function Getsqlcode: TStatusCode;
131      function GetMessage: AnsiString;
132      function CheckStatusVector(ErrorCodes: array of TFBStatusCode): Boolean;
133      function GetIBDataBaseErrorMessages: TIBDataBaseErrorMessages;
134      procedure SetIBDataBaseErrorMessages(Value: TIBDataBaseErrorMessages);
135    end;
136  
137 +  { TFBLibrary }
138 +
139 +  TFBLibrary = class(TFBInterfacedObject,IFirebirdLibrary)
140 +  private
141 +    class var FEnvSetupDone: boolean;
142 +    class var FLibraryList: array of IFirebirdLibrary;
143 +  private
144 +    FFirebirdAPI: IFirebirdAPI;
145 +    FRequestedLibName: string;
146 +    function LoadIBLibrary: boolean;
147 +  protected
148 +    FFBLibraryName: string;
149 +    FIBLibrary: TLibHandle;
150 +    procedure FreeFBLibrary;
151 +    function GetOverrideLibName: string;
152 +    class procedure SetupEnvironment;
153 +  protected
154 +    function GetFirebird3API: IFirebirdAPI; virtual; abstract;
155 +    function GetLegacyFirebirdAPI: IFirebirdAPI; virtual; abstract;
156 +  public
157 +    constructor Create(aLibPathName: string='');
158 +    destructor Destroy; override;
159 +    class function GetFBLibrary(aLibPathName: string): IFirebirdLibrary;
160 +    class procedure FreeLibraries;
161 +    function SameLibrary(aLibName: string): boolean;
162 +
163 +  public
164 +    {IFirebirdLibrary}
165 +    function GetHandle: TLibHandle;
166 +    function GetLibraryName: string;
167 +    function GetLibraryFilePath: string;
168 +    function GetFirebirdAPI: IFirebirdAPI;
169 +    property IBLibrary: TLibHandle read FIBLibrary;
170 +  end;
171 +
172    { TFBClientAPI }
173  
174    TFBClientAPI = class(TFBInterfacedObject)
175    private
176 <    FOwnsIBLibrary: boolean;
176 >    FLocalTimeZoneName: AnsiString; {Informal Time Zone Name from tzname e.g. GMT or BST}
177 >    FTZDataTimeZoneID: AnsiString; {TZData DB ID e.g. Europe/London}
178 >    FLocalTimeOffset: integer;
179 >    FIsDaylightSavingsTime: boolean;
180      class var FIBCS: TRTLCriticalSection;
181 <    procedure LoadIBLibrary;
181 >    function FBTimeStampToDateTime(aDate, aTime: longint): TDateTime;
182 >    procedure GetTZDataSettings;
183    protected
184 <    class var FFBLibraryName: string;
137 <    class var IBLibrary: TLibHandle;
138 <    {$IFDEF WINDOWS}
139 <    class var FFBLibraryPath: string;
140 <    {$ENDIF}
184 >    FFBLibrary: TFBLibrary;
185      function GetProcAddr(ProcName: PAnsiChar): Pointer;
186 <    function GetOverrideLibName: string;
187 <    {$IFDEF UNIX}
188 <    function GetFirebirdLibList: string; virtual; abstract;
189 <    {$ENDIF}
190 <    procedure LoadInterface; virtual;
186 >
187 >  protected type
188 >    Tfb_shutdown = function (timeout: uint;
189 >                                 const reason: int): int;
190 >                   {$IFDEF WINDOWS} stdcall; {$ELSE} cdecl; {$ENDIF}
191 >  protected
192 >    {FB Shutdown API}
193 >    fb_shutdown: Tfb_shutdown;
194 >
195    public
196      {Taken from legacy API}
197      isc_sqlcode: Tisc_sqlcode;
198      isc_sql_interprete: Tisc_sql_interprete;
151    isc_interprete: Tisc_interprete;
199      isc_event_counts: Tisc_event_counts;
200      isc_event_block: Tisc_event_block;
201      isc_free: Tisc_free;
202 +    isc_portable_integer: Tisc_portable_integer;
203  
204 <    constructor Create;
157 <    destructor Destroy; override;
204 >    constructor Create(aFBLibrary: TFBLibrary);
205      procedure IBAlloc(var P; OldSize, NewSize: Integer);
206      procedure IBDataBaseError;
207 <    procedure SetupEnvironment;
207 >    function LoadInterface: boolean; virtual;
208 >    procedure FBShutdown; virtual;
209 >    function GetAPI: IFirebirdAPI; virtual; abstract;
210 >    {$IFDEF UNIX}
211 >    function GetFirebirdLibList: string; virtual; abstract;
212 >    {$ENDIF}
213 >    function HasDecFloatSupport: boolean;
214 >    function HasInt128Support: boolean; virtual;
215 >    function HasLocalTZDB: boolean; virtual;
216 >    function HasExtendedTZSupport: boolean; virtual;
217 >    function HasTimeZoneSupport: boolean; virtual;
218  
219 +  public
220 +    property LocalTimeZoneName: AnsiString read FLocalTimeZoneName;
221 +    property TZDataTimeZoneID: AnsiString read FTZDataTimeZoneID;
222 +    property LocalTimeOffset: integer read FLocalTimeOffset;
223 +  public
224      {Encode/Decode}
225      procedure EncodeInteger(aValue: integer; len: integer; buffer: PByte);
226 <    function DecodeInteger(bufptr: PByte; len: short): integer; virtual; abstract;
227 <    procedure SQLEncodeDate(aDate: TDateTime; bufptr: PByte); virtual; abstract;
228 <    function SQLDecodeDate(byfptr: PByte): TDateTime; virtual; abstract;
229 <    procedure SQLEncodeTime(aTime: TDateTime; bufptr: PByte); virtual; abstract;
226 >    function DecodeInteger(bufptr: PByte; len: short): int64;
227 >    procedure SQLEncodeDate(aDate: TDateTime; bufptr: PByte);  virtual; abstract;
228 >    function SQLDecodeDate(byfptr: PByte): TDateTime;  virtual; abstract;
229 >    procedure SQLEncodeTime(aTime: TDateTime; bufptr: PByte);  virtual; abstract;
230      function SQLDecodeTime(bufptr: PByte): TDateTime;  virtual; abstract;
231      procedure SQLEncodeDateTime(aDateTime: TDateTime; bufptr: PByte); virtual; abstract;
232 <    function SQLDecodeDateTime(bufptr: PByte): TDateTime; virtual; abstract;
233 <
232 >    function  SQLDecodeDateTime(bufptr: PByte): TDateTime; virtual; abstract;
233 >    function FormatStatus(Status: TFBStatus): AnsiString; virtual; abstract;
234 >    function Int128ToStr(bufptr: PByte; scale: integer): AnsiString; virtual;
235 >    procedure StrToInt128(scale: integer; aValue: AnsiString; bufptr: PByte);
236 >      virtual;
237 >    procedure SQLDecFloatEncode(aValue: tBCD; SQLType: cardinal; bufptr: PByte); virtual;
238 >    function SQLDecFloatDecode(SQLType: cardinal;  bufptr: PByte): tBCD; virtual;
239  
240      {IFirebirdAPI}
241      function GetStatus: IStatus; virtual; abstract;
242      function IsLibraryLoaded: boolean;
243      function IsEmbeddedServer: boolean; virtual; abstract;
244 <    function GetLibraryName: string;
245 < end;
244 >    function GetFBLibrary: IFirebirdLibrary;
245 >    function GetImplementationVersion: AnsiString;
246 >    function GetClientMajor: integer;  virtual; abstract;
247 >    function GetClientMinor: integer;  virtual; abstract;
248 >  end;
249  
250 < var FirebirdClientAPI: TFBClientAPI = nil;
250 >    IJournallingHook = interface
251 >      ['{7d3e45e0-3628-416a-9e22-c20474825031}']
252 >      procedure TransactionStart(Tr: ITransaction);
253 >      function TransactionEnd(TransactionID: integer; Action: TTransactionAction): boolean;
254 >      procedure TransactionRetained(Tr: ITransaction; OldTransactionID: integer; Action: TTransactionAction);
255 >      procedure ExecQuery(Stmt: IStatement);
256 >    end;
257  
258   implementation
259  
260 < uses IBUtils, Registry, {$IFDEF Unix} initc, {$ENDIF}
260 > uses IBUtils, Registry,
261 >  {$IFDEF Unix} unix, initc, dl, {$ENDIF}
262   {$IFDEF FPC}
263   {$IFDEF WINDOWS }
264   WinDirs,
# Line 197 | Line 274 | SysUtils;
274   {$I 'include/wloadlibrary.inc'}
275   {$ENDIF}
276  
277 <  {$IFDEF Unix}
278 <  {SetEnvironmentVariable doesn't exist so we have to use C Library}
279 <  function setenv(name:Pchar; value:Pchar; replace:integer):integer;cdecl;external clib name 'setenv';
280 <  function unsetenv(name:Pchar):integer;cdecl;external clib name 'unsetenv';
281 <  function SetEnvironmentVariable(name:PAnsiChar; value:PAnsiChar):boolean;
282 <  // Set environment variable; if empty string given, remove it.
277 >
278 > { TFBLibrary }
279 >
280 > function TFBLibrary.GetOverrideLibName: string;
281 > begin
282 >  Result := FFBLibraryName;
283 >  if (Result = '') and AllowUseOfFBLIB then
284 >    Result := GetEnvironmentVariable('FBLIB');
285 >  if Result = '' then
286    begin
287 <    result:=false; //assume failure
288 <    if value = '' then
209 <    begin
210 <      // Assume user wants to remove variable.
211 <      if unsetenv(name)=0 then result:=true;
212 <    end
213 <    else
214 <    begin
215 <      // Non empty so set the variable
216 <      if setenv(name, value, 1)=0 then result:=true;
217 <    end;
287 >    if assigned(OnGetLibraryName) then
288 >      OnGetLibraryName(Result)
289    end;
290 <  {$ENDIF}
290 > end;
291  
292 < { TFBClientAPI }
292 > procedure TFBLibrary.FreeFBLibrary;
293 > begin
294 >  (FFirebirdAPI as TFBClientAPI).FBShutdown;
295 >  if FIBLibrary <> NilHandle then
296 >    FreeLibrary(FIBLibrary);
297 >  FIBLibrary := NilHandle;
298 >  FFBLibraryName := '';
299 > end;
300  
301 < constructor TFBClientAPI.Create;
301 > function TFBLibrary.GetLibraryName: string;
302 > begin
303 >  Result := ExtractFileName(FFBLibraryName);
304 > end;
305 >
306 > function TFBLibrary.GetFirebirdAPI: IFirebirdAPI;
307 > begin
308 >  Result := FFirebirdAPI;
309 > end;
310 >
311 > constructor TFBLibrary.Create(aLibPathName: string);
312   begin
313    inherited Create;
314 <  LoadIBLibrary;
315 <  if (IBLibrary <> NilHandle) then
314 >  SetupEnvironment;
315 >  FFBLibraryName := aLibPathName;
316 >  FIBLibrary := NilHandle;
317 >  FFirebirdAPI := GetFirebird3API;
318 >  FRequestedLibName := aLibPathName;
319 >  if aLibPathName <> '' then
320 >  begin
321 >    SetLength(FLibraryList,Length(FLibraryList)+1);
322 >    FLibraryList[Length(FLibraryList)-1] := self;
323 >  end;
324 >  if FFirebirdAPI <> nil then
325 >  begin
326 >    {First try Firebird 3}
327 >    if not LoadIBLibrary or not (FFirebirdAPI as TFBClientAPI).LoadInterface then
328 >      FFirebirdAPI := nil;
329 >  end;
330 >
331 >  if FFirebirdAPI = nil then
332    begin
333 <    SetupEnvironment;
334 <    LoadInterface;
333 >    {now try Firebird 2.5. Under Unix we need to reload the library in case we
334 >     are to use the embedded library}
335 >    FFirebirdAPI := GetLegacyFirebirdAPI;
336 >    if FFirebirdAPI <> nil then
337 >    begin
338 >      {$IFDEF UNIX}
339 >      FreeFBLibrary;
340 >      {$ENDIF}
341 >      if not LoadIBLibrary or not (FFirebirdAPI as TFBClientAPI).LoadInterface then
342 >        FFirebirdAPI := nil;
343 >    end;
344    end;
345 <  FirebirdClientAPI := self;
345 >  {Note: FFirebirdAPI will be set to nil if the Firebird API fails to load}
346   end;
347  
348 < destructor TFBClientAPI.Destroy;
348 > destructor TFBLibrary.Destroy;
349   begin
350 <  FirebirdClientAPI := nil;
351 <  if FOwnsIBLibrary and (IBLibrary <> NilHandle) then
239 <    FreeLibrary(IBLibrary);
240 <  IBLibrary := NilHandle;
350 >  FreeFBLibrary;
351 >  FFirebirdAPI := nil;
352    inherited Destroy;
353   end;
354  
355 + class function TFBLibrary.GetFBLibrary(aLibPathName: string): IFirebirdLibrary;
356 + var i: integer;
357 + begin
358 +  Result := nil;
359 +  if aLibPathName <> '' then
360 +  begin
361 +    for i := 0 to Length(FLibraryList) - 1 do
362 +    begin
363 +      if (FLibraryList[i] as TFBLibrary).SameLibrary(aLibPathName) then
364 +      begin
365 +        Result := FLibraryList[i];
366 +        Exit;
367 +      end;
368 +    end;
369 +    Result := Create(aLibPathName);
370 +  end;
371 +
372 + end;
373 +
374 + class procedure TFBLibrary.FreeLibraries;
375 + var i: integer;
376 + begin
377 +  for i := 0 to Length(FLibraryList) - 1 do
378 +    FLibraryList[i] := nil;
379 +  SetLength(FLibraryList,0);
380 + end;
381 +
382 + function TFBLibrary.SameLibrary(aLibName: string): boolean;
383 + begin
384 +  Result := FRequestedLibName = aLibName;
385 + end;
386 +
387 + function TFBLibrary.GetHandle: TLibHandle;
388 + begin
389 +  Result := FIBLibrary;
390 + end;
391 +
392 + { TFBClientAPI }
393 +
394 + constructor TFBClientAPI.Create(aFBLibrary: TFBLibrary);
395 + begin
396 +  inherited Create;
397 +  FFBLibrary := aFBLibrary;
398 +  GetTZDataSettings;
399 + end;
400 +
401   procedure TFBClientAPI.IBAlloc(var P; OldSize, NewSize: Integer);
402   var
403    i: Integer;
# Line 254 | Line 411 | begin
411    raise EIBInterBaseError.Create(GetStatus);
412   end;
413  
257 {Under Unixes, if using an embedded server then set up local TMP and LOCK Directories}
258
259 procedure TFBClientAPI.SetupEnvironment;
260 var TmpDir: AnsiString;
261 begin
262  {$IFDEF UNIX}
263    TmpDir := GetTempDir +
264        DirectorySeparator + 'firebird_' + sysutils.GetEnvironmentVariable('USER');
265    if sysutils.GetEnvironmentVariable('FIREBIRD_TMP') = '' then
266    begin
267      if not DirectoryExists(tmpDir) then
268        mkdir(tmpDir);
269      SetEnvironmentVariable('FIREBIRD_TMP',PAnsiChar(TmpDir));
270    end;
271    if sysutils.GetEnvironmentVariable('FIREBIRD_LOCK') = '' then
272    begin
273      if not DirectoryExists(tmpDir) then
274        mkdir(tmpDir);
275      SetEnvironmentVariable('FIREBIRD_LOCK',PAnsiChar(TmpDir));
276    end;
277  {$ENDIF}
278 end;
279
414   procedure TFBClientAPI.EncodeInteger(aValue: integer; len: integer; buffer: PByte);
415   begin
416    while len > 0 do
# Line 288 | Line 422 | begin
422    end;
423   end;
424  
425 + function TFBClientAPI.DecodeInteger(bufptr: PByte; len: short): int64;
426 + begin
427 +  Result := isc_portable_integer(bufptr,len);
428 + end;
429 +
430 + function TFBClientAPI.Int128ToStr(bufptr: PByte; scale: integer): AnsiString;
431 + begin
432 +  if not HasInt128Support then
433 +    IBError(ibxeNotSupported,[]);
434 + end;
435 +
436 + procedure TFBClientAPI.StrToInt128(scale: integer; aValue: AnsiString; bufptr: PByte);
437 + begin
438 +  if not HasInt128Support then
439 +    IBError(ibxeNotSupported,[]);
440 + end;
441 +
442 + procedure TFBClientAPI.SQLDecFloatEncode(aValue: tBCD; SQLType: cardinal;
443 +  bufptr: PByte);
444 + begin
445 +  if not HasDecFloatSupport then
446 +    IBError(ibxeNotSupported,[]);
447 + end;
448 +
449 + function TFBClientAPI.SQLDecFloatDecode(SQLType: cardinal; bufptr: PByte): tBCD;
450 + begin
451 +  if not HasDecFloatSupport then
452 +    IBError(ibxeNotSupported,[]);
453 + end;
454 +
455   function TFBClientAPI.IsLibraryLoaded: boolean;
456   begin
457 <  Result := IBLibrary <> NilHandle;
457 >  Result := FFBLibrary.IBLibrary <> NilHandle;
458 > end;
459 >
460 > function TFBClientAPI.GetFBLibrary: IFirebirdLibrary;
461 > begin
462 >  Result := FFBLibrary;
463 > end;
464 >
465 > function TFBClientAPI.FBTimeStampToDateTime(aDate, aTime: longint): TDateTime;
466 > begin
467 >  {aDate/aTime are in TTimestamp format but aTime is decimilliseconds}
468 >  aDate := aDate - DateDelta;
469 >  if aDate < 0 then
470 >    Result := trunc(aDate) - abs(frac(aTime / (MSecsPerDay*10)))
471 >  else
472 >    Result := trunc(aDate) + abs(frac(aTime / (MSecsPerDay*10)));
473   end;
474  
475 + {$IFDEF UNIX}
476 +
477 + procedure TFBClientAPI.GetTZDataSettings;
478 + var S: TStringList;
479 + begin
480 +  FLocalTimeOffset := GetLocalTimeOffset;
481 +  {$if declared(Gettzname)}
482 +  FLocalTimeZoneName := Gettzname(tzdaylight);
483 +  {$else}
484 +  FLocalTimeZoneName := tzname[tzdaylight];
485 +  {$ifend}
486 +  FIsDaylightSavingsTime := tzdaylight;
487 +  if FileExists(DefaultTimeZoneFile) then
488 +  begin
489 +    S := TStringList.Create;
490 +    try
491 +      S.LoadFromFile(DefaultTimeZoneFile);
492 +      if S.Count > 0 then
493 +        FTZDataTimeZoneID := S[0];
494 +    finally
495 +      S.Free;
496 +    end;
497 +  end;
498 + end;
499 + {$ENDIF}
500 +
501 + {$IFDEF WINDOWS}
502 + procedure TFBClientAPI.GetTZDataSettings;
503 + var TZInfo: TTimeZoneInformation;
504 + begin
505 +  FIsDaylightSavingsTime := false;
506 +  {is there any way of working out the default TZData DB time zone ID under Windows?}
507 +  case GetTimeZoneInformation(TZInfo) of
508 +    TIME_ZONE_ID_UNKNOWN:
509 +      begin
510 +        FLocalTimeZoneName := '';
511 +        FLocalTimeOffset := 0;
512 +      end;
513 +    TIME_ZONE_ID_STANDARD:
514 +      begin
515 +        FLocalTimeZoneName := strpas(PWideChar(@TZInfo.StandardName));
516 +        FLocalTimeOffset := TZInfo.Bias;
517 +      end;
518 +    TIME_ZONE_ID_DAYLIGHT:
519 +      begin
520 +        FLocalTimeZoneName := strpas(PWideChar(@TZInfo.DaylightName));
521 +        FLocalTimeOffset := TZInfo.DayLightBias;
522 +        FIsDaylightSavingsTime := true;
523 +      end;
524 +  end;
525 + end;
526 + {$ENDIF}
527 +
528   function TFBClientAPI.GetProcAddr(ProcName: PAnsiChar): Pointer;
529   begin
530 <  Result := GetProcAddress(IBLibrary, ProcName);
530 >  Result := nil;
531 >  if assigned(FFBLibrary) and (FFBLibrary.IBLibrary <> NilHandle) then
532 >    Result := GetProcAddress(FFBLibrary.IBLibrary, ProcName);
533    if not Assigned(Result) then
534      raise Exception.CreateFmt(SFirebirdAPIFuncNotFound,[ProcName]);
535   end;
536  
537 < function TFBClientAPI.GetOverrideLibName: string;
537 > function TFBClientAPI.HasDecFloatSupport: boolean;
538   begin
539 <  Result := '';
540 <  if AllowUseOfFBLIB then
541 <    Result := GetEnvironmentVariable('FBLIB');
542 <  if Result = '' then
543 <  begin
544 <    if assigned(OnGetLibraryName) then
545 <      OnGetLibraryName(Result)
546 <  end;
539 >  Result := GetClientMajor >= 4;
540 > end;
541 >
542 > function TFBClientAPI.HasInt128Support: boolean;
543 > begin
544 >  Result := false;
545 > end;
546 >
547 > function TFBClientAPI.HasLocalTZDB: boolean;
548 > begin
549 >  Result := false;
550 > end;
551 >
552 > function TFBClientAPI.HasExtendedTZSupport: boolean;
553 > begin
554 >  Result := false;
555   end;
556  
557 < procedure TFBClientAPI.LoadInterface;
557 > function TFBClientAPI.HasTimeZoneSupport: boolean;
558 > begin
559 >  Result := false;
560 > end;
561 >
562 > function TFBClientAPI.GetImplementationVersion: AnsiString;
563 > begin
564 >  Result := Format('%d.%d',[GetClientMajor,GetClientMinor]);
565 > end;
566 >
567 > function TFBClientAPI.LoadInterface: boolean;
568   begin
569    isc_sqlcode := GetProcAddr('isc_sqlcode'); {do not localize}
570    isc_sql_interprete := GetProcAddr('isc_sql_interprete'); {do not localize}
319  isc_interprete := GetProcAddr('isc_interprete'); {do not localize}
571    isc_event_counts := GetProcAddr('isc_event_counts'); {do not localize}
572    isc_event_block := GetProcAddr('isc_event_block'); {do not localize}
573    isc_free := GetProcAddr('isc_free'); {do not localize}
574 +  isc_portable_integer := GetProcAddr('isc_portable_integer'); {do not localize}
575 +  fb_shutdown := GetProcAddr('fb_shutdown'); {do not localize}
576 +  Result := assigned(isc_free);
577   end;
578  
579 < function TFBClientAPI.GetLibraryName: string;
579 > procedure TFBClientAPI.FBShutdown;
580   begin
581 <  Result := FFBLibraryName;
581 >  if assigned(fb_shutdown) then
582 >    fb_shutdown(0,fb_shutrsn_exit_called);
583   end;
584  
330 const
331  IBLocalBufferLength = 512;
332  IBBigLocalBufferLength = IBLocalBufferLength * 2;
333  IBHugeLocalBufferLength = IBBigLocalBufferLength * 20;
334
585   { TFBStatus }
586  
587 < constructor TFBStatus.Create(aOwner: TFBClientAPI);
587 > constructor TFBStatus.Create(aOwner: TFBClientAPI; prefix: AnsiString);
588   begin
589    inherited Create;
590    FOwner := aOwner;
591 <  FIBDataBaseErrorMessages := [ShowSQLMessage, ShowIBMessage];
591 >  FPrefix := prefix;
592 >  FIBDataBaseErrorMessages := [ShowSQLCode, ShowSQLMessage, ShowIBMessage];
593   end;
594  
595 < function TFBStatus.GetIBErrorCode: Long;
595 > function TFBStatus.GetIBErrorCode: TStatusCode;
596   begin
597    Result := StatusVector^[1];
598   end;
599  
600 < function TFBStatus.Getsqlcode: Long;
600 > function TFBStatus.Getsqlcode: TStatusCode;
601   begin
602    with FOwner do
603      Result := isc_sqlcode(PISC_STATUS(StatusVector));
# Line 356 | Line 607 | function TFBStatus.GetMessage: AnsiStrin
607   var local_buffer: array[0..IBHugeLocalBufferLength - 1] of AnsiChar;
608      IBDataBaseErrorMessages: TIBDataBaseErrorMessages;
609      sqlcode: Long;
359    psb: PStatusVector;
610   begin
611 <  Result := '';
611 >  Result := FPrefix;
612    IBDataBaseErrorMessages := FIBDataBaseErrorMessages;
613    sqlcode := Getsqlcode;
614    if (ShowSQLCode in IBDataBaseErrorMessages) then
615      Result := Result + 'SQLCODE: ' + IntToStr(sqlcode); {do not localize}
616  
367  Exclude(IBDataBaseErrorMessages, ShowSQLMessage);
617    if (ShowSQLMessage in IBDataBaseErrorMessages) then
618    begin
619      with FOwner do
620 <      isc_sql_interprete(sqlcode, local_buffer, IBLocalBufferLength);
620 >      isc_sql_interprete(sqlcode, local_buffer, sizeof(local_buffer));
621      if (ShowSQLCode in FIBDataBaseErrorMessages) then
622 <      Result := Result + CRLF;
623 <    Result := Result + strpas(local_buffer);
622 >      Result := Result + LineEnding;
623 >    Result := Result + 'Engine Code: ' + IntToStr(GetIBErrorCode) + ' ' + strpas(local_buffer);
624    end;
625  
626    if (ShowIBMessage in IBDataBaseErrorMessages) then
627    begin
628      if (ShowSQLCode in IBDataBaseErrorMessages) or
629         (ShowSQLMessage in IBDataBaseErrorMessages) then
630 <      Result := Result + CRLF;
631 <    psb := StatusVector;
383 <    with FOwner do
384 <    while (isc_interprete(@local_buffer, @psb) > 0) do
385 <    begin
386 <      if (Result <> '') and (Result[Length(Result)] <> LF) then
387 <        Result := Result + CRLF;
388 <      Result := Result + strpas(local_buffer);
389 <    end;
630 >      Result := Result + LineEnding;
631 >    Result := Result + FOwner.FormatStatus(self);
632    end;
633    if (Result <> '') and (Result[Length(Result)] = '.') then
634      Delete(Result, Length(Result), 1);
# Line 444 | Line 686 | begin
686   end;
687  
688   initialization
689 <  TFBClientAPI.IBLibrary := NilHandle;
689 >  TFBLibrary.FEnvSetupDone := false;
690    {$IFNDEF FPC}
691    InitializeCriticalSection(TFBClientAPI.FIBCS);
692    {$ELSE}
# Line 452 | Line 694 | initialization
694    {$ENDIF}
695  
696   finalization
697 +  TFBLibrary.FreeLibraries;
698    {$IFNDEF FPC}
699    DeleteCriticalSection(TFBClientAPI.FIBCS);
700    {$ELSE}
701    DoneCriticalSection(TFBClientAPI.FIBCS);
702    {$ENDIF}
460  if TFBClientAPI.IBLibrary <> NilHandle then
461  begin
462    FreeLibrary(TFBClientAPI.IBLibrary);
463    TFBClientAPI.IBLibrary := NilHandle;
464    TFBClientAPI.FFBLibraryName := '';
465  end;
466
703   end.
704  

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines