diff --git a/pom.xml b/pom.xml index f2dbc0637..bc63b157e 100644 --- a/pom.xml +++ b/pom.xml @@ -20,6 +20,16 @@ + + mysql + mysql-connector-java + 8.0.33 + + + org.hibernate.orm + hibernate-core + 6.4.4.Final + org.apache.commons commons-lang3 diff --git a/src/main/java/mate/academy/Main.java b/src/main/java/mate/academy/Main.java index 0058fbf96..1feaef6e3 100644 --- a/src/main/java/mate/academy/Main.java +++ b/src/main/java/mate/academy/Main.java @@ -1,7 +1,18 @@ package mate.academy; +import mate.academy.lib.Injector; +import mate.academy.model.Movie; +import mate.academy.service.MovieService; + public class Main { public static void main(String[] args) { + MovieService movieService = (MovieService) Injector.getInstance(MovieService.class); + Movie movie = new Movie(); + movie.setTitle("Harry Potter"); + movie.setDescription("Nice Movie"); + Movie saveMovie = movieService.add(movie); + Movie getMovie = movieService.get(1L); + System.out.println(getMovie); } } diff --git a/src/main/java/mate/academy/dao/MovieDao.java b/src/main/java/mate/academy/dao/MovieDao.java new file mode 100644 index 000000000..c513a613e --- /dev/null +++ b/src/main/java/mate/academy/dao/MovieDao.java @@ -0,0 +1,12 @@ +package mate.academy.dao; + +import java.util.Optional; +import mate.academy.lib.Dao; +import mate.academy.model.Movie; + +@Dao +public interface MovieDao { + Movie add(Movie movie); + + Optional get(Long id); +} diff --git a/src/main/java/mate/academy/dao/impl/MovieDaoImpl.java b/src/main/java/mate/academy/dao/impl/MovieDaoImpl.java new file mode 100644 index 000000000..df9c4ce6d --- /dev/null +++ b/src/main/java/mate/academy/dao/impl/MovieDaoImpl.java @@ -0,0 +1,52 @@ +package mate.academy.dao.impl; + +import java.util.Optional; +import mate.academy.dao.MovieDao; +import mate.academy.exeption.DataProcessingException; +import mate.academy.lib.Dao; +import mate.academy.model.Movie; +import mate.academy.util.HibernateUtil; +import org.hibernate.Session; +import org.hibernate.Transaction; + +@Dao +public class MovieDaoImpl implements MovieDao { + + @Override + public Movie add(Movie movie) { + Session session = null; + Transaction transaction = null; + try { + session = HibernateUtil.getSessionFactory().openSession(); + transaction = session.beginTransaction(); + session.save(movie); + transaction.commit(); + return movie; + } catch (Exception e) { + if (transaction != null) { + transaction.rollback(); + } + throw new DataProcessingException("Can't add movie: " + movie); + } finally { + if (session != null) { + session.close(); + } + } + } + + @Override + public Optional get(Long id) { + Session session = null; + try { + session = HibernateUtil.getSessionFactory().openSession(); + session.get(Movie.class, id); + return Optional.ofNullable(session.get(Movie.class, id)); + } catch (Exception e) { + throw new DataProcessingException("Can't get movie by id : " + id); + } finally { + if (session != null) { + session.close(); + } + } + } +} diff --git a/src/main/java/mate/academy/exeption/DataProcessingException.java b/src/main/java/mate/academy/exeption/DataProcessingException.java new file mode 100644 index 000000000..209046c68 --- /dev/null +++ b/src/main/java/mate/academy/exeption/DataProcessingException.java @@ -0,0 +1,7 @@ +package mate.academy.exeption; + +public class DataProcessingException extends RuntimeException { + public DataProcessingException(String message) { + super(message); + } +} diff --git a/src/main/java/mate/academy/lib/Dao.java b/src/main/java/mate/academy/lib/Dao.java index f558d09aa..6c89c7098 100644 --- a/src/main/java/mate/academy/lib/Dao.java +++ b/src/main/java/mate/academy/lib/Dao.java @@ -1,8 +1,11 @@ package mate.academy.lib; +import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; +@Target(ElementType.TYPE) @Retention(RetentionPolicy.RUNTIME) public @interface Dao { } diff --git a/src/main/java/mate/academy/lib/Inject.java b/src/main/java/mate/academy/lib/Inject.java index dfd2a0486..b6684e85c 100644 --- a/src/main/java/mate/academy/lib/Inject.java +++ b/src/main/java/mate/academy/lib/Inject.java @@ -1,8 +1,11 @@ package mate.academy.lib; +import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; +@Target(ElementType.TYPE) @Retention(RetentionPolicy.RUNTIME) public @interface Inject { } diff --git a/src/main/java/mate/academy/lib/Injector.java b/src/main/java/mate/academy/lib/Injector.java index c5008b336..827d32aeb 100644 --- a/src/main/java/mate/academy/lib/Injector.java +++ b/src/main/java/mate/academy/lib/Injector.java @@ -13,8 +13,8 @@ public class Injector { private static final Map injectors = new HashMap<>(); - private final Map, Object> instanceOfClasses = new HashMap<>(); - private final List> classes = new ArrayList<>(); + private static final Map, Object> instanceOfClasses = new HashMap<>(); + private static final List> classes = new ArrayList<>(); private Injector(String mainPackageName) { try { @@ -33,7 +33,7 @@ public static Injector getInstance(String mainPackageName) { return injector; } - public Object getInstance(Class certainInterface) { + public static Object getInstance(Class certainInterface) { Object newInstanceOfClass = null; Class clazz = findClassExtendingInterface(certainInterface); Object instanceOfCurrentClass = createInstance(clazz); @@ -57,7 +57,7 @@ public Object getInstance(Class certainInterface) { return newInstanceOfClass; } - private Class findClassExtendingInterface(Class certainInterface) { + private static Class findClassExtendingInterface(Class certainInterface) { for (Class clazz : classes) { Class[] interfaces = clazz.getInterfaces(); for (Class singleInterface : interfaces) { @@ -73,7 +73,7 @@ private Class findClassExtendingInterface(Class certainInterface) { + " interface and has valid annotation (Dao or Service)"); } - private Object getNewInstance(Class certainClass) { + private static Object getNewInstance(Class certainClass) { if (instanceOfClasses.containsKey(certainClass)) { return instanceOfClasses.get(certainClass); } @@ -82,7 +82,7 @@ private Object getNewInstance(Class certainClass) { return newInstance; } - private boolean isFieldInitialized(Field field, Object instance) { + private static boolean isFieldInitialized(Field field, Object instance) { field.setAccessible(true); try { return field.get(instance) != null; @@ -91,7 +91,7 @@ private boolean isFieldInitialized(Field field, Object instance) { } } - private Object createInstance(Class clazz) { + private static Object createInstance(Class clazz) { Object newInstance; try { Constructor classConstructor = clazz.getConstructor(); @@ -102,7 +102,7 @@ private Object createInstance(Class clazz) { return newInstance; } - private void setValueToField(Field field, Object instanceOfClass, Object classToInject) { + private static void setValueToField(Field field, Object instanceOfClass, Object classToInject) { try { field.setAccessible(true); field.set(instanceOfClass, classToInject); diff --git a/src/main/java/mate/academy/lib/Service.java b/src/main/java/mate/academy/lib/Service.java index 94010448d..7348180d2 100644 --- a/src/main/java/mate/academy/lib/Service.java +++ b/src/main/java/mate/academy/lib/Service.java @@ -1,8 +1,11 @@ package mate.academy.lib; +import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; +@Target(ElementType.TYPE) @Retention(RetentionPolicy.RUNTIME) public @interface Service { } diff --git a/src/main/java/mate/academy/model/Movie.java b/src/main/java/mate/academy/model/Movie.java new file mode 100644 index 000000000..b0ff07548 --- /dev/null +++ b/src/main/java/mate/academy/model/Movie.java @@ -0,0 +1,42 @@ +package mate.academy.model; + +import jakarta.persistence.Entity; +import jakarta.persistence.GeneratedValue; +import jakarta.persistence.GenerationType; +import jakarta.persistence.Id; +import mate.academy.lib.Inject; + +@Entity +@Inject +public class Movie { + @Id + @GeneratedValue(strategy = GenerationType.IDENTITY) + private long id; + private String title; + private String description; + + public long getId() { + return id; + } + + public void setId(long id) { + this.id = id; + } + + public String getTitle() { + return title; + } + + public void setTitle(String title) { + this.title = title; + } + + public String getDescription() { + return description; + } + + public void setDescription(String description) { + this.description = description; + } + +} diff --git a/src/main/java/mate/academy/service/MovieService.java b/src/main/java/mate/academy/service/MovieService.java new file mode 100644 index 000000000..128713d60 --- /dev/null +++ b/src/main/java/mate/academy/service/MovieService.java @@ -0,0 +1,11 @@ +package mate.academy.service; + +import mate.academy.lib.Service; +import mate.academy.model.Movie; + +@Service +public interface MovieService { + Movie add(Movie movie); + + Movie get(Long id); +} diff --git a/src/main/java/mate/academy/service/imlp/MovieServiceImpl.java b/src/main/java/mate/academy/service/imlp/MovieServiceImpl.java new file mode 100644 index 000000000..564a3fb18 --- /dev/null +++ b/src/main/java/mate/academy/service/imlp/MovieServiceImpl.java @@ -0,0 +1,22 @@ +package mate.academy.service.imlp; + +import mate.academy.dao.MovieDao; +import mate.academy.lib.Injector; +import mate.academy.lib.Service; +import mate.academy.model.Movie; +import mate.academy.service.MovieService; + +@Service +public class MovieServiceImpl implements MovieService { + private MovieDao movieDao = (MovieDao) Injector.getInstance(MovieDao.class); + + @Override + public Movie add(Movie movie) { + return movieDao.add(movie); + } + + @Override + public Movie get(Long id) { + return movieDao.get(id).orElse(null); + } +} diff --git a/src/main/java/mate/academy/util/HibernateUtil.java b/src/main/java/mate/academy/util/HibernateUtil.java new file mode 100644 index 000000000..7c8c9a440 --- /dev/null +++ b/src/main/java/mate/academy/util/HibernateUtil.java @@ -0,0 +1,19 @@ +package mate.academy.util; + +import org.hibernate.SessionFactory; +import org.hibernate.cfg.Configuration; + +public class HibernateUtil { + private static SessionFactory instance = getSessionFactory(); + + private HibernateUtil() { + } + + public static SessionFactory initSessionFactory() { + return new Configuration().configure().buildSessionFactory(); + } + + public static SessionFactory getSessionFactory() { + return instance; + } +} diff --git a/src/main/resources/hibernate.cfg.xml b/src/main/resources/hibernate.cfg.xml new file mode 100644 index 000000000..cb6b87090 --- /dev/null +++ b/src/main/resources/hibernate.cfg.xml @@ -0,0 +1,18 @@ + + + + + + org.hibernate.dialect.MySQL8Dialect + jdbc:mysql://localhost:3306 + com.mysql.cj.jdbc.Driver + root + qwerty123 + true + update + + + + \ No newline at end of file diff --git a/src/test/resources/hibernate.cfg.xml b/src/test/resources/hibernate.cfg.xml index b8ff2c8c1..7982d7a8c 100644 --- a/src/test/resources/hibernate.cfg.xml +++ b/src/test/resources/hibernate.cfg.xml @@ -1,10 +1,13 @@ + jdbc:mysql://localhost:3306 org.hsqldb.jdbcDriver - jdbc:hsqldb:mem - sa - + root + qwerty123 org.hibernate.dialect.HSQLDialect true + create-drop + +