128 |
|
FOwnsSQLData: boolean; |
129 |
|
FBlobMetaData: IBlobMetaData; |
130 |
|
FArrayMetaData: IArrayMetaData; |
131 |
+ |
FMetadataSize: short; {size of field from metadata} |
132 |
|
FXSQLVAR: PXSQLVAR; { Points to the PXSQLVAR in the owner object } |
133 |
|
protected |
134 |
|
function GetSQLType: cardinal; override; |
145 |
|
function GetIsNullable: boolean; override; |
146 |
|
function GetSQLData: PByte; override; |
147 |
|
function GetDataLength: cardinal; override; |
148 |
+ |
function GetSize: cardinal; override; |
149 |
+ |
function GetAttachment: IAttachment; override; |
150 |
+ |
function GetDefaultTextSQLType: cardinal; override; |
151 |
|
procedure SetIsNull(Value: Boolean); override; |
152 |
|
procedure SetIsNullable(Value: Boolean); override; |
153 |
|
procedure SetSQLData(AValue: PByte; len: cardinal); override; |
167 |
|
procedure Initialize; override; |
168 |
|
|
169 |
|
property Statement: TFB25Statement read FStatement; |
170 |
+ |
property SQLType: cardinal read GetSQLType write SetSQLType; |
171 |
|
end; |
172 |
|
|
173 |
|
TIBXINPUTSQLDA = class; |
236 |
|
constructor Create(aResults: TIBXOUTPUTSQLDA); |
237 |
|
destructor Destroy; override; |
238 |
|
{IResultSet} |
239 |
< |
function FetchNext: boolean; |
239 |
> |
function FetchNext: boolean; {fetch next record} |
240 |
> |
function FetchPrior: boolean; {fetch previous record} |
241 |
> |
function FetchFirst:boolean; {fetch first record} |
242 |
> |
function FetchLast: boolean; {fetch last record} |
243 |
> |
function FetchAbsolute(position: Integer): boolean; {fetch record by its absolute position in result set} |
244 |
> |
function FetchRelative(offset: Integer): boolean; {fetch record by position relative to current} |
245 |
|
function GetCursorName: AnsiString; |
246 |
|
function GetTransaction: ITransaction; override; |
247 |
|
function IsEof: boolean; |
248 |
+ |
function IsBof: boolean; |
249 |
|
procedure Close; |
250 |
|
end; |
251 |
|
|
264 |
|
protected |
265 |
|
procedure CheckHandle; override; |
266 |
|
procedure GetDsqlInfo(info_request: byte; buffer: ISQLInfoResults); override; |
267 |
< |
procedure InternalPrepare; override; |
267 |
> |
procedure InternalPrepare(CursorName: AnsiString=''); override; |
268 |
|
function InternalExecute(aTransaction: ITransaction): IResults; override; |
269 |
< |
function InternalOpenCursor(aTransaction: ITransaction): IResultSet; override; |
269 |
> |
function InternalOpenCursor(aTransaction: ITransaction; Scrollable: boolean): IResultSet; override; |
270 |
|
procedure ProcessSQL(sql: AnsiString; GenerateParamNames: boolean; var processedSQL: AnsiString); override; |
271 |
|
procedure FreeHandle; override; |
272 |
|
procedure InternalClose(Force: boolean); override; |
273 |
|
public |
274 |
|
constructor Create(Attachment: TFB25Attachment; Transaction: ITransaction; |
275 |
< |
sql: AnsiString; aSQLDialect: integer); |
275 |
> |
sql: AnsiString; aSQLDialect: integer; CursorName: AnsiString=''); |
276 |
|
constructor CreateWithParameterNames(Attachment: TFB25Attachment; |
277 |
|
Transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; GenerateParamNames: boolean; |
278 |
< |
CaseSensitiveParams: boolean=false); |
278 |
> |
CaseSensitiveParams: boolean=false; CursorName: AnsiString=''); |
279 |
|
destructor Destroy; override; |
280 |
|
function FetchNext: boolean; |
281 |
|
|
394 |
|
Result := FXSQLVAR^.sqllen; |
395 |
|
end; |
396 |
|
|
397 |
+ |
function TIBXSQLVAR.GetSize: cardinal; |
398 |
+ |
begin |
399 |
+ |
Result := FMetadataSize; |
400 |
+ |
end; |
401 |
+ |
|
402 |
+ |
function TIBXSQLVAR.GetAttachment: IAttachment; |
403 |
+ |
begin |
404 |
+ |
Result := FStatement.GetAttachment; |
405 |
+ |
end; |
406 |
+ |
|
407 |
|
function TIBXSQLVAR.GetArrayMetaData: IArrayMetaData; |
408 |
|
begin |
409 |
|
if GetSQLType <> SQL_ARRAY then |
477 |
|
FOwnsSQLData := true; |
478 |
|
with FFirebird25ClientAPI, FXSQLVar^ do |
479 |
|
begin |
480 |
+ |
FMetadataSize := sqllen; |
481 |
|
case sqltype and (not 1) of |
482 |
|
SQL_TEXT, SQL_TYPE_DATE, SQL_TYPE_TIME, SQL_TIMESTAMP, |
483 |
|
SQL_BLOB, SQL_ARRAY, SQL_QUAD, SQL_SHORT, SQL_BOOLEAN, |
503 |
|
else |
504 |
|
sqlInd := nil; |
505 |
|
end; |
506 |
+ |
SaveMetaData; |
507 |
|
end; |
508 |
|
|
509 |
|
procedure TIBXSQLVAR.SetIsNull(Value: Boolean); |
590 |
|
end; |
591 |
|
end; |
592 |
|
|
593 |
+ |
function TIBXSQLVAR.GetDefaultTextSQLType: cardinal; |
594 |
+ |
begin |
595 |
+ |
Result := SQL_TEXT; |
596 |
+ |
end; |
597 |
+ |
|
598 |
|
constructor TIBXSQLVAR.Create(aParent: TIBXSQLDA; aIndex: integer); |
599 |
|
begin |
600 |
|
inherited Create(aParent,aIndex); |
643 |
|
FResults.Column[i].RowChange; |
644 |
|
end; |
645 |
|
|
646 |
+ |
function TResultSet.FetchPrior: boolean; |
647 |
+ |
begin |
648 |
+ |
IBError(ibxeNoScrollableCursors,[]); |
649 |
+ |
end; |
650 |
+ |
|
651 |
+ |
function TResultSet.FetchFirst: boolean; |
652 |
+ |
begin |
653 |
+ |
IBError(ibxeNoScrollableCursors,[]); |
654 |
+ |
end; |
655 |
+ |
|
656 |
+ |
function TResultSet.FetchLast: boolean; |
657 |
+ |
begin |
658 |
+ |
IBError(ibxeNoScrollableCursors,[]); |
659 |
+ |
end; |
660 |
+ |
|
661 |
+ |
function TResultSet.FetchAbsolute(position: Integer): boolean; |
662 |
+ |
begin |
663 |
+ |
IBError(ibxeNoScrollableCursors,[]); |
664 |
+ |
end; |
665 |
+ |
|
666 |
+ |
function TResultSet.FetchRelative(offset: Integer): boolean; |
667 |
+ |
begin |
668 |
+ |
IBError(ibxeNoScrollableCursors,[]); |
669 |
+ |
end; |
670 |
+ |
|
671 |
|
function TResultSet.GetCursorName: AnsiString; |
672 |
|
begin |
673 |
|
Result := FResults.FStatement.FCursor; |
683 |
|
Result := FResults.FStatement.FEof; |
684 |
|
end; |
685 |
|
|
686 |
+ |
function TResultSet.IsBof: boolean; |
687 |
+ |
begin |
688 |
+ |
Result := FResults.FStatement.FBof; |
689 |
+ |
end; |
690 |
+ |
|
691 |
|
procedure TResultSet.Close; |
692 |
|
begin |
693 |
|
if FCursorSeqNo = FResults.FStatement.FCursorSeqNo then |
975 |
|
IBDatabaseError; |
976 |
|
end; |
977 |
|
|
978 |
< |
procedure TFB25Statement.InternalPrepare; |
978 |
> |
procedure TFB25Statement.InternalPrepare(CursorName: AnsiString); |
979 |
|
var |
980 |
+ |
GUID: TGUID; |
981 |
|
RB: ISQLInfoResults; |
982 |
|
TRHandle: TISC_TR_HANDLE; |
983 |
|
begin |
984 |
|
if FPrepared then |
985 |
|
Exit; |
986 |
+ |
|
987 |
|
if (FSQL = '') then |
988 |
|
IBError(ibxeEmptyQuery, [nil]); |
989 |
+ |
|
990 |
+ |
FCursor := CursorName; |
991 |
+ |
if FCursor = '' then |
992 |
+ |
begin |
993 |
+ |
CreateGuid(GUID); |
994 |
+ |
FCursor := GUIDToString(GUID); |
995 |
+ |
end; |
996 |
+ |
|
997 |
|
try |
998 |
|
CheckTransaction(FTransactionIntf); |
999 |
|
with FFirebird25ClientAPI do |
1012 |
|
Call(isc_dsql_prepare(StatusVector, @(TRHandle), @FHandle, 0, |
1013 |
|
PAnsiChar(FSQL), FSQLDialect, nil), True); |
1014 |
|
end; |
1015 |
+ |
|
1016 |
|
{ After preparing the statement, query the stmt type and possibly |
1017 |
|
create a FSQLRecord "holder" } |
1018 |
|
{ Get the type of the statement } |
1022 |
|
else |
1023 |
|
FSQLStatementType := SQLUnknown; |
1024 |
|
|
1025 |
+ |
if FSQLStatementType = SQLSelect then |
1026 |
+ |
with FFirebird25ClientAPI do |
1027 |
+ |
Call( |
1028 |
+ |
isc_dsql_set_cursor_name(StatusVector, @FHandle, PAnsiChar(FCursor), 0), |
1029 |
+ |
True); |
1030 |
+ |
|
1031 |
|
case FSQLStatementType of |
1032 |
|
SQLGetSegment, |
1033 |
|
SQLPutSegment, |
1055 |
|
if (FHandle <> nil) then |
1056 |
|
FreeHandle; |
1057 |
|
if E is EIBInterBaseError then |
1058 |
< |
raise EIBInterBaseError.Create(EIBInterBaseError(E).SQLCode, |
1059 |
< |
EIBInterBaseError(E).IBErrorCode, |
985 |
< |
EIBInterBaseError(E).Message + |
986 |
< |
sSQLErrorSeparator + FSQL) |
987 |
< |
else |
988 |
< |
raise; |
1058 |
> |
E.Message := E.Message + sSQLErrorSeparator + FSQL; |
1059 |
> |
raise; |
1060 |
|
end; |
1061 |
|
end; |
1062 |
|
FPrepared := true; |
1088 |
|
CheckHandle; |
1089 |
|
if aTransaction <> FTransactionIntf then |
1090 |
|
AddMonitor(aTransaction as TFB25Transaction); |
1091 |
< |
if (FSQLParams.FTransactionSeqNo < (FTransactionIntf as TFB25transaction).TransactionSeqNo) then |
1091 |
> |
if FStaleReferenceChecks and (FSQLParams.FTransactionSeqNo < (FTransactionIntf as TFB25transaction).TransactionSeqNo) then |
1092 |
|
IBError(ibxeInterfaceOutofDate,[nil]); |
1093 |
|
|
1094 |
|
try |
1137 |
|
Inc(FChangeSeqNo); |
1138 |
|
end; |
1139 |
|
|
1140 |
< |
function TFB25Statement.InternalOpenCursor(aTransaction: ITransaction |
1141 |
< |
): IResultSet; |
1140 |
> |
function TFB25Statement.InternalOpenCursor(aTransaction: ITransaction; |
1141 |
> |
Scrollable: boolean): IResultSet; |
1142 |
|
var TRHandle: TISC_TR_HANDLE; |
1072 |
– |
GUID : TGUID; |
1143 |
|
begin |
1144 |
|
if FSQLStatementType <> SQLSelect then |
1145 |
|
IBError(ibxeIsASelectStatement,[]); |
1146 |
|
|
1147 |
+ |
if Scrollable then |
1148 |
+ |
IBError(ibxeNoScrollableCursors,[]); |
1149 |
+ |
|
1150 |
|
CheckTransaction(aTransaction); |
1151 |
|
if not FPrepared then |
1152 |
|
InternalPrepare; |
1153 |
|
CheckHandle; |
1154 |
|
if aTransaction <> FTransactionIntf then |
1155 |
|
AddMonitor(aTransaction as TFB25Transaction); |
1156 |
< |
if (FSQLParams.FTransactionSeqNo < (FTransactionIntf as TFB25transaction).TransactionSeqNo) then |
1156 |
> |
if FStaleReferenceChecks and (FSQLParams.FTransactionSeqNo < (FTransactionIntf as TFB25transaction).TransactionSeqNo) then |
1157 |
|
IBError(ibxeInterfaceOutofDate,[nil]); |
1158 |
|
|
1159 |
|
with FFirebird25ClientAPI do |
1168 |
|
SQLDialect, |
1169 |
|
FSQLParams.AsXSQLDA, |
1170 |
|
nil), True); |
1098 |
– |
if FCursor = '' then |
1099 |
– |
begin |
1100 |
– |
CreateGuid(GUID); |
1101 |
– |
FCursor := GUIDToString(GUID); |
1102 |
– |
Call( |
1103 |
– |
isc_dsql_set_cursor_name(StatusVector, @FHandle, PAnsiChar(FCursor), 0), |
1104 |
– |
True); |
1105 |
– |
end; |
1171 |
|
|
1172 |
|
if FCollectStatistics then |
1173 |
|
begin |
1242 |
|
end; |
1243 |
|
|
1244 |
|
constructor TFB25Statement.Create(Attachment: TFB25Attachment; |
1245 |
< |
Transaction: ITransaction; sql: AnsiString; aSQLDialect: integer); |
1245 |
> |
Transaction: ITransaction; sql: AnsiString; aSQLDialect: integer; |
1246 |
> |
CursorName: AnsiString); |
1247 |
|
begin |
1248 |
|
inherited Create(Attachment,Transaction,sql,aSQLDialect); |
1249 |
|
FDBHandle := Attachment.Handle; |
1251 |
|
OnDatabaseError := FFirebird25ClientAPI.IBDataBaseError; |
1252 |
|
FSQLParams := TIBXINPUTSQLDA.Create(self); |
1253 |
|
FSQLRecord := TIBXOUTPUTSQLDA.Create(self); |
1254 |
< |
InternalPrepare; |
1254 |
> |
InternalPrepare(CursorName); |
1255 |
|
end; |
1256 |
|
|
1257 |
|
constructor TFB25Statement.CreateWithParameterNames( |
1258 |
|
Attachment: TFB25Attachment; Transaction: ITransaction; sql: AnsiString; |
1259 |
|
aSQLDialect: integer; GenerateParamNames: boolean; |
1260 |
< |
CaseSensitiveParams: boolean); |
1260 |
> |
CaseSensitiveParams: boolean; CursorName: AnsiString); |
1261 |
|
begin |
1262 |
|
inherited CreateWithParameterNames(Attachment,Transaction,sql,aSQLDialect,GenerateParamNames); |
1263 |
|
FDBHandle := Attachment.Handle; |
1266 |
|
FSQLParams := TIBXINPUTSQLDA.Create(self); |
1267 |
|
FSQLParams.CaseSensitiveParams := CaseSensitiveParams; |
1268 |
|
FSQLRecord := TIBXOUTPUTSQLDA.Create(self); |
1269 |
< |
InternalPrepare; |
1269 |
> |
InternalPrepare(CursorName); |
1270 |
|
end; |
1271 |
|
|
1272 |
|
destructor TFB25Statement.Destroy; |