SCALA-268 (#1760)

* SCALA-268
Scala CSV Read/Write

* Naming convention fixed

Author: maenolis

build.sbt

@@ -442,7 +442,11 @@ lazy val scala_libraries = (project in file("scala-libraries"))
       "org.apache.logging.log4j" % "log4j-core" % "2.24.3" % Runtime,
       "com.typesafe.scala-logging" %% "scala-logging" % "3.9.5",
       "software.amazon.awssdk" % "s3" % "2.25.9",
-      "com.github.seratch" %% "awscala" % "0.9.2"
+      "com.github.seratch" %% "awscala" % "0.9.2",
+      "com.opencsv" % "opencsv" % "5.9",
+      "com.github.tototoshi" %% "scala-csv" % "2.0.0",
+      "org.apache.commons" % "commons-csv" % "1.12.0"
+
     ),
     libraryDependencies ++= Seq(
       "org.playframework" %% "play-slick" % LibraryVersions.playSlickVersion,

scala-libraries/src/main/resources/persons.csv

@@ -0,0 +1,4 @@
+id,name
+1,Jim
+2,Bob
+3,Mary

scala-libraries/src/main/scala/com/baeldung/csv/reader/ApacheCommonsCSVReader.scala

@@ -0,0 +1,24 @@
+package com.baeldung.csv.reader
+
+import org.apache.commons.csv.CSVFormat
+
+import java.io.{File, FileInputStream, InputStreamReader}
+import scala.jdk.CollectionConverters.IterableHasAsScala
+
+class ApacheCommonsCSVReader extends CommaSeparatedValuesReader {
+
+  override def read(file: File): CSVReadDigest = {
+    val in = new InputStreamReader(new FileInputStream(file))
+    val csvParser = CSVFormat.DEFAULT
+      .builder()
+      .setHeader()
+      .build()
+      .parse(in)
+    val result = CSVReadDigest(
+      csvParser.getHeaderNames.asScala.toSeq,
+      csvParser.getRecords.asScala.map(r => r.values().toSeq).toSeq
+    )
+    csvParser.close()
+    result
+  }
+}

scala-libraries/src/main/scala/com/baeldung/csv/reader/CSVReaders.scala

@@ -0,0 +1,23 @@
+package com.baeldung.csv.reader
+
+import java.io.File
+
+object CSVReaders {
+
+  def main(args: Array[String]): Unit = {
+
+    val apacheCommonsCSVReader = new ApacheCommonsCSVReader
+    val simpleCSVReader = new SimpleCSVReader
+    val scalaCSVReader = new ScalaCSVReader
+    val openCSVReader = new OpenCSVReader
+
+    val file = new File(getClass.getResource("/persons.csv").getFile)
+
+    println(apacheCommonsCSVReader.read(file))
+    println(simpleCSVReader.read(file))
+    println(scalaCSVReader.read(file))
+    println(openCSVReader.read(file))
+
+  }
+
+}

scala-libraries/src/main/scala/com/baeldung/csv/reader/CommaSeparatedValuesReader.scala

@@ -0,0 +1,10 @@
+package com.baeldung.csv.reader
+
+import java.io.File
+
+case class CSVReadDigest(headers: Seq[String], rows: Seq[Seq[String]])
+trait CommaSeparatedValuesReader {
+
+  def read(file: File): CSVReadDigest
+
+}

scala-libraries/src/main/scala/com/baeldung/csv/reader/OpenCSVReader.scala

@@ -0,0 +1,35 @@
+package com.baeldung.csv.reader
+
+import com.opencsv.CSVReader
+
+import java.io.{File, FileInputStream, InputStreamReader}
+import scala.annotation.tailrec
+
+class OpenCSVReader extends CommaSeparatedValuesReader {
+
+  override def read(file: File): CSVReadDigest = {
+
+    val reader = new CSVReader(
+      new InputStreamReader(new FileInputStream(file))
+    )
+
+    @tailrec
+    def readLinesRecursively(
+      currentReader: CSVReader,
+      result: Seq[Seq[String]]
+    ): Seq[Seq[String]] = {
+      currentReader.readNext() match {
+        case null => result
+        case line => readLinesRecursively(currentReader, result :+ line.toSeq)
+      }
+    }
+
+    val csvLines = readLinesRecursively(reader, List())
+    reader.close()
+
+    CSVReadDigest(
+      csvLines.head,
+      csvLines.tail
+    )
+  }
+}

scala-libraries/src/main/scala/com/baeldung/csv/reader/ScalaCSVReader.scala

@@ -0,0 +1,15 @@
+package com.baeldung.csv.reader
+
+import com.github.tototoshi.csv.CSVReader
+
+import java.io.File
+
+class ScalaCSVReader extends CommaSeparatedValuesReader {
+
+  override def read(file: File): CSVReadDigest = {
+    val reader = CSVReader.open(file)
+    val all = reader.all()
+    reader.close()
+    CSVReadDigest(all.head, all.tail)
+  }
+}

scala-libraries/src/main/scala/com/baeldung/csv/reader/SimpleCSVReader.scala

@@ -0,0 +1,36 @@
+package com.baeldung.csv.reader
+
+import java.io.{BufferedReader, File, FileInputStream, InputStreamReader}
+import scala.annotation.tailrec
+
+class SimpleCSVReader extends CommaSeparatedValuesReader {
+
+  override def read(file: File): CSVReadDigest = {
+    val in = new InputStreamReader(new FileInputStream(file))
+    val bufferedReader = new BufferedReader(in)
+
+    @tailrec
+    def readLinesRecursively(
+      currentBufferedReader: BufferedReader,
+      result: Seq[Seq[String]]
+    ): Seq[Seq[String]] = {
+      currentBufferedReader.readLine() match {
+        case null => result
+        case line =>
+          readLinesRecursively(
+            currentBufferedReader,
+            result :+ line.split(",").toSeq
+          )
+      }
+    }
+
+    val csvLines = readLinesRecursively(bufferedReader, List())
+
+    bufferedReader.close()
+
+    CSVReadDigest(
+      csvLines.head,
+      csvLines.tail
+    )
+  }
+}

scala-libraries/src/main/scala/com/baeldung/csv/writer/ApacheCommonsCSVWriter.scala

@@ -0,0 +1,25 @@
+package com.baeldung.csv.writer
+import org.apache.commons.csv.{CSVFormat, CSVPrinter}
+
+import java.io.{File, FileWriter}
+import scala.util.Try
+
+class ApacheCommonsCSVWriter extends CommaSeparatedValuesWriter {
+
+  override def write(
+    file: File,
+    headers: Seq[String],
+    rows: Seq[Seq[String]]
+  ): Try[Unit] = Try {
+
+    val csvFormat = CSVFormat.DEFAULT
+      .builder()
+      .setHeader(headers: _*)
+      .build()
+
+    val out = new FileWriter(file)
+    val printer = new CSVPrinter(out, csvFormat)
+    rows.foreach(row => printer.printRecord(row: _*))
+    printer.close()
+  }
+}

scala-libraries/src/main/scala/com/baeldung/csv/writer/CommaSeparatedValuesWriter.scala

@@ -0,0 +1,14 @@
+package com.baeldung.csv.writer
+
+import java.io.File
+import scala.util.Try
+
+trait CommaSeparatedValuesWriter {
+
+  def write(
+    file: File,
+    headers: Seq[String],
+    rows: Seq[Seq[String]]
+  ): Try[Unit]
+
+}