Scala MongoDB, override codec to write/read Array[Byte]

Question

I am using http://mongodb.github.io/mongo-scala-driver/

I am defining codec for one CC.

 lazy val userInfoCodec: Codec[UserInfo] = new Codec[UserInfo] {

    override def encode(writer: BsonWriter, value: UserInfo, encoderContext: EncoderContext): Unit = ???
    override def decode(reader: BsonReader, decoderContext: DecoderContext): UserInfo = ???
}

Inside I am doing encryption, so fields instead of being Strings are Array[Byte]. Do you know how to use BsonWriter to write bytes array there ? I saw some stuff like writeStartArray, but I dont get how to use it.

Thanks for help!

I don't think you need to write a real BSON Array, but instead you may give a look to the BsonBinary type which takes a byte[] as its data argument. (the BsonWriter API exposes a method for writing BinaryData). - Other option would be to encode the byte[] as a Base64 String after doing the encryption. — Luis Miguel Mejía Suárez
– Luis Miguel Mejía Suárez, Commented Jan 15, 2019 at 21:23

sarveshseri · Accepted Answer · 2019-01-16 06:41:07Z

3

case class UserInfo(ab: Array[Byte])

val userInfoCodec: Codec[UserInfo] = new Codec[UserInfo] {
  override def getEncoderClass: Class[UserInfo] = classOf[UserInfo]

  override def encode(writer: BsonWriter, value: UserInfo, encoderContext: EncoderContext): Unit = {
    val bsonBinary = new BsonBinary(value.ab)
    writer.writeBinaryData(bsonBinary)
  }



  override def decode(reader: BsonReader, decoderContext: DecoderContext): UserInfo = {
    val bsonBinary = reader.readBinaryData()
    UserInfo(bsonBinary.getData)
  }
}

answered Jan 16, 2019 at 6:41

sarveshseri

14k30 silver badges50 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

Scala MongoDB, override codec to write/read Array[Byte]

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related