2

我有一个用于批量更新/添加折扣价格的 php 函数。

代码运行良好，直到我 在选择语句中添加了 p.sku的 sku 上添加了额外的 $new_price 条件和 substr 检查。
它现在给了我一个空白屏幕，当我尝试执行它时查询没有运行。

if ($user_group == 15 && $percent == 0) {
$this->db->query("DELETE FROM " . DB_PREFIX . "product_discount WHERE customer_group_id = '".$user_group."' AND quantity = '".$quantity."'");

    $query = $this->db->query("SELECT p.product_id, p.sku, p.cost, p.price FROM product p");

    foreach ($query->rows as $result) {

        if ((substr($result['sku'],0,3) == 'ACA')) {
        $new_price = ($result['cost'] * 32.5 / 100 + $result['cost']);
        } else {
        $new_price = ($result['cost'] * 40 / 100 + $result['cost']);
        }

        $this->db->query("INSERT INTO " . DB_PREFIX . "product_discount SET 
        `product_id` = '" . $result['product_id'] . "', 
        `customer_group_id` = '15',
        `quantity` = '".$quantity."',
        `priority` = '".$priority."',
        `price` = '".$new_price."',
        `date_start` = '".$start_date."',
        `date_end` = '".$expire_date."'");
    }

}

我在这里想念什么？我一直在搜索论坛和谷歌等，整个下午都在尝试各种事情，我受够了！请帮助任何人！

在 index.php 中添加错误报告后，我终于得到了一个线索：
“致命错误：允许的 134217728 字节的内存大小用尽（试图分配 32 字节）”

这是函数的完整代码，根据评论进行了一些细微的更改，我不知道为什么所有内存都用完了，希望有人能提供帮助：

<?php
    class ModelBulkDiscount extends Model {

    public function updateDiscount($user_group = null, $percent = 0, $quantity = 1, $priority = 0, $start_date = null, $expire_date = null) {

if($user_group != 15 && $percent > 0) {
$this->db->query("DELETE FROM " . DB_PREFIX . "product_discount WHERE customer_group_id = '".$user_group."' AND quantity = '".$quantity."'");

    $query = $this->db->query("SELECT p.product_id, p.price FROM " . DB_PREFIX . "product p");

    foreach ($query->rows as $result) {

        $new_price = $result['price'] - (($result['price'] / 100) * $percent);

        $this->db->query("INSERT INTO " . DB_PREFIX . "product_discount SET 
        `product_id` = '" . $result['product_id'] . "', 
        `customer_group_id` = '" . $user_group . "',
        `quantity` = '".$quantity."',
        `priority` = '".$priority."',
        `price` = '".$new_price."',
        `date_start` = '".$start_date."',
        `date_end` = '".$expire_date."'");

    }

} else if ($user_group == 15 && $percent == 0) {
$this->db->query("DELETE FROM " . DB_PREFIX . "product_discount WHERE customer_group_id = '".$user_group."' AND quantity = '".$quantity."'");

    $query = $this->db->query("SELECT p.product_id, p.sku, p.cost, p.price FROM " . DB_PREFIX . "product p");

    foreach ($query->rows as $result) {

    if ((substr($result['sku'],0,3) == 'ACA')) {
        $new_price = ($result['cost'] * 1.325);
    } else {
        $new_price = ($result['cost'] * 1.4);
    }

        $this->db->query("INSERT INTO " . DB_PREFIX . "product_discount SET 
        `product_id` = '" . $result['product_id'] . "', 
        `customer_group_id` = '15',
        `quantity` = '".$quantity."',
        `priority` = '".$priority."',
        `price` = '".$new_price."',
        `date_start` = '".$start_date."',
        `date_end` = '".$expire_date."'");
    }

} else if ($user_group == 15 && $percent > 0) {
$this->db->query("DELETE FROM " . DB_PREFIX . "product_discount WHERE customer_group_id = '".$user_group."' AND quantity = '".$quantity."'");

    $query = $this->db->query("SELECT p.product_id, p.cost, p.price FROM " . DB_PREFIX . "product p");

    foreach ($query->rows as $result) {
        $temp_price = ($result['cost'] * 1.325);
        $new_price = $temp_price - (($temp_price / 100) * $percent);

        $this->db->query("INSERT INTO " . DB_PREFIX . "product_discount SET 
        `product_id` = '" . $result['product_id'] . "', 
        `customer_group_id` = '15',
        `quantity` = '".$quantity."',
        `priority` = '".$priority."',
        `price` = '".$new_price."',
        `date_start` = '".$start_date."',
        `date_end` = '".$expire_date."'");
    }
}
}
}
?>
4

1 回答 1

0

通过查看您的代码，我唯一能想到的可能是初始 SQL 查询返回的数据集超出了 PHP 的内存限制。也许您可以尝试LIMIT 100在查询中添加或类似内容，看看问题是否仍然存在。您还可以寻找一种从数据库服务器获取表大小（以字节为单位）的方法，并查看它是否超过 128MB。

另一方面：在 PHP 中处理大量记录并不是性能方面的最佳方法，因为必须将整个数据从 SQL 服务器传输到 PHP 解释器进程，然后再传输回来。您发布的代码看起来像是您通常会使用特殊查询直接在数据库中实现的代码（甚至可能使用存储过程）。

本质上，您是在尝试根据另一个表中的数据插入大量记录。因此，您想对该表执行选择并将其用作插入的子表达式。看看：https ://dev.mysql.com/doc/refman/5.1/en/insert-select.html

我不认为自己是 SQL 专家，但为了让您了解这可能如何工作，仅针对部分字段：

INSERT INTO product_discount (product_id, customer_product_id, new_price) SELECT 
sub.product_id, 15, sub.new_price FROM (
    SELECT p.product_id, p.price*1.35 AS new_price FROM products
) AS sub;

注意：我省略了 new_price 计算的一部分，因为它需要另一个子 SELECT，并且我想保持可读性。但也可以使用纯 SQL。它不像命令式编程那样直观，但 SQL 提供了很多功能，并且条件表达式之类的东西也是可能的。

您应该能够制定一个完全在数据库中执行所需操作的查询。这样，就不需要在 DB 和 PHP 之间传输任何数据，这很可能会快得多，而且您不会耗尽内存。

于 2013-01-09T20:08:24.320 回答