Невозможно получить вставку, обновление и удаление для работы с spring-data-jpa - PullRequest
Новая
       13

Невозможно получить вставку, обновление и удаление для работы с spring-data-jpa

0 голосов
/ 27 декабря 2018

Я пытаюсь создать веб-сервис, который выполняет основные операции CRUD, написанные с использованием весенней загрузки 2. Операция выбора работает нормально, однако операции вставки, удаления и обновления не имеют никакого эффекта, поскольку их запрос не генерируется и не выполняется.

Я просмотрел разные примеры, но не могу выяснить какие-либо проблемы.Основное беспокойство для меня вызывает тот факт, что даже запрос запускается для операций вставки, удаления или обновления.

Студенческая организация 

@Entity
@Table(name = "student")
@JsonIgnoreProperties({"hibernateLazyInitializer", "handler"})
public class Student {

@Id
@NotNull
@Column(name = "id")
private int id;

@NotNull
@Column(name = "name")
private String name;

@Column(name = "course")
private String course;

public Student(int id, String name, String course) {
    this.id = id;
    this.name = name;
    this.course = course;
}

public Student(){}

public int getId() {
    return id;
}

public void setId(int id) {
    this.id = id;
}

public String getName() {
    return name;
}

public void setName(String name) {
    this.name = name;
}

public String getCourse() {
    return course;
}

public void setCourse(String course) {
    this.course = course;
}

@Override
public String toString() {
    return "Student{ id=" + id + ", name='" + name + '\'' + ", course='" + course + '\'' + '}';
}
}

StudentDaoImpl 

@Repository
@Transactional
public class StudentDaoImpl implements StudentDao {

@Autowired
private EntityManagerFactory entityManagerFactory;

@Override
public List<Student> fetchAllStudents() {
    Session session = entityManagerFactory.unwrap(SessionFactory.class).openSession();
    CriteriaBuilder cb = session.getCriteriaBuilder();
    CriteriaQuery<Student> cq = cb.createQuery(Student.class);
    Root<Student> root = cq.from(Student.class);
    CriteriaQuery<Student> all = cq.select(root);
    List<Student> solution = session.createQuery(all).getResultList();
    session.close();
    return solution;
}

@Override
public Student deleteStudent(Integer id) {
    Session session = entityManagerFactory.unwrap(SessionFactory.class).openSession();
    Student student = session.load(Student.class, id);
    if (student != null){
        session.delete(student);
        session.close();
    }
    return student;
}

@Override
public Student fetchForId(Integer id){
    Session session = entityManagerFactory.unwrap(SessionFactory.class).openSession();
    Student student = session.load(Student.class, id);
    session.close();
    return student;
}

@Override
public Student insertStudent(Student student) {
    Session session = entityManagerFactory.unwrap(SessionFactory.class).openSession();
    session.save(student);
    session.close();
    return student;
}

@Override
public Student updateStudent(Student student) {
    Session session = entityManagerFactory.unwrap(SessionFactory.class).openSession();
    Student studentCheck = session.load(Student.class, student.getId());
    if (studentCheck != null) {
        session.saveOrUpdate(student);
        session.close();
    }
    return student;
}
}

application.properties 

spring.datasource.url=jdbc:mysql://localhost:3306/test
spring.datasource.username=root
spring.datasource.password=

spring.jpa.database = MYSQL
spring.jpa.show-sql = true

spring.jpa.hibernate.ddl-auto = update
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.jpa.hibernate.naming.physical-strategy=org.hibernate.boot.model.naming.PhysicalNamingStrategyStandardImpl

spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.MySQL5Dialect

Редактировать

Замена EntityManagerFactory на EntityManager (+ Постоянная контекстная аннотация) работала для меня.Однако я до сих пор не понял, почему постоянство сработало для EntityManager.

Ответы [ 2 ]

0 голосов
/ 28 декабря 2018

Я хотел бы предложить этот репозиторий 

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;


@Repository
public interface StudentRepository extends JpaRepository<Student, Integer> {

}

Возможно, вам нужно изменить идентификатор Студента с int на Integer.

И этот репозиторий имеет методы для извлечения, обновления,создание и удаление.

Допустим, вы хотите использовать этот репозиторий в Сервисе, вы можете сделать это следующим образом: 

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
@Transactional(rollbackFor = Exception.class)
public class StudentService {

    @Autowired
    private StudentRepository studentRepository;

    ......

}
0 голосов
/ 28 декабря 2018

Если это не совсем важно, вы можете сделать это, используя NativeQuery и его executeUpdate API: 

String query = "insert into student values(1,?)";

em.createNativeQuery(query)
   .setParameter(1, "Tom")
   .executeUpdate();
...