import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
@Override
public TransactionManagerAdapter getTransactionManager(StepContext stepContext) throws TransactionManagementException {
    logger.entering(CLASSNAME, "getTransactionManager", stepContext);

    TransactionManagerAdapter transactionManager = null;

    // get the JTA tran manager if we are in Java EE
    if (! this.batchConfig.isJ2seMode()) {
        // use the container JNDI java:comp/UserTransaction
        logger.fine("getting transaction object from JNDI java:comp/UserTransaction");
        transactionManager = new JTAUserTransactionAdapter("java:comp/UserTransaction");
    } 
    else if (this.batchConfig.isJ2seMode()) { 
    // If we are in J2SE mode use the non-transactional manager
    
        // java environment is Java SE
        // NoOp transaction manager
        logger.fine("J2SE mode non-transactional manager");
        transactionManager = new DefaultNonTransactionalManager();
    }

    logger.exiting(CLASSNAME, "getTransactionManager", transactionManager);
    return transactionManager;
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
public static <T> GroovyInstance<T> newInstance(final Class<T> expected, final String path, final JobContext jobContext, final StepContext stepContext)
        throws IllegalAccessException, InstantiationException {
    if (path == null) {
        throw new BatchRuntimeException("no script configured expected");
    }
    final File script = new File(path);
    if (!script.exists()) {
        throw new BatchRuntimeException("Can't find script: " + path);
    }

    final ClassLoader tccl = Thread.currentThread().getContextClassLoader();
    final GroovyClassLoader loader = new GroovyClassLoader(tccl);

    final Class<?> clazz;
    try {
        clazz = loader.parseClass(script);
    } catch (final IOException e) {
        throw new BatchRuntimeException(e);
    }

    final T delegate = expected.cast(clazz.newInstance());
    injectIfBatcheeIfAvailable(tccl, delegate, jobContext, stepContext);
    return new GroovyInstance<T>(loader, delegate);
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
public InjectionReferences(JobContext jobContext, StepContext stepContext, 
        List<Property> props) {

    this.jobContext = jobContext;
    this.stepContext = stepContext;
    this.props = props;
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
@Produces
@Dependent
public StepContext getStepContext() {
	if (ProxyFactory.getInjectionReferences() != null) {
		return ProxyFactory.getInjectionReferences().getStepContext();
	} else {
		return null;
	}
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
@Produces
public StepContext getStepContext() {
    if (ProxyFactory.getInjectionReferences() != null) {
        return ProxyFactory.getInjectionReferences().getStepContext();
    }
    return null;
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
private static <T> void injectIfBatcheeIfAvailable(final ClassLoader tccl, final T delegate, final JobContext jobContext, final StepContext stepContext) {
    try {
        final Class<?> dependencyInjections = tccl.loadClass("org.apache.batchee.container.util.DependencyInjections");
        final Class<?> injectionReferences = tccl.loadClass("org.apache.batchee.container.proxy.InjectionReferences");
        final Method inject = dependencyInjections.getMethod("injectReferences", Object.class, injectionReferences);
        final Constructor<?> injectionReferencesConstructor = injectionReferences.getConstructors()[0]; // there is a unique constructor
        inject.invoke(null, delegate, injectionReferencesConstructor.newInstance(jobContext, stepContext, null));
    } catch (final Throwable th) {
        // no-op: BatchEE is not available, injections will not be available
    }
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
@Override
protected Long currentKey() {
    StepContext stepContext = getContextResolver().getStepContext();
    if (stepContext == null) {
        return null;
    }

    return stepContext.getStepExecutionId();
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
@Override
public StepContext getStepContext() {

    InjectionReferences references = getInjectionReferences();
    if (references != null) {
        return references.getStepContext();
    }

    return null;
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
public StepContext getStepContext() {
    return stepContext;
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
protected StepContext getStepContext() {
    return stepCtx;
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
@Override
public TransactionManagerAdapter getTransactionManager(StepContext stepContext)
{
    return mockTxAdapter;
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
@Override
public TransactionManagerAdapter getTransactionManager(final StepContext stepContext) throws TransactionManagementException {
    // Doesn't currently make use of stepContext but keeping signature
    return  getTransactionManager();
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
@Override
public StepContext getStepContext() {
    return resolve(StepContext.class);
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
@Override
public TransactionManagerAdapter getTransactionManager(StepContext stepContext) {
    UserTransaction ut = ThreadExecutorEjb.getUserTransaction();

    return new UserTransactionTxAdapter(ut);
}
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
/**
 * @return the current {@link StepContext} for this {@link Thread}
 */
StepContext getStepContext();
 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
public TransactionManagerAdapter getTransactionManager(StepContext stepContext) ; 

import javax.batch.runtime.context.StepContext; //导入依赖的package包/类
TransactionManagerAdapter getTransactionManager(StepContext stepContext);