ナンセンスではありません。コードにアクセスしてください。
using MongoDB.Bson.Serialization.Attributes;namespace XL.Core.MongoDB
{public interface IEntity<tkey>{/// <summary>/// 主键/// </summary> [BsonId]
TKey Id { get; set; }
}
}</tkey>
コードを表示
[BsonIgnoreExtraElements(Inherited = true)]public abstract class Entity : IEntity<string>{/// <summary>/// 主键/// </summary> [BsonRepresentation(BsonType.ObjectId)]public virtual string Id { get; set; }
}</string>
コードを表示
りー コードの表示
は次のように使用されます:
public interface IRepository<t> : IQueryable<t> where T : IEntity<tkey>{#region Fileds/// <summary>/// MongoDB表/// </summary>IMongoCollection<t> DbSet { get; }/// <summary>/// MongoDB库/// </summary>IMongoDatabase DbContext { get; }#endregion#region Find/// <summary>/// 根据主键获取对象/// </summary>/// <param>/// <returns></returns> T GetById(TKey id);/// <summary>/// 获取对象/// </summary>/// <param>/// <returns></returns>IEnumerable<t> Get(Expression<func>> predicate);/// <summary>/// 获取对象/// </summary>/// <param>/// <param>/// <returns></returns>Task<ienumerable>> GetAsync(Expression<func>> predicate,
CancellationToken cancellationToken = default(CancellationToken));#endregion#region Insert/// <summary>/// 插入文档/// </summary>/// <param>/// <returns></returns> T Insert(T entity);/// <summary>/// 异步插入文档/// </summary>/// <param>/// <param>/// <returns></returns>Task InsertAsync(T entity, CancellationToken cancellationToken = default(CancellationToken));/// <summary>/// Adds the new entities in the repository./// </summary>/// <param>The entities of type T.void Insert(IEnumerable<t> entities);/// <summary>/// 插入文档/// </summary>/// <param>/// <param>/// <returns></returns>Task InsertAsync(IEnumerable<t> entities, CancellationToken cancellationToken = default(CancellationToken));#endregion#region Update/// <summary>/// 更新文档/// </summary>/// <param>/// <returns></returns> UpdateResult Update(T entity);/// <summary>/// 异步更新文档/// </summary>/// <param>/// <param>/// <returns></returns>Task<updateresult> UpdateAsync(T entity, CancellationToken cancellationToken = default(CancellationToken));#endregion#region Delete/// <summary>/// 根据主键ID/// </summary>/// <param>/// <returns></returns> T Delete(TKey id);/// <summary>/// 异步根据ID删除文档/// </summary>/// <param>/// <param>/// <returns></returns>Task<t> DeleteAsync(TKey id, CancellationToken cancellationToken = default(CancellationToken));/// <summary>/// 异步删除/// </summary>/// <param>/// <param>/// <returns></returns>Task<deleteresult> DeleteAsync(Expression<func>> predicate,
CancellationToken cancellationToken = default(CancellationToken));/// <summary>/// 删除/// </summary>/// <param>/// <returns></returns>DeleteResult Delete(Expression<func>> predicate);#endregion#region Other/// <summary>/// 计数/// </summary>/// <param>/// <returns></returns>long Count(Expression<func>> predicate);/// <summary>/// 计数/// </summary>/// <param>/// <param>/// <returns></returns>Task<long> CountAsync(Expression<func>> predicate,
CancellationToken cancellationToken = new CancellationToken());/// <summary>/// 是否存在/// </summary>/// <param>/// <returns></returns>bool Exists(Expression<func>> predicate);#endregion#region Query/// <summary>/// 分页/// 注：只适合单属性排序/// </summary>/// <param>/// <param>/// <param>/// <param>/// <returns></returns>IEnumerable<t> Paged(Expression<func>> predicate, Expression<func>> sortBy,int pageSize, int pageIndex = 1);/// <summary>/// /// </summary>/// <param>/// <param>/// <param>/// <param>/// <param>/// <returns></returns>Task<list>> PagedAsync(Expression<func>> predicate, Expression<func>> sortBy,int pageSize, int pageIndex = 1,
CancellationToken cancellationToken = new CancellationToken());#endregion} public interface IRepository<t> : IRepository<t>where T : IEntity<string>{
}</string></t></t></func></func></list></func></func></t></func></func></long></func></func></func></deleteresult></t></updateresult></t></t></func></ienumerable></func></t></t></tkey></t></t>
コードの表示
public class MongoRepository<t> : IRepository<t> where T : IEntity<string>{#region Constructorprotected MongoRepository(IMongoCollection<t> collection)
{
DbSet = collection;
DbContext = collection.Database;
}#endregionpublic IEnumerator<t> GetEnumerator()
{return DbSet.AsQueryable().GetEnumerator();
}
IEnumerator IEnumerable.GetEnumerator()
{return GetEnumerator();
}#region 字段public Type ElementType => DbSet.AsQueryable().ElementType;public Expression Expression => DbSet.AsQueryable().Expression;public IQueryProvider Provider => DbSet.AsQueryable().Provider;public IMongoCollection<t> DbSet { get; }public IMongoDatabase DbContext { get; }#endregion#region Findpublic T GetById(string id)
{return Get(a => a.Id.Equals(id)).FirstOrDefault();
}public IEnumerable<t> Get(Expression<func>> predicate)
{return DbSet.FindSync(predicate).Current;
}public async Task<ienumerable>> GetAsync(Expression<func>> predicate,
CancellationToken cancellationToken = new CancellationToken())
{var task = await DbSet.FindAsync(predicate, null, cancellationToken);return task.Current;
}#endregion#region Insertpublic T Insert(T entity)
{
DbSet.InsertOne(entity);return entity;
}public Task InsertAsync(T entity, CancellationToken cancellationToken = new CancellationToken())
{return DbSet.InsertOneAsync(entity, null, cancellationToken);
}public void Insert(IEnumerable<t> entities)
{
DbSet.InsertMany(entities);
}public Task InsertAsync(IEnumerable<t> entities, CancellationToken cancellationToken = new CancellationToken())
{return DbSet.InsertManyAsync(entities, null, cancellationToken);
}#endregion#region Updatepublic UpdateResult Update(T entity)
{var doc = entity.ToBsonDocument();return DbSet.UpdateOne(Builders<t>.Filter.Eq(e => e.Id, entity.Id),new BsonDocumentUpdateDefinition<t>(doc));
}public Task<updateresult> UpdateAsync(T entity, CancellationToken cancellationToken = new CancellationToken())
{var doc = entity.ToBsonDocument();return DbSet.UpdateOneAsync(Builders<t>.Filter.Eq(e => e.Id, entity.Id),new BsonDocumentUpdateDefinition<t>(doc), cancellationToken: cancellationToken);
}#endregion#region Deletepublic T Delete(string id)
{return DbSet.FindOneAndDelete(a => a.Id.Equals(id));
}public Task<t> DeleteAsync(string id, CancellationToken cancellationToken = new CancellationToken())
{return DbSet.FindOneAndDeleteAsync(a => a.Id.Equals(id), null, cancellationToken);
}public Task<deleteresult> DeleteAsync(Expression<func>> predicate,
CancellationToken cancellationToken = new CancellationToken())
{return DbSet.DeleteManyAsync(predicate, cancellationToken);
}public DeleteResult Delete(Expression<func>> predicate)
{return DbSet.DeleteMany(predicate);
}#endregion#region Otherpublic long Count(Expression<func>> predicate)
{return DbSet.Count(predicate);
}public Task<long> CountAsync(Expression<func>> predicate,
CancellationToken cancellationToken = new CancellationToken())
{return DbSet.CountAsync(predicate, null, cancellationToken);
}public bool Exists(Expression<func>> predicate)
{return Get(predicate).Any();
}#endregion#region Pagepublic IEnumerable<t> Paged(Expression<func>> predicate, Expression<func>> sortBy,int pageSize, int pageIndex = 1)
{var sort = Builders<t>.Sort.Descending(sortBy);return DbSet.Find(predicate).Sort(sort).Skip(pageSize * pageIndex - 1).Limit(pageSize).ToList();
}public Task<list>> PagedAsync(Expression<func>> predicate, Expression<func>> sortBy,int pageSize, int pageIndex = 1,
CancellationToken cancellationToken = new CancellationToken())
{return Task.Run(() =>{var sort = Builders<t>.Sort.Descending(sortBy);return DbSet.Find(predicate).Sort(sort).Skip(pageSize * pageIndex - 1).Limit(pageSize).ToList();
}, cancellationToken);
}#endregion#region Helper/// <summary>/// 获取类型的所有属性信息/// </summary>/// <typeparam></typeparam>/// <typeparam></typeparam>/// <param>/// <returns></returns>private PropertyInfo[] GetPropertyInfos<tproperty>(Expression<func>> select)
{var body = select.Body;switch (body.NodeType)
{case ExpressionType.Parameter:var parameterExpression = body as ParameterExpression;if (parameterExpression != null) return parameterExpression.Type.GetProperties();break;case ExpressionType.New:var newExpression = body as NewExpression;if (newExpression != null)return newExpression.Members.Select(m => m as PropertyInfo).ToArray();break;
}return null;
}#endregion}</func></tproperty></t></func></func></list></t></func></func></t></func></func></long></func></func></func></deleteresult></t></t></t></updateresult></t></t></t></t></func></ienumerable></func></t></t></t></t></string></t></t>
コードの表示
public class MongoDBSetting
{public string DataBase { get; set; }public string UserName { get; set; }public string Password { get; set; }public List<mongoservers> Services { get; set; }
}public class MongoServers
{public string Host { get; set; }public int Port { get; set; } = 27017;
}</mongoservers> コードを表示
public class LogsContext
{private readonly IMongoDatabase _db;public LogsContext(IOptions<mongodbsetting> options)
{var permissionSystem =MongoCredential.CreateCredential(options.Value.DataBase, options.Value.UserName,
options.Value.Password);var services = new List<mongoserveraddress>();foreach (var item in options.Value.Services)
{
services.Add(new MongoServerAddress(item.Host, item.Port));
}var settings = new MongoClientSettings
{
Credentials = new[] {permissionSystem},
Servers = services
};var _mongoClient = new MongoClient(settings);
_db = _mongoClient.GetDatabase(options.Value.DataBase);
}public IMongoCollection<errorlogs> ErrorLog => _db.GetCollection<errorlogs>("Error");public IMongoCollection<errorlogs> WarningLog => _db.GetCollection<errorlogs>("Warning");
}</errorlogs></errorlogs></errorlogs></errorlogs></mongoserveraddress></mongodbsetting>
コードを表示
最後に: 
public static IServiceCollection UserMongoLog(this IServiceCollection services,
IConfigurationSection configurationSection)
{
services.Configure<mongodbsetting>(configurationSection);
services.AddSingleton<logscontext>();return services;
}</logscontext></mongodbsetting>
コードを表示
"Mongo.Log": {"DataBase": "PermissionSystem","UserName": "sa","Password": "shtx@123","Services": [
{"Host": "192.168.1.6","Port": "27017" }
]
}刚学洗使用MongoDB，才疏学浅，请大神多多指教
以上がAsp.Net Core MongoDB に関するサンプルコードの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
C＃.NETエコシステム：フレームワーク、ライブラリ、およびツールApr 24, 2025 am 12:02 AMC＃.NETエコシステムは、開発者がアプリケーションを効率的に構築できるようにするための豊富なフレームワークとライブラリを提供します。 1.ASP.NETCOREは、高性能Webアプリケーションの構築に使用されます。2.EntityFrameWorkCoreは、データベース操作に使用されます。これらのツールの使用とベストプラクティスを理解することにより、開発者はアプリケーションの品質とパフォーマンスを向上させることができます。
azure/awsへのc＃.netアプリケーションの展開：ステップバイステップガイドApr 23, 2025 am 12:06 AMc＃.netアプリをAzureまたはAWSに展開する方法は？答えは、AzureAppServiceとAwselasticBeanStalkを使用することです。 1。Azureでは、AzureAppServiceとAzurePipelinesを使用して展開を自動化します。 2。AWSでは、Amazon ElasticBeanstalkとAwslambdaを使用して、展開とサーバーレス計算を実装します。
C＃.NET：強力なプログラミング言語の紹介Apr 22, 2025 am 12:04 AMC＃と.NETの組み合わせにより、開発者に強力なプログラミング環境を提供します。 1）C＃は、多型と非同期プログラミングをサポートします。2）.NETは、クロスプラットフォーム機能と同時処理メカニズムを提供し、デスクトップ、Web、モバイルアプリケーション開発で広く使用されています。
.NETフレームワーク対C＃：用語のデコードApr 21, 2025 am 12:05 AM.NetFrameworkはソフトウェアフレームワークであり、C＃はプログラミング言語です。 1..netframeworkは、デスクトップ、Web、モバイルアプリケーションの開発をサポートするライブラリとサービスを提供します。 2.C＃は.NetFrameWork用に設計されており、最新のプログラミング機能をサポートしています。 3..NetFrameworkはCLRを介してコード実行を管理し、C＃コードはILにコンパイルされ、CLRによって実行されます。 4. .NetFrameWorkを使用してアプリケーションをすばやく開発し、C＃はLINQなどの高度な関数を提供します。 5.一般的なエラーには、タイプ変換と非同期プログラミングデッドロックが含まれます。 VisualStudioツールは、デバッグに必要です。
C＃.NETの分解：初心者の概要Apr 20, 2025 am 12:11 AMC＃は、Microsoftが開発した最新のオブジェクト指向プログラミング言語であり、.NETはMicrosoftが提供する開発フレームワークです。 C＃は、CのパフォーマンスとJavaのシンプルさを組み合わせており、さまざまなアプリケーションの構築に適しています。 .NETフレームワークは、複数の言語をサポートし、ガベージコレクションメカニズムを提供し、メモリ管理を簡素化します。
C＃と.NETランタイム：それらがどのように連携するかApr 19, 2025 am 12:04 AMC＃と.NETランタイムは密接に連携して、開発者に効率的で強力なプラットフォームの開発機能に力を与えます。 1）C＃は、.NETフレームワークとシームレスに統合するように設計されたタイプセーフおよびオブジェクト指向のプログラミング言語です。 2）.NETランタイムは、C＃コードの実行を管理し、ガベージコレクション、タイプの安全性、その他のサービスを提供し、効率的でクロスプラットフォームの操作を保証します。
C＃.NET開発：始めるための初心者向けガイドApr 18, 2025 am 12:17 AMC＃.NET開発を開始するには、次のことが必要です。1。C＃の基本的な知識と.NETフレームワークのコア概念を理解する。 2。変数、データ型、制御構造、関数、クラスの基本概念をマスターします。 3。LINQや非同期プログラミングなど、C＃の高度な機能を学習します。 4.一般的なエラーのためのデバッグテクニックとパフォーマンス最適化方法に精通してください。これらの手順を使用すると、C＃.NETの世界に徐々に浸透し、効率的なアプリケーションを書き込むことができます。
C＃と.NET：2つの関係を理解しますApr 17, 2025 am 12:07 AMC＃と.NETの関係は切り離せませんが、同じものではありません。 C＃はプログラミング言語であり、.NETは開発プラットフォームです。 C＃は、コードの書き込み、.NETの中間言語（IL）にコンパイルされ、.NET Runtime（CLR）によって実行されるために使用されます。
ホットAIツール
Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ
AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。
Undress AI Tool
脱衣画像を無料で
Clothoff.io
AI衣類リムーバー
Video Face Swap
完全無料の AI 顔交換ツールを使用して、あらゆるビデオの顔を簡単に交換できます。
人気の記事
アサシンのクリードシャドウズ：シーシェルリドルソリューション
3週間前ByDDD
Atomfallのクレーンコントロールキーカードを見つける場所
3週間前ByDDD
<🎜>：Dead Rails-すべての課題を完了する方法
4週間前ByDDD
Atomfall Guide：アイテムの場所、クエストガイド、およびヒント
1 か月前ByDDD
ホットツール
ドリームウィーバー CS6
ビジュアル Web 開発ツール
MantisBT
Mantis は、製品の欠陥追跡を支援するために設計された、導入が簡単な Web ベースの欠陥追跡ツールです。 PHP、MySQL、Web サーバーが必要です。デモおよびホスティング サービスをチェックしてください。
SublimeText3 Mac版
神レベルのコード編集ソフト（SublimeText3）
VSCode Windows 64 ビットのダウンロード
Microsoft によって発売された無料で強力な IDE エディター
SublimeText3 中国語版
中国語版、とても使いやすい
