MongoDB中如何基于字符串类型经纬度搜索最近地点

问题背景 #

MongoDB集合中误将latitude和longitude以字符串类型存储，现有代码基于带2dsphere索引的Point类型location字段设计，且使用$geoNear聚合查询（仅支持数值型坐标），导致无法正常执行最近地点搜索。

误存的数据格式 #

{
    _id: new ObjectId("6501e33954b107bda89701f5"),
    name: 'M/s Mango Eco Management Pvt. Ltd.',
    address: '348, Folk Industrial Area, Delhi - 002200',
    phone: '+91 1231231231',
    capacity: '1.5 Tonne / Day',
    contact_person: 'Mr. Suman Kumar',
    latitude: '28.538132819961014', 
    longitude: '76.09083529557478'
}

理想的Mongoose Schema #

const nearestSchema = new mongoose.Schema({
    name: String,
    address: String,
    phone: String,
    capacity: String,
    contact_person: String,
    location: {
        type: {
            type: String,
            enum: ['Point'],
            required: true,
        },
        coordinates: {
            type: [Number], 
            index: '2dsphere', 
        },
    },
});
const NearestFacility = mongoose.model('nearests', nearestSchema);

现有无法工作的API代码 #

app.get('/locations', async (req, res) => {
    if (!req.query.latitude || !req.query.longitude) {
        res.status(400).json({ error: 'Missing latitude and longitude parameters' });
        return;
    }

    try {
        const latitude = parseFloat(req.query.latitude);
        const longitude = parseFloat(req.query.longitude);

        const nearestFacility = await NearestFacility.aggregate([
            {
                $geoNear: {
                    near: {
                        type: 'Point',
                        coordinates: [longitude, latitude], 
                    },
                    distanceField: 'distance',
                    spherical: true,
                },
            },
            {
                $match: {
                    distance: { $lte: 10000 } 
                }
            },
            { $limit: 1 },
        ]);

        console.log('Query Coordinates:', longitude, latitude);
        console.log('Nearest Facility:', nearestFacility);

        if (nearestFacility.length > 0) {
            res.json(nearestFacility[0]);
        } else {
            res.status(404).json({ error: 'No e-waste facility found near this location' });
        }
    } catch (error) {
        console.error(error);
        res.status(500).json({ error: 'An error occurred while searching for the nearest facility' });
    }
});

解决方案 #

方案1：修改聚合查询适配字符串坐标 #

直接在聚合管道中转换字符串为数值，构造临时地理字段后执行近邻查询，无需修改原有数据：

app.get('/locations', async (req, res) => {
    if (!req.query.latitude || !req.query.longitude) {
        res.status(400).json({ error: 'Missing latitude and longitude parameters' });
        return;
    }

    try {
        const latitude = parseFloat(req.query.latitude);
        const longitude = parseFloat(req.query.longitude);

        const nearestFacility = await NearestFacility.aggregate([
            // 将字符串经纬度转为数值，构造符合Point类型的临时location字段
            {
                $addFields: {
                    location: {
                        type: "Point",
                        coordinates: [
                            { $toDouble: "$longitude" },
                            { $toDouble: "$latitude" }
                        ]
                    }
                }
            },
            // 使用$nearSphere执行球面近邻查询，限制最大距离10000米
            {
                $match: {
                    location: {
                        $nearSphere: {
                            $geometry: {
                                type: "Point",
                                coordinates: [longitude, latitude]
                            },
                            $maxDistance: 10000
                        }
                    }
                }
            },
            // 可选：计算精确距离值（单位米）
            {
                $addFields: {
                    distance: {
                        $geoDistance: {
                            near: { type: "Point", coordinates: [longitude, latitude] },
                            spherical: true
                        }
                    }
                }
            },
            { $limit: 1 }
        ]);

        console.log('Query Coordinates:', longitude, latitude);
        console.log('Nearest Facility:', nearestFacility);

        if (nearestFacility.length > 0) {
            res.json(nearestFacility[0]);
        } else {
            res.status(404).json({ error: 'No e-waste facility found near this location' });
        }
    } catch (error) {
        console.error(error);
        res.status(500).json({ error: 'An error occurred while searching for the nearest facility' });
    }
});

关键修改说明：

• 使用$toDouble操作符将字符串类型的latitude和longitude转换为数值类型，满足地理查询的类型要求。
• 构造临时的location字段（符合Point类型规范），用于后续地理查询。
• 替换$geoNear为$nearSphere：$geoNear依赖集合上已存在的2dsphere索引，但当前实际数据无location字段导致索引失效；$nearSphere可直接基于临时字段执行球面距离查询，且默认按距离由近到远排序。

方案2：批量修正数据（推荐） #

一次性将集合中所有字符串类型的经纬度转换为数值并写入location字段，后续可直接使用原有API代码：

// 执行批量修正脚本（可在MongoDB Shell或Node.js脚本中运行）
await NearestFacility.updateMany(
    {}, // 匹配所有文档
    [
        {
            $set: {
                location: {
                    type: "Point",
                    coordinates: [
                        { $toDouble: "$longitude" },
                        { $toDouble: "$latitude" }
                    ]
                }
            }
        }
    ]
);

优势：

• 修正后数据完全匹配理想Schema，后续查询无需额外转换，性能更优。
• 原有$geoNear聚合查询可直接正常工作，无需修改API代码。

内容的提问来源于stack exchange，提问作者Abhishek