[C#] MongoDB の bson データを読んでみた

hokatsuhokatsusan

6年前

C# を使用して MongoDB の bson を読み込んでみた。
MongoDB の操作用 DLL をプロジェクトに取り込み、bson ファイルを読み込むことになる。
ハマったのが、必要なデータのみを読もうとするとエラーになるとうところ。不要なデータを Read した上で捨てる処理が必要。DoAwayReadValue() のような処理が必要とだった。

using MongoDB.Bson;
using MongoDB.Bson.IO;

// ※本クラスは、正式版から抜粋した内容であるため、このままでは動作しません。
class Test {

    private void AnalyzeSystemBson(ZipEntry entry)
    {
        entry.Extract(extractedDirectory);
        string extractedFilePath = Path.Combine(extractedDirectory, entry.FileName);
        using (Stream stream = File.OpenRead(extractedFilePath))
        {
            using (var reader = new BsonBinaryReader(stream))
            {
                while (!reader.IsAtEndOfFile())
                {
                    string email = null;
                    int type = -1;
                    reader.ReadStartDocument();
                    while (reader.ReadBsonType() != BsonType.EndOfDocument)
                    {
                        string fieldName = reader.ReadName();
                        if (fieldName.Equals("email"))
                        {
                            email = reader.ReadString();
                        }
                        else if (fieldName.Equals("type"))
                        {
                            type = reader.ReadInt32();
                        }
                        else
                        {
                            DoAwayReadValue(reader);
                        }
                    }
                  //modelDictionary[email] = type;
                    reader.ReadEndDocument();
                }
            }
        }
    }

    private static void DoAwayReadValue(BsonBinaryReader reader)
    {
        switch (reader.GetCurrentBsonType())
        {
            case BsonType.ObjectId:
                reader.ReadObjectId();
                break;
            case BsonType.String:
                reader.ReadString();
                break;
            case BsonType.Int32:
                reader.ReadInt32();
                break;
        }
    }
}

using MongoDB.Bson;

using MongoDB.Bson.IO;

// ※本クラスは、正式版から抜粋した内容であるため、このままでは動作しません。

class Test {

private void AnalyzeSystemBson(ZipEntry entry)

{

entry.Extract(extractedDirectory);

string extractedFilePath = Path.Combine(extractedDirectory, entry.FileName);

using (Stream stream = File.OpenRead(extractedFilePath))

{

using (var reader = new BsonBinaryReader(stream))

{

while (!reader.IsAtEndOfFile())

{

string email = null;

int type = -1;

reader.ReadStartDocument();

while (reader.ReadBsonType() != BsonType.EndOfDocument)

{

string fieldName = reader.ReadName();

if (fieldName.Equals("email"))

{

email = reader.ReadString();

}

else if (fieldName.Equals("type"))

{

type = reader.ReadInt32();

}

else

{

DoAwayReadValue(reader);

}

//modelDictionary[email] = type;

reader.ReadEndDocument();

}

private static void DoAwayReadValue(BsonBinaryReader reader)

{

switch (reader.GetCurrentBsonType())

{

case BsonType.ObjectId:

reader.ReadObjectId();

break;

case BsonType.String:

reader.ReadString();

break;

case BsonType.Int32:

reader.ReadInt32();

break;

}