Skończyło się na procedurze wymienionej poniżej. Działa, ale nie jestem pewien, czy ze wszystkimi zapytaniami jest efektywne identyfikowanie kolejnych zakresów. Można go wywołać za pomocą następujących argumentów (przykład):
call chunkUpdate('SET var=0','someTable','theKey',500000);
Zasadniczo pierwszym argumentem jest polecenie aktualizacji (np. coś w rodzaju „set x =...”), po którym następuje nazwa tabeli mysql, a następnie klucz numeryczny (całkowity), który musi być unikalny, po którym następuje rozmiar kawałki do przetworzenia. Klucz powinien mieć indeks dla rozsądnej wydajności. Zmienna „n” i instrukcje „select” w poniższym kodzie można usunąć i służą tylko do debugowania.
Ogranicznikdelimiter //
CREATE PROCEDURE chunkUpdate (IN cmd VARCHAR(255), IN tab VARCHAR(255), IN ky VARCHAR(255),IN sz INT)
BEGIN
SET @sqlgetmin = CONCAT("SELECT MIN(",ky,")-1 INTO @minkey FROM ",tab);
SET @sqlgetmax = CONCAT("SELECT MAX(",ky,") INTO @maxkey FROM ( SELECT ",ky," FROM ",tab," WHERE ",ky,">@minkey ORDER BY ",ky," LIMIT ",sz,") AS TMP");
SET @sqlstatement = CONCAT("UPDATE ",tab," ",cmd," WHERE ",ky,">@minkey AND ",ky,"<[email protected]");
SET @n=1;
PREPARE getmin from @sqlgetmin;
PREPARE getmax from @sqlgetmax;
PREPARE statement from @sqlstatement;
EXECUTE getmin;
REPEAT
EXECUTE getmax;
SELECT cmd,@n AS step, @minkey AS min, @maxkey AS max;
EXECUTE statement;
set @[email protected];
set @[email protected]+1;
UNTIL @maxkey IS NULL
END REPEAT;
select CONCAT(cmd, " EXECUTED IN ",@n," STEPS") AS MESSAGE;
END//