如何从 Vapor 3 中的 JSON 响应中保存父子关系
How to save Parent-Child relation from a JSON response in Vapor 3
我正在使用 Vapor 3 开发 REST API。此 API 使用另一个 API 创建稍后将由应用程序使用的内容。
所以我创建了一个函数,从这个 API(联赛和赛季)中获取内容并将它们存储在我的 MySQL 数据库中。 API 的响应还包含我也想存储的嵌套对象,如果可能的话,它们都在同一个请求中。这是 API 响应:
{
"data": [
{
"id": 271,
"name": "Superliga",
"current_season_id": 16020,
"season": {
"data": {
"id": 16020,
"name": "2019/2020",
"league_id": 271,
}
}
}
]
}
模型如下:
final class League: MySQLModel {
var id: League.ID?
var name: String
var current_season_id: Season.ID
var currentSeason: Parent<League, Season> {
return parent(\League.current_season_id)
}
}
final class Season: MySQLModel {
var id: Season.ID?
var name: String
var league_id: League.ID
var league: Parent<Season, League> {
return parent(\.league_id)
}
}
这是执行请求并存储在数据库上的函数。
func getLeagues(using context: CommandContext) throws -> EventLoopFuture<Void> {
guard let url = URL(string: "SOME_API_URL") else { return .done(on: context.container) }
let client = try context.container.client()
return client.get(url).flatMap({ (response) -> EventLoopFuture<Void> in // do the request
let leagues = response.content.get([League].self, at: "data") // get the array of EventLoopFuture<[League]>
return context.container.requestPooledConnection(to: .mysql).flatMap({ (connection) -> EventLoopFuture<Void> in // connecto to DB
let savedLeagues = leagues.flatMap(to: [League].self, { (flattenLeagues) -> EventLoopFuture<[League]> in
return flattenLeagues.map { (league) -> EventLoopFuture<League> in
return league.create(orUpdate: true, on: connection) // save on the DB
}.flatten(on: context.container)
})
return savedLeagues.flatMap { (_) -> EventLoopFuture<Void> in
return .done(on: context.container)
}
})
})
}
问题是:可以保存父子关系吗?我必须使用 decode/encode 函数手动完成吗?
我确实实现了 encode/decode 并创建了联赛,但不知道如何创建赛季以及在执行 league.create(orUpdate: true, on: connection)
时如何保存所有内容
如有任何帮助,我们将不胜感激。
如我所见,您可以先解码 APIModel
,然后像这样将两个对象保存在展平循环中
struct APILeague: Content {
let id: League.ID
let name: String
let current_season_id: Season.ID
struct _Season: Codable {
let data: Season
}
let season: _Season
}
final class League: MySQLModel {
var id: League.ID?
var name: String
var current_season_id: Season.ID
var currentSeason: Parent<League, Season> {
return parent(\League.current_season_id)
}
init (_ data: APILeague) {
self.id = data.id
self.name = data.name
self.current_season_id = data.current_season_id
}
}
func getLeagues(using context: CommandContext) throws -> Future<Void> {
guard let url = URL(string: "SOME_API_URL") else { return .done(on: context.container) }
let client = try context.container.client()
return client.get(url).flatMap { response in // do the request
return response.content.get([APILeague].self, at: "data").flatMap { leagues in
return context.container.requestPooledConnection(to: .mysql).flatMap { connection in // connecto to DB
let operations = leagues.map { league in
return League(league).create(orUpdate: true, on: connection).flatMap { _ in
return league.season.data.create(orUpdate: true, on: connection).transform(to: ()) // transforming to Void
}
}
return operations.flatten(on: context.container)flatMap {
return .done(on: context.container)
}
}
}
}
}
我正在使用 Vapor 3 开发 REST API。此 API 使用另一个 API 创建稍后将由应用程序使用的内容。 所以我创建了一个函数,从这个 API(联赛和赛季)中获取内容并将它们存储在我的 MySQL 数据库中。 API 的响应还包含我也想存储的嵌套对象,如果可能的话,它们都在同一个请求中。这是 API 响应:
{
"data": [
{
"id": 271,
"name": "Superliga",
"current_season_id": 16020,
"season": {
"data": {
"id": 16020,
"name": "2019/2020",
"league_id": 271,
}
}
}
]
}
模型如下:
final class League: MySQLModel {
var id: League.ID?
var name: String
var current_season_id: Season.ID
var currentSeason: Parent<League, Season> {
return parent(\League.current_season_id)
}
}
final class Season: MySQLModel {
var id: Season.ID?
var name: String
var league_id: League.ID
var league: Parent<Season, League> {
return parent(\.league_id)
}
}
这是执行请求并存储在数据库上的函数。
func getLeagues(using context: CommandContext) throws -> EventLoopFuture<Void> {
guard let url = URL(string: "SOME_API_URL") else { return .done(on: context.container) }
let client = try context.container.client()
return client.get(url).flatMap({ (response) -> EventLoopFuture<Void> in // do the request
let leagues = response.content.get([League].self, at: "data") // get the array of EventLoopFuture<[League]>
return context.container.requestPooledConnection(to: .mysql).flatMap({ (connection) -> EventLoopFuture<Void> in // connecto to DB
let savedLeagues = leagues.flatMap(to: [League].self, { (flattenLeagues) -> EventLoopFuture<[League]> in
return flattenLeagues.map { (league) -> EventLoopFuture<League> in
return league.create(orUpdate: true, on: connection) // save on the DB
}.flatten(on: context.container)
})
return savedLeagues.flatMap { (_) -> EventLoopFuture<Void> in
return .done(on: context.container)
}
})
})
}
问题是:可以保存父子关系吗?我必须使用 decode/encode 函数手动完成吗?
我确实实现了 encode/decode 并创建了联赛,但不知道如何创建赛季以及在执行 league.create(orUpdate: true, on: connection)
如有任何帮助,我们将不胜感激。
如我所见,您可以先解码 APIModel
,然后像这样将两个对象保存在展平循环中
struct APILeague: Content {
let id: League.ID
let name: String
let current_season_id: Season.ID
struct _Season: Codable {
let data: Season
}
let season: _Season
}
final class League: MySQLModel {
var id: League.ID?
var name: String
var current_season_id: Season.ID
var currentSeason: Parent<League, Season> {
return parent(\League.current_season_id)
}
init (_ data: APILeague) {
self.id = data.id
self.name = data.name
self.current_season_id = data.current_season_id
}
}
func getLeagues(using context: CommandContext) throws -> Future<Void> {
guard let url = URL(string: "SOME_API_URL") else { return .done(on: context.container) }
let client = try context.container.client()
return client.get(url).flatMap { response in // do the request
return response.content.get([APILeague].self, at: "data").flatMap { leagues in
return context.container.requestPooledConnection(to: .mysql).flatMap { connection in // connecto to DB
let operations = leagues.map { league in
return League(league).create(orUpdate: true, on: connection).flatMap { _ in
return league.season.data.create(orUpdate: true, on: connection).transform(to: ()) // transforming to Void
}
}
return operations.flatten(on: context.container)flatMap {
return .done(on: context.container)
}
}
}
}
}