java - 是否可以在 ingiteRepository 中使用“findbyId”方法?
问题描述
我想使用 IgniteRepository 和查询方法。“save”方法和“findAll”方法没问题,但是当我尝试通过id查找数据时,我无法使用“findById”方法。是否可以通过 ignite 存储库使用查询方法?(Ignite 缓存使用 Key-Value 格式。我也想知道 IgniteRepository 中“findById”处的 id,表示值中是键还是 @id。)
以下是错误信息。
java.lang.IllegalArgumentException: No fragment found for method public abstract java.util.Optional org.springframework.data.repository.CrudRepository.findById(java.lang.Object) at org.springframework.data.repository.core.support.RepositoryComposition$RepositoryFragments.lambda$null$2(RepositoryComposition.java:353) ~[spring-data-commons-2.1.9.RELEASE.jar:2.1.9.RELEASE] at java.util.Optional.orElseThrow(Optional.java:290) ~[na:1.8.0_232] at org.springframework.data.repository.core.support.RepositoryComposition$RepositoryFragments.lambda$invoke$3(RepositoryComposition.java:353) ~[spring-data-commons-2.1.9.RELEASE.jar:2.1.9.RELEASE] at java.util.concurrent.ConcurrentMap.computeIfAbsent(ConcurrentMap.java:324) ~[na:1.8.0_232] at org.springframework.data.repository.core.support.RepositoryComposition$RepositoryFragments.invoke(RepositoryComposition.java:348) ~[spring-data-commons-2.1.9.RELEASE.jar:2.1.9.RELEASE] at org.springframework.data.repository.core.support.RepositoryComposition.invoke(RepositoryComposition.java:200) ~[spring-data-commons-2.1.9.RELEASE.jar:2.1.9.RELEASE] at org.springframework.data.repository.core.support.RepositoryFactorySupport$ImplementationMethodExecutionInterceptor.invoke(RepositoryFactorySupport.java:644) ~[spring-data-commons-2.1.9.RELEASE.jar:2.1.9.RELEASE] at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.doInvoke(RepositoryFactorySupport.java:608) ~[spring-data-commons-2.1.9.RELEASE.jar:2.1.9.RELEASE] at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.lambda$invoke$3(RepositoryFactorySupport.java:595) ~[spring-data-commons-2.1.9.RELEASE.jar:2.1.9.RELEASE] at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.invoke(RepositoryFactorySupport.java:595) ~[spring-data-commons-2.1.9.RELEASE.jar:2.1.9.RELEASE] at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.data.projection.DefaultMethodInvokingMethodInterceptor.invoke(DefaultMethodInvokingMethodInterceptor.java:59) ~[spring-data-commons-2.1.9.RELEASE.jar:2.1.9.RELEASE] at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:93) ~[spring-aop-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.data.repository.core.support.SurroundingTransactionDetectorMethodInterceptor.invoke(SurroundingTransactionDetectorMethodInterceptor.java:61) ~[spring-data-commons-2.1.9.RELEASE.jar:2.1.9.RELEASE] at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:212) ~[spring-aop-5.1.8.RELEASE.jar:5.1.8.RELEASE] at com.sun.proxy.$Proxy145.findById(Unknown Source) ~[na:na] at kr.co.ignite.api.MyRestController.getDog(MyRestController.java:68) ~[classes/:na] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_232] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_232] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_232] at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_232] at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190) ~[spring-web-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138) ~[spring-web-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104) ~[spring-webmvc-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:892) ~[spring-webmvc-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:797) ~[spring-webmvc-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) ~[spring-webmvc-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1039) ~[spring-webmvc-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:942) ~[spring-webmvc-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1005) ~[spring-webmvc-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:897) ~[spring-webmvc-5.1.8.RELEASE.jar:5.1.8.RELEASE] at javax.servlet.http.HttpServlet.service(HttpServlet.java:634) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:882) ~[spring-webmvc-5.1.8.RELEASE.jar:5.1.8.RELEASE] at javax.servlet.http.HttpServlet.service(HttpServlet.java:741) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53) ~[tomcat-embed-websocket-9.0.21.jar:9.0.21] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99) ~[spring-web-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:109) ~[spring-web-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:92) ~[spring-web-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:109) ~[spring-web-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:93) ~[spring-web-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:109) ~[spring-web-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:200) ~[spring-web-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:109) ~[spring-web-5.1.8.RELEASE.jar:5.1.8.RELEASE] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202) ~[tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96) [tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:490) [tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139) [tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92) [tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) [tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343) [tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:408) [tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66) [tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:853) [tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1587) [tomcat-embed-core-9.0.21.jar:9.0.21] at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) [tomcat-embed-core-9.0.21.jar:9.0.21] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_232] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_232] at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) [tomcat-embed-core-9.0.21.jar:9.0.21] at java.lang.Thread.run(Thread.java:748) [na:1.8.0_232]
以下是实体。
import java.io.Serializable; import java.util.Date; import javax.persistence.Entity; import javax.persistence.GeneratedValue; import javax.persistence.GenerationType; import javax.persistence.Id; import org.apache.ignite.cache.query.annotations.QuerySqlField; import lombok.AccessLevel; import lombok.Data; import lombok.NoArgsConstructor; import lombok.ToString; @NoArgsConstructor(access = AccessLevel.PUBLIC) @ToString @Data @Entity public class Dog implements Serializable { private static final long serialVersionUID = 1L; @Id @QuerySqlField(index = true) @GeneratedValue(strategy = GenerationType.AUTO) private Long id; @QuerySqlField(index = true) private String name; @QuerySqlField(index = true) private Date birthday; }
以下是 Repository 女巫扩展了 IgniteRepository。
import org.apache.ignite.springdata.repository.IgniteRepository; import org.apache.ignite.springdata.repository.config.RepositoryConfig; import kr.co.ignite.model.Dog; @RepositoryConfig(cacheName = "DogCache") public interface DogRepository extends IgniteRepository < Dog, Long > { }
以下是点燃配置。
import org.apache.ignite.Ignite; import org.apache.ignite.Ignition; import org.apache.ignite.configuration.CacheConfiguration; import org.apache.ignite.configuration.IgniteConfiguration; import org.apache.ignite.springdata.repository.config.EnableIgniteRepositories; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.repository.query.QueryLookupStrategy; import kr.co.ignite.model.Breed; import kr.co.ignite.model.Dog; import kr.co.ignite.repository.BreedRepository; import kr.co.ignite.repository.DogRepository; @Configuration @EnableIgniteRepositories(basePackageClasses = {BreedRepository.class, DogRepository.class}, queryLookupStrategy = QueryLookupStrategy.Key.CREATE_IF_NOT_FOUND) public class SpringAppConfig { @Bean public Ignite igniteInstance() { IgniteConfiguration cfg = new IgniteConfiguration(); // Setting some custom name for the node. cfg.setIgniteInstanceName("springDataNode"); // Enabling peer-class loading feature. cfg.setPeerClassLoadingEnabled(true); cfg.setLocalHost("127.0.0.1"); // Defining and creating a new cache to be used by Ignite Spring Data // repository. CacheConfiguration<Long, Dog> ccfgDog = new CacheConfiguration<Long, Dog>("DogCache"); CacheConfiguration<Long, Breed> ccfgBreed = new CacheConfiguration<Long, Breed>("BreedCache"); // Setting SQL schema for the cache. ccfgBreed.setIndexedTypes(Long.class, Breed.class); ccfgDog.setIndexedTypes(Long.class, Dog.class); cfg.setCacheConfiguration(new CacheConfiguration[] { ccfgDog, ccfgBreed }); return Ignition.start(cfg); } }
以下是控制器。
import java.util.Date; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.DeleteMapping; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PutMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import kr.co.ignite.model.BeanUtil; import kr.co.ignite.model.Dog; import kr.co.ignite.model.UETenancy; import kr.co.ignite.repository.DogRepository; import kr.co.ignite.repository.TenancyRepository; @RestController @RequestMapping(value = "/api") public class MyRestController { private long increment = 0L; /* */ @PostMapping(value = "/ignite") public ResponseEntity<String> addDog(@RequestBody Dog dog) throws Exception { DogRepository dogRepository = BeanUtil.getBean(DogRepository.class); dog.setId(increment); dog.setBirthday(new Date()); dogRepository.save(increment++, dog); return ResponseEntity.ok().body("ok"); } /* */ @GetMapping(value = "/ignite") public ResponseEntity<Iterable<Dog>> getDogs() throws Exception { DogRepository dogRepository = BeanUtil.getBean(DogRepository.class); return ResponseEntity.ok().body(dogRepository.findAll()); } /* */ @GetMapping(value = "ignite/{id}") public ResponseEntity<Dog> getDog(@PathVariable long id) throws Exception { DogRepository dogRepository = BeanUtil.getBean(DogRepository.class); return ResponseEntity.ok().body(dogRepository.findById(id).get()); } /* */ @PutMapping(value = "/ignite/{id}") public ResponseEntity<Dog> editDog(@RequestBody Dog dog, @PathVariable long id) throws Exception { DogRepository dogRepository = BeanUtil.getBean(DogRepository.class); Dog dogToEdit = dogRepository.findById(id).get(); dogToEdit.setName(dog.getName()); dogToEdit.setBirthday(dog.getBirthday()); return ResponseEntity.ok().body(dogRepository.findById(dogToEdit.getId()).get()); } @DeleteMapping(value = "/ignite/{id}") public ResponseEntity<String> removeDog(@PathVariable long id) throws Exception { DogRepository dogRepository = BeanUtil.getBean(DogRepository.class); dogRepository.deleteById(id); return ResponseEntity.ok().body("ok"); } }
解决方案
是的,某些方法尚不支持。请参阅此和此链接以获取更多详细信息。
但是您可以通过使用缓存 API 和 IgniteRepository API 来实现所有这些,如下所示,
@RequestMapping("/persons")
@RestController
public class PersonRestController {
@Autowired
private Ignite ignite;
@Autowired
private PersonRepository ps;
private IgniteCache<Integer, Person> personCache;
@PostConstruct
private void postConstruct() {
personCache = ignite.cache("person-cache");
}
@GetMapping("/count")
public Long count() {
return ps.count();
}
@GetMapping
public Iterable<Person> findAll() {
return ps.findAll();
}
@GetMapping("/{id}")
public Person findById(@PathVariable Integer id) {
return personCache.get(id);
}
@DeleteMapping("/{id}")
public boolean deleteById(@PathVariable Integer id) {
return personCache.remove(id);
}
}
谢谢!
推荐阅读
- node.js - 节点红色全局流程
- facebook - Facebook Marketing API 调用中的广告帐户缺少数据
- youtube - Youtube-DL AUDIO-ONLY 播放列表
- java - Java/Hibernate 错误:检测到连接泄漏。内部连接池已达到最大大小,当前没有可用连接
- colors - 如何在 tmux 中反转选定的选项卡颜色?
- android - 使用 GeoFire 将用户纬度和经度存储到我的数据库中 - 它没有持续更新
- android - 单击按钮时如何转到另一个活动(选项卡中的按钮)
- python - Matplotlib:采样数据时动态重新标记 x 轴
- javascript - 有什么方法可以等待 Dom 更新或异步更新 Dom?
- android - Android App Transfer 找不到交易 ID