add persistence module

Author: xlorne

pom.xml

@@ -220,6 +220,7 @@
                 <module>springboot-starter-security-jwt</module>
                 <module>springboot-starter-data-fast</module>
                 <module>springboot-starter-id-generator</module>
+                <module>springboot-starter-persistence</module>
             </modules>
         </profile>
 
@@ -232,6 +233,7 @@
                 <module>springboot-starter-security-jwt</module>
                 <module>springboot-starter-data-fast</module>
                 <module>springboot-starter-id-generator</module>
+                <module>springboot-starter-persistence</module>
             </modules>
 
             <build>
@@ -282,6 +284,7 @@
                 <module>springboot-starter-security-jwt</module>
                 <module>springboot-starter-data-fast</module>
                 <module>springboot-starter-id-generator</module>
+                <module>springboot-starter-persistence</module>
             </modules>
 
 

springboot-starter-persistence/pom.xml

@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xmlns="http://maven.apache.org/POM/4.0.0"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>springboot-parent</artifactId>
+        <groupId>com.codingapi.springboot</groupId>
+        <version>3.1.6</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>springboot-starter-persistence</artifactId>
+
+    <properties>
+        <java.version>17</java.version>
+    </properties>
+
+    <dependencies>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-jdbc</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>com.h2database</groupId>
+            <artifactId>h2</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+    </dependencies>
+
+</project>

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

@@ -0,0 +1,17 @@
+package com.codingapi.springboot.persistence;
+
+import com.codingapi.springboot.persistence.scanner.SchemaScanner;
+import com.codingapi.springboot.persistence.schema.SchemaExecutor;
+import com.codingapi.springboot.persistence.schema.SchemaFactory;
+import org.springframework.beans.factory.annotation.Configurable;
+import org.springframework.context.annotation.Bean;
+
+@Configurable
+public class AutoConfiguration {
+
+    @Bean
+    public SchemaScanner domainScanner(SchemaExecutor schemaExecutor, SchemaFactory schemaFactory) {
+        return new SchemaScanner(schemaExecutor, schemaFactory);
+    }
+
+}

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

@@ -0,0 +1,9 @@
+package com.codingapi.springboot.persistence;
+
+public interface DomainPersistence {
+
+    void save(Object domain);
+
+    <T> T get(Class<T> domainClass, Object id);
+
+}

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

@@ -0,0 +1,29 @@
+package com.codingapi.springboot.persistence.jdbc;
+
+import com.codingapi.springboot.persistence.DomainPersistence;
+import com.codingapi.springboot.persistence.schema.SchemaExecutor;
+import com.codingapi.springboot.persistence.schema.SchemaFactory;
+import org.springframework.beans.factory.annotation.Configurable;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.context.annotation.Bean;
+import org.springframework.jdbc.core.JdbcTemplate;
+
+@ConditionalOnClass(JdbcTemplate.class)
+@Configurable
+public class JdbcAutoConfiguration {
+
+    @Bean
+    public SchemaExecutor schemaExecutor(JdbcTemplate jdbcTemplate) {
+        return new JdbcSchemaExecutor(jdbcTemplate);
+    }
+
+    @Bean
+    public DomainPersistence domainPersistence(JdbcTemplate jdbcTemplate) {
+        return new JdbcDomainPersistence(jdbcTemplate);
+    }
+
+    @Bean
+    public SchemaFactory schemaFactory() {
+        return new JdbcSchemaFactory();
+    }
+}

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

