~ubuntu-branches/ubuntu/wily/libhibernate3-java/wily-proposed

if ( !(getDialect() instanceof MySQLDialect) && !(getDialect() instanceof HSQLDialect) && !(getDialect() instanceof MckoiDialect) && !(getDialect() instanceof PointbaseDialect) ) {

707

s.find("from Fum fum1 where exists elements(fum1.friends)");

708

if(!(getDialect() instanceof TimesTenDialect)) { // can't execute because TimesTen can't do subqueries combined with aggreations

709

s.find("from Fum fum1 where size(fum1.friends) = 0");

710

}

711

}

712

s.find("select elements(fum1.friends) from Fum fum1");

713

s.find("from Fum fum1, fr in elements( fum1.friends )");

714

s.connection().commit();

715

s.close();

716

}

717

718

public void testUnflushedSessionSerialization() throws Exception {

719

720

///////////////////////////////////////////////////////////////////////////

721

// Test insertions across serializations

722

Session s = getSessions().openSession();

723

s.setFlushMode(FlushMode.NEVER);

724

725

Simple simple = new Simple();

726

simple.setAddress("123 Main St. Anytown USA");

727

simple.setCount(1);

728

simple.setDate( new Date() );

729

simple.setName("My UnflushedSessionSerialization Simple");

730

simple.setPay( new Float(5000) );

731

s.save( simple, new Long(10) );

732

733

// Now, try to serialize session without flushing...

734

s.disconnect();

735

Session s2 = spoofSerialization(s);

736

s.close();

737

s = s2;

738

s.reconnect();

739

740

simple = (Simple) s.load( Simple.class, new Long(10) );

741

Simple other = new Simple();

742

other.init();

743

s.save( other, new Long(11) );

744

745

simple.setOther(other);

746

s.flush();

747

748

s.connection().commit();

749

s.close();

750

Simple check = simple;

751

752

///////////////////////////////////////////////////////////////////////////

753

// Test updates across serializations

754

s = getSessions().openSession();

755

s.setFlushMode(FlushMode.NEVER);

756

757

simple = (Simple) s.get( Simple.class, new Long(10) );

758

assertTrue("Not same parent instances", check.getName().equals( simple.getName() ) );

759

assertTrue("Not same child instances", check.getOther().getName().equals( other.getName() ) );

760

761

simple.setName("My updated name");

762

763

s.disconnect();

764

s2 = spoofSerialization(s);

765

s.close();

766

s = s2;

767

s.reconnect();

768

s.flush();

769

770

s.connection().commit();

771

s.close();

772

check = simple;

773

774

///////////////////////////////////////////////////////////////////////////

775

// Test deletions across serializations

776

s = getSessions().openSession();

777

s.setFlushMode(FlushMode.NEVER);

778

779

simple = (Simple) s.get( Simple.class, new Long(10) );

780

assertTrue("Not same parent instances", check.getName().equals( simple.getName() ) );

781

assertTrue("Not same child instances", check.getOther().getName().equals( other.getName() ) );

782

783

// Now, lets delete across serialization...

784

s.delete(simple);

785

786

s.disconnect();

787

s2 = spoofSerialization(s);

788

s.close();

789

s = s2;

790

s.reconnect();

791

s.flush();

792

793

s.connection().commit();

794

s.close();

795

796

///////////////////////////////////////////////////////////////////////////

797

// Test collection actions across serializations

798

s = getSessions().openSession();

799

s.setFlushMode(FlushMode.NEVER);

800

801

Fum fum = new Fum( fumKey("uss-fum") );

802

fum.setFo( new Fum( fumKey("uss-fo") ) );

803

fum.setFum("fo fee fi");

804

fum.getFo().setFum("stuff");

805

Fum fr = new Fum( fumKey("uss-fr") );

806

fr.setFum("goo");

807

Fum fr2 = new Fum( fumKey("uss-fr2") );

808

fr2.setFum("soo");

809

fum.setFriends( new HashSet() );

810

fum.getFriends().add(fr);

811

fum.getFriends().add(fr2);

812

s.save(fr);

813

s.save(fr2);

814

s.save( fum.getFo() );

815

s.save(fum);

816

817

s.disconnect();

818

s2 = spoofSerialization(s);

819

s.close();

820

s = s2;

821

s.reconnect();

822

s.flush();

823

824

s.connection().commit();

825

s.close();

826

827

s = getSessions().openSession();

828

s.setFlushMode(FlushMode.NEVER);

829

fum = (Fum) s.load( Fum.class, fum.getId() );

830

831

assertTrue("the Fum.friends did not get saved", fum.getFriends().size() == 2);

832

833

fum.setFriends(null);

834

s.disconnect();

835

s2 = spoofSerialization(s);

836

s.close();

837

838

s = s2;

839

s.reconnect();

840

s.flush();

841

842

s.connection().commit();

843

s.close();

844

845

s = getSessions().openSession();

846

s.setFlushMode(FlushMode.NEVER);

847

fum = (Fum) s.load( Fum.class, fum.getId() );

848

assertTrue("the Fum.friends is not empty", fum.getFriends() == null || fum.getFriends().size() == 0);

849

s.connection().commit();

850

s.close();

851

}

852

853

private Session spoofSerialization(Session session) throws IOException {

854

try {

855

// Serialize the incoming out to memory

856

ByteArrayOutputStream serBaOut = new ByteArrayOutputStream();

857

ObjectOutputStream serOut = new ObjectOutputStream(serBaOut);

858

859

serOut.writeObject(session);

860

861

// Now, re-constitute the model from memory

862

ByteArrayInputStream serBaIn =

863

new ByteArrayInputStream(serBaOut.toByteArray());

864

ObjectInputStream serIn = new ObjectInputStream(serBaIn);

865

866

Session outgoing = (Session) serIn.readObject();

867

868

return outgoing;

869

}

870

catch (ClassNotFoundException cnfe) {

871

throw new IOException("Unable to locate class on reconstruction");

872

}

873

}

874

875

}

876

877

878

879

880

881

882

Older »