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

Comparing:
ibx/trunk/fbintf/client/FBAttachment.pas (file contents), Revision 270 by tony, Fri Jan 18 11:10:37 2019 UTC vs.
ibx/branches/journaling/fbintf/client/FBAttachment.pas (file contents), Revision 363 by tony, Tue Dec 7 13:30:05 2021 UTC

# Line 39 | Line 39 | interface
39  
40   uses
41    Classes, SysUtils, {$IFDEF WINDOWS} windows, {$ENDIF} IB,  FBParamBlock,
42 <  FBActivityMonitor, FBClientAPI;
42 >  FBActivityMonitor, FBClientAPI, IBUtils;
43 >
44 > const
45 >  DefaultMaxInlineBlobLimit = 8192;
46  
47   type
48    TCharsetMap = record
# Line 50 | Line 53 | type
53      AllowReverseLookup: boolean; {used to ensure that lookup of CP_UTF* does not return UNICODE_FSS}
54    end;
55  
56 +  { Database Journalling.
57 +
58 +    This class is intended to support a client side journal of all database
59 +    updates, inserts and deletes made by the client during a session. It also records
60 +    the transaction each update was made under.
61 +
62 +    The database schema is required to include a control table "IBX$JOURNALS" and
63 +    an SQL Sequence IBX$SESSIONS. These are created by the class when the
64 +    database is opened, if they are not already present. However, it is recommended
65 +    that they are created as an orginal part of the database schema in order to
66 +    unnecessarily avoid each user being given sufficient priviledge to create tables
67 +    and Sequences.
68 +
69 +    Syntax:
70 +
71 +    Transaction Start:
72 +    *S:<date/time>,<session id>,<transaction no.>,<string length>:<transaction Name>,<string length>:<TPB>,<default Completion>
73 +
74 +    Transaction Commit:
75 +    *C:<date/time>,<session id>,<transaction no.>
76 +
77 +    Transaction Commit retaining :
78 +    *c:<date/time>,<session id>,<transaction no.><old transaction no.>
79 +
80 +    Transaction Rollback:
81 +    *R:<date/time>,<session id>,<transaction no.>
82 +
83 +    Transaction Rollback retaining:
84 +    *r:<date/time>,<session id>,<transaction no.><old transaction no.>
85 +
86 +    Update/Insert/Delete
87 +    *Q:<date/time>,<session id>,<transaction no.>,<length of query text in bytes>:<query text>
88 +
89 +  }
90 +
91 +  { TFBJournaling }
92 +
93 +  TFBJournaling = class(TActivityHandler, IJournallingHook)
94 +  private
95 +    {Logfile}
96 +    const sQueryJournal          = '*Q:''%s'',%d,%d,%d:%s' + LineEnding;
97 +    const sTransStartJnl         = '*S:''%s'',%d,%d,%d:%s,%d:%s,%d' + LineEnding;
98 +    const sTransCommitJnl        = '*C:''%s'',%d,%d' + LineEnding;
99 +    const sTransCommitRetJnl     = '*c:''%s'',%d,%d,%d' + LineEnding;
100 +    const sTransRollBackJnl      = '*R:''%s'',%d,%d' + LineEnding;
101 +    const sTransRollBackRetJnl   = '*r:''%s'',%d,%d,%d' + LineEnding;
102 +  private
103 +    FOptions: TJournalOptions;
104 +    FJournalFilePath: string;
105 +    FJournalFileStream: TStream;
106 +    FSessionID: integer;
107 +    FDoNotJournal: boolean;
108 +    function GetDateTimeFmt: AnsiString;
109 +  protected
110 +    procedure EndSession(RetainJournal: boolean);
111 +    function GetAttachment: IAttachment; virtual; abstract;
112 +  public
113 +    {IAttachment}
114 +    procedure Disconnect(Force: boolean=false); virtual;
115 +  public
116 +    {IJournallingHook}
117 +    procedure TransactionStart(Tr: ITransaction);
118 +    function TransactionEnd( TransactionID: integer; Action: TTransactionAction): boolean;
119 +    procedure TransactionRetained(Tr: ITransaction; OldTransactionID: integer;
120 +      Action: TTransactionAction);
121 +    procedure ExecQuery(Stmt: IStatement);
122 +  public
123 +    {Client side Journaling}
124 +    function JournalingActive: boolean;
125 +    function GetJournalOptions: TJournalOptions;
126 +    function StartJournaling(aJournalLogFile: AnsiString): integer; overload;
127 +    function StartJournaling(aJournalLogFile: AnsiString; Options: TJournalOptions): integer; overload;
128 +    procedure StopJournaling(RetainJournal: boolean);
129 +  end;
130 +
131    { TFBAttachment }
132  
133 <  TFBAttachment = class(TActivityHandler)
133 >  TFBAttachment = class(TFBJournaling)
134    private
135      FDPB: IDPB;
136      FFirebirdAPI: IFirebirdAPI;
# Line 60 | Line 138 | type
138      FODSMinorVersion: integer;
139      FUserCharSetMap: array of TCharSetMap;
140      FSecDatabase: AnsiString;
141 +    FInlineBlobLimit: integer;
142    protected
143      FDatabaseName: AnsiString;
144      FRaiseExceptionOnConnectError: boolean;
# Line 79 | Line 158 | type
158      procedure EndAllTransactions;
159      procedure DPBFromCreateSQL(CreateSQL: AnsiString);
160      procedure SetParameters(SQLParams: ISQLParams; params: array of const);
161 +    procedure UseServerICUChanged; virtual;
162    public
163      destructor Destroy; override;
164      function getFirebirdAPI: IFirebirdAPI;
165      function getDPB: IDPB;
166      function AllocateBPB: IBPB;
167      function AllocateDIRB: IDIRB;
168 <    function StartTransaction(TPB: array of byte; DefaultCompletion: TTransactionCompletion): ITransaction; overload; virtual; abstract;
169 <    function StartTransaction(TPB: ITPB; DefaultCompletion: TTransactionCompletion): ITransaction; overload; virtual; abstract;
170 <    procedure Disconnect(Force: boolean=false); virtual; abstract;
168 >    function StartTransaction(TPB: array of byte;
169 >      DefaultCompletion: TTransactionCompletion;
170 >      aName: AnsiString=''): ITransaction; overload; virtual; abstract;
171 >    function StartTransaction(TPB: ITPB; DefaultCompletion: TTransactionCompletion;
172 >      aName: AnsiString=''): ITransaction; overload; virtual; abstract;
173      procedure ExecImmediate(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer); overload; virtual; abstract;
174      procedure ExecImmediate(TPB: array of byte; sql: AnsiString; aSQLDialect: integer); overload;
175      procedure ExecImmediate(transaction: ITransaction; sql: AnsiString); overload;
# Line 96 | Line 178 | type
178      function ExecuteSQL(transaction: ITransaction; sql: AnsiString; SQLDialect: integer; params: array of const): IResults; overload;
179      function ExecuteSQL(TPB: array of byte; sql: AnsiString; params: array of const): IResults; overload;
180      function ExecuteSQL(transaction: ITransaction; sql: AnsiString; params: array of const): IResults; overload;
181 <    function OpenCursor(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer): IResultSet; overload;
181 >    function OpenCursor(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer;
182 >                             Scrollable: boolean=false): IResultSet; overload;
183      function OpenCursor(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer;
184                               params: array of const): IResultSet; overload;
185 <    function OpenCursor(transaction: ITransaction; sql: AnsiString): IResultSet; overload;
185 >    function OpenCursor(transaction: ITransaction; sql: AnsiString; Scrollable: boolean=false): IResultSet; overload;
186      function OpenCursor(transaction: ITransaction; sql: AnsiString;
187                               params: array of const): IResultSet; overload;
188 <    function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer): IResultSet; overload;
188 >    function OpenCursor(transaction: ITransaction; sql: AnsiString; Scrollable: boolean;
189 >                             params: array of const): IResultSet; overload;
190 >    function OpenCursor(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; Scrollable: boolean;
191 >                             params: array of const): IResultSet; overload;
192      function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer;
193 +                             Scrollable: boolean=false): IResultSet; overload;
194 +    function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer;
195 +                             params: array of const): IResultSet; overload;
196 +    function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; Scrollable: boolean;
197                               params: array of const): IResultSet; overload;
198 <    function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString): IResultSet; overload;
198 >    function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; Scrollable: boolean=false): IResultSet; overload;
199      function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString;
200                               params: array of const): IResultSet; overload;
201 <    function OpenCursorAtStart(sql: AnsiString): IResultSet; overload;
201 >    function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; Scrollable: boolean;
202 >                             params: array of const): IResultSet; overload;
203 >    function OpenCursorAtStart(sql: AnsiString;Scrollable: boolean=false): IResultSet; overload;
204 >    function OpenCursorAtStart(sql: AnsiString; Scrollable: boolean;
205 >                             params: array of const): IResultSet; overload;
206      function OpenCursorAtStart(sql: AnsiString;
207                               params: array of const): IResultSet; overload;
208 <    function Prepare(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer): IStatement; overload; virtual; abstract;
209 <    function Prepare(transaction: ITransaction; sql: AnsiString): IStatement; overload;
208 >    function Prepare(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; CursorName: AnsiString=''): IStatement; overload; virtual; abstract;
209 >    function Prepare(transaction: ITransaction; sql: AnsiString; CursorName: AnsiString=''): IStatement; overload;
210      function PrepareWithNamedParameters(transaction: ITransaction; sql: AnsiString;
211                         aSQLDialect: integer; GenerateParamNames: boolean=false;
212 <                       CaseSensitiveParams: boolean = false): IStatement; overload; virtual; abstract;
212 >                       CaseSensitiveParams: boolean = false; CursorName: AnsiString=''): IStatement; overload; virtual; abstract;
213      function PrepareWithNamedParameters(transaction: ITransaction; sql: AnsiString;
214                         GenerateParamNames: boolean=false;
215 <                       CaseSensitiveParams: boolean = false): IStatement; overload;
215 >                       CaseSensitiveParams: boolean = false; CursorName: AnsiString=''): IStatement; overload;
216      function GetEventHandler(Events: TStrings): IEvents; overload; virtual; abstract;
217      function GetEventHandler(Event: AnsiString): IEvents; overload;
218  
219      function GetSQLDialect: integer;
220 +    function CreateBlob(transaction: ITransaction; RelationName, ColumnName: AnsiString; BPB: IBPB=nil): IBlob; overload;
221 +    function CreateBlob(transaction: ITransaction; BlobMetaData: IBlobMetaData; BPB: IBPB=nil): IBlob; overload; virtual; abstract;
222      function OpenBlob(transaction: ITransaction; BlobMetaData: IBlobMetaData; BlobID: TISC_QUAD; BPB: IBPB=nil): IBlob; overload; virtual; abstract;
223 +    function OpenBlob(transaction: ITransaction; RelationName, ColumnName: AnsiString; BlobID: TISC_QUAD; BPB: IBPB=nil): IBlob; overload;
224      function OpenBlob(transaction: ITransaction; Field: ISQLData; BPB: IBPB=nil): IBlob; overload;
225 +    function CreateArray(transaction: ITransaction; RelationName, ColumnName: AnsiString
226 +      ): IArray; overload;
227 +    function CreateArray(transaction: ITransaction; ArrayMetaData: IArrayMetaData): IArray; overload; virtual; abstract;
228 +    function OpenArray(transaction: ITransaction; RelationName, ColumnName: AnsiString; ArrayID: TISC_QUAD): IArray; overload;
229 +    function OpenArray(transaction: ITransaction; ArrayMetaData: IArrayMetaData; ArrayID: TISC_QUAD): IArray; overload; virtual; abstract;
230      property SQLDialect: integer read FSQLDialect;
231      property DPB: IDPB read FDPB;
232 < public
233 <  function GetDBInformation(Requests: array of byte): IDBInformation; overload;
234 <  function GetDBInformation(Request: byte): IDBInformation; overload;
235 <  function GetDBInformation(Requests: IDIRB): IDBInformation; overload;
236 <  function GetConnectString: AnsiString;
237 <  function GetRemoteProtocol: AnsiString;
238 <  function GetAuthenticationMethod: AnsiString;
239 <  function GetSecurityDatabase: AnsiString;
240 <  function GetODSMajorVersion: integer;
241 <  function GetODSMinorVersion: integer;
242 <  {Character Sets}
243 <  function HasDefaultCharSet: boolean;
244 <  function GetDefaultCharSetID: integer;
245 <  function GetCharsetName(CharSetID: integer): AnsiString;
246 <  function CharSetID2CodePage(CharSetID: integer; var CodePage: TSystemCodePage): boolean;
247 <  function CodePage2CharSetID(CodePage: TSystemCodePage; var CharSetID: integer): boolean;
248 <  function CharSetName2CharSetID(CharSetName: AnsiString; var CharSetID: integer): boolean;
249 <  function CharSetWidth(CharSetID: integer; var Width: integer): boolean;
250 <  procedure RegisterCharSet(CharSetName: AnsiString; CodePage: TSystemCodePage;
251 <    AllowReverseLookup:boolean; out CharSetID: integer);
252 <  property CharSetID: integer read FCharSetID;
253 <  property CodePage: TSystemCodePage read FCodePage;
232 >  public
233 >    function GetDBInformation(Requests: array of byte): IDBInformation; overload;
234 >    function GetDBInformation(Request: byte): IDBInformation; overload;
235 >    function GetDBInformation(Requests: IDIRB): IDBInformation; overload;
236 >    function GetAttachmentID: integer;
237 >    function GetConnectString: AnsiString;
238 >    function GetRemoteProtocol: AnsiString;
239 >    function GetAuthenticationMethod: AnsiString;
240 >    function GetSecurityDatabase: AnsiString;
241 >    function GetODSMajorVersion: integer;
242 >    function GetODSMinorVersion: integer;
243 >    function HasDecFloatSupport: boolean; virtual;
244 >    function GetInlineBlobLimit: integer;
245 >    procedure SetInlineBlobLimit(limit: integer);
246 >    function HasBatchMode: boolean; virtual;
247 >    function HasTable(aTableName: AnsiString): boolean;
248 >
249 >  public
250 >    {Character Sets}
251 >    function HasDefaultCharSet: boolean;
252 >    function GetDefaultCharSetID: integer;
253 >    function GetCharsetName(CharSetID: integer): AnsiString;
254 >    function CharSetID2CodePage(CharSetID: integer; var CodePage: TSystemCodePage): boolean;
255 >    function CodePage2CharSetID(CodePage: TSystemCodePage; var CharSetID: integer): boolean;
256 >    function CharSetName2CharSetID(CharSetName: AnsiString; var CharSetID: integer): boolean;
257 >    function CharSetWidth(CharSetID: integer; var Width: integer): boolean;
258 >    procedure RegisterCharSet(CharSetName: AnsiString; CodePage: TSystemCodePage;
259 >      AllowReverseLookup:boolean; out CharSetID: integer);
260 >    function GetBlobMetaData(Transaction: ITransaction; tableName, columnName: AnsiString): IBlobMetaData; virtual; abstract;
261 >    function GetArrayMetaData(Transaction: ITransaction; tableName, columnName: AnsiString): IArrayMetaData; virtual; abstract;
262 >    property CharSetID: integer read FCharSetID;
263 >    property CodePage: TSystemCodePage read FCodePage;
264 >
265 >  public
266 >    {Time Zone Support}
267 >    function GetTimeZoneServices: ITimeZoneServices; virtual;
268 >    function HasTimeZoneSupport: boolean; virtual;
269 >
270 >  end;
271 >
272 >  { TDPBItem }
273 >
274 >  TDPBItem = class(TParamBlockItem,IDPBItem)
275 >  public
276 >   function getParamTypeName: AnsiString; override;
277 >  end;
278 >
279 >  { TDPB }
280 >
281 >  TDPB = class (TCustomParamBlock<TDPBItem,IDPBItem>, IDPB)
282 >  protected
283 >   function LookupItemType(ParamTypeName: AnsiString): byte; override;
284 >  public
285 >    constructor Create(api: TFBClientAPI);
286 >    function GetParamTypeName(ParamType: byte): Ansistring;
287 >    {$IFDEF FPC}
288 >    function IDPB.GetDPBParamTypeName = GetParamTypeName;
289 >    {$ELSE}
290 >    function GetDPBParamTypeName(ParamType: byte): Ansistring;
291 >    {$ENDIF}
292    end;
293  
294   implementation
295  
296 < uses FBMessages, IBUtils, FBTransaction {$IFDEF HASREQEX}, RegExpr{$ENDIF};
296 > uses FBMessages, IBErrorCodes, FBTransaction {$IFDEF HASREQEX}, RegExpr{$ENDIF};
297 >
298 > const
299 >  {Journaling}
300 >  sJournalTableName = 'IBX$JOURNALS';
301 >  sSequenceName = 'IBX$SESSIONS';
302 >
303 >  sqlCreateJournalTable =
304 >    'Create Table ' + sJournalTableName + '(' +
305 >    '  IBX$SessionID Integer not null, '+
306 >    '  IBX$TransactionID Integer not null, '+
307 >    '  IBX$OldTransactionID Integer, '+
308 >    '  IBX$USER VarChar(32) Default CURRENT_USER, '+
309 >    '  IBX$CREATED TIMESTAMP Default CURRENT_TIMESTAMP, '+
310 >    '  Primary Key(IBX$SessionID,IBX$TransactionID)' +
311 >    ')';
312 >
313 >  sqlCreateSequence = 'CREATE SEQUENCE ' + sSequenceName;
314 >
315 >  sqlGetNextSessionID = 'Select Gen_ID(' + sSequenceName + ',1) as SessionID From RDB$DATABASE';
316 >
317 >  sqlRecordJournalEntry = 'Insert into ' + sJournalTableName + '(IBX$SessionID,IBX$TransactionID,IBX$OldTransactionID) '+
318 >                        'Values(?,?,?)';
319 >
320 >  sqlCleanUpSession = 'Delete From ' + sJournalTableName + ' Where IBX$SessionID = ?';
321  
322   const
323    CharSetMap: array [0..69] of TCharsetMap = (
# Line 229 | Line 393 | const
393    (CharsetID: 69; CharSetName: 'GB18030'; CharSetWidth: 4; CodePage: 54936; AllowReverseLookup: true)
394   );
395  
396 + const
397 +  isc_dpb_last_dpb_constant = isc_dpb_decfloat_traps;
398 +
399 +  DPBConstantNames: array[1..isc_dpb_last_dpb_constant] of string = (
400 +    'cdd_pathname',
401 +    'allocation',
402 +    'journal',
403 +    'page_size',
404 +    'num_buffers',
405 +    'buffer_length',
406 +    'debug',
407 +    'garbage_collect',
408 +    'verify',
409 +    'sweep',
410 +    'enable_journal',
411 +    'disable_journal',
412 +    'dbkey_scope',
413 +    'number_of_users',
414 +    'trace',
415 +    'no_garbage_collect',
416 +    'damaged',
417 +    'license',
418 +    'sys_user_name',
419 +    'encrypt_key',
420 +    'activate_shadow',
421 +    'sweep_interval',
422 +    'delete_shadow',
423 +    'force_write',
424 +    'begin_log',
425 +    'quit_log',
426 +    'no_reserve',
427 +    'user_name',
428 +    'password',
429 +    'password_enc',
430 +    'sys_user_name_enc',
431 +    'interp',
432 +    'online_dump',
433 +    'old_file_size',
434 +    'old_num_files',
435 +    'old_file',
436 +    'old_start_page',
437 +    'old_start_seqno',
438 +    'old_start_file',
439 +    'drop_walfile',
440 +    'old_dump_id',
441 +    'wal_backup_dir',
442 +    'wal_chkptlen',
443 +    'wal_numbufs',
444 +    'wal_bufsize',
445 +    'wal_grp_cmt_wait',
446 +    'lc_messages',
447 +    'lc_ctype',
448 +    'cache_manager',
449 +    'shutdown',
450 +    'online',
451 +    'shutdown_delay',
452 +    'reserved',
453 +    'overwrite',
454 +    'sec_attach',
455 +    'disable_wal',
456 +    'connect_timeout',
457 +    'dummy_packet_interval',
458 +    'gbak_attach',
459 +    'sql_role_name',
460 +    'set_page_buffers',
461 +    'working_directory',
462 +    'sql_dialect',
463 +    'set_db_readonly',
464 +    'set_db_sql_dialect',
465 +    'gfix_attach',
466 +    'gstat_attach',
467 +    'set_db_charset',
468 +    'gsec_attach',
469 +    'address_path' ,
470 +    'process_id',
471 +    'no_db_triggers',
472 +    'trusted_auth',
473 +    'process_name',
474 +    'trusted_role',
475 +    'org_filename',
476 +    'utf8_ilename',
477 +    'ext_call_depth',
478 +    'auth_block',
479 +    'client_version',
480 +    'remote_protocol',
481 +    'host_name',
482 +    'os_user',
483 +    'specific_auth_data',
484 +    'auth_plugin_list',
485 +    'auth_plugin_name',
486 +    'config',
487 +    'nolinger',
488 +    'reset_icu',
489 +    'map_attach',
490 +    'session_time_zone',
491 +    'set_db_replica',
492 +    'set_bind',
493 +    'decfloat_round',
494 +    'decfloat_traps'
495 +    );
496 +
497 + type
498 +
499 +  { TQueryProcessor }
500 +
501 +  TQueryProcessor=class(TSQLTokeniser)
502 +  private
503 +    FInString: AnsiString;
504 +    FIndex: integer;
505 +    FStmt: IStatement;
506 +    function DoExecute: AnsiString;
507 +    function GetParamValue(ParamIndex: integer): AnsiString;
508 +  protected
509 +    function GetChar: AnsiChar; override;
510 +  public
511 +    class function Execute(Stmt: IStatement): AnsiString;
512 +  end;
513 +
514 +  { TQueryProcessor }
515 +
516 + function TQueryProcessor.DoExecute: AnsiString;
517 + var token: TSQLTokens;
518 +    ParamIndex: integer;
519 + begin
520 +  Result := '';
521 +  ParamIndex := 0;
522 +
523 +  while not EOF do
524 +  begin
525 +    token := GetNextToken;
526 +    case token of
527 +    sqltPlaceHolder:
528 +      begin
529 +        Result := Result + GetParamValue(ParamIndex);
530 +        Inc(ParamIndex);
531 +      end;
532 +    else
533 +      Result := Result + TokenText;
534 +    end;
535 +  end;
536 + end;
537 +
538 + function TQueryProcessor.GetParamValue(ParamIndex: integer): AnsiString;
539 + begin
540 +  with FStmt.SQLParams[ParamIndex] do
541 +  begin
542 +    if IsNull then
543 +      Result := 'NULL'
544 +    else
545 +    case GetSQLType of
546 +    SQL_BLOB:
547 +      if getSubType = 1 then {string}
548 +        Result := '''' + SQLSafeString(GetAsString) + ''''
549 +      else
550 +        Result := TSQLXMLReader.FormatBlob(GetAsString,getSubType);
551 +
552 +    SQL_ARRAY:
553 +        Result := TSQLXMLReader.FormatArray(getAsArray);
554 +
555 +    SQL_VARYING,
556 +    SQL_TEXT,
557 +    SQL_TIMESTAMP,
558 +    SQL_TYPE_DATE,
559 +    SQL_TYPE_TIME,
560 +    SQL_TIMESTAMP_TZ_EX,
561 +    SQL_TIME_TZ_EX,
562 +    SQL_TIMESTAMP_TZ,
563 +    SQL_TIME_TZ:
564 +      Result := '''' + SQLSafeString(GetAsString) + '''';
565 +    else
566 +      Result := GetAsString;
567 +    end;
568 +  end;
569 + end;
570 +
571 + function TQueryProcessor.GetChar: AnsiChar;
572 + begin
573 +  if FIndex <= Length(FInString) then
574 +  begin
575 +    Result := FInString[FIndex];
576 +    Inc(FIndex);
577 +  end
578 +  else
579 +    Result := #0;
580 + end;
581 +
582 + class function TQueryProcessor.Execute(Stmt: IStatement): AnsiString;
583 + begin
584 +  if not Stmt.IsPrepared then
585 +    IBError(ibxeSQLClosed,[]);
586 +  with self.Create do
587 +  try
588 +    FStmt := Stmt;
589 +    FInString := Stmt.GetProcessedSQLText;
590 +    FIndex := 1;
591 +    Result := Trim(DoExecute);
592 +  finally
593 +    Free;
594 +  end;
595 + end;
596 +
597 + { TFBJournaling }
598 +
599 + function TFBJournaling.GetDateTimeFmt: AnsiString;
600 + begin
601 +  {$IF declared(DefaultFormatSettings)}
602 +  with DefaultFormatSettings do
603 +  {$ELSE}
604 +  {$IF declared(FormatSettings)}
605 +  with FormatSettings do
606 +  {$IFEND}
607 +  {$IFEND}
608 +  Result := ShortDateFormat + ' ' + LongTimeFormat + '.zzzz'
609 + end;
610 +
611 + procedure TFBJournaling.EndSession(RetainJournal: boolean);
612 + begin
613 +  if JournalingActive then
614 +  begin
615 +    FreeAndNil(FJournalFileStream);
616 +    if not RetainJournal then
617 +    try
618 +        GetAttachment.ExecuteSQL([isc_tpb_write,isc_tpb_wait,isc_tpb_consistency],
619 +             sqlCleanUpSession,[FSessionID]);
620 +        sysutils.DeleteFile(FJournalFilePath);
621 +    except On E: EIBInterBaseError do
622 +      if E.IBErrorCode <> isc_lost_db_connection then
623 +        raise;
624 +      {ignore - do not delete journal if database gone away}
625 +    end;
626 +    FSessionID := -1;
627 +  end;
628 + end;
629 +
630 + procedure TFBJournaling.Disconnect(Force: boolean);
631 + begin
632 +  if JournalingActive then
633 +    EndSession(Force);
634 + end;
635 +
636 + procedure TFBJournaling.TransactionStart(Tr: ITransaction);
637 + var LogEntry: AnsiString;
638 +    TPBText: AnsiString;
639 + begin
640 +  FDoNotJournal := true;
641 +  try
642 +    GetAttachment.ExecuteSQL(Tr,sqlRecordJournalEntry,[FSessionID,Tr.GetTransactionID,NULL]);
643 +  finally
644 +    FDoNotJournal := false;
645 +  end;
646 +  TPBText := Tr.getTPB.AsText;
647 +  LogEntry := Format(sTransStartJnl,[FBFormatDateTime(GetDateTimeFmt,Now),
648 +                                     FSessionID,
649 +                                     Tr.GetTransactionID,
650 +                                     Length(Tr.TransactionName),
651 +                                     Tr.TransactionName,
652 +                                     Length(TPBText),TPBText,
653 +                                     ord(tr.GetDefaultCompletion)]);
654 +  if assigned(FJournalFileStream) then
655 +    FJournalFileStream.Write(LogEntry[1],Length(LogEntry));
656 + end;
657 +
658 + function TFBJournaling.TransactionEnd(TransactionID: integer;
659 +  Action: TTransactionAction): boolean;
660 +
661 + var LogEntry: AnsiString;
662 + begin
663 +  Result := false;
664 +    case Action of
665 +    TARollback:
666 +      begin
667 +        LogEntry := Format(sTransRollbackJnl,[FBFormatDateTime(GetDateTimeFmt,Now),FSessionID,TransactionID]);
668 +        Result := true;
669 +      end;
670 +    TACommit:
671 +      begin
672 +        LogEntry := Format(sTransCommitJnl,[FBFormatDateTime(GetDateTimeFmt,Now),FSessionID,TransactionID]);
673 +        Result := true;
674 +      end;
675 +    end;
676 +    if assigned(FJournalFileStream) then
677 +      FJournalFileStream.Write(LogEntry[1],Length(LogEntry));
678 + end;
679 +
680 + procedure TFBJournaling.TransactionRetained(Tr: ITransaction;
681 +  OldTransactionID: integer; Action: TTransactionAction);
682 + var LogEntry: AnsiString;
683 + begin
684 +    case Action of
685 +      TACommitRetaining:
686 +          LogEntry := Format(sTransCommitRetJnl,[FBFormatDateTime(GetDateTimeFmt,Now),
687 +                                  FSessionID,Tr.GetTransactionID,OldTransactionID]);
688 +      TARollbackRetaining:
689 +          LogEntry := Format(sTransRollbackRetJnl,[FBFormatDateTime(GetDateTimeFmt,Now),
690 +                                      FSessionID,Tr.GetTransactionID,OldTransactionID]);
691 +    end;
692 +    if assigned(FJournalFileStream) then
693 +      FJournalFileStream.Write(LogEntry[1],Length(LogEntry));
694 +
695 +    FDoNotJournal := true;
696 +    try
697 +      GetAttachment.ExecuteSQL(Tr,sqlRecordJournalEntry,[FSessionID,Tr.GetTransactionID,OldTransactionID]);
698 +    finally
699 +      FDoNotJournal := false;
700 +   end;
701 + end;
702 +
703 + procedure TFBJournaling.ExecQuery(Stmt: IStatement);
704 + var SQL: AnsiString;
705 +    LogEntry: AnsiString;
706 + begin
707 +  SQL := TQueryProcessor.Execute(Stmt);
708 +  LogEntry := Format(sQueryJournal,[FBFormatDateTime(GetDateTimeFmt,Now),
709 +                                      FSessionID,
710 +                                      Stmt.GetTransaction.GetTransactionID,
711 +                                      Length(SQL),SQL]);
712 +  if assigned(FJournalFileStream) then
713 +    FJournalFileStream.Write(LogEntry[1],Length(LogEntry));
714 + end;
715 +
716 + function TFBJournaling.JournalingActive: boolean;
717 + begin
718 +  Result := (FJournalFileStream <> nil) and not FDoNotJournal;
719 + end;
720 +
721 + function TFBJournaling.GetJournalOptions: TJournalOptions;
722 + begin
723 +  Result := FOptions;
724 + end;
725 +
726 + function TFBJournaling.StartJournaling(aJournalLogFile: AnsiString): integer;
727 + begin
728 +  Result := StartJournaling(aJournalLogFile,[joReadWriteTransactions,joModifyQueries]);
729 + end;
730 +
731 + function TFBJournaling.StartJournaling(aJournalLogFile: AnsiString;
732 +  Options: TJournalOptions): integer;
733 + begin
734 +  FOptions := Options;
735 +  with GetAttachment do
736 +  begin
737 +    if not HasTable(sJournalTableName) then
738 +    begin
739 +      ExecImmediate([isc_tpb_write,isc_tpb_wait,isc_tpb_consistency],sqlCreateJournalTable);
740 +      ExecImmediate([isc_tpb_write,isc_tpb_wait,isc_tpb_consistency],sqlCreateSequence);
741 +    end;
742 +    FSessionID := OpenCursorAtStart(sqlGetNextSessionID)[0].AsInteger;
743 +  end;
744 +  FJournalFilePath := aJournalLogFile;
745 +  FJournalFileStream := TFileStream.Create(FJournalFilePath,fmCreate);
746 +  Result := FSessionID;
747 + end;
748 +
749 + procedure TFBJournaling.StopJournaling(RetainJournal: boolean);
750 + begin
751 +  EndSession(RetainJournal);
752 + end;
753 +
754  
755  
756  
# Line 263 | Line 785 | begin
785    begin
786      Stmt := Prepare(StartTransaction([isc_tpb_read,isc_tpb_nowait,isc_tpb_concurrency],taCommit),
787                      'Select MON$CHARACTER_SET_ID, MON$REMOTE_PROTOCOL, MON$AUTH_METHOD, MON$SEC_DATABASE From MON$ATTACHMENTS, MON$DATABASE '+
788 <                    'Where MON$ATTACHMENT_ID = CURRENT_CONNECTION');
788 >                    'Where MON$ATTACHMENT_ID = CURRENT_CONNECTION ');
789      ResultSet := Stmt.OpenCursor;
790      if ResultSet.FetchNext then
791      begin
# Line 314 | Line 836 | begin
836    FRaiseExceptionOnConnectError := RaiseExceptionOnConnectError;
837    FODSMajorVersion := 0;
838    FODSMinorVersion := 0;
839 +  FInlineBlobLimit := DefaultMaxInlineBlobLimit;
840   end;
841  
842   function TFBAttachment.GenerateCreateDatabaseSQL(DatabaseName: AnsiString;  aDPB: IDPB): AnsiString;
# Line 447 | Line 970 | begin
970    end;
971   end;
972  
973 + procedure TFBAttachment.UseServerICUChanged;
974 + begin
975 +  // Do nothing by default
976 + end;
977 +
978   destructor TFBAttachment.Destroy;
979   begin
980    Disconnect(true);
# Line 522 | Line 1050 | begin
1050   end;
1051  
1052   function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString;
1053 <  aSQLDialect: integer): IResultSet;
1053 >  aSQLDialect: integer; Scrollable: boolean): IResultSet;
1054   begin
1055 <  Result := OpenCursor(transaction,sql,aSQLDialect,[]);
1055 >  Result := OpenCursor(transaction,sql,aSQLDialect,Scrollable,[]);
1056   end;
1057  
1058   function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString;
1059    aSQLDialect: integer; params: array of const): IResultSet;
1060 < var Statement: IStatement;
1060 >
1061   begin
1062 <  CheckHandle;
535 <  Statement := Prepare(transaction,sql,aSQLDialect);
536 <  SetParameters(Statement.SQLParams,params);
537 <  Result := Statement.OpenCursor;
1062 >  Result := OpenCursor(transaction,sql,FSQLDialect,false,params);
1063   end;
1064  
1065 < function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString
1066 <  ): IResultSet;
1065 > function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString;
1066 >  Scrollable: boolean): IResultSet;
1067 > begin
1068 >  Result := OpenCursor(transaction,sql,FSQLDialect,Scrollable,[]);
1069 > end;
1070 >
1071 > function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString;
1072 >  params: array of const): IResultSet;
1073   begin
1074 <  Result := OpenCursor(transaction,sql,FSQLDialect,[]);
1074 >  Result := OpenCursor(transaction,sql,FSQLDialect,false,params);
1075   end;
1076  
1077   function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString;
1078 +  Scrollable: boolean; params: array of const): IResultSet;
1079 + begin
1080 +  Result := OpenCursor(transaction,sql,FSQLDialect,Scrollable,params);
1081 + end;
1082 +
1083 + function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString;
1084 +  aSQLDialect: integer; Scrollable: boolean;
1085    params: array of const): IResultSet;
1086 + var Statement: IStatement;
1087   begin
1088 <  Result := OpenCursor(transaction,sql,FSQLDialect,params);
1088 >  CheckHandle;
1089 >  Statement := Prepare(transaction,sql,aSQLDialect);
1090 >  SetParameters(Statement.SQLParams,params);
1091 >  Result := Statement.OpenCursor(Scrollable);
1092   end;
1093  
1094   function TFBAttachment.OpenCursorAtStart(transaction: ITransaction;
1095 <  sql: AnsiString; aSQLDialect: integer): IResultSet;
1095 >  sql: AnsiString; aSQLDialect: integer; Scrollable: boolean): IResultSet;
1096   begin
1097 <  Result := OpenCursor(transaction,sql,aSQLDialect,[]);
1097 >  Result := OpenCursor(transaction,sql,aSQLDialect,Scrollable,[]);
1098    Result.FetchNext;
1099   end;
1100  
# Line 563 | Line 1105 | begin
1105    Result.FetchNext;
1106   end;
1107  
1108 < function TFBAttachment.OpenCursorAtStart(transaction: ITransaction; sql: AnsiString
1109 <  ): IResultSet;
1108 > function TFBAttachment.OpenCursorAtStart(transaction: ITransaction;
1109 >  sql: AnsiString; aSQLDialect: integer; Scrollable: boolean;
1110 >  params: array of const): IResultSet;
1111 > begin
1112 >  Result := OpenCursor(transaction,sql,aSQLDialect,Scrollable,params);
1113 >  Result.FetchNext;
1114 > end;
1115 >
1116 > function TFBAttachment.OpenCursorAtStart(transaction: ITransaction;
1117 >  sql: AnsiString; Scrollable: boolean): IResultSet;
1118   begin
1119 <  Result := OpenCursorAtStart(transaction,sql,FSQLDialect,[]);
1119 >  Result := OpenCursorAtStart(transaction,sql,FSQLDialect,Scrollable,[]);
1120   end;
1121  
1122   function TFBAttachment.OpenCursorAtStart(transaction: ITransaction;
# Line 575 | Line 1125 | begin
1125    Result := OpenCursorAtStart(transaction,sql,FSQLDialect,params);
1126   end;
1127  
1128 < function TFBAttachment.OpenCursorAtStart(sql: AnsiString): IResultSet;
1128 > function TFBAttachment.OpenCursorAtStart(transaction: ITransaction;
1129 >  sql: AnsiString; Scrollable: boolean; params: array of const): IResultSet;
1130 > begin
1131 >  Result := OpenCursorAtStart(transaction,sql,FSQLDialect,Scrollable,params);
1132 > end;
1133 >
1134 > function TFBAttachment.OpenCursorAtStart(sql: AnsiString; Scrollable: boolean
1135 >  ): IResultSet;
1136 > begin
1137 >  Result := OpenCursorAtStart(sql,Scrollable,[]);
1138 > end;
1139 >
1140 > function TFBAttachment.OpenCursorAtStart(sql: AnsiString; Scrollable: boolean;
1141 >  params: array of const): IResultSet;
1142   begin
1143 <  Result := OpenCursorAtStart(sql,[]);
1143 >  Result := OpenCursorAtStart(StartTransaction([isc_tpb_read,isc_tpb_wait,isc_tpb_concurrency],taCommit),sql,FSQLDialect,
1144 >                   Scrollable,params);
1145   end;
1146  
1147   function TFBAttachment.OpenCursorAtStart(sql: AnsiString;
1148    params: array of const): IResultSet;
1149   begin
1150 <  Result := OpenCursorAtStart(StartTransaction([isc_tpb_read,isc_tpb_wait,isc_tpb_concurrency],taCommit),sql,FSQLDialect,params);
1150 >  Result := OpenCursorAtStart(StartTransaction([isc_tpb_read,isc_tpb_wait,isc_tpb_concurrency],taCommit),sql,FSQLDialect,
1151 >                   false,params);
1152   end;
1153  
1154 < function TFBAttachment.Prepare(transaction: ITransaction; sql: AnsiString
1155 <  ): IStatement;
1154 > function TFBAttachment.Prepare(transaction: ITransaction; sql: AnsiString;
1155 >  CursorName: AnsiString): IStatement;
1156   begin
1157 <  Result := Prepare(transaction,sql,FSQLDialect);
1157 >  Result := Prepare(transaction,sql,FSQLDialect,CursorName);
1158   end;
1159  
1160   function TFBAttachment.PrepareWithNamedParameters(transaction: ITransaction;
1161 <  sql: AnsiString; GenerateParamNames: boolean; CaseSensitiveParams: boolean): IStatement;
1161 >  sql: AnsiString; GenerateParamNames: boolean; CaseSensitiveParams: boolean;
1162 >  CursorName: AnsiString): IStatement;
1163   begin
1164 <  Result := PrepareWithNamedParameters(transaction,sql,FSQLDialect,GenerateParamNames,CaseSensitiveParams);
1164 >  Result := PrepareWithNamedParameters(transaction,sql,FSQLDialect,GenerateParamNames,CaseSensitiveParams,CursorName);
1165   end;
1166  
1167   function TFBAttachment.GetEventHandler(Event: AnsiString): IEvents;
# Line 615 | Line 1181 | begin
1181    Result := FSQLDialect;
1182   end;
1183  
1184 + function TFBAttachment.CreateBlob(transaction: ITransaction; RelationName,
1185 +  ColumnName: AnsiString; BPB: IBPB): IBlob;
1186 + begin
1187 +  Result := CreateBlob(transaction,GetBlobMetaData(Transaction,RelationName,ColumnName),BPB);
1188 + end;
1189 +
1190 + function TFBAttachment.OpenBlob(transaction: ITransaction; RelationName,
1191 +  ColumnName: AnsiString; BlobID: TISC_QUAD; BPB: IBPB): IBlob;
1192 + begin
1193 +  Result := OpenBlob(Transaction,
1194 +                GetBlobMetaData(Transaction,RelationName,ColumnName),
1195 +                BlobID,BPB);
1196 + end;
1197 +
1198   function TFBAttachment.OpenBlob(transaction: ITransaction; Field: ISQLData;
1199    BPB: IBPB): IBlob;
1200   begin
1201    Result := OpenBlob(Transaction,Field.GetBlobMetadata, Field.AsQuad,BPB);
1202   end;
1203  
1204 + function TFBAttachment.CreateArray(transaction: ITransaction; RelationName,
1205 +  ColumnName: AnsiString): IArray;
1206 + begin
1207 +  Result := CreateArray(transaction,GetArrayMetaData(transaction,RelationName,ColumnName));
1208 + end;
1209 +
1210 + function TFBAttachment.OpenArray(transaction: ITransaction; RelationName,
1211 +  ColumnName: AnsiString; ArrayID: TISC_QUAD): IArray;
1212 + begin
1213 +  Result := OpenArray(transaction,
1214 +    GetArrayMetaData(transaction,RelationName,ColumnName),ArrayID);
1215 + end;
1216 +
1217   function TFBAttachment.GetDBInformation(Requests: array of byte
1218    ): IDBInformation;
1219   var ReqBuffer: PByte;
# Line 657 | Line 1250 | begin
1250      Result := GetDBInfo(getBuffer,getDataLength);
1251   end;
1252  
1253 + function TFBAttachment.GetAttachmentID: integer;
1254 + var Info: IDBInformation;
1255 + begin
1256 +  Info := GetDBInformation(isc_info_attachment_id);
1257 +  if (Info.Count > 0) and (Info[0].getItemType = isc_info_attachment_id) then
1258 +    Result := Info[0].getAsInteger
1259 +  else
1260 +    Result := -1;
1261 + end;
1262 +
1263   function TFBAttachment.GetConnectString: AnsiString;
1264   begin
1265    Result := FDatabaseName;
# Line 687 | Line 1290 | begin
1290    Result := FODSMinorVersion;
1291   end;
1292  
1293 + function TFBAttachment.HasDecFloatSupport: boolean;
1294 + begin
1295 +  Result := false;
1296 + end;
1297 +
1298 + function TFBAttachment.GetInlineBlobLimit: integer;
1299 + begin
1300 +  Result := FInlineBlobLimit;
1301 + end;
1302 +
1303 + procedure TFBAttachment.SetInlineBlobLimit(limit: integer);
1304 + begin
1305 +  if limit > 32*1024 then
1306 +     FInlineBlobLimit := 32*1024
1307 +  else
1308 +    FInlineBlobLimit := limit;
1309 + end;
1310 +
1311 + function TFBAttachment.HasBatchMode: boolean;
1312 + begin
1313 +  Result := false;
1314 + end;
1315 +
1316 + function TFBAttachment.HasTable(aTableName: AnsiString): boolean;
1317 + begin
1318 +  Result := OpenCursorAtStart(
1319 +       'Select count(*) From RDB$RELATIONS Where RDB$RELATION_NAME = ?',
1320 +          [aTableName])[0].AsInteger > 0;
1321 + end;
1322 +
1323   function TFBAttachment.HasDefaultCharSet: boolean;
1324   begin
1325    Result := FHasDefaultCharSet
# Line 831 | Line 1464 | begin
1464    CharSetID := CharSets[0].AsInteger;
1465   end;
1466  
1467 + function TFBAttachment.GetTimeZoneServices: ITimeZoneServices;
1468 + begin
1469 +  IBError(ibxeNotSupported,[]);
1470 + end;
1471 +
1472 + function TFBAttachment.HasTimeZoneSupport: boolean;
1473 + begin
1474 +  Result := false;
1475 + end;
1476 +
1477 + { TDPBItem }
1478 +
1479 + function TDPBItem.getParamTypeName: AnsiString;
1480 + begin
1481 +  Result := DPBPrefix + DPBConstantNames[getParamType];
1482 + end;
1483 +
1484 + { TDPB }
1485 +
1486 + constructor TDPB.Create(api: TFBClientAPI);
1487 + begin
1488 +  inherited Create(api);
1489 +  FDataLength := 1;
1490 +  FBuffer^ := isc_dpb_version1;
1491 + end;
1492 +
1493 + function TDPB.GetParamTypeName(ParamType: byte): Ansistring;
1494 + begin
1495 +  if ParamType <= isc_dpb_last_dpb_constant then
1496 +    Result := DPBConstantNames[ParamType]
1497 +  else
1498 +    Result := '';
1499 + end;
1500 +
1501 + {$IFNDEF FPC}
1502 + function TDPB.GetDPBParamTypeName(ParamType: byte): Ansistring;
1503 + begin
1504 +  Result := GetParamTypeName(ParamType);
1505 + end;
1506 + {$ENDIF}
1507 +
1508 + function TDPB.LookupItemType(ParamTypeName: AnsiString): byte;
1509 + var i: byte;
1510 + begin
1511 +  Result := 0;
1512 +  ParamTypeName := LowerCase(ParamTypeName);
1513 +  if (Pos(DPBPrefix, ParamTypeName) = 1) then
1514 +    Delete(ParamTypeName, 1, Length(DPBPrefix));
1515 +
1516 +  for i := 1 to isc_dpb_last_dpb_constant do
1517 +    if (ParamTypeName = DPBConstantNames[i]) then
1518 +    begin
1519 +      Result := i;
1520 +      break;
1521 +    end;
1522 + end;
1523 +
1524   end.
1525  

Diff Legend

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