0.0.17

build.sbt

@@ -11,7 +11,7 @@ licenses += ("Apache-2.0", url("http://www.apache.org/licenses/LICENSE-2.0"))
 publishMavenStyle := true
 
 name := "asta4e"
-version := "0.0.16"
+version := "0.0.17"
 
 scalaVersion := "2.11.12"
 crossScalaVersions := Seq("2.11.12", "2.12.8" /*, "2.13.0"*/)

src/main/scala/com/axtstar/asta4e/basic/CsvBasic.scala

@@ -22,6 +22,57 @@ trait CsvBasic extends DataCore with InitialCore [CsvBasic] {
     this
   }
 
+  def getColumnSize(iStream: FileInputStream)={
+    val parser = new CSVParserBuilder()
+      .withSeparator(separator)
+      .withQuoteChar(quoteChar)
+      .build()
+    val inputStreamReader = new InputStreamReader(iStream, encoding)
+    val reader = new CSVReaderBuilder(inputStreamReader)
+      .withCSVParser(parser)
+      .build()
+    try {
+
+      val oneLine = reader.readNext()
+      oneLine.size
+    } catch {
+      case ex:Throwable =>
+        throw ex
+    }
+    finally {
+      reader.close()
+      inputStreamReader.close()
+      iStream.close()
+    }
+
+  }
+
+  def getRowSize(iStream: FileInputStream)={
+    val parser = new CSVParserBuilder()
+      .withSeparator(separator)
+      .withQuoteChar(quoteChar)
+      .build()
+    val inputStreamReader = new InputStreamReader(iStream, encoding)
+    val reader = new CSVReaderBuilder(inputStreamReader)
+      .withCSVParser(parser)
+      .build()
+    try {
+
+      val oneLine = reader.readAll()
+      oneLine.size
+    } catch {
+      case ex:Throwable =>
+        throw ex
+    }
+    finally {
+      reader.close()
+      inputStreamReader.close()
+      iStream.close()
+    }
+
+  }
+
+
   override def _getData(iStream: FileInputStream): IndexedSeq[(String, Map[String, Any])] = {
     val parser = new CSVParserBuilder()
       .withSeparator(separator)

src/test/scala/com/axtstar/asta4e/csv/CsvTest.scala

@@ -229,7 +229,23 @@ class CsvTest extends Specification {
 
     }
 
+    "column size" in {
+      val target = CsvMapper
+        .getColumnSize(
+          new FileInputStream(s"${currentDir}/src/test/resources/csv/data.csv")
+        )
+
+      target must be_==(3)
+    }
 
+    "row size" in {
+      val target = CsvMapper
+        .getRowSize(
+          new FileInputStream(s"${currentDir}/src/test/resources/csv/data.csv")
+        )
+
+      target must be_==(2)
+    }
 
 
   }