diff --git a/backend/utils/sequelize.js b/backend/utils/sequelize.js index 29ab74e..a584d1c 100644 --- a/backend/utils/sequelize.js +++ b/backend/utils/sequelize.js @@ -3,8 +3,6 @@ import dotenv from 'dotenv'; dotenv.config(); - - const sequelize = new Sequelize(process.env.DB_NAME, process.env.DB_USER, process.env.DB_PASS, { host: process.env.DB_HOST, dialect: 'postgres', @@ -135,10 +133,10 @@ const checkSchemaForUpdates = async (schemaName, models) => { const tables = await sequelize.query(` SELECT table_name FROM information_schema.tables - WHERE table_schema = :schemaName + WHERE table_schema = $1 ORDER BY table_name `, { - replacements: { schemaName }, + bind: [schemaName], type: sequelize.QueryTypes.SELECT }); @@ -186,11 +184,11 @@ const checkForMissingTables = async (schemaName, models) => { const tableExists = await sequelize.query(` SELECT EXISTS ( SELECT FROM information_schema.tables - WHERE table_schema = :schemaName - AND table_name = :tableName + WHERE table_schema = $1 + AND table_name = $2 ); `, { - replacements: { schemaName, tableName: model.tableName }, + bind: [schemaName, model.tableName], type: sequelize.QueryTypes.SELECT }); @@ -221,11 +219,11 @@ const checkTableForUpdates = async (schemaName, tableName, models) => { const currentColumns = await sequelize.query(` SELECT column_name, data_type, is_nullable, column_default FROM information_schema.columns - WHERE table_schema = :schemaName - AND table_name = :tableName + WHERE table_schema = $1 + AND table_name = $2 ORDER BY ordinal_position `, { - replacements: { schemaName, tableName }, + bind: [schemaName, tableName], type: sequelize.QueryTypes.SELECT });