从Ignite缓存导出数据

import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.Ignition;
import org.apache.ignite.cache.query.QueryCursor;
import org.apache.ignite.cache.query.SqlFieldsQuery;

import java.io.FileWriter;
import java.io.IOException;
import java.util.List;

public class CacheExporter {
    public static void main(String[] args) {
        try (Ignite ignite = Ignition.start()) {
            IgniteCache<Long, Person> cache = ignite.getOrCreateCache("myCache");

            // 假设我们有一个Person类
            // public class Person { private Long id; private String name; ... }

            // 使用SQL查询获取数据
            SqlFieldsQuery sql = new SqlFieldsQuery("SELECT id, name FROM Person");
            QueryCursor<List<?>> cursor = cache.query(sql);

            try (FileWriter writer = new FileWriter("cache_data.csv")) {
                // 写入CSV文件头
                writer.append("ID,Name\n");

                // 写入数据
                for (List<?> row : cursor) {
                    writer.append(row.get(0).toString()).append(",");
                    writer.append(row.get(1).toString()).append("\n");
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}