【问题标题】:Dump records from Database to file in CSV format以 CSV 格式将记录从数据库转储到文件
【发布时间】:2018-08-20 08:35:44
【问题描述】:

我正在使用Jooq 从数据库中读取数据并将记录转储到文件中。 我想以 CSV 格式转储记录,并在每条记录之间换行。我查看了Jooq Docs 并在 Google 上进行了研究,但没有找到任何帮助。 Jooq 支持 CSV format 但如何在我的用例中加入该功能。

我正在使用以下代码转储文件中的记录:

SelectQuery<Record> query = getDslContext().selectQuery();       

        try {

            @Cleanup FileOutputStream fileOutputStream = new FileOutputStream(FILE);
            @Cleanup GZIPOutputStream gzipOutputStream = new GZIPOutputStream(fileOutputStream);
            @Cleanup OutputStreamWriter outputStreamWriter = new OutputStreamWriter(gzipOutputStream, charsetName);
            @Cleanup BufferedWriter writer = new BufferedWriter(outputStreamWriter);
            @Cleanup Cursor<Record> cursor = query.fetchSize(MAX_FETCH_SIZE).fetchLazy();
            while(cursor.hasNext()){
                Result<Record> results = cursor.fetchNext(MAX_FETCH_SIZE);
                for (Record record : results){
                    writer.write(record.formatJSON());
                    writer.newLine();
                }
            }

【问题讨论】:

    标签: java sql jooq


    【解决方案1】:

    使用CSVFormat.newline() 属性:

    String csv = results.formatCSV(new CSVFormat().newline("\n\n"));
    

    或者,由于您是在行子集的基础上迭代光标,您可能也想删除标题:

    String csv = results.formatCSV(new CSVFormat().newline("\n\n").header(false));
    

    这也会在末尾产生两个尾随换行符,如果不需要,您可以轻松删除它们:

    csv = csv.trim();
    

    【讨论】:

      【解决方案2】:

      您可以直接从Result&lt;Record&gt; results 格式化记录,而无需手动遍历每条记录。

      唯一的问题是,由于您正在以MAX_FETCH_SIZE 的批次获取记录,因此每个批次的格式化 csv 将包含标头,您可能只需要在第一批中写入标头。

      @Cleanup Cursor<Record> cursor = query.fetchSize(2).fetchLazy();
      
      boolean includeHeaders = true;
      int dataStartIndex = 0;
      
      while(cursor.hasNext()){
      
          Result<Record> results = cursor.fetchNext(2);
          String csv = results.formatCSV();
      
          if (includeHeaders) {
              writer.write(csv);
              dataStartIndex = csv.indexOf('\n') + 1;
              includeHeaders = false;
              continue;
          }
      
          writer.write(csv.substring(dataStartIndex));
      }
      

      【讨论】:

        猜你喜欢
        • 1970-01-01
        • 2014-09-09
        • 1970-01-01
        • 2014-12-10
        • 2011-02-14
        • 2017-05-27
        • 2019-06-20
        • 1970-01-01
        • 2014-04-26
        相关资源
        最近更新 更多