Запрос вложенных объектов из MongoDB (часть 2) - PullRequest
Новая
       280

Запрос вложенных объектов из MongoDB (часть 2)

3 голосов
/ 04 января 2012

С некоторой ранее помощью я создал сценарий C # в SSIS для извлечения данных из MongoDB в SQL Server. В то время как обычные документы можно легко найти, вложенные документы и массивы проблематичны.

Проблема 1 : у меня есть shipping_address.country, который возвращает результаты с помощью 

this.UserDBBuffer.SCountry = document["shipping_address"].AsBsonDocument["country"].ToString();

Однако, mlocation.address выдает ошибку «страна не найдена» с использованием того же кода: 

this.UserDBBuffer.Country = document["mlocation"].AsBsonDocument["country"].ToString();

Задача 2 : извлечение элементов из массивов. У меня есть массив, который выглядит как «устройства -> документ -> данные_устройства -> модель» или «устройства -> документ -> данные_устройства -> бренд». Как получить значения «модель» или «бренд» в моем коде?

Большое спасибо за вашу помощь. Ниже весь мой код: 

public override void CreateNewOutputRows()
{
    string connectionString = "mongodb://localhost";
    MongoServer myMongo = MongoServer.Create(connectionString);
    myMongo.Connect();
    var db = myMongo.GetDatabase("UserDB");

    //Declaring variables for Date Created conversions
    string DateCreatedString;
    DateTime DateCreatedDateUTC;
    DateTime DateCreatedDateLocal;

    var fields = Fields.Include("mlocation.country", "mlocation", "_id", "primary_email", "gender", "date_created");
    var collection = db.GetCollection<BsonDocument>("users");

    foreach (var document in collection.FindAll().SetFields(fields))
    {
        this.UserDBBuffer.AddRow();
        this.UserDBBuffer.ID = document["_id"] == null ? "" : document["_id"].ToString();
        this.UserDBBuffer.Country = document["mlocation"].AsBsonDocument["country"].ToString();
        this.UserDBBuffer.PrimaryEmail = document["primary_email"] == null ? "" : document["primary_email"].ToString();
        this.UserDBBuffer.Gender = document["gender"] == null ? "" : document["gender"].ToString();

        //Importing Date Created as String for data manipulation
        DateCreatedString = document["date_created"] == null ? "" : document["date_created"].ToString();
        //First, making sure that we have a UTC datetime
        DateCreatedDateUTC = DateTime.Parse(DateCreatedString).ToUniversalTime();

        //Second, converting to Local Time
        DateCreatedDateLocal = DateTime.Parse(DateCreatedString).ToLocalTime();

        //Finally, assigning variables to rows
        this.UserDBBuffer.DateTimeCreatedUTC = DateCreatedDateUTC;
        this.UserDBBuffer.DateTimeCreatedLocal = DateCreatedDateLocal;
    }

    myMongo.Disconnect();
}

Для Задачи 2, Я нашел Java Script, который кто-то использовал; если я смогу преобразовать его в C #, это может сильно помочь: 

count = 0;

function user_list(){
    var cursor = db.users.find()

    //var cursor = db.users.find({"devices": {"$ne":[]}})
    cursor.forEach(function(user) {
        var deviceInfo = "";
        if (user.devices){
            if (user.devices[0]){
                dd = user.devices[0].device_data; 
                if (dd) {
                    deviceInfo = dd.model + "," + dd.brand  + "," + dd.model + "," + dd.device + "," + dd.pixel_height + "," + dd.pixel_width + "," + dd.pixel_format;
                }
            }
        }
        var location = "";
        if (user.mlocation) location = user.mlocation.country;
        print(user._id + "," + location + "," + user.primary_email + "," + user.date_created + "," + deviceInfo);
        count++;
    });
}
user_list();
print(count);

Ответы [ 4 ]

1 голос
/ 05 января 2012

В случае проблемы 1 вы уверены, что во всех документах содержится поле mlocation, являющееся документом, содержащим поле страны. Мне удалось воспроизвести «Страна элемента не найдена» с документом, в котором отсутствует значение. например с

db.users.find () {"_id": ObjectId ("4f04c56a0f8fa4413bed1078"), "primary_email": "email@email.com", "shipping_address": [{"country": "USA", "city": "Сан-Франциско"}, {" country ":" IN "," city ":" Chennai "}]," mlocation ": {" country ":" Canada "," city ":" Montreal "}} {"_id": ObjectId ("4f04d1605ab5a3805aaa8666"), "primary_email": "invalid@email.com", "shipping_address": [{"country": "MX", "city": "Cabo San Lucas"}], "mlocation": {"city": "Montreal"}} 2-й документ вызывает исключение. Вы можете либо проверить его наличие, либо использовать значение по умолчанию document ["mlocation"]. AsBsonDocument.GetValue ("страна", ноль)

Для задачи 2 вы не можете использовать BsonArray как документ. Так, например, чтобы получить shipping_address.country, вы можете сделать что-то вроде 

foreach (var addr in document["shipping_address"].AsBsonArray)
{
    var country = addr.AsBsonDocument["country"].AsString;
}
0 голосов
/ 06 января 2012

Вместо: 

var mlocation = document["mlocation"].AsBsonDocument;
var country = "";
if (mlocation != null && mlocation.Contains("country"))
{
    country = mlocation.AsBsonDocument.GetValue("country").ToString();
}

Я бы написал: 

var mlocation = document["mlocation"].AsBsonDocument;
var country = "";
if (mlocation.Contains("country"))
{
    country = mlocation["country"].AsString;
}

И вместо: 

var devices = document["devices"].AsBsonArray;
if (devices.ToList().Count > 0)
{
    if (devices[0].AsBsonDocument != null)
    {
        var deviceinfo = devices[0].AsBsonDocument;
        if (deviceinfo["device_data"].AsBsonDocument != null)
        {
            var deviceData = deviceinfo["device_data"].AsBsonDocument;
            model = deviceData.GetValue("model", null).AsString;
        }
    }
}

Я бы написал: 

var devices = document["devices"].AsBsonArray;
if (devices.Count > 0)
{
    var deviceinfo = devices[0].AsBsonDocument;
    if (deviceinfo.Contains("device_data"))
    {
        var deviceData = deviceinfo["device_data"].AsBsonDocument;
        var model = deviceData.GetValue("model", "").AsString; // "" instead of null
    }
}
0 голосов
/ 05 января 2012

Чтобы уточнить ваш комментарий к ответу Роберта, вы можете использовать BsonDocument.Contains, чтобы проверить, содержит ли данный BsonDocument поле с указанным именем, прежде чем получить его значение (http://api.mongodb.org/csharp/current/html/6181f23f-f6ce-fc7d-25a7-fc682ffd3c04.htm)

0 голосов
/ 05 января 2012

Предполагая, что элемент devices - это массив, просто углубитесь в искомый элемент, например: 

BsonDocument document; // assume this comes from somewhere
var devices = document["devices"].AsBsonArray;
var device = devices[0].AsBsonDocument; // first element of array
var deviceData = device["device_data"].AsBsonDocument;
var model = deviceData["model"].AsString;
var brand = deviceData["brand"].AsString;

Для ясности я разбил его на шаги, но вы можете объединить некоторые из этих шагов в более длинные выражения, если хотите.

...