Apache.Ignite.NET 通过 ODBC 查询键/值数据

Question

Ignite 有（除其他外）用例“内存中键/值存储”和“通过 ODBC 的 SQL”。我想知道这些用例是否可以组合起来。

让我们使用这个模型：

class Person
{
    public string Name { get; set; }
    public int Age { get; set; }
}

将“人”添加到键/值存储：

using (var ignite = Ignition.Start())
{
    var cache = ignite.GetOrCreateCache<int, Person>("person-cache");
    cache.Put(1, new Person { Name = "Test", Age=7 });
}

现在，我可以做类似的事情

SELECT * FROM Person; 

通过 ODBC 连接？如果是，非常感谢 C#/Ignite.NET 中的代码示例。 还是因为我们谈论的是完全独立的数据存储/缓存所以不可能？

Answer 1

当然，您可以使用Apache Ignite 来完成。 要做三件事：

1. 使用所需的 SQL 字段更新您的 Person 模型：

   class Person
   {
       [QuerySqlField(IsIndexed = true)]
       public string Name { get; set; }
   
       [QuerySqlField]
       public int Age { get; set; }
   }
   

2. 将 SQL 查询类型（Person 类型）添加到 CacheConfiguration
   

3. 在访问表时不要忘记使用带引号的架构名称（= 缓存名称）：
   

       using (var ignite = Ignition.Start())
       {
           var cache = ignite.GetOrCreateCache<int, Person>(new CacheConfiguration("person-cache", typeof(Person)));
   
           cache.Put(1, new Person { Name = "Test", Age = 7 });
   
           var dbConnection = new OdbcConnection(@"DRIVER={Apache Ignite};ADDRESS=localhost:10800");
           try
           {
               dbConnection.Open();
   
               using (var dbCommand = dbConnection.CreateCommand())
               {
                   dbCommand.CommandText = @"SELECT * FROM ""person-cache"".Person WHERE Name=?";
                   dbCommand.Parameters.Add("Name", OdbcType.Char).Value = "Test";
                   var dbReader = dbCommand.ExecuteReader();
   
                   var fCount = dbReader.FieldCount;
                   while (dbReader.Read())
                   {
                       for (var i = 0; i < fCount; i++)
                       {
                           var val = dbReader.GetString(i);
                           var name = dbReader.GetName(i);
   
                           Console.WriteLine(name + "=" + val);
                       }
                   }
                   dbReader.Close();
               }
           }
           catch (OdbcException ex)
           {
               Console.WriteLine(ex);
           }
   
           Console.ReadKey();
       }
   

谢谢你， 阿列克谢