/*
    * File:    AbstractQuery.java
    * Created: 30.05.2007 10:43:19
    *
    * Copyright 2007 Michal Burda.
    *
    * This program is free software; you can redistribute it and/or modify
    * it under the terms of the GNU General Public License as published by
    * the Free Software Foundation; either version 2 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 General Public License
   * along with this program; if not, write to the Free Software
   * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
   */
  
  package net.sf.webmancer.db;
  
  import java.util.HashMap;
  import java.util.LinkedList;
  import java.util.List;
  import java.util.Map;
  import java.util.Vector;
  
  import net.sf.webmancer.util.ContractChecker;
  import net.sf.webmancer.util.immutable.ImmutableList;
  import net.sf.webmancer.util.immutable.ImmutableMap;
  
  /**
   * @author Michal Burda
   *
   */
  public class Query implements IQuery {
      /**
       * 
       */
      private Map<String, IAttribute> attributes;
      
      /**
       * 
       */
      private List<IRestrictor> restrictors;
  
      /**
       * 
       */
      private List<ICondition> conditions;
  
      /**
       * 
       */
      private long limit;
  
      /**
       * 
       */
      private long offset;
  
      /**
       * 
       */
      private IAttribute orderingAttribute;
  
      /**
       * 
       */
      private boolean orderingIsAscending;
  
      /**
       * 
       */
      private IDatabaseOperationPerformer performer;
  
      /**
       * Constructs the AbstractQuery.
       *
       */
      public Query(IDatabaseOperationPerformer performer) {
          super();
          ContractChecker.mustNotBeNull(performer, "performer");
          this.performer = performer;
          this.attributes = new HashMap<String, IAttribute>();
          this.restrictors = new Vector<IRestrictor>();
          this.conditions = new LinkedList<ICondition>();
          this.limit = 0;
          this.orderingAttribute = null;
          this.orderingIsAscending = true;
      }
  
      /**
       * @see net.sf.webmancer.db.IQuery#addAttribute(net.sf.webmancer.db.IAttribute)
       */
      public void addAttribute(IAttribute attribute) {
          ContractChecker.mustNotBeNull(attribute, "attribute");
         this.attributes.put(attribute.getId(), attribute);
     }
 
     /**
      * @see net.sf.webmancer.db.IQuery#queryCount()
      */
     public long queryCount() {
         return performer.performQueryCount(this.getConditions());
     }
 
     /**
      * @see net.sf.webmancer.db.IQuery#queryResult()
      */
     public IData queryResult() {
         return performer.performQueryResult(this.getAttributes(), this.getConditions(), this.getLimit(), this.getOffset(), this.getOrderingAttribute(), this.isOrderingAscending());
     }
 
     /**
      * @see net.sf.webmancer.db.IQuery#delete()
      */
     public long delete() {
         return performer.performDelete(this.getConditions());
     }
 
     /**
      * @see net.sf.webmancer.db.IQuery#update(java.util.Map)
      */
     public long update(Map<IAttribute, ICell> row) {
         return performer.performUpdate(row, this.getConditions());
     }
 
     /**
      * @see net.sf.webmancer.db.IQuery#insert(java.util.Map)
      */
     public void insert(Map<IAttribute, ICell> row) {
         performer.performInsert(row);
     }
 
     public void insert(IData data) {
         performer.performInsert(data);
     }
 
     /**
      * @see net.sf.webmancer.db.IRestrictable#registerRestrictor(net.sf.webmancer.db.IRestrictor)
      */
     public void registerRestrictor(IRestrictor restrictor) {
         ContractChecker.mustNotBeNull(restrictor, "restrictor");
         this.restrictors.add(restrictor);
     }
 
     /**
      * @see net.sf.webmancer.db.IRestrictable#restrictByCondition(net.sf.webmancer.db.ICondition)
      */
     public void restrictByCondition(ICondition condition) {
         ContractChecker.mustNotBeNull(condition, "condition");
         this.conditions.add(condition);
     }
 
     /**
      * @see net.sf.webmancer.db.IRestrictable#restrictLimit(long)
      */
     public void restrictLimit(long limit) {
         ContractChecker.mustNotBeNegative(limit, "limit");
         this.limit = limit;
     }
 
     /**
      * @see net.sf.webmancer.db.IRestrictable#restrictOffset(long)
      */
     public void restrictOffset(long offset) {
         ContractChecker.mustNotBeNegative(offset, "offset");
         this.offset = offset;
     }
 
     /**
      * @see net.sf.webmancer.db.IRestrictable#restrictOrdering(net.sf.webmancer.db.IAttribute, boolean)
      */
     public void restrictOrdering(IAttribute attribute, boolean ascending) {
         ContractChecker.mustNotBeNull(attribute, "attribute");
         this.orderingAttribute = attribute;
         this.orderingIsAscending = ascending;
     }
 
     /**
      * @param type
      */
     protected void callRestrictors(RestrictionType type) {
         for (IRestrictor restrictor : this.restrictors) {
             restrictor.restrict(this, type);
         }
     }
 
     /**
      * Returns the attributes.
      *
      * @return the attributes
      */
     protected Map<String, IAttribute> getAttributes() {
         return new ImmutableMap<String, IAttribute>(this.attributes);
     }
 
     /**
      * Sets the attributes.
      *
      * @param attributes the attributes to set
      */
     public void setAttributes(Map<String, IAttribute> attributes) {
         ContractChecker.mustNotBeNull(attributes, "attributes");
         this.attributes = attributes;
     }
 
     /**
      * Returns the conditions.
      *
      * @return the conditions
      */
     protected List<ICondition> getConditions() {
         return new ImmutableList<ICondition>(this.conditions);
     }
 
     /**
      * Sets the conditions.
      *
      * @param conditions the conditions to set
      */
     public void setConditions(List<ICondition> conditions) {
         this.conditions = conditions;
     }
 
     /**
      * Returns the limit.
      *
      * @return the limit
      */
     protected long getLimit() {
         return this.limit;
     }
 
     /**
      * Sets the limit.
      *
      * @param limit the limit to set
      */
     public void setLimit(long limit) {
         ContractChecker.mustNotBeNegative(limit, "limit");
         this.limit = limit;
     }
 
     /**
      * Returns the offset.
      *
      * @return the offset
      */
     protected long getOffset() {
         return this.offset;
     }
 
     /**
      * Sets the offset.
      *
      * @param offset the offset to set
      */
     public void setOffset(long offset) {
         ContractChecker.mustNotBeNegative(offset, "offset");
         this.offset = offset;
     }
 
     /**
      * Returns the ordering attribute.
      *
      * @return the orderingAttribute
      */
     protected IAttribute getOrderingAttribute() {
         return this.orderingAttribute;
     }
 
     /**
      * Sets the ordering attribute.
      *
      * @param attribute the orderingAttribute to set
      */
     public void setOrderingAttribute(IAttribute attribute) {
         ContractChecker.mustNotBeNull(attribute, "attribute");
         this.orderingAttribute = attribute;
     }
 
     /**
      * Returns the orderingIsAscending.
      *
      * @return the orderingIsAscending
      */
     protected boolean isOrderingAscending() {
         return this.orderingIsAscending;
     }
 
     /**
      * Sets the orderingIsAscending.
      *
      * @param ascending the orderingIsAscending to set
      */
     public void setOrderingAscending(boolean ascending) {
         this.orderingIsAscending = ascending;
     }
 
 }