oxcounter.php

Go to the documentation of this file.

<?php

class oxCounter
{

    public function getNext($sIdent)
    {
        $oDb = oxDb::getDb();
        $oDb->startTransaction();

        $sQ = "SELECT `oxcount` FROM `oxcounters` WHERE `oxident` = " . $oDb->quote($sIdent) . " FOR UPDATE";

        if (($iCnt = $oDb->getOne($sQ, false, false)) === false) {
            $sQ = "INSERT INTO `oxcounters` (`oxident`, `oxcount`) VALUES (?, '0')";
            $oDb->execute($sQ, array($sIdent));
        }

        $iCnt = ((int) $iCnt) + 1;
        $sQ = "UPDATE `oxcounters` SET `oxcount` = ? WHERE `oxident` = ?";
        $oDb->execute($sQ, array($iCnt, $sIdent));

        $oDb->commitTransaction();

        return $iCnt;
    }

    public function update($sIdent, $iCount)
    {
        $oDb = oxDb::getDb();
        $oDb->startTransaction();

        $sQ = "SELECT `oxcount` FROM `oxcounters` WHERE `oxident` = " . $oDb->quote($sIdent) . " FOR UPDATE";

        if (($iCnt = $oDb->getOne($sQ, false, false)) === false) {
            $sQ = "INSERT INTO `oxcounters` (`oxident`, `oxcount`) VALUES (?, ?)";
            $blResult = $oDb->execute($sQ, array($sIdent, $iCount));
        } else {
            $sQ = "UPDATE `oxcounters` SET `oxcount` = ? WHERE `oxident` = ? AND `oxcount` < ?";
            $blResult = $oDb->execute($sQ, array($iCount, $sIdent, $iCount));
        }

        $oDb->commitTransaction();

        return $blResult;
    }
}