ViewVC Help

View File | Revision Log | Show Annotations | Download File | View Changeset | Root Listing

root/public/ibx/branches/udr/client/FBSQLData.pas

Comparing ibx/trunk/fbintf/client/FBSQLData.pas (file contents):
Revision 56 by tony, Mon Mar 6 10:20:02 2017 UTC vs.
Revision 287 by tony, Thu Apr 11 08:51:23 2019 UTC

#	Line 76 | Line 76 | unit FBSQLData;
76		methods are needed for SQL parameters only. The string getters and setters
77		are virtual as SQLVar and Array encodings of string data is different.}
78
79	–	{ $define ALLOWDIALECT3PARAMNAMES}
80	–
81	–	{$ifndef ALLOWDIALECT3PARAMNAMES}
82	–
83	–	{ Note on SQL Dialects and SQL Parameter Names
84	–	--------------------------------------------
85	–
86	–	Even when dialect 3 quoted format parameter names are not supported, IBX still processes
87	–	parameter names case insensitive. This does result in some additional overhead
88	–	due to a call to "AnsiUpperCase". This can be avoided by undefining
89	–	"UseCaseInSensitiveParamName" below.
90	–
91	–	Note: do not define "UseCaseSensitiveParamName" when "ALLOWDIALECT3PARAMNAMES"
92	–	is defined. This will not give a useful result.
93	–	}
94	–	{$define UseCaseInSensitiveParamName}
95	–	{$endif}
79
80		interface
81
82		uses
83	<	Classes, SysUtils, IBExternals, IBHeader, IB,  FBActivityMonitor;
83	>	Classes, SysUtils, IBExternals, IBHeader, IB,  FBActivityMonitor, FBClientAPI;
84
85		type
86
#	Line 105 | Line 88 | type
88
89		TSQLDataItem = class(TFBInterfacedObject)
90		private
91	+	FFirebirdClientAPI: TFBClientAPI;
92		function AdjustScale(Value: Int64; aScale: Integer): Double;
93		function AdjustScaleToInt64(Value: Int64; aScale: Integer): Int64;
94		function AdjustScaleToCurrency(Value: Int64; aScale: Integer): Currency;
95	+	function GetTimestampFormatStr: AnsiString;
96	+	function GetDateFormatStr(IncludeTime: boolean): AnsiString;
97	+	function GetTimeFormatStr: AnsiString;
98		procedure SetAsInteger(AValue: Integer);
99		protected
100		function AdjustScaleFromCurrency(Value: Currency; aScale: Integer): Int64;
#	Line 128 | Line 115 | type
115		property DataLength: cardinal read GetDataLength write SetDataLength;
116
117		public
118	+	constructor Create(api: TFBClientAPI);
119		function GetSQLType: cardinal; virtual; abstract;
120		function GetSQLTypeName: AnsiString; overload;
121		class function GetSQLTypeName(SQLType: short): AnsiString; overload;
#	Line 145 | Line 133 | type
133		function GetAsShort: short;
134		function GetAsString: AnsiString; virtual;
135		function GetIsNull: Boolean; virtual;
136	<	function getIsNullable: boolean; virtual;
136	>	function GetIsNullable: boolean; virtual;
137		function GetAsVariant: Variant;
138		function GetModified: boolean; virtual;
139	+	function GetDateTimeStrLength(DateTimeFormat: TIBDateTimeFormats): integer;
140		procedure SetAsBoolean(AValue: boolean); virtual;
141		procedure SetAsCurrency(Value: Currency); virtual;
142		procedure SetAsInt64(Value: Int64); virtual;
#	Line 162 | Line 151 | type
151		procedure SetAsShort(Value: short); virtual;
152		procedure SetAsString(Value: AnsiString); virtual;
153		procedure SetAsVariant(Value: Variant);
154	+	procedure SetAsNumeric(Value: Int64; aScale: integer);
155		procedure SetIsNull(Value: Boolean); virtual;
156		procedure SetIsNullable(Value: Boolean); virtual;
157		procedure SetName(aValue: AnsiString); virtual;
#	Line 195 | Line 185 | type
185
186		TSQLDataArea = class
187		private
188	+	FCaseSensitiveParams: boolean;
189		function GetColumn(index: integer): TSQLVarData;
190		function GetCount: integer;
191		protected
#	Line 217 | Line 208 | type
208		var data: PByte); virtual;
209		procedure RowChange;
210		function StateChanged(var ChangeSeqNo: integer): boolean; virtual; abstract;
211	+	property CaseSensitiveParams: boolean read FCaseSensitiveParams
212	+	write FCaseSensitiveParams; {Only used when IsInputDataArea true}
213		property Count: integer read GetCount;
214		property Column[index: integer]: TSQLVarData read GetColumn;
215		property UniqueRelationName: AnsiString read FUniqueRelationName;
#	Line 428 | Line 421 | type
421		function getSQLParam(index: integer): ISQLParam;
422		function ByName(Idx: AnsiString): ISQLParam ;
423		function GetModified: Boolean;
424	+	function GetHasCaseSensitiveParams: Boolean;
425		end;
426
427		{ TResults }
#	Line 455 | Line 449 | type
449
450		implementation
451
452	<	uses FBMessages, FBClientAPI, variants, IBUtils, FBTransaction;
459	<
452	>	uses FBMessages, variants, IBUtils, FBTransaction, DateUtils;
453
454		{ TSQLDataArea }
455
#	Line 509 | Line 502 | end;
502
503		procedure TSQLDataArea.PreprocessSQL(sSQL: AnsiString; GenerateParamNames: boolean;
504		var sProcessedSQL: AnsiString);
512	–	var
513	–	cCurChar, cNextChar, cQuoteChar: AnsiChar;
514	–	sParamName: AnsiString;
515	–	j, i, iLenSQL, iSQLPos: Integer;
516	–	iCurState {$ifdef ALLOWDIALECT3PARAMNAMES}, iCurParamState {$endif}: Integer;
517	–	iParamSuffix: Integer;
518	–	slNames: TStrings;
519	–	StrBuffer: PByte;
520	–	found: boolean;
521	–
522	–	const
523	–	DefaultState = 0;
524	–	CommentState = 1;
525	–	QuoteState = 2;
526	–	ParamState = 3;
527	–	ArrayDimState = 4;
528	–	{$ifdef ALLOWDIALECT3PARAMNAMES}
529	–	ParamDefaultState = 0;
530	–	ParamQuoteState = 1;
531	–	{$endif}
505
506	<	procedure AddToProcessedSQL(cChar: AnsiChar);
534	<	begin
535	<	StrBuffer[iSQLPos] := byte(cChar);
536	<	Inc(iSQLPos);
537	<	end;
506	>	var slNames: TStrings;
507
508	<	begin
509	<	if not IsInputDataArea then
510	<	IBError(ibxeNotPermitted,[nil]);
511	<
512	<	sParamName := '';
544	<	iLenSQL := Length(sSQL);
545	<	GetMem(StrBuffer,iLenSQL + 1);
546	<	slNames := TStringList.Create;
547	<	try
548	<	{ Do some initializations of variables }
549	<	iParamSuffix := 0;
550	<	cQuoteChar := '''';
551	<	i := 1;
552	<	iSQLPos := 0;
553	<	iCurState := DefaultState;
554	<	{$ifdef ALLOWDIALECT3PARAMNAMES}
555	<	iCurParamState := ParamDefaultState;
556	<	{$endif}
557	<	{ Now, traverse through the SQL string, character by character,
558	<	picking out the parameters and formatting correctly for InterBase }
559	<	while (i <= iLenSQL) do begin
560	<	{ Get the current token and a look-ahead }
561	<	cCurChar := sSQL[i];
562	<	if i = iLenSQL then
563	<	cNextChar := #0
564	<	else
565	<	cNextChar := sSQL[i + 1];
566	<	{ Now act based on the current state }
567	<	case iCurState of
568	<	DefaultState:
569	<	begin
570	<	case cCurChar of
571	<	'''', '"':
572	<	begin
573	<	cQuoteChar := cCurChar;
574	<	iCurState := QuoteState;
575	<	end;
576	<	'?', ':':
577	<	begin
578	<	iCurState := ParamState;
579	<	AddToProcessedSQL('?');
580	<	end;
581	<	'/': if (cNextChar = '*') then
582	<	begin
583	<	AddToProcessedSQL(cCurChar);
584	<	Inc(i);
585	<	iCurState := CommentState;
586	<	end;
587	<	'[':
588	<	begin
589	<	AddToProcessedSQL(cCurChar);
590	<	Inc(i);
591	<	iCurState := ArrayDimState;
592	<	end;
593	<	end;
594	<	end;
595	<
596	<	ArrayDimState:
597	<	begin
598	<	case cCurChar of
599	<	':',',','0'..'9',' ',#9,#10,#13:
600	<	begin
601	<	AddToProcessedSQL(cCurChar);
602	<	Inc(i);
603	<	end;
604	<	else
605	<	begin
606	<	AddToProcessedSQL(cCurChar);
607	<	Inc(i);
608	<	iCurState := DefaultState;
609	<	end;
610	<	end;
611	<	end;
612	<
613	<	CommentState:
614	<	begin
615	<	if (cNextChar = #0) then
616	<	IBError(ibxeSQLParseError, [SEOFInComment])
617	<	else if (cCurChar = '*') then begin
618	<	if (cNextChar = '/') then
619	<	iCurState := DefaultState;
620	<	end;
621	<	end;
622	<	QuoteState: begin
623	<	if cNextChar = #0 then
624	<	IBError(ibxeSQLParseError, [SEOFInString])
625	<	else if (cCurChar = cQuoteChar) then begin
626	<	if (cNextChar = cQuoteChar) then begin
627	<	AddToProcessedSQL(cCurChar);
628	<	Inc(i);
629	<	end else
630	<	iCurState := DefaultState;
631	<	end;
632	<	end;
633	<	ParamState:
634	<	begin
635	<	{ collect the name of the parameter }
636	<	{$ifdef ALLOWDIALECT3PARAMNAMES}
637	<	if iCurParamState = ParamDefaultState then
638	<	begin
639	<	if cCurChar = '"' then
640	<	iCurParamState := ParamQuoteState
641	<	else
642	<	{$endif}
643	<	if (cCurChar in ['A'..'Z', 'a'..'z', '0'..'9', '_', '$']) then
644	<	sParamName := sParamName + cCurChar
645	<	else if GenerateParamNames then
646	<	begin
647	<	sParamName := 'IBXParam' + IntToStr(iParamSuffix); {do not localize}
648	<	Inc(iParamSuffix);
649	<	iCurState := DefaultState;
650	<	slNames.AddObject(sParamName,self); //Note local convention
651	<	//add pointer to self to mark entry
652	<	sParamName := '';
653	<	end
654	<	else
655	<	IBError(ibxeSQLParseError, [SParamNameExpected]);
656	<	{$ifdef ALLOWDIALECT3PARAMNAMES}
657	<	end
658	<	else begin
659	<	{ determine if Quoted parameter name is finished }
660	<	if cCurChar = '"' then
661	<	begin
662	<	Inc(i);
663	<	slNames.Add(sParamName);
664	<	SParamName := '';
665	<	iCurParamState := ParamDefaultState;
666	<	iCurState := DefaultState;
667	<	end
668	<	else
669	<	sParamName := sParamName + cCurChar
670	<	end;
671	<	{$endif}
672	<	{ determine if the unquoted parameter name is finished }
673	<	if {$ifdef ALLOWDIALECT3PARAMNAMES}(iCurParamState <> ParamQuoteState) and {$endif}
674	<	(iCurState <> DefaultState) then
675	<	begin
676	<	if not (cNextChar in ['A'..'Z', 'a'..'z',
677	<	'0'..'9', '_', '$']) then begin
678	<	Inc(i);
679	<	iCurState := DefaultState;
680	<	slNames.Add(sParamName);
681	<	sParamName := '';
682	<	end;
683	<	end;
684	<	end;
685	<	end;
686	<	if (iCurState <> ParamState) and (i <= iLenSQL) then
687	<	AddToProcessedSQL(sSQL[i]);
688	<	Inc(i);
689	<	end;
690	<	AddToProcessedSQL(#0);
691	<	sProcessedSQL := strpas(PAnsiChar(StrBuffer));
508	>	procedure SetColumnNames(slNames: TStrings);
509	>	var i, j: integer;
510	>	found: boolean;
511	>	begin
512	>	found := false;
513		SetCount(slNames.Count);
514		for i := 0 to slNames.Count - 1 do
515		begin
#	Line 709 | Line 530 | begin
530		Column[i].UniqueName := not found;
531		end;
532		end;
533	+	end;
534	+
535	+	begin
536	+	if not IsInputDataArea then
537	+	IBError(ibxeNotPermitted,[nil]);
538	+
539	+	slNames := TStringList.Create;
540	+	try
541	+	sProcessedSQL := TSQLParamProcessor.Execute(sSQL,GenerateParamNames,slNames);
542	+	SetColumnNames(slNames);
543		finally
544		slNames.Free;
714	–	FreeMem(StrBuffer);
545		end;
546		end;
547
#	Line 725 | Line 555 | var
555		s: AnsiString;
556		i: Integer;
557		begin
558	<	{$ifdef UseCaseInSensitiveParamName}
559	<	s := AnsiUpperCase(Idx);
560	<	{$else}
558	>	if not IsInputDataArea or not CaseSensitiveParams then
559	>	s := AnsiUpperCase(Idx)
560	>	else
561		s := Idx;
562	<	{$endif}
562	>
563		for i := 0 to Count - 1 do
564		if Column[i].Name = s then
565		begin
#	Line 761 | Line 591 | end;
591
592		procedure TSQLVarData.SetName(AValue: AnsiString);
593		begin
594	<	if FName = AValue then Exit;
765	<	{$ifdef UseCaseInSensitiveParamName}
766	<	if Parent.IsInputDataArea then
594	>	if not Parent.IsInputDataArea or not Parent.CaseSensitiveParams then
595		FName := AnsiUpperCase(AValue)
596		else
769	–	{$endif}
597		FName := AValue;
598		end;
599
#	Line 787 | Line 614 | begin
614
615		FVarString := aValue;
616		SQLType := SQL_TEXT;
617	+	Scale := 0;
618		SetSQLData(PByte(PAnsiChar(FVarString)),Length(aValue));
619		end;
620
#	Line 947 | Line 775 | begin
775		result := Value;
776		end;
777
778	+	function TSQLDataItem.GetDateFormatStr(IncludeTime: boolean): AnsiString;
779	+	begin
780	+	{$IF declared(DefaultFormatSettings)}
781	+	with DefaultFormatSettings do
782	+	{$ELSE}
783	+	{$IF declared(FormatSettings)}
784	+	with FormatSettings do
785	+	{$IFEND}
786	+	{$IFEND}
787	+	case GetSQLDialect of
788	+	1:
789	+	if IncludeTime then
790	+	result := ShortDateFormat + ' ' + LongTimeFormat
791	+	else
792	+	result := ShortDateFormat;
793	+	3:
794	+	result := ShortDateFormat;
795	+	end;
796	+	end;
797	+
798	+	function TSQLDataItem.GetTimeFormatStr: AnsiString;
799	+	begin
800	+	{$IF declared(DefaultFormatSettings)}
801	+	with DefaultFormatSettings do
802	+	{$ELSE}
803	+	{$IF declared(FormatSettings)}
804	+	with FormatSettings do
805	+	{$IFEND}
806	+	{$IFEND}
807	+	Result := LongTimeFormat;
808	+	end;
809	+
810	+	function TSQLDataItem.GetTimestampFormatStr: AnsiString;
811	+	begin
812	+	{$IF declared(DefaultFormatSettings)}
813	+	with DefaultFormatSettings do
814	+	{$ELSE}
815	+	{$IF declared(FormatSettings)}
816	+	with FormatSettings do
817	+	{$IFEND}
818	+	{$IFEND}
819	+	Result := ShortDateFormat + ' ' +  LongTimeFormat + '.zzz';
820	+	end;
821	+
822		procedure TSQLDataItem.SetAsInteger(AValue: Integer);
823		begin
824		SetAsLong(aValue);
#	Line 1045 | Line 917 | begin
917		//Do nothing by default
918		end;
919
920	+	constructor TSQLDataItem.Create(api: TFBClientAPI);
921	+	begin
922	+	inherited Create;
923	+	FFirebirdClientAPI := api;
924	+	end;
925	+
926		function TSQLDataItem.GetSQLTypeName: AnsiString;
927		begin
928		Result := GetSQLTypeName(GetSQLType);
#	Line 1151 | Line 1029 | begin
1029		CheckActive;
1030		result := 0;
1031		if not IsNull then
1032	<	with FirebirdClientAPI do
1032	>	with FFirebirdClientAPI do
1033		case SQLType of
1034		SQL_TEXT, SQL_VARYING: begin
1035		try
#	Line 1291 | Line 1169 | begin
1169		result := '';
1170		{ Check null, if so return a default string }
1171		if not IsNull then
1172	<	with FirebirdClientAPI do
1172	>	with FFirebirdClientAPI do
1173		case SQLType of
1174		SQL_BOOLEAN:
1175		if AsBoolean then
#	Line 1316 | Line 1194 | begin
1194		Result := rs
1195		end;
1196		SQL_TYPE_DATE:
1197	<	case GetSQLDialect of
1320	<	1 : result := DateTimeToStr(AsDateTime);
1321	<	3 : result := DateToStr(AsDateTime);
1322	<	end;
1197	>	result := FormatDateTime(GetDateFormatStr(TimeOf(AsDateTime)<>0),AsDateTime);
1198		SQL_TYPE_TIME :
1199	<	result := TimeToStr(AsDateTime);
1199	>	result := FormatDateTime(GetTimeFormatStr,AsDateTime);
1200		SQL_TIMESTAMP:
1201	<	{$IF declared(DefaultFormatSettings)}
1327	<	with DefaultFormatSettings do
1328	<	{$ELSE}
1329	<	{$IF declared(FormatSettings)}
1330	<	with FormatSettings do
1331	<	{$IFEND}
1332	<	{$IFEND}
1333	<	result := FormatDateTime(ShortDateFormat + ' ' +
1334	<	LongTimeFormat+'.zzz',AsDateTime);
1201	>	result := FormatDateTime(GetTimestampFormatStr,AsDateTime);
1202		SQL_SHORT, SQL_LONG:
1203		if Scale = 0 then
1204		result := IntToStr(AsLong)
#	Line 1359 | Line 1226 | begin
1226		Result := false;
1227		end;
1228
1229	<	function TSQLDataItem.getIsNullable: boolean;
1229	>	function TSQLDataItem.GetIsNullable: boolean;
1230		begin
1231		CheckActive;
1232		Result := false;
#	Line 1407 | Line 1274 | begin
1274		Result := false;
1275		end;
1276
1277	+	function TSQLDataItem.GetDateTimeStrLength(DateTimeFormat: TIBDateTimeFormats
1278	+	): integer;
1279	+	begin
1280	+	case DateTimeFormat of
1281	+	dfTimestamp:
1282	+	Result := Length(GetTimestampFormatStr);
1283	+	dfDateTime:
1284	+	Result := Length(GetDateFormatStr(true));
1285	+	dfTime:
1286	+	Result := Length(GetTimeFormatStr);
1287	+	else
1288	+	Result := 0;
1289	+	end;
1290	+	end;
1291	+
1292
1293		procedure TSQLDataItem.SetIsNull(Value: Boolean);
1294		begin
#	Line 1470 | Line 1352 | begin
1352
1353		SQLType := SQL_TYPE_DATE;
1354		DataLength := SizeOf(ISC_DATE);
1355	<	with FirebirdClientAPI do
1355	>	with FFirebirdClientAPI do
1356		SQLEncodeDate(Value,SQLData);
1357		Changed;
1358		end;
#	Line 1490 | Line 1372 | begin
1372
1373		SQLType := SQL_TYPE_TIME;
1374		DataLength := SizeOf(ISC_TIME);
1375	<	with FirebirdClientAPI do
1375	>	with FFirebirdClientAPI do
1376		SQLEncodeTime(Value,SQLData);
1377		Changed;
1378		end;
#	Line 1504 | Line 1386 | begin
1386		Changing;
1387		SQLType := SQL_TIMESTAMP;
1388		DataLength := SizeOf(ISC_TIME) + sizeof(ISC_DATE);
1389	<	with FirebirdClientAPI do
1389	>	with FFirebirdClientAPI do
1390		SQLEncodeDateTime(Value,SQLData);
1391		Changed;
1392		end;
#	Line 1629 | Line 1511 | begin
1511		end;
1512		end;
1513
1514	+	procedure TSQLDataItem.SetAsNumeric(Value: Int64; aScale: integer);
1515	+	begin
1516	+	CheckActive;
1517	+	Changing;
1518	+	if IsNullable then
1519	+	IsNull := False;
1520	+
1521	+	SQLType := SQL_INT64;
1522	+	Scale := aScale;
1523	+	DataLength := SizeOf(Int64);
1524	+	PInt64(SQLData)^ := Value;
1525	+	Changed;
1526	+	end;
1527	+
1528		procedure TSQLDataItem.SetAsBoolean(AValue: boolean);
1529		begin
1530		CheckActive;
#	Line 1676 | Line 1572 | end;
1572
1573		constructor TColumnMetaData.Create(aOwner: IUnknown; aIBXSQLVAR: TSQLVarData);
1574		begin
1575	<	inherited Create;
1575	>	inherited Create(aIBXSQLVAR.GetStatement.GetAttachment.getFirebirdAPI as TFBClientAPI);
1576		FIBXSQLVAR := aIBXSQLVAR;
1577		FOwner := aOwner;
1578		FPrepareSeqNo := FIBXSQLVAR.Parent.PrepareSeqNo;
#	Line 1840 | Line 1736 | end;
1736		{ TSQLParam }
1737
1738		procedure TSQLParam.InternalSetAsString(Value: AnsiString);
1739	+
1740	+	procedure DoSetString;
1741	+	begin
1742	+	Changing;
1743	+	FIBXSQLVar.SetString(Transliterate(Value,GetCodePage));
1744	+	Changed;
1745	+	end;
1746	+
1747		var b: IBlob;
1748	+	dt: TDateTime;
1749	+	CurrValue: Currency;
1750	+	FloatValue: single;
1751		begin
1752		CheckActive;
1753		if IsNullable then
#	Line 1866 | Line 1773 | begin
1773
1774		SQL_VARYING,
1775		SQL_TEXT:
1776	<	begin
1870	<	Changing;
1871	<	FIBXSQLVar.SetString(Transliterate(Value,GetCodePage));
1872	<	Changed;
1873	<	end;
1776	>	DoSetString;
1777
1778		SQL_SHORT,
1779		SQL_LONG,
1780		SQL_INT64:
1781	<	SetAsInt64(StrToInt(Value));
1781	>	if TryStrToCurr(Value,CurrValue) then
1782	>	SetAsNumeric(AdjustScaleFromCurrency(CurrValue,GetScale),GetScale)
1783	>	else
1784	>	DoSetString;
1785
1786		SQL_D_FLOAT,
1787		SQL_DOUBLE,
1788		SQL_FLOAT:
1789	<	SetAsDouble(StrToFloat(Value));
1789	>	if TryStrToFloat(Value,FloatValue) then
1790	>	SetAsDouble(FloatValue)
1791	>	else
1792	>	DoSetString;
1793
1794		SQL_TIMESTAMP:
1795	<	SetAsDateTime(StrToDateTime(Value));
1795	>	if TryStrToDateTime(Value,dt) then
1796	>	SetAsDateTime(dt)
1797	>	else
1798	>	DoSetString;
1799
1800		SQL_TYPE_DATE:
1801	<	SetAsDate(StrToDateTime(Value));
1801	>	if TryStrToDateTime(Value,dt) then
1802	>	SetAsDate(dt)
1803	>	else
1804	>	DoSetString;
1805
1806		SQL_TYPE_TIME:
1807	<	SetAsTime(StrToDateTime(Value));
1807	>	if TryStrToDateTime(Value,dt) then
1808	>	SetAsTime(dt)
1809	>	else
1810	>	DoSetString;
1811
1812		else
1813		IBError(ibxeInvalidDataConversion,[nil]);
#	Line 2475 | Line 2393 | begin
2393		end;
2394		end;
2395
2396	+	function TSQLParams.GetHasCaseSensitiveParams: Boolean;
2397	+	begin
2398	+	Result := FSQLParams.CaseSensitiveParams;
2399	+	end;
2400	+
2401		{ TResults }
2402
2403		procedure TResults.CheckActive;

Diff Legend

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