在scala中将CassandraRow转换为JSON form字符串

libraryDependencies += "com.datastax.cassandra" % "cassandra-driver-core" % "4.13.0"

import com.datastax.driver.core.{Row, DataType}
import com.datastax.driver.core.utils.UUIDs
import org.json4s._
import org.json4s.jackson.Serialization
import org.json4s.jackson.Serialization.write

def cassandraRowToJson(row: Row): String = {
  implicit val formats: DefaultFormats.type = DefaultFormats
  val columns = row.getColumnDefinitions.asList()

  val jsonMap = columns.foldLeft(Map.empty[String, Any]) { (acc, column) =>
    val columnName = column.getName
    val columnValue = row.getObject(columnName)

    val jsonValue = column.getType.getName match {
      case DataType.Name.UUID => columnValue.toString
      case DataType.Name.TIMESTAMP => columnValue.asInstanceOf[java.util.Date].getTime
      case _ => columnValue
    }

    acc + (columnName -> jsonValue)
  }

  write(jsonMap)
}

val cassandraRow: Row = ... // 从Cassandra查询结果中获取的CassandraRow对象
val jsonString: String = cassandraRowToJson(cassandraRow)