From 773286bd0624317d3a3131bae8a0033bd6a2d483 Mon Sep 17 00:00:00 2001
From: Neozonz <neozonz@gmail.com>
Date: Sun, 19 Jan 2014 06:00:29 -0500
Subject: [PATCH] ORDER BY for Updates/Deletes

---
 public/include/classes/base.class.php   | 2 +-
 public/include/classes/block.class.php  | 2 +-
 public/include/classes/payout.class.php | 2 +-
 public/include/classes/token.class.php  | 2 +-
 public/include/classes/worker.class.php | 4 ++--
 5 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/public/include/classes/base.class.php b/public/include/classes/base.class.php
index 85b43d57..78a22808 100644
--- a/public/include/classes/base.class.php
+++ b/public/include/classes/base.class.php
@@ -234,7 +234,7 @@ class Base {
   protected function updateSingle($id, $field, $table='') {
     if (empty($table)) $table = $this->table;
     $this->debug->append("STA " . __METHOD__, 4);
-    $stmt = $this->mysqli->prepare("UPDATE $table SET " . $field['name'] . " = ? WHERE id = ? LIMIT 1");
+    $stmt = $this->mysqli->prepare("UPDATE $table SET " . $field['name'] . " = ? WHERE id = ? ORDER BY id LIMIT 1");
     if ($this->checkStmt($stmt) && $stmt->bind_param($field['type'].'i', $field['value'], $id) && $stmt->execute())
       return true;
     $this->debug->append("Unable to update " . $field['name'] . " with " . $field['value'] . " for ID $id");
diff --git a/public/include/classes/block.class.php b/public/include/classes/block.class.php
index b65d88a3..4f101dce 100644
--- a/public/include/classes/block.class.php
+++ b/public/include/classes/block.class.php
@@ -145,7 +145,7 @@ class Block extends Base {
    * @return bool
    **/
   public function setConfirmations($block_id, $confirmations) {
-    $stmt = $this->mysqli->prepare("UPDATE $this->table SET confirmations = ? WHERE id = ?");
+    $stmt = $this->mysqli->prepare("UPDATE $this->table SET confirmations = ? WHERE id = ? ORDER BY id LIMIT 1");
     if ($this->checkStmt($stmt) && $stmt->bind_param("ii", $confirmations, $block_id) && $stmt->execute())
       return true;
     return $this->sqlError();
diff --git a/public/include/classes/payout.class.php b/public/include/classes/payout.class.php
index d7c2cae1..e0fc93e2 100644
--- a/public/include/classes/payout.class.php
+++ b/public/include/classes/payout.class.php
@@ -49,7 +49,7 @@ class Payout Extends Base {
    * @return boolean bool True or False
    **/
   public function setProcessed($id) {
-    $stmt = $this->mysqli->prepare("UPDATE $this->table SET completed = 1 WHERE id = ?");
+    $stmt = $this->mysqli->prepare("UPDATE $this->table SET completed = 1 WHERE id = ? ORDER BY id LIMIT 1");
     if ($stmt && $stmt->bind_param('i', $id) && $stmt->execute())
       return true;
     return $this->sqlError('E0051');
diff --git a/public/include/classes/token.class.php b/public/include/classes/token.class.php
index 8453c245..18ed5d53 100644
--- a/public/include/classes/token.class.php
+++ b/public/include/classes/token.class.php
@@ -49,7 +49,7 @@ class Token Extends Base {
    * @return bool
    **/
   public function deleteToken($token) {
-    $stmt = $this->mysqli->prepare("DELETE FROM $this->table WHERE token = ? LIMIT 1");
+    $stmt = $this->mysqli->prepare("DELETE FROM $this->table WHERE token = ? ORDER BY id LIMIT 1");
     if ($stmt && $stmt->bind_param('s', $token) && $stmt->execute())
       return true;
     return $this->sqlError();
diff --git a/public/include/classes/worker.class.php b/public/include/classes/worker.class.php
index a028d5a4..ba886d09 100644
--- a/public/include/classes/worker.class.php
+++ b/public/include/classes/worker.class.php
@@ -31,7 +31,7 @@ class Worker extends Base {
       }
       // Prefix the WebUser to Worker name
       $value['username'] = "$username." . $value['username'];
-      $stmt = $this->mysqli->prepare("UPDATE $this->table SET password = ?, username = ?, monitor = ? WHERE account_id = ? AND id = ?");
+      $stmt = $this->mysqli->prepare("UPDATE $this->table SET password = ?, username = ?, monitor = ? WHERE account_id = ? AND id = ? ORDER BY id LIMIT 1");
       if ( ! ( $this->checkStmt($stmt) && $stmt->bind_param('ssiii', $value['password'], $value['username'], $value['monitor'], $account_id, $key) && $stmt->execute()) )
         $iFailed++;
       }
@@ -259,7 +259,7 @@ class Worker extends Base {
    **/
   public function deleteWorker($account_id, $id) {
     $this->debug->append("STA " . __METHOD__, 4);
-    $stmt = $this->mysqli->prepare("DELETE FROM $this->table WHERE account_id = ? AND id = ?");
+    $stmt = $this->mysqli->prepare("DELETE FROM $this->table WHERE account_id = ? AND id = ? ORDER BY id LIMIT 1");
     if ($this->checkStmt($stmt) && $stmt->bind_param('ii', $account_id, $id) && $stmt->execute() && $stmt->affected_rows == 1)
         return true;
     return $this->sqlError('E0061');