Scala中将null转为0问题：处理数据库空值求和报错

看起来你是在处理从数据库读取的可能为空的数值，直接调用.get会因为空值抛出异常对吧？别担心，Scala有很优雅的方式处理这种场景，分三种常见情况给你解决方案：

一、如果你的price/quantity是Scala原生的Option类型 #

这是Scala推荐的处理空值的方式，直接用getOrElse方法兜底即可，当值不存在（即None）时返回默认值0：

// 假设price和quantity是Option[Double]类型
val price: Option[Double] = ... // 可能是Some(10.5)或者None
val quantity: Option[Int] = ... // 可能是Some(5)或者None

// 计算总金额，空值自动转为0
val total = price.getOrElse(0.0) * quantity.getOrElse(0)

为什么之前报错？因为Option的.get方法只有在值存在（Some）时才有效，空值（None）调用.get会直接抛出NoSuchElementException，用getOrElse就完美规避了这个问题。

二、如果你的price/quantity是Java风格的null（比如JDBC直接返回的数值） #

如果是从数据库读取的Java类型（比如java.lang.Double，可能为null），先把它转成Scala的Option，再用上面的方法：

// 假设javaPrice和javaQuantity是可能为null的Java数值类型
val javaPrice: java.lang.Double = ... // 可能是10.5或者null
val javaQuantity: java.lang.Integer = ... // 可能是5或者null

// 把Java null转成Scala Option：null会变成None，非null值变成Some(值)
val scalaPrice = Option(javaPrice)
val scalaQuantity = Option(javaQuantity)

// 同样用getOrElse计算
val total = scalaPrice.getOrElse(0.0) * scalaQuantity.getOrElse(0)

甚至可以一步到位，不用单独转换：

val total = Option(javaPrice).getOrElse(0.0) * Option(javaQuantity).getOrElse(0)

三、如果是在Spark DataFrame中处理数据库数据 #

如果是用Spark操作数据库表的DataFrame，那用Spark SQL的函数更高效：
用coalesce函数，它会返回第一个非空的值，刚好适合我们的场景：

import org.apache.spark.sql.functions.{coalesce, lit}

// 假设df是从数据库读取的DataFrame，包含price和quantity列
val resultDF = df.withColumn(
  "total",
  coalesce(col("price"), lit(0.0)) * coalesce(col("quantity"), lit(0.0))
)

或者用when/otherwise的写法，逻辑更直观：

import org.apache.spark.sql.functions.{when, lit, col}

val resultDF = df.withColumn(
  "total",
  when(col("price").isNull, lit(0.0)).otherwise(col("price")) * 
  when(col("quantity").isNull, lit(0.0)).otherwise(col("quantity"))
)

这些方法都能确保空值被替换成0后再计算，不会抛出异常。

内容的提问来源于stack exchange，提问作者Jose Cabrera Zuniga