41 |
|
Classes, SysUtils, {$IFDEF WINDOWS} windows, {$ENDIF} IB, FBParamBlock, |
42 |
|
FBActivityMonitor, FBClientAPI; |
43 |
|
|
44 |
+ |
const |
45 |
+ |
DefaultMaxInlineBlobLimit = 8192; |
46 |
+ |
|
47 |
|
type |
48 |
|
TCharsetMap = record |
49 |
|
CharsetID: integer; |
63 |
|
FODSMinorVersion: integer; |
64 |
|
FUserCharSetMap: array of TCharSetMap; |
65 |
|
FSecDatabase: AnsiString; |
66 |
+ |
FInlineBlobLimit: integer; |
67 |
|
protected |
68 |
|
FDatabaseName: AnsiString; |
69 |
|
FRaiseExceptionOnConnectError: boolean; |
83 |
|
procedure EndAllTransactions; |
84 |
|
procedure DPBFromCreateSQL(CreateSQL: AnsiString); |
85 |
|
procedure SetParameters(SQLParams: ISQLParams; params: array of const); |
86 |
+ |
procedure UseServerICUChanged; virtual; |
87 |
|
public |
88 |
|
destructor Destroy; override; |
89 |
|
function getFirebirdAPI: IFirebirdAPI; |
101 |
|
function ExecuteSQL(transaction: ITransaction; sql: AnsiString; SQLDialect: integer; params: array of const): IResults; overload; |
102 |
|
function ExecuteSQL(TPB: array of byte; sql: AnsiString; params: array of const): IResults; overload; |
103 |
|
function ExecuteSQL(transaction: ITransaction; sql: AnsiString; params: array of const): IResults; overload; |
104 |
< |
function OpenCursor(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer): IResultSet; overload; |
104 |
> |
function OpenCursor(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; |
105 |
> |
Scrollable: boolean=false): IResultSet; overload; |
106 |
|
function OpenCursor(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; |
107 |
|
params: array of const): IResultSet; overload; |
108 |
< |
function OpenCursor(transaction: ITransaction; sql: AnsiString): IResultSet; overload; |
108 |
> |
function OpenCursor(transaction: ITransaction; sql: AnsiString; Scrollable: boolean=false): IResultSet; overload; |
109 |
|
function OpenCursor(transaction: ITransaction; sql: AnsiString; |
110 |
|
params: array of const): IResultSet; overload; |
111 |
< |
function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer): IResultSet; overload; |
111 |
> |
function OpenCursor(transaction: ITransaction; sql: AnsiString; Scrollable: boolean; |
112 |
> |
params: array of const): IResultSet; overload; |
113 |
> |
function OpenCursor(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; Scrollable: boolean; |
114 |
> |
params: array of const): IResultSet; overload; |
115 |
> |
function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; |
116 |
> |
Scrollable: boolean=false): IResultSet; overload; |
117 |
|
function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; |
118 |
|
params: array of const): IResultSet; overload; |
119 |
< |
function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString): IResultSet; overload; |
119 |
> |
function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; Scrollable: boolean; |
120 |
> |
params: array of const): IResultSet; overload; |
121 |
> |
function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; Scrollable: boolean=false): IResultSet; overload; |
122 |
|
function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; |
123 |
|
params: array of const): IResultSet; overload; |
124 |
< |
function OpenCursorAtStart(sql: AnsiString): IResultSet; overload; |
124 |
> |
function OpenCursorAtStart(transaction: ITransaction; sql: AnsiString; Scrollable: boolean; |
125 |
> |
params: array of const): IResultSet; overload; |
126 |
> |
function OpenCursorAtStart(sql: AnsiString;Scrollable: boolean=false): IResultSet; overload; |
127 |
> |
function OpenCursorAtStart(sql: AnsiString; Scrollable: boolean; |
128 |
> |
params: array of const): IResultSet; overload; |
129 |
|
function OpenCursorAtStart(sql: AnsiString; |
130 |
|
params: array of const): IResultSet; overload; |
131 |
< |
function Prepare(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer): IStatement; overload; virtual; abstract; |
132 |
< |
function Prepare(transaction: ITransaction; sql: AnsiString): IStatement; overload; |
131 |
> |
function Prepare(transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; CursorName: AnsiString=''): IStatement; overload; virtual; abstract; |
132 |
> |
function Prepare(transaction: ITransaction; sql: AnsiString; CursorName: AnsiString=''): IStatement; overload; |
133 |
|
function PrepareWithNamedParameters(transaction: ITransaction; sql: AnsiString; |
134 |
|
aSQLDialect: integer; GenerateParamNames: boolean=false; |
135 |
< |
CaseSensitiveParams: boolean = false): IStatement; overload; virtual; abstract; |
135 |
> |
CaseSensitiveParams: boolean = false; CursorName: AnsiString=''): IStatement; overload; virtual; abstract; |
136 |
|
function PrepareWithNamedParameters(transaction: ITransaction; sql: AnsiString; |
137 |
|
GenerateParamNames: boolean=false; |
138 |
< |
CaseSensitiveParams: boolean = false): IStatement; overload; |
138 |
> |
CaseSensitiveParams: boolean = false; CursorName: AnsiString=''): IStatement; overload; |
139 |
|
function GetEventHandler(Events: TStrings): IEvents; overload; virtual; abstract; |
140 |
|
function GetEventHandler(Event: AnsiString): IEvents; overload; |
141 |
|
|
152 |
|
function OpenArray(transaction: ITransaction; ArrayMetaData: IArrayMetaData; ArrayID: TISC_QUAD): IArray; overload; virtual; abstract; |
153 |
|
property SQLDialect: integer read FSQLDialect; |
154 |
|
property DPB: IDPB read FDPB; |
155 |
< |
public |
156 |
< |
function GetDBInformation(Requests: array of byte): IDBInformation; overload; |
157 |
< |
function GetDBInformation(Request: byte): IDBInformation; overload; |
158 |
< |
function GetDBInformation(Requests: IDIRB): IDBInformation; overload; |
159 |
< |
function GetConnectString: AnsiString; |
160 |
< |
function GetRemoteProtocol: AnsiString; |
161 |
< |
function GetAuthenticationMethod: AnsiString; |
162 |
< |
function GetSecurityDatabase: AnsiString; |
163 |
< |
function GetODSMajorVersion: integer; |
164 |
< |
function GetODSMinorVersion: integer; |
165 |
< |
{Character Sets} |
166 |
< |
function HasDefaultCharSet: boolean; |
167 |
< |
function GetDefaultCharSetID: integer; |
168 |
< |
function GetCharsetName(CharSetID: integer): AnsiString; |
169 |
< |
function CharSetID2CodePage(CharSetID: integer; var CodePage: TSystemCodePage): boolean; |
170 |
< |
function CodePage2CharSetID(CodePage: TSystemCodePage; var CharSetID: integer): boolean; |
171 |
< |
function CharSetName2CharSetID(CharSetName: AnsiString; var CharSetID: integer): boolean; |
172 |
< |
function CharSetWidth(CharSetID: integer; var Width: integer): boolean; |
173 |
< |
procedure RegisterCharSet(CharSetName: AnsiString; CodePage: TSystemCodePage; |
174 |
< |
AllowReverseLookup:boolean; out CharSetID: integer); |
175 |
< |
function GetBlobMetaData(Transaction: ITransaction; tableName, columnName: AnsiString): IBlobMetaData; virtual; abstract; |
176 |
< |
function GetArrayMetaData(Transaction: ITransaction; tableName, columnName: AnsiString): IArrayMetaData; virtual; abstract; |
177 |
< |
property CharSetID: integer read FCharSetID; |
178 |
< |
property CodePage: TSystemCodePage read FCodePage; |
155 |
> |
public |
156 |
> |
function GetDBInformation(Requests: array of byte): IDBInformation; overload; |
157 |
> |
function GetDBInformation(Request: byte): IDBInformation; overload; |
158 |
> |
function GetDBInformation(Requests: IDIRB): IDBInformation; overload; |
159 |
> |
function GetConnectString: AnsiString; |
160 |
> |
function GetRemoteProtocol: AnsiString; |
161 |
> |
function GetAuthenticationMethod: AnsiString; |
162 |
> |
function GetSecurityDatabase: AnsiString; |
163 |
> |
function GetODSMajorVersion: integer; |
164 |
> |
function GetODSMinorVersion: integer; |
165 |
> |
function HasDecFloatSupport: boolean; virtual; |
166 |
> |
function GetInlineBlobLimit: integer; |
167 |
> |
procedure SetInlineBlobLimit(limit: integer); |
168 |
> |
function HasBatchMode: boolean; virtual; |
169 |
> |
|
170 |
> |
public |
171 |
> |
{Character Sets} |
172 |
> |
function HasDefaultCharSet: boolean; |
173 |
> |
function GetDefaultCharSetID: integer; |
174 |
> |
function GetCharsetName(CharSetID: integer): AnsiString; |
175 |
> |
function CharSetID2CodePage(CharSetID: integer; var CodePage: TSystemCodePage): boolean; |
176 |
> |
function CodePage2CharSetID(CodePage: TSystemCodePage; var CharSetID: integer): boolean; |
177 |
> |
function CharSetName2CharSetID(CharSetName: AnsiString; var CharSetID: integer): boolean; |
178 |
> |
function CharSetWidth(CharSetID: integer; var Width: integer): boolean; |
179 |
> |
procedure RegisterCharSet(CharSetName: AnsiString; CodePage: TSystemCodePage; |
180 |
> |
AllowReverseLookup:boolean; out CharSetID: integer); |
181 |
> |
function GetBlobMetaData(Transaction: ITransaction; tableName, columnName: AnsiString): IBlobMetaData; virtual; abstract; |
182 |
> |
function GetArrayMetaData(Transaction: ITransaction; tableName, columnName: AnsiString): IArrayMetaData; virtual; abstract; |
183 |
> |
property CharSetID: integer read FCharSetID; |
184 |
> |
property CodePage: TSystemCodePage read FCodePage; |
185 |
> |
|
186 |
> |
public |
187 |
> |
{Time Zone Support} |
188 |
> |
function GetTimeZoneServices: ITimeZoneServices; virtual; |
189 |
> |
function HasTimeZoneSupport: boolean; virtual; |
190 |
> |
|
191 |
> |
end; |
192 |
> |
|
193 |
> |
{ TDPBItem } |
194 |
> |
|
195 |
> |
TDPBItem = class(TParamBlockItem,IDPBItem) |
196 |
> |
public |
197 |
> |
function getParamTypeName: AnsiString; override; |
198 |
> |
end; |
199 |
> |
|
200 |
> |
{ TDPB } |
201 |
> |
|
202 |
> |
TDPB = class (TCustomParamBlock<TDPBItem,IDPBItem>, IDPB) |
203 |
> |
protected |
204 |
> |
function LookupItemType(ParamTypeName: AnsiString): byte; override; |
205 |
> |
public |
206 |
> |
constructor Create(api: TFBClientAPI); |
207 |
> |
function GetParamTypeName(ParamType: byte): Ansistring; |
208 |
> |
{$IFDEF FPC} |
209 |
> |
function IDPB.GetDPBParamTypeName = GetParamTypeName; |
210 |
> |
{$ELSE} |
211 |
> |
function GetDPBParamTypeName(ParamType: byte): Ansistring; |
212 |
> |
{$ENDIF} |
213 |
|
end; |
214 |
|
|
215 |
|
implementation |
290 |
|
(CharsetID: 69; CharSetName: 'GB18030'; CharSetWidth: 4; CodePage: 54936; AllowReverseLookup: true) |
291 |
|
); |
292 |
|
|
293 |
+ |
const |
294 |
+ |
isc_dpb_last_dpb_constant = isc_dpb_decfloat_traps; |
295 |
+ |
|
296 |
+ |
DPBConstantNames: array[1..isc_dpb_last_dpb_constant] of string = ( |
297 |
+ |
'cdd_pathname', |
298 |
+ |
'allocation', |
299 |
+ |
'journal', |
300 |
+ |
'page_size', |
301 |
+ |
'num_buffers', |
302 |
+ |
'buffer_length', |
303 |
+ |
'debug', |
304 |
+ |
'garbage_collect', |
305 |
+ |
'verify', |
306 |
+ |
'sweep', |
307 |
+ |
'enable_journal', |
308 |
+ |
'disable_journal', |
309 |
+ |
'dbkey_scope', |
310 |
+ |
'number_of_users', |
311 |
+ |
'trace', |
312 |
+ |
'no_garbage_collect', |
313 |
+ |
'damaged', |
314 |
+ |
'license', |
315 |
+ |
'sys_user_name', |
316 |
+ |
'encrypt_key', |
317 |
+ |
'activate_shadow', |
318 |
+ |
'sweep_interval', |
319 |
+ |
'delete_shadow', |
320 |
+ |
'force_write', |
321 |
+ |
'begin_log', |
322 |
+ |
'quit_log', |
323 |
+ |
'no_reserve', |
324 |
+ |
'user_name', |
325 |
+ |
'password', |
326 |
+ |
'password_enc', |
327 |
+ |
'sys_user_name_enc', |
328 |
+ |
'interp', |
329 |
+ |
'online_dump', |
330 |
+ |
'old_file_size', |
331 |
+ |
'old_num_files', |
332 |
+ |
'old_file', |
333 |
+ |
'old_start_page', |
334 |
+ |
'old_start_seqno', |
335 |
+ |
'old_start_file', |
336 |
+ |
'drop_walfile', |
337 |
+ |
'old_dump_id', |
338 |
+ |
'wal_backup_dir', |
339 |
+ |
'wal_chkptlen', |
340 |
+ |
'wal_numbufs', |
341 |
+ |
'wal_bufsize', |
342 |
+ |
'wal_grp_cmt_wait', |
343 |
+ |
'lc_messages', |
344 |
+ |
'lc_ctype', |
345 |
+ |
'cache_manager', |
346 |
+ |
'shutdown', |
347 |
+ |
'online', |
348 |
+ |
'shutdown_delay', |
349 |
+ |
'reserved', |
350 |
+ |
'overwrite', |
351 |
+ |
'sec_attach', |
352 |
+ |
'disable_wal', |
353 |
+ |
'connect_timeout', |
354 |
+ |
'dummy_packet_interval', |
355 |
+ |
'gbak_attach', |
356 |
+ |
'sql_role_name', |
357 |
+ |
'set_page_buffers', |
358 |
+ |
'working_directory', |
359 |
+ |
'sql_dialect', |
360 |
+ |
'set_db_readonly', |
361 |
+ |
'set_db_sql_dialect', |
362 |
+ |
'gfix_attach', |
363 |
+ |
'gstat_attach', |
364 |
+ |
'set_db_charset', |
365 |
+ |
'gsec_attach', |
366 |
+ |
'address_path' , |
367 |
+ |
'process_id', |
368 |
+ |
'no_db_triggers', |
369 |
+ |
'trusted_auth', |
370 |
+ |
'process_name', |
371 |
+ |
'trusted_role', |
372 |
+ |
'org_filename', |
373 |
+ |
'utf8_ilename', |
374 |
+ |
'ext_call_depth', |
375 |
+ |
'auth_block', |
376 |
+ |
'client_version', |
377 |
+ |
'remote_protocol', |
378 |
+ |
'host_name', |
379 |
+ |
'os_user', |
380 |
+ |
'specific_auth_data', |
381 |
+ |
'auth_plugin_list', |
382 |
+ |
'auth_plugin_name', |
383 |
+ |
'config', |
384 |
+ |
'nolinger', |
385 |
+ |
'reset_icu', |
386 |
+ |
'map_attach', |
387 |
+ |
'session_time_zone', |
388 |
+ |
'set_db_replica', |
389 |
+ |
'set_bind', |
390 |
+ |
'decfloat_round', |
391 |
+ |
'decfloat_traps' |
392 |
+ |
); |
393 |
|
|
394 |
|
|
395 |
|
|
424 |
|
begin |
425 |
|
Stmt := Prepare(StartTransaction([isc_tpb_read,isc_tpb_nowait,isc_tpb_concurrency],taCommit), |
426 |
|
'Select MON$CHARACTER_SET_ID, MON$REMOTE_PROTOCOL, MON$AUTH_METHOD, MON$SEC_DATABASE From MON$ATTACHMENTS, MON$DATABASE '+ |
427 |
< |
'Where MON$ATTACHMENT_ID = CURRENT_CONNECTION'); |
427 |
> |
'Where MON$ATTACHMENT_ID = CURRENT_CONNECTION '); |
428 |
|
ResultSet := Stmt.OpenCursor; |
429 |
|
if ResultSet.FetchNext then |
430 |
|
begin |
475 |
|
FRaiseExceptionOnConnectError := RaiseExceptionOnConnectError; |
476 |
|
FODSMajorVersion := 0; |
477 |
|
FODSMinorVersion := 0; |
478 |
+ |
FInlineBlobLimit := DefaultMaxInlineBlobLimit; |
479 |
|
end; |
480 |
|
|
481 |
|
function TFBAttachment.GenerateCreateDatabaseSQL(DatabaseName: AnsiString; aDPB: IDPB): AnsiString; |
609 |
|
end; |
610 |
|
end; |
611 |
|
|
612 |
+ |
procedure TFBAttachment.UseServerICUChanged; |
613 |
+ |
begin |
614 |
+ |
// Do nothing by default |
615 |
+ |
end; |
616 |
+ |
|
617 |
|
destructor TFBAttachment.Destroy; |
618 |
|
begin |
619 |
|
Disconnect(true); |
689 |
|
end; |
690 |
|
|
691 |
|
function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString; |
692 |
< |
aSQLDialect: integer): IResultSet; |
692 |
> |
aSQLDialect: integer; Scrollable: boolean): IResultSet; |
693 |
|
begin |
694 |
< |
Result := OpenCursor(transaction,sql,aSQLDialect,[]); |
694 |
> |
Result := OpenCursor(transaction,sql,aSQLDialect,Scrollable,[]); |
695 |
|
end; |
696 |
|
|
697 |
|
function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString; |
698 |
|
aSQLDialect: integer; params: array of const): IResultSet; |
699 |
< |
var Statement: IStatement; |
699 |
> |
|
700 |
|
begin |
701 |
< |
CheckHandle; |
545 |
< |
Statement := Prepare(transaction,sql,aSQLDialect); |
546 |
< |
SetParameters(Statement.SQLParams,params); |
547 |
< |
Result := Statement.OpenCursor; |
701 |
> |
Result := OpenCursor(transaction,sql,FSQLDialect,false,params); |
702 |
|
end; |
703 |
|
|
704 |
< |
function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString |
705 |
< |
): IResultSet; |
704 |
> |
function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString; |
705 |
> |
Scrollable: boolean): IResultSet; |
706 |
> |
begin |
707 |
> |
Result := OpenCursor(transaction,sql,FSQLDialect,Scrollable,[]); |
708 |
> |
end; |
709 |
> |
|
710 |
> |
function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString; |
711 |
> |
params: array of const): IResultSet; |
712 |
|
begin |
713 |
< |
Result := OpenCursor(transaction,sql,FSQLDialect,[]); |
713 |
> |
Result := OpenCursor(transaction,sql,FSQLDialect,false,params); |
714 |
|
end; |
715 |
|
|
716 |
|
function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString; |
717 |
+ |
Scrollable: boolean; params: array of const): IResultSet; |
718 |
+ |
begin |
719 |
+ |
Result := OpenCursor(transaction,sql,FSQLDialect,Scrollable,params); |
720 |
+ |
end; |
721 |
+ |
|
722 |
+ |
function TFBAttachment.OpenCursor(transaction: ITransaction; sql: AnsiString; |
723 |
+ |
aSQLDialect: integer; Scrollable: boolean; |
724 |
|
params: array of const): IResultSet; |
725 |
+ |
var Statement: IStatement; |
726 |
|
begin |
727 |
< |
Result := OpenCursor(transaction,sql,FSQLDialect,params); |
727 |
> |
CheckHandle; |
728 |
> |
Statement := Prepare(transaction,sql,aSQLDialect); |
729 |
> |
SetParameters(Statement.SQLParams,params); |
730 |
> |
Result := Statement.OpenCursor(Scrollable); |
731 |
|
end; |
732 |
|
|
733 |
|
function TFBAttachment.OpenCursorAtStart(transaction: ITransaction; |
734 |
< |
sql: AnsiString; aSQLDialect: integer): IResultSet; |
734 |
> |
sql: AnsiString; aSQLDialect: integer; Scrollable: boolean): IResultSet; |
735 |
|
begin |
736 |
< |
Result := OpenCursor(transaction,sql,aSQLDialect,[]); |
736 |
> |
Result := OpenCursor(transaction,sql,aSQLDialect,Scrollable,[]); |
737 |
|
Result.FetchNext; |
738 |
|
end; |
739 |
|
|
744 |
|
Result.FetchNext; |
745 |
|
end; |
746 |
|
|
747 |
< |
function TFBAttachment.OpenCursorAtStart(transaction: ITransaction; sql: AnsiString |
748 |
< |
): IResultSet; |
747 |
> |
function TFBAttachment.OpenCursorAtStart(transaction: ITransaction; |
748 |
> |
sql: AnsiString; aSQLDialect: integer; Scrollable: boolean; |
749 |
> |
params: array of const): IResultSet; |
750 |
|
begin |
751 |
< |
Result := OpenCursorAtStart(transaction,sql,FSQLDialect,[]); |
751 |
> |
Result := OpenCursor(transaction,sql,aSQLDialect,Scrollable,params); |
752 |
> |
Result.FetchNext; |
753 |
> |
end; |
754 |
> |
|
755 |
> |
function TFBAttachment.OpenCursorAtStart(transaction: ITransaction; |
756 |
> |
sql: AnsiString; Scrollable: boolean): IResultSet; |
757 |
> |
begin |
758 |
> |
Result := OpenCursorAtStart(transaction,sql,FSQLDialect,Scrollable,[]); |
759 |
|
end; |
760 |
|
|
761 |
|
function TFBAttachment.OpenCursorAtStart(transaction: ITransaction; |
764 |
|
Result := OpenCursorAtStart(transaction,sql,FSQLDialect,params); |
765 |
|
end; |
766 |
|
|
767 |
< |
function TFBAttachment.OpenCursorAtStart(sql: AnsiString): IResultSet; |
767 |
> |
function TFBAttachment.OpenCursorAtStart(transaction: ITransaction; |
768 |
> |
sql: AnsiString; Scrollable: boolean; params: array of const): IResultSet; |
769 |
> |
begin |
770 |
> |
Result := OpenCursorAtStart(transaction,sql,FSQLDialect,Scrollable,params); |
771 |
> |
end; |
772 |
> |
|
773 |
> |
function TFBAttachment.OpenCursorAtStart(sql: AnsiString; Scrollable: boolean |
774 |
> |
): IResultSet; |
775 |
> |
begin |
776 |
> |
Result := OpenCursorAtStart(sql,Scrollable,[]); |
777 |
> |
end; |
778 |
> |
|
779 |
> |
function TFBAttachment.OpenCursorAtStart(sql: AnsiString; Scrollable: boolean; |
780 |
> |
params: array of const): IResultSet; |
781 |
|
begin |
782 |
< |
Result := OpenCursorAtStart(sql,[]); |
782 |
> |
Result := OpenCursorAtStart(StartTransaction([isc_tpb_read,isc_tpb_wait,isc_tpb_concurrency],taCommit),sql,FSQLDialect, |
783 |
> |
Scrollable,params); |
784 |
|
end; |
785 |
|
|
786 |
|
function TFBAttachment.OpenCursorAtStart(sql: AnsiString; |
787 |
|
params: array of const): IResultSet; |
788 |
|
begin |
789 |
< |
Result := OpenCursorAtStart(StartTransaction([isc_tpb_read,isc_tpb_wait,isc_tpb_concurrency],taCommit),sql,FSQLDialect,params); |
789 |
> |
Result := OpenCursorAtStart(StartTransaction([isc_tpb_read,isc_tpb_wait,isc_tpb_concurrency],taCommit),sql,FSQLDialect, |
790 |
> |
false,params); |
791 |
|
end; |
792 |
|
|
793 |
< |
function TFBAttachment.Prepare(transaction: ITransaction; sql: AnsiString |
794 |
< |
): IStatement; |
793 |
> |
function TFBAttachment.Prepare(transaction: ITransaction; sql: AnsiString; |
794 |
> |
CursorName: AnsiString): IStatement; |
795 |
|
begin |
796 |
< |
Result := Prepare(transaction,sql,FSQLDialect); |
796 |
> |
Result := Prepare(transaction,sql,FSQLDialect,CursorName); |
797 |
|
end; |
798 |
|
|
799 |
|
function TFBAttachment.PrepareWithNamedParameters(transaction: ITransaction; |
800 |
< |
sql: AnsiString; GenerateParamNames: boolean; CaseSensitiveParams: boolean): IStatement; |
800 |
> |
sql: AnsiString; GenerateParamNames: boolean; CaseSensitiveParams: boolean; |
801 |
> |
CursorName: AnsiString): IStatement; |
802 |
|
begin |
803 |
< |
Result := PrepareWithNamedParameters(transaction,sql,FSQLDialect,GenerateParamNames,CaseSensitiveParams); |
803 |
> |
Result := PrepareWithNamedParameters(transaction,sql,FSQLDialect,GenerateParamNames,CaseSensitiveParams,CursorName); |
804 |
|
end; |
805 |
|
|
806 |
|
function TFBAttachment.GetEventHandler(Event: AnsiString): IEvents; |
919 |
|
Result := FODSMinorVersion; |
920 |
|
end; |
921 |
|
|
922 |
+ |
function TFBAttachment.HasDecFloatSupport: boolean; |
923 |
+ |
begin |
924 |
+ |
Result := false; |
925 |
+ |
end; |
926 |
+ |
|
927 |
+ |
function TFBAttachment.GetInlineBlobLimit: integer; |
928 |
+ |
begin |
929 |
+ |
Result := FInlineBlobLimit; |
930 |
+ |
end; |
931 |
+ |
|
932 |
+ |
procedure TFBAttachment.SetInlineBlobLimit(limit: integer); |
933 |
+ |
begin |
934 |
+ |
if limit > 32*1024 then |
935 |
+ |
FInlineBlobLimit := 32*1024 |
936 |
+ |
else |
937 |
+ |
FInlineBlobLimit := limit; |
938 |
+ |
end; |
939 |
+ |
|
940 |
+ |
function TFBAttachment.HasBatchMode: boolean; |
941 |
+ |
begin |
942 |
+ |
Result := false; |
943 |
+ |
end; |
944 |
+ |
|
945 |
|
function TFBAttachment.HasDefaultCharSet: boolean; |
946 |
|
begin |
947 |
|
Result := FHasDefaultCharSet |
1086 |
|
CharSetID := CharSets[0].AsInteger; |
1087 |
|
end; |
1088 |
|
|
1089 |
+ |
function TFBAttachment.GetTimeZoneServices: ITimeZoneServices; |
1090 |
+ |
begin |
1091 |
+ |
IBError(ibxeNotSupported,[]); |
1092 |
+ |
end; |
1093 |
+ |
|
1094 |
+ |
function TFBAttachment.HasTimeZoneSupport: boolean; |
1095 |
+ |
begin |
1096 |
+ |
Result := false; |
1097 |
+ |
end; |
1098 |
+ |
|
1099 |
+ |
{ TDPBItem } |
1100 |
+ |
|
1101 |
+ |
function TDPBItem.getParamTypeName: AnsiString; |
1102 |
+ |
begin |
1103 |
+ |
Result := DPBPrefix + DPBConstantNames[getParamType]; |
1104 |
+ |
end; |
1105 |
+ |
|
1106 |
+ |
{ TDPB } |
1107 |
+ |
|
1108 |
+ |
constructor TDPB.Create(api: TFBClientAPI); |
1109 |
+ |
begin |
1110 |
+ |
inherited Create(api); |
1111 |
+ |
FDataLength := 1; |
1112 |
+ |
FBuffer^ := isc_dpb_version1; |
1113 |
+ |
end; |
1114 |
+ |
|
1115 |
+ |
function TDPB.GetParamTypeName(ParamType: byte): Ansistring; |
1116 |
+ |
begin |
1117 |
+ |
if ParamType <= isc_dpb_last_dpb_constant then |
1118 |
+ |
Result := DPBConstantNames[ParamType] |
1119 |
+ |
else |
1120 |
+ |
Result := ''; |
1121 |
+ |
end; |
1122 |
+ |
|
1123 |
+ |
{$IFNDEF FPC} |
1124 |
+ |
function TDPB.GetDPBParamTypeName(ParamType: byte): Ansistring; |
1125 |
+ |
begin |
1126 |
+ |
Result := GetParamTypeName(ParamType); |
1127 |
+ |
end; |
1128 |
+ |
{$ENDIF} |
1129 |
+ |
|
1130 |
+ |
function TDPB.LookupItemType(ParamTypeName: AnsiString): byte; |
1131 |
+ |
var i: byte; |
1132 |
+ |
begin |
1133 |
+ |
Result := 0; |
1134 |
+ |
ParamTypeName := LowerCase(ParamTypeName); |
1135 |
+ |
if (Pos(DPBPrefix, ParamTypeName) = 1) then |
1136 |
+ |
Delete(ParamTypeName, 1, Length(DPBPrefix)); |
1137 |
+ |
|
1138 |
+ |
for i := 1 to isc_dpb_last_dpb_constant do |
1139 |
+ |
if (ParamTypeName = DPBConstantNames[i]) then |
1140 |
+ |
begin |
1141 |
+ |
Result := i; |
1142 |
+ |
break; |
1143 |
+ |
end; |
1144 |
+ |
end; |
1145 |
+ |
|
1146 |
|
end. |
1147 |
|
|