不支持DML操作。使用Spring Data无法更新PostgreSQL数据库中的数据。

3

你好,我正在使用Spring Boot和Spring Data。我想根据id从数据库中获取数据,但我无法检索到它。

我得到了这个错误 "exception": "org.springframework.dao.InvalidDataAccessApiUsageException","message":"org.hibernate.hql.internal.QueryExecutionRequestException: Not supported for DML operations [Update com.ge.health.poc.model.SpringModel SET name='sneha' where id=?]; nested exception is java.lang.IllegalStateException: org.hibernate.hql.internal.QueryExecutionRequestException: Not supported for DML operations [Update com.ge.health.poc.model.SpringModel SET name='sneha' where id=?]","path":"/updatedata"}

主类:

  package com.ge.health.poc;

  import org.springframework.boot.SpringApplication;
  import org.springframework.boot.autoconfigure.SpringBootApplication;

  @SpringBootApplication
  public class SpringDataApplication {

     public static void main(String[] args) {
         SpringApplication.run(SpringDataApplication.class, args);
     }
  }

控制器类

    package com.ge.health.poc.controller;

    import java.io.IOException;
    import java.text.ParseException;

    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestBody;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.ResponseBody;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.servlet.mvc.support.RedirectAttributes;

    import com.fasterxml.jackson.core.JsonParseException;
    import com.fasterxml.jackson.databind.JsonMappingException;
    import com.fasterxml.jackson.databind.ObjectMapper;
    import com.ge.health.poc.model.SpringModel;
    import com.ge.health.poc.service.BookServiceImpl;

    @RestController
    public class SpringController {

        @Autowired
        BookServiceImpl bookserviceimpl;

        @RequestMapping(value = "/insertdata", method = RequestMethod.POST)
        @ResponseBody
        public void helloService(@RequestBody String input, final RedirectAttributes redirectAttributes)
                throws JsonParseException, JsonMappingException, IOException, ParseException {

            System.out.println(input);
            ObjectMapper mapper = new ObjectMapper();
            SpringModel pojodata = mapper.readValue(input, SpringModel.class);
            System.out.println(pojodata);
            System.out.println(pojodata.getAuthor());
            bookserviceimpl.save(pojodata);
        }

        @RequestMapping(value = "/getdata/{id}")
        @ResponseBody
        public void retreiveData(@PathVariable("id") int id)
                throws JsonParseException, JsonMappingException, IOException, ParseException {

            System.out.println("id is:" + id);
            bookserviceimpl.retreive(id);

        }

        @RequestMapping(value = "/deletedata", method = RequestMethod.DELETE)
        @ResponseBody
        public void deleteData(@RequestBody String id)
                throws JsonParseException, JsonMappingException, IOException, ParseException {

            System.out.println("M in delete");
            System.out.println(id);

            ObjectMapper mapper = new ObjectMapper();
            SpringModel pojodata = mapper.readValue(id, SpringModel.class);
            int idd = (pojodata.getId());
            System.out.println("value oof idd is:" + idd);
            System.out.println("M into delete method");

            bookserviceimpl.delete(idd);

        }

        @RequestMapping(value = "/updatedata", method = RequestMethod.PUT)
        @ResponseBody
        public void updateData(@RequestBody String id)
                throws JsonParseException, JsonMappingException, IOException, ParseException {

            System.out.println("M in update");
            System.out.println(id);

            ObjectMapper mapper = new ObjectMapper();
            SpringModel pojodata = mapper.readValue(id, SpringModel.class);
            int idd = (pojodata.getId());
            System.out.println("value oof idd is:" + idd);
            bookserviceimpl.update(idd);
        }

    }

仓库

    package com.ge.health.poc.interfac;

    import org.springframework.data.jpa.repository.JpaRepository;
    import org.springframework.data.jpa.repository.Query;
    import org.springframework.stereotype.Repository;
    import org.springframework.transaction.annotation.Transactional;

    import com.ge.health.poc.model.SpringModel;

    @Repository
    @Transactional
    public interface BookRepository extends JpaRepository<SpringModel, Long> {

        @Query("select author from SpringModel where id=?")
        String findName(int id);

        @Query("Update SpringModel SET name='sneha' where id=?")
        String UpdateByID(int id);

        @Query("delete from SpringModel where id=?")
        String deleteById(int id);

    }

BookServiceImpl.java

    package com.ge.health.poc.service;

    import javax.persistence.EntityManager;

    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;

    import com.ge.health.poc.interfac.BookRepository;
    import com.ge.health.poc.model.SpringModel;

    @Component
    public class BookServiceImpl implements BookService {

        @Autowired
        EntityManager entitymanager;

        @Autowired
        BookRepository bookrepo;

        @Override
        public void save(SpringModel bookdata) {

            bookrepo.save(bookdata);
        }

        public String retreive(int id) {
            String s = bookrepo.findName(id);
            System.out.println("Author name is:" + s);
            return null;

        }

        public void delete(int id) {

            System.out.println("M into service delete method");
            bookrepo.deleteById(id);
        }

        public void update(int id) {

            System.out.println("M in service update");
            bookrepo.UpdateByID(id);

        }

    }

这是模型类。
            package com.ge.health.poc.model;

            import javax.persistence.Column;
            import javax.persistence.Entity;
            import javax.persistence.Id;
            import javax.persistence.Table;

            @Entity
            @Table(name = "spring_model")
            public class SpringModel {

                @Id
                private Long id;

                @Column
                private String name;

                public Long getId() {
                    return id;
                }

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

                @Column
                private String isbn;

                @Override
                public String toString() {
                    return "SpringModel [id=" + id + ", name=" + name + ", isbn=" + isbn + ", author=" + author + ", pages=" + pages
                            + "]";
                }

                @Column
                private String author;

                @Column
                private String pages;

                public String getName() {
                    return name;
                }

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

                public String getIsbn() {
                    return isbn;
                }

                public void setIsbn(String isbn) {
                    this.isbn = isbn;
                }

                public String getAuthor() {
                    return author;
                }

                public void setAuthor(String author) {
                    this.author = author;
                }

                public String getPages() {
                    return pages;
                }

                public void setPages(String pages) {
                    this.pages = pages;
                }
            }
2个回答

10

尝试在仓库方法上使用注释@Modifying(org.springframework.data.jpa.repository.Modifying)和在执行DML操作的服务实现中使用注释@Transactional(org.springframework.transaction.annotation.Transactional)。 有关更多信息,请参见此答案


1
我已经在删除查询上添加了修改注释。它仍然抛出相同的错误。 - Nikhil Sahu
@NikhilSahu,您的服务实现可能缺少事务处理,请参考此答案:https://dev59.com/quk5XIcBkEYKwwoY_Ox3#47066201 - tk_

1
默认情况下,Spring JPA会认为查询是选择查询。因此,要确保查询更新特定实体的现有行,请在更新现有行的方法上添加@modifying注释。这可能适用于您。

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接