не пинайте. я начинающий. с БД сталкиваюсь впервые. понадобилось сконвертировать данные в таблице более 300 000 строк.
таблица вида: id, dateFrom, dateTo, lD_CL, inA, inB, status ...
записи периодами 15 минут (но не все). т.е. например dateFrom = '01.01.2020 10:00:00' dateTo = '01.01.2020 10:15:00' и т.д
понадобилось сконвертировать в 1 часовые. НО с доп проверкой их полноты и т.д....
До sql запроса я не смог догадаться, как голову ни ломал...
плюс нужна доп обработка, поэтому слобал на дельфи:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
var mtL, mtR, mt: TFDMemTable;
d,d1,d2: tdatetime;
s,id: string;
c:char; idR, m, line, status, InA, InC, OutA, OutC, h:int64;
begin
c:=chr(39);
mtL:=TFDMemTable.Create(nil); mtR:=TFDMemTable.Create(nil);
FDQueryL[0].Connection:=FDConnectL[0];
FDQueryR[0].Connection:=FDConnectL[0];
FDQueryL[0].FetchOptions.Unidirectional := False;
FDQueryR[0].FetchOptions.Unidirectional := False;
FDQueryL[0].Sql.Text := 'SELECT * FROM source_table;';
FDQueryL[0].Open;
FDQueryL[0].FetchAll;
FDQueryR[0].Sql.Text := 'SELECT * FROM destination_table;';
FDQueryR[0].Open;
FDQueryR[0].FetchAll;
// mtL.Data:=FDQueryL[0].Data;
// mtR.Data:=FDQueryR[0].Data;
mtL.CopyDataSet(FDQueryL[0], [coStructure, coRestart, coAppend] );
mtR.CopyDataSet(FDQueryR[0], [coStructure, coRestart, coAppend] );
mtL.Open;
mtR.Open;
mtL.DisableControls;
mtR.DisableControls;
with mtR do
begin
LogChanges := False;
FetchOptions.RecsMax := 300000; //Sample value
ResourceOptions.SilentMode := True;
UpdateOptions.LockMode := lmNone;
UpdateOptions.LockPoint := lpDeferred;
UpdateOptions.FetchGeneratorsPoint := gpImmediate;
end;
mtR.BeginBatch;
idR:=0;
d:=EncodeDate(2019,6,1)+EncodeTime(1,0,0,0); d1:=d;
while d<now do
begin
for line := 4 to 20 do
begin
//выбитаем все что в 1 часе
mtL.Filtered := False;
//не обращайте внимания на кривизну кода фильтра
mtL.Filter := '(ID_CL='+inttostr(line)+') AND '+
'(TimeFrom >= '+c+DateTimeToStr(d)+c+
') AND ('+
'TimeFrom < '+c+FormatDateTime('dd.mm.yyyy h:mm:ss', IncSecond(d, 3599))+c+')';
mtL.Filtered := true;
//считаем сумму минут
m:=0; InA:=0; InC:=0; OutA:=0; OutC:=0;
mtL.First;
while (not mtL.Eof) do
begin
m:=m+SecondOfTheDay(mtL.Fields[2].AsDateTime)-SecondOfTheDay(mtL.Fields[1].AsDateTime);
InA:=InA + mtL.Fields[4].AsInteger; InC:=InC + mtL.Fields[5].AsInteger;
OutA:=OutA + mtL.Fields[6].AsInteger; OutC:=OutC + mtL.Fields[7].AsInteger;
Application.ProcessMessages;
mtL.Next;
end;
//выставляем статус пакету
if m=3600 then status:=1 else status:=0;
if m<>0 then //добавляем записб в приемник
begin
with mtR do
begin
Append;
Fields[0].AsInteger := idR;
Fields[1].AsDateTime := d;
Fields[2].AsDateTime := d+EncodeTime(1,0,0,0);
Fields[3].AsInteger := line;
Fields[4].AsInteger := InA; Fields[5].AsInteger := InC;
Fields[6].AsInteger := OutA; Fields[7].AsInteger := OutC;
Post;
end;
idR:=idR+1;
end;
end;
d:=RecodeMilliSecond(d, 0);
d:=IncSecond(d,3600);
Application.ProcessMessages;
end;
mtR.EndBatch;
mtL.EnableControls;
mtR.EnableControls;
FDQueryR[0].Close;
FDQueryR[0].CopyDataSet(mtR);
FDQueryR[0].Open;
mtL.Free; mtR.Free;
обрабатывает около СУТОК !!! что я делаю неправильно ?
