Execute($sqlCnt); if ($rs && !$rs->EOF) { $row = $rs->fetchRow(); if (!'0' == $row['cnt']) { die('`abc_forecast` not empty, try truncating first.'); } } else { die('DB Error'); } $sql = <<Execute($sql); if ($rs && !$rs->EOF) { $priceData = $rs->getAssoc(); } else { die('DB Error'); } foreach($priceData as $key => $value) { $price[$key] = (float)$value; } $sql = <<Execute($sql); if ($rs && !$rs->EOF) { $baseData = $rs->getArray(); } else { die('DB Error'); } $sql = <<Execute($sql, array($fDate, $row['channel_id'], $row['item_id'], $row['region_id'], $fQty, $fRev)); } $rs = $conn->Execute($sqlCnt); if ($rs && !$rs->EOF) { $row = $rs->fetchRow(); print $row['cnt'] . ' records inserted into `abc_forecast`.'; } ?>