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 209 by tony, Wed Mar 14 12:48:51 2018 UTC vs.
Revision 291 by tony, Fri Apr 17 10:26:08 2020 UTC

# Line 38 | Line 38 | unit FBAttachment;
38   interface
39  
40   uses
41 <  Classes, SysUtils, {$IFDEF WINDOWS} windows, {$ENDIF} IB,  FBParamBlock, FBActivityMonitor;
41 >  Classes, SysUtils, {$IFDEF WINDOWS} windows, {$ENDIF} IB,  FBParamBlock,
42 >  FBActivityMonitor, FBClientAPI;
43  
44   type
45    TCharsetMap = record
# Line 68 | Line 69 | type
69      FCodePage: TSystemCodePage;
70      FRemoteProtocol: AnsiString;
71      FAuthMethod: AnsiString;
72 <    constructor Create(DatabaseName: AnsiString; DPB: IDPB;
72 >    constructor Create(api: TFBClientAPI; DatabaseName: AnsiString; DPB: IDPB;
73        RaiseExceptionOnConnectError: boolean);
74      procedure CheckHandle; virtual; abstract;
75      function GenerateCreateDatabaseSQL(DatabaseName: AnsiString; aDPB: IDPB): AnsiString;
# Line 80 | Line 81 | type
81      procedure SetParameters(SQLParams: ISQLParams; params: array of const);
82    public
83      destructor Destroy; override;
84 +    function getFirebirdAPI: IFirebirdAPI;
85      function getDPB: IDPB;
86      function AllocateBPB: IBPB;
87      function AllocateDIRB: IDIRB;
# Line 112 | Line 114 | type
114      function Prepare(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer): IStatement; overload; virtual; abstract;
115      function Prepare(transaction: ITransaction; sql: AnsiString): IStatement; overload;
116      function PrepareWithNamedParameters(transaction: ITransaction; sql: AnsiString;
117 <                       aSQLDialect: integer; GenerateParamNames: boolean=false): IStatement; overload; virtual; abstract;
117 >                       aSQLDialect: integer; GenerateParamNames: boolean=false;
118 >                       CaseSensitiveParams: boolean = false): IStatement; overload; virtual; abstract;
119      function PrepareWithNamedParameters(transaction: ITransaction; sql: AnsiString;
120 <                       GenerateParamNames: boolean=false): IStatement; overload;
120 >                       GenerateParamNames: boolean=false;
121 >                       CaseSensitiveParams: boolean = false): IStatement; overload;
122      function GetEventHandler(Events: TStrings): IEvents; overload; virtual; abstract;
123      function GetEventHandler(Event: AnsiString): IEvents; overload;
124  
125      function GetSQLDialect: integer;
126 +    function CreateBlob(transaction: ITransaction; RelationName, ColumnName: AnsiString; BPB: IBPB=nil): IBlob; overload;
127 +    function CreateBlob(transaction: ITransaction; BlobMetaData: IBlobMetaData; BPB: IBPB=nil): IBlob; overload; virtual; abstract;
128      function OpenBlob(transaction: ITransaction; BlobMetaData: IBlobMetaData; BlobID: TISC_QUAD; BPB: IBPB=nil): IBlob; overload; virtual; abstract;
129 +    function OpenBlob(transaction: ITransaction; RelationName, ColumnName: AnsiString; BlobID: TISC_QUAD; BPB: IBPB=nil): IBlob; overload;
130      function OpenBlob(transaction: ITransaction; Field: ISQLData; BPB: IBPB=nil): IBlob; overload;
131 +    function CreateArray(transaction: ITransaction; RelationName, ColumnName: AnsiString
132 +      ): IArray; overload;
133 +    function CreateArray(transaction: ITransaction; ArrayMetaData: IArrayMetaData): IArray; overload; virtual; abstract;
134 +    function OpenArray(transaction: ITransaction; RelationName, ColumnName: AnsiString; ArrayID: TISC_QUAD): IArray; overload;
135 +    function OpenArray(transaction: ITransaction; ArrayMetaData: IArrayMetaData; ArrayID: TISC_QUAD): IArray; overload; virtual; abstract;
136      property SQLDialect: integer read FSQLDialect;
137      property DPB: IDPB read FDPB;
138   public
# Line 143 | Line 155 | public
155    function CharSetWidth(CharSetID: integer; var Width: integer): boolean;
156    procedure RegisterCharSet(CharSetName: AnsiString; CodePage: TSystemCodePage;
157      AllowReverseLookup:boolean; out CharSetID: integer);
158 +  function GetBlobMetaData(Transaction: ITransaction; tableName, columnName: AnsiString): IBlobMetaData; virtual; abstract;
159 +  function GetArrayMetaData(Transaction: ITransaction; tableName, columnName: AnsiString): IArrayMetaData; virtual; abstract;
160    property CharSetID: integer read FCharSetID;
161    property CodePage: TSystemCodePage read FCodePage;
162    end;
# Line 298 | Line 312 | begin
312    FHasDefaultCharSet := CharSetID2CodePage(FCharSetID,FCodePage) and (FCharSetID > 1);
313   end;
314  
315 < constructor TFBAttachment.Create(DatabaseName: AnsiString; DPB: IDPB;
316 <  RaiseExceptionOnConnectError: boolean);
315 > constructor TFBAttachment.Create(api: TFBClientAPI; DatabaseName: AnsiString;
316 >  DPB: IDPB; RaiseExceptionOnConnectError: boolean);
317   begin
318    inherited Create;
319 <  FFirebirdAPI := FirebirdAPI; {Keep reference to interface}
319 >  FFirebirdAPI := api.GetAPI; {Keep reference to interface}
320    FSQLDialect := 3;
321    FDatabaseName := DatabaseName;
322    FDPB := DPB;
# Line 449 | Line 463 | begin
463    inherited Destroy;
464   end;
465  
466 + function TFBAttachment.getFirebirdAPI: IFirebirdAPI;
467 + begin
468 +  Result := FFirebirdAPI;
469 + end;
470 +
471   function TFBAttachment.getDPB: IDPB;
472   begin
473    Result := FDPB;
# Line 456 | Line 475 | end;
475  
476   function TFBAttachment.AllocateBPB: IBPB;
477   begin
478 <  Result := TBPB.Create;
478 >  Result := TBPB.Create(FFirebirdAPI as TFBClientAPI);
479   end;
480  
481   function TFBAttachment.AllocateDIRB: IDIRB;
482   begin
483 <  Result := TDIRB.Create;
483 >  Result := TDIRB.Create(FFirebirdAPI as TFBClientAPI);
484   end;
485  
486   procedure TFBAttachment.ExecImmediate(TPB: array of byte; sql: AnsiString;
# Line 584 | Line 603 | begin
603   end;
604  
605   function TFBAttachment.PrepareWithNamedParameters(transaction: ITransaction;
606 <  sql: AnsiString; GenerateParamNames: boolean): IStatement;
606 >  sql: AnsiString; GenerateParamNames: boolean; CaseSensitiveParams: boolean): IStatement;
607   begin
608 <  Result := PrepareWithNamedParameters(transaction,sql,FSQLDialect,GenerateParamNames);
608 >  Result := PrepareWithNamedParameters(transaction,sql,FSQLDialect,GenerateParamNames,CaseSensitiveParams);
609   end;
610  
611   function TFBAttachment.GetEventHandler(Event: AnsiString): IEvents;
# Line 606 | Line 625 | begin
625    Result := FSQLDialect;
626   end;
627  
628 + function TFBAttachment.CreateBlob(transaction: ITransaction; RelationName,
629 +  ColumnName: AnsiString; BPB: IBPB): IBlob;
630 + begin
631 +  Result := CreateBlob(transaction,GetBlobMetaData(Transaction,RelationName,ColumnName),BPB);
632 + end;
633 +
634 + function TFBAttachment.OpenBlob(transaction: ITransaction; RelationName,
635 +  ColumnName: AnsiString; BlobID: TISC_QUAD; BPB: IBPB): IBlob;
636 + begin
637 +  Result := OpenBlob(Transaction,
638 +                GetBlobMetaData(Transaction,RelationName,ColumnName),
639 +                BlobID,BPB);
640 + end;
641 +
642   function TFBAttachment.OpenBlob(transaction: ITransaction; Field: ISQLData;
643    BPB: IBPB): IBlob;
644   begin
645    Result := OpenBlob(Transaction,Field.GetBlobMetadata, Field.AsQuad,BPB);
646   end;
647  
648 + function TFBAttachment.CreateArray(transaction: ITransaction; RelationName,
649 +  ColumnName: AnsiString): IArray;
650 + begin
651 +  Result := CreateArray(transaction,GetArrayMetaData(transaction,RelationName,ColumnName));
652 + end;
653 +
654 + function TFBAttachment.OpenArray(transaction: ITransaction; RelationName,
655 +  ColumnName: AnsiString; ArrayID: TISC_QUAD): IArray;
656 + begin
657 +  Result := OpenArray(transaction,
658 +    GetArrayMetaData(transaction,RelationName,ColumnName),ArrayID);
659 + end;
660 +
661   function TFBAttachment.GetDBInformation(Requests: array of byte
662    ): IDBInformation;
663   var ReqBuffer: PByte;
# Line 757 | Line 803 | var i: integer;
803   begin
804    Result := false;
805    for i := Low(CharSetMap) to High(CharSetMap) do
806 <    if AnsiCompareStr(CharSetMap[i].CharSetName, CharSetName) = 0 then
806 >    if AnsiCompareText(CharSetMap[i].CharSetName, CharSetName) = 0 then
807      begin
808        CharSetID := CharSetMap[i].CharSetID;
809        Result := true;
# Line 765 | Line 811 | begin
811      end;
812  
813      for i := 0 to Length(FUserCharSetMap) - 1 do
814 <      if AnsiCompareStr(FUserCharSetMap[i].CharSetName, CharSetName) = 0 then
814 >      if AnsiCompareText(FUserCharSetMap[i].CharSetName, CharSetName) = 0 then
815        begin
816          CharSetID := FUserCharSetMap[i].CharSetID;
817          Result := true;

Diff Legend

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