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

ExecutionContext.getTransaction介绍

暂无

代码示例

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
 * Method to assert if the current transaction is active or non transactional writes are allowed.
 * Throws a TransactionNotWritableException if not active and non transactional writes are disabled
 */
protected void assertWritable()
{
  if (!ec.getTransaction().isActive() && !ec.getTransaction().getNontransactionalWrite())
  {
    throw new TransactionNotWritableException();
  }
}

代码示例来源：origin: org.datanucleus/datanucleus-rdbms

public void managedConnectionPreClose()
{
  if (!ec.getTransaction().isActive())
  {
    // Disconnect the query from this ManagedConnection (read in unread rows etc)
    qr1.disconnect();
  }
}
public void managedConnectionPostClose(){}

代码示例来源：origin: org.datanucleus/datanucleus-neo4j

public void managedConnectionPreClose()
{
  if (!ec.getTransaction().isActive())
  {
    // Non-Tx : disconnect query from ManagedConnection (read in unread rows etc)
    qr1.disconnect();
  }
}
public void managedConnectionPostClose(){}

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
 * Convenience method to add a listener for transaction events (begin, commit, rollback).
 * @param listener The listener.
 */
public void addTransactionEventListener(TransactionEventListener listener)
{
  assertIsOpen();
  ec.getTransaction().bindTransactionEventListener(listener);
}

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
   * Convenience method to remove the supplied listener from transaction event notification.
   * @param listener The listener
   */
  public void removeTransactionEventListener(TransactionEventListener listener)
  {
    assertIsOpen();
    ec.getTransaction().removeTransactionEventListener(listener);
  }
}

代码示例来源：origin: org.datanucleus/datanucleus-rdbms

public void managedConnectionPreClose()
{
  if (!ec.getTransaction().isActive())
  {
    // Non-Tx : disconnect query from ManagedConnection (read in unread rows etc)
    qr1.disconnect();
  }
}
public void managedConnectionPostClose(){}

代码示例来源：origin: org.datanucleus/datanucleus-rdbms

public void managedConnectionPreClose()
{
  if (!ec.getTransaction().isActive())
  {
    // Non-Tx : disconnect query from ManagedConnection (read in unread rows etc)
    qr1.disconnect();
  }
}
public void managedConnectionPostClose(){}

代码示例来源：origin: org.datanucleus/datanucleus-mongodb

public void managedConnectionPreClose()
{
  if (!ec.getTransaction().isActive())
  {
    // Non-Tx : disconnect query from ManagedConnection (read in unread rows etc)
    qr1.disconnect();
  }
}
public void managedConnectionPostClose(){}

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
 * Method to assert if the current transaction is active.
 * Throws a TransactionNotActiveException if not active.
 */
protected void assertActiveTransaction()
{
  if (!ec.getTransaction().isActive())
  {
    throw new TransactionNotActiveException();
  }
}

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
 * Method to assert if no active transaction and nontransactionalRead is not set.
 * Throws JDOUserException if the tx is not active and no non-transactional read is available
 * @param operation The operation
 */
protected void assertReadable(String operation)
{
  if (!ec.getTransaction().isActive() && !ec.getTransaction().getNontransactionalRead())
  {
    throw new JDOUserException(Localiser.msg("011001", operation));
  }
}

代码示例来源：origin: org.datanucleus/datanucleus-neo4j

public void managedConnectionPreClose()
{
  if (!ec.getTransaction().isActive())
  {
    // Non-Tx : disconnect query from ManagedConnection (read in unread rows etc)
    qr1.disconnect();
  }
}
public void managedConnectionPostClose(){}

代码示例来源：origin: org.datanucleus/datanucleus-mongodb

public void managedConnectionPreClose()
{
  if (!ec.getTransaction().isActive())
  {
    // Non-Tx : disconnect query from ManagedConnection (read in unread rows etc)
    qr1.disconnect();
  }
}
public void managedConnectionPostClose(){}

