Scala中的MongoDB编解码器坏了？

我有一个用Scala编写的应用程序来访问Mongo数据库，我可以在其中查询和插入数据。Scala中的MongoDB编解码器坏了？

然而，当我尝试使用collection.distinct("user")我得到的错误：

Unknown Error org.bson.codecs.configuration.CodecConfigurationException: 
    Can't find a codec for class scala.runtime.Nothing$.

做一些谷歌上搜索，我发现我需要指定的编解码器后，所以我initalised的MongoClient一个：

val clusterSettings = ClusterSettings 
    .builder() 
    .hosts(scala.collection.immutable.List(new com.mongodb.ServerAddress(addr)).asJava) 
    .build() 

val settings = MongoClientSettings.builder() 
       .codecRegistry(MongoClient.DEFAULT_CODEC_REGISTRY) 
       .clusterSettings(clusterSettings) 
       .build() 

val mongoClient: MongoClient = MongoClient(settings)

仍然没有运气，得到了同样的错误。

我想我会需要做一个自定义的编解码器as per this web page：

class NothingCodec extends Codec[Nothing] { 
    override def encode(writer:BsonWriter, value:Nothing, encoderContext:EncoderContext)={} 
    override def decode(reader: BsonReader, decoderContext: DecoderContext): Nothing = { 
     throw new Exception 
    } 
    override def getEncoderClass(): Class[Nothing] = { 
     classOf[Nothing] 
    } 
}

但是，这并不工作，也没有意义，没有什么是不是一个有效的返回类型; there exist no instances of this type。因此，这obekouly不工作与Unknown Error java.lang.Exception（显然！）的新错误

我错过了一些与Mongo Scala驱动程序？还是它刚刚坏了？

来源

2016-11-25 Soapy

或者你可以看看http://reactivemongo.org/ – cchantep

使用文档代替：

collection.distinct[Document]("user") 

// i.e. 

case class User(name: String, id: String) 

records.distinct[Document]("user") 
.toFuture() 
.map(_ map { doc => getUserFromBson(doc).get }) 

def getUserFromBson(doc: Document): Option[User] = { 
for { 
    name <- doc.get("name") map { x => x.asString().getValue } 
    id <- doc.get("id") map { x => x.asString().getValue } 
    }yield(User(name, id)) 
}

希望这会有所帮助。

来源

2016-11-25 23:41:18 EmiCareOfCell44

Scala中的MongoDB编解码器坏了？

回答

相关问题