diff --git a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20251212182900.java b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20251212182900.java index 86898b466c..2bc5faa782 100644 --- a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20251212182900.java +++ b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20251212182900.java @@ -1,15 +1,29 @@ -package it.integry.ems.migration.model;import it.integry.ems.migration._base.BaseMigration; +package it.integry.ems.migration.model; + +import it.integry.ems.migration._base.BaseMigration; +import it.integry.ems.migration._base.IntegryCustomerDB; import it.integry.ems.migration._base.MigrationModelInterface; -public class Migration_20251212182900 extends BaseMigration implements MigrationModelInterface{ +public class Migration_20251212182900 extends BaseMigration implements MigrationModelInterface { @Override - public void up()throws Exception { - if(isHistoryDB()) + public void up() throws Exception { + if (isHistoryDB()) return; + + if (isCustomerDb(IntegryCustomerDB.FolliesGroup_FolliesGroup)) { + executeStatement("delete from mtb_aart_anag\n" + + "from (select mtb_aart_anag.cod_anag, mtb_aart_anag.cod_mart, mtb_aart_anag.cod_col, mtb_aart_anag.cod_tagl, max(id) as id \n" + + "\t\tfrom (select cod_anag, cod_mart, cod_col, cod_tagl, row_number() over (partition by cod_anag, cod_mart, cod_col, cod_tagl order by cod_anag, cod_mart, cod_col, cod_tagl, id desc) as riga \n" + + "\t\tfrom dbo.mtb_aart_anag \n" + + "\t\t)error inner join mtb_aart_anag on mtb_aart_anag.cod_anag = error.cod_anag and \n" + + "\t\t\t\t\t\t\t\t\t\t\tmtb_aart_anag.cod_mart = error.cod_mart \n" + + "where riga > 1 \n" + + "group by mtb_aart_anag.cod_anag, mtb_aart_anag.cod_col, mtb_aart_anag.cod_tagl, mtb_aart_anag.cod_mart)rowDelete inner join mtb_aart_anag on rowDelete.id = mtb_aart_anag.id"); + } } @Override - public void down()throws Exception { + public void down() throws Exception { } } \ No newline at end of file