// license-header java merge-point
   //
   // Attention: Generated code! Do not modify by hand!
   // Generated by: SpringHibernateDaoImpl.vsl in andromda-spring-cartridge.
   //
   package fr.ifremer.quadrige2.core.dao.administration.user;
   
   /*-
    * #%L
   * Quadrige2 Core :: Quadrige2 Server Core
   * $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.base.Joiner;
  import com.google.common.base.Preconditions;
  import com.google.common.collect.Maps;
  import fr.ifremer.quadrige2.core.exception.Quadrige2TechnicalException;
  import fr.ifremer.quadrige2.core.dao.technical.jdbc.OptionalDataSourceJdbcDaoSupport;
  import fr.ifremer.quadrige2.core.vo.administration.user.DepartmentVO;
  import org.apache.commons.io.IOUtils;
  import org.apache.commons.lang3.StringUtils;
  import org.springframework.beans.factory.InitializingBean;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.context.annotation.Lazy;
  import org.springframework.dao.DataAccessException;
  import org.springframework.jdbc.core.ResultSetExtractor;
  import org.springframework.jdbc.core.RowMapper;
  import org.springframework.stereotype.Repository;
  
  import javax.annotation.Resource;
  import javax.sql.DataSource;
  import java.io.IOException;
  import java.io.InputStream;
  import java.sql.ResultSet;
  import java.sql.SQLException;
  import java.util.List;
  import java.util.Map;
  import java.util.Properties;
  
  /**
   * <p>
   * DepartmentJdbcDaoImpl class.
   * </p>
   * 
   * @see Quser
   */
  @Repository("departmentJdbcDao")
  @Lazy
  public class DepartmentJdbcDaoImpl
  		extends OptionalDataSourceJdbcDaoSupport
  		implements DepartmentJdbcDao, InitializingBean {
  
  	private final static String QUERIES_FILE_PATH = "queries.jdbc.xml";
  
  	@Resource(name = "queriesJdbcProperties")
  	protected Properties queriesJdbcProperties;
  
  	protected Properties connectionProperties;
  
  	/**
  	 * Constructor used by Spring
  	 * 
  	 * @param dataSource
  	 *            a {@link javax.sql.DataSource} object.
  	 */
  	@Autowired
  	public DepartmentJdbcDaoImpl(DataSource dataSource) {
  		super(dataSource);
  	}
  
  	/**
  	 * Constructor without Spring (e.g. for synchro)
  	 */
  	public DepartmentJdbcDaoImpl() {
  		this((Properties) null);
  	}
  
  	/**
  	 * Constructor without Spring (e.g. for synchro)
  	 * 
  	 * @param connectionProperties
  	 *            a {@link java.util.Properties} object.
 	 */
 	public DepartmentJdbcDaoImpl(Properties connectionProperties) {
 		super();
 		this.connectionProperties = connectionProperties;
 
 		// Load properties
 		Properties properties = new Properties();
 		InputStream is = null;
 		try {
 			is = getClass().getClassLoader().getResourceAsStream(QUERIES_FILE_PATH);
 			properties.loadFromXML(is);
 
 			this.queriesJdbcProperties = properties;
 		} catch (IOException e) {
 			throw new Quadrige2TechnicalException(
 					String.format("Unable to read file [%s] from classpath", QUERIES_FILE_PATH),
 					e);
 		} finally {
 			IOUtils.closeQuietly(is);
 		}
 
 		// Check all queries
 		checkAllQueriesExists();
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public void afterPropertiesSet() throws Exception {
 		checkAllQueriesExists();
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public DepartmentVO getDepartmentById(int depId) {
 		return getDepartmentById(connectionProperties, depId);
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public DepartmentVO getDepartmentById(Properties connectionProperties, int depId) {
 		// Find the user, by id
 		String sql = queriesJdbcProperties.getProperty("departmentById");
 
 		Map<String, Object> paramMap = Maps.newHashMap();
 		paramMap.put("depId", depId);
 
 		return query(connectionProperties, sql, paramMap, new ResultSetExtractor<DepartmentVO>() {
 			@Override
 			public DepartmentVO extractData(ResultSet rs) throws SQLException, DataAccessException {
 				return toDepartmentVO(rs);
 			}
 		});
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public List<DepartmentVO> getDepartmentsByIds(List<Integer> ids) {
 		return getDepartmentsByIds(connectionProperties, ids);
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public List<DepartmentVO> getDepartmentsByIds(Properties connectionProperties, List<Integer> ids) {
 		// Find the user, by id
 		String sql = queriesJdbcProperties.getProperty("departmentsByIds");
 		sql = sql.replace(":ids", Joiner.on(',').skipNulls().join(ids));
 
 		Map<String, Object> paramMap = Maps.newHashMap();
 
 		return query(connectionProperties, sql, paramMap, new RowMapper<DepartmentVO>() {
 			@Override
 			public DepartmentVO mapRow(ResultSet rs, int rowNum) throws SQLException, DataAccessException {
 				return toDepartmentVO(rs);
 			}
 		});
 	}
 
 	/* -- Internal methods -- */
 
 	/**
 	 * <p>
 	 * toDepartmentVO.
 	 * </p>
 	 * 
 	 * @param source
 	 *            a {@link java.sql.ResultSet} object.
 	 * @return a {@link fr.ifremer.quadrige2.core.vo.administration.user.DepartmentVO} object.
 	 * @throws java.sql.SQLException
 	 *             if any.
 	 */
 	protected DepartmentVO toDepartmentVO(ResultSet source) throws SQLException {
 		DepartmentVO target = new DepartmentVO();
 		int col = 1;
 		target.setDepId(safeGetInteger(source, col++));
 		target.setDepCd(source.getString(col++));
 		target.setDepNm(source.getString(col++));
 		target.setDepEMail(source.getString(col++));
 		target.setDepAddress(source.getString(col++));
 		target.setDepPhone(source.getString(col++));
 		target.setDepLdapPresent(source.getString(col++));
 		target.setDepCreationDt(source.getDate(col++));
 		target.setUpdateDt(source.getTimestamp(col++));
 		target.setParentDepartmentId(source.getInt(col++));
 		target.setStatusCd(source.getString(col++));
 
 		return target;
 	}
 
 	/**
 	 * <p>
 	 * checkAllQueriesExists.
 	 * </p>
 	 */
 	protected void checkAllQueriesExists() {
 		checkQueryExists("departmentById");
 	}
 
 	/**
 	 * <p>
 	 * checkQueryExists.
 	 * </p>
 	 * 
 	 * @param queryName
 	 *            a {@link java.lang.String} object.
 	 */
 	protected void checkQueryExists(String queryName) {
 		Preconditions.checkArgument(
 				StringUtils.isNotBlank(queriesJdbcProperties.getProperty(queryName)),
 				"Property with name [%s] not exists on JDBC queries file");
 	}
 }