ViewVC Help
View File | Revision Log | Show Annotations | Download File | View Changeset | Root Listing
root/public/ibx/trunk/runtime/IBUpdateSQL.pas
(Generate patch)

Comparing ibx/trunk/runtime/IBUpdateSQL.pas (file contents):
Revision 5 by tony, Fri Feb 18 16:26:16 2011 UTC vs.
Revision 33 by tony, Sat Jul 18 12:30:52 2015 UTC

# Line 24 | Line 24
24   {       Corporation. All Rights Reserved.                                }
25   {    Contributor(s): Jeff Overcash                                       }
26   {                                                                        }
27 + {    IBX For Lazarus (Firebird Express)                                  }
28 + {    Contributor: Tony Whyman, MWA Software http://www.mwasoftware.co.uk }
29 + {    Portions created by MWA Software are copyright McCallum Whyman      }
30 + {    Associates Ltd 2011                                                 }
31 + {                                                                        }
32   {************************************************************************}
33  
34   unit IBUpdateSQL;
# Line 32 | Line 37 | unit IBUpdateSQL;
37  
38   interface
39  
40 < uses SysUtils, Classes, DB, IB, IBCustomDataSet, IBQuery;
40 > uses SysUtils, Classes, DB, IB, IBCustomDataSet, IBSQL;
41  
42   type
43   { TIBUpdateSQL }
# Line 40 | Line 45 | type
45    TIBUpdateSQL = class(TIBDataSetUpdateObject)
46    private
47      FDataSet: TIBCustomDataSet;
48 <    FQueries: array[TUpdateKind] of TIBQuery;
48 >    FQueries: array[TUpdateKind] of TIBSQL;
49      FSQLText: array[TUpdateKind] of TStrings;
50 <    function GetQuery(UpdateKind: TUpdateKind): TIBQuery;
50 >    function GetQuery(UpdateKind: TUpdateKind): TIBSQL;
51      function GetSQLIndex(Index: Integer): TStrings;
52      procedure SetSQL(UpdateKind: TUpdateKind; Value: TStrings);
53      procedure SetSQLIndex(Index: Integer; Value: TStrings);
54    protected
55 +    procedure InternalPrepare(UpdateKind: TUpdateKind);
56      function GetSQL(UpdateKind: TUpdateKind): TStrings; override;
57      function GetDataSet: TIBCustomDataSet; override;
58      procedure SetDataSet(ADataSet: TIBCustomDataSet); override;
59      procedure SQLChanged(Sender: TObject);
60 +    procedure Apply(UpdateKind: TUpdateKind; buff: PChar); override;
61 +    procedure ExecSQL(UpdateKind: TUpdateKind);
62    public
63      constructor Create(AOwner: TComponent); override;
64      destructor Destroy; override;
57 –    procedure Apply(UpdateKind: TUpdateKind); override;
58 –    procedure ExecSQL(UpdateKind: TUpdateKind);
59 –    procedure SetParams(UpdateKind: TUpdateKind);
65      property DataSet;
66 <    property Query[UpdateKind: TUpdateKind]: TIBQuery read GetQuery;
66 >    property Query[UpdateKind: TUpdateKind]: TIBSQL read GetQuery;
67      property SQL[UpdateKind: TUpdateKind]: TStrings read GetSQL write SetSQL;
68    published
69      property ModifySQL: TStrings index 0 read GetSQLIndex write SetSQLIndex;
# Line 97 | Line 102 | end;
102  
103   procedure TIBUpdateSQL.ExecSQL(UpdateKind: TUpdateKind);
104   begin
105 +  InternalPrepare(UpdateKind);
106    with Query[UpdateKind] do
107    begin
108 <    Prepare;
109 <    ExecSQL;
110 <    if RowsAffected <> 1 then IBError(ibxeUpdateFailed, [nil]);
108 >    ExecQuery;
109 > //    if RowsAffected <> 1 then IBError(ibxeUpdateFailed, [nil]);
110 > // Commented out in release 1.2
111    end;
112   end;
113  
114 < function TIBUpdateSQL.GetQuery(UpdateKind: TUpdateKind): TIBQuery;
114 > function TIBUpdateSQL.GetQuery(UpdateKind: TUpdateKind): TIBSQL;
115   begin
116    if not Assigned(FQueries[UpdateKind]) then
117    begin
118 <    FQueries[UpdateKind] := TIBQuery.Create(Self);
118 >    FQueries[UpdateKind] := TIBSQL.Create(Self);
119      FQueries[UpdateKind].SQL.Assign(FSQLText[UpdateKind]);
120      if (FDataSet is TIBCustomDataSet) then
121      begin
# Line 150 | Line 156 | begin
156    SetSQL(TUpdateKind(Index), Value);
157   end;
158  
159 + procedure TIBUpdateSQL.InternalPrepare(UpdateKind: TUpdateKind);
160 + begin
161 +  with Query[UpdateKind] do
162 +  begin
163 +    with Transaction do
164 +      if not InTransaction then StartTransaction;
165 +    if not Prepared then Prepare;
166 +  end;
167 + end;
168 +
169   procedure TIBUpdateSQL.SQLChanged(Sender: TObject);
170   var
171    UpdateKind: TUpdateKind;
# Line 158 | Line 174 | begin
174      if Sender = FSQLText[UpdateKind] then
175      begin
176        if Assigned(FQueries[UpdateKind]) then
161 –      begin
162 –        FQueries[UpdateKind].Params.Clear;
177          FQueries[UpdateKind].SQL.Assign(FSQLText[UpdateKind]);
164 –      end;
178        Break;
179      end;
180   end;
181  
182 < procedure TIBUpdateSQL.SetParams(UpdateKind: TUpdateKind);
170 < var
171 <  I: Integer;
172 <  Old: Boolean;
173 <  Param: TParam;
174 <  PName: string;
175 <  Field: TField;
176 <  Value: Variant;
182 > procedure TIBUpdateSQL.Apply(UpdateKind: TUpdateKind; buff: PChar);
183   begin
184    if not Assigned(FDataSet) then Exit;
185 <  with Query[UpdateKind] do
186 <  begin
181 <    for I := 0 to Params.Count - 1 do
182 <    begin
183 <      Param := Params[I];
184 <      PName := Param.Name;
185 <      Old := CompareText(Copy(PName, 1, 4), 'OLD_') = 0; {do not localize}
186 <      if Old then
187 <        System.Delete(PName, 1, 4);
188 <      Field := FDataSet.FindField(PName);
189 <      if not Assigned(Field) then
190 <        Continue;
191 <      if Old then
192 <        Param.AssignFieldValue(Field, Field.OldValue) else
193 <      begin
194 <        Value := Field.NewValue;
195 <        if VarIsEmpty(Value) then
196 <          Value := Field.OldValue;
197 <        Param.AssignFieldValue(Field, Value);
198 <      end;
199 <    end;
200 <  end;
201 < end;
202 <
203 < procedure TIBUpdateSQL.Apply(UpdateKind: TUpdateKind);
204 < begin
205 <  SetParams(UpdateKind);
185 >  InternalPrepare(UpdateKind);
186 >  InternalSetParams(Query[UpdateKind],buff);
187    ExecSQL(UpdateKind);
188   end;
189  
190 < end.
190 > end.

Diff Legend

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