Examples of org.apache.ojb.broker.accesslayer.ConnectionManagerIF.executeBatch()

Package org.apache.ojb.broker.accesslayer

Class org.apache.ojb.broker.accesslayer.ConnectionManagerIF

Examples of org.apache.ojb.broker.accesslayer.ConnectionManagerIF.executeBatch()

org.apache.ojb.broker.accesslayer.ConnectionManagerIF.executeBatch()
Execute batch (if the batch mode where used).

                    pbh.close();
                }
                handleList.clear();
            }
            ConnectionManagerIF cm = serviceConnectionManager();
            if(cm.isBatchMode()) cm.executeBatch();
            // close connection immediately when in JTA-tx to avoid bad reports from server con-pool
            if(cm.isInLocalTransaction())
            {
                // we should not be in a local tx when performing tx completion
                log.warn("Seems the used PersistenceBroker handle wasn't closed, close the used" +

View Full Code Here


        public void beforeCompletion()
        {
            if (log.isDebugEnabled()) log.debug("beforeCompletion was called, nothing to do");
            ConnectionManagerIF cm = serviceConnectionManager();
            if(cm.isBatchMode()) cm.executeBatch();
            // close connection immediately when in JTA-tx to avoid bad reports from server con-pool
            if(cm.isInLocalTransaction())
            {
                // we should not be in a local tx when performing tx completion
                log.warn("Seems the used PersistenceBroker handle wasn't closed, close the used" +

View Full Code Here


            // 3. commit objects.
            commitAllEnvelopes(broker);


            // 4. execute batch
            connMan.executeBatch();


            // 5.Update all Envelopes to new CleanState
            setCleanState();


        }

View Full Code Here

                    {
                        _pb.delete(entry.cacheObject);
                    }
                    entry.state = state.commit();
                }
                connMan.executeBatch();
            }
            finally
            {
                connMan.setBatchMode(saveBatchMode);
            }

View Full Code Here

                    pbh.close();
                }
                handleList.clear();
            }
            ConnectionManagerIF cm = serviceConnectionManager();
            if(cm.isBatchMode()) cm.executeBatch();
            // close connection immediately when in JTA-tx to avoid bad reports from server con-pool
            if(cm.isInLocalTransaction())
            {
                // we should not be in a local tx when performing tx completion
                log.warn("Seems the used PersistenceBroker handle wasn't closed, close the used" +

View Full Code Here


            // 5. write objects.
            writeAllEnvelopes(broker, needsReusePrepare);


            // 6. execute batch
            connMan.executeBatch();


            // 7. Update all Envelopes to new CleanState
            cleanupEnvelopes(needsReusePrepare);


            // 6. commit cleanup

View Full Code Here


        ProductGroup pg1 = new ProductGroup();
        pg1.setName("ProductGroup#1_" + name);
        broker.store(pg1);


        conMan.executeBatch();


        Article a1 = new Article();
        a1.setArticleName(name);
        a1.setProductGroup(pg1);
        pg1.add(a1);

View Full Code Here

        a3.setArticleName(name);
        a3.setProductGroup(pg3);
        pg3.add(a3);
        broker.store(a3);


        conMan.executeBatch();


        broker.delete(a1);


        conMan.executeBatch();

View Full Code Here


        conMan.executeBatch();


        broker.delete(a1);


        conMan.executeBatch();


        broker.delete(pg1);
        broker.delete(a2);
        broker.delete(pg2);
        broker.delete(a3);

View Full Code Here

        pg3.getAllArticles().clear();
        broker.store(pg3);
        broker.delete(pg3);
        broker.store(pg3);
        broker.delete(pg3);
        conMan.executeBatch();
        broker.commitTransaction();
    }


    /**
     * collection-descriptor without inverse reference-descriptor

View Full Code Here

0 1 2

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.