ViewVC Help
View File | Revision Log | Show Annotations | Download File | View Changeset | Root Listing
root/public/ibx/trunk/runtime/IBServices.pas
(Generate patch)

Comparing ibx/trunk/runtime/IBServices.pas (file contents):
Revision 29 by tony, Sat May 9 11:37:49 2015 UTC vs.
Revision 45 by tony, Tue Dec 6 10:33:46 2016 UTC

# Line 1 | Line 1
1 < {************************************************************************}
2 < {                                                                        }
3 < {       Borland Delphi Visual Component Library                          }
4 < {       InterBase Express core components                                }
5 < {                                                                        }
6 < {       Copyright (c) 1998-2000 Inprise Corporation                      }
7 < {                                                                        }
8 < {    InterBase Express is based in part on the product                   }
9 < {    Free IB Components, written by Gregory H. Deatz for                 }
10 < {    Hoagland, Longo, Moran, Dunst & Doukas Company.                     }
11 < {    Free IB Components is used under license.                           }
12 < {                                                                        }
13 < {    The contents of this file are subject to the InterBase              }
14 < {    Public License Version 1.0 (the "License"); you may not             }
15 < {    use this file except in compliance with the License. You            }
16 < {    may obtain a copy of the License at http://www.Inprise.com/IPL.html }
17 < {    Software distributed under the License is distributed on            }
18 < {    an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, either              }
19 < {    express or implied. See the License for the specific language       }
20 < {    governing rights and limitations under the License.                 }
21 < {    The Original Code was created by InterBase Software Corporation     }
22 < {       and its successors.                                              }
23 < {    Portions created by Inprise Corporation are Copyright (C) Inprise   }
24 < {       Corporation. All Rights Reserved.                                }
25 < {    Contributor(s): Jeff Overcash                                       }
26 < {                                                                        }
27 < {    IBX For Lazarus (Firebird Express)                                  }
28 < {    Contributor: Tony Whyman, MWA Software http://www.mwasoftware.co.uk }
29 < {    Portions created by MWA Software are copyright McCallum Whyman      }
30 < {    Associates Ltd 2011                                                 }
31 < {                                                                        }
32 < {************************************************************************}
33 <
34 < {
35 <  InterBase Express provides component interfaces to
36 <  functions introduced in InterBase 6.0.  The Services
37 <  components (TIB*Service, TIBServerProperties)
38 <  function only if you have installed InterBase 6.0 or
39 <  later software, including Firebird
40 < }
41 <
42 < unit IBServices;
43 <
44 < {$Mode Delphi}
45 <
46 < interface
47 <
48 < uses
49 < {$IFDEF WINDOWS }
50 <  Windows,
51 < {$ELSE}
52 <  unix,
53 < {$ENDIF}
54 <  SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
55 <  IBDialogs, IBHeader, IB, IBExternals;
56 <
57 < const
58 <  DefaultBufferSize = 32000;
59 <
60 <  SPBPrefix = 'isc_spb_';
61 <  SPBConstantNames: array[1..isc_spb_last_spb_constant] of String = (
62 <    'user_name',
63 <    'sys_user_name',
64 <    'sys_user_name_enc',
65 <    'password',
66 <    'password_enc',
67 <    'command_line',
68 <    'db_name',
69 <    'verbose',
70 <    'options',
71 <    'connect_timeout',
72 <    'dummy_packet_interval',
73 <    'sql_role_name'
74 <  );
75 <
76 <  SPBConstantValues: array[1..isc_spb_last_spb_constant] of Integer = (
77 <    isc_spb_user_name_mapped_to_server,
78 <    isc_spb_sys_user_name_mapped_to_server,
79 <    isc_spb_sys_user_name_enc_mapped_to_server,
80 <    isc_spb_password_mapped_to_server,
81 <    isc_spb_password_enc_mapped_to_server,
82 <    isc_spb_command_line_mapped_to_server,
83 <    isc_spb_dbname_mapped_to_server,
84 <    isc_spb_verbose_mapped_to_server,
85 <    isc_spb_options_mapped_to_server,
86 <    isc_spb_connect_timeout_mapped_to_server,
87 <    isc_spb_dummy_packet_interval_mapped_to_server,
88 <    isc_spb_sql_role_name_mapped_to_server
89 <  );
90 <
91 < type
92 <  TProtocol = (TCP, SPX, NamedPipe, Local);
93 <  TOutputBufferOption = (ByLine, ByChunk);
94 <
95 <  TIBCustomService = class;
96 <
97 <  TLoginEvent = procedure(Database: TIBCustomService;
98 <    LoginParams: TStrings) of object;
99 <
100 <  TIBCustomService = class(TComponent)
101 <  private
102 <    FIBLoaded: Boolean;
103 <    FParamsChanged : Boolean;
104 <    FSPB, FQuerySPB : PChar;
105 <    FSPBLength, FQuerySPBLength : Short;
106 <    FTraceFlags: TTraceFlags;
107 <    FOnLogin: TLoginEvent;
108 <    FLoginPrompt: Boolean;
109 <    FBufferSize: Integer;
110 <    FOutputBuffer: PChar;
111 <    FQueryParams: String;
112 <    FServerName: string;
113 <    FHandle: TISC_SVC_HANDLE;
114 <    FStreamedActive  : Boolean;
115 <    FOnAttach: TNotifyEvent;
116 <    FOutputBufferOption: TOutputBufferOption;
117 <    FProtocol: TProtocol;
118 <    FParams: TStrings;
119 <    function GetActive: Boolean;
120 <    function GetServiceParamBySPB(const Idx: Integer): String;
121 <    procedure SetActive(const Value: Boolean);
122 <    procedure SetBufferSize(const Value: Integer);
123 <    procedure SetParams(const Value: TStrings);
124 <    procedure SetServerName(const Value: string);
125 <    procedure SetProtocol(const Value: TProtocol);
126 <    procedure SetServiceParamBySPB(const Idx: Integer;
127 <      const Value: String);
128 <    function IndexOfSPBConst(st: String): Integer;
129 <    procedure ParamsChange(Sender: TObject);
130 <    procedure ParamsChanging(Sender: TObject);
131 <    procedure CheckServerName;
132 <    function Call(ErrCode: ISC_STATUS; RaiseError: Boolean): ISC_STATUS;
133 <    function ParseString(var RunLen: Integer): string;
134 <    function ParseInteger(var RunLen: Integer): Integer;
135 <    procedure GenerateSPB(sl: TStrings; var SPB: String; var SPBLength: Short);
136 <
137 <  protected
138 <    procedure Loaded; override;
139 <    function Login: Boolean;
140 <    procedure CheckActive;
141 <    procedure CheckInactive;
142 <    property OutputBuffer : PChar read FOutputBuffer;
143 <    property OutputBufferOption : TOutputBufferOption read FOutputBufferOption write FOutputBufferOption;
144 <    property BufferSize : Integer read FBufferSize write SetBufferSize default DefaultBufferSize;
145 <    procedure InternalServiceQuery;
146 <    property ServiceQueryParams: String read FQueryParams write FQueryParams;
147 <
148 <  public
149 <    constructor Create(AOwner: TComponent); override;
150 <    destructor Destroy; override;
151 <    procedure Attach;
152 <    procedure Detach;
153 <    property Handle: TISC_SVC_HANDLE read FHandle;
154 <    property ServiceParamBySPB[const Idx: Integer]: String read GetServiceParamBySPB
155 <                                                      write SetServiceParamBySPB;
156 <  published
157 <    property Active: Boolean read GetActive write SetActive default False;
158 <    property ServerName: string read FServerName write SetServerName;
159 <    property Protocol: TProtocol read FProtocol write SetProtocol default Local;
160 <    property Params: TStrings read FParams write SetParams;
161 <    property LoginPrompt: Boolean read FLoginPrompt write FLoginPrompt default True;
162 <    property TraceFlags: TTraceFlags read FTraceFlags write FTraceFlags;
163 <    property OnAttach: TNotifyEvent read FOnAttach write FOnAttach;
164 <    property OnLogin: TLoginEvent read FOnLogin write FOnLogin;
165 <  end;
166 <
167 <  TDatabaseInfo = class
168 <  public
169 <    NoOfAttachments: Integer;
170 <    NoOfDatabases: Integer;
171 <    DbName: array of string;
172 <    constructor Create;
173 <    destructor Destroy; override;
174 <  end;
175 <
176 <  TLicenseInfo = class
177 <  public
178 <    Key: array of string;
179 <    Id: array of string;
180 <    Desc: array of string;
181 <    LicensedUsers: Integer;
182 <    constructor Create;
183 <    destructor Destroy; override;
184 <  end;
185 <
186 <  TLicenseMaskInfo = class
187 <  public
188 <    LicenseMask: Integer;
189 <    CapabilityMask: Integer;
190 <  end;
191 <
192 <  TConfigFileData = class
193 <  public
194 <    ConfigFileValue: array of integer;
195 <    ConfigFileKey: array of integer;
196 <    constructor Create;
197 <    destructor Destroy; override;
198 <  end;
199 <
200 <  TConfigParams = class
201 <  public
202 <    ConfigFileData: TConfigFileData;
203 <    ConfigFileParams: array of string;
204 <    BaseLocation: string;
205 <    LockFileLocation: string;
206 <    MessageFileLocation: string;
207 <    SecurityDatabaseLocation: string;
208 <    constructor Create;
209 <    destructor Destroy; override;
210 <  end;
211 <
212 <  TVersionInfo = class
213 <    ServerVersion: String;
214 <    ServerImplementation: string;
215 <    ServiceVersion: Integer;
216 <  end;
217 <
218 <  TPropertyOption = (Database, License, LicenseMask, ConfigParameters, Version);
219 <  TPropertyOptions = set of TPropertyOption;
220 <
221 <  TIBServerProperties = class(TIBCustomService)
222 <  private
223 <    FOptions: TPropertyOptions;
224 <    FDatabaseInfo: TDatabaseInfo;
225 <    FLicenseInfo: TLicenseInfo;
226 <    FLicenseMaskInfo: TLicenseMaskInfo;
227 <    FVersionInfo: TVersionInfo;
228 <    FConfigParams: TConfigParams;
229 <    procedure ParseConfigFileData(var RunLen: Integer);
230 <  public
231 <    constructor Create(AOwner: TComponent); override;
232 <    destructor Destroy; override;
233 <    procedure Fetch;
234 <    procedure FetchDatabaseInfo;
235 <    procedure FetchLicenseInfo;
236 <    procedure FetchLicenseMaskInfo;
237 <    procedure FetchConfigParams;
238 <    procedure FetchVersionInfo;
239 <    property DatabaseInfo: TDatabaseInfo read FDatabaseInfo;
240 <    property LicenseInfo: TLicenseInfo read FLicenseInfo;
241 <    property LicenseMaskInfo: TLicenseMaskInfo read FLicenseMaskInfo;
242 <    property VersionInfo: TVersionInfo read FVersionInfo;
243 <    property ConfigParams: TConfigParams read FConfigParams;
244 <  published
245 <    property Options : TPropertyOptions read FOptions write FOptions;
246 <  end;
247 <
248 <  TIBControlService = class (TIBCustomService)
249 <  private
250 <    FStartParams: String;
251 <    FStartSPB: PChar;
252 <    FStartSPBLength: Integer;
253 <    function GetIsServiceRunning: Boolean;
254 <  protected
255 <    property ServiceStartParams: String read FStartParams write FStartParams;
256 <    procedure SetServiceStartOptions; virtual;
257 <    procedure ServiceStartAddParam (Value: string; param: Integer); overload;
258 <    procedure ServiceStartAddParam (Value: Integer; param: Integer); overload;
259 <    procedure InternalServiceStart;
260 <
261 <  public
262 <    constructor Create(AOwner: TComponent); override;
263 <    procedure ServiceStart; virtual;
264 <    property IsServiceRunning : Boolean read GetIsServiceRunning;
265 <  end;
266 <
267 <  TIBControlAndQueryService = class (TIBControlService)
268 <  private
269 <    FEof: Boolean;
270 <    FAction: Integer;
271 <    procedure SetAction(Value: Integer);
272 <  protected
273 <    property Action: Integer read FAction write SetAction;
274 <  public
275 <    constructor create (AOwner: TComponent); override;
276 <    function GetNextLine : String;
277 <    function GetNextChunk : String;
278 <    property Eof: boolean read FEof;
279 <  published
280 <    property BufferSize;
281 <  end;
282 <
283 <  TShutdownMode = (Forced, DenyTransaction, DenyAttachment);
284 <
285 <  TIBConfigService = class(TIBControlService)
286 <  private
287 <    FDatabaseName: string;
288 <    procedure SetDatabaseName(const Value: string);
289 <  protected
290 <
291 <  public
292 <    procedure ServiceStart; override;
293 <    procedure ShutdownDatabase (Options: TShutdownMode; Wait: Integer);
294 <    procedure SetSweepInterval (Value: Integer);
295 <    procedure SetDBSqlDialect (Value: Integer);
296 <    procedure SetPageBuffers (Value: Integer);
297 <    procedure ActivateShadow;
298 <    procedure BringDatabaseOnline;
299 <    procedure SetReserveSpace (Value: Boolean);
300 <    procedure SetAsyncMode (Value: Boolean);
301 <    procedure SetReadOnly (Value: Boolean);
302 <  published
303 <    property DatabaseName: string read FDatabaseName write SetDatabaseName;
304 <  end;
305 <
306 <  TIBLogService = class(TIBControlAndQueryService)
307 <  private
308 <
309 <  protected
310 <    procedure SetServiceStartOptions; override;
311 <  public
312 <  published
313 <  end;
314 <
315 <  TStatOption = (DataPages, DbLog, HeaderPages, IndexPages, SystemRelations);
316 <  TStatOptions = set of TStatOption;
317 <
318 <  TIBStatisticalService = class(TIBControlAndQueryService)
319 <  private
320 <    FDatabaseName: string;
321 <    FOptions: TStatOptions;
322 <    procedure SetDatabaseName(const Value: string);
323 <  protected
324 <    procedure SetServiceStartOptions; override;
325 <  public
326 <  published
327 <    property DatabaseName: string read FDatabaseName write SetDatabaseName;
328 <    property Options :  TStatOptions read FOptions write FOptions;
329 <  end;
330 <
331 <
332 <  TIBBackupRestoreService = class(TIBControlAndQueryService)
333 <  private
334 <    FVerbose: Boolean;
335 <  protected
336 <  public
337 <  published
338 <    property Verbose : Boolean read FVerbose write FVerbose default False;
339 <  end;
340 <
341 <  TBackupOption = (IgnoreChecksums, IgnoreLimbo, MetadataOnly, NoGarbageCollection,
342 <    OldMetadataDesc, NonTransportable, ConvertExtTables);
343 <  TBackupOptions = set of TBackupOption;
344 <
345 <  TIBBackupService = class (TIBBackupRestoreService)
346 <  private
347 <    FDatabaseName: string;
348 <    FOptions: TBackupOptions;
349 <    FBackupFile: TStrings;
350 <    FBlockingFactor: Integer;
351 <    procedure SetBackupFile(const Value: TStrings);
352 <  protected
353 <    procedure SetServiceStartOptions; override;
354 <  public
355 <    constructor Create(AOwner: TComponent); override;
356 <    destructor Destroy; override;
357 <
358 <  published
359 <    { a name=value pair of filename and length }
360 <    property BackupFile: TStrings read FBackupFile write SetBackupFile;
361 <    property BlockingFactor: Integer read FBlockingFactor write FBlockingFactor;
362 <    property DatabaseName: string read FDatabaseName write FDatabaseName;
363 <    property Options : TBackupOptions read FOptions write FOptions;
364 <  end;
365 <
366 <  TRestoreOption = (DeactivateIndexes, NoShadow, NoValidityCheck, OneRelationAtATime,
367 <    Replace, CreateNewDB, UseAllSpace);
368 <
369 <  TRestoreOptions = set of TRestoreOption;
370 <  TIBRestoreService = class (TIBBackupRestoreService)
371 <  private
372 <    FDatabaseName: TStrings;
373 <    FBackupFile: TStrings;
374 <    FOptions: TRestoreOptions;
375 <    FPageSize: Integer;
376 <    FPageBuffers: Integer;
377 <    procedure SetBackupFile(const Value: TStrings);
378 <    procedure SetDatabaseName(const Value: TStrings);
379 <  protected
380 <    procedure SetServiceStartOptions; override;
381 <  public
382 <    constructor Create(AOwner: TComponent); override;
383 <    destructor Destroy; override;
384 <  published
385 <    { a name=value pair of filename and length }
386 <    property DatabaseName: TStrings read FDatabaseName write SetDatabaseName;
387 <    property BackupFile: TStrings read FBackupFile write SetBackupFile;
388 <    property PageSize: Integer read FPageSize write FPageSize;
389 <    property PageBuffers: Integer read FPageBuffers write FPageBuffers;
390 <    property Options : TRestoreOptions read FOptions write FOptions default [CreateNewDB];
391 <  end;
392 <
393 <  TValidateOption = (LimboTransactions, CheckDB, IgnoreChecksum, KillShadows, MendDB,
394 <    SweepDB, ValidateDB, ValidateFull);
395 <  TValidateOptions = set of TValidateOption;
396 <
397 <  TTransactionGlobalAction = (CommitGlobal, RollbackGlobal, RecoverTwoPhaseGlobal,
398 <                             NoGlobalAction);
399 <  TTransactionState = (LimboState, CommitState, RollbackState, UnknownState);
400 <  TTransactionAdvise = (CommitAdvise, RollbackAdvise, UnknownAdvise);
401 <  TTransactionAction = (CommitAction, RollbackAction);
402 <
403 <  TLimboTransactionInfo = class
404 <  public
405 <    MultiDatabase: Boolean;
406 <    ID: Integer;
407 <    HostSite: String;
408 <    RemoteSite: String;
409 <    RemoteDatabasePath: String;
410 <    State: TTransactionState;
411 <    Advise: TTransactionAdvise;
412 <    Action: TTransactionAction;
413 <  end;
414 <
415 <  TIBValidationService = class(TIBControlAndQueryService)
416 <  private
417 <    FDatabaseName: string;
418 <    FOptions: TValidateOptions;
419 <    FLimboTransactionInfo: array of TLimboTransactionInfo;
420 <    FGlobalAction: TTransactionGlobalAction;
421 <    procedure SetDatabaseName(const Value: string);
422 <    function GetLimboTransactionInfo(index: integer): TLimboTransactionInfo;
423 <    function GetLimboTransactionInfoCount: integer;
424 <
425 <  protected
426 <    procedure SetServiceStartOptions; override;
427 <  public
428 <    constructor Create(AOwner: TComponent); override;
429 <    destructor Destroy; override;
430 <    procedure FetchLimboTransactionInfo;
431 <    procedure FixLimboTransactionErrors;
432 <    property LimboTransactionInfo[Index: integer]: TLimboTransactionInfo read GetLimboTransactionInfo;
433 <    property LimboTransactionInfoCount: Integer read GetLimboTransactionInfoCount;
434 <
435 <  published
436 <    property DatabaseName: string read FDatabaseName write SetDatabaseName;
437 <    property Options: TValidateOptions read FOptions write FOptions;
438 <    property GlobalAction: TTransactionGlobalAction read FGlobalAction
439 <                                         write FGlobalAction;
440 <  end;
441 <
442 <  TUserInfo = class
443 <  public
444 <    UserName: string;
445 <    FirstName: string;
446 <    MiddleName: string;
447 <    LastName: string;
448 <    GroupID: Integer;
449 <    UserID: Integer;
450 <  end;
451 <
452 <  TSecurityAction = (ActionAddUser, ActionDeleteUser, ActionModifyUser, ActionDisplayUser);
453 <  TSecurityModifyParam = (ModifyFirstName, ModifyMiddleName, ModifyLastName, ModifyUserId,
454 <                         ModifyGroupId, ModifyPassword);
455 <  TSecurityModifyParams = set of TSecurityModifyParam;
456 <
457 <  TIBSecurityService = class(TIBControlAndQueryService)
458 <  private
459 <    FUserID: Integer;
460 <    FGroupID: Integer;
461 <    FFirstName: string;
462 <    FUserName: string;
463 <    FPassword: string;
464 <    FSQLRole: string;
465 <    FLastName: string;
466 <    FMiddleName: string;
467 <    FUserInfo: array of TUserInfo;
468 <    FSecurityAction: TSecurityAction;
469 <    FModifyParams: TSecurityModifyParams;
470 <    procedure ClearParams;
471 <    procedure SetSecurityAction (Value: TSecurityAction);
472 <    procedure SetFirstName (Value: String);
473 <    procedure SetMiddleName (Value: String);
474 <    procedure SetLastName (Value: String);
475 <    procedure SetPassword (Value: String);
476 <    procedure SetUserId (Value: Integer);
477 <    procedure SetGroupId (Value: Integer);
478 <
479 <    procedure FetchUserInfo;
480 <    function GetUserInfo(Index: Integer): TUserInfo;
481 <    function GetUserInfoCount: Integer;
482 <
483 <  protected
484 <    procedure Loaded; override;
485 <    procedure SetServiceStartOptions; override;
486 <  public
487 <    constructor Create(AOwner: TComponent); override;
488 <    destructor Destroy; override;
489 <    procedure DisplayUsers;
490 <    procedure DisplayUser(UserName: string);
491 <    procedure AddUser;
492 <    procedure DeleteUser;
493 <    procedure ModifyUser;
494 <    property  UserInfo[Index: Integer]: TUserInfo read GetUserInfo;
495 <    property  UserInfoCount: Integer read GetUserInfoCount;
496 <
497 <  published
498 <    property SecurityAction: TSecurityAction read FSecurityAction
499 <                                             write SetSecurityAction;
500 <    property SQlRole : string read FSQLRole write FSQLrole;
501 <    property UserName : string read FUserName write FUserName;
502 <    property FirstName : string read FFirstName write SetFirstName;
503 <    property MiddleName : string read FMiddleName write SetMiddleName;
504 <    property LastName : string read FLastName write SetLastName;
505 <    property UserID : Integer read FUserID write SetUserID;
506 <    property GroupID : Integer read FGroupID write SetGroupID;
507 <    property Password : string read FPassword write setPassword;
508 <  end;
509 <
510 <
511 < implementation
512 <
513 < uses
514 <  IBIntf , IBSQLMonitor, Math;
515 <
516 < { TIBCustomService }
517 <
518 < procedure TIBCustomService.Attach;
519 < var
520 <  SPB: String;
521 <  ConnectString: String;
522 < begin
523 <  CheckInactive;
524 <  CheckServerName;
525 <
526 <  if FLoginPrompt and not Login then
527 <    IBError(ibxeOperationCancelled, [nil]);
528 <
529 <  { Generate a new SPB if necessary }
530 <  if FParamsChanged then
531 <  begin
532 <    FParamsChanged := False;
533 <    GenerateSPB(FParams, SPB, FSPBLength);
534 <    IBAlloc(FSPB, 0, FsPBLength);
535 <    Move(SPB[1], FSPB[0], FSPBLength);
536 <  end;
537 <  case FProtocol of
538 <    TCP: ConnectString := FServerName + ':service_mgr'; {do not localize}
539 <    SPX: ConnectString := FServerName + '@service_mgr'; {do not localize}
540 <    NamedPipe: ConnectString := '\\' + FServerName + '\service_mgr'; {do not localize}
541 <    Local: ConnectString := 'service_mgr'; {do not localize}
542 <  end;
543 <  if call(isc_service_attach(StatusVector, Length(ConnectString),
544 <                         PChar(ConnectString), @FHandle,
545 <                         FSPBLength, FSPB), False) > 0 then
546 <  begin
547 <    FHandle := nil;
548 <    IBDataBaseError;
549 <  end;
550 <
551 <  if Assigned(FOnAttach) then
552 <    FOnAttach(Self);
553 <
554 <  MonitorHook.ServiceAttach(Self);
555 < end;
556 <
557 < procedure TIBCustomService.Loaded;
558 < begin
559 <  inherited Loaded;
560 <  try
561 <    if FStreamedActive and (not Active) then
562 <      Attach;
563 <  except
564 <    if csDesigning in ComponentState then
565 <      Application.HandleException(Self)
566 <    else
567 <      raise;
568 <  end;
569 < end;
570 <
571 < function TIBCustomService.Login: Boolean;
572 < var
573 <  IndexOfUser, IndexOfPassword: Integer;
574 <  Username, Password: String;
575 <  LoginParams: TStrings;
576 < begin
577 <  if Assigned(FOnLogin) then begin
578 <    result := True;
579 <    LoginParams := TStringList.Create;
580 <    try
581 <      LoginParams.Assign(Params);
582 <      FOnLogin(Self, LoginParams);
583 <      Params.Assign (LoginParams);
584 <    finally
585 <      LoginParams.Free;
586 <    end;
587 <  end
588 <  else begin
589 <    IndexOfUser := IndexOfSPBConst(SPBConstantNames[isc_spb_user_name]);
590 <    if IndexOfUser <> -1 then
591 <      Username := Copy(Params[IndexOfUser],
592 <                                         Pos('=', Params[IndexOfUser]) + 1, {mbcs ok}
593 <                                         Length(Params[IndexOfUser]));
594 <    IndexOfPassword := IndexOfSPBConst(SPBConstantNames[isc_spb_password]);
595 <    if IndexOfPassword <> -1 then
596 <      Password := Copy(Params[IndexOfPassword],
597 <                                         Pos('=', Params[IndexOfPassword]) + 1, {mbcs ok}
598 <                                         Length(Params[IndexOfPassword]));
599 <    result := ServerLoginDialog(serverName, Username, Password);
600 <    if result then
601 <    begin
602 <      IndexOfPassword := IndexOfSPBConst(SPBConstantNames[isc_spb_password]);
603 <      if IndexOfUser = -1 then
604 <        Params.Add(SPBConstantNames[isc_spb_user_name] + '=' + Username)
605 <      else
606 <        Params[IndexOfUser] := SPBConstantNames[isc_spb_user_name] +
607 <                                 '=' + Username;
608 <      if IndexOfPassword = -1 then
609 <        Params.Add(SPBConstantNames[isc_spb_password] + '=' + Password)
610 <      else
611 <        Params[IndexOfPassword] := SPBConstantNames[isc_spb_password] +
612 <                                     '=' + Password;
613 <    end;
614 <  end;
615 < end;
616 <
617 < procedure TIBCustomService.CheckActive;
618 < begin
619 <  if FStreamedActive and (not Active) then
620 <    Loaded;
621 <  if FHandle = nil then
622 <    IBError(ibxeServiceActive, [nil]);
623 < end;
624 <
625 < procedure TIBCustomService.CheckInactive;
626 < begin
627 <  if FHandle <> nil then
628 <    IBError(ibxeServiceInActive, [nil]);
629 < end;
630 <
631 < constructor TIBCustomService.Create(AOwner: TComponent);
632 < begin
633 <  inherited Create(AOwner);
634 <  FIBLoaded := False;
635 <  CheckIBLoaded;
636 <  FIBLoaded := True;
637 <  FserverName := '';
638 <  FParams := TStringList.Create;
639 <  FParamsChanged := True;
640 <  TStringList(FParams).OnChange := ParamsChange;
641 <  TStringList(FParams).OnChanging := ParamsChanging;
642 <  FSPB := nil;
643 <  FQuerySPB := nil;
644 <  FBufferSize := DefaultBufferSize;
645 <  FHandle := nil;
646 <  FLoginPrompt := True;
647 <  FTraceFlags := [];
648 <  FOutputbuffer := nil;
649 <  FProtocol := Local;
650 < end;
651 <
652 < destructor TIBCustomService.Destroy;
653 < begin
654 <  if FIBLoaded then
655 <  begin
656 <    if FHandle <> nil then
657 <      Detach;
658 <    FreeMem(FSPB);
659 <    FSPB := nil;
660 <    FParams.Free;
661 <  end;
662 <  ReallocMem(FOutputBuffer, 0);
663 <  inherited Destroy;
664 < end;
665 <
666 < procedure TIBCustomService.Detach;
667 < begin
668 <  CheckActive;
669 <  if (Call(isc_service_detach(StatusVector, @FHandle), False) > 0) then
670 <  begin
671 <    FHandle := nil;
672 <    IBDataBaseError;
673 <  end
674 <  else
675 <    FHandle := nil;
676 <  MonitorHook.ServiceDetach(Self);
677 < end;
678 <
679 < function TIBCustomService.GetActive: Boolean;
680 < begin
681 <  result := FHandle <> nil;
682 < end;
683 <
684 < function TIBCustomService.GetServiceParamBySPB(const Idx: Integer): String;
685 < var
686 <  ConstIdx, EqualsIdx: Integer;
687 < begin
688 <  if (Idx > 0) and (Idx <= isc_spb_last_spb_constant) then
689 <  begin
690 <    ConstIdx := IndexOfSPBConst(SPBConstantNames[Idx]);
691 <    if ConstIdx = -1 then
692 <      result := ''
693 <    else
694 <    begin
695 <      result := Params[ConstIdx];
696 <      EqualsIdx := Pos('=', result); {mbcs ok}
697 <      if EqualsIdx = 0 then
698 <        result := ''
699 <      else
700 <        result := Copy(result, EqualsIdx + 1, Length(result));
701 <    end;
702 <  end
703 <  else
704 <    result := '';
705 < end;
706 <
707 < procedure TIBCustomService.InternalServiceQuery;
708 < begin
709 <  FQuerySPBLength := Length(FQueryParams);
710 <  if FQuerySPBLength = 0 then
711 <    IBError(ibxeQueryParamsError, [nil]);
712 <  IBAlloc(FQuerySPB, 0, FQuerySPBLength);
713 <  Move(FQueryParams[1], FQuerySPB[0], FQuerySPBLength);
714 <  if (FOutputBuffer = nil) then
715 <    IBAlloc(FOutputBuffer, 0, FBufferSize);
716 <  try
717 <    if call(isc_service_query(StatusVector, @FHandle, nil, 0, nil,
718 <                           FQuerySPBLength, FQuerySPB,
719 <                           FBufferSize, FOutputBuffer), False) > 0 then
720 <    begin
721 <      FHandle := nil;
722 <      IBDataBaseError;
723 <    end;
724 <  finally
725 <    FreeMem(FQuerySPB);
726 <    FQuerySPB := nil;
727 <    FQuerySPBLength := 0;
728 <    FQueryParams := '';
729 <  end;
730 <  MonitorHook.ServiceQuery(Self);
731 < end;
732 <
733 < procedure TIBCustomService.SetActive(const Value: Boolean);
734 < begin
735 <  if csReading in ComponentState then
736 <    FStreamedActive := Value
737 <  else
738 <    if Value <> Active then  
739 <      if Value then
740 <        Attach
741 <      else
742 <        Detach;
743 < end;
744 <
745 < procedure TIBCustomService.SetBufferSize(const Value: Integer);
746 < begin
747 <  if (FOutputBuffer <> nil) and (Value <> FBufferSize) then
748 <    IBAlloc(FOutputBuffer, 0, FBufferSize);
749 < end;
750 <
751 < procedure TIBCustomService.SetParams(const Value: TStrings);
752 < begin
753 <  FParams.Assign(Value);
754 < end;
755 <
756 < procedure TIBCustomService.SetServerName(const Value: string);
757 < begin
758 <  if FServerName <> Value then
759 <  begin
760 <    CheckInactive;
761 <    FServerName := Value;
762 <  end;
763 < end;
764 <
765 < procedure TIBCustomService.SetProtocol(const Value: TProtocol);
766 < begin
767 <  if FProtocol <> Value then
768 <  begin
769 <    CheckInactive;
770 <    FProtocol := Value;
771 <    if (Value = Local) then
772 <      FServerName := '';
773 <  end;
774 < end;
775 <
776 < procedure TIBCustomService.SetServiceParamBySPB(const Idx: Integer;
777 <  const Value: String);
778 < var
779 <  ConstIdx: Integer;
780 < begin
781 <  ConstIdx := IndexOfSPBConst(SPBConstantNames[Idx]);
782 <  if (Value = '') then
783 <  begin
784 <    if ConstIdx <> -1 then
785 <      Params.Delete(ConstIdx);
786 <  end
787 <  else
788 <  begin
789 <    if (ConstIdx = -1) then
790 <      Params.Add(SPBConstantNames[Idx] + '=' + Value)
791 <    else
792 <      Params[ConstIdx] := SPBConstantNames[Idx] + '=' + Value;
793 <  end;
794 < end;
795 <
796 < function TIBCustomService.IndexOfSPBConst(st: String): Integer;
797 < var
798 <  i, pos_of_str: Integer;
799 < begin
800 <  result := -1;
801 <  for i := 0 to Params.Count - 1 do
802 <  begin
803 <    pos_of_str := Pos(st, Params[i]); {mbcs ok}
804 <    if (pos_of_str = 1) or (pos_of_str = Length(SPBPrefix) + 1) then
805 <    begin
806 <      result := i;
807 <      break;
808 <    end;
809 <  end;
810 < end;
811 <
812 < procedure TIBCustomService.ParamsChange(Sender: TObject);
813 < begin
814 <  FParamsChanged := True;
815 < end;
816 <
817 < procedure TIBCustomService.ParamsChanging(Sender: TObject);
818 < begin
819 <  CheckInactive;
820 < end;
821 <
822 < procedure TIBCustomService.CheckServerName;
823 < begin
824 <  if (FServerName = '') and (FProtocol <> Local) then
825 <    IBError(ibxeServerNameMissing, [nil]);
826 < end;
827 <
828 < function TIBCustomService.Call(ErrCode: ISC_STATUS;
829 <  RaiseError: Boolean): ISC_STATUS;
830 < begin
831 <  result := ErrCode;
832 <  if RaiseError and (ErrCode > 0) then
833 <    IBDataBaseError;
834 < end;
835 <
836 < function TIBCustomService.ParseString(var RunLen: Integer): string;
837 < var
838 <  Len: UShort;
839 <  tmp: Char;
840 < begin
841 <  Len := isc_vax_integer(OutputBuffer + RunLen, 2);
842 <  RunLen := RunLen + 2;
843 <  if (Len <> 0) then
844 <  begin
845 <    tmp := OutputBuffer[RunLen + Len];
846 <    OutputBuffer[RunLen + Len] := #0;
847 <    result := String(PChar(@OutputBuffer[RunLen]));
848 <    OutputBuffer[RunLen + Len] := tmp;
849 <    RunLen := RunLen + Len;
850 <  end
851 <  else
852 <    result := '';
853 < end;
854 <
855 < function TIBCustomService.ParseInteger(var RunLen: Integer): Integer;
856 < begin
857 <  result := isc_vax_integer(OutputBuffer + RunLen, 4);
858 <  RunLen := RunLen + 4;
859 < end;
860 <
861 < {
862 < * GenerateSPB -
863 < *  Given a string containing a textual representation
864 < *  of the Service parameters, generate a service
865 < *  parameter buffer, and return it and its length
866 < *  in SPB and SPBLength, respectively.
867 < }
868 < procedure TIBCustomService.GenerateSPB(sl: TStrings; var SPB: String;
869 <  var SPBLength: Short);
870 < var
871 <  i, j, SPBVal, SPBServerVal: UShort;
872 <  param_name, param_value: String;
873 < begin
874 <  { The SPB is initially empty, with the exception that
875 <   the SPB version must be the first byte of the string.
876 <  }
877 <  SPBLength := 2;
878 <  SPB := Char(isc_spb_version);
879 <  SPB := SPB + Char(isc_spb_current_version);
880 <  { Iterate through the textual service parameters, constructing
881 <   a SPB on-the-fly }
882 <  if sl.Count > 0 then
883 <  for i := 0 to sl.Count - 1 do
884 <  begin
885 <   { Get the parameter's name and value from the list,
886 <     and make sure that the name is all lowercase with
887 <     no leading 'isc_spb_' prefix }
888 <    if (Trim(sl.Names[i]) = '') then continue;
889 <    param_name := LowerCase(sl.Names[i]); {mbcs ok}
890 <    param_value := Copy(sl[i], Pos('=', sl[i]) + 1, Length(sl[i])); {mbcs ok}
891 <    if (Pos(SPBPrefix, param_name) = 1) then {mbcs ok}
892 <      Delete(param_name, 1, Length(SPBPrefix));
893 <    { We want to translate the parameter name to some integer
894 <      value. We do this by scanning through a list of known
895 <      service parameter names (SPBConstantNames, defined above). }
896 <    SPBVal := 0;
897 <    SPBServerVal := 0;
898 <    { Find the parameter }
899 <    for j := 1 to isc_spb_last_spb_constant do
900 <      if (param_name = SPBConstantNames[j]) then
901 <      begin
902 <        SPBVal := j;
903 <        SPBServerVal := SPBConstantValues[j];
904 <        break;
905 <      end;
906 <    case SPBVal of
907 <      isc_spb_user_name, isc_spb_password:
908 <      begin
909 <        SPB := SPB +
910 <               Char(SPBServerVal) +
911 <               Char(Length(param_value)) +
912 <               param_value;
913 <        Inc(SPBLength, 2 + Length(param_value));
914 <      end;
915 <      else
916 <      begin
917 <        if (SPBVal > 0) and
918 <           (SPBVal <= isc_dpb_last_dpb_constant) then
919 <          IBError(ibxeSPBConstantNotSupported,
920 <                   [SPBConstantNames[SPBVal]])
921 <        else
922 <          IBError(ibxeSPBConstantUnknown, [SPBVal]);
923 <      end;
924 <    end;
925 <  end;
926 < end;
927 <
928 < { TIBServerProperties }
929 < constructor TIBServerProperties.Create(AOwner: TComponent);
930 < begin
931 <  inherited Create(AOwner);
932 <  FDatabaseInfo := TDatabaseInfo.Create;
933 <  FLicenseInfo := TLicenseInfo.Create;
934 <  FLicenseMaskInfo := TLicenseMaskInfo.Create;
935 <  FVersionInfo := TVersionInfo.Create;
936 <  FConfigParams := TConfigParams.Create;
937 < end;
938 <
939 < destructor TIBServerProperties.Destroy;
940 < begin
941 <  FDatabaseInfo.Free;
942 <  FLicenseInfo.Free;
943 <  FLicenseMaskInfo.Free;
944 <  FVersionInfo.Free;
945 <  FConfigParams.Free;
946 <  inherited Destroy;
947 < end;
948 <
949 < procedure TIBServerProperties.ParseConfigFileData(var RunLen: Integer);
950 < begin
951 <  Inc(RunLen);
952 <  with FConfigParams.ConfigFileData do
953 <  begin
954 <    SetLength (ConfigFileValue, Length(ConfigFileValue)+1);
955 <    SetLength (ConfigFileKey, Length(ConfigFileKey)+1);
956 <
957 <    ConfigFileKey[High(ConfigFileKey)] := Integer(OutputBuffer[RunLen-1]);
958 <    ConfigFileValue[High(ConfigFileValue)] := ParseInteger(RunLen);
959 <  end;
960 < end;
961 <
962 < procedure TIBServerProperties.Fetch;
963 < begin
964 <  if (Database in Options) then
965 <    FetchDatabaseInfo;
966 <  if (License in Options) then
967 <    FetchLicenseInfo;
968 <  if (LicenseMask in Options) then
969 <    FetchLicenseMaskInfo;
970 <  if (ConfigParameters in Options) then
971 <    FetchConfigParams;
972 <  if (Version in Options) then
973 <    FetchVersionInfo;
974 < end;
975 <
976 < procedure TIBServerProperties.FetchConfigParams;
977 < var
978 <  RunLen: Integer;
979 <
980 < begin
981 <  ServiceQueryParams := Char(isc_info_svc_get_config) +
982 <                        Char(isc_info_svc_get_env) +
983 <                        Char(isc_info_svc_get_env_lock) +
984 <                        Char(isc_info_svc_get_env_msg) +
985 <                        Char(isc_info_svc_user_dbpath);
986 <
987 <  InternalServiceQuery;
988 <  RunLen := 0;
989 <  While (not (Integer(OutputBuffer[RunLen]) = isc_info_end)) do
990 <  begin
991 <    case Integer(OutputBuffer[RunLen]) of
992 <      isc_info_svc_get_config:
993 <      begin
994 <        FConfigParams.ConfigFileData.ConfigFileKey := nil;
995 <        FConfigParams.ConfigFileData.ConfigFileValue := nil;
996 <        Inc (RunLen);
997 <        while (not (Integer(OutputBuffer[RunLen]) = isc_info_flag_end)) do
998 <          ParseConfigFileData (RunLen);
999 <        if (Integer(OutputBuffer[RunLen]) = isc_info_flag_end) then
1000 <          Inc (RunLen);
1001 <      end;
1002 <
1003 <      isc_info_svc_get_env:
1004 <      begin
1005 <        Inc (RunLen);
1006 <        FConfigParams.BaseLocation := ParseString(RunLen);
1007 <      end;
1008 <
1009 <      isc_info_svc_get_env_lock:
1010 <      begin
1011 <        Inc (RunLen);
1012 <        FConfigParams.LockFileLocation := ParseString(RunLen);
1013 <      end;
1014 <
1015 <      isc_info_svc_get_env_msg:
1016 <      begin
1017 <        Inc (RunLen);
1018 <        FConfigParams.MessageFileLocation := ParseString(RunLen);
1019 <      end;
1020 <
1021 <      isc_info_svc_user_dbpath:
1022 <      begin
1023 <        Inc (RunLen);
1024 <        FConfigParams.SecurityDatabaseLocation := ParseString(RunLen);
1025 <      end;
1026 <      else
1027 <        IBError(ibxeOutputParsingError, [nil]);
1028 <    end;
1029 <  end;
1030 < end;
1031 <
1032 < procedure TIBServerProperties.FetchDatabaseInfo;
1033 < var
1034 <  i, RunLen: Integer;
1035 < begin
1036 <  ServiceQueryParams := Char(isc_info_svc_svr_db_info);
1037 <  InternalServiceQuery;
1038 <  if (OutputBuffer[0] <> Char(isc_info_svc_svr_db_info)) then
1039 <      IBError(ibxeOutputParsingError, [nil]);
1040 <  RunLen := 1;
1041 <  if (OutputBuffer[RunLen] <> Char(isc_spb_num_att)) then
1042 <      IBError(ibxeOutputParsingError, [nil]);
1043 <  Inc(RunLen);
1044 <  FDatabaseInfo.NoOfAttachments := ParseInteger(RunLen);
1045 <  if (OutputBuffer[RunLen] <> Char(isc_spb_num_db)) then
1046 <      IBError(ibxeOutputParsingError, [nil]);
1047 <  Inc(RunLen);
1048 <  FDatabaseInfo.NoOfDatabases := ParseInteger(RunLen);
1049 <  FDatabaseInfo.DbName := nil;
1050 <  SetLength(FDatabaseInfo.DbName, FDatabaseInfo.NoOfDatabases);
1051 <  i := 0;
1052 <  while (OutputBuffer[RunLen] <> Char(isc_info_flag_end)) do
1053 <  begin
1054 <    if (OutputBuffer[RunLen] <> Char(SPBConstantValues[isc_spb_dbname])) then
1055 <      IBError(ibxeOutputParsingError, [nil]);
1056 <    Inc(RunLen);
1057 <    FDatabaseInfo.DbName[i] := ParseString(RunLen);
1058 <    Inc (i);
1059 <  end;
1060 < end;
1061 <
1062 < procedure TIBServerProperties.FetchLicenseInfo;
1063 < var
1064 <  i, RunLen: Integer;
1065 <  done: Integer;
1066 < begin
1067 <  ServiceQueryParams := Char(isc_info_svc_get_license) +
1068 <                        Char(isc_info_svc_get_licensed_users);
1069 <  InternalServiceQuery;
1070 <  RunLen := 0;
1071 <  done := 0;
1072 <  i := 0;
1073 <  FLicenseInfo.key := nil;
1074 <  FLicenseInfo.id := nil;
1075 <  FLicenseInfo.desc := nil;
1076 <
1077 <  While done < 2 do begin
1078 <    Inc(Done);
1079 <    Inc(RunLen);
1080 <    case Integer(OutputBuffer[RunLen-1]) of
1081 <      isc_info_svc_get_license:
1082 <      begin
1083 <        while (OutputBuffer[RunLen] <> Char(isc_info_flag_end)) do
1084 <        begin
1085 <          if (i >= Length(FLicenseInfo.key)) then
1086 <          begin
1087 <            SetLength(FLicenseInfo.key, i + 10);
1088 <            SetLength(FLicenseInfo.id, i + 10);
1089 <            SetLength(FLicenseInfo.desc, i + 10);
1090 <          end;
1091 <          if (OutputBuffer[RunLen] <> Char(isc_spb_lic_id)) then
1092 <              IBError(ibxeOutputParsingError, [nil]);
1093 <          Inc(RunLen);
1094 <          FLicenseInfo.id[i] := ParseString(RunLen);
1095 <          if (OutputBuffer[RunLen] <> Char(isc_spb_lic_key)) then
1096 <              IBError(ibxeOutputParsingError, [nil]);
1097 <          Inc(RunLen);
1098 <          FLicenseInfo.key[i] := ParseString(RunLen);
1099 <          if (OutputBuffer[RunLen] <> Char(7)) then
1100 <              IBError(ibxeOutputParsingError, [nil]);
1101 <          Inc(RunLen);
1102 <          FLicenseInfo.desc[i] := ParseString(RunLen);
1103 <          Inc(i);
1104 <        end;
1105 <        Inc(RunLen);
1106 <        if (Length(FLicenseInfo.key) > i) then
1107 <        begin
1108 <          SetLength(FLicenseInfo.key, i);
1109 <          SetLength(FLicenseInfo.id, i);
1110 <          SetLength(FLicenseInfo.desc, i);
1111 <        end;
1112 <      end;
1113 <      isc_info_svc_get_licensed_users:
1114 <        FLicenseInfo.LicensedUsers := ParseInteger(RunLen);
1115 <      else
1116 <        IBError(ibxeOutputParsingError, [nil]);
1117 <    end;
1118 <  end;
1119 < end;
1120 <
1121 < procedure TIBServerProperties.FetchLicenseMaskInfo();
1122 < var
1123 <  done,RunLen:integer;
1124 < begin
1125 <  ServiceQueryParams := Char(isc_info_svc_get_license_mask) +
1126 <                        Char(isc_info_svc_capabilities);
1127 <  InternalServiceQuery;
1128 <  RunLen := 0;
1129 <  done := 0;
1130 <  While done <= 1 do
1131 <  begin
1132 <    Inc(done);
1133 <    Inc(RunLen);
1134 <    case Integer(OutputBuffer[RunLen-1]) of
1135 <      isc_info_svc_get_license_mask:
1136 <        FLicenseMaskInfo.LicenseMask := ParseInteger(RunLen);
1137 <      isc_info_svc_capabilities:
1138 <        FLicenseMaskInfo.CapabilityMask := ParseInteger(RunLen);
1139 <      else
1140 <        IBError(ibxeOutputParsingError, [nil]);
1141 <    end;
1142 <  end;
1143 < end;
1144 <
1145 <
1146 < procedure TIBServerProperties.FetchVersionInfo;
1147 < var
1148 <  RunLen: Integer;
1149 <  done: Integer;
1150 < begin
1151 <  ServiceQueryParams := Char(isc_info_svc_version) +
1152 <                        Char(isc_info_svc_server_version) +
1153 <                        Char(isc_info_svc_implementation);
1154 <  InternalServiceQuery;
1155 <  RunLen := 0;
1156 <  done := 0;
1157 <
1158 <  While done <= 2 do
1159 <  begin
1160 <    Inc(done);
1161 <    Inc(RunLen);
1162 <    case Integer(OutputBuffer[RunLen-1]) of
1163 <      isc_info_svc_version:
1164 <        FVersionInfo.ServiceVersion := ParseInteger(RunLen);
1165 <      isc_info_svc_server_version:
1166 <        FVersionInfo.ServerVersion := ParseString(RunLen);
1167 <      isc_info_svc_implementation:
1168 <        FVersionInfo.ServerImplementation := ParseString(RunLen);
1169 <      else
1170 <        IBError(ibxeOutputParsingError, [nil]);
1171 <    end;
1172 <  end;
1173 < end;
1174 <
1175 < { TIBControlService }
1176 < procedure TIBControlService.SetServiceStartOptions;
1177 < begin
1178 <
1179 < end;
1180 <
1181 < function TIBControlService.GetIsServiceRunning: Boolean;
1182 < var
1183 <  RunLen: Integer;
1184 < begin
1185 <  ServiceQueryParams := Char(isc_info_svc_running);
1186 <  InternalServiceQuery;
1187 <  if (OutputBuffer[0] <> Char(isc_info_svc_running)) then
1188 <    IBError(ibxeOutputParsingError, [nil]);
1189 <  RunLen := 1;
1190 <  if (ParseInteger(RunLen) = 1) then
1191 <    result := True
1192 <  else
1193 <    result := False;
1194 < end;
1195 <
1196 < procedure TIBControlService.ServiceStartAddParam (Value: string; param: Integer);
1197 < var
1198 <  Len: UShort;
1199 < begin
1200 <  Len := Length(Value);
1201 <  if Len > 0 then
1202 <  begin
1203 <    FStartParams  := FStartParams +
1204 <                     Char(Param) +
1205 <                     PChar(@Len)[0] +
1206 <                     PChar(@Len)[1] +
1207 <                     Value;
1208 <  end;
1209 < end;
1210 <
1211 < procedure TIBControlService.ServiceStartAddParam (Value: Integer; param: Integer);
1212 < begin
1213 <  FStartParams  := FStartParams +
1214 <                   Char(Param) +
1215 <                   PChar(@Value)[0] +
1216 <                   PChar(@Value)[1] +
1217 <                   PChar(@Value)[2] +
1218 <                   PChar(@Value)[3];
1219 < end;
1220 <
1221 < constructor TIBControlService.Create(AOwner: TComponent);
1222 < begin
1223 <  inherited create(AOwner);
1224 <  FStartParams := '';
1225 <  FStartSPB := nil;
1226 <  FStartSPBLength := 0;
1227 < end;
1228 <
1229 < procedure TIBControlService.InternalServiceStart;
1230 < begin
1231 <  FStartSPBLength := Length(FStartParams);
1232 <  if FStartSPBLength = 0 then
1233 <    IBError(ibxeStartParamsError, [nil]);
1234 <  IBAlloc(FStartSPB, 0, FStartSPBLength);
1235 <  Move(FStartParams[1], FStartSPB[0], FstartSPBLength);
1236 <  try
1237 <    if call(isc_service_start(StatusVector, @FHandle, nil,
1238 <                           FStartSPBLength, FStartSPB), False) > 0 then
1239 <    begin
1240 <      FHandle := nil;
1241 <      IBDataBaseError;
1242 <    end;
1243 <  finally
1244 <    FreeMem(FStartSPB);
1245 <    FStartSPB := nil;
1246 <    FStartSPBLength := 0;
1247 <    FStartParams := '';
1248 <  end;
1249 <  MonitorHook.ServiceStart(Self);
1250 < end;
1251 <
1252 < procedure TIBControlService.ServiceStart;
1253 < begin
1254 <  CheckActive;
1255 <  SetServiceStartOptions;
1256 <  InternalServiceStart;
1257 < end;
1258 <
1259 < { TIBConfigService }
1260 <
1261 < procedure TIBConfigService.ServiceStart;
1262 < begin
1263 <  IBError(ibxeUseSpecificProcedures, [nil]);
1264 < end;
1265 <
1266 < procedure TIBConfigService.ActivateShadow;
1267 < begin
1268 <  ServiceStartParams  := Char(isc_action_svc_properties);
1269 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1270 <  ServiceStartAddParam (isc_spb_prp_activate, SPBConstantValues[isc_spb_options]);
1271 <  InternalServiceStart;
1272 < end;
1273 <
1274 < procedure TIBConfigService.BringDatabaseOnline;
1275 < begin
1276 <  ServiceStartParams  := Char(isc_action_svc_properties);
1277 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1278 <  ServiceStartAddParam (isc_spb_prp_db_online, SPBConstantValues[isc_spb_options]);
1279 <  InternalServiceStart;
1280 < end;
1281 <
1282 < procedure TIBConfigService.SetAsyncMode(Value: Boolean);
1283 < begin
1284 <  ServiceStartParams  := Char(isc_action_svc_properties);
1285 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1286 <  ServiceStartParams := ServiceStartParams +
1287 <                        Char(isc_spb_prp_write_mode);
1288 <  if Value then
1289 <    ServiceStartParams  := ServiceStartParams +
1290 <                           Char(isc_spb_prp_wm_async)
1291 <  else
1292 <    ServiceStartParams  := ServiceStartParams +
1293 <                           Char(isc_spb_prp_wm_sync);
1294 <  InternalServiceStart;
1295 < end;
1296 <
1297 < procedure TIBConfigService.SetDatabaseName(const Value: string);
1298 < begin
1299 <  FDatabaseName := Value;
1300 < end;
1301 <
1302 < procedure TIBConfigService.SetPageBuffers(Value: Integer);
1303 < begin
1304 <  ServiceStartParams  := Char(isc_action_svc_properties);
1305 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1306 <  ServiceStartAddParam (Value, isc_spb_prp_page_buffers);
1307 <  InternalServiceStart;
1308 < end;
1309 <
1310 < procedure TIBConfigService.SetReadOnly(Value: Boolean);
1311 < begin
1312 <  ServiceStartParams  := Char(isc_action_svc_properties);
1313 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1314 <  ServiceStartParams := ServiceStartParams +
1315 <                         Char(isc_spb_prp_access_mode);
1316 <  if Value then
1317 <    ServiceStartParams  := ServiceStartParams +
1318 <                           Char(isc_spb_prp_am_readonly)
1319 <  else
1320 <    ServiceStartParams  := ServiceStartParams +
1321 <                           Char(isc_spb_prp_am_readwrite);
1322 <  InternalServiceStart;
1323 < end;
1324 <
1325 < procedure TIBConfigService.SetReserveSpace(Value: Boolean);
1326 < begin
1327 <  ServiceStartParams  := Char(isc_action_svc_properties);
1328 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1329 <  ServiceStartParams := ServiceStartParams +
1330 <                        Char(isc_spb_prp_reserve_space);
1331 <  if Value then
1332 <    ServiceStartParams  := ServiceStartParams +
1333 <                           Char(isc_spb_prp_res)
1334 <  else
1335 <    ServiceStartParams  := ServiceStartParams +
1336 <                           Char(isc_spb_prp_res_use_full);
1337 <  InternalServiceStart;
1338 < end;
1339 <
1340 < procedure TIBConfigService.SetSweepInterval(Value: Integer);
1341 < begin
1342 <  ServiceStartParams  := Char(isc_action_svc_properties);
1343 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1344 <  ServiceStartAddParam (Value, isc_spb_prp_sweep_interval);
1345 <  InternalServiceStart;
1346 < end;
1347 <
1348 < procedure TIBConfigService.SetDBSqlDialect(Value: Integer);
1349 < begin
1350 <  ServiceStartParams  := Char(isc_action_svc_properties);
1351 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1352 <  ServiceStartAddParam (Value, isc_spb_prp_set_sql_dialect);
1353 <  InternalServiceStart;
1354 < end;
1355 <
1356 < procedure TIBConfigService.ShutdownDatabase(Options: TShutdownMode;
1357 <  Wait: Integer);
1358 < begin
1359 <  ServiceStartParams  := Char(isc_action_svc_properties);
1360 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1361 <  if (Options = Forced) then
1362 <    ServiceStartAddParam (Wait, isc_spb_prp_shutdown_db)
1363 <  else if (Options = DenyTransaction) then
1364 <    ServiceStartAddParam (Wait, isc_spb_prp_deny_new_transactions)
1365 <  else
1366 <    ServiceStartAddParam (Wait, isc_spb_prp_deny_new_attachments);
1367 <  InternalServiceStart;
1368 < end;
1369 <
1370 < { TIBStatisticalService }
1371 <
1372 < procedure TIBStatisticalService.SetDatabaseName(const Value: string);
1373 < begin
1374 <  FDatabaseName := Value;
1375 < end;
1376 <
1377 < procedure TIBStatisticalService.SetServiceStartOptions;
1378 < var
1379 <  param: Integer;
1380 < begin
1381 <  if FDatabaseName = '' then
1382 <    IBError(ibxeStartParamsError, [nil]);
1383 <  param := 0;
1384 <  if (DataPages in Options) then
1385 <    param := param or isc_spb_sts_data_pages;
1386 <  if (DbLog in Options) then
1387 <    param := param or isc_spb_sts_db_log;
1388 <  if (HeaderPages in Options) then
1389 <    param := param or isc_spb_sts_hdr_pages;
1390 <  if (IndexPages in Options) then
1391 <    param := param or isc_spb_sts_idx_pages;
1392 <  if (SystemRelations in Options) then
1393 <    param := param or isc_spb_sts_sys_relations;
1394 <  Action := isc_action_svc_db_stats;
1395 <  ServiceStartParams  := Char(isc_action_svc_db_stats);
1396 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1397 <  ServiceStartAddParam (param, SPBConstantValues[isc_spb_options]);
1398 < end;
1399 <
1400 < { TIBBackupService }
1401 < procedure TIBBackupService.SetServiceStartOptions;
1402 < var
1403 <  param, i: Integer;
1404 <  value: String;
1405 < begin
1406 <  if FDatabaseName = '' then
1407 <    IBError(ibxeStartParamsError, [nil]);
1408 <  param := 0;
1409 <  if (IgnoreChecksums in Options) then
1410 <    param := param or isc_spb_bkp_ignore_checksums;
1411 <  if (IgnoreLimbo in Options) then
1412 <    param := param or isc_spb_bkp_ignore_limbo;
1413 <  if (MetadataOnly in Options) then
1414 <    param := param or isc_spb_bkp_metadata_only;
1415 <  if (NoGarbageCollection in Options) then
1416 <    param := param or isc_spb_bkp_no_garbage_collect;
1417 <  if (OldMetadataDesc in Options) then
1418 <    param := param or isc_spb_bkp_old_descriptions;
1419 <  if (NonTransportable in Options) then
1420 <    param := param or isc_spb_bkp_non_transportable;
1421 <  if (ConvertExtTables in Options) then
1422 <    param := param or isc_spb_bkp_convert;
1423 <  Action := isc_action_svc_backup;
1424 <  ServiceStartParams  := Char(isc_action_svc_backup);
1425 <  ServiceStartAddParam(FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1426 <  ServiceStartAddParam(param, SPBConstantValues[isc_spb_options]);
1427 <  if Verbose then
1428 <    ServiceStartParams := ServiceStartParams + Char(SPBConstantValues[isc_spb_verbose]);
1429 <  if FBlockingFactor > 0 then
1430 <    ServiceStartAddParam(FBlockingFactor, isc_spb_bkp_factor);
1431 <  for i := 0 to FBackupFile.Count - 1 do
1432 <  begin
1433 <    if (Trim(FBackupFile[i]) = '') then
1434 <      continue;
1435 <    if (Pos('=', FBackupFile[i]) <> 0) then
1436 <    begin {mbcs ok}
1437 <      ServiceStartAddParam(FBackupFile.Names[i], isc_spb_bkp_file);
1438 <      value := Copy(FBackupFile[i], Pos('=', FBackupFile[i]) + 1, Length(FBackupFile.Names[i])); {mbcs ok}
1439 <      param := StrToInt(value);
1440 <      ServiceStartAddParam(param, isc_spb_bkp_length);
1441 <    end
1442 <    else
1443 <      ServiceStartAddParam(FBackupFile[i], isc_spb_bkp_file);
1444 <  end;
1445 < end;
1446 <
1447 < constructor TIBBackupService.Create(AOwner: TComponent);
1448 < begin
1449 <  inherited Create(AOwner);
1450 <  FBackupFile := TStringList.Create;
1451 < end;
1452 <
1453 < destructor TIBBackupService.Destroy;
1454 < begin
1455 <  FBackupFile.Free;
1456 <  inherited Destroy;
1457 < end;
1458 <
1459 < procedure TIBBackupService.SetBackupFile(const Value: TStrings);
1460 < begin
1461 <  FBackupFile.Assign(Value);
1462 < end;
1463 <
1464 < { TIBRestoreService }
1465 <
1466 < procedure TIBRestoreService.SetServiceStartOptions;
1467 < var
1468 <  param, i: Integer;
1469 <  value: String;
1470 < begin
1471 <  param := 0;
1472 <  if (DeactivateIndexes in Options) then
1473 <    param := param or isc_spb_res_deactivate_idx;
1474 <  if (NoShadow in Options) then
1475 <    param := param or isc_spb_res_no_shadow;
1476 <  if (NoValidityCheck in Options) then
1477 <    param := param or isc_spb_res_no_validity;
1478 <  if (OneRelationAtATime in Options) then
1479 <    param := param or isc_spb_res_one_at_a_time;
1480 <  if (Replace in Options) then
1481 <    param := param or isc_spb_res_replace;
1482 <  if (CreateNewDB in Options) then
1483 <    param := param or isc_spb_res_create;
1484 <  if (UseAllSpace in Options) then
1485 <    param := param or isc_spb_res_use_all_space;
1486 <  Action := isc_action_svc_restore;
1487 <  ServiceStartParams  := Char(isc_action_svc_restore);
1488 <  ServiceStartAddParam(param, SPBConstantValues[isc_spb_options]);
1489 <  if Verbose then ServiceStartParams := ServiceStartParams + Char(SPBConstantValues[isc_spb_verbose]);
1490 <  if FPageSize > 0 then
1491 <    ServiceStartAddParam(FPageSize, isc_spb_res_page_size);
1492 <  if FPageBuffers > 0 then
1493 <    ServiceStartAddParam(FPageBuffers, isc_spb_res_buffers);
1494 <  for i := 0 to FBackupFile.Count - 1 do
1495 <  begin
1496 <    if (Trim(FBackupFile[i]) = '') then continue;
1497 <    if (Pos('=', FBackupFile[i]) <> 0) then  {mbcs ok}
1498 <    begin
1499 <      ServiceStartAddParam(FBackupFile.Names[i], isc_spb_bkp_file);
1500 <      value := Copy(FBackupFile[i], Pos('=', FBackupFile[i]) + 1, Length(FBackupFile.Names[i])); {mbcs ok}
1501 <      param := StrToInt(value);
1502 <      ServiceStartAddParam(param, isc_spb_bkp_length);
1503 <    end
1504 <    else
1505 <      ServiceStartAddParam(FBackupFile[i], isc_spb_bkp_file);
1506 <  end;
1507 <  for i := 0 to FDatabaseName.Count - 1 do
1508 <  begin
1509 <    if (Trim(FDatabaseName[i]) = '') then continue;
1510 <    if (Pos('=', FDatabaseName[i]) <> 0) then {mbcs ok}
1511 <    begin
1512 <      ServiceStartAddParam(FDatabaseName.Names[i], SPBConstantValues[isc_spb_dbname]);
1513 <      value := Copy(FDatabaseName[i], Pos('=', FDatabaseName[i]) + 1, Length(FDatabaseName[i])); {mbcs ok}
1514 <      param := StrToInt(value);
1515 <      ServiceStartAddParam(param, isc_spb_res_length);
1516 <    end
1517 <    else
1518 <      ServiceStartAddParam(FDatabaseName[i], SPBConstantValues[isc_spb_dbname]);
1519 <  end;
1520 < end;
1521 <
1522 < constructor TIBRestoreService.Create(AOwner: TComponent);
1523 < begin
1524 <  inherited Create(AOwner);
1525 <  FDatabaseName := TStringList.Create;
1526 <  FBackupFile := TStringList.Create;
1527 <  Include (FOptions, CreateNewDB);
1528 < end;
1529 <
1530 < destructor TIBRestoreService.Destroy;
1531 < begin
1532 <  FDatabaseName.Free;
1533 <  FBackupFile.Free;
1534 <  inherited Destroy;
1535 < end;
1536 <
1537 < procedure TIBRestoreService.SetBackupFile(const Value: TStrings);
1538 < begin
1539 <  FBackupFile.Assign(Value);
1540 < end;
1541 <
1542 < procedure TIBRestoreService.SetDatabaseName(const Value: TStrings);
1543 < begin
1544 <  FDatabaseName.Assign(Value);
1545 < end;
1546 <
1547 < { TIBValidationService }
1548 < constructor TIBValidationService.Create(AOwner: TComponent);
1549 < begin
1550 <  inherited Create(AOwner);
1551 < end;
1552 <
1553 < destructor TIBValidationService.Destroy;
1554 < var
1555 <  i : Integer;
1556 < begin
1557 <  for i := 0 to High(FLimboTransactionInfo) do
1558 <    FLimboTransactionInfo[i].Free;
1559 <  FLimboTransactionInfo := nil;
1560 <  inherited Destroy;
1561 < end;
1562 <
1563 < procedure TIBValidationService.FetchLimboTransactionInfo;
1564 < var
1565 <  i, RunLen: Integer;
1566 <  Value: Char;
1567 < begin
1568 <  ServiceQueryParams := Char(isc_info_svc_limbo_trans);
1569 <  InternalServiceQuery;
1570 <  RunLen := 0;
1571 <  if (OutputBuffer[RunLen] <> Char(isc_info_svc_limbo_trans)) then
1572 <    IBError(ibxeOutputParsingError, [nil]);
1573 <  Inc(RunLen, 3);
1574 <  for i := 0 to High(FLimboTransactionInfo) do
1575 <    FLimboTransactionInfo[i].Free;
1576 <  FLimboTransactionInfo := nil;
1577 <  i := 0;
1578 <  while (OutputBuffer[RunLen] <> Char(isc_info_end)) do
1579 <  begin
1580 <    if (i >= Length(FLimboTransactionInfo)) then
1581 <      SetLength(FLimboTransactionInfo, i + 10);
1582 <    if FLimboTransactionInfo[i] = nil then
1583 <      FLimboTransactionInfo[i] := TLimboTransactionInfo.Create;
1584 <    with FLimboTransactionInfo[i] do
1585 <    begin
1586 <      if (OutputBuffer[RunLen] = Char(isc_spb_single_tra_id)) then
1587 <      begin
1588 <        Inc(RunLen);
1589 <        MultiDatabase := False;
1590 <        ID := ParseInteger(RunLen);
1591 <      end
1592 <      else
1593 <      begin
1594 <        Inc(RunLen);
1595 <        MultiDatabase := True;
1596 <        ID := ParseInteger(RunLen);
1597 <        HostSite := ParseString(RunLen);
1598 <        if (OutputBuffer[RunLen] <> Char(isc_spb_tra_state)) then
1599 <          IBError(ibxeOutputParsingError, [nil]);
1600 <        Inc(RunLen);
1601 <        Value := OutputBuffer[RunLen];
1602 <        Inc(RunLen);
1603 <        if (Value = Char(isc_spb_tra_state_limbo)) then
1604 <          State := LimboState
1605 <        else
1606 <          if (Value = Char(isc_spb_tra_state_commit)) then
1607 <            State := CommitState
1608 <          else
1609 <            if (Value = Char(isc_spb_tra_state_rollback)) then
1610 <              State := RollbackState
1611 <            else
1612 <              State := UnknownState;
1613 <        RemoteSite := ParseString(RunLen);
1614 <        RemoteDatabasePath := ParseString(RunLen);
1615 <        Value := OutputBuffer[RunLen];
1616 <        Inc(RunLen);
1617 <        if (Value = Char(isc_spb_tra_advise_commit)) then
1618 <        begin
1619 <          Advise := CommitAdvise;
1620 <          Action:= CommitAction;
1621 <        end
1622 <        else
1623 <          if (Value = Char(isc_spb_tra_advise_rollback)) then
1624 <          begin
1625 <            Advise := RollbackAdvise;
1626 <            Action := RollbackAction;
1627 <          end
1628 <          else
1629 <          begin
1630 <            { if no advice commit as default }
1631 <            Advise := UnknownAdvise;
1632 <            Action:= CommitAction;
1633 <          end;
1634 <      end;
1635 <      Inc (i);
1636 <    end;
1637 <  end;
1638 <  if (i > 0) then
1639 <    SetLength(FLimboTransactionInfo, i+1);
1640 < end;
1641 <
1642 < procedure TIBValidationService.FixLimboTransactionErrors;
1643 < var
1644 <  i: Integer;
1645 < begin
1646 <  ServiceStartParams  := Char(isc_action_svc_repair);
1647 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1648 <  if (FGlobalAction = NoGlobalAction) then
1649 <  begin
1650 <    i := 0;
1651 <    while (FLimboTransactionInfo[i].ID <> 0) do
1652 <    begin
1653 <      if (FLimboTransactionInfo[i].Action = CommitAction) then
1654 <        ServiceStartAddParam (FLimboTransactionInfo[i].ID, isc_spb_rpr_commit_trans)
1655 <      else
1656 <        ServiceStartAddParam (FLimboTransactionInfo[i].ID, isc_spb_rpr_rollback_trans);                              
1657 <      Inc(i);
1658 <    end;
1659 <  end
1660 <  else
1661 <  begin
1662 <    i := 0;
1663 <    if (FGlobalAction = CommitGlobal) then
1664 <      while (FLimboTransactionInfo[i].ID <> 0) do
1665 <      begin
1666 <        ServiceStartAddParam (FLimboTransactionInfo[i].ID, isc_spb_rpr_commit_trans);
1667 <        Inc(i);
1668 <      end
1669 <    else
1670 <      while (FLimboTransactionInfo[i].ID <> 0) do
1671 <      begin
1672 <        ServiceStartAddParam (FLimboTransactionInfo[i].ID, isc_spb_rpr_rollback_trans);
1673 <        Inc(i);
1674 <      end;
1675 <  end;
1676 <  InternalServiceStart;
1677 < end;
1678 <
1679 < function TIBValidationService.GetLimboTransactionInfo(index: integer): TLimboTransactionInfo;
1680 < begin
1681 <  if index <= High(FLimboTransactionInfo) then
1682 <    result := FLimboTransactionInfo[index]
1683 <  else
1684 <    result := nil;
1685 < end;
1686 <
1687 < function TIBValidationService.GetLimboTransactionInfoCount: integer;
1688 < begin
1689 <  Result := High(FLimboTransactionInfo);
1690 < end;
1691 <
1692 < procedure TIBValidationService.SetDatabaseName(const Value: string);
1693 < begin
1694 <  FDatabaseName := Value;
1695 < end;
1696 <
1697 < procedure TIBValidationService.SetServiceStartOptions;
1698 < var
1699 <  param: Integer;
1700 < begin
1701 <  Action := isc_action_svc_repair;
1702 <  if FDatabaseName = '' then
1703 <    IBError(ibxeStartParamsError, [nil]);
1704 <  param := 0;
1705 <  if (SweepDB in Options) then
1706 <    param := param or isc_spb_rpr_sweep_db;
1707 <  if (ValidateDB in Options) then
1708 <    param := param or isc_spb_rpr_validate_db;
1709 <  ServiceStartParams  := Char(isc_action_svc_repair);
1710 <  ServiceStartAddParam (FDatabaseName, SPBConstantValues[isc_spb_dbname]);
1711 <  if param > 0 then
1712 <    ServiceStartAddParam (param, SPBConstantValues[isc_spb_options]);
1713 <  param := 0;
1714 <  if (LimboTransactions in Options) then
1715 <    param := param or isc_spb_rpr_list_limbo_trans;
1716 <  if (CheckDB in Options) then
1717 <    param := param or isc_spb_rpr_check_db;
1718 <  if (IgnoreChecksum in Options) then
1719 <    param := param or isc_spb_rpr_ignore_checksum;
1720 <  if (KillShadows in Options) then
1721 <    param := param or isc_spb_rpr_kill_shadows;
1722 <  if (MendDB in Options) then
1723 <    param := param or isc_spb_rpr_mend_db;
1724 <  if (ValidateFull in Options) then
1725 <  begin
1726 <     param := param or isc_spb_rpr_full;
1727 <     if not (MendDB in Options) then
1728 <       param := param or isc_spb_rpr_validate_db;
1729 <  end;
1730 <  if param > 0 then
1731 <    ServiceStartAddParam (param, SPBConstantValues[isc_spb_options]);
1732 < end;
1733 <
1734 < { TIBSecurityService }
1735 < constructor TIBSecurityService.Create(AOwner: TComponent);
1736 < begin
1737 <  inherited Create(AOwner);
1738 <  FModifyParams := [];
1739 < end;
1740 <
1741 < destructor TIBSecurityService.Destroy;
1742 < var
1743 <  i : Integer;
1744 < begin
1745 <  for i := 0 to High(FUserInfo) do
1746 <    FUserInfo[i].Free;
1747 <  FUserInfo := nil;
1748 <  inherited Destroy;
1749 < end;
1750 <
1751 < procedure TIBSecurityService.FetchUserInfo;
1752 < var
1753 <  i, RunLen: Integer;
1754 < begin
1755 <  ServiceQueryParams := Char(isc_info_svc_get_users);
1756 <  InternalServiceQuery;
1757 <  RunLen := 0;
1758 <  if (OutputBuffer[RunLen] <> Char(isc_info_svc_get_users)) then
1759 <    IBError(ibxeOutputParsingError, [nil]);
1760 <  Inc(RunLen);
1761 <  for i := 0 to High(FUserInfo) do
1762 <    FUserInfo[i].Free;
1763 <  FUserInfo := nil;
1764 <  i := 0;
1765 <  { Don't have any use for the combined length
1766 <   so increment past by 2 }
1767 <  Inc(RunLen, 2);
1768 <  while (OutputBuffer[RunLen] <> Char(isc_info_end)) do
1769 <  begin
1770 <    if (i >= Length(FUSerInfo)) then
1771 <      SetLength(FUserInfo, i + 10);
1772 <    if (OutputBuffer[RunLen] <> Char(isc_spb_sec_username)) then
1773 <      IBError(ibxeOutputParsingError, [nil]);
1774 <    Inc(RunLen);
1775 <    if FUserInfo[i] = nil then
1776 <      FUserInfo[i] := TUserInfo.Create;
1777 <    FUserInfo[i].UserName := ParseString(RunLen);
1778 <    if (OutputBuffer[RunLen] <> Char(isc_spb_sec_firstname)) then
1779 <      IBError(ibxeOutputParsingError, [nil]);
1780 <    Inc(RunLen);
1781 <    FUserInfo[i].FirstName := ParseString(RunLen);
1782 <    if (OutputBuffer[RunLen] <> Char(isc_spb_sec_middlename)) then
1783 <      IBError(ibxeOutputParsingError, [nil]);
1784 <    Inc(RunLen);
1785 <    FUserInfo[i].MiddleName := ParseString(RunLen);
1786 <    if (OutputBuffer[RunLen] <> Char(isc_spb_sec_lastname)) then
1787 <      IBError(ibxeOutputParsingError, [nil]);
1788 <    Inc(RunLen);
1789 <    FUserInfo[i].LastName := ParseString(RunLen);
1790 <    if (OutputBuffer[RunLen] <> Char(isc_spb_sec_userId)) then
1791 <      IBError(ibxeOutputParsingError, [nil]);
1792 <    Inc(RunLen);
1793 <    FUserInfo[i].UserId := ParseInteger(RunLen);
1794 <    if (OutputBuffer[RunLen] <> Char(isc_spb_sec_groupid)) then
1795 <      IBError(ibxeOutputParsingError, [nil]);
1796 <    Inc(RunLen);
1797 <    FUserInfo[i].GroupID := ParseInteger(RunLen);
1798 <    Inc (i);
1799 <  end;
1800 <  if (i > 0) then
1801 <    SetLength(FUserInfo, i+1);
1802 < end;
1803 <
1804 < function TIBSecurityService.GetUserInfo(Index: Integer): TUserInfo;
1805 < begin
1806 <  if Index <= High(FUSerInfo) then
1807 <    result := FUserInfo[Index]
1808 <  else
1809 <    result := nil;
1810 < end;
1811 <
1812 < function TIBSecurityService.GetUserInfoCount: Integer;
1813 < begin
1814 <  Result := Max(High(FUSerInfo),0);
1815 < end;
1816 <
1817 < procedure TIBSecurityService.AddUser;
1818 < begin
1819 <  SecurityAction := ActionAddUser;
1820 <  ServiceStart;
1821 < end;
1822 <
1823 < procedure TIBSecurityService.DeleteUser;
1824 < begin
1825 <  SecurityAction := ActionDeleteUser;
1826 <  ServiceStart;
1827 < end;
1828 <
1829 < procedure TIBSecurityService.DisplayUsers;
1830 < begin
1831 <  SecurityAction := ActionDisplayUser;
1832 <  ServiceStartParams  := Char(isc_action_svc_display_user);
1833 <  InternalServiceStart;
1834 <  FetchUserInfo;
1835 < end;
1836 <
1837 < procedure TIBSecurityService.DisplayUser(UserName: String);
1838 < begin
1839 <  SecurityAction := ActionDisplayUser;
1840 <  ServiceStartParams  := Char(isc_action_svc_display_user);
1841 <  ServiceStartAddParam (UserName, isc_spb_sec_username);
1842 <  InternalServiceStart;
1843 <  FetchUserInfo;
1844 < end;
1845 <
1846 < procedure TIBSecurityService.ModifyUser;
1847 < begin
1848 <  SecurityAction := ActionModifyUser;
1849 <  ServiceStart;
1850 < end;
1851 <
1852 < procedure TIBSecurityService.SetSecurityAction (Value: TSecurityAction);
1853 < begin
1854 <  FSecurityAction := Value;
1855 <  if Value = ActionDeleteUser then
1856 <    ClearParams;
1857 < end;
1858 <
1859 < procedure TIBSecurityService.ClearParams;
1860 < begin
1861 <  FModifyParams := [];
1862 <  FFirstName := '';
1863 <  FMiddleName := '';
1864 <  FLastName := '';
1865 <  FGroupID := 0;
1866 <  FUserID := 0;
1867 <  FPassword := '';
1868 < end;
1869 <
1870 < procedure TIBSecurityService.SetFirstName (Value: String);
1871 < begin
1872 <  FFirstName := Value;
1873 <  Include (FModifyParams, ModifyFirstName);
1874 < end;
1875 <
1876 < procedure TIBSecurityService.SetMiddleName (Value: String);
1877 < begin
1878 <  FMiddleName := Value;
1879 <  Include (FModifyParams, ModifyMiddleName);
1880 < end;
1881 <
1882 < procedure TIBSecurityService.SetLastName (Value: String);
1883 < begin
1884 <  FLastName := Value;
1885 <  Include (FModifyParams, ModifyLastName);
1886 < end;
1887 <
1888 < procedure TIBSecurityService.SetPassword (Value: String);
1889 < begin
1890 <  FPassword := Value;
1891 <  Include (FModifyParams, ModifyPassword);
1892 < end;
1893 <
1894 < procedure TIBSecurityService.SetUserId (Value: Integer);
1895 < begin
1896 <  FUserId := Value;
1897 <  Include (FModifyParams, ModifyUserId);
1898 < end;
1899 <
1900 < procedure TIBSecurityService.SetGroupId (Value: Integer);
1901 < begin
1902 <  FGroupId := Value;
1903 <  Include (FModifyParams, ModifyGroupId);
1904 < end;
1905 <
1906 < procedure TIBSecurityService.Loaded;
1907 < begin
1908 <  inherited Loaded;
1909 <  ClearParams;
1910 < end;
1911 <
1912 < procedure TIBSecurityService.SetServiceStartOptions;
1913 < var
1914 <  Len: UShort;
1915 <
1916 < begin
1917 <  case FSecurityAction of
1918 <    ActionAddUser:
1919 <    begin
1920 <      Action := isc_action_svc_add_user;
1921 <      if ( Pos(' ', FUserName) > 0 ) then
1922 <        IBError(ibxeStartParamsError, [nil]);
1923 <      Len := Length(FUserName);
1924 <      if (Len = 0) then
1925 <        IBError(ibxeStartParamsError, [nil]);
1926 <      ServiceStartParams  := Char(isc_action_svc_add_user);
1927 <      ServiceStartAddParam (FSQLRole, SPBConstantValues[isc_spb_sql_role_name]);
1928 <      ServiceStartAddParam (FUserName, isc_spb_sec_username);
1929 <      ServiceStartAddParam (FUserID, isc_spb_sec_userid);
1930 <      ServiceStartAddParam (FGroupID, isc_spb_sec_groupid);
1931 <      ServiceStartAddParam (FPassword, isc_spb_sec_password);
1932 <      ServiceStartAddParam (FFirstName, isc_spb_sec_firstname);
1933 <      ServiceStartAddParam (FMiddleName, isc_spb_sec_middlename);
1934 <      ServiceStartAddParam (FLastName, isc_spb_sec_lastname);
1935 <    end;
1936 <    ActionDeleteUser:
1937 <    begin
1938 <      Action := isc_action_svc_delete_user;
1939 <      Len := Length(FUserName);
1940 <      if (Len = 0) then
1941 <        IBError(ibxeStartParamsError, [nil]);
1942 <      ServiceStartParams  := Char(isc_action_svc_delete_user);
1943 <      ServiceStartAddParam (FSQLRole, SPBConstantValues[isc_spb_sql_role_name]);
1944 <      ServiceStartAddParam (FUserName, isc_spb_sec_username);
1945 <    end;
1946 <    ActionModifyUser:
1947 <    begin
1948 <      Action := isc_action_svc_modify_user;
1949 <      Len := Length(FUserName);
1950 <      if (Len = 0) then
1951 <        IBError(ibxeStartParamsError, [nil]);
1952 <      ServiceStartParams  := Char(isc_action_svc_modify_user);
1953 <      ServiceStartAddParam (FSQLRole, SPBConstantValues[isc_spb_sql_role_name]);
1954 <      ServiceStartAddParam (FUserName, isc_spb_sec_username);
1955 <      if (ModifyUserId in FModifyParams) then
1956 <        ServiceStartAddParam (FUserID, isc_spb_sec_userid);
1957 <      if (ModifyGroupId in FModifyParams) then
1958 <        ServiceStartAddParam (FGroupID, isc_spb_sec_groupid);
1959 <      if (ModifyPassword in FModifyParams) then
1960 <        ServiceStartAddParam (FPassword, isc_spb_sec_password);
1961 <      if (ModifyFirstName in FModifyParams) then
1962 <        ServiceStartAddParam (FFirstName, isc_spb_sec_firstname);
1963 <      if (ModifyMiddleName in FModifyParams) then
1964 <        ServiceStartAddParam (FMiddleName, isc_spb_sec_middlename);
1965 <      if (ModifyLastName in FModifyParams) then
1966 <        ServiceStartAddParam (FLastName, isc_spb_sec_lastname);
1967 <    end;
1968 <  end;
1969 <  ClearParams;
1970 < end;
1971 <
1972 < { TIBUnStructuredService }
1973 < constructor TIBControlAndQueryService.Create(AOwner: TComponent);
1974 < begin
1975 <  inherited Create(AOwner);
1976 <  FEof := False;
1977 <  FAction := 0;
1978 < end;
1979 <
1980 < procedure TIBControlAndQueryService.SetAction(Value: Integer);
1981 < begin
1982 <  FEof := False;
1983 <  FAction := Value;
1984 < end;
1985 <
1986 <
1987 < function TIBControlAndQueryService.GetNextChunk: String;
1988 < var
1989 <  Length: Integer;
1990 < begin
1991 <  if (FEof = True) then
1992 <  begin
1993 <    result := '';
1994 <    exit;
1995 <  end;
1996 <  if (FAction = 0) then
1997 <    IBError(ibxeQueryParamsError, [nil]);
1998 <  ServiceQueryParams := Char(isc_info_svc_to_eof);
1999 <  InternalServiceQuery;
2000 <  if (OutputBuffer[0] <> Char(isc_info_svc_to_eof)) then
2001 <    IBError(ibxeOutputParsingError, [nil]);
2002 <  Length := isc_vax_integer(OutputBuffer + 1, 2);
2003 <  if (OutputBuffer[3 + Length] = Char(isc_info_truncated)) then
2004 <    FEof := False
2005 <  else
2006 <    if (OutputBuffer[3 + Length] = Char(isc_info_end)) then
2007 <      FEof := True
2008 <    else
2009 <      IBError(ibxeOutputParsingError, [nil]);
2010 <  OutputBuffer[3 + Length] := #0;
2011 <  result := String(PChar(@OutputBuffer[3]));
2012 < end;
2013 <
2014 < function TIBControlAndQueryService.GetNextLine: String;
2015 < var
2016 <  Length: Integer;
2017 < begin
2018 <  if (FEof = True) then
2019 <  begin
2020 <    result := '';
2021 <    exit;
2022 <  end;
2023 <  if (FAction = 0) then
2024 <    IBError(ibxeQueryParamsError, [nil]);
2025 <  ServiceQueryParams := Char(isc_info_svc_line);
2026 <  InternalServiceQuery;
2027 <  if (OutputBuffer[0] <> Char(isc_info_svc_line)) then
2028 <    IBError(ibxeOutputParsingError, [nil]);
2029 <  Length := isc_vax_integer(OutputBuffer + 1, 2);
2030 <  if (OutputBuffer[3 + Length] <> Char(isc_info_end)) then
2031 <    IBError(ibxeOutputParsingError, [nil]);
2032 <  if (length <> 0) then
2033 <    FEof := False
2034 <  else
2035 <  begin
2036 <    result := '';
2037 <    FEof := True;
2038 <    exit;
2039 <  end;
2040 <  OutputBuffer[3 + Length] := #0;
2041 <  result := String(PChar(@OutputBuffer[3]));
2042 < end;
2043 <
2044 < { TIBLogService }
2045 <
2046 < procedure TIBLogService.SetServiceStartOptions;
2047 < begin
2048 <  Action := isc_action_svc_get_ib_log;
2049 <  ServiceStartParams  := Char(isc_action_svc_get_ib_log);
2050 < end;
2051 <
2052 < { TDatabaseInfo }
2053 <
2054 < constructor TDatabaseInfo.Create;
2055 < begin
2056 <  DbName := nil;
2057 < end;
2058 <
2059 < destructor TDatabaseInfo.Destroy;
2060 < begin
2061 <  DbName := nil;
2062 <  inherited Destroy;
2063 < end;
2064 <
2065 < { TLicenseInfo }
2066 <
2067 < constructor TLicenseInfo.Create;
2068 < begin
2069 <  Key := nil;
2070 <  Id := nil;
2071 <  Desc := nil;
2072 < end;
2073 <
2074 < destructor TLicenseInfo.Destroy;
2075 < begin
2076 <  Key := nil;
2077 <  Id := nil;
2078 <  Desc := nil;
2079 <  inherited Destroy;
2080 < end;
2081 <
2082 < { TConfigFileData }
2083 <
2084 < constructor TConfigFileData.Create;
2085 < begin
2086 <  ConfigFileValue := nil;
2087 <  ConfigFileKey := nil;
2088 < end;
2089 <
2090 < destructor TConfigFileData.Destroy;
2091 < begin
2092 <  ConfigFileValue := nil;
2093 <  ConfigFileKey := nil;
2094 <  inherited Destroy;
2095 < end;
2096 <
2097 < { TConfigParams }
2098 <
2099 < constructor TConfigParams.Create;
2100 < begin
2101 <  ConfigFileData := TConfigFileData.Create;
2102 <  ConfigFileParams := nil;
2103 < end;
2104 <
2105 < destructor TConfigParams.Destroy;
2106 < begin
2107 <  ConfigFileData.Free;
2108 <  ConfigFileParams := nil;
2109 <  inherited Destroy;
2110 < end;
2111 <
2112 < end.
1 > {************************************************************************}
2 > {                                                                        }
3 > {       Borland Delphi Visual Component Library                          }
4 > {       InterBase Express core components                                }
5 > {                                                                        }
6 > {       Copyright (c) 1998-2000 Inprise Corporation                      }
7 > {                                                                        }
8 > {    InterBase Express is based in part on the product                   }
9 > {    Free IB Components, written by Gregory H. Deatz for                 }
10 > {    Hoagland, Longo, Moran, Dunst & Doukas Company.                     }
11 > {    Free IB Components is used under license.                           }
12 > {                                                                        }
13 > {    The contents of this file are subject to the InterBase              }
14 > {    Public License Version 1.0 (the "License"); you may not             }
15 > {    use this file except in compliance with the License. You            }
16 > {    may obtain a copy of the License at http://www.Inprise.com/IPL.html }
17 > {    Software distributed under the License is distributed on            }
18 > {    an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, either              }
19 > {    express or implied. See the License for the specific language       }
20 > {    governing rights and limitations under the License.                 }
21 > {    The Original Code was created by InterBase Software Corporation     }
22 > {       and its successors.                                              }
23 > {    Portions created by Inprise Corporation are Copyright (C) Inprise   }
24 > {       Corporation. All Rights Reserved.                                }
25 > {    Contributor(s): Jeff Overcash                                       }
26 > {                                                                        }
27 > {    IBX For Lazarus (Firebird Express)                                  }
28 > {    Contributor: Tony Whyman, MWA Software http://www.mwasoftware.co.uk }
29 > {    Portions created by MWA Software are copyright McCallum Whyman      }
30 > {    Associates Ltd 2011                                                 }
31 > {                                                                        }
32 > {************************************************************************}
33 >
34 > {
35 >  InterBase Express provides component interfaces to
36 >  functions introduced in InterBase 6.0.  The Services
37 >  components (TIB*Service, TIBServerProperties)
38 >  function only if you have installed InterBase 6.0 or
39 >  later software, including Firebird
40 > }
41 >
42 > unit IBServices;
43 >
44 > {$Mode Delphi}
45 > {$codepage UTF8}
46 >
47 > interface
48 >
49 > uses
50 > {$IFDEF WINDOWS }
51 >  Windows,
52 > {$ELSE}
53 >  unix,
54 > {$ENDIF}
55 >  SysUtils, Classes, IBHeader, IB, IBExternals, CustApp, IBTypes, IBSQL;
56 >
57 > const
58 >  DefaultBufferSize = 32000;
59 >
60 >  SPBPrefix = 'isc_spb_';
61 >  isc_spb_last_spb_constant = 12;
62 >  SPBConstantNames: array[1..isc_spb_last_spb_constant] of String = (
63 >    'user_name',
64 >    'sys_user_name',
65 >    'sys_user_name_enc',
66 >    'password',
67 >    'password_enc',
68 >    'command_line',
69 >    'db_name',
70 >    'verbose',
71 >    'options',
72 >    'connect_timeout',
73 >    'dummy_packet_interval',
74 >    'sql_role_name'
75 >  );
76 >
77 >  SPBConstantValues: array[1..isc_spb_last_spb_constant] of Integer = (
78 >    isc_spb_user_name,
79 >    isc_spb_sys_user_name,
80 >    isc_spb_sys_user_name_enc,
81 >    isc_spb_password,
82 >    isc_spb_password_enc,
83 >    isc_spb_command_line,
84 >    isc_spb_dbname,
85 >    isc_spb_verbose,
86 >    isc_spb_options,
87 >    isc_spb_connect_timeout,
88 >    isc_spb_dummy_packet_interval,
89 >    isc_spb_sql_role_name
90 >  );
91 >
92 > type
93 >  TOutputBufferOption = (ByLine, ByChunk);
94 >
95 >  TIBCustomService = class;
96 >
97 >  TLoginEvent = procedure(Database: TIBCustomService;
98 >    LoginParams: TStrings) of object;
99 >
100 >  { TIBCustomService }
101 >
102 >  TIBCustomService = class(TComponent)
103 >  private
104 >    FParamsChanged : Boolean;
105 >    FQueryParams: String;
106 >    FSPB : ISPB;
107 >    FSRB: ISRB;
108 >    FSQPB: ISQPB;
109 >    FTraceFlags: TTraceFlags;
110 >    FOnLogin: TLoginEvent;
111 >    FLoginPrompt: Boolean;
112 >    FServerName: string;
113 >    FService: IServiceManager;
114 >    FStreamedActive  : Boolean;
115 >    FOnAttach: TNotifyEvent;
116 >    FOutputBufferOption: TOutputBufferOption;
117 >    FProtocol: TProtocol;
118 >    FParams: TStrings;
119 >    FServiceQueryResults: IServiceQueryResults;
120 >    function GetActive: Boolean;
121 >    function GetServiceParamBySPB(const Idx: Integer): String;
122 >    function GetSQPB: ISQPB;
123 >    function GetSRB: ISRB;
124 >    procedure SetActive(const Value: Boolean);
125 >    procedure SetParams(const Value: TStrings);
126 >    procedure SetServerName(const Value: string);
127 >    procedure SetProtocol(const Value: TProtocol);
128 >    procedure SetService(AValue: IServiceManager);
129 >    procedure SetServiceParamBySPB(const Idx: Integer;
130 >      const Value: String);
131 >    function IndexOfSPBConst(action: byte): Integer;
132 >    function GetSPBConstName(action: byte): string;
133 >    procedure ParamsChange(Sender: TObject);
134 >    procedure ParamsChanging(Sender: TObject);
135 >    procedure CheckServerName;
136 >    function GenerateSPB(sl: TStrings): ISPB;
137 >
138 >  protected
139 >    procedure Loaded; override;
140 >    function Login(var aServerName: string): Boolean;
141 >    procedure CheckActive;
142 >    procedure CheckInactive;
143 >    procedure HandleException(Sender: TObject);
144 >    procedure InternalServiceQuery;
145 >    property SRB: ISRB read GetSRB;
146 >    property SQPB: ISQPB read GetSQPB;
147 >    property ServiceQueryResults: IServiceQueryResults read FServiceQueryResults;
148 >
149 >  public
150 >    constructor Create(AOwner: TComponent); override;
151 >    destructor Destroy; override;
152 >    procedure Attach;
153 >    procedure Detach;
154 >    property ServiceIntf: IServiceManager read FService write SetService;
155 >    property ServiceParamBySPB[const Idx: Integer]: String read GetServiceParamBySPB
156 >                                                      write SetServiceParamBySPB;
157 >  published
158 >    property Active: Boolean read GetActive write SetActive default False;
159 >    property ServerName: string read FServerName write SetServerName;
160 >    property Protocol: TProtocol read FProtocol write SetProtocol default Local;
161 >    property Params: TStrings read FParams write SetParams;
162 >    property LoginPrompt: Boolean read FLoginPrompt write FLoginPrompt default True;
163 >    property TraceFlags: TTraceFlags read FTraceFlags write FTraceFlags;
164 >    property OnAttach: TNotifyEvent read FOnAttach write FOnAttach;
165 >    property OnLogin: TLoginEvent read FOnLogin write FOnLogin;
166 >  end;
167 >
168 >  TDatabaseInfo = class
169 >  public
170 >    NoOfAttachments: Integer;
171 >    NoOfDatabases: Integer;
172 >    DbName: array of string;
173 >    constructor Create;
174 >    destructor Destroy; override;
175 >  end;
176 >
177 >  TLicenseInfo = class
178 >  public
179 >    Key: array of string;
180 >    Id: array of string;
181 >    Desc: array of string;
182 >    LicensedUsers: Integer;
183 >    constructor Create;
184 >    destructor Destroy; override;
185 >  end;
186 >
187 >  TLicenseMaskInfo = class
188 >  public
189 >    LicenseMask: Integer;
190 >    CapabilityMask: Integer;
191 >  end;
192 >
193 >  TConfigFileData = class
194 >  public
195 >    ConfigFileValue: array of integer;
196 >    ConfigFileKey: array of integer;
197 >    constructor Create;
198 >    destructor Destroy; override;
199 >  end;
200 >
201 >  TConfigParams = class
202 >  public
203 >    ConfigFileData: TConfigFileData;
204 >    ConfigFileParams: array of string;
205 >    BaseLocation: string;
206 >    LockFileLocation: string;
207 >    MessageFileLocation: string;
208 >    SecurityDatabaseLocation: string;
209 >    constructor Create;
210 >    destructor Destroy; override;
211 >  end;
212 >
213 >  TVersionInfo = class
214 >    ServerVersion: String;
215 >    ServerImplementation: string;
216 >    ServiceVersion: Integer;
217 >  end;
218 >
219 >  TPropertyOption = (Database, License, LicenseMask, ConfigParameters, Version);
220 >  TPropertyOptions = set of TPropertyOption;
221 >
222 >  TIBServerProperties = class(TIBCustomService)
223 >  private
224 >    FOptions: TPropertyOptions;
225 >    FDatabaseInfo: TDatabaseInfo;
226 >    FLicenseInfo: TLicenseInfo;
227 >    FLicenseMaskInfo: TLicenseMaskInfo;
228 >    FVersionInfo: TVersionInfo;
229 >    FConfigParams: TConfigParams;
230 >  public
231 >    constructor Create(AOwner: TComponent); override;
232 >    destructor Destroy; override;
233 >    procedure Fetch;
234 >    procedure FetchDatabaseInfo;
235 >    procedure FetchLicenseInfo;
236 >    procedure FetchLicenseMaskInfo;
237 >    procedure FetchConfigParams;
238 >    procedure FetchVersionInfo;
239 >    property DatabaseInfo: TDatabaseInfo read FDatabaseInfo;
240 >    property LicenseInfo: TLicenseInfo read FLicenseInfo;
241 >    property LicenseMaskInfo: TLicenseMaskInfo read FLicenseMaskInfo;
242 >    property VersionInfo: TVersionInfo read FVersionInfo;
243 >    property ConfigParams: TConfigParams read FConfigParams;
244 >  published
245 >    property Options : TPropertyOptions read FOptions write FOptions;
246 >  end;
247 >
248 >  { TIBControlService }
249 >
250 >  TIBControlService = class (TIBCustomService)
251 >  private
252 >    function GetIsServiceRunning: Boolean;
253 >  protected
254 >    procedure CheckServiceNotRunning;
255 >    procedure InternalServiceStart;
256 >    procedure SetServiceStartOptions; virtual;
257 >
258 >  public
259 >    constructor Create(AOwner: TComponent); override;
260 >    procedure ServiceStart; virtual;
261 >    property IsServiceRunning : Boolean read GetIsServiceRunning;
262 >  end;
263 >
264 >  { TIBControlAndQueryService }
265 >
266 >  TIBControlAndQueryService = class (TIBControlService)
267 >  private
268 >    FEof: Boolean;
269 >    FAction: Integer;
270 >    procedure SetAction(Value: Integer);
271 >  protected
272 >    property Action: Integer read FAction write SetAction;
273 >  public
274 >    constructor create (AOwner: TComponent); override;
275 >    function GetNextLine : String;
276 >    function GetNextChunk : String;
277 >    function WriteNextChunk(stream: TStream): integer;
278 >    property Eof: boolean read FEof;
279 >  end;
280 >
281 >  TShutdownMode = (Forced, DenyTransaction, DenyAttachment);
282 >
283 >  TIBConfigService = class(TIBControlService)
284 >  private
285 >    FDatabaseName: string;
286 >    procedure SetDatabaseName(const Value: string);
287 >  protected
288 >
289 >  public
290 >    procedure ServiceStart; override;
291 >    procedure ShutdownDatabase (Options: TShutdownMode; Wait: Integer);
292 >    procedure SetSweepInterval (Value: Integer);
293 >    procedure SetDBSqlDialect (Value: Integer);
294 >    procedure SetPageBuffers (Value: Integer);
295 >    procedure ActivateShadow;
296 >    procedure BringDatabaseOnline;
297 >    procedure SetReserveSpace (Value: Boolean);
298 >    procedure SetAsyncMode (Value: Boolean);
299 >    procedure SetReadOnly (Value: Boolean);
300 >  published
301 >    property DatabaseName: string read FDatabaseName write SetDatabaseName;
302 >  end;
303 >
304 >  TIBLogService = class(TIBControlAndQueryService)
305 >  private
306 >
307 >  protected
308 >    procedure SetServiceStartOptions; override;
309 >  public
310 >  published
311 >  end;
312 >
313 >  TStatOption = (DataPages, {DbLog,} HeaderPages, IndexPages, SystemRelations);
314 >  TStatOptions = set of TStatOption;
315 >
316 >  TIBStatisticalService = class(TIBControlAndQueryService)
317 >  private
318 >    FDatabaseName: string;
319 >    FOptions: TStatOptions;
320 >    procedure SetDatabaseName(const Value: string);
321 >  protected
322 >    procedure SetServiceStartOptions; override;
323 >  public
324 >  published
325 >    property DatabaseName: string read FDatabaseName write SetDatabaseName;
326 >    property Options :  TStatOptions read FOptions write FOptions;
327 >  end;
328 >
329 >  TBackupLocation = (flServerSide,flClientSide);
330 >
331 >  { TIBBackupRestoreService }
332 >
333 >  TIBBackupRestoreService = class(TIBControlAndQueryService)
334 >  private
335 >    FBackupFileLocation: TBackupLocation;
336 >    FVerbose: Boolean;
337 >  protected
338 >  public
339 >    constructor Create(AOwner: TComponent); override;
340 >  published
341 >    property Verbose : Boolean read FVerbose write FVerbose default False;
342 >    property BackupFileLocation: TBackupLocation read FBackupFileLocation
343 >                                                      write FBackupFileLocation default flServerSide;
344 >  end;
345 >
346 >  TBackupOption = (IgnoreChecksums, IgnoreLimbo, MetadataOnly, NoGarbageCollection,
347 >    OldMetadataDesc, NonTransportable, ConvertExtTables);
348 >  TBackupOptions = set of TBackupOption;
349 >
350 >  TIBBackupService = class (TIBBackupRestoreService)
351 >  private
352 >    FDatabaseName: string;
353 >    FOptions: TBackupOptions;
354 >    FBackupFile: TStrings;
355 >    FBlockingFactor: Integer;
356 >    procedure SetBackupFile(const Value: TStrings);
357 >  protected
358 >    procedure SetServiceStartOptions; override;
359 >  public
360 >    constructor Create(AOwner: TComponent); override;
361 >    destructor Destroy; override;
362 >
363 >  published
364 >    { a name=value pair of filename and length }
365 >    property BackupFile: TStrings read FBackupFile write SetBackupFile;
366 >    property BlockingFactor: Integer read FBlockingFactor write FBlockingFactor;
367 >    property DatabaseName: string read FDatabaseName write FDatabaseName;
368 >    property Options : TBackupOptions read FOptions write FOptions;
369 >  end;
370 >
371 >  TRestoreOption = (DeactivateIndexes, NoShadow, NoValidityCheck, OneRelationAtATime,
372 >    Replace, CreateNewDB, UseAllSpace);
373 >
374 >  TRestoreOptions = set of TRestoreOption;
375 >
376 >  { TIBRestoreService }
377 >
378 >  TIBRestoreService = class (TIBBackupRestoreService)
379 >  private
380 >    FDatabaseName: TStrings;
381 >    FBackupFile: TStrings;
382 >    FOptions: TRestoreOptions;
383 >    FPageSize: Integer;
384 >    FPageBuffers: Integer;
385 >    FSendBytes: integer;
386 >    procedure SetBackupFile(const Value: TStrings);
387 >    procedure SetDatabaseName(const Value: TStrings);
388 >  protected
389 >    procedure SetServiceStartOptions; override;
390 >  public
391 >    constructor Create(AOwner: TComponent); override;
392 >    destructor Destroy; override;
393 >    function SendNextChunk(stream: TStream; var line: String): integer;
394 >  published
395 >    { a name=value pair of filename and length }
396 >    property DatabaseName: TStrings read FDatabaseName write SetDatabaseName;
397 >    property BackupFile: TStrings read FBackupFile write SetBackupFile;
398 >    property PageSize: Integer read FPageSize write FPageSize;
399 >    property PageBuffers: Integer read FPageBuffers write FPageBuffers;
400 >    property Options : TRestoreOptions read FOptions write FOptions default [CreateNewDB];
401 >  end;
402 >
403 >  TValidateOption = (LimboTransactions, CheckDB, IgnoreChecksum, KillShadows, MendDB,
404 >    SweepDB, ValidateDB, ValidateFull);
405 >  TValidateOptions = set of TValidateOption;
406 >
407 >  TTransactionGlobalAction = (CommitGlobal, RollbackGlobal, RecoverTwoPhaseGlobal,
408 >                             NoGlobalAction);
409 >  TTransactionState = (LimboState, CommitState, RollbackState, UnknownState);
410 >  TTransactionAdvise = (CommitAdvise, RollbackAdvise, UnknownAdvise);
411 >  TTransactionAction = (CommitAction, RollbackAction);
412 >
413 >  TLimboTransactionInfo = class
414 >  public
415 >    MultiDatabase: Boolean;
416 >    ID: Integer;
417 >    HostSite: String;
418 >    RemoteSite: String;
419 >    RemoteDatabasePath: String;
420 >    State: TTransactionState;
421 >    Advise: TTransactionAdvise;
422 >    Action: TTransactionAction;
423 >  end;
424 >
425 >  TIBValidationService = class(TIBControlAndQueryService)
426 >  private
427 >    FDatabaseName: string;
428 >    FOptions: TValidateOptions;
429 >    FLimboTransactionInfo: array of TLimboTransactionInfo;
430 >    FGlobalAction: TTransactionGlobalAction;
431 >    procedure SetDatabaseName(const Value: string);
432 >    function GetLimboTransactionInfo(index: integer): TLimboTransactionInfo;
433 >    function GetLimboTransactionInfoCount: integer;
434 >
435 >  protected
436 >    procedure SetServiceStartOptions; override;
437 >  public
438 >    constructor Create(AOwner: TComponent); override;
439 >    destructor Destroy; override;
440 >    procedure FetchLimboTransactionInfo;
441 >    procedure FixLimboTransactionErrors;
442 >    property LimboTransactionInfo[Index: integer]: TLimboTransactionInfo read GetLimboTransactionInfo;
443 >    property LimboTransactionInfoCount: Integer read GetLimboTransactionInfoCount;
444 >
445 >  published
446 >    property DatabaseName: string read FDatabaseName write SetDatabaseName;
447 >    property Options: TValidateOptions read FOptions write FOptions;
448 >    property GlobalAction: TTransactionGlobalAction read FGlobalAction
449 >                                         write FGlobalAction;
450 >  end;
451 >
452 >  TUserInfo = class
453 >  public
454 >    UserName: string;
455 >    FirstName: string;
456 >    MiddleName: string;
457 >    LastName: string;
458 >    GroupID: Integer;
459 >    UserID: Integer;
460 >  end;
461 >
462 >  TSecurityAction = (ActionAddUser, ActionDeleteUser, ActionModifyUser, ActionDisplayUser);
463 >  TSecurityModifyParam = (ModifyFirstName, ModifyMiddleName, ModifyLastName, ModifyUserId,
464 >                         ModifyGroupId, ModifyPassword);
465 >  TSecurityModifyParams = set of TSecurityModifyParam;
466 >
467 >  TIBSecurityService = class(TIBControlAndQueryService)
468 >  private
469 >    FUserID: Integer;
470 >    FGroupID: Integer;
471 >    FFirstName: string;
472 >    FUserName: string;
473 >    FPassword: string;
474 >    FSQLRole: string;
475 >    FLastName: string;
476 >    FMiddleName: string;
477 >    FUserInfo: array of TUserInfo;
478 >    FSecurityAction: TSecurityAction;
479 >    FModifyParams: TSecurityModifyParams;
480 >    procedure ClearParams;
481 >    procedure SetSecurityAction (Value: TSecurityAction);
482 >    procedure SetFirstName (Value: String);
483 >    procedure SetMiddleName (Value: String);
484 >    procedure SetLastName (Value: String);
485 >    procedure SetPassword (Value: String);
486 >    procedure SetUserId (Value: Integer);
487 >    procedure SetGroupId (Value: Integer);
488 >
489 >    procedure FetchUserInfo;
490 >    function GetUserInfo(Index: Integer): TUserInfo;
491 >    function GetUserInfoCount: Integer;
492 >
493 >  protected
494 >    procedure Loaded; override;
495 >    procedure SetServiceStartOptions; override;
496 >  public
497 >    constructor Create(AOwner: TComponent); override;
498 >    destructor Destroy; override;
499 >    procedure DisplayUsers;
500 >    procedure DisplayUser(UserName: string);
501 >    procedure AddUser;
502 >    procedure DeleteUser;
503 >    procedure ModifyUser;
504 >    property  UserInfo[Index: Integer]: TUserInfo read GetUserInfo;
505 >    property  UserInfoCount: Integer read GetUserInfoCount;
506 >
507 >  published
508 >    property SecurityAction: TSecurityAction read FSecurityAction
509 >                                             write SetSecurityAction;
510 >    property SQlRole : string read FSQLRole write FSQLrole;
511 >    property UserName : string read FUserName write FUserName;
512 >    property FirstName : string read FFirstName write SetFirstName;
513 >    property MiddleName : string read FMiddleName write SetMiddleName;
514 >    property LastName : string read FLastName write SetLastName;
515 >    property UserID : Integer read FUserID write SetUserID;
516 >    property GroupID : Integer read FGroupID write SetGroupID;
517 >    property Password : string read FPassword write setPassword;
518 >  end;
519 >
520 >
521 > implementation
522 >
523 > uses
524 >  IBSQLMonitor, Math, FBMessages;
525 >
526 > { TIBBackupRestoreService }
527 >
528 > constructor TIBBackupRestoreService.Create(AOwner: TComponent);
529 > begin
530 >  inherited Create(AOwner);
531 >  FBackupFileLocation := flServerSide;
532 > end;
533 >
534 > { TIBCustomService }
535 >
536 > procedure TIBCustomService.Attach;
537 > var aServerName: string;
538 > begin
539 >  CheckInactive;
540 >  CheckServerName;
541 >
542 >  aServerName := FServerName;
543 >
544 >  if FLoginPrompt and not Login(aServerName) then
545 >    IBError(ibxeOperationCancelled, [nil]);
546 >
547 >  { Generate a new SPB if necessary }
548 >  if FParamsChanged then
549 >  begin
550 >    FParamsChanged := False;
551 >    FSPB := GenerateSPB(FParams);
552 >  end;
553 >
554 >  FService := FirebirdAPI.GetServiceManager(aServerName,FProtocol,FSPB);
555 >
556 >  if Assigned(FOnAttach) then
557 >    FOnAttach(Self);
558 >
559 >  MonitorHook.ServiceAttach(Self);
560 > end;
561 >
562 > procedure TIBCustomService.Loaded;
563 > begin
564 >  inherited Loaded;
565 >  try
566 >    if FStreamedActive and (not Active) then
567 >      Attach;
568 >  except
569 >    if csDesigning in ComponentState then
570 >       HandleException(self)
571 >    else
572 >      raise;
573 >  end;
574 > end;
575 >
576 > function TIBCustomService.Login(var aServerName: string): Boolean;
577 > var
578 >  IndexOfUser, IndexOfPassword: Integer;
579 >  Username, Password: String;
580 >  LoginParams: TStrings;
581 > begin
582 >  if Assigned(FOnLogin) then begin
583 >    result := True;
584 >    LoginParams := TStringList.Create;
585 >    try
586 >      LoginParams.Assign(Params);
587 >      FOnLogin(Self, LoginParams);
588 >      Params.Assign (LoginParams);
589 >      aServerName := ServerName;
590 >    finally
591 >      LoginParams.Free;
592 >    end;
593 >  end
594 >  else
595 >  if assigned(IBGUIInterface)  then
596 >  begin
597 >    IndexOfUser := IndexOfSPBConst(isc_spb_user_name);
598 >    if IndexOfUser <> -1 then
599 >      Username := Copy(Params[IndexOfUser],
600 >                                         Pos('=', Params[IndexOfUser]) + 1, {mbcs ok}
601 >                                         Length(Params[IndexOfUser]));
602 >    IndexOfPassword := IndexOfSPBConst(isc_spb_password);
603 >    if IndexOfPassword <> -1 then
604 >      Password := Copy(Params[IndexOfPassword],
605 >                                         Pos('=', Params[IndexOfPassword]) + 1, {mbcs ok}
606 >                                         Length(Params[IndexOfPassword]));
607 >    result := IBGUIInterface.ServerLoginDialog(aServerName, Username, Password);
608 >    if result then
609 >    begin
610 >      IndexOfPassword := IndexOfSPBConst(isc_spb_password);
611 >      if IndexOfUser = -1 then
612 >        Params.Add(GetSPBConstName(isc_spb_user_name) + '=' + Username)
613 >      else
614 >        Params[IndexOfUser] := GetSPBConstName(isc_spb_user_name) +
615 >                                 '=' + Username;
616 >      if IndexOfPassword = -1 then
617 >        Params.Add(GetSPBConstName(isc_spb_password) + '=' + Password)
618 >      else
619 >        Params[IndexOfPassword] := GetSPBConstName(isc_spb_password) +
620 >                                     '=' + Password;
621 >    end
622 >  end
623 >  else
624 >    IBError(ibxeNoLoginDialog,[]);
625 > end;
626 >
627 > procedure TIBCustomService.CheckActive;
628 > begin
629 >  if FStreamedActive and (not Active) then
630 >    Loaded;
631 >  if FService = nil then
632 >    IBError(ibxeServiceActive, [nil]);
633 > end;
634 >
635 > procedure TIBCustomService.CheckInactive;
636 > begin
637 >  if FService <> nil then
638 >    IBError(ibxeServiceInActive, [nil]);
639 > end;
640 >
641 > procedure TIBCustomService.HandleException(Sender: TObject);
642 > var aParent: TComponent;
643 > begin
644 >  aParent := Owner;
645 >  while aParent <> nil do
646 >  begin
647 >    if aParent is TCustomApplication then
648 >    begin
649 >      TCustomApplication(aParent).HandleException(Sender);
650 >      Exit;
651 >    end;
652 >    aParent := aParent.Owner;
653 >  end;
654 >  SysUtils.ShowException(ExceptObject,ExceptAddr);
655 > end;
656 >
657 > constructor TIBCustomService.Create(AOwner: TComponent);
658 > begin
659 >  inherited Create(AOwner);
660 >  FserverName := '';
661 >  FParams := TStringList.Create;
662 >  FParamsChanged := True;
663 >  TStringList(FParams).OnChange := ParamsChange;
664 >  TStringList(FParams).OnChanging := ParamsChanging;
665 >  FLoginPrompt := True;
666 >  FTraceFlags := [];
667 >  FService := nil;
668 >  FSRB := nil;
669 >  FSPB := nil;
670 >  FServiceQueryResults := nil;
671 >  FProtocol := Local;
672 >  if (AOwner <> nil) and
673 >     (AOwner is TCustomApplication) and
674 >     TCustomApplication(AOwner).ConsoleApplication then
675 >    LoginPrompt := false;
676 > end;
677 >
678 > destructor TIBCustomService.Destroy;
679 > begin
680 >  if FService <> nil then
681 >      Detach;
682 >  FSRB := nil;
683 >  FSPB := nil;
684 >  FParams.Free;
685 >  FServiceQueryResults := nil;
686 >  inherited Destroy;
687 > end;
688 >
689 > procedure TIBCustomService.Detach;
690 > begin
691 >  CheckActive;
692 >  FService.Detach;
693 >  FService := nil;
694 >  MonitorHook.ServiceDetach(Self);
695 > end;
696 >
697 > function TIBCustomService.GetActive: Boolean;
698 > begin
699 >  result := FService <> nil;
700 > end;
701 >
702 > function TIBCustomService.GetServiceParamBySPB(const Idx: Integer): String;
703 > var
704 >  ConstIdx, EqualsIdx: Integer;
705 > begin
706 >  if (Idx > 0) and (Idx <= isc_spb_last_spb_constant) then
707 >  begin
708 >    ConstIdx := IndexOfSPBConst(Idx);
709 >    if ConstIdx = -1 then
710 >      result := ''
711 >    else
712 >    begin
713 >      result := Params[ConstIdx];
714 >      EqualsIdx := Pos('=', result); {mbcs ok}
715 >      if EqualsIdx = 0 then
716 >        result := ''
717 >      else
718 >        result := Copy(result, EqualsIdx + 1, Length(result));
719 >    end;
720 >  end
721 >  else
722 >    result := '';
723 > end;
724 >
725 > function TIBCustomService.GetSQPB: ISQPB;
726 > begin
727 >  CheckActive;
728 >  if FSQPB = nil then
729 >    FSQPB := FService.AllocateSQPB;
730 >  Result := FSQPB;
731 > end;
732 >
733 > function TIBCustomService.GetSRB: ISRB;
734 > begin
735 >  CheckActive;
736 >  if FSRB = nil then
737 >    FSRB := FService.AllocateSRB;
738 >  Result := FSRB;
739 > end;
740 >
741 > procedure TIBCustomService.InternalServiceQuery;
742 > begin
743 >  FServiceQueryResults := FService.Query(FSQPB,FSRB);
744 >  FSQPB := nil;
745 >  FSRB := nil;
746 >  MonitorHook.ServiceQuery(Self);
747 > end;
748 >
749 > procedure TIBCustomService.SetActive(const Value: Boolean);
750 > begin
751 >  if csReading in ComponentState then
752 >    FStreamedActive := Value
753 >  else
754 >    if Value <> Active then
755 >    begin
756 >      if Value then
757 >        Attach
758 >      else
759 >        Detach;
760 >    end
761 >   else if Value then
762 >   begin
763 >     FService.Detach;
764 >     FService.Attach;
765 >   end;
766 > end;
767 >
768 > procedure TIBCustomService.SetParams(const Value: TStrings);
769 > begin
770 >  FParams.Assign(Value);
771 > end;
772 >
773 > procedure TIBCustomService.SetServerName(const Value: string);
774 > begin
775 >  if FServerName <> Value then
776 >  begin
777 >    CheckInactive;
778 >    FServerName := Value;
779 >  end;
780 > end;
781 >
782 > procedure TIBCustomService.SetProtocol(const Value: TProtocol);
783 > begin
784 >  if FProtocol <> Value then
785 >  begin
786 >    CheckInactive;
787 >    FProtocol := Value;
788 >    if (Value = Local) then
789 >      FServerName := '';
790 >  end;
791 > end;
792 >
793 > procedure TIBCustomService.SetService(AValue: IServiceManager);
794 > begin
795 >  if FService = AValue then Exit;
796 >  FService := AValue;
797 >  if AValue <> nil then
798 >    FServerName := FService.getServerName;
799 > end;
800 >
801 > procedure TIBCustomService.SetServiceParamBySPB(const Idx: Integer;
802 >  const Value: String);
803 > var
804 >  ConstIdx: Integer;
805 > begin
806 >  ConstIdx := IndexOfSPBConst(Idx);
807 >  if (Value = '') then
808 >  begin
809 >    if ConstIdx <> -1 then
810 >      Params.Delete(ConstIdx);
811 >  end
812 >  else
813 >  begin
814 >    if (ConstIdx = -1) then
815 >      Params.Add(GetSPBConstName(Idx) + '=' + Value)
816 >    else
817 >      Params[ConstIdx] := GetSPBConstName(Idx) + '=' + Value;
818 >  end;
819 > end;
820 >
821 > function TIBCustomService.IndexOfSPBConst(action: byte): Integer;
822 > var
823 >  i,  pos_of_str: Integer;
824 >  st: string;
825 > begin
826 >  result := -1;
827 >  st := GetSPBConstName(action);
828 >  if st <> '' then
829 >  for i := 0 to Params.Count - 1 do
830 >  begin
831 >    pos_of_str := Pos(st, Params[i]); {mbcs ok}
832 >    if (pos_of_str = 1) or (pos_of_str = Length(SPBPrefix) + 1) then
833 >    begin
834 >      result := i;
835 >      break;
836 >    end;
837 >  end;
838 > end;
839 >
840 > function TIBCustomService.GetSPBConstName(action: byte): string;
841 > var i: integer;
842 > begin
843 >  Result := '';
844 >  for i := Low(SPBConstantValues) to High(SPBConstantValues) do
845 >    if SPBConstantValues[i] = action then
846 >    begin
847 >      Result := SPBConstantNames[i];
848 >      break;
849 >    end;
850 > end;
851 >
852 > procedure TIBCustomService.ParamsChange(Sender: TObject);
853 > begin
854 >  FParamsChanged := True;
855 > end;
856 >
857 > procedure TIBCustomService.ParamsChanging(Sender: TObject);
858 > begin
859 >  CheckInactive;
860 > end;
861 >
862 > procedure TIBCustomService.CheckServerName;
863 > begin
864 >  if (FServerName = '') and (FProtocol <> Local) then
865 >    IBError(ibxeServerNameMissing, [nil]);
866 > end;
867 >
868 > {
869 > * GenerateSPB -
870 > *  Given a string containing a textual representation
871 > *  of the Service parameters, generate a service
872 > *  parameter buffer, and return it .
873 > }
874 > function TIBCustomService.GenerateSPB(sl: TStrings): ISPB;
875 > var
876 >  i, j, SPBVal, SPBServerVal: UShort;
877 >  param_name, param_value: String;
878 > begin
879 >  { The SPB is initially empty, with the exception that
880 >   the SPB version must be the first byte of the string.
881 >  }
882 >  Result := FirebirdAPI.AllocateSPB;
883 >
884 >  { Iterate through the textual service parameters, constructing
885 >   a SPB on-the-fly }
886 >  if sl.Count > 0 then
887 >  for i := 0 to sl.Count - 1 do
888 >  begin
889 >   { Get the parameter's name and value from the list,
890 >     and make sure that the name is all lowercase with
891 >     no leading 'isc_spb_' prefix }
892 >    if (Trim(sl.Names[i]) = '') then continue;
893 >    param_name := LowerCase(sl.Names[i]); {mbcs ok}
894 >    param_value := Copy(sl[i], Pos('=', sl[i]) + 1, Length(sl[i])); {mbcs ok}
895 >    if (Pos(SPBPrefix, param_name) = 1) then {mbcs ok}
896 >      Delete(param_name, 1, Length(SPBPrefix));
897 >    { We want to translate the parameter name to some integer
898 >      value. We do this by scanning through a list of known
899 >      service parameter names (SPBConstantNames, defined above). }
900 >    SPBVal := 0;
901 >    SPBServerVal := 0;
902 >    { Find the parameter }
903 >    for j := 1 to isc_spb_last_spb_constant do
904 >      if (param_name = SPBConstantNames[j]) then
905 >      begin
906 >        SPBVal := j;
907 >        SPBServerVal := SPBConstantValues[j];
908 >        break;
909 >      end;
910 >    case SPBServerVal of
911 >      isc_spb_user_name, isc_spb_password:
912 >        Result.Add(SPBServerVal).AsString := param_value;
913 >      else
914 >      begin
915 >        if GetSPBConstName(SPBServerVal) <> '' then
916 >          IBError(ibxeSPBConstantNotSupported,
917 >                   [GetSPBConstName(SPBServerVal)])
918 >        else
919 >          IBError(ibxeSPBConstantUnknown, [SPBServerVal]);
920 >      end;
921 >    end;
922 >  end;
923 > end;
924 >
925 > { TIBServerProperties }
926 > constructor TIBServerProperties.Create(AOwner: TComponent);
927 > begin
928 >  inherited Create(AOwner);
929 >  FDatabaseInfo := TDatabaseInfo.Create;
930 >  FLicenseInfo := TLicenseInfo.Create;
931 >  FLicenseMaskInfo := TLicenseMaskInfo.Create;
932 >  FVersionInfo := TVersionInfo.Create;
933 >  FConfigParams := TConfigParams.Create;
934 > end;
935 >
936 > destructor TIBServerProperties.Destroy;
937 > begin
938 >  FDatabaseInfo.Free;
939 >  FLicenseInfo.Free;
940 >  FLicenseMaskInfo.Free;
941 >  FVersionInfo.Free;
942 >  FConfigParams.Free;
943 >  inherited Destroy;
944 > end;
945 >
946 > procedure TIBServerProperties.Fetch;
947 > begin
948 >  if (Database in Options) then
949 >    FetchDatabaseInfo;
950 >  if (License in Options) then
951 >    FetchLicenseInfo;
952 >  if (LicenseMask in Options) then
953 >    FetchLicenseMaskInfo;
954 >  if (ConfigParameters in Options) then
955 >    FetchConfigParams;
956 >  if (Version in Options) then
957 >    FetchVersionInfo;
958 > end;
959 >
960 > procedure TIBServerProperties.FetchConfigParams;
961 > var
962 >  i, j: Integer;
963 >
964 > begin
965 >  SRB.Add(isc_info_svc_get_config);
966 >  SRB.Add(isc_info_svc_get_env);
967 >  SRB.Add(isc_info_svc_get_env_lock);
968 >  SRB.Add(isc_info_svc_get_env_msg);
969 >  SRB.Add(isc_info_svc_user_dbpath);
970 >
971 >  InternalServiceQuery;
972 >
973 >  for i := 0 to FServiceQueryResults.Count - 1 do
974 >  with FServiceQueryResults[i] do
975 >  begin
976 >    case getItemType of
977 >      isc_info_svc_get_config:
978 >      begin
979 >        SetLength (FConfigParams.ConfigFileData.ConfigFileValue, Count);
980 >        SetLength (FConfigParams.ConfigFileData.ConfigFileKey, Count);
981 >
982 >        for j := 0 to Count - 1 do
983 >        begin
984 >          FConfigParams.ConfigFileData.ConfigFileKey[j] := getItemType;
985 >          FConfigParams.ConfigFileData.ConfigFileValue[j] := AsInteger;
986 >        end;
987 >      end;
988 >
989 >      isc_info_svc_get_env:
990 >        FConfigParams.BaseLocation := AsString;
991 >
992 >      isc_info_svc_get_env_lock:
993 >        FConfigParams.LockFileLocation := AsString;
994 >
995 >      isc_info_svc_get_env_msg:
996 >        FConfigParams.MessageFileLocation := AsString;
997 >
998 >      isc_info_svc_user_dbpath:
999 >        FConfigParams.SecurityDatabaseLocation := AsString;
1000 >
1001 >      else
1002 >        IBError(ibxeOutputParsingError, [getItemType]);
1003 >    end;
1004 >  end;
1005 > end;
1006 >
1007 > procedure TIBServerProperties.FetchDatabaseInfo;
1008 > var
1009 >  i,j: Integer;
1010 > begin
1011 >  SRB.Add(isc_info_svc_svr_db_info);
1012 >  InternalServiceQuery;
1013 >
1014 >  SetLength(FDatabaseInfo.DbName,0);
1015 >  for i := 0 to FServiceQueryResults.Count - 1 do
1016 >  with FServiceQueryResults[i] do
1017 >  begin
1018 >    case getItemType of
1019 >      isc_info_svc_svr_db_info:
1020 >        for j := 0 to FServiceQueryResults[i].Count - 1 do
1021 >        with FServiceQueryResults[i][j] do
1022 >        case getItemType of
1023 >        isc_spb_num_att:
1024 >          FDatabaseInfo.NoOfAttachments := AsInteger;
1025 >
1026 >        isc_spb_num_db:
1027 >          FDatabaseInfo.NoOfDatabases := AsInteger;
1028 >
1029 >        isc_spb_dbname:
1030 >          begin
1031 >            SetLength(FDatabaseInfo.DbName,length(FDatabaseInfo.DbName)+1);
1032 >            FDatabaseInfo.DbName[length(FDatabaseInfo.DbName)-1] := AsString;
1033 >          end;
1034 >        else
1035 >          IBError(ibxeOutputParsingError, [getItemType]);
1036 >        end;
1037 >      else
1038 >        IBError(ibxeOutputParsingError, [getItemType]);
1039 >    end;
1040 > end;
1041 > end;
1042 >
1043 > procedure TIBServerProperties.FetchLicenseInfo;
1044 > var
1045 >  i,j : Integer;
1046 > begin
1047 >  SRB.Add(isc_info_svc_get_license);
1048 >  SRB.Add(isc_info_svc_get_licensed_users);
1049 >  InternalServiceQuery;
1050 >
1051 >  SetLength(FLicenseInfo.key, 0);
1052 >  SetLength(FLicenseInfo.id, 0);
1053 >  SetLength(FLicenseInfo.desc, 0);
1054 >
1055 >  for i := 0 to FServiceQueryResults.Count - 1 do
1056 >  with FServiceQueryResults[i] do
1057 >  begin
1058 >    case getItemType of
1059 >      isc_info_svc_get_license:
1060 >        begin
1061 >          SetLength(FLicenseInfo.key, Count);
1062 >          SetLength(FLicenseInfo.id, Count);
1063 >          SetLength(FLicenseInfo.desc, Count);
1064 >
1065 >          for j := 0 to Count -1 do
1066 >          with Items[j] do
1067 >          case getItemType of
1068 >             isc_spb_lic_id:
1069 >                FLicenseInfo.id[j] := AsString;
1070 >
1071 >             isc_spb_lic_key:
1072 >                FLicenseInfo.key[j] := AsString;
1073 >
1074 >             isc_spb_lic_desc:
1075 >               FLicenseInfo.desc[j] := AsString;
1076 >          else
1077 >            IBError(ibxeOutputParsingError, [getItemType]);
1078 >          end;
1079 >        end;
1080 >      else
1081 >        IBError(ibxeOutputParsingError, [getItemType]);
1082 >    end;
1083 >  end;
1084 > end;
1085 >
1086 > procedure TIBServerProperties.FetchLicenseMaskInfo();
1087 > var
1088 >  i : Integer;
1089 > begin
1090 >  SRB.Add(isc_info_svc_get_license_mask);
1091 >  SRB.Add(isc_info_svc_capabilities);
1092 >  InternalServiceQuery;
1093 >
1094 >  for i := 0 to FServiceQueryResults.Count - 1 do
1095 >  with FServiceQueryResults[i] do
1096 >  begin
1097 >    case getItemType of
1098 >      isc_info_svc_get_license_mask:
1099 >        FLicenseMaskInfo.LicenseMask := AsInteger;
1100 >      isc_info_svc_capabilities:
1101 >        FLicenseMaskInfo.CapabilityMask := AsInteger;
1102 >      else
1103 >        IBError(ibxeOutputParsingError, [getItemType]);
1104 >    end;
1105 >  end;
1106 > end;
1107 >
1108 >
1109 > procedure TIBServerProperties.FetchVersionInfo;
1110 > var
1111 >  i : Integer;
1112 > begin
1113 >  SRB.Add(isc_info_svc_version);
1114 >  SRB.Add(isc_info_svc_server_version);
1115 >  SRB.Add(isc_info_svc_implementation);
1116 >  InternalServiceQuery;
1117 >
1118 >  for i := 0 to FServiceQueryResults.Count - 1 do
1119 >  with FServiceQueryResults[i] do
1120 >  begin
1121 >    case getItemType of
1122 >      isc_info_svc_version:
1123 >        FVersionInfo.ServiceVersion := AsInteger;
1124 >      isc_info_svc_server_version:
1125 >        FVersionInfo.ServerVersion := AsString;
1126 >      isc_info_svc_implementation:
1127 >        FVersionInfo.ServerImplementation := AsString;
1128 >      else
1129 >        IBError(ibxeOutputParsingError, [getItemType]);
1130 >    end;
1131 >  end;
1132 > end;
1133 >
1134 > { TIBControlService }
1135 >
1136 > procedure TIBControlService.SetServiceStartOptions;
1137 > begin
1138 >
1139 > end;
1140 >
1141 > function TIBControlService.GetIsServiceRunning: Boolean;
1142 > begin
1143 >  SRB.Add(isc_info_svc_running);
1144 >  InternalServiceQuery;
1145 >
1146 >  Result := (FServiceQueryResults.Count > 0) and
1147 >             (FServiceQueryResults[0].getItemType = isc_info_svc_running) and
1148 >              (FServiceQueryResults[0].AsInteger = 1);
1149 > end;
1150 >
1151 > procedure TIBControlService.CheckServiceNotRunning;
1152 > begin
1153 >  if IsServiceRunning then
1154 >    IBError(ibxeServiceRunning,[nil]);
1155 > end;
1156 >
1157 > constructor TIBControlService.Create(AOwner: TComponent);
1158 > begin
1159 >  inherited create(AOwner);
1160 >  FSRB := nil;
1161 >  FSPB := nil;
1162 > end;
1163 >
1164 > procedure TIBControlService.InternalServiceStart;
1165 > begin
1166 >  if SRB = nil then
1167 >    IBError(ibxeStartParamsError, [nil]);
1168 >
1169 >  try
1170 >    FService.Start(SRB);
1171 >  finally
1172 >    FSRB := nil;
1173 >  end;
1174 >  MonitorHook.ServiceStart(Self);
1175 > end;
1176 >
1177 > procedure TIBControlService.ServiceStart;
1178 > begin
1179 >  CheckActive;
1180 >  CheckServiceNotRunning;
1181 >  SetServiceStartOptions;
1182 >  InternalServiceStart;
1183 > end;
1184 >
1185 > { TIBConfigService }
1186 >
1187 > procedure TIBConfigService.ServiceStart;
1188 > begin
1189 >  IBError(ibxeUseSpecificProcedures, [nil]);
1190 > end;
1191 >
1192 > procedure TIBConfigService.ActivateShadow;
1193 > begin
1194 >  SRB.Add(isc_action_svc_properties);
1195 >  SRB.Add(isc_spb_dbname).AsString :=  FDatabaseName;
1196 >  SRB.Add(isc_spb_options).AsInteger := isc_spb_prp_activate;
1197 >  InternalServiceStart;
1198 > end;
1199 >
1200 > procedure TIBConfigService.BringDatabaseOnline;
1201 > begin
1202 >  SRB.Add(isc_action_svc_properties);
1203 >  SRB.Add(isc_spb_dbname).AsString :=  FDatabaseName;
1204 >  SRB.Add(isc_spb_options).AsInteger := isc_spb_prp_db_online;
1205 >  InternalServiceStart;
1206 > end;
1207 >
1208 > procedure TIBConfigService.SetAsyncMode(Value: Boolean);
1209 > begin
1210 >  SRB.Add(isc_action_svc_properties);
1211 >  SRB.Add(isc_spb_dbname).AsString :=  FDatabaseName;
1212 >  with SRB.Add(isc_spb_prp_write_mode) do
1213 >  if Value then
1214 >    AsInteger := isc_spb_prp_wm_async
1215 >  else
1216 >    AsInteger := isc_spb_prp_wm_sync;
1217 >  InternalServiceStart;
1218 > end;
1219 >
1220 > procedure TIBConfigService.SetDatabaseName(const Value: string);
1221 > begin
1222 >  FDatabaseName := Value;
1223 > end;
1224 >
1225 > procedure TIBConfigService.SetPageBuffers(Value: Integer);
1226 > begin
1227 >  SRB.Add(isc_action_svc_properties);
1228 >  SRB.Add(isc_spb_dbname).AsString :=  FDatabaseName;
1229 >  SRB.Add(isc_spb_prp_page_buffers).AsInteger := Value;
1230 >  InternalServiceStart;
1231 > end;
1232 >
1233 > procedure TIBConfigService.SetReadOnly(Value: Boolean);
1234 > begin
1235 >  SRB.Add(isc_action_svc_properties);
1236 >  SRB.Add(isc_spb_dbname).AsString :=  FDatabaseName;
1237 >  with SRB.Add(isc_spb_prp_access_mode) do
1238 >  if Value then
1239 >    AsInteger := isc_spb_prp_am_readonly
1240 >  else
1241 >    AsInteger := isc_spb_prp_am_readwrite;
1242 >  InternalServiceStart;
1243 > end;
1244 >
1245 > procedure TIBConfigService.SetReserveSpace(Value: Boolean);
1246 > begin
1247 >  SRB.Add(isc_action_svc_properties);
1248 >  SRB.Add(isc_spb_dbname).AsString :=  FDatabaseName;
1249 >  with SRB.Add(isc_spb_prp_reserve_space) do
1250 >  if Value then
1251 >    AsInteger := isc_spb_prp_res
1252 >  else
1253 >    AsInteger := isc_spb_prp_res_use_full;
1254 >  InternalServiceStart;
1255 > end;
1256 >
1257 > procedure TIBConfigService.SetSweepInterval(Value: Integer);
1258 > begin
1259 >  SRB.Add(isc_action_svc_properties);
1260 >  SRB.Add(isc_spb_dbname).AsString :=  FDatabaseName;
1261 >  SRB.Add(isc_spb_prp_sweep_interval).AsInteger := Value;
1262 >  InternalServiceStart;
1263 > end;
1264 >
1265 > procedure TIBConfigService.SetDBSqlDialect(Value: Integer);
1266 > begin
1267 >  SRB.Add(isc_action_svc_properties);
1268 >  SRB.Add(isc_spb_dbname).AsString :=  FDatabaseName;
1269 >  SRB.Add(isc_spb_prp_set_sql_dialect).AsInteger := Value;
1270 >  InternalServiceStart;
1271 > end;
1272 >
1273 > procedure TIBConfigService.ShutdownDatabase(Options: TShutdownMode;
1274 >  Wait: Integer);
1275 > begin
1276 >  SRB.Add(isc_action_svc_properties);
1277 >  SRB.Add(isc_spb_dbname).AsString :=  FDatabaseName;
1278 >  if (Options = Forced) then
1279 >  SRB.Add(isc_spb_prp_shutdown_db).AsInteger := Wait
1280 >  else if (Options = DenyTransaction) then
1281 >    SRB.Add(isc_spb_prp_deny_new_transactions).AsInteger := Wait
1282 >  else
1283 >    SRB.Add(isc_spb_prp_deny_new_attachments).AsInteger := Wait;
1284 >  InternalServiceStart;
1285 > end;
1286 >
1287 >
1288 > { TIBStatisticalService }
1289 >
1290 > procedure TIBStatisticalService.SetDatabaseName(const Value: string);
1291 > begin
1292 >  FDatabaseName := Value;
1293 > end;
1294 >
1295 > procedure TIBStatisticalService.SetServiceStartOptions;
1296 > var param: integer;
1297 > begin
1298 >  if FDatabaseName = '' then
1299 >    IBError(ibxeStartParamsError, [nil]);
1300 >
1301 >  param := 0;
1302 >  if (DataPages in Options) then
1303 >    param := param or isc_spb_sts_data_pages;
1304 > {  if (DbLog in Options) then
1305 >    param := param or isc_spb_sts_db_log; -- removed from Firebird 2}
1306 >  if (HeaderPages in Options) then
1307 >    param := param or isc_spb_sts_hdr_pages;
1308 >  if (IndexPages in Options) then
1309 >    param := param or isc_spb_sts_idx_pages;
1310 >  if (SystemRelations in Options) then
1311 >    param := param or isc_spb_sts_sys_relations;
1312 >  Action := isc_action_svc_db_stats;
1313 >  SRB.Add(isc_action_svc_db_stats);
1314 >  SRB.Add(isc_spb_dbname).AsString := FDatabaseName;
1315 >  SRB.Add(isc_spb_options).AsInteger := param;
1316 > end;
1317 >
1318 > { TIBBackupService }
1319 > procedure TIBBackupService.SetServiceStartOptions;
1320 > var
1321 >  param, i: Integer;
1322 >  value: String;
1323 > begin
1324 >  if FDatabaseName = '' then
1325 >    IBError(ibxeStartParamsError, [nil]);
1326 >  param := 0;
1327 >  if (IgnoreChecksums in Options) then
1328 >    param := param or isc_spb_bkp_ignore_checksums;
1329 >  if (IgnoreLimbo in Options) then
1330 >    param := param or isc_spb_bkp_ignore_limbo;
1331 >  if (MetadataOnly in Options) then
1332 >    param := param or isc_spb_bkp_metadata_only;
1333 >  if (NoGarbageCollection in Options) then
1334 >    param := param or isc_spb_bkp_no_garbage_collect;
1335 >  if (OldMetadataDesc in Options) then
1336 >    param := param or isc_spb_bkp_old_descriptions;
1337 >  if (NonTransportable in Options) then
1338 >    param := param or isc_spb_bkp_non_transportable;
1339 >  if (ConvertExtTables in Options) then
1340 >    param := param or isc_spb_bkp_convert;
1341 >  Action := isc_action_svc_backup;
1342 >  SRB.Add(isc_action_svc_backup);
1343 >  SRB.Add(isc_spb_dbname).AsString := FDatabaseName;
1344 >  SRB.Add(isc_spb_options).AsInteger := param;
1345 >  if Verbose  and (BackupFileLocation = flServerSide) then
1346 >    SRB.Add(isc_spb_verbose);
1347 >  if FBlockingFactor > 0 then
1348 >    SRB.Add(isc_spb_bkp_factor).AsInteger := FBlockingFactor;
1349 >  if BackupFileLocation = flServerSide then
1350 >  for i := 0 to FBackupFile.Count - 1 do
1351 >  begin
1352 >    if (Trim(FBackupFile[i]) = '') then
1353 >      continue;
1354 >    if (Pos('=', FBackupFile[i]) <> 0) then
1355 >    begin {mbcs ok}
1356 >      SRB.Add(isc_spb_bkp_file).AsString := FBackupFile.Names[i];
1357 >      value := Copy(FBackupFile[i], Pos('=', FBackupFile[i]) + 1, Length(FBackupFile.Names[i])); {mbcs ok}
1358 >      SRB.Add(isc_spb_bkp_length).AsInteger := StrToInt(value);;
1359 >    end
1360 >    else
1361 >      SRB.Add(isc_spb_bkp_file).AsString := FBackupFile[i];
1362 >  end
1363 >  else
1364 >  SRB.Add(isc_spb_bkp_file).AsString := 'stdout';
1365 > end;
1366 >
1367 > constructor TIBBackupService.Create(AOwner: TComponent);
1368 > begin
1369 >  inherited Create(AOwner);
1370 >  FBackupFile := TStringList.Create;
1371 > end;
1372 >
1373 > destructor TIBBackupService.Destroy;
1374 > begin
1375 >  FBackupFile.Free;
1376 >  inherited Destroy;
1377 > end;
1378 >
1379 > procedure TIBBackupService.SetBackupFile(const Value: TStrings);
1380 > begin
1381 >  FBackupFile.Assign(Value);
1382 > end;
1383 >
1384 > { TIBRestoreService }
1385 >
1386 > procedure TIBRestoreService.SetServiceStartOptions;
1387 > var
1388 >  param, i: Integer;
1389 >  value: String;
1390 > begin
1391 >  param := 0;
1392 >  if (DeactivateIndexes in Options) then
1393 >    param := param or isc_spb_res_deactivate_idx;
1394 >  if (NoShadow in Options) then
1395 >    param := param or isc_spb_res_no_shadow;
1396 >  if (NoValidityCheck in Options) then
1397 >    param := param or isc_spb_res_no_validity;
1398 >  if (OneRelationAtATime in Options) then
1399 >    param := param or isc_spb_res_one_at_a_time;
1400 >  if (Replace in Options) then
1401 >    param := param or isc_spb_res_replace;
1402 >  if (CreateNewDB in Options) then
1403 >    param := param or isc_spb_res_create;
1404 >  if (UseAllSpace in Options) then
1405 >    param := param or isc_spb_res_use_all_space;
1406 >  Action := isc_action_svc_restore;
1407 >  SRB.Add(isc_action_svc_restore);
1408 >  SRB.Add(isc_spb_options).AsInteger := param;
1409 >  if Verbose then
1410 >    SRB.Add(isc_spb_verbose);
1411 >  if FPageSize > 0 then
1412 >    SRB.Add(isc_spb_res_page_size).AsInteger := FPageSize;
1413 >  if FPageBuffers > 0 then
1414 >    SRB.Add(isc_spb_res_buffers).AsInteger := FPageBuffers;
1415 >  if BackupFileLocation = flServerSide then
1416 >  for i := 0 to FBackupFile.Count - 1 do
1417 >  begin
1418 >    if (Trim(FBackupFile[i]) = '') then continue;
1419 >    if (Pos('=', FBackupFile[i]) <> 0) then  {mbcs ok}
1420 >    begin
1421 >      SRB.Add(isc_spb_bkp_file).AsString := FBackupFile.Names[i];
1422 >      value := Copy(FBackupFile[i], Pos('=', FBackupFile[i]) + 1, Length(FBackupFile.Names[i])); {mbcs ok}
1423 >      SRB.Add(isc_spb_bkp_length).AsInteger := StrToInt(value);;
1424 >    end
1425 >    else
1426 >      SRB.Add(isc_spb_bkp_file).AsString := FBackupFile[i];
1427 >  end
1428 >  else
1429 >    SRB.Add(isc_spb_bkp_file).AsString := 'stdin';
1430 >
1431 >  for i := 0 to FDatabaseName.Count - 1 do
1432 >  begin
1433 >    if (Trim(FDatabaseName[i]) = '') then continue;
1434 >    if (Pos('=', FDatabaseName[i]) <> 0) then {mbcs ok}
1435 >    begin
1436 >      SRB.Add(isc_spb_dbname).AsString := FDatabaseName.Names[i];
1437 >      value := Copy(FDatabaseName[i], Pos('=', FDatabaseName[i]) + 1, Length(FDatabaseName[i])); {mbcs ok}
1438 >      SRB.Add(isc_spb_res_length).AsInteger :=  StrToInt(value);
1439 >    end
1440 >    else
1441 >      SRB.Add(isc_spb_dbname).AsString := FDatabaseName[i];
1442 >  end;
1443 > end;
1444 >
1445 > constructor TIBRestoreService.Create(AOwner: TComponent);
1446 > begin
1447 >  inherited Create(AOwner);
1448 >  FDatabaseName := TStringList.Create;
1449 >  FBackupFile := TStringList.Create;
1450 >  Include (FOptions, CreateNewDB);
1451 > end;
1452 >
1453 > destructor TIBRestoreService.Destroy;
1454 > begin
1455 >  FDatabaseName.Free;
1456 >  FBackupFile.Free;
1457 >  inherited Destroy;
1458 > end;
1459 >
1460 > function TIBRestoreService.SendNextChunk(stream: TStream; var line: String
1461 >  ): integer;
1462 > var
1463 >  i: Integer;
1464 > begin
1465 >  Result := 0;
1466 >  line := '';
1467 >  if (FEof = True) then
1468 >    exit;
1469 >
1470 >  if (FAction = 0) then
1471 >    IBError(ibxeQueryParamsError, [nil]);
1472 >
1473 >  SRB.Add(isc_info_svc_line);
1474 >  SRB.Add(isc_info_svc_stdin);
1475 >
1476 >  SQPB.Add(isc_info_svc_timeout).AsInteger := 1;
1477 >  if FSendBytes > 0 then
1478 >    Result := SQPB.Add(isc_info_svc_line).CopyFrom(stream,FSendBytes);
1479 >  InternalServiceQuery;
1480 >
1481 >  FSendBytes := 0;
1482 >  for i := 0 to FServiceQueryResults.Count - 1 do
1483 >  with FServiceQueryResults[i] do
1484 >  begin
1485 >    case getItemType of
1486 >      isc_info_svc_line:
1487 >         line := AsString;
1488 >
1489 >      isc_info_svc_stdin:
1490 >        FSendBytes := AsInteger;
1491 >
1492 >      isc_info_svc_timeout,
1493 >      isc_info_data_not_ready:
1494 >        {ignore};
1495 >    else
1496 >      IBError(ibxeOutputParsingError, [getItemType]);
1497 >    end;
1498 >  end;
1499 >  FEOF := (FSendBytes = 0) and (line = '');
1500 > end;
1501 >
1502 > procedure TIBRestoreService.SetBackupFile(const Value: TStrings);
1503 > begin
1504 >  FBackupFile.Assign(Value);
1505 > end;
1506 >
1507 > procedure TIBRestoreService.SetDatabaseName(const Value: TStrings);
1508 > begin
1509 >  FDatabaseName.Assign(Value);
1510 > end;
1511 >
1512 > { TIBValidationService }
1513 > constructor TIBValidationService.Create(AOwner: TComponent);
1514 > begin
1515 >  inherited Create(AOwner);
1516 > end;
1517 >
1518 > destructor TIBValidationService.Destroy;
1519 > var
1520 >  i : Integer;
1521 > begin
1522 >  for i := 0 to High(FLimboTransactionInfo) do
1523 >    FLimboTransactionInfo[i].Free;
1524 >  FLimboTransactionInfo := nil;
1525 >  inherited Destroy;
1526 > end;
1527 >
1528 > procedure TIBValidationService.FetchLimboTransactionInfo;
1529 >
1530 >  procedure NextLimboTransaction(index: integer);
1531 >  begin
1532 >    SetLength(FLimboTransactionInfo, index+1);
1533 >    FLimboTransactionInfo[index] := TLimboTransactionInfo.Create;
1534 >    { if no advice commit as default }
1535 >    FLimboTransactionInfo[index].Advise := UnknownAdvise;
1536 >    FLimboTransactionInfo[index].Action:= CommitAction;
1537 >  end;
1538 >
1539 > var
1540 >  i,j, k: Integer;
1541 >  Value: Char;
1542 > begin
1543 >  for i := 0 to High(FLimboTransactionInfo) do
1544 >    FLimboTransactionInfo[i].Free;
1545 >  SetLength(FLimboTransactionInfo,0);
1546 >
1547 >  SRB.Add(isc_info_svc_limbo_trans);
1548 >  InternalServiceQuery;
1549 >
1550 >  k := -1;
1551 >  for i := 0 to FServiceQueryResults.Count - 1 do
1552 >  with FServiceQueryResults[i] do
1553 >  case getItemType of
1554 >  isc_info_svc_limbo_trans:
1555 >    begin
1556 >      if FServiceQueryResults[i].Count = 0 then continue;
1557 >      NextLimboTransaction(0);
1558 >      for j := 0 to FServiceQueryResults[i].Count - 1 do
1559 >      begin
1560 >        with FServiceQueryResults[i][j] do
1561 >        begin
1562 >          case getItemType of
1563 >            isc_spb_single_tra_id:
1564 >            begin
1565 >              Inc(k);
1566 >              if k > 0 then
1567 >                NextLimboTransaction(k);
1568 >              FLimboTransactionInfo[k].MultiDatabase := False;
1569 >              FLimboTransactionInfo[k].ID := AsInteger;
1570 >            end;
1571 >
1572 >            isc_spb_multi_tra_id:
1573 >            begin
1574 >              Inc(k);
1575 >              if k > 0 then
1576 >                NextLimboTransaction(k);
1577 >              FLimboTransactionInfo[k].MultiDatabase := True;
1578 >              FLimboTransactionInfo[k].ID := AsInteger;
1579 >            end;
1580 >
1581 >            isc_spb_tra_host_site:
1582 >              FLimboTransactionInfo[k].HostSite := AsString;
1583 >
1584 >            isc_spb_tra_state:
1585 >              case AsByte of
1586 >                isc_spb_tra_state_limbo:
1587 >                  FLimboTransactionInfo[k].State := LimboState;
1588 >
1589 >                isc_spb_tra_state_commit:
1590 >                  FLimboTransactionInfo[k].State := CommitState;
1591 >
1592 >                isc_spb_tra_state_rollback:
1593 >                  FLimboTransactionInfo[k].State := RollbackState;
1594 >
1595 >                else
1596 >                  FLimboTransactionInfo[k].State := UnknownState;
1597 >              end;
1598 >
1599 >            isc_spb_tra_remote_site:
1600 >              FLimboTransactionInfo[k].RemoteSite := AsString;
1601 >
1602 >            isc_spb_tra_db_path:
1603 >              FLimboTransactionInfo[k].RemoteDatabasePath := AsString;
1604 >
1605 >            isc_spb_tra_advise:
1606 >            with FLimboTransactionInfo[k] do
1607 >            begin
1608 >              case (AsByte) of
1609 >              isc_spb_tra_advise_commit:
1610 >              begin
1611 >                Advise := CommitAdvise;
1612 >                Action:= CommitAction;
1613 >              end;
1614 >
1615 >              isc_spb_tra_advise_rollback:
1616 >              begin
1617 >                Advise := RollbackAdvise;
1618 >                Action := RollbackAction;
1619 >              end;
1620 >
1621 >              else
1622 >                Advise := UnknownAdvise;
1623 >              end;
1624 >            end;
1625 >
1626 >            else
1627 >              IBError(ibxeOutputParsingError, [getItemType]);
1628 >          end;
1629 >        end;
1630 >      end;
1631 >    end;
1632 >  else
1633 >    IBError(ibxeOutputParsingError, [getItemType]);
1634 >  end;
1635 > end;
1636 >
1637 > procedure TIBValidationService.FixLimboTransactionErrors;
1638 > var
1639 >  i: Integer;
1640 > begin
1641 >  SRB.Add(isc_action_svc_repair);
1642 >  SRB.Add(isc_spb_dbname).AsString := FDatabaseName;
1643 >  case FGlobalAction of
1644 >  NoGlobalAction:
1645 >    begin
1646 >      for i := 0 to LimboTransactionInfoCount - 1 do
1647 >      begin
1648 >        if (FLimboTransactionInfo[i].Action = CommitAction) then
1649 >          SRB.Add(isc_spb_rpr_commit_trans).AsInteger :=  FLimboTransactionInfo[i].ID
1650 >        else
1651 >          SRB.Add(isc_spb_rpr_rollback_trans).AsInteger :=  FLimboTransactionInfo[i].ID;
1652 >      end;
1653 >    end;
1654 >
1655 >  CommitGlobal:
1656 >    begin
1657 >      for i := 0 to LimboTransactionInfoCount - 1 do
1658 >        SRB.Add(isc_spb_rpr_commit_trans).AsInteger :=  FLimboTransactionInfo[i].ID;
1659 >    end;
1660 >
1661 >    RollbackGlobal:
1662 >      begin
1663 >        for i := 0 to LimboTransactionInfoCount - 1 do
1664 >          SRB.Add(isc_spb_rpr_rollback_trans).AsInteger :=  FLimboTransactionInfo[i].ID;
1665 >      end;
1666 >
1667 >    RecoverTwoPhaseGlobal:
1668 >    begin
1669 >      for i := 0 to LimboTransactionInfoCount - 1 do
1670 >        SRB.Add(isc_spb_rpr_recover_two_phase).AsInteger :=  FLimboTransactionInfo[i].ID;
1671 >    end;
1672 >  end;
1673 >  InternalServiceStart;
1674 > end;
1675 >
1676 > function TIBValidationService.GetLimboTransactionInfo(index: integer): TLimboTransactionInfo;
1677 > begin
1678 >  if index <= High(FLimboTransactionInfo) then
1679 >    result := FLimboTransactionInfo[index]
1680 >  else
1681 >    result := nil;
1682 > end;
1683 >
1684 > function TIBValidationService.GetLimboTransactionInfoCount: integer;
1685 > begin
1686 >  Result := Length(FLimboTransactionInfo);
1687 > end;
1688 >
1689 > procedure TIBValidationService.SetDatabaseName(const Value: string);
1690 > begin
1691 >  FDatabaseName := Value;
1692 > end;
1693 >
1694 > procedure TIBValidationService.SetServiceStartOptions;
1695 > var
1696 >  param: Integer;
1697 > begin
1698 >  Action := isc_action_svc_repair;
1699 >  if FDatabaseName = '' then
1700 >    IBError(ibxeStartParamsError, [nil]);
1701 >  SRB.Add(isc_action_svc_repair);
1702 >  SRB.Add(isc_spb_dbname).AsString := FDatabaseName;
1703 >  param := 0;
1704 >  if (SweepDB in Options) then
1705 >    param := param or isc_spb_rpr_sweep_db;
1706 >  if (ValidateDB in Options) then
1707 >    param := param or isc_spb_rpr_validate_db;
1708 >
1709 >  if (LimboTransactions in Options) then
1710 >    param := param or isc_spb_rpr_list_limbo_trans;
1711 >  if (CheckDB in Options) then
1712 >    param := param or isc_spb_rpr_check_db;
1713 >  if (IgnoreChecksum in Options) then
1714 >    param := param or isc_spb_rpr_ignore_checksum;
1715 >  if (KillShadows in Options) then
1716 >    param := param or isc_spb_rpr_kill_shadows;
1717 >  if (MendDB in Options) then
1718 >    param := param or isc_spb_rpr_mend_db;
1719 >  if (ValidateFull in Options) then
1720 >  begin
1721 >     param := param or isc_spb_rpr_full;
1722 >     if not (MendDB in Options) then
1723 >       param := param or isc_spb_rpr_validate_db;
1724 >  end;
1725 >  if param > 0 then
1726 >   SRB.Add(isc_spb_options).AsInteger := param;
1727 > end;
1728 >
1729 > { TIBSecurityService }
1730 > constructor TIBSecurityService.Create(AOwner: TComponent);
1731 > begin
1732 >  inherited Create(AOwner);
1733 >  FModifyParams := [];
1734 > end;
1735 >
1736 > destructor TIBSecurityService.Destroy;
1737 > var
1738 >  i : Integer;
1739 > begin
1740 >  for i := 0 to High(FUserInfo) do
1741 >    FUserInfo[i].Free;
1742 >  FUserInfo := nil;
1743 >  inherited Destroy;
1744 > end;
1745 >
1746 > procedure TIBSecurityService.FetchUserInfo;
1747 > var
1748 >  i, j, k: Integer;
1749 > begin
1750 >  SRB.Add(isc_info_svc_get_users);
1751 >  InternalServiceQuery;
1752 >
1753 >  for i := 0 to High(FUserInfo) do
1754 >    FUserInfo[i].Free;
1755 >  for i := 0 to FServiceQueryResults.Count - 1 do
1756 >  with FServiceQueryResults[i] do
1757 >  begin
1758 >    case getItemType of
1759 >    isc_info_svc_get_users:
1760 >      begin
1761 >        SetLength(FUserInfo,1);
1762 >        k := 0;
1763 >        FUserInfo[0] := TUserInfo.Create;
1764 >        FUserInfo[0].UserName := '';
1765 >        for j := 0 to FServiceQueryResults[i].Count - 1 do
1766 >        begin
1767 >          with FServiceQueryResults[i][j] do
1768 >          case getItemType of
1769 >          isc_spb_sec_username:
1770 >            begin
1771 >              if FUserInfo[k].UserName <> '' then
1772 >              begin
1773 >                Inc(k);
1774 >                SetLength(FUserInfo,k+1);
1775 >                if FUserInfo[k] = nil then
1776 >                  FUserInfo[k] := TUserInfo.Create;
1777 >              end;
1778 >              FUserInfo[k].UserName := AsString;
1779 >            end;
1780 >
1781 >          isc_spb_sec_firstname:
1782 >            FUserInfo[k].FirstName := AsString;
1783 >
1784 >          isc_spb_sec_middlename:
1785 >            FUserInfo[k].MiddleName := AsString;
1786 >
1787 >          isc_spb_sec_lastname:
1788 >            FUserInfo[k].LastName := AsString;
1789 >
1790 >          isc_spb_sec_userId:
1791 >            FUserInfo[k].UserId := AsInteger;
1792 >
1793 >          isc_spb_sec_groupid:
1794 >            FUserInfo[k].GroupID := AsInteger;
1795 >
1796 >          else
1797 >            IBError(ibxeOutputParsingError, [getItemType]);
1798 >          end;
1799 >        end;
1800 >      end;
1801 >    else
1802 >      IBError(ibxeOutputParsingError, [getItemType]);
1803 >    end;
1804 >  end;
1805 > end;
1806 >
1807 > function TIBSecurityService.GetUserInfo(Index: Integer): TUserInfo;
1808 > begin
1809 >  if Index <= High(FUSerInfo) then
1810 >    result := FUserInfo[Index]
1811 >  else
1812 >    result := nil;
1813 > end;
1814 >
1815 > function TIBSecurityService.GetUserInfoCount: Integer;
1816 > begin
1817 >  Result := Length(FUserInfo);
1818 > end;
1819 >
1820 > procedure TIBSecurityService.AddUser;
1821 > begin
1822 >  SecurityAction := ActionAddUser;
1823 >  ServiceStart;
1824 > end;
1825 >
1826 > procedure TIBSecurityService.DeleteUser;
1827 > begin
1828 >  SecurityAction := ActionDeleteUser;
1829 >  ServiceStart;
1830 > end;
1831 >
1832 > procedure TIBSecurityService.DisplayUsers;
1833 > begin
1834 >  SecurityAction := ActionDisplayUser;
1835 >  SRB.Add(isc_action_svc_display_user);
1836 >  InternalServiceStart;
1837 >  FetchUserInfo;
1838 > end;
1839 >
1840 > procedure TIBSecurityService.DisplayUser(UserName: String);
1841 > begin
1842 >  SecurityAction := ActionDisplayUser;
1843 >  SRB.Add(isc_action_svc_display_user);
1844 >  SRB.Add(isc_spb_sec_username).AsString := UserName;
1845 >  InternalServiceStart;
1846 >  FetchUserInfo;
1847 > end;
1848 >
1849 > procedure TIBSecurityService.ModifyUser;
1850 > begin
1851 >  SecurityAction := ActionModifyUser;
1852 >  ServiceStart;
1853 > end;
1854 >
1855 > procedure TIBSecurityService.SetSecurityAction (Value: TSecurityAction);
1856 > begin
1857 >  FSecurityAction := Value;
1858 >  if Value = ActionDeleteUser then
1859 >    ClearParams;
1860 > end;
1861 >
1862 > procedure TIBSecurityService.ClearParams;
1863 > begin
1864 >  FModifyParams := [];
1865 >  FFirstName := '';
1866 >  FMiddleName := '';
1867 >  FLastName := '';
1868 >  FGroupID := 0;
1869 >  FUserID := 0;
1870 >  FPassword := '';
1871 > end;
1872 >
1873 > procedure TIBSecurityService.SetFirstName (Value: String);
1874 > begin
1875 >  FFirstName := Value;
1876 >  Include (FModifyParams, ModifyFirstName);
1877 > end;
1878 >
1879 > procedure TIBSecurityService.SetMiddleName (Value: String);
1880 > begin
1881 >  FMiddleName := Value;
1882 >  Include (FModifyParams, ModifyMiddleName);
1883 > end;
1884 >
1885 > procedure TIBSecurityService.SetLastName (Value: String);
1886 > begin
1887 >  FLastName := Value;
1888 >  Include (FModifyParams, ModifyLastName);
1889 > end;
1890 >
1891 > procedure TIBSecurityService.SetPassword (Value: String);
1892 > begin
1893 >  FPassword := Value;
1894 >  Include (FModifyParams, ModifyPassword);
1895 > end;
1896 >
1897 > procedure TIBSecurityService.SetUserId (Value: Integer);
1898 > begin
1899 >  FUserId := Value;
1900 >  Include (FModifyParams, ModifyUserId);
1901 > end;
1902 >
1903 > procedure TIBSecurityService.SetGroupId (Value: Integer);
1904 > begin
1905 >  FGroupId := Value;
1906 >  Include (FModifyParams, ModifyGroupId);
1907 > end;
1908 >
1909 > procedure TIBSecurityService.Loaded;
1910 > begin
1911 >  inherited Loaded;
1912 >  ClearParams;
1913 > end;
1914 >
1915 > procedure TIBSecurityService.SetServiceStartOptions;
1916 > var
1917 >  Len: UShort;
1918 >
1919 > begin
1920 >  case FSecurityAction of
1921 >    ActionAddUser:
1922 >    begin
1923 >      Action := isc_action_svc_add_user;
1924 >      if ( Pos(' ', FUserName) > 0 ) then
1925 >        IBError(ibxeStartParamsError, [nil]);
1926 >      Len := Length(FUserName);
1927 >      if (Len = 0) then
1928 >        IBError(ibxeStartParamsError, [nil]);
1929 >      SRB.Add(isc_action_svc_add_user);
1930 >      SRB.Add(isc_spb_sec_username).AsString := FUserName;
1931 >      SRB.Add(isc_spb_sql_role_name).AsString := FSQLRole;
1932 >      SRB.Add(isc_spb_sec_userid).AsInteger := FUserID;
1933 >      SRB.Add(isc_spb_sec_groupid).AsInteger := FGroupID;
1934 >      SRB.Add(isc_spb_sec_password).AsString := FPassword;
1935 >      SRB.Add(isc_spb_sec_firstname).AsString := FFirstName;
1936 >      SRB.Add(isc_spb_sec_middlename).AsString := FMiddleName;
1937 >      SRB.Add(isc_spb_sec_lastname).AsString := FLastName;
1938 >    end;
1939 >    ActionDeleteUser:
1940 >    begin
1941 >      Action := isc_action_svc_delete_user;
1942 >      Len := Length(FUserName);
1943 >      if (Len = 0) then
1944 >        IBError(ibxeStartParamsError, [nil]);
1945 >      SRB.Add(isc_action_svc_delete_user);
1946 >      SRB.Add(isc_spb_sec_username).AsString := FUserName;
1947 >      SRB.Add(isc_spb_sql_role_name).AsString := FSQLRole;
1948 >    end;
1949 >    ActionModifyUser:
1950 >    begin
1951 >      Action := isc_action_svc_modify_user;
1952 >      Len := Length(FUserName);
1953 >      if (Len = 0) then
1954 >        IBError(ibxeStartParamsError, [nil]);
1955 >      SRB.Add(isc_action_svc_modify_user);
1956 >      SRB.Add(isc_spb_sec_username).AsString := FUserName;
1957 >      SRB.Add(isc_spb_sql_role_name).AsString := FSQLRole;
1958 >      if (ModifyUserId in FModifyParams) then
1959 >        SRB.Add(isc_spb_sec_userid).AsInteger := FUserID;
1960 >      if (ModifyGroupId in FModifyParams) then
1961 >        SRB.Add(isc_spb_sec_groupid).AsInteger := FGroupID;
1962 >      if (ModifyPassword in FModifyParams) then
1963 >        SRB.Add(isc_spb_sec_password).AsString := FPassword;
1964 >      if (ModifyFirstName in FModifyParams) then
1965 >        SRB.Add(isc_spb_sec_firstname).AsString := FFirstName;
1966 >      if (ModifyMiddleName in FModifyParams) then
1967 >        SRB.Add(isc_spb_sec_middlename).AsString := FMiddleName;
1968 >      if (ModifyLastName in FModifyParams) then
1969 >        SRB.Add(isc_spb_sec_lastname).AsString := FLastName;
1970 >    end;
1971 >  end;
1972 >  ClearParams;
1973 > end;
1974 >
1975 > { TIBUnStructuredService }
1976 > constructor TIBControlAndQueryService.create(AOwner: TComponent);
1977 > begin
1978 >  inherited Create(AOwner);
1979 >  FEof := False;
1980 >  FAction := 0;
1981 > end;
1982 >
1983 > procedure TIBControlAndQueryService.SetAction(Value: Integer);
1984 > begin
1985 >  FEof := False;
1986 >  FAction := Value;
1987 > end;
1988 >
1989 >
1990 > function TIBControlAndQueryService.GetNextChunk: String;
1991 > var
1992 >  i: Integer;
1993 > begin
1994 >  if (FEof = True) then
1995 >  begin
1996 >    result := '';
1997 >    exit;
1998 >  end;
1999 >  if (FAction = 0) then
2000 >    IBError(ibxeQueryParamsError, [nil]);
2001 >
2002 >  SRB.Add(isc_info_svc_to_eof);
2003 >  InternalServiceQuery;
2004 >
2005 >  FEof := True;
2006 >  for i := 0 to FServiceQueryResults.Count - 1 do
2007 >  with FServiceQueryResults[i] do
2008 >  begin
2009 >    case getItemType of
2010 >      isc_info_svc_to_eof:
2011 >        Result := AsString;
2012 >
2013 >      isc_info_truncated:
2014 >        FEof := False;
2015 >    else
2016 >      IBError(ibxeOutputParsingError, [getItemType]);
2017 >    end;
2018 >  end;
2019 > end;
2020 >
2021 > function TIBControlAndQueryService.WriteNextChunk(stream: TStream): integer;
2022 > var
2023 >  i: Integer;
2024 > begin
2025 >  result := 0;
2026 >  if (FEof = True) then
2027 >    exit;
2028 >  if (FAction = 0) then
2029 >    IBError(ibxeQueryParamsError, [nil]);
2030 >
2031 >  SQPB.Add(isc_info_svc_timeout).AsInteger := 1;
2032 >  SRB.Add(isc_info_svc_to_eof);
2033 >  InternalServiceQuery;
2034 >
2035 >  FEof := True;
2036 >  for i := 0 to FServiceQueryResults.Count - 1 do
2037 >  with FServiceQueryResults[i] do
2038 >  begin
2039 >    case getItemType of
2040 >      isc_info_svc_to_eof:
2041 >      begin
2042 >        Result := CopyTo(stream,0);
2043 >        FEof := Result = 0;
2044 >      end;
2045 >
2046 >      isc_info_truncated:
2047 >        FEof := False;
2048 >
2049 >      isc_info_svc_timeout:
2050 >        {ignore};
2051 >    else
2052 >      IBError(ibxeOutputParsingError, [getItemType]);
2053 >    end;
2054 >  end;
2055 > end;
2056 >
2057 > function TIBControlAndQueryService.GetNextLine: String;
2058 > var
2059 >  i: Integer;
2060 > begin
2061 >  Result := '';
2062 >  if (FEof = True) then
2063 >    exit;
2064 >
2065 >  if (FAction = 0) then
2066 >    IBError(ibxeQueryParamsError, [nil]);
2067 >
2068 >  SRB.Add(isc_info_svc_line);
2069 >  InternalServiceQuery;
2070 >
2071 >  for i := 0 to FServiceQueryResults.Count - 1 do
2072 >  with FServiceQueryResults[i] do
2073 >  begin
2074 >    case getItemType of
2075 >      isc_info_svc_line:
2076 >         Result := AsString;
2077 >    else
2078 >      IBError(ibxeOutputParsingError, [getItemType]);
2079 >    end;
2080 >  end;
2081 >  FEOF := Result = '';
2082 > end;
2083 >
2084 > { TIBLogService }
2085 >
2086 > procedure TIBLogService.SetServiceStartOptions;
2087 > begin
2088 >  Action := isc_action_svc_get_ib_log;
2089 >  SRB.Add(isc_action_svc_get_ib_log);
2090 > end;
2091 >
2092 > { TDatabaseInfo }
2093 >
2094 > constructor TDatabaseInfo.Create;
2095 > begin
2096 >  DbName := nil;
2097 > end;
2098 >
2099 > destructor TDatabaseInfo.Destroy;
2100 > begin
2101 >  DbName := nil;
2102 >  inherited Destroy;
2103 > end;
2104 >
2105 > { TLicenseInfo }
2106 >
2107 > constructor TLicenseInfo.Create;
2108 > begin
2109 >  Key := nil;
2110 >  Id := nil;
2111 >  Desc := nil;
2112 > end;
2113 >
2114 > destructor TLicenseInfo.Destroy;
2115 > begin
2116 >  Key := nil;
2117 >  Id := nil;
2118 >  Desc := nil;
2119 >  inherited Destroy;
2120 > end;
2121 >
2122 > { TConfigFileData }
2123 >
2124 > constructor TConfigFileData.Create;
2125 > begin
2126 >  ConfigFileValue := nil;
2127 >  ConfigFileKey := nil;
2128 > end;
2129 >
2130 > destructor TConfigFileData.Destroy;
2131 > begin
2132 >  ConfigFileValue := nil;
2133 >  ConfigFileKey := nil;
2134 >  inherited Destroy;
2135 > end;
2136 >
2137 > { TConfigParams }
2138 >
2139 > constructor TConfigParams.Create;
2140 > begin
2141 >  ConfigFileData := TConfigFileData.Create;
2142 >  ConfigFileParams := nil;
2143 > end;
2144 >
2145 > destructor TConfigParams.Destroy;
2146 > begin
2147 >  ConfigFileData.Free;
2148 >  ConfigFileParams := nil;
2149 >  inherited Destroy;
2150 > end;
2151 >
2152 > end.

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines