scala io Ausnahmebehandlung

Question

Ich versuche, eine durch Komma getrennte Datei in scala zu lesen und diese in eine Liste von Json-Objekten umzuwandeln. Der Code funktioniert, wenn alle Datensätze gültig sind. Wie finde ich die Ausnahme für die Datensätze, die in meiner Funktion nicht gültig sind. Wenn ein Datensatz nicht gültig ist, sollte er die Datei auslösen und ausschließen und weiterlesen. Aber in meinem Fall, sobald ein ungültiger Datensatz kommt, stoppt die Anwendung.

def parseFile(file: String): List[JsObject] = { 

val bufferedSource = Source.fromFile(file) 
try { 
    bufferedSource.getLines().map(line => { 
    val cols = line.split(",").map(_.trim) 
    (Json.obj("Name" -> cols(0), "Media" -> cols(1), "Gender" -> cols(2), "Age" -> cols(3).toInt)) // Need to handle io exception here. 
    }).toList 
} 

finally { 
    bufferedSource.close() 
    } 
} 

Answer 1

ich glaube, Sie verwenden Option profitieren können (http://danielwestheide.com/blog/2012/12/19/the-neophytes-guide-to-scala-part-5-the-option-type.html) und das Try-Objekt (http://danielwestheide.com/blog/2012/12/26/the-neophytes-guide-to-scala-part-6-error-handling-with-try.html)

Was Sie hier tun, alle Arbeiten zu stoppen, wenn ein Fehler (dh geschieht werfen Sie die Karte, um außerhalb) Eine bessere Möglichkeit besteht darin, den Fehler zu isolieren und ein Objekt zurückzugeben, das wir herausfiltern können. Nachfolgend finden Sie eine schnelle Umsetzung I

gemacht

package csv 

import play.api.libs.json.{JsObject, Json} 

import scala.io.Source 
import scala.util.Try 

object CsvParser extends App { 

    //Because a bad row can either != 4 columns or the age can not be a int we want to return an option that will be ignored by our caller 
    def toTuple(array : Array[String]): Option[(String, String, String, Int)] = { 
    array match { 
     //if our array has exactly 4 columns 
     case Array(name, media, gender, age) => Try((name, media, gender, age.toInt)).toOption 
     // any other array size will be ignored 
     case _ => None 
    } 
    } 

    def toJson(line: String): Option[JsObject] = { 
    val cols = line.split(",").map(_.trim) 
    toTuple(cols) match { 
     case Some((name: String, media: String, gender: String, age: Int)) => Some(Json.obj("Name" -> name, "Media" -> media, "Gender" -> gender, "Age" -> age)) 
     case _ => None 
    } 
    } 

    def parseFile(file: String): List[JsObject] = { 

    val bufferedSource = Source.fromFile(file) 
    try { bufferedSource.getLines().map(toJson).toList.flatten } finally { bufferedSource.close() } 

    } 

    parseFile("my/csv/file/path") 

} 

Der obige Code wird alle Zeilen ignorieren, wo es nicht genau 4 Spalten. Es enthält auch die NumberFormatException von .toInt.

Die Idee besteht darin, den Fehler zu isolieren und einen Typ zurückzugeben, mit dem der Aufrufer arbeiten kann, wenn die Zeile geparst wurde ... oder zu ignorieren, wenn ein Fehler aufgetreten ist.