SELECT następnie natychmiast USUŃ rekord mysql

Question

Mam skrypt PHP, który uruchamia zapytanie SELECT, a następnie natychmiast usuwa rekord. Istnieje wiele maszyn, które wysyłają ping do tego samego pliku php i pobierają dane z tej samej tabeli. Każda zdalna maszyna działa w zadaniu cron.

Mój problem polega na tym, że czasami nie można usunąć wystarczająco szybko, ponieważ niektóre maszyny pingują dokładnie w tym samym czasie.

Moje pytanie brzmi: jak mogę wybrać rekord z bazy danych i usunąć go, zanim następny komputer go pobierze. Na razie dodałem tylko krótkie opóźnienie, ale nie działa zbyt dobrze. Próbowałem użyć transakcji, ale nie sądzę, że ma ona zastosowanie tutaj.

Oto przykładowy fragment mojego skryptu:

<?php 

$query = "SELECT * FROM `queue` LIMIT 1"; 
$result = mysql_query($query) or die(mysql_error()); 

while($row = mysql_fetch_array($result)){ 
    $email = $row['email']; 
    $campaign_id = $row['campaign']; 
} 

$queryx = "DELETE FROM `queue` WHERE `email` = '".$email."'"; 
$resultx = mysql_query($queryx) or die(mysql_error()); 

?> 

naprawdę docenić pomoc.

Answer 1

Połóż swoje kwerendy do usunięcia w pętli while, po prostu przysięgnij, że chcesz zwiększyć limit od swojego wyboru.

<?php 
$query = mysql_query("SELECT * FROM `queue` LIMIT 1") or die(mysql_error()); 

while($row = mysql_fetch_array($query)){ 
    mysql_query("DELETE FROM `queue` WHERE `email` = '" . $row['email'] . "' LIMIT 1") or die(mysql_error()); 
} 
?> 

Powyższy kod będzie tak samo jak bieganie:

mysql_query("DELETE FROM `queue` LIMIT 1") or die(mysql_error()); 

Bądź ostrożny przy użyciu DELETE, jeśli pole email jest puste, to usunąć wszystkie wiersze, które mają pusty e-mail. Dodaj LIMIT 1 do zapytania usuwania, aby uniknąć usunięcia wielu wierszy.

Aby dodać losowe opóźnienie, można dodać sleep na początku skryptu,

np

<?php 
$seconds = mt_rand(1,10); 
sleep($seconds); 
?> 

Answer 2

dobrze użyłbym zamki tabeli read more here

zamek jest bezpieczny i dotyczy jednej sesji klienta. Blokada stołu chroni tylko przed nieodpowiednimi odczytami lub zapisami wykonanymi przez inne sesje.

Answer 3

uruchom zapytanie o aktualizację, które zmieni klucz przed dokonaniem wyboru. Dokonaj wyboru za pomocą tego nowego klucza, który jest znany tylko w tej samej sesji.
Jeśli tabela jest innoDB, rekord jest zablokowany, a kiedy zostanie zwolniony, pozostałe opcje nie znajdą rekordu.

Answer 4

Należy użyć podzapytania następująco ...

<?php 

$queryx = "DELETE FROM `queue` WHERE `email` IN (SELECT email FROM `queue` LIMIT 1)"; 
$resultx = mysql_query($queryx) or die(mysql_error()); 

?> 

* Uwaga: Zawsze wybrać tylko te pola, które chcesz ... unikać select * ... będzie to spowolnić działanie

Answer 5

Jeśli używasz MariaDB 10:

DELETE FROM `queue` LIMIT 1 RETURNING * 

Documentation.