add fast show #16

xlorne · xlorne · commit 8cd88a123dc0 · 2022-09-10T15:02:56.000+08:00
diff --git a/springboot-example/src/main/java/com/codingapi/springboot/example/application/executor/DemoExecutor.java b/springboot-example/src/main/java/com/codingapi/springboot/example/application/executor/DemoExecutor.java
@@ -1,14 +1,23 @@
 package com.codingapi.springboot.example.application.executor;
 
 import com.codingapi.springboot.example.domain.entity.Demo;
+import com.codingapi.springboot.example.domain.repository.DemoRepository;
 import com.codingapi.springboot.example.domain.service.DemoChangeService;
+import lombok.AllArgsConstructor;
 import org.springframework.stereotype.Component;
 
 @Component
+@AllArgsConstructor
 public class DemoExecutor {
 
+    private final DemoRepository demoRepository;
     public void swap(Demo demo1, Demo demo2) {
         DemoChangeService demoChangeService = new DemoChangeService(demo1,demo2);
         demoChangeService.swap();
     }
+
+    public void create(String name){
+        Demo demo = new Demo(name);
+        demoRepository.save(demo);
+    }
 }
diff --git a/springboot-example/src/main/java/com/codingapi/springboot/example/insfrastructure/query/DemoQueryApi.java b/springboot-example/src/main/java/com/codingapi/springboot/example/insfrastructure/query/DemoQueryApi.java
diff --git a/springboot-example/src/main/java/com/codingapi/springboot/example/insfrastructure/query/FastDemoApi.java b/springboot-example/src/main/java/com/codingapi/springboot/example/insfrastructure/query/FastDemoApi.java
@@ -0,0 +1,17 @@
+package com.codingapi.springboot.example.insfrastructure.query;
+
+import com.codingapi.springboot.example.insfrastructure.entity.DemoEntity;
+import com.codingapi.springboot.fastshow.annotation.FastController;
+import com.codingapi.springboot.fastshow.annotation.FastMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.List;
+
+@FastController
+public interface FastDemoApi {
+
+    @FastMapping(method = RequestMethod.GET,mapping = "/open/fast/demo/findAll",hql = "select d from DemoEntity d where name = ?1")
+    List<DemoEntity> findAll(@RequestParam("name") String name);
+
+}
diff --git a/springboot-example/src/main/java/com/codingapi/springboot/example/insfrastructure/query/FastShowConfiguration.java b/springboot-example/src/main/java/com/codingapi/springboot/example/insfrastructure/query/FastShowConfiguration.java
diff --git a/springboot-example/src/main/java/com/codingapi/springboot/example/ui/controller/OpenController.java b/springboot-example/src/main/java/com/codingapi/springboot/example/ui/controller/OpenController.java
@@ -0,0 +1,23 @@
+package com.codingapi.springboot.example.ui.controller;
+
+import com.codingapi.springboot.example.application.executor.DemoExecutor;
+import com.codingapi.springboot.framework.dto.response.Response;
+import lombok.AllArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/open/demo")
+@AllArgsConstructor
+public class OpenController {
+
+    private final DemoExecutor executor;
+
+    @GetMapping("/save")
+    public Response save(@RequestParam("name") String name){
+        executor.create(name);
+        return Response.buildSuccess();
+    }
+}
diff --git a/springboot-starter-fastshow/pom.xml b/springboot-starter-fastshow/pom.xml
@@ -22,6 +22,17 @@
             <groupId>org.springframework</groupId>
             <artifactId>spring-webmvc</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>com.codingapi.springboot</groupId>
+            <artifactId>springboot-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jpa</artifactId>
+        </dependency>
+
     </dependencies>
 
 </project>
diff --git a/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/FastShowConfiguration.java b/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/FastShowConfiguration.java
@@ -1,13 +1,17 @@
 package com.codingapi.springboot.fastshow;
 
+import com.codingapi.springboot.fastshow.executor.JpaExecutor;
 import com.codingapi.springboot.fastshow.mapping.MvcEndpointMapping;
