client/3.0/FB30Array.pas

(*
 *  Firebird Interface (fbintf). The fbintf components provide a set of
 *  Pascal language bindings for the Firebird API.
 *
 *  The contents of this file are subject to the Initial Developer's
 *  Public License Version 1.0 (the "License"); you may not use this
 *  file except in compliance with the License. You may obtain a copy
 *  of the License here:
 *
 *    http://www.firebirdsql.org/index.php?op=doc&id=idpl
 *
 *  Software distributed under the License is distributed on an "AS
 *  IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
 *  implied. See the License for the specific language governing rights
 *  and limitations under the License.
 *
 *  The Initial Developer of the Original Code is Tony Whyman.
 *
 *  The Original Code is (C) 2016 Tony Whyman, MWA Software
 *  (http://www.mwasoftware.co.uk).
 *
 *  All Rights Reserved.
 *
 *  Contributor(s): ______________________________________.
 *
*)
unit FB30Array;
{$IFDEF MSWINDOWS} 
{$DEFINE WINDOWS} 
{$ENDIF}

{$IFDEF FPC}
{$mode delphi}
{$codepage UTF8}
{$interfaces COM}
{$ENDIF}

interface

uses
  Classes, SysUtils, Firebird, IB, FBArray, IBHeader, FB30Attachment, FBClientAPI,
  FB30Transaction, FBParamBlock;

type

  ISDLItem = interface(IParameterBlockItem)
    ['{a34b6064-5ae9-4fc1-85c3-f145f069b607}']
    procedure addByte(aValue: byte);
    procedure addShortInteger(aValue: integer);
    procedure SetAsShortInteger(aValue: integer);
    procedure SetAsTinyInteger(aValue: integer);
  end;

  ISDL = interface(IParameterBlock<ISDLItem>)
    ['{52ae1f5f-657b-4b14-81aa-7b3658454f4c}']
  end;

  { TFB30ArrayMetaData }

  TFB30ArrayMetaData = class(TFBArrayMetaData,IArrayMetaData)
  private
    FCodePage: TSystemCodePage;
  protected
    procedure LoadMetaData(aAttachment: IAttachment; aTransaction: ITransaction;
                   relationName, columnName: AnsiString); override;
  public
    function GetCharSetID: cardinal; override;
    function GetCodePage: TSystemCodePage; override;
  end;

  { TFB30Array }

  TFB30Array = class(TFBArray,IArray)
  private
    FAttachmentIntf: Firebird.IAttachment;
    FTransactionIntf: Firebird.ITransaction;
    FSDL: ISDL;
  protected
    procedure AllocateBuffer; override;
    procedure InternalGetSlice; override;
    procedure InternalPutSlice(Force: boolean); override;
  public
    constructor Create(aAttachment: TFB30Attachment; aTransaction: TFB30Transaction; aField: IArrayMetaData); overload;
    constructor Create(aAttachment: TFB30Attachment; aTransaction: TFB30Transaction; aField: IArrayMetaData; ArrayID: TISC_QUAD); overload;
 end;

  TSDLItem = class(TParamBlockItem,ISDLItem);

  { TSDLBlock }

  TSDLBlock = class (TCustomParamBlock<TSDLItem,ISDLItem>, ISDL)
  public
    constructor Create;
  end;

implementation

uses FBAttachment, FB30ClientAPI, FB30Statement;

const
  sGetArrayMetaData = 'Select F.RDB$FIELD_LENGTH, F.RDB$FIELD_SCALE, F.RDB$FIELD_TYPE, '+
                      'F.RDB$DIMENSIONS, FD.RDB$DIMENSION, FD.RDB$LOWER_BOUND, FD.RDB$UPPER_BOUND, '+
                      'F.RDB$CHARACTER_SET_ID '+
                      'From RDB$FIELDS F JOIN RDB$RELATION_FIELDS RF '+
                      'On F.RDB$FIELD_NAME = RF.RDB$FIELD_SOURCE JOIN RDB$FIELD_DIMENSIONS FD '+
                      'On FD.RDB$FIELD_NAME = F.RDB$FIELD_NAME ' +
                      'Where RF.RDB$RELATION_NAME = ? and RF.RDB$FIELD_NAME = ? Order by FD.RDB$DIMENSION asc';


{ TFB30ArrayMetaData }

{Assemble the array descriptor from the System Tables}

procedure TFB30ArrayMetaData.LoadMetaData(aAttachment: IAttachment;
  aTransaction: ITransaction; relationName, columnName: AnsiString);
var stmt: IStatement;
    CharWidth: integer;
begin
  RelationName := AnsiUpperCase(RelationName);
  ColumnName := AnsiUpperCase(ColumnName);
  stmt := TFB30Statement.Create(aAttachment as TFB30Attachment,aTransaction,
                               sGetArrayMetaData ,aAttachment.GetSQLDialect);
  with stmt do
  begin
    SQLParams[0].AsString := RelationName;
    SQLParams[1].AsString := ColumnName;
    with OpenCursor do
    if FetchNext then
    begin
      FillChar(FArrayDesc.array_desc_field_name,sizeof(FArrayDesc.array_desc_field_name),' ');
      FillChar(FArrayDesc.array_desc_relation_name,sizeof(FArrayDesc.array_desc_relation_name),' ');
      Move(columnName[1],FArrayDesc.array_desc_field_name,Length(columnName));
      Move(relationName[1],FArrayDesc.array_desc_relation_name,length(relationName));
      FArrayDesc.array_desc_length := Data[0].AsInteger;
      FArrayDesc.array_desc_scale := Data[1].AsInteger;
      FArrayDesc.array_desc_dtype := Data[2].AsInteger;
      FArrayDesc.array_desc_dimensions := Data[3].AsInteger;
      FArrayDesc.array_desc_flags := 0; {row major}
      FCharSetID := Data[7].AsInteger;
      if (FCharSetID > 1) and (aAttachment as TFB30Attachment).HasDefaultCharSet then
        FCharSetID := (aAttachment as TFB30Attachment).CharSetID;
      FCodePage := CP_NONE;
      FAttachment.CharSetID2CodePage(FCharSetID,FCodePage);
      if (FArrayDesc.array_desc_dtype in [blr_text,blr_cstring, blr_varying]) and
        (FCharSetID = 0) then {This really shouldn't be necessary - but it is :(}
      with aAttachment as TFBAttachment do
      begin
        if HasDefaultCharSet  and FAttachment.CharSetWidth(CharSetID,CharWidth) then
          FArrayDesc.array_desc_length := FArrayDesc.array_desc_length * CharWidth;
      end;
      repeat
        with FArrayDesc.array_desc_bounds[Data[4].AsInteger] do
        begin
          array_bound_lower := Data[5].AsInteger;
          array_bound_upper := Data[6].AsInteger;
        end;
      until not FetchNext;
    end;
  end;
end;

function TFB30ArrayMetaData.GetCharSetID: cardinal;
begin
  Result := FCharSetID;
end;

function TFB30ArrayMetaData.GetCodePage: TSystemCodePage;
begin
  Result := FCodePage;
end;

{ TFB30Array }

procedure TFB30Array.AllocateBuffer;

  procedure AddVarInteger(aValue: integer);
  begin
    if (aValue >= -128) and (aValue <= 127) then
      FSDL.Add(isc_sdl_tiny_integer).SetAsTinyInteger(aValue)
    else
    if (aValue >= -32768) and (aValue <= 32767) then
      FSDL.Add(isc_sdl_short_integer).SetAsShortInteger(aValue)
    else
      FSDL.Add(isc_sdl_long_integer).SetAsInteger(aValue);
  end;

var i: integer;
    SDLItem: ISDLItem;
begin
  inherited AllocateBuffer;
  {Now set up the SDL}

  FSDL := TSDLBlock.Create;
  with GetArrayDesc^ do
  {The following is based on gen_SDL from Firebird src/dsql/array.cpp}
  begin
    SDLItem := FSDL.Add(isc_sdl_struct);
    SDLItem.SetAsByte(array_desc_dtype);

    case array_desc_dtype of
    blr_short,blr_long,
    blr_int64,blr_quad:
        SDLItem.AddByte(byte(array_desc_scale));

    blr_text,blr_cstring, blr_varying:
        SDLItem.addShortInteger(array_desc_length);
    end;

    FSDL.Add(isc_sdl_relation).SetAsString(array_desc_relation_name);
    FSDL.Add(isc_sdl_field).SetAsString(array_desc_field_name);

    for i := 0 to array_desc_dimensions - 1 do
    begin
      if array_desc_bounds[i].array_bound_lower = 1 then
        FSDL.Add(isc_sdl_do1).SetAsTinyInteger(i)
      else
      begin
        FSDL.Add(isc_sdl_do2).SetAsTinyInteger(i);
        AddVarInteger(array_desc_bounds[i].array_bound_lower);
      end;
      AddVarInteger(array_desc_bounds[i].array_bound_upper);
    end;

    SDLItem := FSDL.Add(isc_sdl_element);
    SDLItem.AddByte(1);
    SDLItem := FSDL.Add(isc_sdl_scalar);
    SDLItem.AddByte(0);
    SDLItem.AddByte(array_desc_dimensions);
    for i := 0 to array_desc_dimensions - 1 do
    begin
      SDLItem := FSDL.Add(isc_sdl_variable);
      SDLItem.AddByte(i);
    end;
    FSDL.Add(isc_sdl_eoc);
  end;
end;

procedure TFB30Array.InternalGetSlice;
begin
  with Firebird30ClientAPI do
  begin
    FAttachmentIntf.getSlice(StatusIntf,FTransactionIntf,
                          @FArrayID,
                          (FSDL as TSDLBlock).getDataLength,
                          BytePtr((FSDL as TSDLBlock).getBuffer),
                          0,nil,
                          FBufSize,BytePtr(FBuffer)
                          );
    Check4DataBaseError;
  end;
  SignalActivity;
end;

procedure TFB30Array.InternalPutSlice(Force: boolean);
begin
  with Firebird30ClientAPI do
  begin
    FAttachmentIntf.putSlice(StatusIntf,FTransactionIntf, @FArrayID,
                          (FSDL as TSDLBlock).getDataLength,
                          BytePtr((FSDL as TSDLBlock).getBuffer),
                          0,nil,
                          FBufSize,BytePtr(FBuffer)
                          );
    if not Force then
      Check4DataBaseError;
  end;
  SignalActivity;
end;

constructor TFB30Array.Create(aAttachment: TFB30Attachment;
  aTransaction: TFB30Transaction; aField: IArrayMetaData);
begin
  inherited Create(aAttachment,aTransaction,aField);
  FAttachmentIntf := aAttachment.AttachmentIntf;
  FTransactionIntf := aTransaction.TransactionIntf;
end;

constructor TFB30Array.Create(aAttachment: TFB30Attachment;
  aTransaction: TFB30Transaction; aField: IArrayMetaData; ArrayID: TISC_QUAD);
begin
  inherited Create(aAttachment,aTransaction,aField,ArrayID);
  FAttachmentIntf := aAttachment.AttachmentIntf;
  FTransactionIntf := aTransaction.TransactionIntf;
end;

{ TSDLBlock }

constructor TSDLBlock.Create;
begin
  inherited Create;
  FDataLength := 1;
  FBuffer^ := isc_sdl_version1;
end;

end.

Revision:	60
Committed:	Mon Mar 27 15:21:02 2017 UTC (7 years, 8 months ago) by tony
Content type:	text/x-pascal
Original Path:	*ibx/trunk/fbintf/client/3.0/FB30Array.pas*
File size:	9386 byte(s)
Log Message:
#	User	Rev	Content
1	tony	45	(*
2			* Firebird Interface (fbintf). The fbintf components provide a set of
3			* Pascal language bindings for the Firebird API.
4			*
5			* The contents of this file are subject to the Initial Developer's
6			* Public License Version 1.0 (the "License"); you may not use this
7			* file except in compliance with the License. You may obtain a copy
8			* of the License here:
9			*
10			* http://www.firebirdsql.org/index.php?op=doc&id=idpl
11			*
12			* Software distributed under the License is distributed on an "AS
13			* IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
14			* implied. See the License for the specific language governing rights
15			* and limitations under the License.
16			*
17			* The Initial Developer of the Original Code is Tony Whyman.
18			*
19			* The Original Code is (C) 2016 Tony Whyman, MWA Software
20			* (http://www.mwasoftware.co.uk).
21			*
22			* All Rights Reserved.
23			*
24			* Contributor(s): ______________________________________.
25			*
26			*)
27			unit FB30Array;
28	tony	56	{$IFDEF MSWINDOWS}
29			{$DEFINE WINDOWS}
30			{$ENDIF}
31	tony	45
32			{$IFDEF FPC}
33	tony	56	{$mode delphi}
34	tony	45	{$codepage UTF8}
35			{$interfaces COM}
36			{$ENDIF}
37
38			interface
39
40			uses
41			Classes, SysUtils, Firebird, IB, FBArray, IBHeader, FB30Attachment, FBClientAPI,
42			FB30Transaction, FBParamBlock;
43
44			type
45
46	tony	56	ISDLItem = interface(IParameterBlockItem)
47			['{a34b6064-5ae9-4fc1-85c3-f145f069b607}']
48	tony	45	procedure addByte(aValue: byte);
49			procedure addShortInteger(aValue: integer);
50			procedure SetAsShortInteger(aValue: integer);
51			procedure SetAsTinyInteger(aValue: integer);
52			end;
53
54	tony	56	ISDL = interface(IParameterBlock<ISDLItem>)
55			['{52ae1f5f-657b-4b14-81aa-7b3658454f4c}']
56	tony	45	end;
57
58			{ TFB30ArrayMetaData }
59
60			TFB30ArrayMetaData = class(TFBArrayMetaData,IArrayMetaData)
61			private
62			FCodePage: TSystemCodePage;
63			protected
64			procedure LoadMetaData(aAttachment: IAttachment; aTransaction: ITransaction;
65	tony	56	relationName, columnName: AnsiString); override;
66	tony	45	public
67			function GetCharSetID: cardinal; override;
68			function GetCodePage: TSystemCodePage; override;
69			end;
70
71			{ TFB30Array }
72
73			TFB30Array = class(TFBArray,IArray)
74			private
75			FAttachmentIntf: Firebird.IAttachment;
76			FTransactionIntf: Firebird.ITransaction;
77			FSDL: ISDL;
78			protected
79			procedure AllocateBuffer; override;
80			procedure InternalGetSlice; override;
81			procedure InternalPutSlice(Force: boolean); override;
82			public
83			constructor Create(aAttachment: TFB30Attachment; aTransaction: TFB30Transaction; aField: IArrayMetaData); overload;
84			constructor Create(aAttachment: TFB30Attachment; aTransaction: TFB30Transaction; aField: IArrayMetaData; ArrayID: TISC_QUAD); overload;
85			end;
86
87			TSDLItem = class(TParamBlockItem,ISDLItem);
88
89			{ TSDLBlock }
90
91	tony	56	TSDLBlock = class (TCustomParamBlock<TSDLItem,ISDLItem>, ISDL)
92	tony	45	public
93			constructor Create;
94			end;
95
96			implementation
97
98	tony	47	uses FBAttachment, FB30ClientAPI, FB30Statement;
99	tony	45
100			const
101			sGetArrayMetaData = 'Select F.RDB$FIELD_LENGTH, F.RDB$FIELD_SCALE, F.RDB$FIELD_TYPE, '+
102			'F.RDB$DIMENSIONS, FD.RDB$DIMENSION, FD.RDB$LOWER_BOUND, FD.RDB$UPPER_BOUND, '+
103			'F.RDB$CHARACTER_SET_ID '+
104			'From RDB$FIELDS F JOIN RDB$RELATION_FIELDS RF '+
105			'On F.RDB$FIELD_NAME = RF.RDB$FIELD_SOURCE JOIN RDB$FIELD_DIMENSIONS FD '+
106			'On FD.RDB$FIELD_NAME = F.RDB$FIELD_NAME ' +
107			'Where RF.RDB$RELATION_NAME = ? and RF.RDB$FIELD_NAME = ? Order by FD.RDB$DIMENSION asc';
108
109
110			{ TFB30ArrayMetaData }
111
112			{Assemble the array descriptor from the System Tables}
113
114			procedure TFB30ArrayMetaData.LoadMetaData(aAttachment: IAttachment;
115	tony	56	aTransaction: ITransaction; relationName, columnName: AnsiString);
116	tony	45	var stmt: IStatement;
117	tony	47	CharWidth: integer;
118	tony	45	begin
119			RelationName := AnsiUpperCase(RelationName);
120			ColumnName := AnsiUpperCase(ColumnName);
121			stmt := TFB30Statement.Create(aAttachment as TFB30Attachment,aTransaction,
122			sGetArrayMetaData ,aAttachment.GetSQLDialect);
123			with stmt do
124			begin
125			SQLParams[0].AsString := RelationName;
126			SQLParams[1].AsString := ColumnName;
127			with OpenCursor do
128			if FetchNext then
129			begin
130			FillChar(FArrayDesc.array_desc_field_name,sizeof(FArrayDesc.array_desc_field_name),' ');
131	tony	47	FillChar(FArrayDesc.array_desc_relation_name,sizeof(FArrayDesc.array_desc_relation_name),' ');
132	tony	45	Move(columnName[1],FArrayDesc.array_desc_field_name,Length(columnName));
133			Move(relationName[1],FArrayDesc.array_desc_relation_name,length(relationName));
134			FArrayDesc.array_desc_length := Data[0].AsInteger;
135	tony	56	FArrayDesc.array_desc_scale := Data[1].AsInteger;
136	tony	45	FArrayDesc.array_desc_dtype := Data[2].AsInteger;
137			FArrayDesc.array_desc_dimensions := Data[3].AsInteger;
138			FArrayDesc.array_desc_flags := 0; {row major}
139			FCharSetID := Data[7].AsInteger;
140			if (FCharSetID > 1) and (aAttachment as TFB30Attachment).HasDefaultCharSet then
141			FCharSetID := (aAttachment as TFB30Attachment).CharSetID;
142			FCodePage := CP_NONE;
143	tony	60	FAttachment.CharSetID2CodePage(FCharSetID,FCodePage);
144	tony	47	if (FArrayDesc.array_desc_dtype in [blr_text,blr_cstring, blr_varying]) and
145			(FCharSetID = 0) then {This really shouldn't be necessary - but it is :(}
146			with aAttachment as TFBAttachment do
147			begin
148	tony	60	if HasDefaultCharSet and FAttachment.CharSetWidth(CharSetID,CharWidth) then
149	tony	56	FArrayDesc.array_desc_length := FArrayDesc.array_desc_length * CharWidth;
150	tony	47	end;
151	tony	45	repeat
152			with FArrayDesc.array_desc_bounds[Data[4].AsInteger] do
153			begin
154			array_bound_lower := Data[5].AsInteger;
155			array_bound_upper := Data[6].AsInteger;
156			end;
157			until not FetchNext;
158			end;
159			end;
160			end;
161
162			function TFB30ArrayMetaData.GetCharSetID: cardinal;
163			begin
164			Result := FCharSetID;
165			end;
166
167			function TFB30ArrayMetaData.GetCodePage: TSystemCodePage;
168			begin
169			Result := FCodePage;
170			end;
171
172			{ TFB30Array }
173
174			procedure TFB30Array.AllocateBuffer;
175
176			procedure AddVarInteger(aValue: integer);
177			begin
178			if (aValue >= -128) and (aValue <= 127) then
179			FSDL.Add(isc_sdl_tiny_integer).SetAsTinyInteger(aValue)
180			else
181			if (aValue >= -32768) and (aValue <= 32767) then
182			FSDL.Add(isc_sdl_short_integer).SetAsShortInteger(aValue)
183			else
184			FSDL.Add(isc_sdl_long_integer).SetAsInteger(aValue);
185			end;
186
187			var i: integer;
188			SDLItem: ISDLItem;
189			begin
190			inherited AllocateBuffer;
191			{Now set up the SDL}
192
193			FSDL := TSDLBlock.Create;
194			with GetArrayDesc^ do
195			{The following is based on gen_SDL from Firebird src/dsql/array.cpp}
196			begin
197			SDLItem := FSDL.Add(isc_sdl_struct);
198			SDLItem.SetAsByte(array_desc_dtype);
199
200			case array_desc_dtype of
201			blr_short,blr_long,
202			blr_int64,blr_quad:
203			SDLItem.AddByte(byte(array_desc_scale));
204
205			blr_text,blr_cstring, blr_varying:
206			SDLItem.addShortInteger(array_desc_length);
207			end;
208
209	tony	47	FSDL.Add(isc_sdl_relation).SetAsString(array_desc_relation_name);
210			FSDL.Add(isc_sdl_field).SetAsString(array_desc_field_name);
211	tony	45
212			for i := 0 to array_desc_dimensions - 1 do
213			begin
214			if array_desc_bounds[i].array_bound_lower = 1 then
215			FSDL.Add(isc_sdl_do1).SetAsTinyInteger(i)
216			else
217			begin
218			FSDL.Add(isc_sdl_do2).SetAsTinyInteger(i);
219			AddVarInteger(array_desc_bounds[i].array_bound_lower);
220			end;
221			AddVarInteger(array_desc_bounds[i].array_bound_upper);
222			end;
223
224			SDLItem := FSDL.Add(isc_sdl_element);
225			SDLItem.AddByte(1);
226			SDLItem := FSDL.Add(isc_sdl_scalar);
227			SDLItem.AddByte(0);
228			SDLItem.AddByte(array_desc_dimensions);
229			for i := 0 to array_desc_dimensions - 1 do
230			begin
231			SDLItem := FSDL.Add(isc_sdl_variable);
232			SDLItem.AddByte(i);
233			end;
234			FSDL.Add(isc_sdl_eoc);
235			end;
236			end;
237
238			procedure TFB30Array.InternalGetSlice;
239			begin
240			with Firebird30ClientAPI do
241			begin
242			FAttachmentIntf.getSlice(StatusIntf,FTransactionIntf,
243			@FArrayID,
244			(FSDL as TSDLBlock).getDataLength,
245			BytePtr((FSDL as TSDLBlock).getBuffer),
246			0,nil,
247			FBufSize,BytePtr(FBuffer)
248			);
249			Check4DataBaseError;
250			end;
251			SignalActivity;
252			end;
253
254			procedure TFB30Array.InternalPutSlice(Force: boolean);
255			begin
256			with Firebird30ClientAPI do
257			begin
258			FAttachmentIntf.putSlice(StatusIntf,FTransactionIntf, @FArrayID,
259			(FSDL as TSDLBlock).getDataLength,
260			BytePtr((FSDL as TSDLBlock).getBuffer),
261			0,nil,
262			FBufSize,BytePtr(FBuffer)
263			);
264			if not Force then
265			Check4DataBaseError;
266			end;
267			SignalActivity;
268			end;
269
270			constructor TFB30Array.Create(aAttachment: TFB30Attachment;
271			aTransaction: TFB30Transaction; aField: IArrayMetaData);
272			begin
273			inherited Create(aAttachment,aTransaction,aField);
274			FAttachmentIntf := aAttachment.AttachmentIntf;
275			FTransactionIntf := aTransaction.TransactionIntf;
276			end;
277
278			constructor TFB30Array.Create(aAttachment: TFB30Attachment;
279			aTransaction: TFB30Transaction; aField: IArrayMetaData; ArrayID: TISC_QUAD);
280			begin
281			inherited Create(aAttachment,aTransaction,aField,ArrayID);
282			FAttachmentIntf := aAttachment.AttachmentIntf;
283			FTransactionIntf := aTransaction.TransactionIntf;
284			end;
285
286			{ TSDLBlock }
287
288			constructor TSDLBlock.Create;
289			begin
290			inherited Create;
291			FDataLength := 1;
292	tony	56	FBuffer^ := isc_sdl_version1;
293	tony	45	end;
294
295			end.
296