connect_error) {
die("Connection failed: " . $conn->connect_error);
}
$x = 11;
$e = $x + 10;
while($x <= $e) {
echo "Starting : ".$x;
$lowerLimit = $x * 500;
$sql = "SELECT id, lnd_kde, prd_kde , totale_liters,rk,datum FROM mapper_data WHERE processed = 0 LIMIT ".$lowerLimit;
$result = $conn->query($sql);
if ($result->num_rows > 0) {
// output data of each row
while($row = $result->fetch_assoc()) {
$new_totale_liters = $row['totale_liters'];
//echo date('m', strtotime($row['datum']));
if($row['rk'] == 'R')
{
$new_totale_liters = $row['totale_liters'] * -1;
}
$sql_land = "SELECT group_name_afrikaans , group_name FROM country_groups WHERE kde = '".$row['lnd_kde']."'";
$result_land = $conn->query($sql_land);
$sql_product = "SELECT beskrywing_vir_verslag,description_for_reports,white_or_red,type FROM produk_kodes WHERE kd = '".$row['prd_kde']."'";
$result_product = $conn->query($sql_product);
$rl = mysqli_fetch_assoc($result_land);
$rp = mysqli_fetch_assoc($result_product);
$rl_group_name = "";
if(isset($rl['group_name_afrikaans']))
{
$rl_group_name = $rl['group_name_afrikaans'];
}
$rp_beskrywing_vir_verslag = "";
if(isset($rp['beskrywing_vir_verslag']))
{
$rp_beskrywing_vir_verslag = $rp['beskrywing_vir_verslag'];
}
$rp_description_for_reports = "";
if(isset($rp['description_for_reports']))
{
$rp_description_for_reports = $rp['description_for_reports'];
}
$sql = "UPDATE mapper_data
SET group_name='".$rl['group_name']."',
group_name_afrikaans='".$rl_group_name."',
beskrywing_vir_verslag='". $rp_beskrywing_vir_verslag."',
description_for_reports='".$rp_description_for_reports."',
white_or_red='".$rp['white_or_red']."', type='".$rp['type']."',
totale_liters= '".$new_totale_liters."',
year = ".date('Y', strtotime($row['datum'])).",
month = ".date('m', strtotime($row['datum'])).",
datumtyd = '".date("Y-m-d H:i:s", strtotime($row['datum']))."',
processed = 1
WHERE id=".$row['id'];
//echo $sql; exit;
if ($conn->query($sql) === TRUE) {
echo "\nUR:".$row['id'] . "
";
//echo "\nUR:".$row['id'] . "|RK:".$row['rk']." |QE:".$sql."
";
} else {
echo "Error updating record: " . $conn->error." |QE:".$sql."
";
}
}
} else {
echo "0 results :".$x;
exit;
}
$x++;
}
$conn->close();
?>