使用scala写一些数据处理的时候,有的时候需要使用到json数据的解析。查了下资料,在spark或者flink中包含的有json解析工具包。如果只是scala的话,可能就需要添加上相应的json解析的包。
compile group: 'com.fasterxml.jackson.module', name: 'jackson-module-scala_2.13', version: '2.10.4'
> 官方文档: https://github.com/FasterXML/jackson-module-scala
case class和json字符串互相转换。
import com.fasterxml.jackson.databind.ObjectMapper
import com.fasterxml.jackson.module.scala.{DefaultScalaModule, ScalaObjectMapper}
case class Person(name: String, age :Int, habbit:List[String],isStudent: Boolean)
object JSONScalaDemo {
def main(args: Array[String]): Unit = {
val bigBoy = Person("shuaige", 18, List("Reading", "Swimming"), isStudent = true)
// object --> json
val jsonMapper = new ObjectMapper()
jsonMapper.registerModule(DefaultScalaModule)
val v = jsonMapper.writeValueAsString(bigBoy)
println(v)
// json--> object
val mapper = new ObjectMapper() with ScalaObjectMapper
mapper.registerModule(DefaultScalaModule)
val o = mapper.readValue[Map[String, Object]](v)
println(o)
}
}
case class转为json的时候需要注意, 注册默认模型。DefaultScalaModule是一个Scala对象,支持所有当前Scala支持的数据类型。
val jsonMapper = new ObjectMapper()
jsonMapper.registerModule(DefaultScalaModule)