Skip to content

Commit 4ff4189

Browse files
committed
Avoid overloading confusion
1 parent f4ae78f commit 4ff4189

File tree

3 files changed

+11
-11
lines changed

3 files changed

+11
-11
lines changed

mysql-async/src/main/scala/com/github/mauricio/async/db/mysql/encoder/PreparedStatementExecuteEncoder.scala

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -36,12 +36,12 @@ class PreparedStatementExecuteEncoder( rowEncoder : BinaryRowEncoder ) extends M
3636
if ( m.parameters.isEmpty ) {
3737
buffer
3838
} else {
39-
Unpooled.wrappedBuffer(buffer, encode(m.values))
39+
Unpooled.wrappedBuffer(buffer, encodeValues(m.values))
4040
}
4141

4242
}
4343

44-
private[encoder] def encode( values : Seq[Any] ) : ByteBuf = {
44+
private[encoder] def encodeValues( values : Seq[Any] ) : ByteBuf = {
4545
val nullBitsCount = (values.size + 7) / 8
4646
val nullBits = new Array[Byte](nullBitsCount)
4747
val bitMapBuffer = ByteBufferUtils.mysqlBuffer(1 + nullBitsCount)
@@ -57,8 +57,8 @@ class PreparedStatementExecuteEncoder( rowEncoder : BinaryRowEncoder ) extends M
5757
parameterTypesBuffer.writeShort(ColumnTypes.FIELD_TYPE_NULL)
5858
} else {
5959
value match {
60-
case Some(v) => encode(parameterTypesBuffer, parameterValuesBuffer, v)
61-
case _ => encode(parameterTypesBuffer, parameterValuesBuffer, value)
60+
case Some(v) => encodeValue(parameterTypesBuffer, parameterValuesBuffer, v)
61+
case _ => encodeValue(parameterTypesBuffer, parameterValuesBuffer, value)
6262
}
6363
}
6464
index += 1
@@ -74,7 +74,7 @@ class PreparedStatementExecuteEncoder( rowEncoder : BinaryRowEncoder ) extends M
7474
Unpooled.wrappedBuffer( bitMapBuffer, parameterTypesBuffer, parameterValuesBuffer )
7575
}
7676

77-
private def encode(parameterTypesBuffer: ByteBuf, parameterValuesBuffer: ByteBuf, value: Any): Unit = {
77+
private def encodeValue(parameterTypesBuffer: ByteBuf, parameterValuesBuffer: ByteBuf, value: Any): Unit = {
7878
val encoder = rowEncoder.encoderFor(value)
7979
parameterTypesBuffer.writeShort(encoder.encodesTo)
8080
if (!encoder.isLong(value))

mysql-async/src/main/scala/com/github/mauricio/async/db/mysql/encoder/SendLongDataEncoder.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,10 @@ class SendLongDataEncoder( rowEncoder : BinaryRowEncoder ) extends MessageEncode
1515
buffer.writeBytes(m.statementId)
1616
buffer.writeShort(m.paramId)
1717

18-
Unpooled.wrappedBuffer(buffer, encodeLong(m.value))
18+
Unpooled.wrappedBuffer(buffer, encodeValue(m.value))
1919
}
2020

21-
private def encodeLong( maybeValue: Any ) : ByteBuf = {
21+
private def encodeValue( maybeValue: Any ) : ByteBuf = {
2222
if ( maybeValue == null || maybeValue == None ) {
2323
throw new UnsupportedOperationException("Cannot encode NULL as long value")
2424
} else {

mysql-async/src/test/scala/com/github/mauricio/async/db/mysql/encoder/PreparedStatementExecuteEncoderSpec.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,16 +27,16 @@ class PreparedStatementExecuteEncoderSpec extends Specification {
2727
"binary row encoder" should {
2828

2929
"encode Some(value) like value" in {
30-
val actual = encoder.encode(List(Some(1l), Some("foo")))
31-
val expected = encoder.encode(List(1l, "foo"))
30+
val actual = encoder.encodeValues(List(Some(1l), Some("foo")))
31+
val expected = encoder.encodeValues(List(1l, "foo"))
3232

3333
actual mustEqual expected
3434

3535
}
3636

3737
"encode None as null" in {
38-
val actual = encoder.encode(List(None))
39-
val expected = encoder.encode(List(null))
38+
val actual = encoder.encodeValues(List(None))
39+
val expected = encoder.encodeValues(List(null))
4040

4141
actual mustEqual expected
4242
}

0 commit comments

Comments
 (0)