/*
 * Hibernate, Relational Persistence for Idiomatic Java
 *
 * License: GNU Lesser General Public License (LGPL), version 2.1 or later.
 * See the lgpl.txt file in the root directory or <http://www.gnu.org/licenses/lgpl-2.1.html>.
 */
package org.hibernate.test.hql;

import javax.persistence.ElementCollection;
import javax.persistence.Embeddable;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.OneToMany;
import javax.persistence.Table;
import java.util.Arrays;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;

import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.HibernateException;
import org.hibernate.testing.TestForIssue;
import org.junit.Test;

import org.hibernate.testing.junit4.BaseCoreFunctionalTestCase;

import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.core.Is.is;
import static org.hibernate.testing.junit4.ExtraAssertions.assertTyping;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.fail;

/**
 * @author Andrea Boriero
 * @author Christian Beikov
 */
public class CollectionMapWithComponentValueTest extends BaseCoreFunctionalTestCase {
	private final KeyValue keyValue = new KeyValue( "key1" );
	private final EmbeddableValue embeddableValue = new EmbeddableValue( 3 );

	@Override
	protected Class<?>[] getAnnotatedClasses() {
		return new Class[] {
				BaseTestEntity.class,
				TestEntity.class,
				KeyValue.class
		};
	}

	@Override
	protected void prepareTest() throws Exception {
		Session s = openSession();
		s.getTransaction().begin();
		{
			s.save( keyValue );

			BaseTestEntity baseTestEntity1 = new BaseTestEntity();
			TestEntity testEntity = new TestEntity();
			Map<KeyValue, EmbeddableValue> map = new HashMap<>();
			map.put( keyValue, embeddableValue );
			testEntity.values = map;
			s.save( testEntity );
			baseTestEntity1.entities = new HashSet<TestEntity>();
			baseTestEntity1.entities.add( testEntity );
			s.save( baseTestEntity1 );

			KeyValue keyValue2 = new KeyValue( "key2" );
			s.save( keyValue2 );
			BaseTestEntity baseTestEntity2 = new BaseTestEntity();
			s.save( baseTestEntity2 );
			TestEntity testEntity2 = new TestEntity();
			Map<KeyValue, EmbeddableValue> map2 = new HashMap<>();
			map2.put( keyValue2, embeddableValue );
			testEntity2.values = map2;
			s.save( testEntity2 );
		}
		s.getTransaction().commit();
		s.close();
	}

	@Test
	public void testMapKeyExpressionInWhere() {
		Session s = openSession();
		s.getTransaction().begin();
		{
			// JPA form
			Query query = s.createQuery( "select te from TestEntity te join te.values v where ? in (key(v)) " );
			query.setParameter( 0, keyValue );

			assertThat( query.list().size(), is( 1 ) );

			// Hibernate additional form
			query = s.createQuery( "select te from TestEntity te where ? in (key(te.values))" );
			query.setParameter( 0, keyValue );

			assertThat( query.list().size(), is( 1 ) );

			// Test key property dereference
			query = s.createQuery( "select te from TestEntity te join te.values v where key(v).name in :names" );
			query.setParameterList( "names", Arrays.asList( keyValue.name ) );
			assertThat( query.list().size(), is( 1 ) );
		}
		s.getTransaction().commit();
		s.close();
	}

	@Test
	@TestForIssue(jiraKey = "HHH-10577")
	public void testMapValueExpressionInWhere() {
		Session s = openSession();
		s.getTransaction().begin();
		{
			// JPA form
			try {
				Query query = s.createQuery( "select te from TestEntity te join te.values v where ? in (value(v))" );
				query.setParameter( 0, new EmbeddableValue( 3 ) );
				assertThat( query.list().size(), is( 2 ) );
				fail( "HibernateException expected - Could not determine type for EmbeddableValue" );
			}
			catch ( Exception e ) {
				assertTyping( HibernateException.class, e );
			}

			// Hibernate additional form
			try {
				Query query = s.createQuery( "select te from TestEntity te where ? in (value(te.values))" );
				query.setParameter( 0, new EmbeddableValue( 3 ) );
				assertThat( query.list().size(), is( 2 ) );
				fail( "HibernateException expected - Could not determine type for EmbeddableValue" );
			}
			catch ( Exception e ) {
				assertTyping( HibernateException.class, e );
			}

			// Test value property dereference
			Query query = s.createQuery( "select te from TestEntity te join te.values v where value(v).value in :values" );
			query.setParameterList( "values", Arrays.asList( 3 ) );
			assertThat( query.list().size(), is( 2 ) );
		}
		s.getTransaction().commit();
		s.close();
	}

