Mongoose Schema：使数组中的对象具有文档的唯一字段

Question

我不是试图创建一个唯一的数组元素，而是确保如果我有一个 pairs 数组（它们是对象），code 的值都不同。

这是我的架构定义：

const redirectSchema = new mongoose.Schema({
    username: {
        type: String,
        required: true,
    },
    name: {
        type: String,
        required: true,
        unique: true
    },
    default_link: {
        type: String,
        required: true,
    },
    pairs: [
        {
            code: { // I want this field specifically to be unique within the document only
                type: String,
                required: true
            },
            site: {
                type: String,
                required: true
            }

        }
    ],
    date: {
        type: Date,
        required: true,
        default: Date.now
    }
})

例如，像这样插入pair 就可以了。

{
    code: "US",
    site: "google.com"
}

但是不管site如何，在此文档中插入另一个具有相同code的pair是不行的。

{
    code: "US", // Should not work, since the code "US" already exists within the array of pairs
    site: "amazon.com"
}

我正在尝试使用Redirect.findOne() 和Redirect.updateOne() 执行此操作，但是我遇到了编译器错误，或者只有在已经存在重复项后才会执行检查。

这是我目前的路线（允许重复 codes）：

// Add pair to given redirect
router.post('/:name/insert_pair', verifyToken, async (request, response) => {
    const token = request.header("auth-token")
    const usernameFromToken = jwt.decode(token).username

    const { code, site } = request.body

    // Remember: you may edit only your own content
    try {
        const edited = await Redirect.findOneAndUpdate(
            {
                username: usernameFromToken,
                name: request.params.name
            },
            {
                $push: {
                    pairs: { code, site }
                }
            }
        )

        const specific = await Redirect.findOne(
            {
                username: usernameFromToken,
                name: request.params.name
            })

        response.send(specific)
    } catch (error) {
        response.status(400).json(error)
    }

Answer 1

我的代码中的问题在于我使用 forEach 查找遍历文档数组中的 pair 对象。

由于我在POST 路由中使用了async 函数，因此我进行了一些搜索，发现forEach 在async 函数中不能很好地发挥作用。 我切换了使用 oldschool for (let i = 0; 循环，现在可以正常工作了！

这是我的代码。

1. 获取文档并检查pairs数组

2. 如果pairs 包含具有请求代码的对象，则返回错误消息。

3. 如果没有，请将pair 对象添加到文档中。

// Add pair to given redirect
router.post('/:name/insert_pair', verifyToken, async (request, response) => {
    const token = request.header("auth-token")
    const usernameFromToken = jwt.decode(token).username

    const { code, site } = request.body

    // Remember: you may edit only your own content
    try {
        // Get the object as plain JSON and check if it contains the code
        const check = await Redirect.findOne(
            {
                username: usernameFromToken,
                name: request.params.name
            }
        ).lean()

        // SOLUTION: DON'T USE FOREACH WITHIN ASYNC!
        for (let i = 0; i < check.pairs.length; i++) {
            if (check.pairs[i].code === code) {
                return response.status(400).json({
                    message: `${request.params.name} already contains an entry for ${code}`
                })
            }
        }

        // TODO BUG: ONLY WORKS AFTER 1 DUPLICATE HAS ALREADY BEEN MADE.
        // await check.pairs.forEach((pair) => {
        //     if (pair.code === code) {
        //         return response.status(400).json({
        //             message: `${request.params.name} already contains an entry for ${code}`
        //         })
        //     }
        // })

        // Make the edit
        await Redirect.findOneAndUpdate(
            {
                username: usernameFromToken,
                name: request.params.name
            },
            {
                $push: {
                    pairs: { code, site }
                }
            }
        )

        // Get it to display it on screen
        const display = await Redirect.findOne(
            {
                username: usernameFromToken,
                name: request.params.name
            })

        response.json(display)
    } catch (error) {
        response.status(400).json(error)
    }
})