/*
 * Copyright (C) 2004-2006  exedio GmbH (www.exedio.com)
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

package com.exedio.dsmf;

import java.sql.ResultSet;
import java.sql.SQLException;


public class CheckConstraint extends Constraint
{

	public CheckConstraint(final Table table, final String name, final String condition)
	{
		this(table, name, true, condition);
	}

	CheckConstraint(final Table table, final String name, final boolean required, final String condition)
	{
		super(table, name, MASK_CHECK, false, required, condition);
		
		if(condition==null)
			throw new RuntimeException(name);
	}

	@Override
	public boolean isSupported()
	{
		return driver.supportsCheckConstraints();
	}

	@Override
	public int check()
	{
		final StringBuffer bf = new StringBuffer();
		bf.append("select count(*) from ").
			append(protectName(table.name)).
			append(" where not(").
			append(requiredCondition).
			append(')');

		System.out.println("CHECKC:"+bf.toString());
		
		final CheckResultSetHandler handler = new CheckResultSetHandler();
		querySQL(bf.toString(), handler);
		return handler.result;
	}
	
	private static class CheckResultSetHandler implements ResultSetHandler
	{
		int result = Integer.MIN_VALUE;

		public void run(final ResultSet resultSet) throws SQLException
		{
			if(!resultSet.next())
				throw new RuntimeException();
			
			result = resultSet.getInt(1);
		}
	}

	final void createInTable(final StringBuffer bf)
	{
		bf.append(",constraint ").
			append(protectName(name)).
			append(" check(").
			append(requiredCondition).
			append(')');
	}
	
	public final void create()
	{
		final StringBuffer bf = new StringBuffer();
		bf.append("alter table ").
			append(protectName(table.name)).
			append(" add constraint ").
			append(protectName(name)).
			append(" check(").
			append(requiredCondition).
			append(')');

		executeSQL(bf.toString());
	}
	
	public final void drop()
	{
		final StringBuffer bf = new StringBuffer();
		bf.append("alter table ").
			append(protectName(table.name)).
			append(" drop constraint ").
			append(protectName(name));

		executeSQL(bf.toString());
	}
	
}

@@ -1619,16 +1619,18 @@
 )');%0A%0A%09%09
+//
 System.o

remove System.out