2

我有以下文档结构：

{
    "moneys": {
      "someKey": NumberDecimal(99)
      ...
      "someOtherRandomKey": NumberDecimal(99)
    }
{

我想要什么：当不存在的字段增加时，使用 NumberDecimal值创建该字段。

我用 scala 驱动程序尝试过，但不能这样做：

//not compiles
collection.findOneAndUpdate(filters,Updates.inc("someOtherKey", new Decimal128(50)))

因为Updates.inc(k,v)需要Number； Decimal128不是Number

我认为问题不在驱动程序上，而在我的逻辑上。

如何使用 scala/java 驱动程序实现我的案例？

4

1 回答 1

3

通过实现编解码器解决的问题scala.math.BigDecimal：

class BigDecimalScalaCodec extends Codec[scala.math.BigDecimal] {

  override def encode(writer: BsonWriter, value: scala.math.BigDecimal, encoderContext: EncoderContext): Unit = {
    writer.writeDecimal128(new Decimal128(value.bigDecimal))
  }

  override def getEncoderClass: Class[scala.math.BigDecimal] = classOf[scala.math.BigDecimal]

  override def decode(reader: BsonReader, decoderContext: DecoderContext): scala.math.BigDecimal = {
    reader.readDecimal128().bigDecimalValue()
  }
}

在 mongo 中注册：

 val codecRegistry = fromRegistries(fromCodecs(new BigDecimalScalaCodec()), DEFAULT_CODEC_REGISTRY)

 val database: MongoDatabase = mongoClient.getDatabase("dbName")
    .withCodecRegistry(codecRegistry)

现在我们可以使用scala.math.BigDecimal：

collection.findOneAndUpdate(filters,Updates.inc("someOtherKey", BigDecimal(99))
于 2017-07-12T10:21:22.297 回答