0

我正在使用 Scala - Spray - Sorm 开发一个 Rest API。我正在尝试在现有数据库上实现 Sorm 框架。保存、更新和删除已经可以正常工作，但是每当我尝试从数据库中查询某些内容时，它都会给我一个：

[ERROR] [07/22/2016 09:57:14.377] [on-spray-can-akka.actor.default-
dispatcher-5] [akka://on-spray-can/user/growficient-api] argument type mismatch:
Incorrect values of parameter types:
- long:
| class java.lang.Long:
| 91
- class java.lang.String:
| class org.joda.time.LocalDate:
| 2016-04-08
- class java.lang.String:
| class org.joda.time.LocalTime:
| 12:55:27.000
- int:
| class java.lang.Integer:
| 0
- int:
| class java.lang.Double:
| 2155.0
- int:
| class java.lang.Integer:
| 22
- int:
| class java.lang.Integer:
| 35
- int:
| class java.lang.Integer:
| -65

我的模型是：

object Samples extends DefaultJsonProtocol with SprayJsonSupport {
  implicit object samplesFormat extends RootJsonFormat[Samples] {
    override def read(value: JsValue) = {
      println(value)
      value.asJsObject.getFields("gatewayid", "sensorid", "date", "time", "wc", "ec", "temp", "battery", "rssi") match {
        case Seq(
          JsString(gatewayid),
          JsString(sensorid),
          JsString(date),
          JsString(time),
          JsNumber(wc),
          JsNumber(ec),
          JsNumber(temp),
          JsNumber(battery),
          JsNumber(rssi)
        ) =>
          new Samples(gatewayid, sensorid, date, time, wc.toInt, ec.toInt, temp.toInt, battery.toInt, rssi.toInt)
        case _ => throw new DeserializationException(s"$value is not properly formatted")
      }
    }

    override def write(s: Samples) = JsObject(
      "gatewayid" -> JsString(s.gatewayid),
      "sensorid" -> JsString(s.sensorid),
      "date" -> JsString(s.date),
      "time" -> JsString(s.time),
      "wc" -> JsNumber(s.wc),
      "ec" -> JsNumber(s.ec),
      "temp" -> JsNumber(s.temp),
      "battery" -> JsNumber(s.battery),
      "rssi" -> JsNumber(s.rssi)
    )
  }
}

case class Samples(gatewayid: String, sensorid: String, date: String, time: String, wc: Int, ec: Int, temp: Int, battery: Int, rssi: Int)

现在出于测试目的，我只是做一个简单的查询来获取所有内容：

object DB extends Instance(
    entities = Set(
      Entity[Samples]()
    ),
    url = s"jdbc:mysql://$addr:$port/$database",
    user = username,
    password = password,
    initMode = InitMode.Create
  )

  DB.query[Samples].fetch().toList

不幸的是，它在给定错误输出的查询中崩溃。我知道有些东西得到了错误的参数类型，但我不知道是什么。

如果有人能指出我正确的方向，我将不胜感激。

4

1 回答 1

1

罪魁祸首在那里：

- class java.lang.String:
| class org.joda.time.LocalDate:
| 2016-04-08
- class java.lang.String:
| class org.joda.time.LocalTime:
| 12:55:27.000

您应该在相应的字段上使用建议的 Joda 类型而不是 String。

于 2016-07-22T09:40:17.377 回答