	@Test
	public void testMapKeyExpressionInSelect() {
		Session s = openSession();
		s.getTransaction().begin();
		{
			// JPA form
			List results = s.createQuery( "select key(v) from TestEntity te join te.values v" ).list();
			assertEquals( 2, results.size() );
			assertTyping( KeyValue.class, results.get( 0 ) );

			// Hibernate additional form
			results = s.createQuery( "select key(te.values) from TestEntity te" ).list();
			assertEquals( 2, results.size() );
			assertTyping( KeyValue.class, results.get( 0 ) );
		}
		s.getTransaction().commit();
		s.close();
	}

	@Test
	public void testMapValueExpressionInSelect() {
		Session s = openSession();
		s.getTransaction().begin();
		{
			List addresses = s.createQuery( "select value(v) from TestEntity te join te.values v" ).list();
			assertEquals( 2, addresses.size() );
			assertTyping( EmbeddableValue.class, addresses.get( 0 ) );

			addresses = s.createQuery( "select value(te.values) from TestEntity te" ).list();
			assertEquals( 2, addresses.size() );
			assertTyping( EmbeddableValue.class, addresses.get( 0 ) );
		}
		s.getTransaction().commit();
		s.close();
	}

	@Test
	public void testMapEntryExpressionInSelect() {
		Session s = openSession();
		s.getTransaction().begin();
		{
			List addresses = s.createQuery( "select entry(v) from TestEntity te join te.values v" ).list();
			assertEquals( 2, addresses.size() );
			assertTyping( Map.Entry.class, addresses.get( 0 ) );

			addresses = s.createQuery( "select entry(te.values) from TestEntity te" ).list();
			assertEquals( 2, addresses.size() );
			assertTyping( Map.Entry.class, addresses.get( 0 ) );
		}
		s.getTransaction().commit();
		s.close();
	}

	@Test
	@TestForIssue(jiraKey = "HHH-10577")
	public void testMapKeyExpressionDereferenceInSelect() {
		Session s = openSession();
		s.getTransaction().begin();
		{
			List keyValueNames = s.createQuery( "select key(v).name as name from TestEntity te join te.values v order by name" ).list();
			assertEquals( 2, keyValueNames.size() );
			assertEquals( "key1", keyValueNames.get( 0 ) );
			assertEquals( "key2", keyValueNames.get( 1 ) );
		}
		s.getTransaction().commit();
		s.close();
	}

	@Test
	@TestForIssue(jiraKey = "HHH-10537")
	public void testLeftJoinMapAndUseKeyExpression() {
		Session s = openSession();
		s.getTransaction().begin();
		{
			// Assert that a left join is used for joining the map key entity table
			List keyValues= s.createQuery( "select key(v) from BaseTestEntity bte left join bte.entities te left join te.values v" ).list();
			System.out.println( keyValues );
			assertEquals( 2, keyValues.size() );
		}
		s.getTransaction().commit();
		s.close();
	}

	@Override
	protected boolean isCleanupTestDataRequired() {
		return true;
	}

	@Entity(name = "BaseTestEntity")
	@Table(name = "BASE_TEST_ENTITY")
	public static class BaseTestEntity {
		@Id
		@GeneratedValue
		Long id;

		@OneToMany
		Set<TestEntity> entities;
	}

	@Entity(name = "TestEntity")
	@Table(name = "TEST_ENTITY")
	public static class TestEntity {
		@Id
		@GeneratedValue
		Long id;

		@ElementCollection
		Map<KeyValue, EmbeddableValue> values;
	}

	@Entity(name = "KeyValue")
	@Table(name = "KEY_VALUE")
	public static class KeyValue {
		@Id
		@GeneratedValue
		Long id;

		String name;

		public KeyValue() {
		}

		public KeyValue(String name) {
			this.name = name;
		}
	}

	@Embeddable
	public static class EmbeddableValue {
		Integer value;

		EmbeddableValue() {

		}

		EmbeddableValue(Integer value) {
			this.value = value;
		}
	}
}
