whatthefuck.cs

static void Main(string[] args)
{
    ////////// Setup Elastic
    var node = new Uri("http://localhost:9200");
    var settings =
        new ConnectionSettings(node).SetDefaultIndex("fansz")
            .MapDefaultTypeNames(m => m.Add(typeof(UserElastic), "users"));

    var client = new ElasticClient(settings);

    client.CreateIndex(c => c
        .Index("users")
        .Analysis(an => an
            .Analyzers(a => a
                .Add("email-analyzer", new CustomAnalyzer
                {
                    Tokenizer = "keyword", Filter = new[] { "lowercase" }
                })))
        .AddMapping<UserElastic>(m => m.Properties(u => u.String(s => s.Name(d => d.Email).Analyzer("email-analyzer")))));


    ////////// Load Data
    var storageAccount = CloudStorageAccount.Parse(ConfigurationManager.ConnectionStrings["StorageConnectionString"].ConnectionString);

    var tableClient = storageAccount.CreateCloudTableClient();
    var table = tableClient.GetTableReference("Users");
    table.CreateIfNotExists();

    TableContinuationToken token = null;

    var entities = new List<User>();

    do
    {
        var queryResult = table.ExecuteQuerySegmented<User>(new TableQuery<User>(), token);
        entities.AddRange(queryResult.Results);
        token = queryResult.ContinuationToken;
    }
    while (token != null);

    foreach (var entity in entities)
    {
        client.Index(Map(entity));
    }


    ////////// Query that shit!
    var searchResults = client.Search<UserElastic>(s => s
        .Query(q => q.Terms(m => m.Phone, new List<string> { "rogers_bashirian@kesslerhirthe.name" })));
    
    foreach (var searchResult in searchResults.Documents)
    {
        Console.WriteLine(searchResult.Email);
    }
    
    Console.WriteLine("done");
    Console.ReadLine();
}