package eu.dnetlib.goldoa.service;

import eu.dnetlib.goldoa.domain.Funder;
import eu.dnetlib.goldoa.domain.Vocabulary;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;

import javax.sql.DataSource;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.util.List;

/**
 * Created by antleb on 5/6/15.
 */
public class FunderManagerImpl implements FunderManager {

    @Autowired
    private DataSource dataSource;

    private final static String SEARCH_FUNDERS = "select id, name from funder where lower(name) like lower(?)";
    private final static String GET_FUNDER = "select id, name, url, source from funder where id=?";

    @Override
    public List<Vocabulary> search(String term) {
        return new JdbcTemplate(dataSource).query(SEARCH_FUNDERS,  new String[]{"%" + term + "%"}, new int[]{Types.VARCHAR}, new RowMapper<Vocabulary>() {
            @Override
            public Vocabulary mapRow(ResultSet rs, int rowNum) throws SQLException {
                return new Vocabulary(rs.getString("id"), rs.getString("name"));
            }
        });
    }

    @Override
    public Funder getById(String id) {
        try {
            return new JdbcTemplate(dataSource).queryForObject(GET_FUNDER, new String[]{id}, new int[]{Types.VARCHAR}, new RowMapper<Funder>() {
                @Override
                public Funder mapRow(ResultSet rs, int rowNum) throws SQLException {
                    return new Funder(rs.getString("id"), rs.getString("name"), rs.getString("url"), rs.getString("source"));
                }
            });
        } catch (EmptyResultDataAccessException e) {
            return null;
        }
    }
}