@@ -0,0 +1,60 @@
+package com.codingapi.springboot.persistence.jdbc;
+
+import com.codingapi.springboot.persistence.DomainPersistence;
+import com.codingapi.springboot.persistence.scanner.SchemaContext;
+import com.codingapi.springboot.persistence.schema.SaveSchema;
+import com.codingapi.springboot.persistence.schema.Schema;
+import com.codingapi.springboot.persistence.schema.SearchSchema;
+import lombok.AllArgsConstructor;
+import org.springframework.dao.EmptyResultDataAccessException;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.support.GeneratedKeyHolder;
+import org.springframework.jdbc.support.KeyHolder;
+
+import java.sql.PreparedStatement;
+import java.sql.Statement;
+
+@AllArgsConstructor
+public class JdbcDomainPersistence implements DomainPersistence {
+
+    private final JdbcTemplate jdbcTemplate;
+
+    @Override
+    public void save(Object domain) {
+        Schema schema = SchemaContext.getINSTANCE().getSchema(domain.getClass());
+        if (schema != null) {
+            SaveSchema saveSchema = schema.insertSchema();
+            if (schema.getSchemaProperty().hasIdValue(domain)) {
+                jdbcTemplate.update(saveSchema.saveSchema(), saveSchema.getSaveValues(domain));
+            } else {
+                KeyHolder keyHolder = new GeneratedKeyHolder();
+                jdbcTemplate.update(con -> {
+                    PreparedStatement ps = con.prepareStatement(saveSchema.saveSchema(false), Statement.RETURN_GENERATED_KEYS);
+                    int index = 1;
+                    for (Object value : saveSchema.getSaveValues(domain, false)) {
+                        ps.setObject(index++, value);
+                    }
+                    return ps;
+                }, keyHolder);
+                schema.getSchemaProperty().setIdValue(domain, keyHolder.getKey());
+            }
+        }
+    }
+
+    @Override
+    public <T> T get(Class<T> domainClass, Object id) {
+        Schema schema = SchemaContext.getINSTANCE().getSchema(domainClass);
+        if (schema != null) {
+            SearchSchema searchSchema = schema.getById();
+            String sql = searchSchema.getById();
+            try {
+                return jdbcTemplate.queryForObject(sql, new Object[]{id}, new BeanPropertyRowMapper<>(domainClass));
+            } catch (EmptyResultDataAccessException e) {
+                // Handle the case where no results are found or rethrow a custom exception
+                return null;
+            }
+        }
+        return null;
+    }
+}

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

@@ -0,0 +1,22 @@
+package com.codingapi.springboot.persistence.jdbc;
+
+import com.codingapi.springboot.persistence.schema.Schema;
+import com.codingapi.springboot.persistence.schema.SchemaExecutor;
+import lombok.AllArgsConstructor;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Repository;
+
+@Repository
+@AllArgsConstructor
+public class JdbcSchemaExecutor implements SchemaExecutor {
+
+    private final JdbcTemplate jdbcTemplate;
+
+
+    @Override
+    public void create(Schema schema) {
+        jdbcTemplate.execute(schema.buildSchema().createSchema());
+    }
+
+
+}

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

@@ -0,0 +1,14 @@
+package com.codingapi.springboot.persistence.jdbc;
+
+import com.codingapi.springboot.persistence.jdbc.schema.JdbcSchema;
+import com.codingapi.springboot.persistence.schema.Schema;
+import com.codingapi.springboot.persistence.schema.SchemaFactory;
+
+public class JdbcSchemaFactory implements SchemaFactory {
+
+    @Override
+    public Schema getSchema(Class<?> domainClass) {
+        return new JdbcSchema(domainClass);
+    }
+
+}

springboot-starter-persistence/src/main/java/com/codingapi/springboot/persistence/jdbc/schema/JdbcBuildSchema.java

@@ -0,0 +1,35 @@
+package com.codingapi.springboot.persistence.jdbc.schema;
+
+import com.codingapi.springboot.persistence.schema.BuildSchema;
+import com.codingapi.springboot.persistence.schema.Property;
+import com.codingapi.springboot.persistence.schema.Schema;
+
+import java.util.List;
+
+public class JdbcBuildSchema extends BuildSchema {
+
+    public JdbcBuildSchema(Schema schema) {
+        super(schema);
+    }
+
+    @Override
+    public String createSchema() {
+        StringBuilder sql = new StringBuilder();
+        sql.append("CREATE TABLE IF NOT EXISTS ");
+        sql.append(property.getSchemaName());
+        sql.append(" (");
+        sql.append("id INT PRIMARY KEY AUTO_INCREMENT,");
+        List<Property> properties = property.getProperties(false);
+        for (int i = 0; i < properties.size(); i++) {
+            Property property = properties.get(i);
+            sql.append(property.getName());
+            sql.append(" ");
+            sql.append(property.getJdbcType());
+            if (i != properties.size() - 1) {
+                sql.append(", ");
+            }
+        }
+        sql.append(")");
+        return sql.toString();
+    }
+}

springboot-starter-persistence/src/main/java/com/codingapi/springboot/persistence/jdbc/schema/JdbcSaveSchema.java

