List of readF2() Examples

Examples of readF2()

Examples of org.objectweb.speedo.pobjects.basic.BasicA.readF2()

                    pm2.currentTransaction().begin();
                    logger.log(BasicLevel.INFO, "Thread2: getObjectById");
                    BasicA ba = (BasicA) pm2.getObjectById(id, true);
                    Assert.assertNotNull("Object not found", ba);
                    logger.log(BasicLevel.INFO, "Thread2: write");
                    ba.writeF2(ba.readF2() + 1);
                    logger.log(BasicLevel.INFO, "Thread2: write done");


                    logger.log(BasicLevel.INFO, "Thread2: commit");
                    pm2.currentTransaction().commit();
                } catch (JDOFatalException e) {

View Full Code Here

Examples of org.objectweb.speedo.pobjects.basic.BasicA.readF2()

    pm = pmf.getPersistenceManager();
    pm.currentTransaction().begin();
    ba = (BasicA) pm.getObjectById(id, true);
    Assert.assertNotNull("Object not found", ba);
    Assert.assertEquals("Bad f1 value", "1", ba.readF1());
    Assert.assertEquals("Bad f2 value", 4, ba.readF2());
    pm.deletePersistent(ba);
    pm.currentTransaction().commit();
    pm.close();
  }

View Full Code Here

Examples of org.objectweb.speedo.pobjects.basic.BasicA.readF2()

                    pm2.currentTransaction().begin();
                    logger.log(BasicLevel.INFO, "Thread2: getObjectById");
                    BasicA ba = (BasicA) pm2.getObjectById(id, true);
                    Assert.assertNotNull("Object not found", ba);
                    logger.log(BasicLevel.INFO, "Thread2: write");
                    ba.writeF2(ba.readF2() + 1);
                    logger.log(BasicLevel.INFO, "Thread2: write done");


                    logger.log(BasicLevel.INFO, "Thread2: commit");
                    pm2.currentTransaction().commit();
                } catch (JDOFatalException e) {

View Full Code Here

Examples of org.objectweb.speedo.pobjects.basic.BasicA.readF2()


        // end transaction 1
        logger.log(BasicLevel.INFO, "Thread1: write");
        boolean ok = true;
        try {
            ba.writeF2(ba.readF2() + 1);
            ok = true;
            logger.log(BasicLevel.INFO, "Thread1: write done");
            logger.log(BasicLevel.INFO, "Thread1: commit");
            pm1.currentTransaction().commit();
        } catch (JDOException e) {

View Full Code Here

Examples of org.objectweb.speedo.pobjects.basic.BasicA.readF2()

        pm = pmf.getPersistenceManager();
        pm.currentTransaction().begin();
        ba = (BasicA) pm.getObjectById(id, true);
        Assert.assertNotNull("Object not found", ba);
        Assert.assertEquals("Bad f1 value", "1", ba.readF1());
        Assert.assertEquals("Bad f2 value", ( ok ? 4 : 3), ba.readF2());
        pm.deletePersistent(ba);
        pm.currentTransaction().commit();
        pm.close();
    }

View Full Code Here

Examples of org.objectweb.speedo.pobjects.basic.BasicA.readF2()

                switch(actions[j]) {
                case W_ACTION:
                  a.incF2();
                  break;
                case R_W_ACTION:
                  a.writeF2(a.readF2() + 1);
                  break;
                case MIXED_ACTION:
                    if (action == W_ACTION) {
                        a.incF2();
                        action = R_W_ACTION;

View Full Code Here

Examples of org.objectweb.speedo.pobjects.basic.BasicA.readF2()

                case MIXED_ACTION:
                    if (action == W_ACTION) {
                        a.incF2();
                        action = R_W_ACTION;
                    } else if (action == R_W_ACTION) {
                        a.writeF2(a.readF2() + 1);
                        action = W_ACTION;
                    }
                  break;
                }
                pm.currentTransaction().commit();

View Full Code Here

Examples of org.objectweb.speedo.pobjects.basic.BasicA.readF2()

            }
            st.getLogger().log(BasicLevel.DEBUG, "Thread " + threadId + " expect: " + expected);
            Collection found = new ArrayList();
            for (Iterator iter = c.iterator(); iter.hasNext();) {
                ba = (BasicA) iter.next();
                int f2 = ba.readF2();
                found.add(new Integer(f2));
            }
            q.closeAll();
            st.getLogger().log(BasicLevel.DEBUG, "Thread " + threadId + " found: " + found);
            st.assertSameCollection("Bad query result"

View Full Code Here

Examples of org.objectweb.speedo.pobjects.userid.BasicB.readF2()

            bb = (BasicB) pm.getObjectById(o, false);
            Assert.assertNotNull("returned object is null", bb);
            Assert.assertEquals("Bad field 'id1' value", id1, bb.getId1());
            Assert.assertEquals("Bad field 'di2' value", id2, bb.getId2());
            Assert.assertEquals("Bad field 'f1' value", f1, bb.readF1());
            Assert.assertEquals("Bad field 'f1' value", f2, bb.readF2());


      Query q = pm.newQuery(BasicB.class);
      Iterator it = ((Collection) q.execute()).iterator();
      while(it.hasNext()) {
        BasicB _bb = (BasicB) it.next();

View Full Code Here

Examples of org.objectweb.speedo.pobjects.userid.BasicB.readF2()

            bb = (BasicB) pm.getObjectById(id, false);
            Assert.assertNotNull("returned object is null", bb);
            Assert.assertEquals("Bad field 'id1' value", id1, bb.getId1());
            Assert.assertEquals("Bad field 'di2' value", id2, bb.getId2());
            Assert.assertEquals("Bad field 'f1' value", f1, bb.readF1());
            Assert.assertEquals("Bad field 'f1' value", f2, bb.readF2());
            pm.currentTransaction().begin();
            pm.deletePersistent(bb);
            pm.currentTransaction().commit();
            pm.close();
        } catch (Exception e) {

View Full Code Here

0 1 2 3

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.