Как объединить две коллекции в Firebase, используя expressjs? - PullRequest
0 голосов
/ 04 октября 2018

Я пишу Rest API с использованием JS-экспресс-узла с базой данных Firebase.В Firebase у меня есть две коллекции, например:

    Bin (binName, binLocaton, hardwareId)

    BinsInformation (date, payloadFields { hardwareId, levle })

Как я могу объединить эти две коллекции на основе поля hardwareId?

I would like to join to collections like two tables in MySQL. 

Ex. "SELECT * FROM table1 LEFT JOIN table2 ON table1.id = table2.id "
 Like the above MySQL query i would like join my two collections "Bin" and "BinInformation".

Если я присоединюсь к одному документу с определенным идентификаторомэто дает правильный вывод.но когда я пытаюсь объединить все документы в двух коллекциях с отдельным запросом, это дает «асинхронную ошибку».

вот мои коллекции:

Бины:

[
    {
        AreaID: "ZYwQHIrZPEDd359e6WRf"
        Capacity: "123"
        Latitude: "17.658745"
        LocationName: "testing"
        Longitude: "78.9874545"
        hardwareid: "4321"
    },
    {
        AreaID: "ZYwQHIrZPEDd359e6WRf"
        Capacity: "123"
        Latitude: "17.658745"
        LocationName: "testing"
        Longitude: "78.9874545"
        hardwareid: "5432"
    }
]

Информация о бинах:

[
    {
        date: September 24, 2018 at 12:00:00 AM UTC+5:30,
        payload_fields: { 
            hardwareid: "4321"
            level : 60
        }
    },
    {
        date: September 24, 2018 at 12:00:00 AM UTC+5:30,
        payload_fields: { 
            hardwareid: "5432"
            level : 23
        }
    }
]

Здесь мне нужно получить все бины с соответствующей информацией о бинах.мой код выглядит следующим образом

app.get('/twoColectionJoin', asyncHandler( async (req, res, next) => {

    console.log('await');
    try {

        let allDocs = [];

        const snapshot = await db.collection('Bins').get();

        let i = 0;
         snapshot.forEach( async (doc) => {
            let dummyDoc = doc.data();
            const details = await getBinDet(dummyDoc.hardwareid);
            dummyDoc.id = doc.id;  
            dummyDoc.det = details;              
            allDocs.push(dummyDoc);
            i++;
            console.log(allDocs);
        });

            res.status(200).send(allDocs);


    }
    catch(e){

        next(e);
    }
}) );


async function getBinDet(hardwareid){
    let dummyDoc = {};
    return new Promise(function(resolve, reject){

        try{

            setTimeout(function(){ 
             db.collection('BinsInformation')
             .where('payload_fields.hardwareid', '==', hardwareid)
             .limit(1).get()
                .then(snap => {                 
                    snap.forEach(element => {

                        //return element.data();
                        dummyDoc = element.data();

                    });   

                    resolve(dummyDoc);
                })
                .catch(err2 => {

                        reject(err2);
                });
            }, 300);

        }catch(err){

            console.log(err);
        }
    });
}

Ожидаемый вывод:

[
    {
        AreaID: "ZYwQHIrZPEDd359e6WRf"
        Capacity: "123"
        Latitude: "17.658745"
        LocationName: "testing"
        Longitude: "78.9874545"
        hardwareid: "4321",
        det: {
            date: September 24, 2018 at 12:00:00 AM UTC+5:30,
            payload_fields : { 
                hardwareid: "4321"
                level : 60
            }
        }
    },
    {
        AreaID: "ZYwQHIrZPEDd359e6WRf"
        Capacity: "123"
        Latitude: "17.658745"
        LocationName: "testing"
        Longitude: "78.9874545"
        hardwareid: "5432",
        det: {
            date: September 24, 2018 at 12:00:00 AM UTC+5:30,
            payload_fields: { 
                hardwareid: "5432"
                level : 23
            }
        }
    }
] 

Но в результате получается: []

1 Ответ

0 голосов
/ 04 октября 2018

Преобразование SQL-запросов в Firebase-запрос не 1: 1.И если вы пытаетесь выполнить типичные SQL-запросы на Firebase, то Firebase - это не та база данных (NoSQL), которая вам не подходит.

Используя структуру данных, которую вы разместили выше, полный пример будет выглядеть так:

const express = require("express");
const admin = require("firebase-admin");
const serviceAccount = require("./serviceAccountKey.json");

const app = express();

admin.initializeApp({
  credential: admin.credential.cert(serviceAccount),
  databaseURL: "https://example.firebaseio.com"
});

const db = admin.firestore();

async function joinsCollectionsHandler(req, res) {
  const binsRef = await db.collection("bins").get();
  const binData = binsRef.docs.map(doc => doc.data());

  const binsInfoRef = await db.collection("bin-information").get();
  const binInfoData = binsInfoRef.docs.map(doc => doc.data());

  const data = binData.map(bin => {
    const { hardwareId } = bin;
    const det = binInfoData.filter(
      doc => doc.payloadFields.hardwareId === hardwareId
    );
    return { ...bin, det };
  });
  res.json(data);
}

app.get("/twoColectionJoin", joinsCollectionsHandler);

app.listen(3000, () => console.log("Started on 3000"));

Конечный результат:

[
    {
        "latitude": "17.658745",
        "locationName": "testing",
        "longitude": "78.9874545",
        "areaId": "ZYwQHIrZPEDd359e6WRf",
        "hardwareId": "5432",
        "capacity": "123",
        "det": [
            {
                "date": "2018-09-23T18:30:00.000Z",
                "payloadFields": {
                    "level": 23,
                    "hardwareId": "5432"
                }
            }
        ]
    },
    {
        "capacity": "123",
        "areaId": "ZYwQHIrZPEDd359e6WRf",
        "latitude": "17.658745",
        "hardwareId": "4321",
        "locationName": "testing",
        "det": [
            {
                "date": "2018-09-23T18:30:00.000Z",
                "payloadFields": {
                    "level": 60,
                    "hardwareId": "4321"
                }
            }
        ]
    }
]

Я протестировал это локально и работает нормально.Дайте мне знать, если у вас есть какие-либо вопросы.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...