support find schema

Author: xlorne

springboot-starter-persistence/src/main/java/com/codingapi/springboot/persistence/DomainPersistence.java

@@ -1,5 +1,7 @@
 package com.codingapi.springboot.persistence;
 
+import java.util.List;
+
 public interface DomainPersistence {
 
     void save(Object domain);
@@ -9,4 +11,6 @@ public interface DomainPersistence {
     void delete(Class<?> domainClass,Object id);
 
     void update(Object domain);
+
+    <T> List<T> find(Class<T> domainClass, String schema, Object... fields);
 }

springboot-starter-persistence/src/main/java/com/codingapi/springboot/persistence/jdbc/impl/JdbcDomainPersistence.java

@@ -15,6 +15,7 @@
 
 import java.sql.PreparedStatement;
 import java.sql.Statement;
+import java.util.List;
 
 @AllArgsConstructor
 public class JdbcDomainPersistence implements DomainPersistence {
@@ -60,7 +61,7 @@ public <T> T get(Class<T> domainClass, Object id) {
     }
 
     @Override
-    public void delete(Class<?> domainClazz,Object id) {
+    public void delete(Class<?> domainClazz, Object id) {
         Schema schema = SchemaContext.getINSTANCE().getSchema(domainClazz);
         if (schema != null) {
             String sql = schema.deleteSchema().deleteSchema();
@@ -76,4 +77,14 @@ public void update(Object domain) {
             jdbcTemplate.update(updateSchema.updateSchema(), updateSchema.getUpdateValues(domain));
         }
     }
+
+
+    @Override
+    public <T> List<T> find(Class<T> domainClass, String sql, Object... fields) {
+        Schema schema = SchemaContext.getINSTANCE().getSchema(domainClass);
+        if (schema != null) {
+            return jdbcTemplate.query(sql, fields, new BeanPropertyRowMapper<>(domainClass));
+        }
+        return null;
+    }
 }

springboot-starter-persistence/src/test/java/com/example/demo/repository/DemoRepository.java

@@ -6,6 +6,8 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+
 @Slf4j
 @Repository
 @AllArgsConstructor
@@ -22,11 +24,15 @@ public Demo get(int id) {
     }
 
     public void delete(int id) {
-        domainPersistence.delete(Demo.class,id);
+        domainPersistence.delete(Demo.class, id);
     }
 
     public void update(Demo demo) {
         domainPersistence.update(demo);
     }
 
+    public List<Demo> findByName(String name) {
+        return domainPersistence.find(Demo.class, "select * from demo where name = ?", name);
+    }
+
 }

springboot-starter-persistence/src/test/java/com/example/demo/repository/DemoRepositoryTests.java

@@ -6,6 +6,8 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
+import java.util.List;
+
 @Slf4j
 @SpringBootTest
 public class DemoRepositoryTests {
@@ -51,4 +53,10 @@ void update() {
         demo.setName("123456");
         demoRepository.update(demo);
     }
+
+    @Test
+    void getByName() {
+        List<Demo> list = demoRepository.findByName("demo");
+        log.info("list: {}", list);
+    }
 }