foobartest.java

用Java实现的23个常用设计模式源代码

		Session s = openSession();
		Baz baz = new Baz();
		SortedSet stringSet = new TreeSet();
		stringSet.add("foo");
		stringSet.add("bar");
		Set fooSet = new HashSet();
		for (int i=0; i<3; i++) {
			Foo foo = new Foo();
			s.save(foo);
			fooSet.add(foo);
		}
		baz.setFooSet(fooSet);
		baz.setStringSet(stringSet);
		s.save(baz);
		Baz baz2 = new Baz();
		fooSet = new HashSet();
		for (int i=0; i<2; i++) {
			Foo foo = new Foo();
			s.save(foo);
			fooSet.add(foo);
		}
		baz2.setFooSet(fooSet);
		s.save(baz2);
		Baz baz3 = new Baz();
		stringSet = new TreeSet();
		stringSet.add("foo");
		stringSet.add("baz");
		baz3.setStringSet(stringSet);
		s.save(baz3);
		s.flush();
		s.connection().commit();
		s.close();
		
		s = openSession();
		baz = (Baz) s.load( Baz.class, baz.getCode() );
		baz2 = (Baz) s.load( Baz.class, baz2.getCode() );
		baz3 = (Baz) s.load( Baz.class, baz3.getCode() );
		assertFalse( Hibernate.isInitialized(baz.getFooSet()) || Hibernate.isInitialized(baz2.getFooSet()) || Hibernate.isInitialized(baz3.getFooSet()) );
		assertFalse( Hibernate.isInitialized(baz.getStringSet()) || Hibernate.isInitialized(baz2.getStringSet()) || Hibernate.isInitialized(baz3.getStringSet()) );
		assertTrue( baz.getFooSet().size()==3 );
		assertTrue( Hibernate.isInitialized(baz.getFooSet()) && Hibernate.isInitialized(baz2.getFooSet()) && Hibernate.isInitialized(baz3.getFooSet()));
		assertTrue( baz2.getFooSet().size()==2 );
		assertTrue( baz3.getStringSet().contains("baz") );
		assertTrue( Hibernate.isInitialized(baz.getStringSet()) && Hibernate.isInitialized(baz2.getStringSet()) && Hibernate.isInitialized(baz3.getStringSet()));
		assertTrue( baz.getStringSet().size()==2 && baz2.getStringSet().size()==0 );
		s.delete(baz);
		s.delete(baz2);
		s.delete(baz3);
		Iterator iter = new JoinedIterator( new Iterator[] { baz.getFooSet().iterator(), baz2.getFooSet().iterator() } );
		while ( iter.hasNext() ) s.delete( iter.next() );
		s.flush();
		s.connection().commit();
		s.close();
		
	}
	
	public void testFetchInitializedCollection() throws Exception {
		Session s = openSession();
		Baz baz = new Baz();
		Collection fooBag = new ArrayList();
		fooBag.add( new Foo() );
		fooBag.add( new Foo() );
		baz.setFooBag(fooBag);
		s.save(baz);
		s.flush();
		fooBag = baz.getFooBag();
		s.find("from Baz baz left join fetch baz.fooBag");
		assertTrue( fooBag==baz.getFooBag() );
		s.connection().commit();
		s.close();
		
		s = openSession();
		baz = (Baz) s.load( Baz.class, baz.getCode() );
		Object bag = baz.getFooBag();
		assertFalse( Hibernate.isInitialized(bag) );
		s.find("from Baz baz left join fetch baz.fooBag");
		assertTrue( bag==baz.getFooBag() );
		assertTrue( baz.getFooBag().size()==2 );
		s.delete(baz);
		s.flush();
		s.connection().commit();
		s.close();
	}
	
	public void testLateCollectionAdd() throws Exception {
		Session s = openSession();
		Baz baz = new Baz();
		List l = new ArrayList();
		baz.setStringList(l);
		l.add("foo");
		Serializable id = s.save(baz);
		l.add("bar");
		s.flush();
		l.add("baz");
		s.flush();
		s.connection().commit();
		s.close();
		
		s = openSession();
		baz = (Baz) s.load(Baz.class, id);
		assertTrue( baz.getStringList().size()==3 && baz.getStringList().contains("bar") );
		s.delete(baz);
		s.flush();
		s.connection().commit();
		s.close();
		
	}

	public void testUpdate() throws Exception {
		Session s = openSession();
		Foo foo = new Foo();
		s.save(foo);
		s.flush();
		s.connection().commit();
		s.close();
		
		foo = (Foo) SerializationHelper.deserialize( SerializationHelper.serialize(foo) );
		
		s = openSession();
		FooProxy foo2 = (FooProxy) s.load( Foo.class, foo.getKey() );
		foo2.setString("dirty");
		foo2.setBoolean( new Boolean(false) );
		foo2.setBytes( new byte[] { 1,2,3} );
		foo2.setDate(null);
		foo2.setShort( new Short("69") );
		s.flush();
		s.connection().commit();
		s.close();
		
		s = openSession();
		foo2.setString("dirty again");
		s.update(foo2);
		s.flush();
		s.connection().commit();
		s.close();
		
		s = openSession();
		foo2.setString("dirty again 2");
		s.update(foo2);
		s.flush();
		s.connection().commit();
		s.close();
		
		s = openSession();
		Foo foo3 = new Foo();
		s.load( foo3, foo.getKey() );
		// There is an interbase bug that causes null integers to return as 0, also numeric precision is <= 15
		assertTrue( "update", foo2.equalsFoo(foo3) );
		s.delete(foo3);
		s.delete("from Glarch");
		s.flush();
		s.connection().commit();
		s.close();

	}
	
	public void testListRemove() throws Exception {
		Session s = openSession();
		Baz b = new Baz();
		List stringList = new ArrayList();
		List feeList = new ArrayList();
		b.setFees(feeList);
		b.setStringList(stringList);
		feeList.add( new Fee() );
		feeList.add( new Fee() );
		feeList.add( new Fee() );
		feeList.add( new Fee() );
		stringList.add("foo");
		stringList.add("bar");
		stringList.add("baz");
		stringList.add("glarch");
		s.save(b);
		s.flush();
		stringList.remove(1);
		feeList.remove(1);
		s.flush();
		s.evict(b);
		s.refresh(b);
		assertTrue( b.getFees().size()==3 );
		stringList = b.getStringList();
		assertTrue( 
			stringList.size()==3 && 
			"baz".equals( stringList.get(1) ) && 
			"foo".equals( stringList.get(0) ) 
		);
		s.delete(b);
		s.delete("from Fee");
		s.flush();
		s.connection().commit();
		s.close();
	}
	
	public void testFetchInitializedCollectionDupe() throws Exception {
		Session s = openSession();
		Baz baz = new Baz();
		Collection fooBag = new ArrayList();
		fooBag.add( new Foo() );
		fooBag.add( new Foo() );
		baz.setFooBag(fooBag);
		s.save(baz);
		s.flush();
		fooBag = baz.getFooBag();
		s.find("from Baz baz left join fetch baz.fooBag");
		assertTrue( Hibernate.isInitialized(fooBag) );
		assertTrue( fooBag==baz.getFooBag() );
		assertTrue( baz.getFooBag().size()==2 );
		s.connection().commit();
		s.close();
		
		s = openSession();
		baz = (Baz) s.load( Baz.class, baz.getCode() );
		Object bag = baz.getFooBag();
		assertFalse( Hibernate.isInitialized(bag) );
		s.find("from Baz baz left join fetch baz.fooBag");
		assertTrue( Hibernate.isInitialized(bag) );
		assertTrue( bag==baz.getFooBag() );
		assertTrue( baz.getFooBag().size()==2 );
		s.delete(baz);
		s.flush();
		s.connection().commit();
		s.close();
	}
	
	public void testSortables() throws Exception {
		Session s = openSession();
		Baz b = new Baz();
		b.setName("name");
		SortedSet ss = new TreeSet();
		ss.add( new Sortable("foo") );
		ss.add( new Sortable("bar") );
		ss.add( new Sortable("baz") );
		b.setSortablez(ss);
		s.save(b);
		s.flush();
		s.connection().commit();
		s.close();
		
		s = openSession();
		Criteria cr = s.createCriteria(Baz.class);
		if (getDialect() instanceof PostgreSQLDialect) cr.setFetchMode("topGlarchez", FetchMode.LAZY);
		List result = cr
			.addOrder( Order.asc("name") )
			.list();
		assertTrue( result.size()==1 );
		b = (Baz) result.get(0);
		assertTrue( b.getSortablez().size()==3 );
		assertEquals( ( (Sortable) b.getSortablez().iterator().next() ).getName(), "bar" );
		s.connection().commit();
		s.close();
		
		s = openSession();
		result = s.createQuery("from Baz baz left join fetch baz.sortablez order by baz.name asc")
			.list();
		b = (Baz) result.get(0);
		assertTrue( b.getSortablez().size()==3 );
		assertEquals( ( (Sortable) b.getSortablez().iterator().next() ).getName(), "bar" );
		s.connection().commit();
		s.close();
		
		s = openSession();
		result = s.createQuery("from Baz baz order by baz.name asc")
			.list();
		b = (Baz) result.get(0);
		assertTrue( b.getSortablez().size()==3 );
		assertEquals( ( (Sortable) b.getSortablez().iterator().next() ).getName(), "bar" );
		s.delete(b);
		s.flush();
		s.connection().commit();
		s.close();
		
	}
	
	public void testFetchList() throws Exception {
		Session s = openSession();
		Baz baz = new Baz();
		s.save(baz);
		Foo foo = new Foo();
		s.save(foo);
		Foo foo2 = new Foo();
		s.save(foo2);
		s.flush();
		List list = new ArrayList();
		for ( int i=0; i<5; i++ ) {
			Fee fee = new Fee();
			list.add(fee);
		}
		baz.setFees(list);
		list = s.find("from Foo foo, Baz baz left join fetch baz.fees");
		assertTrue( Hibernate.isInitialized( ( (Baz) ( (Object[]) list.get(0) )[1] ).getFees() ) );
		s.delete(foo);
		s.delete(foo2);
		s.delete(baz);
		s.flush();
		s.connection().commit();
		s.close();
	}
	
	public void testBagOneToMany() throws Exception {
		Session s = openSession();
		Baz baz = new Baz();
		List list = new ArrayList();
		baz.setBazez(list);
		list.add( new Baz() );
		s.save(baz);
		s.flush();
		list.add( new Baz() );
		s.flush();
		list.add( 0, new Baz() );
		s.flush();
		s.delete( list.remove(1) );
		s.flush();
		s.delete(baz);
		s.flush();
		s.connection().commit();
		s.close();
	}
	
	public void testQueryLockMode() throws Exception {
		
		Session s = openSession();
		Bar bar = new Bar();
		s.save(bar);
		s.flush();
		bar.setString("changed");
		Baz baz = new Baz();
		baz.setFoo(bar);
		s.save(baz);
		Query q = s.createQuery("from Foo foo, Bar bar");
		if ( !(getDialect() instanceof DB2Dialect) ) {
			q.setLockMode("bar", LockMode.UPGRADE);
		}
		Object[] result = (Object[]) q.uniqueResult();
		Object b = result[0];
		assertTrue( s.getCurrentLockMode(b)==LockMode.WRITE && s.getCurrentLockMode( result[1] )==LockMode.WRITE );
		s.flush();
		s.connection().commit();
		s.disconnect();
		
		s.reconnect();
		assertTrue( s.getCurrentLockMode(b)==LockMode.NONE );
		s.find("from Foo foo");
		assertTrue( s.getCurrentLockMode(b)==LockMode.NONE );
		q = s.createQuery("from Foo foo");
		q.setLockMode("foo", LockMode.READ);
		q.list();
		assertTrue( s.getCurrentLockMode(b)==LockMode.READ);
		s.evict(baz);
		s.connection().commit();
		s.disconnect();
		s.reconnect();
		assertTrue( s.getCurrentLockMode(b)==LockMode.NONE );
		s.delete( s.load( Baz.class, baz.getCode() ) );
		assertTrue( s.getCurrentLockMode(b)==LockMode.NONE );
		s.flush();
		s.connection().commit();
		s.close();
		
		s = openSession();
		q = s.createQuery("from Foo foo, Bar bar, Bar bar2");
		if ( !(getDialect() instanceof DB2Dialect) ) {
			q.setLockMode("bar", LockMode.UPGRADE);
		}
		q.setLockMode("bar2", LockMode.READ);
		result = (Object[]) q.list().get(0);
		if ( !(getDialect() instanceof DB2Dialect) ) {
			assertTrue( s.getCurrentLockMode( result[0] )==LockMode.UPGRADE && s.getCurrentLockMode( result[1] )==LockMode.UPGRADE );
		}
		s.delete( result[0] );
		s.flush();
		s.connection().commit();
		s.close();
	}
	
	public void testManyToManyBag() throws Exception {
		
		Session s = openSession();
		Baz baz = new Baz();
		Serializable id = s.save(baz);
		s.flush();
		s.connection().commit();
		s.close();
		
		s = openSession();
		baz = (Baz) s.load(Baz.class, id);
		baz.getFooBag().add( new Foo() );
		s.flush();
		s.connection().commit();
		s.close();