15年来,我第一次与锡拉db合作。
读了几天关于锡拉和c的书,我得到了下面的代码。在下面的代码中,我连接到scylla集群并尝试查询一个表以从中获取数据。
public static async void test()
{
var cluster = Cluster.Builder().AddContactPoints("test-endpoint").WithQueryOptions(new QueryOptions().SetConsistencyLevel(ConsistencyLevel.LocalQuorum)).Build();
var session = cluster.Connect("processks");
var mapper = new Mapper(session);
var cql = Cql.New("SELECT * FROM test LIMIT 10");
var fetchResult = await mapper.FetchAsync<User>(cql).ConfigureAwait(false);
// this just prints the object which is not what I want
Console.WriteLine(fetchResult);
}
下面是我的 User
班级:
using System.Collections.Generic;
using Cassandra.Mapping;
using Cassandra.Mapping.Attributes;
namespace Test.Objects.POCO.Scylla
{
[TableName("test")]
[PrimaryKey("client_id")]
public class User
{
[Column("client_id")]
public int ClientId { get; set; }
[Column("md")]
public string MD { get; set; }
[Column("process_ids")]
public List<int> ProcessIds { get; set; }
}
}
如何迭代 fetchResult
对象打印执行上述查询后返回的数据?
这是的代码链接 Mapper
在哪里上课 FetchAsync
方法并返回 Task<IEnumerable<T>>
把东西拿回来。
1条答案
按热度按时间xzv2uavs1#
Console.WriteLine(string.Join(Environment.NewLine, fetchResult));
Console.WriteLine(string.Join(
Environment.NewLine,
fetchResult.Select(user => JsonConvert.SerializeObject(user))))