Examples of serviceConnectionManager()

Examples of org.apache.ojb.broker.PersistenceBroker.serviceConnectionManager()

185
186
187
188
189
190
191
192
193
194
195
      }

      PersistenceBrokerTransactionObject txObject = (PersistenceBrokerTransactionObject) transaction;
      txObject.setPersistenceBrokerHolder(new PersistenceBrokerHolder(pb));

      Connection con = pb.serviceConnectionManager().getConnection();
      Integer previousIsolationLevel = DataSourceUtils.prepareConnectionForTransaction(con, definition);
      txObject.setPreviousIsolationLevel(previousIsolationLevel);

      pb.beginTransaction();
View Full Code Here

Examples of org.apache.ojb.broker.PersistenceBroker.serviceConnectionManager()

286
287
288
289
290
291
292
293
294
295
296
      TransactionSynchronizationManager.unbindResource(getDataSource());
    }

    PersistenceBroker pb = txObject.getPersistenceBrokerHolder().getPersistenceBroker();
    try {
      Connection con = pb.serviceConnectionManager().getConnection();
      DataSourceUtils.resetConnectionAfterTransaction(con, txObject.getPreviousIsolationLevel());
    }
    catch (LookupException ex) {
      logger.info("Could not look up JDBC Connection of OJB PersistenceBroker", ex);
    }
View Full Code Here

Examples of org.apache.ojb.broker.PersistenceBroker.serviceConnectionManager()

54
55
56
57
58
59
60
61
62
63
64
    final ConnectionManagerIF cm = (ConnectionManagerIF) cmControl.getMock();
    final Object entity = new Object();
    MockControl conControl = MockControl.createControl(Connection.class);
    Connection con = (Connection) conControl.getMock();

    pb.serviceConnectionManager();
    pbControl.setReturnValue(cm, 2);
    cm.getConnection();
    cmControl.setReturnValue(con, 2);
    con.isReadOnly();
    conControl.setReturnValue(false, 1);
View Full Code Here

Examples of org.apache.ojb.broker.PersistenceBroker.serviceConnectionManager()

104
105
106
107
108
109
110
111
112
113
114
    final ConnectionManagerIF cm = (ConnectionManagerIF) cmControl.getMock();
    final Object entity = new Object();
    MockControl conControl = MockControl.createControl(Connection.class);
    Connection con = (Connection) conControl.getMock();

    pb.serviceConnectionManager();
    pbControl.setReturnValue(cm, 2);
    cm.getConnection();
    cmControl.setReturnValue(con, 2);
    con.setReadOnly(true);
    conControl.setVoidCallable(1);
View Full Code Here

Examples of org.apache.ojb.broker.PersistenceBroker.serviceConnectionManager()

167
168
169
170
171
172
173
174
175
176
177
    final ConnectionManagerIF cm = (ConnectionManagerIF) cmControl.getMock();
    final Object entity = new Object();
    MockControl conControl = MockControl.createControl(Connection.class);
    Connection con = (Connection) conControl.getMock();

    pb.serviceConnectionManager();
    pbControl.setReturnValue(cm, 2);
    cm.getConnection();
    cmControl.setReturnValue(con, 2);
    con.isReadOnly();
    conControl.setReturnValue(false, 1);
View Full Code Here

Examples of org.apache.ojb.broker.PersistenceBroker.serviceConnectionManager()

222
223
224
225
226
227
228
229
230
231
232
    final ConnectionManagerIF cm = (ConnectionManagerIF) cmControl.getMock();
    final Object entity = new Object();
    MockControl conControl = MockControl.createControl(Connection.class);
    Connection con = (Connection) conControl.getMock();

    pb.serviceConnectionManager();
    pbControl.setReturnValue(cm, 2);
    cm.getConnection();
    cmControl.setReturnValue(con, 2);
    con.isReadOnly();
    conControl.setReturnValue(false, 1);
View Full Code Here

Examples of org.apache.ojb.broker.PersistenceBroker.serviceConnectionManager()

293
294
295
296
297
298
299
300
301
302
303
    cmControl.setReturnValue(con, 4);
    con.isReadOnly();
    conControl.setReturnValue(false, 2);
    pb1.beginTransaction();
    pb1Control.setVoidCallable(1);
    pb2.serviceConnectionManager();
    pb2Control.setReturnValue(cm, 2);
    pb2.beginTransaction();
    pb2Control.setVoidCallable(1);
    pb2.commitTransaction();
    pb2Control.setVoidCallable(1);
View Full Code Here

Examples of org.apache.ojb.broker.PersistenceBroker.serviceConnectionManager()

354
355
356
357
358
359
360
361
362
363
364
    final ConnectionManagerIF cm = (ConnectionManagerIF) cmControl.getMock();
    final Object entity = new Object();
    MockControl conControl = MockControl.createControl(Connection.class);
    Connection con = (Connection) conControl.getMock();

    pb.serviceConnectionManager();
    pbControl.setReturnValue(cm, 2);
    cm.getConnection();
    cmControl.setReturnValue(con, 2);
    con.isReadOnly();
    conControl.setReturnValue(false, 1);
View Full Code Here

Examples of org.apache.ojb.broker.PersistenceBroker.serviceConnectionManager()

192
193
194
195
196
197
198
199
200
201
202
            if(log.isDebugEnabled())
            {
                log.debug("Do internal cleanup and close the internal used connection without" +
                        " closing the used broker");
            }
            ConnectionManagerIF cm = broker.serviceConnectionManager();
            if(cm.isInLocalTransaction())
            {
                /*
                arminw:
                in managed environment this call will be ignored because, the JTA transaction
View Full Code Here

Examples of org.apache.ojb.broker.PersistenceBroker.serviceConnectionManager()

124
125
126
127
128
129
130
131
132
133
134
     * DB set <em>true</em>, else set <em>false</em> to improve performance.
     */
    public void writeObjects(boolean reuse) throws TransactionAbortedException, LockNotGrantedException
    {
        PersistenceBroker broker = transaction.getBroker();
        ConnectionManagerIF connMan = broker.serviceConnectionManager();
        boolean saveBatchMode = connMan.isBatchMode();

        try
        {
            if(log.isDebugEnabled())
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.