学习asp.net core集成MongoDB的完整步骤（asp.net core

//扩展方法public static class ServiceCollectionExtensions

zvvq

{ 内容来自zvvq，别采集哟

public static void AddMongoDB(this IServiceCollection services, IConfiguration configuration) 本文来自zvvq

{ zvvq好，好zvvq

services.Configure<Settings>(options =>

内容来自zvvq

{

options.ConnectionString = configuration.GetSection("MongoConnection:ConnectionString").Value; 内容来自zvvq，别采集哟

options.Database = configuration.GetSection("MongoConnection:Database").Value;

zvvq

}); zvvq.cn

}

}

内容来自samhan666

public class MongoDBBase 本文来自zvvq

{

copyright zvvq

private readonly IMongoDatabase _database = null;

public MongoDBBase(string connectionString, string databaseName) 内容来自samhan

{

var client = new MongoClient(connectionString); zvvq

if (client != null) 内容来自zvvq

{

zvvq好，好zvvq

_database = client.GetDatabase(databaseName);

}

copyright zvvq

} 内容来自zvvq，别采集哟

region SELECT

/// <summary> copyright zvvq

/// 根据查询条件，获取数据 内容来自samhan

/// </summary>

/// <typeparam name="T"></typeparam>

/// <param name="id"></param>

内容来自samhan666

/// <returns></returns> 内容来自samhan666

public List<T> GetList<T>(Expression<Func<T, bool>> conditions = null)

内容来自samhan

{ zvvq

var collection = _database.GetCollection<T>(typeof(T).Name);

zvvq好，好zvvq

if (conditions != null) 内容来自zvvq

{ zvvq

return collection.Find(conditions).ToList(); copyright zvvq

}

return collection.Find(_ => true).ToList(); zvvq

}endregion 内容来自zvvq

region INSERT/// <summary>

zvvq.cn

/// 插入多条数据，数据用list表示

内容来自zvvq

/// </summary> 内容来自samhan

/// <typeparam name="T"></typeparam> 本文来自zvvq

/// <param name="list"></param>

/// <returns></returns> 内容来自samhan666

public List<T> InsertMany<T>(List<T> list)

内容来自samhan

{

copyright zvvq

var collection = _database.GetCollection<T>(typeof(T).Name); 内容来自zvvq

collection.InsertMany(list);

return list;

zvvq

} 内容来自zvvq

endregion

zvvq好，好zvvq

} 内容来自zvvq，别采集哟

"MongoConnection": { //mongodb数据库连接

"ConnectionString": "mongodb://127.0.0.1:27017", zvvq

"Database": "testdb", copyright zvvq

"IsSSL": true zvvq好，好zvvq

},

copyright zvvq

[Produces("application/json")]

[Route("api/MongoDB/[action]")] 内容来自samhan

public class MongoDBController : Controller copyright zvvq

{ zvvq

private readonly MongoDBBase _context = null; 内容来自samhan

public MongoDBController(IOptions<Settings> settings)

{

_context = new MongoDBBase(settings.Value.ConnectionString, settings.Value.Database); 本文来自zvvq

}

[HttpGet] 内容来自samhan666

public IActionResult AddList()

{

zvvq好，好zvvq

List<MongoDBPostTest> list = new List<MongoDBPostTest>() 内容来自samhan666

{

new MongoDBPostTest() zvvq.cn

{ copyright zvvq

Id = "2", 本文来自zvvq

Body = "Test note 3",

UpdatedOn = DateTime.Now, 内容来自samhan

UserId = 1,

HeaderImage = new NoteImage

{ zvvq

ImageSize = 10, zvvq好，好zvvq

Url = "http://localhost/image1.png", zvvq

ThumbnailUrl = "http://localhost/image1_small.png" zvvq好，好zvvq

}

内容来自zvvq

}, copyright zvvq

new MongoDBPostTest() 内容来自samhan666

{ zvvq.cn

Id = "3", copyright zvvq

Body = "Test note 4",

zvvq.cn

UpdatedOn = DateTime.Now,

zvvq

UserId = 1,

copyright zvvq

HeaderImage = new NoteImage

{

ImageSize = 14,

Url = "http://localhost/image3.png",

内容来自samhan

ThumbnailUrl = "http://localhost/image3_small.png" 内容来自zvvq，别采集哟

}

} 内容来自zvvq

}; 内容来自samhan

try

内容来自zvvq

{

内容来自zvvq，别采集哟

_context.InsertMany(list);

本文来自zvvq

} 内容来自samhan666

catch (Exception ex) 内容来自zvvq

{

内容来自zvvq，别采集哟

throw; 内容来自zvvq，别采集哟

} 本文来自zvvq

return Ok("成功"); zvvq好，好zvvq

}

zvvq

[HttpGet]

public Result<List<MongoDBPostTest>> SelectSingle() zvvq

{ 本文来自zvvq

//无条件 内容来自zvvq，别采集哟

var list = _context.GetList<MongoDBPostTest>(); zvvq

//有条件 zvvq

//var list = _context.GetList<MongoDBPostTest>(a => a.Id == "1"); 内容来自samhan666

//得到单条数据,无条件

//var list = _context.GetSingle<MongoDBPostTest>();

内容来自zvvq

//得到单条数据,有条件 zvvq好，好zvvq

//var list = _context.GetSingle<MongoDBPostTest>(a => a.Id == "3");

ObjectId internalId = _context.GetInternalId("5bbf41651d3b66668cbb5bfc");

本文来自zvvq

var a = _context.GetSingle<MongoDBPostTest>(note => note.Id == "5bbf41651d3b66668cbb5bfc" || note.InternalId == internalId);

return ResHelper.Suc(1, list, "成功"); zvvq好，好zvvq

} 本文来自zvvq

} 本文来自zvvq

public class MongoDBPostTest zvvq

{ 内容来自samhan666

[BsonId] 内容来自zvvq

// standard BSonId generated by MongoDb

内容来自zvvq

public ObjectId InternalId { get; set; }

zvvq.cn

public string Id { get; set; } 内容来自zvvq，别采集哟

public string Body { get; set; } = string.Empty; 内容来自samhan666

[BsonDateTimeOptions] zvvq

public DateTime UpdatedOn { get; set; } = DateTime.Now; zvvq

public NoteImage HeaderImage { get; set; } copyright zvvq

public int UserId { get; set; } = 0; 内容来自zvvq

} zvvq好，好zvvq

public class NoteImage zvvq好，好zvvq

{

zvvq.cn

public string Url { get; set; } = string.Empty;

public string ThumbnailUrl { get; set; } = string.Empty;

public long ImageSize { get; set; } = 0L;

zvvq.cn

}

zvvq