scala - 如何将 Slick 结果转换为所需格式?
问题描述
我有类型的域对象,Person
它在案例类中定义如下:
case class Person(personName: String, personAge: Int, personId: Long = 0)
对应的查询表如下:
final case class PersonTable(tag: Tag) extends Table[Person](tag, "people") {
def personId = column[Long]("person_id", O.AutoInc, O.PrimaryKey)
def personName = column[String]("person_name")
def age = column[Int]("person_age")
def * = (personName, age, personId).mapTo[Person]
}
我有类型的域对象,Address
它在案例类中定义如下:
case class Address(houseNumber: Int, street: String
, state: String, ownerId: Long, id: Long = 0)
其对应的表类定义如下。人和地址是一对多的关系(一个人可以有多个地址,但一个地址只属于一个人)
final case class AddressTable(tag: Tag) extends Table[Address](tag, "addresses") {
def houseNumber = column[Int]("house_number")
def street = column[String]("street_name")
def state = column[String]("state_name")
def addressId = column[Long]("address_id", O.PrimaryKey, O.AutoInc)
def ownerId = column[Long]("owner_id")
def owner = foreignKey("owner_fk", ownerId, TableQuery[PersonTable])(_.personId, onDelete = ForeignKeyAction.Cascade)
def * = (houseNumber, street, state, ownerId, addressId).mapTo[Address]
}
我想从基于我Akka-http
的 REST API 返回以下类型的 JSON 结果(地址应作为数组返回):
{
"name": "shekhar",
"age": 30,
"id": 1234,
"addresses": [{
"house_number": 1,
"street": "water street",
"state": "foo bar",
"owner_id": 1234,
"address_id": 9874
},
{
"house_number": 99,
"street": "foo bar street",
"state": "foo disk state",
"owner_id": 1234,
"address_id": 007
}
]
}
为了得到这个结果,我使用 Slick 编写了查询,如下所示:
val peopleQueries = TableQuery[PersonTable]
val addressQueries = TableQuery[AddressTable]
val query = peopleQueries.filter(_.personName === "Shekhar") joinLeft addressQueries on (_.personId === _.ownerId)
val futureResultData = db.run(query.result)
我在以下结构中得到了结果(每个地址都重复了个人详细信息):
Vector(
(Person("shekhar",30,1234),
Some(Address(1,"Water Street","foo bar",1234,9874))
)
, (Person("shekhar",30,1234),
Some(Address(99,"foo bar street","foo disk state",1234,007))
)
)
要将上述内容转换为预期的 JSON 格式,我可以等到 DB 查询运行并编写一些 Scala 代码以使其具有所需的格式,但这会阻止请求,直到此后处理完成(如果我错了,请纠正我) )。
我的代码如下所示:
futureResultData.onComplete {
case Success(data) => // code to bring data in desired format
}
我想知道是否有任何方法可以异步/非阻塞方式获得结果?
感谢Pedro,我能够找到解决这个问题的方法。
对我有用的解决方案如下:
futureResultData.map( x => {
x.groupBy(_._1).mapValues(_.map(_._2.get))
})
解决方案
futureResultData.map {
_.transformInDesiredFormat // code to bring data in desired format
}
如果您发布转换的实际代码,我可以为您提供更多帮助
Futures 是 monad,所以当你映射时,你使用的是那个未来的东西,如果你有一个 Future[Int] 并且你映射了那个 Future,那么你在映射中使用 Int。
例子:
val aFuture = Future.successful(1)
aFuture.map(f=> f+ 1)
推荐阅读
- powershell - 如何使用 powershell 将机器名称和应用程序信息导出到 csv
- javascript - 如何集成代码以将 Zapier 连接到 Webflow?
- excel - VBA宏在下载后第一次不工作
- woocommerce - 如何在 WooCommerce 中按付款方式对订单进行排序?
- c - 为什么我不能通过这段代码得到正确的输出?
- linux - 如何监视文件并在终端中打印出更改(使用 inotify)?
- php - 有没有办法选择需要本地作曲家包?
- java - 如何在后续请求中修复错误“每个 RabbitTemplate 仅支持一个 ConfirmCallback”
- c# - 使用 c# 反转字符串
- ios - touchesBegan 在 iOS 12 中被调用,但在 iOS 13 中未被调用