/*
    * Copyright 2013 smartics, Kronseder & Reiner GmbH
    *
    * Licensed under the Apache License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    *
    *     http://www.apache.org/licenses/LICENSE-2.0
    *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   */
  package de.smartics.properties.config.transfer.jdbc;
  
  import org.apache.commons.lang.StringUtils;
  
  import de.smartics.properties.api.config.transfer.PropertySinkFactory;
  import de.smartics.properties.impl.config.ds.DataSourceProxyManager;
  import de.smartics.properties.spi.config.ds.DataSourceConnector;
  import de.smartics.properties.spi.config.ds.DataSourceProxy;
  import de.smartics.properties.spi.config.ds.PropertiesStore;
  
  /**
   * Creates instances of {@link JdbcPropertySink}.
   */
  public final class Factory implements PropertySinkFactory<JdbcPropertySink>
  {
    // ********************************* Fields *********************************
  
    // --- constants ------------------------------------------------------------
  
    // --- members --------------------------------------------------------------
  
    /**
     * The database identifier to select the datasource proxy for a database
     * product.
     */
    private String databaseId;
  
    /**
     * The JDBC URL to the database.
     */
    private String jdbcUrl;
  
    /**
     * The user to authenticate against the database.
     */
    private String user;
  
    /**
     * The password to authenticate against the database.
     */
    private String password;
  
    /**
     * The flag that signals to drop properties table (<code>true</code>) or not (
     * <code>false</code>).
     */
    private boolean dropTable;
  
    /**
     * The flag that signals to create properties table (<code>true</code>) or not
     * ( <code>false</code>).
     */
    private boolean createTable;
  
    // ****************************** Initializer *******************************
  
    // ****************************** Constructors ******************************
  
    /**
     * Default constructor.
     */
    public Factory()
    {
    }
  
    // ****************************** Inner Classes *****************************
  
    // ********************************* Methods ********************************
  
    // --- init -----------------------------------------------------------------
  
    // --- get&set --------------------------------------------------------------
  
    /**
     * Returns the database identifier to select the datasource proxy for a
     * database product.
     *
     * @return the database identifier to select the datasource proxy for a
     *         database product.
     */
    public String getDatabaseId()
    {
      return databaseId;
    }
 
   /**
    * Sets the database identifier to select the datasource proxy for a database
    * product.
    *
    * @param databaseId the database identifier to select the datasource proxy
    *          for a database product.
    */
   public void setDatabaseId(final String databaseId)
   {
     this.databaseId = databaseId;
   }
 
   /**
    * Returns the JDBC URL to the database.
    *
    * @return the JDBC URL to the database.
    */
   public String getJdbcUrl()
   {
     return jdbcUrl;
   }
 
   /**
    * Sets the JDBC URL to the database.
    *
    * @param jdbcUrl the JDBC URL to the database.
    */
   public void setJdbcUrl(final String jdbcUrl)
   {
     this.jdbcUrl = jdbcUrl;
   }
 
   /**
    * Returns the user to authenticate against the database.
    *
    * @return the user to authenticate against the database.
    */
   public String getUser()
   {
     return user;
   }
 
   /**
    * Sets the user to authenticate against the database.
    *
    * @param user the user to authenticate against the database.
    */
   public void setUser(final String user)
   {
     this.user = user;
   }
 
   /**
    * Returns the password to authenticate against the database.
    *
    * @return the password to authenticate against the database.
    */
   public String getPassword()
   {
     return password;
   }
 
   /**
    * Sets the password to authenticate against the database.
    *
    * @param password the password to authenticate against the database.
    */
   public void setPassword(final String password)
   {
     this.password = password;
   }
 
   /**
    * Returns the flag that signals to drop properties table (<code>true</code>)
    * or not ( <code>false</code>).
    *
    * @return the flag that signals to drop properties table (<code>true</code>)
    *         or not ( <code>false</code>).
    */
   public boolean isDropTable()
   {
     return dropTable;
   }
 
   /**
    * Sets the flag that signals to drop properties table (<code>true</code>) or
    * not ( <code>false</code>).
    *
    * @param dropTable the flag that signals to drop properties table (
    *          <code>true</code>) or not ( <code>false</code>).
    */
   public void setDropTable(final boolean dropTable)
   {
     this.dropTable = dropTable;
   }
 
   /**
    * Returns the flag that signals to create properties table (<code>true</code>
    * ) or not ( <code>false</code>).
    *
    * @return the flag that signals to create properties table (<code>true</code>
    *         ) or not ( <code>false</code>).
    */
   public boolean isCreateTable()
   {
     return createTable;
   }
 
   /**
    * Sets the flag that signals to create properties table (<code>true</code>)
    * or not ( <code>false</code>).
    *
    * @param createTable the flag that signals to create properties table (
    *          <code>true</code>) or not ( <code>false</code>).
    */
   public void setCreateTable(final boolean createTable)
   {
     this.createTable = createTable;
   }
 
   // --- business -------------------------------------------------------------
 
   @Override
   public JdbcPropertySink create()
   {
     final PropertiesStore store = createManager();
     return new JdbcPropertySink(store);
   }
 
   private PropertiesStore createManager()
   {
     final PropertiesStore.Builder builder = new PropertiesStore.Builder();
 
     final DataSourceConnector connector =
         DataSourceProxyManager.getConnectorFor(databaseId);
     final DataSourceProxy dataSourceProxy =
         connector.create(jdbcUrl, user, password);
     builder.setDataSourceProxy(dataSourceProxy);
 
     builder.setDropTable(dropTable);
     builder.setIgnoreTableCreationProblems(false);
 
     final String createTableSqlStatementTemplate =
         dataSourceProxy.getCreateTableSqlTemplate();
     if (StringUtils.isNotBlank(createTableSqlStatementTemplate))
     {
       builder
           .setCreateTableSqlStatementTemplate(createTableSqlStatementTemplate);
     }
 
     final String insertOrUpdateSqlTemplate =
         dataSourceProxy.getInsertOrUpdateSqlTemplate();
     if (StringUtils.isNotBlank(insertOrUpdateSqlTemplate))
     {
       builder
           .setInsertOrUpdateSqlStatementTemplate(insertOrUpdateSqlTemplate);
     }
 
     final PropertiesStore manager = builder.build();
 
     if (createTable)
     {
       manager.createConfigTable();
     }
 
     return manager;
   }
 
   // --- object basics --------------------------------------------------------
 
 }