package fr.ifremer.quadrige2.synchro.server.meta;
   
   /*-
    * #%L
    * Quadrige2 Core :: Quadrige2 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.quadrige2.synchro.meta.DatabaseColumns;
  import fr.ifremer.quadrige2.synchro.meta.referential.ReferentialSynchroTables;
  import fr.ifremer.quadrige2.synchro.meta.system.RuleSynchroTables;
  import fr.ifremer.quadrige2.synchro.server.config.SynchroServerConfiguration;
  import fr.ifremer.quadrige2.synchro.service.referential.ReferentialSynchroContext;
  import fr.ifremer.quadrige2.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 SynchroServerConfiguration synchroServerConfiguration;
  
      public ReferentialSynchroDatabaseMetadata(Connection connection, SynchroDatabaseConfiguration config) throws SQLException {
          super(connection, config);
      }
  
      @Autowired
      public ReferentialSynchroDatabaseMetadata(DataSource dataSource,
                                                SynchroConfiguration synchroConfiguration,
                                                SynchroServerConfiguration synchroServerConfiguration) throws SQLException {
          this(getConnection(dataSource), createDatabaseConfiguration(synchroConfiguration));
          this.dataSource = dataSource;
          this.synchroServerConfiguration = synchroServerConfiguration;
      }
  
      @Override
      public void afterPropertiesSet() throws Exception {
          // prepare data tables
          log.info(I18n.t("quadrige2.synchro.server.meta.referential.load",
                  config.getJdbcUrl(),
                  config.getJdbcUser()));
  
          Set<String> tableNames = Sets.newLinkedHashSet(ReferentialSynchroTables.getImportTablesIncludes());
  
          // + Rule tables (need by Q3-déchet)
          if (synchroServerConfiguration.isEnableImportTablesRules()) {
              tableNames.addAll(RuleSynchroTables.tableNames());
          }
  
          prepare(tableNames);
  
          // Close the connection
          if (dataSource != null) {
              DataSourceUtils.releaseConnection(getConnection(), dataSource);
          }
  
          // Close (to free memory)
          close();
     }
 
     /* -- internal methods -- */
 
     @Override
     public void close() {
         super.close();
         this.dataSource = null;
     }
 
     private static Connection getConnection(DataSource dataSource) {
         return DataSourceUtils.getConnection(dataSource);
     }
 
     private static ReferentialSynchroDatabaseConfiguration createDatabaseConfiguration(SynchroConfiguration config) {
         ReferentialSynchroDatabaseConfiguration result = new ReferentialSynchroDatabaseConfiguration(new ReferentialSynchroContext(), 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;
     }
 
 }