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

Comparing ibx/trunk/fbintf/client/FBStatement.pas (file contents):
Revision 47 by tony, Mon Jan 9 15:31:51 2017 UTC vs.
Revision 263 by tony, Thu Dec 6 15:55:01 2018 UTC

# Line 28 | Line 28
28   *
29   *)
30   unit FBStatement;
31 + {$IFDEF MSWINDOWS}
32 + {$DEFINE WINDOWS}
33 + {$ENDIF}
34  
35   {$IFDEF FPC}
36 < {$mode objfpc}{$H+}
36 > {$mode delphi}
37   {$codepage UTF8}
38   {$interfaces COM}
39   {$ENDIF}
# Line 49 | Line 52 | type
52    TFBStatement = class(TActivityReporter)
53    private
54      FAttachmentIntf: IAttachment;
55 +    FFirebirdClientAPI: TFBClientAPI;
56    protected
57      FTransactionIntf: ITransaction;
58      FExecTransactionIntf: ITransaction;
# Line 57 | Line 61 | type
61      FOpen: boolean;
62      FPrepared: boolean;
63      FPrepareSeqNo: integer; {used to check for out of date references from interfaces}
64 <    FSQL: string;
65 <    FProcessedSQL: string;
64 >    FSQL: AnsiString;
65 >    FProcessedSQL: AnsiString;
66      FHasParamNames: boolean;
67      FBOF: boolean;
68      FEOF: boolean;
# Line 75 | Line 79 | type
79      procedure InternalPrepare;  virtual; abstract;
80      function InternalExecute(aTransaction: ITransaction): IResults;  virtual; abstract;
81      function InternalOpenCursor(aTransaction: ITransaction): IResultSet;   virtual; abstract;
82 +    procedure ProcessSQL(sql: AnsiString; GenerateParamNames: boolean; var processedSQL: AnsiString); virtual; abstract;
83      procedure FreeHandle;  virtual; abstract;
84      procedure InternalClose(Force: boolean); virtual; abstract;
85 +    function TimeStampToMSecs(const TimeStamp: TTimeStamp): Int64;
86    public
87      constructor Create(Attachment: IAttachment; Transaction: ITransaction;
88 <      sql: string; SQLDialect: integer);
88 >      sql: AnsiString; SQLDialect: integer);
89      constructor CreateWithParameterNames(Attachment: IAttachment; Transaction: ITransaction;
90 <      sql: string;  SQLDialect: integer; GenerateParamNames: boolean =false);
90 >      sql: AnsiString;  SQLDialect: integer; GenerateParamNames: boolean =false);
91      destructor Destroy; override;
92      procedure Close;
93      procedure TransactionEnding(aTransaction: ITransaction; Force: boolean);
94      property SQLDialect: integer read FSQLDialect;
95 +    property FirebirdClientAPI: TFBClientAPI read FFirebirdClientAPI;
96  
97    public
98      function GetSQLParams: ISQLParams; virtual; abstract;
# Line 93 | Line 100 | type
100      function GetRowsAffected(var SelectCount, InsertCount, UpdateCount,
101        DeleteCount: integer): boolean;
102      function GetSQLStatementType: TIBSQLStatementTypes;
103 <    function GetSQLText: string;
103 >    function GetSQLText: AnsiString;
104 >    function GetProcessedSQLText: AnsiString;
105      function GetSQLDialect: integer;
106  
107      {GetDSQLInfo only supports isc_info_sql_stmt_type, isc_info_sql_get_plan, isc_info_sql_records}
108      procedure Prepare(aTransaction: ITransaction=nil); virtual;
109      function Execute(aTransaction: ITransaction=nil): IResults;
110      function OpenCursor(aTransaction: ITransaction=nil): IResultSet;
111 <    function CreateBlob(paramName: string): IBlob; overload;
111 >    function CreateBlob(paramName: AnsiString): IBlob; overload;
112      function CreateBlob(index: integer): IBlob; overload;
113      function CreateBlob(column: TColumnMetaData): IBlob; overload; virtual; abstract;
114 <    function CreateArray(paramName: string): IArray; overload;
114 >    function CreateArray(paramName: AnsiString): IArray; overload;
115      function CreateArray(index: integer): IArray;  overload;
116      function CreateArray(column: TColumnMetaData): IArray; overload; virtual; abstract;
117      function GetAttachment: IAttachment;
# Line 132 | Line 140 | begin
140      IBError(ibxeNotInTransaction,[]);
141   end;
142  
143 + function TFBStatement.TimeStampToMSecs(const TimeStamp: TTimeStamp): Int64;
144 + begin
145 +  Result := TimeStamp.Time + Int64(timestamp.date)*msecsperday;
146 + end;
147 +
148   constructor TFBStatement.Create(Attachment: IAttachment;
149 <  Transaction: ITransaction; sql: string; SQLDialect: integer);
149 >  Transaction: ITransaction; sql: AnsiString; SQLDialect: integer);
150   begin
151    inherited Create(Transaction as TFBTransaction,2);
152    FAttachmentIntf := Attachment;
153    FTransactionIntf := Transaction;
154 +  FFirebirdClientAPI := Attachment.getFirebirdAPI as TFBClientAPI;
155    FSQLDialect := SQLDialect;
156    FSQL := sql;
157   end;
158  
159   constructor TFBStatement.CreateWithParameterNames(Attachment: IAttachment;
160 <  Transaction: ITransaction; sql: string; SQLDialect: integer;
160 >  Transaction: ITransaction; sql: AnsiString; SQLDialect: integer;
161    GenerateParamNames: boolean);
162   begin
163    FHasParamNames := true;
# Line 214 | Line 228 | begin
228    Result := FSQLStatementType;
229   end;
230  
231 < function TFBStatement.GetSQLText: string;
231 > function TFBStatement.GetSQLText: AnsiString;
232   begin
233    Result := FSQL;
234   end;
235  
236 + function TFBStatement.GetProcessedSQLText: AnsiString;
237 + begin
238 +  if FProcessedSQL = '' then
239 +    ProcessSQL(FSQL,FGenerateParamNames,FProcessedSQL);
240 +  Result := FProcessedSQL
241 + end;
242 +
243   function TFBStatement.GetSQLDialect: integer;
244   begin
245    Result := FSQLDialect;
# Line 253 | Line 274 | begin
274      Result := InternalOpenCursor(aTransaction);
275   end;
276  
277 < function TFBStatement.CreateBlob(paramName: string): IBlob;
277 > function TFBStatement.CreateBlob(paramName: AnsiString): IBlob;
278   var column: TColumnMetaData;
279   begin
280    InternalPrepare;
# Line 269 | Line 290 | begin
290    Result := CreateBlob(SQLParams[index] as TSQLParam);
291   end;
292  
293 < function TFBStatement.CreateArray(paramName: string): IArray;
293 > function TFBStatement.CreateArray(paramName: AnsiString): IArray;
294   var column: TColumnMetaData;
295   begin
296    InternalPrepare;
# Line 297 | Line 318 | end;
318  
319   function TFBStatement.GetDSQLInfo(Request: byte): ISQLInfoResults;
320   begin
321 <  Result := TSQLInfoResultsBuffer.Create;
321 >  Result := TSQLInfoResultsBuffer.Create(FFirebirdClientAPI);
322    GetDsqlInfo(Request,Result);
323   end;
324  

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines