/*
    * Copyright 2004-2006 the Seasar Foundation and the Others.
    *
    * 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 org.seasar.tuigwaa.database.function.criteria;
  
  import java.text.ParseException;
  import java.util.Date;
  
  import org.seasar.tuigwaa.database.DataRow;
  import org.seasar.tuigwaa.database.DataTable;
  import org.seasar.tuigwaa.database.function.aggregation.IProjectionList;
  import org.seasar.tuigwaa.model.core.TgwEntity;
  import org.seasar.tuigwaa.system.Constants;
  import org.seasar.tuigwaa.util.functor.Op;
  
  import com.isenshi.util.functor.BinaryPredicate;
  
  public class DataTableCriteria implements ICriteria {
  
  	private DataTable dataTable_;
  
  	public DataTableCriteria(DataTable dataTable) {
  		this.dataTable_ = dataTable;
  	}
  
  	public TgwEntity getEntity() {
  		return null;
  	}
  
  	private void doFilter(BinaryPredicate predicate, String field, Object value) {
  		while (dataTable_.hasNext()) {
  			DataRow row = (DataRow) dataTable_.next();
  			Object data = row.getCell(field);
  			if (!predicate.test(data, value)) {
  				dataTable_.remove();
  			}
  		}
  	}
  
  	public ICriteria addEq(String field, Object value) {
  		doFilter(Op.EQ, field, value);
  		return this;
  	}
  
  	public ICriteria addLe(String field, Object value) {
  		doFilter(Op.LE, field, value);
  		return this;
  	}
  
  	public ICriteria addGe(String field, Object value) {
  		doFilter(Op.GE, field, value);
  		return this;
  	}
  
  	public ICriteria createCriteria(String field) {
  		throw new RuntimeException("this method is not supported.");
  	}
  
  	public ICriteria createCriteria(String field, String alias) {
  		throw new RuntimeException("this method is not supported.");
  	}
  
  	public ICriteria setProjection(IProjectionList projectionList) {
  		throw new RuntimeException();
  		// DataTableProjectionList dlist =
  		// (DataTableProjectionList)projectionList;
  		// String name = dataTable_.getName();
  		// List headers = dlist.getAliases();
  		// List data = new ArrayList();
  		// DataTable newDataTable = new DataTableImpl(name, headers, data,
  		// DataTable.PRIMITIVE_DATA);
  		// while(dataTable_.hasNext()){
  		// DataRow row = dataTable_.nextRow();
  		// for(Iterator i = headers.iterator(); i.hasNext();){
  		// String alias = (String)i.next();
  		// }
  		// }
  		// return this;
  	}
  
  	public DataTable list() {
  		dataTable_.init();
  		return dataTable_;
  	}
  
  	public ICriteria addOrder(String field, boolean isDesc) {
  		// TODO Auto-generated method stub
 		return null;
 	}
 
 	public ICriteria disjunction() {
 		throw new UnsupportedOperationException("this method is not supported.");
 	}
 
 	public ICriteria addLt(String field, Object value) {
 		doFilter(Op.LT, field, value);
 		return this;
 	}
 
 	public ICriteria addGt(String field, Object value) {
 		doFilter(Op.GT, field, value);
 		return this;
 	}
 
 	public ICriteria addNe(String field, Object value) {
 		doFilter(Op.EQ, field, value);
 		return this;
 	}
 
 	private static final BinaryPredicate BETWEEN = new BinaryPredicate() {
 		public boolean test(Object left, Object right) {
 			Object[] array = (Object[]) right;
 			Date date = null;
 			try {
 				date = Constants.LIGHT_DATEFORMAT.parse((String) left);
 			} catch (ParseException e) {
 				e.printStackTrace();
 				throw new RuntimeException();
 			}
 			return Op.GE.test(date, array[0]) && Op.LE.test(date, array[1]);
 		}
 	};
 
 	public ICriteria addBetween(String field, Object value) {
 		doFilter(BETWEEN, field, value);
 		return this;
 	}
 
 	public ICriteria addLike(String field, Object value) {
 		// TODO Auto-generated method stub
 		return this;
 	}
 
 	public ICriteria setMaxResult(int maxResult) {
 		for (int i = 0; dataTable_.hasNext(); i++) {
 			dataTable_.next();
 			if (i > maxResult) {
 				dataTable_.remove();
 			}
 		}
 		return this;
 	}
 
 	public ICriteria setFirstResult(int firstResult) {
 		for (int i = 0; dataTable_.hasNext(); i++) {
 			dataTable_.next();
 			if (i < firstResult) {
 				dataTable_.remove();
 			}
 		}
 		return this;
 	}
 
 	public ICriteria addIsNull(String field) {
 		// unsupported
 		return this;
 	}
 	
 	public ICriteria addIsNotNull(String field){
 		return this;
 	}
 	
 	public void setJoinType(int joinType){
 		// unsupported
 	}
 
 }