Estoy tratando de aprender a usar knex.js y, como parte de mi aprendizaje, quiero realizar una migración en mi base de datos, quiero actualizar una de mis columnas. Estoy tratando de hacer esto con fragmentos (sé que no es la mejor solución, es solo para fines de aprendizaje). Estoy usando MySQL. En mi base de datos tengo una tabla que contiene la columna "correo electrónico", algunas de las filas terminan con ".com". Estoy tratando de actualizar esta columna omitiendo ".com". En mi código, selecciono las columnas relevantes y estoy usando dash lib para fragmentar todos mis datos. Mis datos fragmentados se ven así:
mi base de datos: ( https://ibb.co/c8kKtcb )
trozo n° 1
[
RowDataPacket {id: 1, correo electrónico: dan@gmail.com},
RowDataPacket {id: 2, correo electrónico: john@gmail},
RowDataPacket {id: 3, correo electrónico: steph@gmail},
]
trozo no.2
[
RowDataPacket {id: 4, correo electrónico: eric@gmail},
RowDataPacket {id: 5, correo electrónico: tommy@gmail.com},
RowDataPacket {id: 6, correo electrónico: bill@gmail.com},
]
trozo no.3
[
RowDataPacket {id: 7, correo electrónico: loe@gmail},
RowDataPacket {id: 8, correo electrónico: helen@gmail.com},
RowDataPacket {id: 9, correo electrónico: niky@gmail.com},
]
…
Este es mi código, traté de hacer la actualización, pero me imagino que estoy haciendo algo mal, ya que su método de lista final .update() funciona con el valor clave. ¿Puedo manipular mis datos?
exports.up = async knex => { const users = await knex("usersWeb") .select("id", "email") .where("email", "like", "%.com"); const userChunks = _.chunk(users, 3); let chunckNumber = 1; for (const chunk of userChunks) { console.log("Chunck number: ", chunckNumber); const k = await knex("usersWeb") .whereIn(columnId, chunk.map(item => item.id)) .update("email": ); // this line :( } chunckNumber++; } exports.down = async knex => {};
Lo resuelvo después de un tiempo y olvidé compartir mi solución, así que aquí está:
exports.up = async knex => { const users = await knex("usersWeb") .select("id") .where("email", "like", "%.com"); const userChunks = _.chunk(users, 3); let chunckNumber = 1; for (const chunk of userChunks) { console.log("Chunck number: ", chunckNumber); const tupleOfAllEmailIds = "(" + chunk.map(item => `${item.id}`).join(", ") + ")"; const query = `UPDATE "usersWeb" SET "email" = REPLACE("email", ".com", "") WHERE id IN ${tupleOfAllEmailIds} `; await knex.raw(query); } chunckNumber++; } exports.down = async knex => {};