View Javadoc
1   package fr.ifremer.quadrige2.synchro.intercept.administration;
2   
3   /*-
4    * #%L
5    * Quadrige2 Core :: Quadrige2 Synchro Core
6    * $Id:$
7    * $HeadURL:$
8    * %%
9    * Copyright (C) 2017 Ifremer
10   * %%
11   * This program is free software: you can redistribute it and/or modify
12   * it under the terms of the GNU Affero General Public License as published by
13   * the Free Software Foundation, either version 3 of the License, or
14   * (at your option) any later version.
15   * 
16   * This program is distributed in the hope that it will be useful,
17   * but WITHOUT ANY WARRANTY; without even the implied warranty of
18   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
19   * GNU General Public License for more details.
20   * 
21   * You should have received a copy of the GNU Affero General Public License
22   * along with this program.  If not, see <http://www.gnu.org/licenses/>.
23   * #L%
24   */
25  
26  import com.google.common.eventbus.Subscribe;
27  import fr.ifremer.common.synchro.dao.SynchroTableDao;
28  import fr.ifremer.common.synchro.intercept.SynchroInterceptorBase;
29  import fr.ifremer.common.synchro.intercept.SynchroOperationRepository;
30  import fr.ifremer.common.synchro.meta.SynchroTableMetadata;
31  import fr.ifremer.common.synchro.meta.event.CreateQueryEvent;
32  import fr.ifremer.common.synchro.query.SynchroQueryBuilder;
33  import fr.ifremer.common.synchro.query.SynchroQueryName;
34  import fr.ifremer.common.synchro.query.SynchroQueryOperator;
35  import fr.ifremer.quadrige2.synchro.meta.DatabaseColumns;
36  import fr.ifremer.quadrige2.synchro.meta.administration.ProgramStrategySynchroTables;
37  import fr.ifremer.quadrige2.synchro.service.referential.ReferentialSynchroDatabaseConfiguration;
38  
39  import java.sql.SQLException;
40  import java.util.List;
41  
42  /**
43   * Manage table PROGRAMME :
44   * <ul>
45   * <li>Delete children tables (STRATEGY)
46   * </ul>
47   * 
48   * @author Benoit Lavenier <benoit.lavenier@e-is.pro>
49   * @since 1.0
50   */
51  public class ProgramInterceptor extends AbstractProgramStrategyInterceptor {
52  
53  	/**
54  	 * <p>
55  	 * Constructor for ProgramInterceptor.
56  	 * </p>
57  	 */
58  	public ProgramInterceptor() {
59  		super(ProgramStrategySynchroTables.PROGRAMME.name());
60  		setEnableOnWrite(true);
61  	}
62  
63  	/** {@inheritDoc} */
64  	@Override
65  	protected void doOnDelete(List<Object> pk, SynchroTableDao sourceDao, SynchroTableDao targetDao, SynchroOperationRepository buffer)
66  			throws SQLException {
67  		// Getting the stratId
68  		String progCd = pk.get(0).toString();
69  
70  		// Delete children tables : STRATEGY
71  		buffer.addChildToDeleteFromOneColumn(ProgramStrategySynchroTables.STRATEGY.name(), DatabaseColumns.PROG_CD.name(), progCd);
72  	}
73  
74  }