QuartzJob中的EntityManager为空

Question

我在QuartzJobs实例上使用EntityManager遇到此问题：

Java语言weblogic上的lang.NullPointerException。坚持不懈CICScopedImprovider。weblogic上的getEMForCurrentCIC（CICScopedImprovider.java:35）。坚持不懈事务实体管理器Proxy Impl。weblogic上的getPersistenceContext（TransactionalEntityManagerProxyImpl.java:122）。坚持不懈BasePersistenceContextProxyImpl。在weblogic上调用（BasePersistenceContextProxyImpl.java:94）。坚持不懈事务实体管理器Proxy Impl。在weblogic上调用（TransactionalEntityManagerProxyImpl.java:164）。坚持不懈BasePersistenceContextProxyImpl。在com上调用（BasePersistenceContextProxyImpl.java:86）。太阳代理$Proxy321.createQuery（未知源）位于com。我的项目。存储库。实施。光沉积impl。com上的getShotsFromBackupOption（photopositoryimpl.java:44）。我的项目。服务实施。PhotoServiceImpl。com上的getPhoto（PhotoServiceImpl.java:90）。我的项目。班长备份作业。在组织中执行（BackupJob.java:46）。石英果心JobRunShell。在org上运行（JobRunShell.java:202）。石英简单。SimpleThreadPool$WorkerThread。运行（SimpleThreadPool.java:573）

这是我的工作：

public class BackupJob implements Job{
    private Logger logger = LoggerFactory.getLogger(getClass());

    @Inject private PhotoService photoService;

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        try {
            String jobName = context.getJobDetail().getKey().getName();
            Long jobGroup = Long.parseLong(context.getJobDetail().getKey().getGroup());

            List<File> fileList = photoService.getPhoto(jobName, jobGroup);

            logger.info("Backup with deep {}", context.getJobDetail().getJobDataMap().get("deep"));
        } catch (Exception e) {
            logger.error("ERROR during backup job", e);
        }       
    }
}

（正确注入了photoService，这与我在photoService中调用的photoRepository方法相同）

这是我的存储库：

@Stateless
public class PhotoRepositoryImpl implements PhotoRepository{

    @PersistenceContext(unitName=Constant.PU_NAME)
    private EntityManager em;

    @Override
    public List<Photo> getShotsFromBackupOption(String jobName, Long jobGroup) throws SQLException{

        Query query = em.createQuery("SELECT p "
                                    + "FROM Shot s "
                                    + "JOIN Photo p "
                                    + "WHERE s.dateShooting < "
                                        + "(SELECT b.previousThan "
                                        + "FROM BackupOption b "
                                        + "WHERE b.jobName = :jobName AND b.syncType.id = :jobGroup)"
                                    + "ORDER BY p.relativePath DESC");
        query.setParameter("jobName", jobName);
        query.setParameter("jobGroup", jobGroup);


        return (List<Photo>) query.getResultList();
    }
}

这是我的工作工厂

public class JobFactoryImpl implements JobFactory {


@Inject
private Instance<Job> jobs;

@Override
public Job newJob(TriggerFiredBundle triggerFiredBundle, Scheduler scheduler) throws SchedulerException {
    final JobDetail jobDetail = triggerFiredBundle.getJobDetail();
    final Class<? extends Job> jobClass = jobDetail.getJobClass();

    for (Job job : jobs) {
        if (job.getClass().isAssignableFrom(jobClass)) {
            return job;
        }
    }

    throw new RuntimeException("Cannot create a Job of type " + jobClass);
}}

Answer 1

我以这种方式解决了获取EntityManager：

@PersistenceUnit(unitName= Constant.PU_NAME)
private EntityManagerFactory emf;

private EntityManager em = emf.createEntityManager();