public static class Program
|
{
|
public static void Main(string[] args)
|
{
|
var client = new MongoClient("mongodb://localhost");
|
client.DropDatabase("test");
|
|
var database = client.GetDatabase("test");
|
var bucket = new GridFSBucket(database);
|
|
var content = "Hello World";
|
var source = Encoding.UTF8.GetBytes(content);
|
var metadata = new BsonDocument
|
{
|
{ "ContainerId", 123 }
|
};
|
var options = new GridFSUploadOptions { Metadata = metadata };
|
bucket.UploadFromBytes("HelloWorld", source, options);
|
|
var fileInfo = TestAsync(bucket).GetAwaiter().GetResult();
|
}
|
|
private static async Task<GridFSFileInfo> TestAsync(IGridFSBucket bucket)
|
{
|
var filter = Builders<GridFSFileInfo>.Filter.Eq(x => x.Metadata["ContainerId"], 123);
|
var cursor = await bucket.FindAsync(filter);
|
var fileInfos = await cursor.ToListAsync();
|
return fileInfos.FirstOrDefault();
|
}
|
}
|