keevol
diff --git a/‎db-async-common/src/main/scala/com/github/mauricio/async/db/general/ArrayRowData.scala
Lines changed: 1 addition & 16 deletions b/‎db-async-common/src/main/scala/com/github/mauricio/async/db/general/ArrayRowData.scala
Lines changed: 1 addition & 16 deletions
diff --git a/‎db-async-common/src/main/scala/com/github/mauricio/async/db/general/MutableResultSet.scala
Lines changed: 2 additions & 8 deletions b/‎db-async-common/src/main/scala/com/github/mauricio/async/db/general/MutableResultSet.scala
Lines changed: 2 additions & 8 deletions
diff --git a/‎mysql-async/src/main/scala/com/github/mauricio/async/db/mysql/binary/BinaryRowDecoder.scala
Lines changed: 2 additions & 2 deletions b/‎mysql-async/src/main/scala/com/github/mauricio/async/db/mysql/binary/BinaryRowDecoder.scala
Lines changed: 2 additions & 2 deletions
@@ -17,14 +17,10 @@
 package com.github.mauricio.async.db.general
 
 import com.github.mauricio.async.db.RowData
-import scala.collection.mutable
 
-class ArrayRowData( columnCount : Int, row : Int, val mapping : Map[String, Int] )
-  extends RowData
+class ArrayRowData(row : Int, val mapping : Map[String, Int], val columns : Array[Any]) extends RowData
 {
 
-  private val columns = new Array[Any](columnCount)
-
   /**
    *
    * Returns a column value by it's position in the originating query.
@@ -51,16 +47,5 @@ class ArrayRowData( columnCount : Int, row : Int, val mapping : Map[String, Int]
    */
   def rowNumber: Int = row
 
-  /**
-   *
-   * Sets a value to a column in this collection.
-   *
-   * @param i
-   * @param x
-   */
-
-  def update(i: Int, x: Any) = columns(i) = x
-
   def length: Int = columns.length
-
 }
@@ -39,14 +39,8 @@ class MutableResultSet[T <: ColumnData](
 
   override def apply(idx: Int): RowData = this.rows(idx)
 
-  def addRow( row : Seq[Any] ) {
-    val realRow = new ArrayRowData( columnTypes.size, this.rows.size, this.columnMapping )
-    var x = 0
-    while ( x < row.size ) {
-      realRow(x) = row(x)
-      x += 1
-    }
-    this.rows += realRow
+  def addRow(row : Array[Any] ) {
+    this.rows += new ArrayRowData(this.rows.size, this.columnMapping, row)
   }
 
 }
@@ -31,7 +31,7 @@ class BinaryRowDecoder {
 
   //import BinaryRowDecoder._
 
-  def decode(buffer: ByteBuf, columns: Seq[ColumnDefinitionMessage]): IndexedSeq[Any] = {
+  def decode(buffer: ByteBuf, columns: Seq[ColumnDefinitionMessage]): Array[Any] = {
 
     //log.debug("columns are {} - {}", buffer.readableBytes(), columns)
     //log.debug( "decoding row\n{}", MySQLHelper.dumpAsHex(buffer))
@@ -79,7 +79,7 @@ class BinaryRowDecoder {
       throw new BufferNotFullyConsumedException(buffer)
     }
 
-    row
+    row.toArray
   }
 
 }
Original file line number	Diff line number	Diff line change
`@@ -39,14 +39,8 @@ class MutableResultSet[T <: ColumnData](`
`39`	`39`
`40`	`40`	`override def apply(idx: Int): RowData = this.rows(idx)`
`41`	`41`
`42`		`- def addRow( row : Seq[Any] ) {`
`43`		`- val realRow = new ArrayRowData( columnTypes.size, this.rows.size, this.columnMapping )`
`44`		`- var x = 0`
`45`		`- while ( x < row.size ) {`
`46`		`- realRow(x) = row(x)`
`47`		`- x += 1`
`48`		`- }`
`49`		`- this.rows += realRow`
	`42`	`+ def addRow(row : Array[Any] ) {`
	`43`	`+ this.rows += new ArrayRowData(this.rows.size, this.columnMapping, row)`
`50`	`44`	`}`
`51`	`45`
`52`	`46`	`}`
Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ class BinaryRowDecoder {`
`31`	`31`
`32`	`32`	`//import BinaryRowDecoder._`
`33`	`33`
`34`		`- def decode(buffer: ByteBuf, columns: Seq[ColumnDefinitionMessage]): IndexedSeq[Any] = {`
	`34`	`+ def decode(buffer: ByteBuf, columns: Seq[ColumnDefinitionMessage]): Array[Any] = {`
`35`	`35`
`36`	`36`	`//log.debug("columns are {} - {}", buffer.readableBytes(), columns)`
`37`	`37`	`//log.debug( "decoding row\n{}", MySQLHelper.dumpAsHex(buffer))`
`@@ -79,7 +79,7 @@ class BinaryRowDecoder {`
`79`	`79`	`throw new BufferNotFullyConsumedException(buffer)`
`80`	`80`	`}`
`81`	`81`
`82`		`- row`
	`82`	`+ row.toArray`
`83`	`83`	`}`
`84`	`84`
`85`	`85`	`}`