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 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.data.DataSynchroTables;
  import fr.ifremer.quadrige2.synchro.service.data.DataSynchroContext;
  import fr.ifremer.quadrige2.synchro.service.data.DataSynchroDatabaseConfiguration;
  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;
  
  @Component("dataSynchroDatabaseMetadata")
  @Lazy
  public class DataSynchroDatabaseMetadata extends SynchroDatabaseMetadata implements InitializingBean {
  
      /** Logger. */
      private static final Log log =
              LogFactory.getLog(DataSynchroDatabaseMetadata.class);
  
      private DataSource dataSource;
      
      public DataSynchroDatabaseMetadata(Connection connection, SynchroDatabaseConfiguration config) throws SQLException {
          super(connection, config);
      }
  
      @Autowired
      public DataSynchroDatabaseMetadata(DataSource dataSource, SynchroConfiguration config) throws SQLException {
          super(getConnection(dataSource), createDatabaseConfiguration(config));
          this.dataSource = dataSource;
      }
      
  
      @Override
      public void afterPropertiesSet() throws Exception {
  
          // Prepare data tables
          log.info(I18n.t("quadrige2.synchro.server.meta.data.load",
                  config.getJdbcUrl(),
                  config.getJdbcUser()));
          prepare(DataSynchroTables.getImportTablesIncludes());
          
          // Close the connection
          if (dataSource != null) {
              DataSourceUtils.releaseConnection(getConnection(), dataSource);
          }
          
          // Close (to free memory)
          close();    
       }
  
      /* -- internal methods -- */
  
      private static Connection getConnection(DataSource dataSource) {
          return DataSourceUtils.getConnection(dataSource);
      }
      
      public static DataSynchroDatabaseConfiguration createDatabaseConfiguration(SynchroConfiguration config) {
          DataSynchroDatabaseConfiguration result = new DataSynchroDatabaseConfiguration(new DataSynchroContext(), config.getImportConnectionProperties(), false);
          result.setFullMetadataEnable(false);
          result.setReadOnly(true);
  
          return result;
      }
  }