Elasticsearch.Net使用入门教程（1）

前端  /  管理员 发布于 3年前   136

本文实例为大家分享了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 

结果图:

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。