从 cassandra 导出数据到 csv 文件

Question

大家好，我想在 cassandra 的指定表中获取数据并将其保存到 csv 文件中。我做了什么

//using c# api
            //  Cluster cluster = Cluster.Builder().AddContactPoint("192.168.0.214").Build();
              Cluster cluster = Cluster.Builder().AddContactPoint("127.0.0.1").Build();
             List<string> lstOfKeyspaces =cluster.Metadata.GetKeyspaces().ToList<string>();
             ISession session = cluster.Connect("integrationobjects");
             //get tables in the keysapce
             List<string> lstString = cluster.Metadata.GetTables("integrationobjects").ToList<string>();
            Console.WriteLine("Connection succeeded");
         //   Console.ReadLine();
            RowSet resultRequest = session.Execute("select json * from emp");

为了将结果保存到 csv 文件中，我们将不胜感激。 提前谢谢你

Answer 1

使用 Cqlsh COPY TO 命令

登录到 Cqlsh 然后使用以下命令：

COPY emp TO 'exp.csv';

Answer 2

这就像遍历查询返回的 RowSet 一样简单。这样的事情就足够了：

// Open the file for output...
...

// Loop over all the rows
IEnumerable<Row> rowEnumerator = resultRequest.GetEnumerator();
while (rowEnumerator.MoveNext()) {
    // Get the row
    Row r = rowEnumerator.Current;

    // Prepare a new line
    List<string> values = new List<string>;

    // Loop over all the columns of the row
    IEnumerator<Object> colEnumerator = r.GetEnumerator();
    while (colEnumerator.MoveNext()) {
        values.Add(...); // Stack the strings here 
    }
    // Create the row
    string line = String.Join(",", values.ToArray());

    // Output line to file
    // ...
}
// Close the file
...