Elasticsearch.Net使用入门教程(1)
本文实例为大家分享了Elasticsearch.Net使用教程,供大家参考,具体内容如下
首先去官网下载Elasticsearch 2.3.4安装包,解压后,在cmd命令行进入安装目录,再进入 bin目录,运行elasticsearch.bat命令。
elasticsearch插件elasticsearch-head安装:
bin目录下执行命令plugin -install mobz/elasticsearch-head
然后开始.net编程,构建控制台应用程序
Program.cs代码如下:
class Program { static void Main(string[] args) { Console.WriteLine("*Program 开始运行 : " + DateTime.Now); var business = new Business(); var swRead = new Stopwatch(); //swRead.Start(); //business.AddToDb();//sqlserver数据库增加数据 //swRead.Stop(); //Console.WriteLine("DB 写入时间 : " + swRead.ElapsedMilliseconds); //swRead.Reset(); //swRead.Start(); //business.AddToElasticIndex(); //swRead.Stop(); //Console.WriteLine("ES 写入时间 : " + swRead.ElapsedMilliseconds); var sw = new Stopwatch(); sw.Start(); var personsFromDB = business.GetFromDB(); sw.Stop(); Console.WriteLine("DB 读时间 : " + sw.ElapsedMilliseconds); sw.Reset(); sw.Start(); var personsFromEs = business.GetFromES(); sw.Stop(); Console.WriteLine("ES 读时间 : " + sw.ElapsedMilliseconds); Console.ReadLine(); } }
BLL层的Business.cs类:
public class Business { private List<PersonDetail> _personList = new List<PersonDetail>(); //SQLSERVER数据库 PersonDbProvider dbProvider = new PersonDbProvider(); //ElasticSearch ESProvider esProvider = new ESProvider(); public void AddToDb() { _personList = Util.Get10000PersonDetails();//辅助类,生成10000条数据 foreach (var personDetail in _personList) { dbProvider.AddPerson(personDetail); } } public void AddToElasticIndex() { _personList = Util.Get10000PersonDetailsWithID(); foreach (var personDetail in _personList) { esProvider.Index(personDetail); } } public List<PersonDetail> GetFromDB() { return dbProvider.GetAllPersonDetails(); } public List<PersonDetail> GetFromES() { return esProvider.GetAll(); } }
PersonDbProvider.cs和ElasticSearchProvider.cs以及Util.cs,Setting.cs类:
public class PersonDbProvider { public bool AddPerson(PersonDetail personDetail) { try { //数据库上下文 using (var db = new PersonContext()) { db.PersonDetails.Add(personDetail); db.SaveChanges(); return true; } } catch (Exception) { return false; } } public List<PersonDetail> GetAllPersonDetails() { try { using (var db = new PersonContext()) { return db.PersonDetails.ToList(); } } catch (Exception) { return null; } } }
public class ESProvider { public static ElasticClient client = new ElasticClient(Setting.ConnectionSettings); public bool Index(PersonDetail person) { var client = new ElasticClient(Setting.ConnectionSettings); try { //添加数据 //在调用下面的index方法的时候,如果没有指定使用哪个index,ElasticSearch会直接使用我们在setting中的defaultIndex,如果没有,则会自动创建 var index = client.Index(person); return index.Created; } catch (Exception ex) { Console.WriteLine(" Excepton Message : " + ex.Message); } return false; } public List<PersonDetail> GetAll() { var searchResults = client.Search<PersonDetail>(s => s .From(0) .Size(10000) ); return searchResults.Documents.ToList(); } public List<PersonDetail> GetEntities(string keyword) { var client = new ElasticClient(Setting.ConnectionSettings); #region 全文搜索 keyword = String.Format("*{0}*", keyword); //默认的Operator是Or,当keyword是类似于"One Two"之类的中间有空格的时候,会被当成两个关键词搜索,然后搜索结果进行or运算 //所以我们需要根据需求来调整Operator var searchResults = client.Search<PersonDetail>(s => s .Index("elastic-search-app") .Query(q => q.QueryString(qs => qs.Query(keyword).DefaultOperator(Operator.And))) ); //-------------------------------------------------------------------------------------- //另外由于ES是分词搜索,所以当我们要用"One"来搜索完整的单词"JustOne"的时候,就必须在"One"外面添加**,类似于SQL里面的%keyword%,但是这样的做法会导致在用完整的单词来搜索的时候搜索不到结果,所以我们需要使用下面的方式 //wholeKeyword = keyword; //keyword = String.Format("*{0}*", keyword); //QueryContainer query = new QueryStringQuery() { Query = keyword, DefaultOperator = Operator.And }; //if (!String.IsNullOrEmpty(wholeKeyword)) //{ // QueryContainer wholeWordQuery = new QueryStringQuery() { Query = wholeKeyword }; // query = query || wholeWordQuery; //} //var searchResults = client.Search<Person>(s => s // .Index("zhixiao-application") // .Query(query) //); #endregion #region 指定属性搜索 //使用term Query //Term是一个被索引的精确值,也就是说Foo, foo, FOO是不相等的,因此 //在使用term query的时候要注意,term query在搜索的Field已经被索引的时候,是不支持大写的。 // QueryContainer query2 = new TermQuery { Field = item.Key, Value = item.Value.ToLower() }; //-------------------------------------------------------------------------------------- //var searchResults = client.Search<PersonDetail>(s => s // .Index("elastic-search-app") // .Query(q => q.Term(t => t.OnField(f => f.LastName == "keyword"))) //); //效果同上 //QueryContainer termQuery = new TermQuery { Field = "lastname", Value = "keyword" }; //var searchResults = client.Search<PersonDetail>(s => s // .Index("elastic-search-app") // .Query(termQuery) //); //-------------------------------------------------------------------------------------- //使用 Query String query //QueryString query一般用于全文搜索,但是也可以用于单个属性的搜索(设置DefaultField属性),queryString query可以不区分大小写。QueryString还有一个好处就是我们可以搜索一个term中的一部分, //例如lastname为"t Boterhuis 1",那么我们可以用"terhuis"搜索到这个数据(虽然需要在外面包上**),在term query里面就做不到,因为ES把每一个属性的值都分析成一个个单独的term,提高了搜索的效率。 //keyword = "t Boterhuis 2"; //QueryContainer wholeWordQuery = new QueryStringQuery() { Query = keyword, DefaultOperator = Operator.And }; //var searchResults = client.Search<PersonDetail>(s => s // .Index("elastic-search-app") // .Query(wholeWordQuery) //); #endregion return searchResults.Documents.ToList(); } public List<PersonDetail> Sort(string keyword) { // 首先我们把原先的索引先删除了 var response = client.DeleteIndex( new DeleteIndexRequest(new IndexNameMarker() { Name = "elastic-search-app", Type = typeof(PersonDetail) })); //然后重新创建索引 var indexResult = client.CreateIndex("PD-application"); var response1 = client.Map<PersonDetail>(m => m.MapFromAttributes()); IEnumerable<PersonDetail> persons = new List<PersonDetail> { new PersonDetail() { Id = 4, FirstName = "Boterhuis-040", LastName = "Gusto-040", }, new PersonDetail() { Id = 5, FirstName = "sales@historichousehotels.com", LastName = "t Boterhuis 1", }, new PersonDetail() { Id = 6, FirstName = "Aberdeen #110", LastName = "sales@historichousehotels.com", }, new PersonDetail() { Id = 7, FirstName = "Aberdeen #110", LastName = "t Boterhuis 2", }, }; foreach (var person in persons) { client.Index(person); } var searchResults = client.Search<PersonDetail>(s => s .Index("PD-application") .Sort(sort => sort.OnField(f => f.Id).Order(SortOrder.Ascending)) ); return searchResults.Documents.ToList(); } }
public static class Util { //生成10000条sqlserver测试数据 public static List<PersonDetail> Get10000PersonDetails() { var personDetailsList = new List<PersonDetail>(); for (int i = 0; i < 10000; i++) { personDetailsList.Add(new PersonDetail() { FirstName = "FN" + new Random().Next(int.MaxValue), LastName = "LN" + new Random().Next(int.MaxValue) }); } return personDetailsList; } //生成10000条ElasticSearch测试数据 public static List<PersonDetail> Get10000PersonDetailsWithID() { var personDetailsList = new List<PersonDetail>(); for (int i = 0; i < 10000; i++) { personDetailsList.Add(new PersonDetail() { Id = i * new Random().Next(99), FirstName = "FN" + new Random().Next(int.MaxValue), LastName = "LN" + new Random().Next(int.MaxValue) }); } return personDetailsList; } }
public static class Setting { public static Uri Node { get { return new Uri("http://localhost:9200"); } } //连接配置 public static ConnectionSettings ConnectionSettings { get { return new ConnectionSettings(Node, defaultIndex: "es-index-app"); } } }
Model层代码:
public partial class PersonDetail { public long Id { get; set; } public string FirstName { get; set; } public string LastName { get; set; } }
public partial class PersonContext : DbContext { static PersonContext() { Database.SetInitializer<PersonContext>(null); } public PersonContext() : base("Name=PersonContext") { } public DbSet<PersonDetail> PersonDetails { get; set; } protected override void OnModelCreating(DbModelBuilder modelBuilder) { //在重写OnModelCreating方法中则可以直接调用映射类,从而减少了OnModelCreating方法的复杂度,同时也增强了代码维护的可读性 modelBuilder.Configurations.Add(new PersonDetailMap()); //属性映射约定 } }
//Fluent API配置Configuration映射类 public class PersonDetailMap : EntityTypeConfiguration<PersonDetail> { public PersonDetailMap() { // 主键 this.HasKey(t => new { t.Id, t.FirstName, t.LastName }); // 属性 this.Property(t => t.Id) .HasDatabaseGeneratedOption(DatabaseGeneratedOption.Identity); this.Property(t => t.FirstName) .IsRequired(); this.Property(t => t.LastName) .IsRequired(); // 表 & 列 映射 this.ToTable("PersonDetails"); this.Property(t => t.Id).HasColumnName("Id"); this.Property(t => t.FirstName).HasColumnName("FirstName"); this.Property(t => t.LastName).HasColumnName("LastName"); } }
sqlserver脚本:
USE [Person] GO SET ANSI_NULLS ON GO SET QUOTED_IDENTIFIER ON GO CREATE TABLE [dbo].[PersonDetails]( [Id] [bigint] IDENTITY(1,1) NOT NULL, [FirstName] [nvarchar](max) NOT NULL, [LastName] [nvarchar](max) NOT NULL ) ON [PRIMARY] GO
结果图:
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持猪先飞。
相关文章
- 这篇文章主要为大家详细介绍了ASP.NET购物车的实现过程,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-09-22
- 这篇文章主要介绍了.NET Core下使用Kafka的方法步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-09-22
- 在开发过程中,使用Visual Studio的断点调试功能可以很方便帮我们调试发现程序存在的错误,同样Visual Studio也支持对SQL Server里面的存储过程进行调试,下面就让我们看看具体的调试方法。...2021-09-22
- 这篇文章主要介绍了Win10 IIS 安装及.net 4.5及Win10安装IIS并配置ASP.NET 4.0的方法,本文给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下...2021-09-22
- 这篇文章主要介绍了详解.NET Core 3.0 里新的JSON API,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-09-22
Elasticsearch工具cerebro的安装与使用教程
这篇文章主要介绍了Elasticsearch工具cerebro的安装与使用教程,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-03-08ASP.NET Core根据环境变量支持多个 appsettings.json配置文件
这篇文章主要介绍了ASP.NET Core根据环境变量支持多个 appsettings.json配置文件,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-09-22- 这篇文章主要介绍了.net数据库操作框架SqlSugar的简单入门,帮助大家更好的理解和学习使用.net技术,感兴趣的朋友可以了解下...2021-09-22
- 这篇文章主要介绍了记一次EFCore类型转换错误及解决方案,帮助大家更好的理解和学习使用asp.net core,感兴趣的朋友可以了解下...2021-09-22
docker 启动elasticsearch镜像,挂载目录后报错的解决
这篇文章主要介绍了docker 启动 elasticsearch镜像,挂载目录后报错的解决,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-11-20详解ASP.NET Core 中基于工厂的中间件激活的实现方法
这篇文章主要介绍了ASP.NET Core 中基于工厂的中间件激活的实现方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-09-22- 这篇文章主要介绍了C#使用Ado.Net更新和添加数据到Excel表格的方法,较为详细的分析了OLEDB的原理与使用技巧,可实现较为方便的操作Excel数据,需要的朋友可以参考下...2020-06-25
- ZXing是一个开放源码的,用Java实现的多种格式的1D/2D条码图像处理库,它包含了联系到其他语言的端口。这篇文章主要给大家介绍了.NET C#利用ZXing生成、识别二维码/条形码的方法,文中给出了详细的示例代码,有需要的朋友们可以参考借鉴。...2020-06-25
asp.net通过消息队列处理高并发请求(以抢小米手机为例)
这篇文章主要介绍了asp.net通过消息队列处理高并发请求(以抢小米手机为例),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-09-22ASP.NET单选按钮控件RadioButton常用属性和方法介绍
RadioButton又称单选按钮,其在工具箱中的图标为 ,单选按钮通常成组出现,用于提供两个或多个互斥选项,即在一组单选钮中只能选择一个...2021-09-22详解.NET Core 使用HttpClient SSL请求出错的解决办法
这篇文章主要介绍了.NET Core 使用HttpClient SSL请求出错的解决办法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧...2021-09-22- 这篇文章主要介绍了Python调用.NET库的方法步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-05-09
ASP.NET中iframe框架点击左边页面链接 右边显示链接页面内容
这篇文章主要介绍了ASP.NET中iframe框架点击左边页面链接,右边显示链接页面内容的实现代码,感兴趣的小伙伴们可以参考一下...2021-09-22- ASP.NET Web API具有与ASP.NET MVC类似的编程方式,ASP.NET Web API不仅仅具有一个完全独立的消息处理管道,而且这个管道比为ASP.NET MVC设计的管道更为复杂,功能也更为强大。下面创建一个简单的Web API项目,需要的朋友可以参考下...2021-09-22
- 通过本文可以帮助大家快速学习Docker安装ElasticSearch的过程,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧...2021-08-31