Ignite事务中执行DELETE查询失败问题咨询

在对采用TRANSACTIONAL原子性模式的缓存执行DELETE查询时，Ignite执行失败并抛出错误：

javax.cache.CacheException: DML statements are not allowed inside a transaction over cache(s) with TRANSACTIONAL atomicity mode (change atomicity mode to TRANSACTIONAL_SNAPSHOT or disable this error message with system property "-DIGNITE_ALLOW_DML_INSIDE_TRANSACTION=true")

但Ignite官方文档未提及该限制，且文档明确说明TRANSACTIONAL_SNAPSHOT已废弃并将在后续版本移除，与错误提示中的建议矛盾。目前可通过添加系统属性规避该错误，以下是对该限制的原因及官方支持情况的说明：

限制原因 #

1. 事务机制兼容性问题：TRANSACTIONAL模式基于乐观锁实现，事务内的变更依赖单个节点的本地数据视图；而DML语句属于跨节点的批量操作，无法在TRANSACTIONAL模式下保证事务的原子性与一致性，容易引发数据不一致问题。
2. 错误提示未及时更新：TRANSACTIONAL_SNAPSHOT是旧版本中支持事务内DML的模式，但官方后续决定废弃该模式并转向优化TRANSACTIONAL模式，不过相关错误提示未同步更新，导致出现矛盾。

官方支持情况 #

• 官方公开文档未明确标注该限制，但代码层面确实存在此校验，属于文档更新滞后的问题。
• 提供的系统属性-DIGNITE_ALLOW_DML_INSIDE_TRANSACTION=true是官方给出的临时规避方案，说明官方已知晓该问题，后续可能会完善TRANSACTIONAL模式对事务内DML的支持，或更新错误提示内容。
• 不建议长期依赖该临时属性，建议关注Ignite版本更新，优先采用官方推荐的事务与查询结合方式。

错误栈信息 #

javax.cache.CacheException: DML statements are not allowed inside a transaction over cache(s) with TRANSACTIONAL atomicity mode (change atomicity mode to TRANSACTIONAL_SNAPSHOT or disable this error message with system property "-DIGNITE_ALLOW_DML_INSIDE_TRANSACTION=true")

 at org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.query(IgniteCacheProxyImpl.java:828)

 at org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.query(IgniteCacheProxyImpl.java:761)

 at org.apache.ignite.internal.processors.cache.GatewayProtectedCacheProxy.query(GatewayProtectedCacheProxy.java:394)

 at com.xxx.xxx.domain.repositories.rbac.RbacCustomRepositoryImpl.removeRoleByUserId(RbacCustomRepositoryImpl.java:976)

 at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

 at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

 at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

 at java.base/java.lang.reflect.Method.invoke(Method.java:566)

 at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.executeMethodOn(RepositoryFactorySupport.java:515)

 at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.doInvoke(RepositoryFactorySupport.java:490)

 at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.invoke(RepositoryFactorySupport.java:477)

 at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)

 at org.springframework.data.projection.DefaultMethodInvokingMethodInterceptor.invoke(DefaultMethodInvokingMethodInterceptor.java:56)

 at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)

 at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)

 at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)

 at org.springframework.data.repository.core.support.SurroundingTransactionDetectorMethodInterceptor.invoke(SurroundingTransactionDetectorMethodInterceptor.java:57)

 at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)

 at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213)

 at com.sun.proxy.$Proxy205.removeRoleByUserId(Unknown Source)

 at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

 at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

 at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

 at java.base/java.lang.reflect.Method.invoke(Method.java:566)

 at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:333)

 at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207)

 at com.sun.proxy.$Proxy113.removeRoleByUserId(Unknown Source)

 at com.xxx.xxx.rbac.server.util.RbacPersistenceUtil.modifyUser(RbacPersistenceUtil.java:621)

 at com.xxx.xxx.rbac.server.controller.RbacController.modifyUser(RbacController.java:1818)

 at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

 at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

 at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

 at java.base/java.lang.reflect.Method.invoke(Method.java:566)

 at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205)

 at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:133)

 at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:97)

 at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827)

 at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738)

 at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)

 at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:967)

 at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:901)

 at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:970)

 at org.springframework.web.servlet.FrameworkServlet.doPut(FrameworkServlet.java:883)

 at javax.servlet.http.HttpServlet.service(HttpServlet.java:664)

 at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:846)

 at javax.servlet.http.HttpServlet.service(HttpServlet.java:742)

 at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)

 at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)

 at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52)

 at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)

 at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)

 at org.springframework.boot.web.filter.ApplicationContextHeaderFilter.doFilterInternal(ApplicationContextHeaderFilter.java:55)

 at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

 at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)

 at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)

 at org.springframework.boot.actuate.trace.WebRequestTraceFilter.doFilterInternal(WebRequestTraceFilter.java:111)

 at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

 at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)

 at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)

 at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99)

 at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

 at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)

 at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)

 at org.springframework.web.filter.HttpPutFormContentFilter.doFilterInternal(HttpPutFormContentFilter.java:109)

 at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

 at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)

 at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)

 at org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:93)

 at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

 at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)

 at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)

 at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:197)

 at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

 at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)

 at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)

 at org.springframework.boot.actuate.autoconfigure.MetricsFilter.doFilterInternal(MetricsFilter.java:103)

 at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

 at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)

 at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)

 at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:198)

 at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)

 at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:493)

 at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:140)

 at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:81)

 at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:87)

 at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:342)

 at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:800)

 at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)

 at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:800)

 at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1471)

 at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)

 at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)

 at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)

 at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)

 at java.base/java.lang.Thread.run(Thread.java:829)

Caused by: org.apache.ignite.internal.processors.query.IgniteSQLException: DML statements are not allowed inside a transaction over cache(s) with TRANSACTIONAL atomicity mode (change atomicity mode to TRANSACTIONAL_SNAPSHOT or disable this error message with system property "-DIGNITE_ALLOW_DML_INSIDE_TRANSACTION=true")

 at org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing.executeDml(IgniteH2Indexing.java:1219)

 at org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing.querySqlFields(IgniteH2Indexing.java:1153)

 at org.apache.ignite.internal.processors.query.GridQueryProcessor$4.applyx(GridQueryProcessor.java:2542)

 at org.apache.ignite.internal.processors.query.GridQueryProcessor$4.applyx(GridQueryProcessor.java:2538)

 at org.apache.ignite.internal.util.lang.IgniteOutClosureX.apply(IgniteOutClosureX.java:35)

 at org.apache.ignite.internal.processors.query.GridQueryProcessor.executeQuery(GridQueryProcessor.java:3054)

 at org.apache.ignite.internal.processors.query.GridQueryProcessor.lambda$querySqlFields$1(GridQueryProcessor.java:2558)

 at org.apache.ignite.internal.processors.query.GridQueryProcessor.executeQuerySafe(GridQueryProcessor.java:2596)

 at org.apache.ignite.internal.processors.query.GridQueryProcessor.querySqlFields(GridQueryProcessor.java:2532)

 at org.apache.ignite.internal.processors.query.GridQueryProcessor.querySqlFields(GridQueryProcessor.java:2459)

 at org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.query(IgniteCacheProxyImpl.java:813)

 ... 94 common frames omitted

内容的提问来源于stack exchange，提问作者lmk