35 |
|
|
36 |
|
{$Mode Delphi} |
37 |
|
|
38 |
– |
{$IF FPC_FULLVERSION >= 20700 } |
38 |
|
{$codepage UTF8} |
40 |
– |
{$ENDIF} |
39 |
|
|
40 |
|
interface |
41 |
|
|
42 |
|
uses SysUtils, Classes, DB, IB, IBDatabase, IBCustomDataSet, |
43 |
< |
IBHeader, IBSQL, IBUtils; |
43 |
> |
IBSQL, IBUtils; |
44 |
|
|
45 |
|
{ TIBStoredProc } |
46 |
|
type |
47 |
|
|
48 |
|
TIBStoredProc = class(TIBCustomDataSet) |
49 |
|
private |
50 |
< |
FIBLoaded: Boolean; |
53 |
< |
FStmtHandle: TISC_STMT_HANDLE; |
50 |
> |
FStmtHandle: IStatement; |
51 |
|
FProcName: string; |
52 |
|
FParams: TParams; |
53 |
|
FPrepared: Boolean; |
85 |
|
procedure Prepare; |
86 |
|
procedure UnPrepare; |
87 |
|
property ParamCount: Word read GetParamsCount; |
88 |
< |
property StmtHandle: TISC_STMT_HANDLE read FStmtHandle; |
88 |
> |
property StmtHandle: IStatement read FStmtHandle; |
89 |
|
property Prepared: Boolean read FPrepared write SetPrepare; |
90 |
|
property StoredProcedureNames: TStrings read GetStoredProcedureNames; |
91 |
|
|
105 |
|
|
106 |
|
implementation |
107 |
|
|
108 |
< |
uses |
112 |
< |
IBIntf; |
108 |
> |
uses FBMessages; |
109 |
|
|
110 |
|
{ TIBStoredProc } |
111 |
|
|
112 |
|
constructor TIBStoredProc.Create(AOwner: TComponent); |
113 |
|
begin |
114 |
|
inherited Create(AOwner); |
119 |
– |
FIBLoaded := False; |
120 |
– |
CheckIBLoaded; |
121 |
– |
FIBLoaded := True; |
115 |
|
FParams := TParams.Create (self); |
116 |
|
FNameList := TStringList.Create; |
117 |
|
end; |
118 |
|
|
119 |
|
destructor TIBStoredProc.Destroy; |
120 |
|
begin |
121 |
< |
if FIBLoaded then |
122 |
< |
begin |
123 |
< |
Destroying; |
124 |
< |
Disconnect; |
132 |
< |
FParams.Free; |
133 |
< |
FNameList.Destroy; |
134 |
< |
end; |
121 |
> |
Destroying; |
122 |
> |
Disconnect; |
123 |
> |
if assigned (FParams) then FParams.Free; |
124 |
> |
if assigned(FNameList) then FNameList.Destroy; |
125 |
|
inherited Destroy; |
126 |
|
end; |
127 |
|
|
247 |
|
Query.Prepare; |
248 |
|
Query.GoToFirstRecordOnExecute := False; |
249 |
|
Query.ExecQuery; |
250 |
< |
while (not Query.EOF) and (Query.Next <> nil) do begin |
251 |
< |
if (Query.Current.ByName('RDB$PARAMETER_TYPE').AsInteger = 0) then begin {do not localize} |
250 |
> |
while (not Query.EOF) and Query.Next do begin |
251 |
> |
if (Query.FieldByName('RDB$PARAMETER_TYPE').AsInteger = 0) then begin {do not localize} |
252 |
|
if (input <> '') then |
253 |
|
input := input + ', :' + |
254 |
|
FormatParameter(Database.SQLDialect, Query.Current.ByName('RDB$PARAMETER_NAME').AsString) else {do not localize} |
272 |
|
DataType : TFieldType; |
273 |
|
begin |
274 |
|
DataType := ftUnknown; |
275 |
< |
for i := 0 to QSelect.Current.Count - 1 do begin |
276 |
< |
case QSelect.Fields[i].SQLtype of |
275 |
> |
for i := 0 to QSelect.MetaData.Count - 1 do begin |
276 |
> |
case QSelect.MetaData[i].SQLtype of |
277 |
|
SQL_TYPE_DATE: DataType := ftDate; |
278 |
|
SQL_TYPE_TIME: DataType := ftTime; |
279 |
|
SQL_TIMESTAMP: DataType := ftDateTime; |
280 |
|
SQL_SHORT: |
281 |
< |
if ((QSelect.Fields[i].AsXSQLVar)^.sqlscale = 0) then |
281 |
> |
if QSelect.MetaData[i].getScale = 0 then |
282 |
|
DataType := ftSmallInt |
283 |
|
else |
284 |
|
DataType := ftBCD; |
285 |
|
SQL_LONG: |
286 |
< |
if ((QSelect.Fields[i].AsXSQLVar)^.sqlscale = 0) then |
286 |
> |
if QSelect.MetaData[i].getScale = 0 then |
287 |
|
DataType := ftInteger |
288 |
< |
else if ((QSelect.Fields[i].AsXSQLVar)^.sqlscale >= (-4)) then |
288 |
> |
else if QSelect.MetaData[i].getScale >= -4 then |
289 |
|
DataType := ftBCD |
290 |
|
else |
291 |
|
DataType := ftFloat; |
292 |
|
SQL_INT64: |
293 |
< |
if ((QSelect.Fields[i].AsXSQLVar)^.sqlscale = 0) then |
293 |
> |
if QSelect.MetaData[i].getScale = 0 then |
294 |
|
DataType := ftLargeInt |
295 |
< |
else if ((QSelect.Fields[i].AsXSQLVar)^.sqlscale >= (-4)) then |
295 |
> |
else if QSelect.MetaData[i].getScale >= -4 then |
296 |
|
DataType := ftBCD |
297 |
|
else |
298 |
|
DataType := ftFloat; |
301 |
|
DataType := ftBoolean; |
302 |
|
SQL_TEXT: DataType := ftString; |
303 |
|
SQL_VARYING: |
304 |
< |
if ((QSelect.Fields[i].AsXSQLVar)^.sqllen < 1024) then |
304 |
> |
if QSelect.MetaData[i].GetSize < 1024 then |
305 |
|
DataType := ftString |
306 |
|
else DataType := ftBlob; |
307 |
|
SQL_BLOB, SQL_ARRAY, SQL_QUAD: DataType := ftBlob; |
308 |
|
end; |
309 |
< |
FParams.CreateParam(DataType, Trim(QSelect.Fields[i].Name), ptOutput); |
309 |
> |
FParams.CreateParam(DataType, Trim(QSelect.MetaData[i].Name), ptOutput); |
310 |
|
end; |
311 |
|
|
312 |
|
DataType := ftUnknown; |
313 |
|
for i := 0 to QSelect.Params.Count - 1 do begin |
314 |
< |
case QSelect.Params[i].SQLtype of |
314 |
> |
case QSelect.Params[i].GetSQLtype of |
315 |
|
SQL_TYPE_DATE: DataType := ftDate; |
316 |
|
SQL_TYPE_TIME: DataType := ftTime; |
317 |
|
SQL_TIMESTAMP: DataType := ftDateTime; |
318 |
|
SQL_SHORT: |
319 |
< |
if ((QSelect.Params[i].AsXSQLVar)^.sqlscale = 0) then |
319 |
> |
if QSelect.Params[i].getScale = 0 then |
320 |
|
DataType := ftSmallInt |
321 |
|
else |
322 |
|
DataType := ftBCD; |
323 |
|
SQL_LONG: |
324 |
< |
if ((QSelect.Params[i].AsXSQLVar)^.sqlscale = 0) then |
324 |
> |
if QSelect.Params[i].getScale = 0 then |
325 |
|
DataType := ftInteger |
326 |
< |
else if ((QSelect.Params[i].AsXSQLVar)^.sqlscale >= (-4)) then |
326 |
> |
else if QSelect.Params[i].getScale >= -4 then |
327 |
|
DataType := ftBCD |
328 |
|
else DataType := ftFloat; |
329 |
|
SQL_INT64: |
330 |
< |
if ((QSelect.Params[i].AsXSQLVar)^.sqlscale = 0) then |
330 |
> |
if QSelect.Params[i].getScale = 0 then |
331 |
|
DataType := ftLargeInt |
332 |
< |
else if ((QSelect.Params[i].AsXSQLVar)^.sqlscale >= (-4)) then |
332 |
> |
else if QSelect.Params[i].getScale >= -4 then |
333 |
|
DataType := ftBCD |
334 |
|
else DataType := ftFloat; |
335 |
|
SQL_DOUBLE, SQL_FLOAT, SQL_D_FLOAT: DataType := ftFloat; |
337 |
|
DataType := ftBoolean; |
338 |
|
SQL_TEXT: DataType := ftString; |
339 |
|
SQL_VARYING: |
340 |
< |
if ((QSelect.Params[i].AsXSQLVar)^.sqllen < 1024) then |
340 |
> |
if QSelect.Params[i].GetSize < 1024 then |
341 |
|
DataType := ftString |
342 |
|
else DataType := ftBlob; |
343 |
|
SQL_BLOB, SQL_ARRAY, SQL_QUAD: DataType := ftBlob; |
439 |
|
Query.SQL.Text := 'Select RDB$PROCEDURE_NAME from RDB$PROCEDURES'; {do not localize} |
440 |
|
Query.Prepare; |
441 |
|
Query.ExecQuery; |
442 |
< |
while (not Query.EOF) and (Query.Next <> nil) do |
442 |
> |
while (not Query.EOF) and Query.Next do |
443 |
|
FNameList.Add(TrimRight(Query.Current.ByName('RDB$PROCEDURE_NAME').AsString)); {do not localize} |
444 |
|
finally |
445 |
|
Query.Free; |