EDIT

// $Id$

/**

* Copyright (C) 2015 EDIT

* European Distributed Institute of Taxonomy

* http://www.e-taxonomy.eu

*

* The contents of this file are subject to the Mozilla Public License Version 1.1

* See LICENSE.TXT at the top of this package for the full license terms.

*/

package eu.etaxonomy.cdm.vaadin.statement;

import java.sql.Connection;

import java.sql.SQLException;

import java.util.List;

import com.vaadin.data.Container.Filter;

import com.vaadin.data.util.sqlcontainer.RowItem;

import com.vaadin.data.util.sqlcontainer.SQLUtil;

import com.vaadin.data.util.sqlcontainer.query.FreeformStatementDelegate;

import com.vaadin.data.util.sqlcontainer.query.OrderBy;

import com.vaadin.data.util.sqlcontainer.query.generator.StatementHelper;

import com.vaadin.data.util.sqlcontainer.query.generator.filter.QueryBuilder;

/**

 * @author cmathew

 * @date 10 Mar 2015

 *

 */

public class CdmStatementDelegate implements FreeformStatementDelegate {

	private static final long serialVersionUID = 8417860805854924886L;

	private List<Filter> filters;

    private List<OrderBy> orderBys;

    private final String select_query;

    private final String count_query;

    private final String contains_query;

    public CdmStatementDelegate(String select_query, String count_query, String contains_query) {

        this.select_query = select_query;

        this.count_query = count_query;

        this.contains_query = contains_query;

    }

    @Override

    public String getQueryString(int offset, int limit) throws UnsupportedOperationException {

        throw new UnsupportedOperationException("Use getQueryStatement method.");

    }

    @Override

    public String getCountQuery() throws UnsupportedOperationException {

        throw new UnsupportedOperationException("Use getCountStatement method.");

    }

    @Override

    public void setFilters(List<Filter> filters) throws UnsupportedOperationException {

        this.filters = filters;

    }

    @Override

    public void setOrderBy(List<OrderBy> orderBys) throws UnsupportedOperationException {

        this.orderBys = orderBys;

    }

    @Override

    public int storeRow(Connection conn, RowItem row) throws UnsupportedOperationException, SQLException {

        // TODO Auto-generated method stub

        return 0;

    }

    @Override

    public boolean removeRow(Connection conn, RowItem row) throws UnsupportedOperationException, SQLException {

        // TODO Auto-generated method stub

        return false;

    }

    @Override

    public String getContainsRowQueryString(Object... keys) throws UnsupportedOperationException {

        throw new UnsupportedOperationException("Use getContainsRowQueryStatement method.");

    }

    @Override

    public StatementHelper getQueryStatement(int offset, int limit) throws UnsupportedOperationException {

        StatementHelper sh = new StatementHelper();

        StringBuffer query = new StringBuffer(select_query);

        if (filters != null) {

            String filterString = QueryBuilder.getWhereStringForFilters(filters, sh);

            query.append(filterString);

        }

        query.append(getOrderByString());

        if (offset != 0 || limit != 0) {

            query.append(" LIMIT ").append(limit);

            query.append(" OFFSET ").append(offset);

        }

        sh.setQueryString(query.toString());

        return sh;

    }

    private String getOrderByString() {

        StringBuffer orderBuffer = new StringBuffer("");

        if (orderBys != null && !orderBys.isEmpty()) {

            orderBuffer.append(" ORDER BY ");

            OrderBy lastOrderBy = orderBys.get(orderBys.size() - 1);

            for (OrderBy orderBy : orderBys) {

                orderBuffer.append(SQLUtil.escapeSQL(orderBy.getColumn()));

                if (orderBy.isAscending()) {

                    orderBuffer.append(" ASC");

                } else {

                    orderBuffer.append(" DESC");

                }

                if (orderBy != lastOrderBy) {

                    orderBuffer.append(", ");

                }

            }

        }

        return orderBuffer.toString();

    }

    @Override

    public StatementHelper getCountStatement() throws UnsupportedOperationException {

        StatementHelper sh = new StatementHelper();

        StringBuffer query = new StringBuffer(count_query);

        if (filters != null) {

            String filterString = QueryBuilder.getWhereStringForFilters(filters, sh);

            query.append(filterString);

        }

        sh.setQueryString(query.toString());

        return sh;

    }

    @Override

    public StatementHelper getContainsRowQueryStatement(Object... keys) throws UnsupportedOperationException {

        StatementHelper sh = new StatementHelper();

        StringBuffer query = new StringBuffer(contains_query);

        sh.addParameterValue(keys[0]);

        sh.setQueryString(query.toString());

        return sh;

    }

}