org.apache.openjpa.kernel.Broker.putUserObject()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(11.1k)|赞(0)|评价(0)|浏览(137)

本文整理了Java中org.apache.openjpa.kernel.Broker.putUserObject()方法的一些代码示例，展示了Broker.putUserObject()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Broker.putUserObject()方法的具体详情如下：
包路径：org.apache.openjpa.kernel.Broker
类名称：Broker
方法名：putUserObject

Broker.putUserObject介绍

[英]Put the specified key-value pair into the map of user objects. Use a value of null to remove the key.
[中]将指定的键值对放入用户对象的映射中。使用null值删除密钥。

代码示例

代码示例来源：origin: org.apache.openjpa/com.springsource.org.apache.openjpa

public Object putUserObject(Object key, Object val) {
  try {
    return _broker.putUserObject(key, val);
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-all

public Object putUserObject(Object key, Object val) {
  try {
    return _broker.putUserObject(key, val);
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openejb.patch/openjpa-kernel

public Object putUserObject(Object key, Object val) {
  try {
    return _broker.putUserObject(key, val);
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-kernel

public Object putUserObject(Object key, Object val) {
  try {
    return _broker.putUserObject(key, val);
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openejb.patch/openjpa

public Object putUserObject(Object key, Object val) {
  try {
    return _broker.putUserObject(key, val);
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.compass-project/compass

public void afterBegin(TransactionEvent transactionEvent) {
    Broker broker = (Broker) transactionEvent.getSource();
    CompassSession session = compass.openSession();
    broker.putUserObject(COMPASS_SESSION_USER_OBJECT_KEY, session);
    CompassTransaction tr = session.beginTransaction();
    broker.putUserObject(COMPASS_TRANSACTION_USER_OBJECT_KEY, tr);
  }
});

代码示例来源：origin: org.apache.openjpa/openjpa-all

public void writeExternal(ObjectOutput out) throws IOException {
  try {
    // this requires that only AbstractBrokerFactory-sourced
    // brokers can be serialized
    Object factoryKey = ((AbstractBrokerFactory) _broker
      .getBrokerFactory()).getPoolKey();
    out.writeObject(factoryKey);
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    ObjectOutputStream innerOut = new ObjectOutputStream(baos);
    _broker.getDelegate().putUserObject(JPAFacadeHelper.EM_KEY, null);
    innerOut.writeObject(_broker.getDelegate());
    innerOut.flush();
    out.writeObject(baos.toByteArray());
  } catch (RuntimeException re) {
    try {
      re = _ret.translate(re);
    } catch (Exception e) {
      // ignore
    }
    throw re;
  }
}

代码示例来源：origin: org.apache.openejb.patch/openjpa-persistence

public void writeExternal(ObjectOutput out) throws IOException {
  try {
    // this requires that only AbstractBrokerFactory-sourced
    // brokers can be serialized
    Object factoryKey = ((AbstractBrokerFactory) _broker
      .getBrokerFactory()).getPoolKey();
    out.writeObject(factoryKey);
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    ObjectOutputStream innerOut = new ObjectOutputStream(baos);
    _broker.getDelegate().putUserObject(JPAFacadeHelper.EM_KEY, null);
    innerOut.writeObject(_broker.getDelegate());
    innerOut.flush();
    out.writeObject(baos.toByteArray());
  } catch (RuntimeException re) {
    try {
      re = _ret.translate(re);
    } catch (Exception e) {
      // ignore
    }
    throw re;
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-persistence

public void writeExternal(ObjectOutput out) throws IOException {
  try {
    // this requires that only AbstractBrokerFactory-sourced
    // brokers can be serialized
    Object factoryKey = ((AbstractBrokerFactory) _broker
      .getBrokerFactory()).getPoolKey();
    out.writeObject(factoryKey);
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    ObjectOutputStream innerOut = new ObjectOutputStream(baos);
    _broker.getDelegate().putUserObject(JPAFacadeHelper.EM_KEY, null);
    innerOut.writeObject(_broker.getDelegate());
    innerOut.flush();
    out.writeObject(baos.toByteArray());
  } catch (RuntimeException re) {
    try {
      re = _ret.translate(re);
    } catch (Exception e) {
      // ignore
    }
    throw re;
  }
}

代码示例来源：origin: org.apache.openejb.patch/openjpa

public void writeExternal(ObjectOutput out) throws IOException {
  try {
    // this requires that only AbstractBrokerFactory-sourced
    // brokers can be serialized
    Object factoryKey = ((AbstractBrokerFactory) _broker
      .getBrokerFactory()).getPoolKey();
    out.writeObject(factoryKey);
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    ObjectOutputStream innerOut = new ObjectOutputStream(baos);
    _broker.getDelegate().putUserObject(JPAFacadeHelper.EM_KEY, null);
    innerOut.writeObject(_broker.getDelegate());
    innerOut.flush();
    out.writeObject(baos.toByteArray());
  } catch (RuntimeException re) {
    try {
      re = _ret.translate(re);
    } catch (Exception e) {
      // ignore
    }
    throw re;
  }
}

代码示例来源：origin: org.compass-project/compass

private void rollback(TransactionEvent trEvent) {
    Broker broker = (Broker) trEvent.getSource();
    CompassTransaction tr = (CompassTransaction) broker.getUserObject(COMPASS_TRANSACTION_USER_OBJECT_KEY);
    CompassSession session = (CompassSession) broker.getUserObject(COMPASS_SESSION_USER_OBJECT_KEY);
    try {
      if (openJpaControlledTransaction) {
        try {
          tr.rollback();
        } finally {
          session.close();
        }
      }
    } finally {
      broker.putUserObject(COMPASS_TRANSACTION_USER_OBJECT_KEY, null);
      broker.putUserObject(COMPASS_SESSION_USER_OBJECT_KEY, null);
    }
  }
});

代码示例来源：origin: org.compass-project/compass

private void commit(TransactionEvent trEvent) {
  Broker broker = (Broker) trEvent.getSource();
  CompassTransaction tr = (CompassTransaction) broker.getUserObject(COMPASS_TRANSACTION_USER_OBJECT_KEY);
  CompassSession session = (CompassSession) broker.getUserObject(COMPASS_SESSION_USER_OBJECT_KEY);
  try {
    if (openJpaControlledTransaction) {
      try {
        tr.commit();
      } finally {
        session.close();
      }
    }
  } finally {
    broker.putUserObject(COMPASS_TRANSACTION_USER_OBJECT_KEY, null);
    broker.putUserObject(COMPASS_SESSION_USER_OBJECT_KEY, null);
  }
}

代码示例来源：origin: org.apache.openejb.patch/openjpa

public void readExternal(ObjectInput in)
  throws IOException, ClassNotFoundException {
  try {
    _ret = PersistenceExceptions.getRollbackTranslator(this);
    // this assumes that serialized Brokers are from something
    // that extends AbstractBrokerFactory.
    Object factoryKey = in.readObject();
    AbstractBrokerFactory factory =
      AbstractBrokerFactory.getPooledFactoryForKey(factoryKey);
    byte[] brokerBytes = (byte[]) in.readObject();
    ObjectInputStream innerIn = new BrokerBytesInputStream(brokerBytes,
      factory.getConfiguration());
    Broker broker = (Broker) innerIn.readObject();
    EntityManagerFactoryImpl emf = (EntityManagerFactoryImpl)
      JPAFacadeHelper.toEntityManagerFactory(
        broker.getBrokerFactory());
    broker.putUserObject(JPAFacadeHelper.EM_KEY, this);
    initialize(emf, broker);
  } catch (RuntimeException re) {
    try {
      re = _ret.translate(re);
    } catch (Exception e) {
      // ignore
    }
    throw re;
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-all

public void readExternal(ObjectInput in)
  throws IOException, ClassNotFoundException {
  try {
    _ret = PersistenceExceptions.getRollbackTranslator(this);
    // this assumes that serialized Brokers are from something
    // that extends AbstractBrokerFactory.
    Object factoryKey = in.readObject();
    AbstractBrokerFactory factory =
      AbstractBrokerFactory.getPooledFactoryForKey(factoryKey);
    byte[] brokerBytes = (byte[]) in.readObject();
    ObjectInputStream innerIn = new BrokerBytesInputStream(brokerBytes,
      factory.getConfiguration());
    Broker broker = (Broker) innerIn.readObject();
    EntityManagerFactoryImpl emf = (EntityManagerFactoryImpl)
      JPAFacadeHelper.toEntityManagerFactory(
        broker.getBrokerFactory());
    broker.putUserObject(JPAFacadeHelper.EM_KEY, this);
    initialize(emf, broker);
  } catch (RuntimeException re) {
    try {
      re = _ret.translate(re);
    } catch (Exception e) {
      // ignore
    }
    throw re;
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-persistence

public void readExternal(ObjectInput in)
  throws IOException, ClassNotFoundException {
  try {
    _ret = PersistenceExceptions.getRollbackTranslator(this);
    // this assumes that serialized Brokers are from something
    // that extends AbstractBrokerFactory.
    Object factoryKey = in.readObject();
    AbstractBrokerFactory factory =
      AbstractBrokerFactory.getPooledFactoryForKey(factoryKey);
    byte[] brokerBytes = (byte[]) in.readObject();
    ObjectInputStream innerIn = new BrokerBytesInputStream(brokerBytes,
      factory.getConfiguration());
    Broker broker = (Broker) innerIn.readObject();
    EntityManagerFactoryImpl emf = (EntityManagerFactoryImpl)
      JPAFacadeHelper.toEntityManagerFactory(
        broker.getBrokerFactory());
    broker.putUserObject(JPAFacadeHelper.EM_KEY, this);
    initialize(emf, broker);
  } catch (RuntimeException re) {
    try {
      re = _ret.translate(re);
    } catch (Exception e) {
      // ignore
    }
    throw re;
  }
}

代码示例来源：origin: org.apache.openjpa/com.springsource.org.apache.openjpa

/**
 * Return a persistence manager facade to the given broker retaining
 * previously associated persistence context type.
 */
public static OpenJPAEntityManager toEntityManager(Broker broker) {
  if (broker == null)
    return null;
  broker.lock();
  try {
    OpenJPAEntityManager em = (OpenJPAEntityManager)
      broker.getUserObject(EM_KEY);
    if (em == null) {
      EntityManagerFactoryImpl emf = (EntityManagerFactoryImpl)
        toEntityManagerFactory(broker.getBrokerFactory());
      em = emf.newEntityManagerImpl(broker);
      broker.putUserObject(EM_KEY, em);
    }
    return em;
  } catch (Exception e) {
    throw PersistenceExceptions.toPersistenceException(e);
  } finally {
    broker.unlock();
  }
}

代码示例来源：origin: org.apache.openejb.patch/openjpa

/**
 * Return a persistence manager facade to the given broker retaining
 * previously associated persistence context type.
 */
public static OpenJPAEntityManager toEntityManager(Broker broker) {
  if (broker == null)
    return null;
  broker.lock();
  try {
    OpenJPAEntityManager em = (OpenJPAEntityManager)
      broker.getUserObject(EM_KEY);
    if (em == null) {
      EntityManagerFactoryImpl emf = (EntityManagerFactoryImpl)
        toEntityManagerFactory(broker.getBrokerFactory());
      em = emf.newEntityManagerImpl(broker);
      broker.putUserObject(EM_KEY, em);
    }
    return em;
  } catch (Exception e) {
    throw PersistenceExceptions.toPersistenceException(e);
  } finally {
    broker.unlock();
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-all

/**
 * Return a persistence manager facade to the given broker retaining
 * previously associated persistence context type.
 */
public static OpenJPAEntityManager toEntityManager(Broker broker) {
  if (broker == null)
    return null;
  broker.lock();
  try {
    OpenJPAEntityManager em = (OpenJPAEntityManager)
      broker.getUserObject(EM_KEY);
    if (em == null) {
      EntityManagerFactoryImpl emf = (EntityManagerFactoryImpl)
        toEntityManagerFactory(broker.getBrokerFactory());
      em = emf.newEntityManagerImpl(broker);
      broker.putUserObject(EM_KEY, em);
    }
    return em;
  } catch (Exception e) {
    throw PersistenceExceptions.toPersistenceException(e);
  } finally {
    broker.unlock();
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-persistence

/**
 * Return a persistence manager facade to the given broker retaining
 * previously associated persistence context type.
 */
public static OpenJPAEntityManager toEntityManager(Broker broker) {
  if (broker == null)
    return null;
  broker.lock();
  try {
    OpenJPAEntityManager em = (OpenJPAEntityManager)
      broker.getUserObject(EM_KEY);
    if (em == null) {
      EntityManagerFactoryImpl emf = (EntityManagerFactoryImpl)
        toEntityManagerFactory(broker.getBrokerFactory());
      em = emf.newEntityManagerImpl(broker);
      broker.putUserObject(EM_KEY, em);
    }
    return em;
  } catch (Exception e) {
    throw PersistenceExceptions.toPersistenceException(e);
  } finally {
    broker.unlock();
  }
}

代码示例来源：origin: org.apache.openejb.patch/openjpa-persistence

/**
 * Return a persistence manager facade to the given broker retaining
 * previously associated persistence context type.
 */
public static OpenJPAEntityManager toEntityManager(Broker broker) {
  if (broker == null)
    return null;
  broker.lock();
  try {
    OpenJPAEntityManager em = (OpenJPAEntityManager)
      broker.getUserObject(EM_KEY);
    if (em == null) {
      EntityManagerFactoryImpl emf = (EntityManagerFactoryImpl)
        toEntityManagerFactory(broker.getBrokerFactory());
      em = emf.newEntityManagerImpl(broker);
      broker.putUserObject(EM_KEY, em);
    }
    return em;
  } catch (Exception e) {
    throw PersistenceExceptions.toPersistenceException(e);
  } finally {
    broker.unlock();
  }
}

内容来源于网络，如有侵权，请联系作者删除！

Broker

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Broker类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com