使用parboiled2解析多行而不是字符串

Question

我想使用parboiled2来解析多个CSV行，而不是单个CSV字符串。其结果可能是：

val parser = new CSVRecordParser(fieldSeparator)
io.Source.fromFile("my-file").getLines().map(line => parser.record.run(line))

其中CSVRecordParser是我的CSV记录的解析器。我遇到的问题是，对于我已经尝试过的内容，我不能这样做，因为煮熟的解析器需要构造函数中的输入，而不是run方法中的输入。因此，我可以为每一行创建一个新的解析器，这不是很好，也可以找到一种方法将输入传递给解析器，以处理我拥有的每个输入。我试图通过将输入设置为变量并将解析器包装在另一个对象中，对解析器进行了一些黑客攻击。

object CSVRecordParser {

  private object CSVRecordParserWrapper extends Parser with StringBuilding {

    val textBase = CharPredicate.Printable -- '"'
    val qTextData = textBase ++ "\r\n"

    var input: ParserInput = _
    var fieldDelimiter: Char = _

    def record = rule { zeroOrMore(field).separatedBy(fieldDelimiter) ~> (Seq[String] _) }
    def field = rule { quotedField | unquotedField }
    def quotedField = rule {
      '"' ~ clearSB() ~ zeroOrMore((qTextData | '"' ~ '"') ~ appendSB()) ~ '"' ~ ows ~ push(sb.toString)
    }
    def unquotedField = rule { capture(zeroOrMore(textData)) }
    def textData = textBase -- fieldDelimiter

    def ows = rule { zeroOrMore(' ') }
  }

  def parse(input: ParserInput, fieldDelimiter: Char): Result[Seq[String]] = {
    CSVRecordParserWrapper.input = input
    CSVRecordParserWrapper.fieldDelimiter = fieldDelimiter
    wrapTry(CSVRecordParserWrapper.record.run())
  }
}

然后，当我想解析一行时，只需调用CSVRecordParser.parse(input, separator)。除了这是可怕的事实，它不工作，我经常有奇怪的错误与以前使用的分析器。我知道这不是我应该用parboiled2编写解析器的方式，我想知道用这个库实现我想要做的事情的最好方法是什么。

Answer 1

在一个需要高速度和低资源的项目中，我已经对超过100万条记录的CSV文件这样做了，我发现为每一行实例化一个新的解析器是很好的。

在注意到parboiled2自述文件提到解析器的重量非常轻之后，我尝试了这种方法。

我甚至不需要从它们的默认值中增加JVM内存或堆限制。每一行的解析器实例化工作得很好。

Answer 2

为什么不在解析器中添加记录规则的结尾。

def EOR = rule { "\r\n" | "\n" }

def record = rule { zeroOrMore(field).separatedBy(fieldDelimiter) ~ EOR ~> (Seq[String] _) }

然后你可以通过多少行你想。