commit 40cffea983c53c46cd529095c1480510bdfb749c Author: Sambo Chea Date: Fri Jul 3 14:53:14 2020 +0700 Add data jpa module and project diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..2310678 --- /dev/null +++ b/.gitignore @@ -0,0 +1,34 @@ +HELP.md +.gradle +build/ +!gradle/wrapper/gradle-wrapper.jar +!**/src/main/** +!**/src/test/** + +gradle.properties + +### STS ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### IntelliJ IDEA ### +.idea +*.iws +*.iml +*.ipr +out/ + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ + +### VS Code ### +.vscode/ diff --git a/README.md b/README.md new file mode 100644 index 0000000..f86695c --- /dev/null +++ b/README.md @@ -0,0 +1,4 @@ +### CUBETIQ Data JPA Module +- [x] Spring Data JPA +- [x] Custom Repository and Service +- [ ] More... \ No newline at end of file diff --git a/build.gradle b/build.gradle new file mode 100644 index 0000000..832421b --- /dev/null +++ b/build.gradle @@ -0,0 +1,46 @@ +plugins { + id 'org.springframework.boot' version '2.3.0.RELEASE' + id 'io.spring.dependency-management' version '1.0.9.RELEASE' + id 'java' + id 'maven' +} + +group 'com.cubetiqs.libra' +version '1.0-SNAPSHOT' +sourceCompatibility = '1.8' + +repositories { + mavenCentral() + maven { + url "${nexusUrl}/repository/maven-public/" + } +} + +dependencies { + implementation 'org.springframework.boot:spring-boot-starter' + implementation 'org.springframework.boot:spring-boot-starter-data-jpa' + implementation 'com.cubetiqs.libra:logging:1.0-20200703.050529-4' + + testCompile group: 'junit', name: 'junit', version: '4.12' +} + +bootJar { + enabled = false +} + +jar { + enabled = true +} + +uploadArchives { + repositories { + mavenDeployer { + repository(url: "${nexusUrl}/repository/maven-releases/") { + authentication(userName: nexusUsername, password: nexusPassword) + } + snapshotRepository(url: "${nexusUrl}/repository/maven-snapshots") { + authentication(userName: nexusUsername, password: nexusPassword) + } + } + } +} \ No newline at end of file diff --git a/gradle.properties.sample b/gradle.properties.sample new file mode 100644 index 0000000..6494df5 --- /dev/null +++ b/gradle.properties.sample @@ -0,0 +1,3 @@ +nexusUrl=https://oss-internal.cubetiqs.com +nexusUsername=user +nexusPassword=pass \ No newline at end of file diff --git a/gradle/wrapper/gradle-wrapper.jar b/gradle/wrapper/gradle-wrapper.jar new file mode 100644 index 0000000..f3d88b1 Binary files /dev/null and b/gradle/wrapper/gradle-wrapper.jar differ diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties new file mode 100644 index 0000000..71af859 --- /dev/null +++ b/gradle/wrapper/gradle-wrapper.properties @@ -0,0 +1,6 @@ +#Mon Jun 08 15:30:03 ICT 2020 +distributionUrl=https\://services.gradle.org/distributions/gradle-6.4.1-all.zip +distributionBase=GRADLE_USER_HOME +distributionPath=wrapper/dists +zipStorePath=wrapper/dists +zipStoreBase=GRADLE_USER_HOME diff --git a/gradlew b/gradlew new file mode 100755 index 0000000..fbd7c51 --- /dev/null +++ b/gradlew @@ -0,0 +1,185 @@ +#!/usr/bin/env sh + +# +# Copyright 2015 the original author or authors. +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# https://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + +############################################################################## +## +## Gradle start up script for UN*X +## +############################################################################## + +# Attempt to set APP_HOME +# Resolve links: $0 may be a link +PRG="$0" +# Need this for relative symlinks. +while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> \(.*\)$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG=`dirname "$PRG"`"/$link" + fi +done +SAVED="`pwd`" +cd "`dirname \"$PRG\"`/" >/dev/null +APP_HOME="`pwd -P`" +cd "$SAVED" >/dev/null + +APP_NAME="Gradle" +APP_BASE_NAME=`basename "$0"` + +# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. +DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"' + +# Use the maximum available, or set MAX_FD != -1 to use that value. +MAX_FD="maximum" + +warn () { + echo "$*" +} + +die () { + echo + echo "$*" + echo + exit 1 +} + +# OS specific support (must be 'true' or 'false'). +cygwin=false +msys=false +darwin=false +nonstop=false +case "`uname`" in + CYGWIN* ) + cygwin=true + ;; + Darwin* ) + darwin=true + ;; + MINGW* ) + msys=true + ;; + NONSTOP* ) + nonstop=true + ;; +esac + +CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar + + +# Determine the Java command to use to start the JVM. +if [ -n "$JAVA_HOME" ] ; then + if [ -x "$JAVA_HOME/jre/sh/java" ] ; then + # IBM's JDK on AIX uses strange locations for the executables + JAVACMD="$JAVA_HOME/jre/sh/java" + else + JAVACMD="$JAVA_HOME/bin/java" + fi + if [ ! -x "$JAVACMD" ] ; then + die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME + +Please set the JAVA_HOME variable in your environment to match the +location of your Java installation." + fi +else + JAVACMD="java" + which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. + +Please set the JAVA_HOME variable in your environment to match the +location of your Java installation." +fi + +# Increase the maximum file descriptors if we can. +if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then + MAX_FD_LIMIT=`ulimit -H -n` + if [ $? -eq 0 ] ; then + if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then + MAX_FD="$MAX_FD_LIMIT" + fi + ulimit -n $MAX_FD + if [ $? -ne 0 ] ; then + warn "Could not set maximum file descriptor limit: $MAX_FD" + fi + else + warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT" + fi +fi + +# For Darwin, add options to specify how the application appears in the dock +if $darwin; then + GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\"" +fi + +# For Cygwin or MSYS, switch paths to Windows format before running java +if [ "$cygwin" = "true" -o "$msys" = "true" ] ; then + APP_HOME=`cygpath --path --mixed "$APP_HOME"` + CLASSPATH=`cygpath --path --mixed "$CLASSPATH"` + + JAVACMD=`cygpath --unix "$JAVACMD"` + + # We build the pattern for arguments to be converted via cygpath + ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null` + SEP="" + for dir in $ROOTDIRSRAW ; do + ROOTDIRS="$ROOTDIRS$SEP$dir" + SEP="|" + done + OURCYGPATTERN="(^($ROOTDIRS))" + # Add a user-defined pattern to the cygpath arguments + if [ "$GRADLE_CYGPATTERN" != "" ] ; then + OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)" + fi + # Now convert the arguments - kludge to limit ourselves to /bin/sh + i=0 + for arg in "$@" ; do + CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -` + CHECK2=`echo "$arg"|egrep -c "^-"` ### Determine if an option + + if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then ### Added a condition + eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"` + else + eval `echo args$i`="\"$arg\"" + fi + i=`expr $i + 1` + done + case $i in + 0) set -- ;; + 1) set -- "$args0" ;; + 2) set -- "$args0" "$args1" ;; + 3) set -- "$args0" "$args1" "$args2" ;; + 4) set -- "$args0" "$args1" "$args2" "$args3" ;; + 5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;; + 6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;; + 7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;; + 8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;; + 9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;; + esac +fi + +# Escape application args +save () { + for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done + echo " " +} +APP_ARGS=`save "$@"` + +# Collect all arguments for the java command, following the shell quoting and substitution rules +eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS" + +exec "$JAVACMD" "$@" diff --git a/gradlew.bat b/gradlew.bat new file mode 100644 index 0000000..a9f778a --- /dev/null +++ b/gradlew.bat @@ -0,0 +1,104 @@ +@rem +@rem Copyright 2015 the original author or authors. +@rem +@rem Licensed under the Apache License, Version 2.0 (the "License"); +@rem you may not use this file except in compliance with the License. +@rem You may obtain a copy of the License at +@rem +@rem https://www.apache.org/licenses/LICENSE-2.0 +@rem +@rem Unless required by applicable law or agreed to in writing, software +@rem distributed under the License is distributed on an "AS IS" BASIS, +@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +@rem See the License for the specific language governing permissions and +@rem limitations under the License. +@rem + +@if "%DEBUG%" == "" @echo off +@rem ########################################################################## +@rem +@rem Gradle startup script for Windows +@rem +@rem ########################################################################## + +@rem Set local scope for the variables with windows NT shell +if "%OS%"=="Windows_NT" setlocal + +set DIRNAME=%~dp0 +if "%DIRNAME%" == "" set DIRNAME=. +set APP_BASE_NAME=%~n0 +set APP_HOME=%DIRNAME% + +@rem Resolve any "." and ".." in APP_HOME to make it shorter. +for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi + +@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. +set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m" + +@rem Find java.exe +if defined JAVA_HOME goto findJavaFromJavaHome + +set JAVA_EXE=java.exe +%JAVA_EXE% -version >NUL 2>&1 +if "%ERRORLEVEL%" == "0" goto init + +echo. +echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. +echo. +echo Please set the JAVA_HOME variable in your environment to match the +echo location of your Java installation. + +goto fail + +:findJavaFromJavaHome +set JAVA_HOME=%JAVA_HOME:"=% +set JAVA_EXE=%JAVA_HOME%/bin/java.exe + +if exist "%JAVA_EXE%" goto init + +echo. +echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% +echo. +echo Please set the JAVA_HOME variable in your environment to match the +echo location of your Java installation. + +goto fail + +:init +@rem Get command-line arguments, handling Windows variants + +if not "%OS%" == "Windows_NT" goto win9xME_args + +:win9xME_args +@rem Slurp the command line arguments. +set CMD_LINE_ARGS= +set _SKIP=2 + +:win9xME_args_slurp +if "x%~1" == "x" goto execute + +set CMD_LINE_ARGS=%* + +:execute +@rem Setup the command line + +set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar + + +@rem Execute Gradle +"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS% + +:end +@rem End local scope for the variables with windows NT shell +if "%ERRORLEVEL%"=="0" goto mainEnd + +:fail +rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of +rem the _cmd.exe /c_ return code! +if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1 +exit /b 1 + +:mainEnd +if "%OS%"=="Windows_NT" endlocal + +:omega diff --git a/scripts/push b/scripts/push new file mode 100755 index 0000000..e8ae0cd --- /dev/null +++ b/scripts/push @@ -0,0 +1,5 @@ +#!/bin/bash + +git push origin master +git push github master + diff --git a/scripts/upload b/scripts/upload new file mode 100755 index 0000000..4bfad26 --- /dev/null +++ b/scripts/upload @@ -0,0 +1,3 @@ +#!/usr/bin/env bash + +gradle upload \ No newline at end of file diff --git a/settings.gradle b/settings.gradle new file mode 100644 index 0000000..89b5a93 --- /dev/null +++ b/settings.gradle @@ -0,0 +1 @@ +rootProject.name = 'data-jpa' diff --git a/src/main/java/com/cubetiqs/data/config/AuditorAwareConfigurer.java b/src/main/java/com/cubetiqs/data/config/AuditorAwareConfigurer.java new file mode 100644 index 0000000..b05c5b1 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/config/AuditorAwareConfigurer.java @@ -0,0 +1,22 @@ +package com.cubetiqs.data.config; + +import com.cubetiqs.data.domain.AuditDetails; +import org.springframework.context.annotation.Bean; +import org.springframework.data.domain.AuditorAware; + +/** + * Auditor Aware Configurer + * + * @author sombochea + * @see AuditorAware + * @see AuditDetails + * @since 1.0 + */ +public interface AuditorAwareConfigurer { + String AUDITOR_AWARE_BEAN = "auditorAware"; + + @Bean + default AuditorAware auditorAware() { + return new AuditorAwareImpl(); + } +} diff --git a/src/main/java/com/cubetiqs/data/config/AuditorAwareImpl.java b/src/main/java/com/cubetiqs/data/config/AuditorAwareImpl.java new file mode 100644 index 0000000..24a7152 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/config/AuditorAwareImpl.java @@ -0,0 +1,25 @@ +package com.cubetiqs.data.config; + +import com.cubetiqs.data.domain.AuditDetails; +import org.springframework.data.domain.AuditorAware; +import org.springframework.lang.NonNull; + +import java.util.Optional; + +/** + * Audit Aware Impl + * + * @author sombochea + * @see AuditorAware + * @see AuditDetails + * @since 1.0 + */ +public class AuditorAwareImpl implements AuditorAware { + private final static String SYSTEM = "admin"; + + @NonNull + @Override + public Optional getCurrentAuditor() { + return Optional.of(new AuditDetails(SYSTEM)); + } +} diff --git a/src/main/java/com/cubetiqs/data/config/PersistenceContext.java b/src/main/java/com/cubetiqs/data/config/PersistenceContext.java new file mode 100644 index 0000000..73fdef1 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/config/PersistenceContext.java @@ -0,0 +1,36 @@ +package com.cubetiqs.data.config; + +import com.cubetiqs.data.repository.BaseRepositoryImpl; +import org.springframework.context.annotation.Configuration; +import org.springframework.data.jpa.repository.config.EnableJpaRepositories; +import org.springframework.transaction.annotation.EnableTransactionManagement; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +/** + * Persistence Configuration Context. + * This identifier used for boot config and app base packages and repositories bean. + * Default scan components are "com.cubetiqs" and "com.cubetiqs.data.repository" for current base repository registration. + * + * @author sombochea + * @see Target + * @see Retention + * @see Configuration + * @see EnableJpaRepositories + * @see EnableTransactionManagement + * @see BaseRepositoryImpl + * @since 1.0 + */ +@Target(ElementType.TYPE) +@Retention(RetentionPolicy.RUNTIME) +@Configuration +@EnableJpaRepositories( + basePackages = {"com.cubetiqs.data.repository", "com.cubetiqs"}, + repositoryBaseClass = BaseRepositoryImpl.class +) +@EnableTransactionManagement +public @interface PersistenceContext { +} diff --git a/src/main/java/com/cubetiqs/data/domain/AuditDetails.java b/src/main/java/com/cubetiqs/data/domain/AuditDetails.java new file mode 100644 index 0000000..996a39f --- /dev/null +++ b/src/main/java/com/cubetiqs/data/domain/AuditDetails.java @@ -0,0 +1,30 @@ +package com.cubetiqs.data.domain; + +import javax.persistence.Embeddable; +import java.io.Serializable; + +/** + * Audit Details + * + * @author sombochea + * @since 1.0 + */ +@Embeddable +public class AuditDetails implements Serializable { + private String createdBy; + + public void setCreatedBy(String createdBy) { + this.createdBy = createdBy; + } + + public String getCreatedBy() { + return createdBy; + } + + public AuditDetails() { + } + + public AuditDetails(String createdBy) { + this.createdBy = createdBy; + } +} diff --git a/src/main/java/com/cubetiqs/data/domain/BaseAuditDomainModel.java b/src/main/java/com/cubetiqs/data/domain/BaseAuditDomainModel.java new file mode 100644 index 0000000..7e687a0 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/domain/BaseAuditDomainModel.java @@ -0,0 +1,44 @@ +package com.cubetiqs.data.domain; + +import org.springframework.data.annotation.CreatedBy; +import org.springframework.data.annotation.CreatedDate; +import org.springframework.data.annotation.LastModifiedBy; +import org.springframework.data.annotation.LastModifiedDate; +import org.springframework.data.jpa.domain.support.AuditingEntityListener; + +import javax.persistence.*; +import java.io.Serializable; +import java.util.Date; + +/** + * Base Domain Model + * + * @author sombochea + * @see BaseEntity + * @since 1.0 + */ +@MappedSuperclass +@EntityListeners(AuditingEntityListener.class) +public abstract class BaseAuditDomainModel extends BaseDomainModel { + @Embedded + @AttributeOverride( + name = "createdBy", + column = @Column(name = "created_by") + ) + @CreatedBy + private AuditDetails createdBy; + + @CreatedDate + private Date createdDate; + + @Embedded + @AttributeOverride( + name = "createdBy", + column = @Column(name = "updated_by") + ) + @LastModifiedBy + private AuditDetails updatedBy; + + @LastModifiedDate + private Date updatedDate; +} diff --git a/src/main/java/com/cubetiqs/data/domain/BaseDomainModel.java b/src/main/java/com/cubetiqs/data/domain/BaseDomainModel.java new file mode 100644 index 0000000..88d9cf2 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/domain/BaseDomainModel.java @@ -0,0 +1,36 @@ +package com.cubetiqs.data.domain; + +import javax.persistence.GeneratedValue; +import javax.persistence.GenerationType; +import javax.persistence.Id; +import javax.persistence.MappedSuperclass; +import java.io.Serializable; + +/** + * Base Domain Model + * + * @author sombochea + * @see BaseEntity + * @since 1.0 + */ +@MappedSuperclass +public abstract class BaseDomainModel implements BaseEntity { + @Id + @GeneratedValue(strategy = GenerationType.AUTO) + private ID id; + + @Override + public void setId(ID id) { + this.id = id; + } + + @Override + public ID getId() { + return id; + } + + @Override + public boolean isNew() { + return id == null; + } +} diff --git a/src/main/java/com/cubetiqs/data/domain/BaseEntity.java b/src/main/java/com/cubetiqs/data/domain/BaseEntity.java new file mode 100644 index 0000000..a071f06 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/domain/BaseEntity.java @@ -0,0 +1,14 @@ +package com.cubetiqs.data.domain; + +import org.springframework.data.domain.Persistable; + +import java.io.Serializable; + +/** + * @author sombochea + * @see Persistable + * @since 1.o + */ +public interface BaseEntity extends Persistable, Serializable { + void setId(ID id); +} diff --git a/src/main/java/com/cubetiqs/data/domain/Queryable.java b/src/main/java/com/cubetiqs/data/domain/Queryable.java new file mode 100644 index 0000000..4d54af9 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/domain/Queryable.java @@ -0,0 +1,13 @@ +package com.cubetiqs.data.domain; + +import org.springframework.data.jpa.domain.Specification; + +/** + * Queryable Specification + * + * @author sombochea + * @see Specification + * @since 1.0 + */ +public interface Queryable extends Specification { +} diff --git a/src/main/java/com/cubetiqs/data/repository/BaseRepository.java b/src/main/java/com/cubetiqs/data/repository/BaseRepository.java new file mode 100644 index 0000000..9ec28f7 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/repository/BaseRepository.java @@ -0,0 +1,23 @@ +package com.cubetiqs.data.repository; + +import com.cubetiqs.data.domain.Queryable; +import org.springframework.data.domain.Page; +import org.springframework.data.domain.Pageable; +import org.springframework.data.jpa.repository.JpaRepository; +import org.springframework.data.repository.NoRepositoryBean; + +import java.util.List; + +/** + * Base Repository + * + * @author sombochea + * @see JpaRepository + * @see NoRepositoryBean + * @since 1.0 + */ +@NoRepositoryBean +public interface BaseRepository extends JpaRepository { + List searchByQueryable(Queryable queryable); + Page searchByQueryable(Queryable queryable, Pageable pageable); +} diff --git a/src/main/java/com/cubetiqs/data/repository/BaseRepositoryImpl.java b/src/main/java/com/cubetiqs/data/repository/BaseRepositoryImpl.java new file mode 100644 index 0000000..435df8c --- /dev/null +++ b/src/main/java/com/cubetiqs/data/repository/BaseRepositoryImpl.java @@ -0,0 +1,47 @@ +package com.cubetiqs.data.repository; + +import com.cubetiqs.data.domain.Queryable; +import com.cubetiqs.logging.Log; +import org.apache.logging.log4j.Logger; +import org.springframework.data.domain.Page; +import org.springframework.data.domain.Pageable; +import org.springframework.data.jpa.repository.support.JpaEntityInformation; +import org.springframework.data.jpa.repository.support.SimpleJpaRepository; +import org.springframework.data.repository.NoRepositoryBean; + +import javax.persistence.EntityManager; +import java.io.Serializable; +import java.util.List; + +/** + * Base Repository Impl + * + * @author sombochea + * @see BaseRepository + * @see SimpleJpaRepository + * @since 1.0 + */ +@NoRepositoryBean +public class BaseRepositoryImpl + extends SimpleJpaRepository + implements BaseRepository { + private final Logger logger = Log.getLogger(getClass()); + + public BaseRepositoryImpl(JpaEntityInformation entityInformation, EntityManager entityManager) { + super(entityInformation, entityManager); + } + + @Override + public List searchByQueryable(Queryable queryable) { + List records = findAll(queryable); + logger.info("find all records: {}", records.size()); + return records; + } + + @Override + public Page searchByQueryable(Queryable queryable, Pageable pageable) { + Page records = findAll(queryable, pageable); + logger.info("find all records: {} and pages: {}", records.getTotalElements(), records.getTotalPages()); + return records; + } +} diff --git a/src/main/java/com/cubetiqs/data/service/BaseService.java b/src/main/java/com/cubetiqs/data/service/BaseService.java new file mode 100644 index 0000000..785c331 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/service/BaseService.java @@ -0,0 +1,20 @@ +package com.cubetiqs.data.service; + +import com.cubetiqs.data.repository.BaseRepository; + +/** + * Base Service Repository + * + * @author sombochea + * @since 1.0 + */ +@NoServiceBean +public interface BaseService { + /** + * Get current entity repository + * + * @return BaseRepository | Whole entity repository + * @see BaseRepository + */ + BaseRepository getRepository(); +} diff --git a/src/main/java/com/cubetiqs/data/service/CrudService.java b/src/main/java/com/cubetiqs/data/service/CrudService.java new file mode 100644 index 0000000..2e0b686 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/service/CrudService.java @@ -0,0 +1,67 @@ +package com.cubetiqs.data.service; + +import java.util.List; + +/** + * Crud Service used for Create, Read, Update and Delete entity + * + * @author sombochea + * @see BaseService + * @since 1.0 + */ +@NoServiceBean +public interface CrudService extends BaseService { + /** + * Find all entities + * + * @return List | Collection of Entity + */ + List findAll(); + + /** + * Create new record + * + * @param entity T + * @return T | Get entity back + */ + T create(T entity); + + /** + * Create all entity records + * + * @param entities List of entities + * @return List | Collection of entity + */ + List createAll(List entities); + + /** + * Read one record from entity ID + * + * @param id ID + * @return T | If have, Get entity back or NULL + */ + T read(ID id); + + /** + * Update entity record with entity ID + * + * @param id ID + * @param entity T + * @return T | Get entity back, after updated + */ + T update(ID id, T entity); + + /** + * Delete entity record with entity ID + * + * @param id ID + */ + void delete(ID id); + + /** + * Delete all entity records + * + * @param ids List of IDs + */ + void deleteAll(List ids); +} diff --git a/src/main/java/com/cubetiqs/data/service/CrudServiceImpl.java b/src/main/java/com/cubetiqs/data/service/CrudServiceImpl.java new file mode 100644 index 0000000..c51eabb --- /dev/null +++ b/src/main/java/com/cubetiqs/data/service/CrudServiceImpl.java @@ -0,0 +1,59 @@ +package com.cubetiqs.data.service; + +import com.cubetiqs.data.domain.BaseEntity; +import com.cubetiqs.data.repository.BaseRepository; + +import java.util.List; + +/** + * Crud Service Impl + * + * @author sombochea + * @since 1.0 + */ +@NoServiceBean +public class CrudServiceImpl> implements CrudService { + @Override + public List findAll() { + return getRepository().findAll(); + } + + @Override + public T create(T entity) { + return getRepository().save(entity); + } + + @Override + public List createAll(List entities) { + return getRepository().saveAll(entities); + } + + @Override + public T read(ID id) { + return getRepository().findById(id).orElse(null); + } + + @Override + public T update(ID id, T entity) { + T update = read(id); + if (update == null) { + return null; + } + return getRepository().save(entity); + } + + @Override + public void delete(ID id) { + getRepository().deleteById(id); + } + + @Override + public void deleteAll(List ids) { + getRepository().deleteAll(getRepository().findAllById(ids)); + } + + @Override + public BaseRepository getRepository() { + throw new ServiceNotImplementException("service must be implement!"); + } +} diff --git a/src/main/java/com/cubetiqs/data/service/NoServiceBean.java b/src/main/java/com/cubetiqs/data/service/NoServiceBean.java new file mode 100644 index 0000000..5c05d9f --- /dev/null +++ b/src/main/java/com/cubetiqs/data/service/NoServiceBean.java @@ -0,0 +1,22 @@ +package com.cubetiqs.data.service; + +import org.springframework.data.repository.NoRepositoryBean; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +/** + * No Service Bean + * + * @author sombochea + * @see NoRepositoryBean + * @since 1.0 + */ +@Target(ElementType.TYPE) +@Retention(RetentionPolicy.RUNTIME) +@NoRepositoryBean +public @interface NoServiceBean { + String value() default ""; +} diff --git a/src/main/java/com/cubetiqs/data/service/PagingCrudService.java b/src/main/java/com/cubetiqs/data/service/PagingCrudService.java new file mode 100644 index 0000000..8b992f4 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/service/PagingCrudService.java @@ -0,0 +1,36 @@ +package com.cubetiqs.data.service; + +import org.springframework.data.domain.Page; +import org.springframework.data.domain.Pageable; +import org.springframework.data.domain.Sort; + +import java.util.List; + +/** + * Paging Crud Service + * Used for Crud Style, but include pagination support + * + * @author sombochea + * @see CrudService + * @since 1.0 + */ +@NoServiceBean +public interface PagingCrudService extends CrudService { + /** + * Find All with pagination + * + * @param pageable Pageable + * @return Page | Page of entity + * @see Pageable + */ + Page findAll(Pageable pageable); + + /** + * Find All with pagination and sort + * + * @param sort Sort + * @return List | Collection of entity that sorted + * @see Sort + */ + List findAll(Sort sort); +} diff --git a/src/main/java/com/cubetiqs/data/service/PagingCrudServiceImpl.java b/src/main/java/com/cubetiqs/data/service/PagingCrudServiceImpl.java new file mode 100644 index 0000000..b86a8b2 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/service/PagingCrudServiceImpl.java @@ -0,0 +1,29 @@ +package com.cubetiqs.data.service; + +import org.springframework.data.domain.Page; +import org.springframework.data.domain.Pageable; +import org.springframework.data.domain.Sort; + +import java.util.List; + +/** + * Paging Crud Service Impl + * + * @author sombochea + * @see CrudService + * @see PagingCrudService + * @see CrudServiceImpl + * @since 1.0 + */ +@NoServiceBean +public class PagingCrudServiceImpl extends CrudServiceImpl implements PagingCrudService { + @Override + public Page findAll(Pageable pageable) { + return getRepository().findAll(pageable); + } + + @Override + public List findAll(Sort sort) { + return getRepository().findAll(sort); + } +} diff --git a/src/main/java/com/cubetiqs/data/service/ServiceNotImplementException.java b/src/main/java/com/cubetiqs/data/service/ServiceNotImplementException.java new file mode 100644 index 0000000..ef4c252 --- /dev/null +++ b/src/main/java/com/cubetiqs/data/service/ServiceNotImplementException.java @@ -0,0 +1,29 @@ +package com.cubetiqs.data.service; + +/** + * Service not implement exception + * + * @author sombochea + * @see RuntimeException + * @since 1.0 + */ +public class ServiceNotImplementException extends RuntimeException { + public ServiceNotImplementException() { + } + + public ServiceNotImplementException(String message) { + super(message); + } + + public ServiceNotImplementException(String message, Throwable cause) { + super(message, cause); + } + + public ServiceNotImplementException(Throwable cause) { + super(cause); + } + + public ServiceNotImplementException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) { + super(message, cause, enableSuppression, writableStackTrace); + } +}