+import com.codingapi.springboot.fastshow.registrar.MvcMappingRegistrar;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 import org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerMapping;
 
+import javax.persistence.EntityManager;
+
 @Configuration
 @ConditionalOnClass(WebMvcConfigurer.class)
 public class FastShowConfiguration {
@@ -19,4 +23,16 @@ public MvcEndpointMapping mvcEndpointMapping(RequestMappingHandlerMapping handle
         return new MvcEndpointMapping(handlerMapping);
     }
 
+    @Bean(initMethod = "registerMvcMapping")
+    @ConditionalOnMissingBean
+    public MvcMappingRegistrar mappingRegistrar(MvcEndpointMapping mvcEndpointMapping,JpaExecutor jpaExecutor){
+        return new MvcMappingRegistrar(mvcEndpointMapping,jpaExecutor);
+    }
+
+    @Bean
+    @ConditionalOnMissingBean
+    public JpaExecutor jpaExecutor(EntityManager entityManager){
+        return new JpaExecutor(entityManager);
+    }
+
 }
diff --git a/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/annotation/FastController.java b/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/annotation/FastController.java
@@ -0,0 +1,12 @@
+package com.codingapi.springboot.fastshow.annotation;
+
+import java.lang.annotation.*;
+
+@Target(ElementType.TYPE)
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface FastController {
+
+
+
+}
diff --git a/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/annotation/FastMapping.java b/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/annotation/FastMapping.java
@@ -0,0 +1,24 @@
+package com.codingapi.springboot.fastshow.annotation;
+
+
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.METHOD)
+@ResponseBody
+public @interface FastMapping {
+
+    String hql() default "";
+
+    RequestMethod method() default RequestMethod.GET;
+
+
+    String mapping() default "";
+
+}
diff --git a/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/executor/JpaExecutor.java b/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/executor/JpaExecutor.java
@@ -0,0 +1,24 @@
+package com.codingapi.springboot.fastshow.executor;
+
+import lombok.AllArgsConstructor;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import javax.persistence.EntityManager;
+import javax.persistence.Query;
+
+@AllArgsConstructor
+public class JpaExecutor {
+
+    private final EntityManager entityManager;
+
+    @ResponseBody
+    public Object execute(String jpaSql,Object[] args){
+        Query query =  entityManager.createQuery(jpaSql);
+        if(args!=null) {
+            for (int i = 0; i < args.length; i++) {
+                query.setParameter(i+1,args[i]);
+            }
+        }
+        return query.getResultList();
+    }
+}
diff --git a/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/mapping/MvcEndpointMapping.java b/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/mapping/MvcEndpointMapping.java
@@ -14,14 +14,14 @@ public class MvcEndpointMapping {
 
     private final RequestMappingHandlerMapping handlerMapping;
 
-    public void addGetMapping(String url, Object handler, Method method) {
+    public void addMapping(String url, RequestMethod requestMethod, Object handler, Method method) {
 
         RequestMappingInfo.BuilderConfiguration options = new RequestMappingInfo.BuilderConfiguration();
         options.setPatternParser(new PathPatternParser());
 
         RequestMappingInfo mappingInfo = RequestMappingInfo
                 .paths(url)
-                .methods(RequestMethod.GET)
+                .methods(requestMethod)
                 .produces(MediaType.APPLICATION_JSON_VALUE)
                 .options(options)
                 .build();
diff --git a/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/registrar/FastShowBeanDefinitionRegistrar.java b/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/registrar/FastShowBeanDefinitionRegistrar.java
@@ -0,0 +1,35 @@
+package com.codingapi.springboot.fastshow.registrar;
+
+import com.codingapi.springboot.fastshow.annotation.FastController;
+import com.codingapi.springboot.framework.registrar.RegisterBeanDefinition;
+import lombok.SneakyThrows;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.support.BeanDefinitionRegistry;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.ImportBeanDefinitionRegistrar;
+import org.springframework.core.type.AnnotationMetadata;
+
+import java.util.Set;
+
+@Slf4j
+@Configuration
+public class FastShowBeanDefinitionRegistrar implements ImportBeanDefinitionRegistrar {
+
+
+    @SneakyThrows
+    @Override
+    public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {
+        RegisterBeanDefinition registerBeanDefinition = new RegisterBeanDefinition(importingClassMetadata, FastController.class);
+        Set<Class<?>> classSet = registerBeanDefinition.findTypes();
+
+        //注册Bean
+        for (Class<?> clazz : classSet) {
+            log.info("FastController class:{}",clazz);
+            MvcMappingRegistrar.classSet.add(clazz);
+        }
+    }
+
+
+
+
+}
diff --git a/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/registrar/MvcMappingRegistrar.java b/springboot-starter-fastshow/src/main/java/com/codingapi/springboot/fastshow/registrar/MvcMappingRegistrar.java
@@ -0,0 +1,63 @@
+package com.codingapi.springboot.fastshow.registrar;
+
+import com.codingapi.springboot.fastshow.annotation.FastMapping;
+import com.codingapi.springboot.fastshow.executor.JpaExecutor;
+import com.codingapi.springboot.fastshow.mapping.MvcEndpointMapping;
+import lombok.AllArgsConstructor;
+import lombok.SneakyThrows;
+import lombok.extern.slf4j.Slf4j;
+
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.Method;
+import java.lang.reflect.Proxy;
+import java.util.HashSet;
+import java.util.Set;
+
+@Slf4j
+@AllArgsConstructor
+public class MvcMappingRegistrar {
+    protected final static  Set<Class<?>> classSet = new HashSet<>();
+    private final MvcEndpointMapping mvcEndpointMapping;
+
+    private final JpaExecutor jpaExecutor;
+
+    @SneakyThrows
+    public void registerMvcMapping() {
+       for(Class<?> clazz:classSet){
+           Method[] methods = clazz.getDeclaredMethods();
+           for(Method method:methods){
+               FastMapping fastMapping =  method.getAnnotation(FastMapping.class);
+               if(fastMapping!=null) {
+                   MethodProxy handler = new MethodProxy(jpaExecutor);
+                   Object methodProxy =  Proxy.newProxyInstance(clazz.getClassLoader(), new Class[]{clazz}, handler);
+                   mvcEndpointMapping.addMapping(fastMapping.mapping(), fastMapping.method(), methodProxy, method);
+               }
+           }
+       }
+    }
+
+    @Slf4j
+    @AllArgsConstructor
+    public static class MethodProxy implements InvocationHandler {
+
+        private final JpaExecutor jpaExecutor;
+
+        @Override
+        public Object invoke(Object proxy, Method method, Object[] args)
+                throws Throwable {
+            if(method.equals(Object.class.getMethod("equals", Object.class))){
+                return false;
+            }
+            if(method.equals(Object.class.getMethod("hashCode"))){
+                return hashCode();
+            }
+            log.info("method.name:{}",method.getName());
+            log.info("xxx->{}",args);
+
+            FastMapping fastMapping = method.getAnnotation(FastMapping.class);
+            return jpaExecutor.execute(fastMapping.hql(),args);
+        }
+    }
+
+
+}
diff --git a/springboot-starter-fastshow/src/main/resources/META-INF/spring.factories b/springboot-starter-fastshow/src/main/resources/META-INF/spring.factories
@@ -1,2 +1,3 @@
 org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
-com.codingapi.springboot.fastshow.FastShowConfiguration
+com.codingapi.springboot.fastshow.FastShowConfiguration,\
+com.codingapi.springboot.fastshow.registrar.FastShowBeanDefinitionRegistrar
diff --git a/springboot-starter/src/main/java/com/codingapi/springboot/framework/handler/HandlerBeanDefinitionRegistrar.java b/springboot-starter/src/main/java/com/codingapi/springboot/framework/handler/HandlerBeanDefinitionRegistrar.java
diff --git a/springboot-starter/src/main/java/com/codingapi/springboot/framework/registrar/RegisterBeanDefinition.java b/springboot-starter/src/main/java/com/codingapi/springboot/framework/registrar/RegisterBeanDefinition.java
