我有一个php函数用于更新/添加批量产品的折扣价格。
在我添加了额外的$new_price条件&sku
的Substr检查我在select语句中添加了psku。现在它给了我一个空白的屏幕，当我试图执行它时，查询没有运行。
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."'");
}
}
}
}
?>
查看您的代码，我能想到的唯一一件事可能是初始SQL查询返回的数据集超出了PHP的内存限制。也许您可以尝试添加LIMIT 100或类似的查询，看看问题是否仍然存在。您还可以寻找一种方法，从DB服务器获取表的大小(以字节为单位)，并查看它是否超过128MB。
另一个注意事项:在PHP中处理大量记录并不是性能方面的最佳方法，因为整个数据必须从SQL服务器传输到PHP解释器进程，然后再传输回来。您发布的代码看起来像您通常会在数据库中使用特殊查询(甚至可能使用存储过程)直接实现的代码。
实际上，您正在尝试根据另一个表的数据插入大量记录。因此，您希望对该表执行select，并将其用作insert的子表达式。看看: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之间传输任何数据，这样很可能会快得多，而且不会耗尽内存。