package fr.ifremer.quadrige3.synchro.server.meta;
   
   /*-
    * #%L
    * Quadrige3 Core :: Quadrige3 Synchro server
    * $Id:$
    * $HeadURL:$
    * %%
    * Copyright (C) 2017 Ifremer
   * %%
   * This program is free software: you can redistribute it and/or modify
   * it under the terms of the GNU Affero General Public License as published by
   * the Free Software Foundation, either version 3 of the License, or
   * (at your option) any later version.
   *
   * This program is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU General Public License for more details.
   *
   * You should have received a copy of the GNU Affero General Public License
   * along with this program.  If not, see <http://www.gnu.org/licenses/>.
   * #L%
   */
  
  import com.google.common.collect.Sets;
  import fr.ifremer.common.synchro.config.SynchroConfiguration;
  import fr.ifremer.common.synchro.meta.SynchroDatabaseMetadata;
  import fr.ifremer.common.synchro.service.SynchroDatabaseConfiguration;
  import fr.ifremer.quadrige3.synchro.meta.DatabaseColumns;
  import fr.ifremer.quadrige3.synchro.meta.referential.ReferentialSynchroTables;
  import fr.ifremer.quadrige3.synchro.meta.system.RuleSynchroTables;
  import fr.ifremer.quadrige3.synchro.server.config.SynchroServerConfiguration;
  import fr.ifremer.quadrige3.synchro.service.referential.ReferentialSynchroContext;
  import fr.ifremer.quadrige3.synchro.service.referential.ReferentialSynchroDatabaseConfiguration;
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  import org.nuiton.i18n.I18n;
  import org.springframework.beans.factory.InitializingBean;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.context.annotation.Lazy;
  import org.springframework.jdbc.datasource.DataSourceUtils;
  import org.springframework.stereotype.Component;
  
  import javax.sql.DataSource;
  import java.sql.Connection;
  import java.sql.SQLException;
  import java.util.Set;
  
  @Component("referentialSynchroDatabaseMetadata")
  @Lazy
  public class ReferentialSynchroDatabaseMetadata extends SynchroDatabaseMetadata implements InitializingBean {
  
      /**
       * Logger.
       */
      private static final Log log =
          LogFactory.getLog(ReferentialSynchroDatabaseMetadata.class);
  
      private DataSource dataSource;
      private SynchroConfiguration synchroConfiguration;
      private SynchroServerConfiguration synchroServerConfiguration;
  
      public ReferentialSynchroDatabaseMetadata(Connection connection, SynchroDatabaseConfiguration config) {
          super(connection, config);
      }
  
      @Autowired
      public ReferentialSynchroDatabaseMetadata(DataSource dataSource,
                                                SynchroConfiguration synchroConfiguration,
                                                SynchroServerConfiguration synchroServerConfiguration) {
          this(getConnection(dataSource), createDatabaseConfiguration(synchroConfiguration, synchroServerConfiguration));
          this.dataSource = dataSource;
          this.synchroConfiguration = synchroConfiguration;
          this.synchroServerConfiguration = synchroServerConfiguration;
      }
  
      @Override
      public void afterPropertiesSet() {
          // prepare referential tables
          prepareTables();
      }
  
      public void updateConfiguration() {
          // Update configuration by copy
          this.config.copy(createDatabaseConfiguration(synchroConfiguration, synchroServerConfiguration));
          // Re-init the metadata
          init(getConnection(dataSource));
          // Prepare referential tables (only program/strategy/moratorium)
          prepareTables();
      }
  
      /* -- internal methods -- */
  
      protected void prepareTables() {
  
          log.info(I18n.t("quadrige3.synchro.server.meta.referential.load",
              config.getJdbcUrl(),
              config.getJdbcUser()));
 
         unloadTables();
         Set<String> tableNames = Sets.newLinkedHashSet(ReferentialSynchroTables.getImportTablesIncludes());
 
         // + Rule tables (need by Q3-déchet)
         if (synchroServerConfiguration.isEnableImportTablesRules()) {
             tableNames.addAll(RuleSynchroTables.tableNames());
         }
 
         prepare(tableNames);
 
         // Close (to free memory)
         close();
     }
 
 
     @Override
     public void close() {
         try {
             DataSourceUtils.releaseConnection(getConnection(), dataSource);
         } catch (SQLException ignored) {
         }
 
         super.close();
     }
 
     /* -- internal methods -- */
 
     private static Connection getConnection(DataSource dataSource) {
         return DataSourceUtils.getConnection(dataSource);
     }
 
     private static ReferentialSynchroDatabaseConfiguration createDatabaseConfiguration(SynchroConfiguration config, SynchroServerConfiguration synchroServerConfiguration) {
 
         // Set program codes from
         ReferentialSynchroContext context = new ReferentialSynchroContext();
         context.setProgramCodes(synchroServerConfiguration.getSynchroProgramCodeIncludes());
 
         ReferentialSynchroDatabaseConfiguration result = new ReferentialSynchroDatabaseConfiguration(context, config.getImportConnectionProperties(), false);
         // Need to have a valid selectMaxUpdate query (e.g. DELETED_ITEM_HISTORY)
         result.setFullMetadataEnable(true);
         result.setColumnUpdateDate(DatabaseColumns.UPDATE_DT.name().toLowerCase());
         return result;
     }
 
 }