E sad, blago meni ispisao sam ja lepo tridesetak linija koda, ali imam problem kako da održim integritet podataka. Sve radi super sada (dok sam ja jedan korisnik), ali šta se dešava kada nas ima 100, kada nestane struja, zabaguje server ili bilo šta slično... Da li nekako mogu da zaključam tabele tako da samo određeni proces može da upisuje podatke u tom trenutku, a ostali da čekaju...
Evo i koda:
Evo i koda:
Code:
$sqli = "SELECT * FROM `cart_isporuka` WHERE ((dok='".$dok."') AND (proknjizeno=0));";
$qi = mysqli_query($link, $sqli);
while($ri=mysqli_fetch_assoc($qi))
{
$sql = "SELECT kolicina FROM lager WHERE ((did='".$ri["did"]."') AND (mid='".$ri["mid"]."'))";
$q = mysqli_query($link, $sql);
$rez = mysqli_num_rows($q);
if($rez == 0)
{
$trenutna_kolicina = 0 - $ri["kolicina"];
$sql_i = "INSERT INTO lager (did, mid, kolicina)
VALUES
( '".$ri["did"]."',
'".$ri["mid"]."',
'".$trenutna_kolicina."')";
}
else while($r=mysqli_fetch_assoc($q))
{
$trenutna_kolicina = $r["kolicina"] - $ri["kolicina"];
$sql_i = "UPDATE lager
SET `kolicina` = '".$trenutna_kolicina."'
WHERE ((`did` = '".$ri["did"]."')
AND (mid = '".$ri["mid"]."'));";
}
$q_i = mysqli_query($link, $sql_i);
$sql_i = "UPDATE cart_isporuka
SET `proknjizeno` = '1'
WHERE (`id` = '".$ri["id"]."');";
$q_i = mysqli_query($link, $sql_i);
}
$sql_i = "UPDATE cart_docs
SET `status` = '5', `obradio` = '".$_SESSION['SESS_MEMBER_ID']."'
WHERE (`dok` = '".$dok."');";
$q_i = mysqli_query($link, $sql_i);
$sqli = "SELECT * FROM `cart_isporuka` WHERE ((dok='".$dok."') AND (proknjizeno=0));";
$qi = mysqli_query($link, $sqli);
while($ri=mysqli_fetch_assoc($qi))
{
$sql = "SELECT kolicina FROM lager WHERE ((did='".$ri["did"]."') AND (mid='".$ri["mid"]."'))";
$q = mysqli_query($link, $sql);
$rez = mysqli_num_rows($q);
if($rez == 0)
{
$trenutna_kolicina = 0 - $ri["kolicina"];
$sql_i = "INSERT INTO lager (did, mid, kolicina)
VALUES
( '".$ri["did"]."',
'".$ri["mid"]."',
'".$trenutna_kolicina."')";
}
else while($r=mysqli_fetch_assoc($q))
{
$trenutna_kolicina = $r["kolicina"] - $ri["kolicina"];
$sql_i = "UPDATE lager
SET `kolicina` = '".$trenutna_kolicina."'
WHERE ((`did` = '".$ri["did"]."')
AND (mid = '".$ri["mid"]."'));";
}
$q_i = mysqli_query($link, $sql_i);
$sql_i = "UPDATE cart_isporuka
SET `proknjizeno` = '1'
WHERE (`id` = '".$ri["id"]."');";
$q_i = mysqli_query($link, $sql_i);
}
$sql_i = "UPDATE cart_docs
SET `status` = '5', `obradio` = '".$_SESSION['SESS_MEMBER_ID']."'
WHERE (`dok` = '".$dok."');";
$q_i = mysqli_query($link, $sql_i);