代码示例来源：origin: org.datanucleus/datanucleus-ldap

private static LDAPTransactionEventListener getTransactionEventListener(ExecutionContext ec)
{
  Transaction transaction = ec.getTransaction();
  Map<String, Object> txOptions = transaction.getOptions();
  LDAPTransactionEventListener listener = (txOptions != null ? (LDAPTransactionEventListener)txOptions.get("LDAPTransactionEventListener") : null);
  if (listener == null)
  {
    listener = new LDAPTransactionEventListener(ec);
    transaction.setOption("LDAPTransactionEventListener", listener);
    transaction.addTransactionEventListener(listener);
  }
  return listener;
}

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
 * Method to transition when serialised.
 * @param op ObjectProvider
 * @return The new LifeCycle state
 */
public LifeCycleState transitionSerialize(ObjectProvider op)
{
  Transaction tx = op.getExecutionContext().getTransaction();
  if (tx.isActive() && !tx.getOptimistic())
  {
    return changeState(op, P_CLEAN);
  }
  return this;
}

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
 * @param op The ObjectProvider
 * @see LifeCycleState#transitionWriteField(ObjectProvider op)
 */
public LifeCycleState transitionWriteField(ObjectProvider op)
{
  Transaction tx = op.getExecutionContext().getTransaction();
  if (tx.isActive())
  {
    op.saveFields();
    return changeTransientState(op,T_DIRTY);
  }
  return this;
}

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
 * Method to transition to write-field state.
 * @param op ObjectProvider.
 * @return new LifeCycle state.
 **/
public LifeCycleState transitionWriteField(ObjectProvider op)
{
  Transaction tx = op.getExecutionContext().getTransaction();
  if (tx.getRestoreValues())
  {
    op.saveFields();
  }
  return changeState(op, P_DIRTY);
}

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
 * Method to transition when serialised.
 * @param op ObjectProvider
 * @return The new LifeCycle state
 */
public LifeCycleState transitionSerialize(ObjectProvider op)
{
  Transaction tx = op.getExecutionContext().getTransaction();
  if (tx.isActive() && !tx.getOptimistic())
  {
    return changeState(op, P_CLEAN);
  }
  return this;
}

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
 * Method to transition to read-field state.
 * @param op ObjectProvider.
 * @param isLoaded if the field was previously loaded.
 * @return new LifeCycle state.
 **/
public LifeCycleState transitionReadField(ObjectProvider op, boolean isLoaded)
{
  Transaction tx = op.getExecutionContext().getTransaction();
  if (!tx.isActive() && !tx.getNontransactionalRead())
  {
    throw new JDOUserException(Localiser.msg("027002"),op.getInternalObjectId());
  }
  return this;
}

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
 * Method to transition to write-field state.
 * @param op ObjectProvider.
 * @return new LifeCycle state.
 */
public LifeCycleState transitionWriteField(ObjectProvider op)
{
  Transaction tx = op.getExecutionContext().getTransaction();
  if (!tx.isActive() && !tx.getNontransactionalWrite())
  {
    throw new TransactionNotWritableException(Localiser.msg("027001"), op.getInternalObjectId());
  }
  return changeState(op, tx.isActive() ? P_DIRTY : P_NONTRANS);
}

代码示例来源：origin: org.datanucleus/datanucleus-api-jdo

/**
 * Method to transition to refresh state.
 * @param op ObjectProvider.
 * @return new LifeCycle state.
 **/
public LifeCycleState transitionRefresh(ObjectProvider op)
{
  op.clearSavedFields();
  // Refresh the FetchPlan fields and unload all others
  op.refreshFieldsInFetchPlan();
  op.unloadNonFetchPlanFields();
  Transaction tx = op.getExecutionContext().getTransaction();
  if (tx.isActive() && !tx.getOptimistic())
  {
    return changeState(op,P_CLEAN);
  }
  return changeState(op,P_NONTRANS);      
}