如何在CodeIgniter中防止并发注册导致重复邮箱（不依赖数据库唯一键）

<?php
defined('BASEPATH') OR exit('No direct script access allowed');

class UserModel extends CI_Model {

    public function __construct() {
        parent::__construct();
        $this->load->database();
    }

    /**
     * 注册新用户，通过表级写锁避免并发重复邮箱
     *
     * @param array $userData 包含用户信息的数组，至少包含 'email' 和 'password'
     * @return array 包含注册结果和消息
     */
    public function registerUserWithLock($userData) {
        if (!isset($userData['email']) || !isset($userData['password'])) {
            return ['status' => 'error', 'message' => '缺少必要的注册信息。'];
        }

        $email = $userData['email'];

        // 1. 获取表级写锁
        // 注意：LOCK TABLES 是 MySQL 语法，其他数据库可能有不同的锁定机制。
        // 这会阻塞所有对 'users' 表的读写操作，直到 UNLOCK TABLES。
        $this->db->query("LOCK TABLES users WRITE");

        try {
            // 2. 在持有锁的情况下，执行邮箱存在性检查
            $this->db->where('email', $email);
            $query = $this->db->get('users');

            if ($query->num_rows() > 0) {
                // 邮箱已存在，释放锁并返回错误
                return ['status' => 'error', 'message' => '该邮箱已被注册。'];
            }

            // 3. 邮箱不存在，进行数据插入
            $userData['created_at'] = date('Y-m-d H:i:s');
            $this->db->insert('users', $userData);

            if ($this->db->affected_rows() > 0) {
                return ['status' => 'success', 'message' => '用户注册成功！'];
            } else {
                return ['status' => 'error', 'message' => '用户注册失败，请重试。'];
            }

        } catch (Exception $e) {
            // 捕获异常，确保在出错时也能释放锁
            log_message('error', '注册用户时发生错误: ' . $e->getMessage());
            return ['status' => 'error', 'message' => '注册过程中发生系统错误。'];
        } finally {
            // 4. 无论成功失败，最终都要释放锁
            $this->db->query("UNLOCK TABLES");
        }
    }
}

<?php
defined('BASEPATH') OR exit('No direct script access allowed');

class Auth extends CI_Controller {

    public function __construct() {
        parent::__construct();
        $this->load->model('UserModel');
        $this->load->library('form_validation');
    }

    public function register() {
        // 假设这里已经完成了基本的输入验证，如非空、格式等
        $this->form_validation->set_rules('email', '邮箱', 'required|valid_email');
        $this->form_validation->set_rules('password', '密码', 'required|min_length[6]');

        if ($this->form_validation->run() == FALSE) {
            // 验证失败，显示错误
            $this->load->view('register_form'); // 假设有一个注册表单视图
        } else {
            $userData = [
                'email' => $this->input->post('email'),
                'password' => password_hash($this->input->post('password'), PASSWORD_DEFAULT), // 密码哈希处理
                // 其他用户数据...
            ];

            $result = $this->UserModel->registerUserWithLock($userData);

            if ($result['status'] === 'success') {
                // 注册成功，重定向或显示成功消息
                redirect('auth/registration_success');
            } else {
                // 注册失败，显示错误消息
                $data['error_message'] = $result['message'];
                $this->load->view('register_form', $data);
            }
        }
    }

    public function registration_success() {
        echo "注册成功！";
    }
}