java - Grails、作业、静态辅助方法和 Hibernate session

Question

我有一个 Grails 作业类 (grails-app/jobs)，它需要调用静态(帮助程序)方法(在 src/groovy 中定义)。该方法分别在 2 个不同的域对象上调用 get 和 find 方法。方法调用的结果是返回一个简单的String(为此可以返回任何内容 - 无关紧要)。

我的问题是，当我调用包含 2 的 fetch 的静态方法(可能是更多)不同的域类？

或者，如何在作业类中声明/使用 Hibernate session ，以便不必使用 .withBlaBla？

编辑(底部的另一个编辑 - 抱歉):获取 EZTable 和 EZRow 的行正在工作。 EmailReminder 我必须用 EmailReminder.with 换行...现在调用 ServiceUtils.handleSubjectOrMessageString(ezTable, ezRow, emailReminder.subject) 的行导致异常(这是“现在”添加的 -整个作业类之前都使用简单的字符串值进行工作)。

class EmailReminderJob implements Job {

    EmailReminder emailReminder
    EZTable ezTable
    EZRow ezRow

    static triggers = {}

    def void execute(JobExecutionContext context) {
        List<String> emails = new ArrayList<String>(0)

        ezTable = EZTable.get(new Long(context.mergedJobDataMap.get('ezTableId')))
        ezRow = EZRow.get(new Long(context.mergedJobDataMap.get('ezRowId')))
        EmailReminder.withTransaction { status ->
            emailReminder = EmailReminder.get(new Long(context.mergedJobDataMap.get('emailReminderId')))
            if(emailReminder.sendMessageToOwnerUser && emailReminder.ownerUser.email!=null)
                emails.add(emailReminder.ownerUser.email)
            if(emailReminder.sendMessageToOwnerCompany && emailReminder.ownerCompany.email!=null)
                emails.add(emailReminder.ownerCompany.email)
            if(emailReminder.emails!=null && emails.size()>0)
                emails.addAll(new ArrayList<String>(emailReminder.emails))
            if(emailReminder.messageReceiverUsers!=null && emailReminder.messageReceiverUsers.size()>0) {
                for(user in emailReminder.messageReceiverUsers) {
                    if(user.email!=null)
                        emails.add(user.email)
                }
            }
        }

        if(emails.size()>0) {
            String host = "localhost";
            Properties properties = System.getProperties();
            properties.setProperty("mail.smtp.host", host);
            Session session = Session.getDefaultInstance(properties);
            try{
                // Create a default MimeMessage object.
                MimeMessage message = new MimeMessage(session);
                message.setFrom(new InternetAddress(emailReminder.emailFrom));
                for(email in emails) {
                    message.addRecipient(
                        Message.RecipientType.TO,
                        new InternetAddress(email)
                    );
                }
                message.setSubject(ServiceUtils.handleSubjectOrMessageString(ezTable, ezRow, emailReminder.subject));
                message.setText(ServiceUtils.handleSubjectOrMessageString(ezTable, ezRow, emailReminder.definedMessage));
                Transport.send(message);
            }catch (MessagingException mex) {
                mex.printStackTrace();
            }
        }
    }
}

src/groove 下我的 util-class 中的静态方法(EZColumn ezcolumn = EZColumn.get(id) 行和下一行导致了异常) :

def static String handleSubjectOrMessageString(EZTable eztable, EZRow ezrow, String subjectOrMessage) {
    String regex = '(?<=\\$\\$)(.*?)(?=\\$\\$)'
    Pattern pattern = Pattern.compile(regex)
    Matcher matcher = pattern.matcher(subjectOrMessage)
    StringBuffer stringBuffer = new StringBuffer();
    while(matcher.find()) {
        if(subjectOrMessage.substring(matcher.start(), matcher.end()).contains('#')) {
            String stringId = subjectOrMessage.substring(matcher.start(), matcher.end()).split('#')[0]
            String name = subjectOrMessage.substring(matcher.start(), matcher.end()).split('#')[1]
            try {
                Long id = new Long(stringId)
                EZColumn ezcolumn = EZColumn.get(id)
                EZCell ezcell = EZCell.findByEzTableAndEzRowAndEzColumn(eztable, ezrow, ezcolumn)
                matcher.appendReplacement(stringBuffer, fetchCellValues(ezcell, ezcolumn))
            } catch(NumberFormatException nfe) {
                if(stringId.equals("id")) {
                    if(name.equals("row"))
                        matcher.appendReplacement(stringBuffer, ezrow.id.toString())
                    else if(name.equals("table"))
                        matcher.appendReplacement(stringBuffer, eztable.id.toString())
                    else
                        matcher.appendReplacement(stringBuffer, "???")
                }
            }
        }
    }
    matcher.appendTail(stringBuffer);
    println stringBuffer.toString().replaceAll('\\$', "")
    return stringBuffer.toString().replaceAll('\\$', "")
}

