Skip to content

Commit 78d9081

Browse files
committed
Fix: Correção final do AV no DBWare otimizando consumo de memória
Fixed #123
1 parent e03d657 commit 78d9081

7 files changed

Lines changed: 12 additions & 16 deletions

File tree

src/database/FireDAC/RALDBFiredacMemTable.pas

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
/// Unit for FireDAC MemTable wrapper
1+
/// Unit for FireDAC MemTable wrapper
22
unit RALDBFiredacMemTable;
33

44
{$I ..\..\base\PascalRAL.inc}
@@ -320,7 +320,7 @@ procedure TRALDBFDMemTable.LoadFromRALStorage(ADataSet: TDataSet; AStream: TStre
320320
if FStorage <> nil then
321321
FStorage.LoadFromStream(ADataSet, AStream)
322322
else
323-
raise Exception.Create('Storage class não localizada');
323+
raise Exception.Create(emStorageClassNotFound);
324324
end;
325325

326326
procedure TRALDBFDMemTable.Notification(AComponent: TComponent; Operation: TOperation);
@@ -344,7 +344,7 @@ procedure TRALDBFDMemTable.OnApplyUpdates(Sender: TObject; AResponse: TRALRespon
344344
begin
345345
if AResponse.StatusCode = HTTP_OK then
346346
begin
347-
vMem := AResponse.ParamByName('Stream').AsStream;
347+
vMem := AResponse.Body.AsStream;
348348
try
349349
FSQLCache.ResponseFromStream(vMem);
350350
for vInt1 := 0 to Pred(FSQLCache.Count) do
@@ -435,7 +435,7 @@ procedure TRALDBFDMemTable.OnExecSQLResponse(Sender: TObject; AResponse: TRALRes
435435
begin
436436
if AResponse.StatusCode = HTTP_OK then
437437
begin
438-
vMem := AResponse.ParamByName('Stream').AsStream;
438+
vMem := AResponse.Body.AsStream;
439439
try
440440
vSQLCache := TRALDBSQLCache.Create;
441441
try
@@ -475,7 +475,7 @@ procedure TRALDBFDMemTable.OnQueryResponse(Sender: TObject; AResponse: TRALRespo
475475
begin
476476
if AResponse.StatusCode = HTTP_OK then
477477
begin
478-
vMem := AResponse.ParamByName('Stream').AsStream;
478+
vMem := AResponse.Body.AsStream;
479479
try
480480
FLoading := True;
481481

src/database/Zeos/RALDBZeosMemTable.pas

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,7 @@ procedure TRALDBZMemTable.LoadFromRALStorage(ADataSet: TDataSet; AStream: TStrea
138138
if FStorage <> nil then
139139
FStorage.LoadFromStream(ADataSet, AStream)
140140
else
141-
raise Exception.Create('Storage class não localizada');
141+
raise Exception.Create(emStorageClassNotFound);
142142
end;
143143

144144
procedure TRALDBZMemTable.InternalDelete;
@@ -324,7 +324,7 @@ procedure TRALDBZMemTable.OnQueryResponse(Sender: TObject; AResponse: TRALRespon
324324
begin
325325
if AResponse.StatusCode = HTTP_OK then
326326
begin
327-
vMem := AResponse.ParamByName('Stream').AsStream;
327+
vMem := AResponse.Body.AsStream;
328328
try
329329
FLoading := True;
330330
vSQLCache := TRALDBSQLCache.Create;
@@ -369,7 +369,7 @@ procedure TRALDBZMemTable.OnExecSQLResponse(Sender: TObject; AResponse: TRALResp
369369
begin
370370
if AResponse.StatusCode = HTTP_OK then
371371
begin
372-
vMem := AResponse.ParamByName('Stream').AsStream;
372+
vMem := AResponse.Body.AsStream;
373373
try
374374
vSQLCache := TRALDBSQLCache.Create;
375375
try
@@ -410,7 +410,7 @@ procedure TRALDBZMemTable.OnApplyUpdates(Sender: TObject; AResponse: TRALRespons
410410
begin
411411
if AResponse.StatusCode = HTTP_OK then
412412
begin
413-
vMem := AResponse.ParamByName('Stream').AsStream;
413+
vMem := AResponse.Body.AsStream;
414414
try
415415
FSQLCache.ResponseFromStream(vMem);
416416
for vInt1 := 0 to Pred(FSQLCache.Count) do

src/database/sqldb/RALDBBufDataset.pas

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -300,7 +300,7 @@ procedure TRALDBBufDataset.OnQueryResponse(Sender: TObject; AResponse: TRALRespo
300300
begin
301301
if AResponse.StatusCode = HTTP_OK then
302302
begin
303-
vMem := AResponse.ParamByName('Stream').AsStream;
303+
vMem := AResponse.Body.AsStream;
304304
try
305305
FLoading := True;
306306

@@ -347,7 +347,7 @@ procedure TRALDBBufDataset.OnExecSQLResponse(Sender: TObject; AResponse: TRALRes
347347
begin
348348
if AResponse.StatusCode = HTTP_OK then
349349
begin
350-
vMem := AResponse.ParamByName('Stream').AsStream;
350+
vMem := AResponse.Body.AsStream;
351351
try
352352
vSQLCache := TRALDBSQLCache.Create;
353353
try
@@ -388,7 +388,7 @@ procedure TRALDBBufDataset.OnApplyUpdates(Sender: TObject; AResponse: TRALRespon
388388
begin
389389
if AResponse.StatusCode = HTTP_OK then
390390
begin
391-
vMem := AResponse.ParamByName('Stream').AsStream;
391+
vMem := AResponse.Body.AsStream;
392392
try
393393
FSQLCache.ResponseFromStream(vMem);
394394
for vInt1 := 0 to Pred(FSQLCache.Count) do

src/engine/fpHTTP/RALfpHTTPClient.pas

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,6 @@ procedure TRALfpHttpClientHTTP.SendUrl(AURL: StringRAL; ARequest: TRALRequest;
145145
AResponse.ContentDisposition := FHttp.ResponseHeaders.Values['Content-Disposition'];
146146
AResponse.StatusCode := FHttp.ResponseStatusCode;
147147
AResponse.ResponseStream := vResult;
148-
AResponse.Params.AddParam('Stream', AResponse.ParamByName('ral_body').AsStream, rpkBODY);
149148
except
150149
on e: ESocketError do
151150
begin

src/engine/indy/RALIndyClient.pas

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,6 @@ procedure TRALIndyClientHTTP.SendUrl(AURL: StringRAL; ARequest: TRALRequest;
168168
AResponse.StatusCode := FHttp.ResponseCode;
169169

170170
AResponse.ResponseStream := vResult;
171-
AResponse.Params.AddParam('Stream', AResponse.ParamByName('ral_body').AsStream, rpkBODY);
172171
except
173172
on e: EIdSocketError do
174173
tratarExcecao(e.LastError, e.Message);

src/engine/netHTTP/RALnetHTTPClient.pas

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -182,7 +182,6 @@ procedure TRALnetHTTPClientHTTP.SendUrl(AURL: StringRAL; ARequest: TRALRequest;
182182
AResponse.ContentType := vResponse.MimeType;
183183
AResponse.StatusCode := vResponse.GetStatusCode;
184184
AResponse.ResponseStream := vResponse.ContentStream;
185-
AResponse.Params.AddParam('Stream', AResponse.ParamByName('ral_body').AsStream, rpkBODY);
186185
end;
187186
except
188187
on e: ENetHTTPClientException do begin

src/engine/synopse/RALSynopseClient.pas

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,6 @@ procedure TRALSynopseClientHTTP.SendUrl(AURL: StringRAL; ARequest: TRALRequest;
146146
AResponse.ContentDisposition := AResponse.ParamByName('Content-Disposition').AsString;
147147
AResponse.StatusCode := vResult;
148148
AResponse.ResponseText := vHttp.Content;
149-
AResponse.Params.AddParam('Stream', AResponse.ParamByName('ral_body').AsStream, rpkBODY);
150149
except
151150
on e: ENetSock do
152151
begin

0 commit comments

Comments
 (0)