您好,登录后才能下订单哦!
这篇文章给大家分享的是有关spring-data-jpa怎么使用自定义repository来实现原生sql的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。
Spring Data JPA中的Repository是接口,是JPA根据方法名帮我们自动生成的。但很多时候,我们需要为Repository提供一些自定义的实现。今天我们看看如何为Repository添加自定义的方法。
首先我们来添加一个自定义的接口:
添加BaseRepository接口
BaseRepository继承了JpaRepository,这样可以保证所有Repository都有jpa提供的基本方法。
在BaseRepository上添加@NoRepositoryBean标注,这样Spring Data Jpa在启动时就不会去实例化BaseRepository这个接口
/** * Created by liangkun on 2016/12/7. */ @NoRepositoryBean public interface BaseRepository<T,ID extends Serializable> extends JpaRepository<T,ID> { //sql原生查询 List<Map<String, Object>> listBySQL(String sql); }
接下来实现BaseRepository接口,并继承SimpleJpaRepository类,使其拥有Jpa Repository的提供的方法实现。
/** * Created by liangkun on 2017/12/7. */ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRepository<T,ID> implements BaseRepository<T,ID> { private final EntityManager entityManager; //父类没有不带参数的构造方法,这里手动构造父类 public BaseRepositoryImpl(Class<T> domainClass, EntityManager entityManager) { super(domainClass, entityManager); this.entityManager = entityManager; } //通过EntityManager来完成查询 @Override public List<Map<String, Object>> listBySQL(String sql) { return entityManager.createNativeQuery(sql).getResultList(); } }
这里着重说下EntityManager
EntityManager是JPA中用于增删改查的接口,它的作用相当于一座桥梁,连接内存中的java对象和数据库的数据存储。也可以根据他进行sql的原生查找。
源码如下:
public interface EntityManager { <T> T find(Class<T> var1, Object var2); Query createNativeQuery(String var1); Query createNativeQuery(String var1, Class var2); Query createNativeQuery(String var1, String var2); }
由上可以看出其有具体的原生查询实现接口 createNativeQuery
接下来需要将我们自定义的Repository接口,通过工厂模式添加到Spring的容器中:
接下来我们来创建一个自定义的RepositoryFactoryBean来代替默认的RepositoryFactoryBean。RepositoryFactoryBean负责返回一个RepositoryFactory,Spring Data Jpa 将使用RepositoryFactory来创建Repository具体实现。
查看JpaRepositoryFactoryBean的源码,通过createRepositoryFactory返回JpaRepositoryFactory实例:
public class JpaRepositoryFactoryBean<T extends Repository<S, ID>, S, ID extends Serializable> extends TransactionalRepositoryFactoryBeanSupport<T, S, ID> { private EntityManager entityManager; public JpaRepositoryFactoryBean(Class<? extends T> repositoryInterface) { super(repositoryInterface); } @PersistenceContext public void setEntityManager(EntityManager entityManager) { this.entityManager = entityManager; } @Override public void setMappingContext(MappingContext<?, ?> mappingContext) { super.setMappingContext(mappingContext); } @Override protected RepositoryFactorySupport doCreateRepositoryFactory() { return createRepositoryFactory(entityManager); } protected RepositoryFactorySupport createRepositoryFactory(EntityManager entityManager) { return new JpaRepositoryFactory(entityManager); } @Override public void afterPropertiesSet() { Assert.notNull(entityManager, "EntityManager must not be null!"); super.afterPropertiesSet(); } }
终上我们可根据相应的规则进行创建自定义RepositoryFactoryBean
/** * Created by liangkun on 2018/07/20. */ public class BaseRepositoryFactoryBean<R extends JpaRepository<T, I>, T, I extends Serializable> extends JpaRepositoryFactoryBean<R, T, I> { public BaseRepositoryFactoryBean(Class<? extends R> repositoryInterface) { super(repositoryInterface); } @Override protected RepositoryFactorySupport createRepositoryFactory(EntityManager em) { return new BaseRepositoryFactory(em); } //创建一个内部类,该类不用在外部访问 private static class BaseRepositoryFactory<T, I extends Serializable> extends JpaRepositoryFactory { private final EntityManager em; public BaseRepositoryFactory(EntityManager em) { super(em); this.em = em; } //设置具体的实现类是BaseRepositoryImpl @Override protected Object getTargetRepository(RepositoryInformation information) { return new BaseRepositoryImpl<T, I>((Class<T>) information.getDomainType(), em); } //设置具体的实现类的class @Override protected Class<?> getRepositoryBaseClass(RepositoryMetadata metadata) { return BaseRepositoryImpl.class; } } }
自定义完成。
一些比较复杂的关联查询要怎么实现呢,JPA的处理方法是:利用原生的SQL命令来实现那些复杂的关联查询,通过设置nativeQuery = true 来设置开启使用数据库原生SQL语句。下面就在上一个案例的基础上实现原生sql的增删改查,代码如下。
//利用原生的SQL进行查询操作 @Query(value = "select s.* from studenttb s where s.student_name=?1", nativeQuery = true) public List<Student> findStudentByName(String name); //利用原生的SQL进行删除操作 @Query(value = "delete from studenttb where student_id=?1 ", nativeQuery = true) @Modifying @Transactional public int deleteStudentById(int uid); //利用原生的SQL进行修改操作 @Query(value = "update studenttb set student_name=?1 where student_id=?2 ", nativeQuery = true) @Modifying @Transactional public int updateStudentName(String name,int id); //利用原生的SQL进行插入操作 @Query(value = "insert into studenttb(student_name,student_age) value(?1,?2)", nativeQuery = true) @Modifying @Transactional public int insertStudent(String name,int age); @Query(value=" SELECT * FROM studenttb WHERE STUDENT_NAME LIKE %:name% ",nativeQuery=true) List<Student> queryBynameSQL(@Param(value = "name") String name);
代码如下:
//原生sql的调用 /*** * http://localhost:8090/findStudentByName?name=刘一 * @param name * @return */ @RequestMapping("/findStudentByName") public Object findStuByName(String name) { List<Student> student = repository.findStudentByName(name); return student; } /*** * http://localhost:8090/deleteStudentById?id=刘 * @param name * @return */ @RequestMapping("/deleteStudentById") public Object deleteStudentById(int id) { int i = repository.deleteStudentById(id); Map<String,Object> map=new HashMap<String,Object>(); if(i>0) { map.put("success", true); } else { map.put("success", false); } return map; } /*** * http://localhost:8090/updateStudentName?name=Tom&id=1 * @param name * @return */ @RequestMapping("/updateStudentName") public Object updateStudentName(String name,int id) { int i = repository.updateStudentName(name,id); Map<String,Object> map=new HashMap<String,Object>(); if(i>0) { map.put("success", true); } else { map.put("success", false); } return map; } /*** * http://localhost:8090/insertStudent?name=xiao&age=18 * @param name * @return */ @RequestMapping("/insertStudent") public Object insertStudent(String name,int age) { int i = repository.insertStudent(name,age); Map<String,Object> map=new HashMap<String,Object>(); if(i>0) { map.put("success", true); } else { map.put("success", false); } return map; } /*** * http://localhost:8090/queryBynameSQL?name=刘 * @param name * @return */ @RequestMapping("/queryBynameSQL") public Object queryBynameSQL(String name) { List<Student> student= repository.queryBynameSQL(name); return student; }
运行效果请各位自行测试。
感谢各位的阅读!关于“spring-data-jpa怎么使用自定义repository来实现原生sql”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。