异常(exception):

| Error 2015-02-11 10:33:33,954 [quartzScheduler_Worker-1] ERROR core.JobRunShell  - Job EmailReminderGroup.ER_3_EZTable_3 threw an unhandled Exception: 
Message: null
   Line | Method
->> 202 | run in org.quartz.core.JobRunShell
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - 
^   573 | run in org.quartz.simpl.SimpleThreadPool$WorkerThread
| Error 2015-02-11 10:33:33,996 [quartzScheduler_Worker-1] ERROR core.ErrorLogger  - Job (EmailReminderGroup.ER_3_EZTable_3 threw an exception.
Message: Job threw an unhandled exception.
   Line | Method
->> 213 | run in org.quartz.core.JobRunShell
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - 
^   573 | run in org.quartz.simpl.SimpleThreadPool$WorkerThread
Caused by NullPointerException: null
->> 202 | run in org.quartz.core.JobRunShell
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - 
^   573 | run in org.quartz.simpl.SimpleThreadPool$WorkerThread
| Error 2015-02-11 10:33:34,005 [quartzScheduler_Worker-1] ERROR listeners.ExceptionPrinterJobListener  - Exception occurred in job: null
Message: org.quartz.SchedulerException: Job threw an unhandled exception. [See nested exception: java.lang.NullPointerException]
   Line | Method
->> 218 | run in org.quartz.core.JobRunShell
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - 
^   573 | run in org.quartz.simpl.SimpleThreadPool$WorkerThread
Caused by SchedulerException: Job threw an unhandled exception.
->> 213 | run in org.quartz.core.JobRunShell
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - 
^   573 | run in org.quartz.simpl.SimpleThreadPool$WorkerThread
Caused by NullPointerException: null
->> 202 | run in org.quartz.core.JobRunShell
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - 
^   573 | run in org.quartz.simpl.SimpleThreadPool$WorkerThread

再次编辑:( :我的静态方法中有许多嵌套调用(matcher.appendReplacement(stringBuffer, fetchCellValues(ezcell, ezcolumn)) 中的 fetchCellValues(ezcell, ezcolumn) - 方法调用更深层次来获取值，我实际上在一次调用中得到了“无 session ”异常(与尝试获取另一个域对象的所有其他调用一样调用常规):

Message: org.quartz.SchedulerException: Job threw an unhandled exception. [See nested exception: org.hibernate.LazyInitializationException: could not initialize proxy - no Session]

Answer 1

您可以像在任何地方一样使用它们。两者都独立于他们所调用的类； withTransaction 只是在事务中运行封装的代码，加入当前 Activity 的事务(如果有)，并且 withSession 使当前的 Hibernate Session 可用于包装的代码，但除此之外不执行任何操作。

您没有说明任何需要的原因，因此不清楚具体建议什么。如果您只读取数据，则不需要事务，并且如果您正在调用域类方法，则不需要访问 session 。

我过去提倡的 withTransaction 的一个用途(几乎是它的唯一用途，因为它通常被误用)是避免在还没有 Activity session 时出现延迟加载异常。将代码包装在 withTransaction block 中具有创建 session 并在该 block 的持续时间内保持打开状态的副作用，这样您就可以使用延迟加载的实例和集合。 Controller 有一个 Activity session ，因为有一个在 View 中打开 session 拦截器，它在请求开始时启动 session ，将其存储在 ThreadLocal 中，并在请求结束时刷新并关闭它。要求。作业是相似的，因为插件使用 Quartz 作业开始/结束事件来执行相同的操作。

但是，无论您是因为延迟加载还是因为更新而使代码具有事务性，您通常都应该在事务性服务中完成这项工作。

服务非常适合事务性工作，因为它们默认是事务性的(只有没有 @Transactional 注释并包含 static transactional = false 的服务才是非事务性的) ，并且可以使用 @Transactional 注释轻松配置每个类和每个方法的事务划分。它们也非常适合封装业务逻辑，而与它们的调用方式无关；服务方法通常不需要任何 HTTP/作业/等。意识，只需将 String/number/boolean/object 参数中所需的数据传递给它，然后让它完成工作。

我喜欢保持 Controller 简单，从请求参数进行数据绑定(bind)并调用服务来完成实际工作，然后渲染响应或路由到下一页，我在 Quartz 作业中做同样的事情。使用 Quartz 来实现调度功能，但在服务中完成真正的工作。像任何 bean (def fooService) 一样依赖注入(inject)服务，并将所有业务逻辑和数据库工作放在那里。它使代码中的内容清晰描述，并使测试变得更加容易，因为您可以测试服务方法而无需模拟 HTTP 调用或 Quartz。