我有一个表作为 ad_banner_queue，我用它来生成基于广告权重的队列。广告被插入到广告表中。如果队列中的所有现有广告都已转换给用户，则会生成队列。

现在的问题是，如果请求同时出现并且 Rand() 返回了相同的记录，我应该如何防止发送重复的广告？

代码如下:

<?php
/* To Get the random Ad */
public function getBanner($params) {
    /* Fetch the Random from table */
    $ads_queue = (new \yii\db\Query())
            ->select('ad_quque_id, banner_image, unique_code')
            ->from('ad_banner_queue')
            ->join('inner join', 'advertisement', 'ad_banner_queue.ad_id = advertisement.ad_id')
            ->where('is_sent=0')
            ->orderBy('RAND()')
            ->one();

    /* In case of queue is not there generate the new queue */
    if ($ads_queue === false) {
        $output = $this->generateAdQueue();
        //In case of something went wrong while generating the queue
        if ($output == false) {
            return array();
        }

        //Now fetch the record again
        $ads_queue = (new \yii\db\Query())
                ->select('ad_quque_id, banner_image, unique_code')
                ->from('ad_banner_queue')
                ->join('inner join', 'advertisement', 'ad_banner_queue.ad_id = advertisement.ad_id')
                ->where('is_sent=0')
                ->orderBy('RAND()')
                ->one();
    }

    /* Now, marked that one as is_sent */
    Yii::$app->db->createCommand()->update('ad_banner_queue', ['is_sent' => 1], 'ad_quque_id =:ad_quque_id', array(':ad_quque_id' => $ads_queue['ad_quque_id']))->execute();
    return $ads_queue;
}

/**
 * Below will Generate the Queue if not exist
 */
public function generateAdQueue() {
    /* First check thatt there is existing queue, if so don't generate it */
    $data_exist = (new \yii\db\Query())
            ->select('ad_quque_id')
            ->from('ad_banner_queue')
            ->where('is_sent=0')
            ->scalar();
    if ($data_exist === false) {
        /* Delete all other entries */
        (new \yii\db\Query())
                ->createCommand()
                ->delete('ad_banner_queue')
                ->execute();

        /* Fetch all banner */
        $ads = (new \yii\db\Query())
                ->select('ad_id, unique_code, ad_name, banner_image,ad_delivery_weightage')
                ->from('advertisement')
                ->where('status_id in (8)') //Means only fetch Approved ads
                ->all();
        if (!empty($ads)) {
            foreach ($ads as $ad) {
                /* Make entry as per that weightage, example, if weightage is 10 then make entry 10 times */
                $ins_fields = array();
                for ($i = 1; $i <= $ad['ad_delivery_weightage']; $i++) {
                    $ins_fields[] = array($ad['ad_id']);
                }
                Yii::$app->db->createCommand()->batchInsert('ad_banner_queue', ['ad_id'], $ins_fields)->execute();
            }
            return true;
        } else {
            return false;
        }
    } else {
        return false;
    }
}

最佳答案

我的意思是您的意思是执行同时请求的不同“人”不应该得到相同的随机行？为了避免在两个正在运行的请求中两次选择同一条记录的微小机会，最可靠的方法可能是锁定表并在事务中执行读取和更新，而无需对其进行测试。您必须使用支持此功能的存储引擎，例如 InnoDB。

实现方式LOCK TABLES和 UNLOCK TABLES对于事务表，例如 InnoDB 表，是用 SET autocommit = 0 开始事务, 不是 START TRANSACTION , 其次是 LOCK TABLES .那你不应该调用UNLOCK TABLES直到您明确提交交易。

例如，如果您需要一次读取和写入您的表，您可以这样做:

SET autocommit = 0;
LOCK TABLES ad_banner_queue AS ad_banner_queue_w WRITE, ad_banner_queue AS ad_banner_queue_r READ;
... perform your select query on ad_banner_queue_r, then update that row in ad_banner_queue_w with is_sent = 1...
COMMIT;
UNLOCK TABLES;

我们使用别名锁定的原因是您 cannot refer to a locked table multiple times in a single query using the same name .所以我们改用别名，并为表和每个别名获得一个单独的锁。

关于php - 防止从 MySQL 和 PHP 发送重复记录，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/52426582/