Java Reference
In-Depth Information
public static void main(String[] argv) {
System.out.println("Creating test user...");
createUser("test");
System.out.println("Proceeding to main test...");
Session s1 = factory.openSession();
Session s2 = factory.openSession();
try {
s1.beginTransaction();
s2.beginTransaction();
System.out.println("Update 1");
Query q1 = s1.createQuery("from Publisher");
Publisher pub1 = (Publisher) q1.uniqueResult();
pub1.setUsername("jeff");
s1.flush();
System.out.println("Update 2");
Query q2 = s2.createQuery("from Subscriber");
Subscriber sub1 = (Subscriber) q2.uniqueResult();
sub1.setUsername("dave");
s2.flush();
System.out.println("Update 3");
Query q3 = s1.createQuery("from Subscriber");
Subscriber sub2 = (Subscriber) q3.uniqueResult();
sub2.setUsername("jeff");
s1.flush();
System.out.println("Update 4");
Query q4 = s2.createQuery("from Publisher");
Publisher pub2 = (Publisher) q4.uniqueResult();
pub2.setUsername("dave");
s2.flush();
s1.getTransaction().commit();
s2.getTransaction().commit();
} catch (RuntimeException e1) {
e1.printStackTrace();
// Run the boilerplate to roll back the sessions
rollback(s1);
rollback(s2);
throw e1;
} finally {
Search WWH ::




Custom Search