|
Hibernate example source code file (ManyToManyTest.java)
The Hibernate ManyToManyTest.java source code/* * Hibernate, Relational Persistence for Idiomatic Java * * Copyright (c) 2011, Red Hat Inc. or third-party contributors as * indicated by the @author tags or express copyright attribution * statements applied by the authors. All third-party contributions are * distributed under license by Red Hat Inc. * * This copyrighted material is made available to anyone wishing to use, modify, * copy, or redistribute it subject to the terms and conditions of the GNU * Lesser General Public License, as published by the Free Software Foundation. * * 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 Lesser General Public License * for more details. * * You should have received a copy of the GNU Lesser General Public License * along with this distribution; if not, write to: * Free Software Foundation, Inc. * 51 Franklin Street, Fifth Floor * Boston, MA 02110-1301 USA */ package org.hibernate.test.annotations.manytomany; import java.util.ArrayList; import java.util.Collection; import java.util.Date; import java.util.HashSet; import java.util.Iterator; import java.util.List; import java.util.Set; import org.hibernate.Hibernate; import org.hibernate.JDBCException; import org.hibernate.Session; import org.hibernate.Transaction; import org.hibernate.criterion.Restrictions; import org.junit.Test; import org.hibernate.testing.TestForIssue; import org.hibernate.testing.junit4.BaseCoreFunctionalTestCase; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; /** * Many to many tests * * @author Emmanuel Bernard */ @SuppressWarnings("unchecked") public class ManyToManyTest extends BaseCoreFunctionalTestCase { @Test public void testDefault() throws Exception { Session s; Transaction tx; s = openSession(); tx = s.beginTransaction(); Store fnac = new Store(); fnac.setName( "Fnac" ); KnownClient emmanuel = new KnownClient(); emmanuel.setName( "Emmanuel" ); emmanuel.setStores( new HashSet<Store>() ); fnac.setCustomers( new HashSet<KnownClient>() ); fnac.getCustomers().add( emmanuel ); emmanuel.getStores().add( fnac ); fnac.setImplantedIn( new HashSet<City>() ); City paris = new City(); fnac.getImplantedIn().add( paris ); paris.setName( "Paris" ); s.persist( fnac ); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); Store store; KnownClient knownClient; City city; store = (Store) s.get( Store.class, fnac.getId() ); assertNotNull( store ); assertNotNull( store.getCustomers() ); assertEquals( 1, store.getCustomers().size() ); knownClient = store.getCustomers().iterator().next(); assertEquals( emmanuel.getName(), knownClient.getName() ); assertNotNull( store.getImplantedIn() ); assertEquals( 1, store.getImplantedIn().size() ); city = store.getImplantedIn().iterator().next(); assertEquals( paris.getName(), city.getName() ); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); knownClient = (KnownClient) s.get( KnownClient.class, emmanuel.getId() ); assertNotNull( knownClient ); assertNotNull( knownClient.getStores() ); assertEquals( 1, knownClient.getStores().size() ); store = knownClient.getStores().iterator().next(); assertEquals( fnac.getName(), store.getName() ); tx.commit(); s.close(); } @Test public void testCanUseCriteriaQuery() throws Exception { Session s; Transaction tx; s = openSession(); tx = s.beginTransaction(); Store fnac = new Store(); fnac.setName( "Fnac" ); Supplier emi = new Supplier(); emi.setName( "Emmanuel" ); emi.setSuppStores( new HashSet<Store>() ); fnac.setSuppliers( new HashSet<Supplier>() ); fnac.getSuppliers().add( emi ); emi.getSuppStores().add( fnac ); s.persist( fnac ); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); List result = s.createCriteria( Supplier.class ).createAlias( "suppStores", "s" ).add( Restrictions.eq( "s.name", "Fnac" ) ).list(); assertEquals( 1, result.size() ); tx.commit(); s.close(); } @Test public void testDefaultCompositePk() throws Exception { Session s; Transaction tx; s = openSession(); tx = s.beginTransaction(); CatPk catPk = new CatPk(); catPk.setName( "Minou" ); catPk.setThoroughbred( "Persan" ); Cat cat = new Cat(); cat.setId( catPk ); cat.setAge( 32 ); Woman woman = new Woman(); WomanPk womanPk = new WomanPk(); womanPk.setFirstName( "Emma" ); womanPk.setLastName( "Peel" ); woman.setId( womanPk ); woman.setCats( new HashSet<Cat>() ); woman.getCats().add( cat ); cat.setHumanContacts( new HashSet<Woman>() ); cat.getHumanContacts().add( woman ); s.persist( woman ); s.persist( cat ); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); Cat sameCat = (Cat) s.get( Cat.class, cat.getId() ); assertNotNull( sameCat ); assertNotNull( sameCat.getHumanContacts() ); assertEquals( 1, sameCat.getHumanContacts().size() ); Woman sameWoman = sameCat.getHumanContacts().iterator().next(); assertEquals( sameWoman.getId().getLastName(), woman.getId().getLastName() ); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); sameWoman = (Woman) s.get( Woman.class, woman.getId() ); assertNotNull( sameWoman ); assertNotNull( sameWoman.getCats() ); assertEquals( 1, sameWoman.getCats().size() ); sameCat = sameWoman.getCats().iterator().next(); assertEquals( cat.getAge(), sameCat.getAge() ); tx.commit(); s.close(); } @Test public void testMappedBy() throws Exception { Session s; Transaction tx; s = openSession(); tx = s.beginTransaction(); Store fnac = new Store(); fnac.setName( "Fnac" ); Supplier emi = new Supplier(); emi.setName( "Emmanuel" ); emi.setSuppStores( new HashSet<Store>() ); fnac.setSuppliers( new HashSet<Supplier>() ); fnac.getSuppliers().add( emi ); emi.getSuppStores().add( fnac ); s.persist( fnac ); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); Store store; Supplier supplier; store = (Store) s.get( Store.class, fnac.getId() ); assertNotNull( store ); assertNotNull( store.getSuppliers() ); assertEquals( 1, store.getSuppliers().size() ); supplier = store.getSuppliers().iterator().next(); assertEquals( emi.getName(), supplier.getName() ); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); supplier = (Supplier) s.get( Supplier.class, emi.getId() ); assertNotNull( supplier ); assertNotNull( supplier.getSuppStores() ); assertEquals( 1, supplier.getSuppStores().size() ); store = supplier.getSuppStores().iterator().next(); assertEquals( fnac.getName(), store.getName() ); tx.commit(); s.close(); } @Test public void testBasic() throws Exception { Session s; Transaction tx; s = openSession(); tx = s.beginTransaction(); Employer er = new Employer(); Employee ee = new Employee(); s.persist( ee ); Set erColl = new HashSet(); Collection eeColl = new ArrayList(); erColl.add( ee ); eeColl.add( er ); er.setEmployees( erColl ); ee.setEmployers( eeColl ); //s.persist(ee); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); er = (Employer) s.load( Employer.class, er.getId() ); assertNotNull( er ); assertNotNull( er.getEmployees() ); assertEquals( 1, er.getEmployees().size() ); Employee eeFromDb = (Employee) er.getEmployees().iterator().next(); assertEquals( ee.getId(), eeFromDb.getId() ); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); ee = (Employee) s.get( Employee.class, ee.getId() ); assertNotNull( ee ); assertFalse( "ManyToMany mappedBy lazyness", Hibernate.isInitialized( ee.getEmployers() ) ); tx.commit(); assertFalse( "ManyToMany mappedBy lazyness", Hibernate.isInitialized( ee.getEmployers() ) ); s.close(); s = openSession(); tx = s.beginTransaction(); ee = (Employee) s.get( Employee.class, ee.getId() ); assertNotNull( ee ); er = ee.getEmployers().iterator().next(); assertTrue( "second join non lazy", Hibernate.isInitialized( er ) ); s.delete( er ); s.delete( ee ); tx.commit(); s.close(); } @Test public void testOrderByEmployee() throws Exception { Session s; Transaction tx; s = openSession(); tx = s.beginTransaction(); Employer employer = new Employer(); Employee employee1 = new Employee(); employee1.setName( "Emmanuel" ); Employee employee2 = new Employee(); employee2.setName( "Alice" ); s.persist( employee1 ); s.persist( employee2 ); Set erColl = new HashSet(); Collection eeColl = new ArrayList(); Collection eeColl2 = new ArrayList(); erColl.add( employee1 ); erColl.add( employee2 ); eeColl.add( employer ); eeColl2.add( employer ); employer.setEmployees( erColl ); employee1.setEmployers( eeColl ); employee2.setEmployers( eeColl2 ); s.flush(); s.clear(); employer = (Employer) s.get( Employer.class, employer.getId() ); assertNotNull( employer ); assertNotNull( employer.getEmployees() ); assertEquals( 2, employer.getEmployees().size() ); Employee eeFromDb = (Employee) employer.getEmployees().iterator().next(); assertEquals( employee2.getName(), eeFromDb.getName() ); tx.rollback(); s.close(); } @Test public void testRemoveInBetween() throws Exception { Session s; Transaction tx; s = openSession(); tx = s.beginTransaction(); Employer er = new Employer(); Employee ee = new Employee(); Employee ee2 = new Employee(); s.persist( ee ); s.persist( ee2 ); Set erColl = new HashSet(); Collection eeColl = new ArrayList(); erColl.add( ee ); erColl.add( ee2 ); eeColl.add( er ); er.setEmployees( erColl ); ee.setEmployers( eeColl ); //s.persist(ee); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); er = (Employer) s.load( Employer.class, er.getId() ); assertNotNull( er ); assertNotNull( er.getEmployees() ); assertEquals( 2, er.getEmployees().size() ); Iterator iterator = er.getEmployees().iterator(); Employee eeFromDb = (Employee) iterator.next(); if ( eeFromDb.getId().equals( ee.getId() ) ) { eeFromDb = (Employee) iterator.next(); } assertEquals( ee2.getId(), eeFromDb.getId() ); er.getEmployees().remove( eeFromDb ); eeFromDb.getEmployers().remove( er ); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); ee = (Employee) s.get( Employee.class, ee.getId() ); assertNotNull( ee ); assertFalse( "ManyToMany mappedBy lazyness", Hibernate.isInitialized( ee.getEmployers() ) ); tx.commit(); assertFalse( "ManyToMany mappedBy lazyness", Hibernate.isInitialized( ee.getEmployers() ) ); s.close(); s = openSession(); tx = s.beginTransaction(); ee = (Employee) s.get( Employee.class, ee.getId() ); assertNotNull( ee ); er = ee.getEmployers().iterator().next(); assertTrue( "second join non lazy", Hibernate.isInitialized( er ) ); assertEquals( 1, er.getEmployees().size() ); s.delete( er ); s.delete( ee ); tx.commit(); s.close(); } @Test public void testSelf() throws Exception { Session s; Transaction tx; s = openSession(); tx = s.beginTransaction(); Friend f = new Friend(); Friend sndF = new Friend(); f.setName( "Starsky" ); sndF.setName( "Hutch" ); Set frnds = new HashSet(); frnds.add( sndF ); f.setFriends( frnds ); //Starsky is a friend of Hutch but hutch is not s.persist( f ); tx.commit(); s.close(); s = openSession(); tx = s.beginTransaction(); f = (Friend) s.load( Friend.class, f.getId() ); assertNotNull( f ); assertNotNull( f.getFriends() ); assertEquals( 1, f.getFriends().size() ); Friend fromDb2ndFrnd = f.getFriends().iterator().next(); assertEquals( fromDb2ndFrnd.getId(), sndF.getId() ); assertEquals( 0, fromDb2ndFrnd.getFriends().size() ); tx.commit(); s.close(); } @Test public void testCompositePk() throws Exception { Session s; Transaction tx; ManPk m1pk = new ManPk(); m1pk.setElder( true ); m1pk.setFirstName( "Lucky" ); m1pk.setLastName( "Luke" ); ManPk m2pk = new ManPk(); m2pk.setElder( false ); m2pk.setFirstName( "Joe" ); m2pk.setLastName( "Dalton" ); Man m1 = new Man(); m1.setId( m1pk ); m1.setCarName( "Jolly Jumper" ); Man m2 = new Man(); m2.setId( m2pk ); WomanPk w1pk = new WomanPk(); w1pk.setFirstName( "Ma" ); w1pk.setLastName( "Dalton" ); WomanPk w2pk = new WomanPk(); w2pk.setFirstName( "Carla" ); w2pk.setLastName( "Bruni" ); Woman w1 = new Woman(); w1.setId( w1pk ); Woman w2 = new Woman(); w2.setId( w2pk ); Set<Woman> womens = new HashSet Other Hibernate examples (source code examples)Here is a short list of links related to this Hibernate ManyToManyTest.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.