@@ -0,0 +1,34 @@
+package com.codingapi.springboot.persistence.jdbc.schema;
+
+import com.codingapi.springboot.persistence.schema.Property;
+import com.codingapi.springboot.persistence.schema.SaveSchema;
+import com.codingapi.springboot.persistence.schema.Schema;
+
+public class JdbcSaveSchema extends SaveSchema {
+
+    public JdbcSaveSchema(Schema schema) {
+        super(schema);
+    }
+
+    @Override
+    public String saveSchema(boolean hasId) {
+        StringBuilder sql = new StringBuilder();
+        sql.append("INSERT INTO ");
+        sql.append(property.getSchemaName());
+        sql.append(" (");
+        for (Property property : property.getProperties(hasId)) {
+            sql.append(property.getName());
+            sql.append(", ");
+        }
+        sql.delete(sql.length() - 2, sql.length());
+        sql.append(") VALUES (");
+        for (Property property : property.getProperties(hasId)) {
+            sql.append("?, ");
+        }
+        sql.delete(sql.length() - 2, sql.length());
+        sql.append(")");
+        return sql.toString();
+    }
+
+
+}

springboot-starter-persistence/src/main/java/com/codingapi/springboot/persistence/jdbc/schema/JdbcSchema.java

@@ -0,0 +1,28 @@
+package com.codingapi.springboot.persistence.jdbc.schema;
+
+import com.codingapi.springboot.persistence.schema.BuildSchema;
+import com.codingapi.springboot.persistence.schema.SaveSchema;
+import com.codingapi.springboot.persistence.schema.Schema;
+import com.codingapi.springboot.persistence.schema.SearchSchema;
+
+public class JdbcSchema extends Schema {
+
+    public JdbcSchema(Class<?> domainClass) {
+        super(domainClass);
+    }
+
+    @Override
+    public BuildSchema buildSchema() {
+        return new JdbcBuildSchema(this);
+    }
+
+    @Override
+    public SaveSchema insertSchema() {
+        return new JdbcSaveSchema(this);
+    }
+
+    @Override
+    public SearchSchema getById() {
+        return new JdbcSearchSchema(this);
+    }
+}

springboot-starter-persistence/src/main/java/com/codingapi/springboot/persistence/jdbc/schema/JdbcSearchSchema.java

@@ -0,0 +1,18 @@
+package com.codingapi.springboot.persistence.jdbc.schema;
+
+import com.codingapi.springboot.persistence.schema.Schema;
+import com.codingapi.springboot.persistence.schema.SearchSchema;
+
+public class JdbcSearchSchema extends SearchSchema {
+
+    public JdbcSearchSchema(Schema schema) {
+        super(schema);
+    }
+
+    @Override
+    public String getById() {
+        return "SELECT * FROM " + property.getSchemaName() + " WHERE id = ?";
+    }
+
+
+}

springboot-starter-persistence/src/main/java/com/codingapi/springboot/persistence/register/DomainClassRegister.java

@@ -0,0 +1,29 @@
+package com.codingapi.springboot.persistence.register;
+
+import lombok.Getter;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Getter
+public class DomainClassRegister {
+
+    private final List<Class<?>> classes;
+
+    public final static DomainClassRegister INSTANCE = new DomainClassRegister();
+
+    private DomainClassRegister() {
+        this.classes = new ArrayList<>();
+    }
+
+    public void register(Class<?> domainClass) {
+        this.classes.add(domainClass);
+    }
+
+    public boolean supports(Class<?> domainClass) {
+        return this.classes.stream()
+                .anyMatch(clazz -> clazz.equals(domainClass));
+
+    }
+
+}

springboot-starter-persistence/src/main/java/com/codingapi/springboot/persistence/scanner/SchemaContext.java

@@ -0,0 +1,30 @@
+package com.codingapi.springboot.persistence.scanner;
+
+import com.codingapi.springboot.persistence.schema.Schema;
+import lombok.Getter;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class SchemaContext {
+
+    @Getter
+    public final static SchemaContext INSTANCE = new SchemaContext();
+
+    private final List<Schema> schemas;
+
+    private SchemaContext() {
+        this.schemas = new ArrayList<>();
+    }
+
+    public void register(Schema schema) {
+        this.schemas.add(schema);
+    }
+
+    public Schema getSchema(Class<?> domainClass) {
+        return schemas.stream()
+                .filter(schema -> schema.getDomainClass().equals(domainClass))
+                .findFirst()
+                .orElseThrow(() -> new RuntimeException("schema not found"));
+    }
+}