Actualmente estoy luchando por hacer un upsert con vapor/fluidez. Tengo un modelo algo como esto:
struct DeviceToken: PostgreSQLModel { var id: Int? var token: String var updatedAt: Date = Date() init(id: Int? = nil, token: String, updatedAt: Date = Date()) { self.id = id self.token = token self.updatedAt = updatedAt } } struct Account: PostgreSQLModel { var id: Int? let username: String let service: String ... let deviceTokenId: DeviceToken.ID init(id: Int? = nil, service: String, username: String, ..., deviceTokenId: DeviceToken.ID) { self.id = id self.username = username .... self.deviceTokenId = deviceTokenId } }Del cliente algo como
{ "deviceToken": { "token": "ab123", "updatedAt": "01-01-2019 10:10:10" }, "account": { "username": "user1", "service": "some service" } }es enviar
Lo que me gustaría hacer es insertar los nuevos modelos si no existen, sino actualizarlos. Vi el método create(orUpdate:) , sin embargo, esto solo se actualizará si la identificación es la misma (según tengo entendido). Dado que el cliente no envía la identificación, no estoy muy seguro de cómo manejar esto.
Además, no puedo decodificar el modelo ya que la cuenta se envía sin el deviceTokenId y, por lo tanto, la decodificación fallará. Supongo que puedo abordar el último problema anulando NodeCovertible o usando dos modelos diferentes (uno para decodificar el json sin la identificación y el modelo real de arriba). Sin embargo, el primer problema aún permanece.
Lo que quiero hacer exactamente es:
Actualice un DeviceToken si ya existe una entrada con token; de lo contrario, créelo
Si ya existe una cuenta con la combinación de nombre de usuario y servicio, actualice su nombre de usuario, servicio y deviceTokenId; de lo contrario, créela. DeviceTokenId es la identificación devuelta por 1.
¿Alguna posibilidad de que me puedas ayudar aquí?
Para todos los que estén interesados: lo resolví escribiendo una extensión en PostgreSQLModel para proporcionar un método upsert. Agregué una esencia para que le eches un vistazo: aquí .
Dado que este tipo de enlaces a veces se rompen cuando necesita la información aquí una descripción general rápida:
Implementación real upsert:
extension QueryBuilder where Result: PostgreSQLModel, Result.Database == Database { /// Creates the model or updates it depending on whether a model /// with the same ID already exists. internal func upsert(_ model: Result, columns: [PostgreSQLColumnIdentifier]) -> Future<Result> { let row = SQLQueryEncoder(PostgreSQLExpression.self).encode(model) /// remove id from row if not available /// otherwise the not-null constraint will break row = row.filter { (key, value) -> Bool in if key == "id" && value.isNull { return false } return true } let values = row .map { row -> (PostgreSQLIdentifier, PostgreSQLExpression) in return (.identifier(row.key), row.value) } self.query.upsert = .upsert(columns, values) return create(model) } }Métodos de conveniencia
extension PostgreSQLModel { /// Creates the model or updates it depending on whether a model /// with the same ID already exists. internal func upsert(on connection: DatabaseConnectable) -> Future<Self> { return Self .query(on: connection) .upsert(self, columns: [.keyPath(Self.idKey)]) } internal func upsert<U>(on connection: DatabaseConnectable, onConflict keyPath: KeyPath<Self, U>) -> Future<Self> { return Self .query(on: connection) .upsert(self, columns: [.keyPath(keyPath)]) } .... }Resolví el otro problema que tenía de que mi modelo de base de datos no se podía decodificar ya que la identificación no se envió desde el cliente, usando una estructura interna que contendría solo las propiedades que enviaría el cliente. La identificación y otras propiedades generadas por la base de datos están en la estructura externa. Algo como:
struct DatabaseModel: PostgreSQLModel { var id: Int? var someProperty: String init(id: Int? = nil, form: DatabaseModelForm) { self.id = id self.someProperty = form.someProperty } struct DatabaseModelForm: Content { let someProperty: String } }