美文网首页程序员
使用Fast-csv,实现Springboot 读取 csv文件

使用Fast-csv,实现Springboot 读取 csv文件

作者: 奇点一氪 | 来源:发表于2022-06-21 12:16 被阅读0次

    模块介绍 ?

    fast-csv是一款开源软件包,主要用来处理csv格式的文本数据,就是一种有固定格式的文本文件。fast-csv是一个流式的推式解析器,即收到一段数据就解析一段数据,不需要收完全部的数据才开始解析。推式就是每一行,每一个字段都全部都解析出来,不论你最后用了还是不用。

    如何使用?

    在pom.xml中添加依赖信息:

    <dependency>
                <groupId>de.siegmar</groupId>
                <artifactId>fastcsv</artifactId>
                <version>1.0.3</version>
    </dependency>
    

    代码工具类实现:

     
    import de.siegmar.fastcsv.reader.CsvContainer;
    import de.siegmar.fastcsv.reader.CsvParser;
    import de.siegmar.fastcsv.reader.CsvReader;
    import de.siegmar.fastcsv.reader.CsvRow;
    import org.springframework.stereotype.Component;
     
    import java.io.File;
    import java.io.IOException;
    import java.nio.charset.Charset;
    import java.nio.charset.StandardCharsets;
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
     
    /**
     * @author : Jone
     * @date : 10:18 2021/11/11 0011
     * @function :
     */
    @Component
    public class CsvRead {
     
       
        public static void csvReadOperation(String path)  {
     
            try{
                // File file = new File("F:\\Excel\\customer-info.csv");
                File file = new File(path);
                CsvReader csvReader = new CsvReader();
                csvReader.setContainsHeader(true);
     
                // CsvContainer csv = csvReader.read(file, StandardCharsets.UTF_8);
                // 将解决中文乱码问题
                CsvContainer csv = csvReader.read(file, Charset.forName("GBK"));
                // csv.getRowCount() 记录行数量
                // csv.getHeader().size() 记录 记录列数量
                // csv.getHeader().get(0) 编号
                // csv.getHeader().get(1) 时间
                for (CsvRow row : csv.getRows()) {
                    System.out.println("=======");
                    System.out.println("First column of line: " + row.getField("编号"));
                    System.out.println("First column of line: " + row.getField("时间"));
                    System.out.println("First column of line: " + row.getField("句子"));
                    System.out.println("First column of line: " + row.getField("博客"));
                    System.out.println("First column of line: " + row.getField("关键词"));
                    System.out.println("First column of line: " + row.getField("话题"));
                }
            }catch (Exception e){e.printStackTrace();}
     
        }
     
      
      
        public static void csvReadData(String path)  {
     
            // 初始化对象
            Map<String, Object> map = new HashMap<String, Object>();
     
            List<Map<String, Object>> list = new ArrayList<>();
     
     
     
            try {
     
                File file = new File(path);
                CsvReader csvReader = new CsvReader();
                csvReader.setContainsHeader(true);
     
                // CsvContainer csv = csvReader.read(file, StandardCharsets.UTF_8);
                // 将解决中文乱码问题
                CsvContainer csv = csvReader.read(file, Charset.forName("GBK"));
                // csv.getRowCount() 记录行数量
                // csv.getHeader().size() 记录 记录列数量
                // csv.getHeader().get(0) 编号
                // csv.getHeader().get(1) 时间
     
                for (int i = 0; i < csv.getRowCount(); i++) {
     
                    for (int j = 0; j < csv.getHeader().size(); j++) {
     
                        map.put(csv.getHeader().get(j), csv.getRow(i).getField(csv.getHeader().get(j)));
     
                    }
                    list.add(map);
                }
     
                System.out.println(list);
     
                // 格式转换
                String result = list.toString();
     
                //  打印转换格式后的数据信息
                System.out.println(result);
     
            }catch (Exception e) {
                e.printStackTrace();
            }
     
        }
     
     
        // 获取csv 的行
        public static void analysisData(String path){
     
            List<String> list = new ArrayList<>();
     
     
            try {
     
                File file = new File(path);
                CsvReader csvReader = new CsvReader();
                csvReader.setContainsHeader(true);
     
                // CsvContainer csv = csvReader.read(file, StandardCharsets.UTF_8);
                // 将解决中文乱码问题
                CsvContainer csv = csvReader.read(file, Charset.forName("GBK"));
                // csv.getRowCount() 记录行数量
                // csv.getHeader().size() 记录 记录列数量
                // csv.getHeader().get(0) 编号
                // csv.getHeader().get(1) 时间
     
                for (int j = 0; j < csv.getHeader().size(); j++) {
     
                    list.add(csv.getHeader().get(j));
     
                }
     
                System.out.println(list);
     
                // 格式转换
                String result = list.toString();
     
                //  打印转换格式后的数据信息
                System.out.println(result);
     
            }catch (Exception e) {
                e.printStackTrace();
            }
     
     
     
        }
     
     
    }
    

    相关文章

      网友评论

        本文标题:使用Fast-csv,实现Springboot 读取 csv文件

        本文链接:https://www.haomeiwen.com/subject/vbtevrtx.html