JPA学习（四点五）抽象baseDao方法，减少代码量

清疚 2023-06-08 04:53 1阅读 0赞

基于前一章的问题，cat和dog的Dao层实现类方法几乎一致的，

所以可以抽象一个basedao的实现类,来满足减少代码的问题

大概流程如下:

# 1.创建IBaseDao接口 #

1.新建一个接口叫IBaseDao

public interface IBaseDao<T> { //通过泛型 来处理类
        void save(T t);
    
        void update(T t);
    
        void delete(Long id);
    
        Cat findOne(Long id);
    
        List<T> findAll();
    }

通过泛型处理，来保证具体调用的时候都可以使用通用的方法。

2.创建cat和dog的接口，继承IBaseDao接口

public interface ICatDao extends IBaseDao<Cat> {
    }

public interface IDogDao extends IBaseDao<Dog> {
    }

为什么创建两个接口呢  我觉得是因为如果遇到以后需要添加的比较特殊的方法 比如只针对cat 或者dog 就可以在这上面写了。

# 2.创建BaseDaoImpl实现类 #

这个类就是具体实现增删改查的功能的。

代码如下：

public class BaseDaoImpl<T> implements IBaseDao<T> {
    
        private Class<T> entityClass;
    
        public BaseDaoImpl(Class<T> entityClass) {  //使用构造函数 让具体的实现类能够将domain的类传递进来
            super();
            this.entityClass = entityClass;
        }
    
        public void save(T t) {  //插入
            EntityManager entityManager = JPAUtil.getEntityManager();
            entityManager.getTransaction().begin();
            entityManager.persist(t);
            entityManager.getTransaction().commit();
            entityManager.close();
        }
    
        public void update(T t) { //更新
            EntityManager entityManager = JPAUtil.getEntityManager();
            entityManager.getTransaction().begin();
            entityManager.merge(t);
            entityManager.getTransaction().commit();
            entityManager.close();
    
        }
    
        public void delete(Long id) {  //删除
            EntityManager entityManager = JPAUtil.getEntityManager();
            entityManager.getTransaction().begin();
            T deleteT = entityManager.find(entityClass, id); //注意使用的类是构造传递过来的类
            entityManager.remove(deleteT);
    
            entityManager.getTransaction().commit();
            entityManager.close();
        }
    
        public T findOne(Long id) {
            EntityManager entityManager = JPAUtil.getEntityManager();
            T t = entityManager.find(entityClass, 1L);
            if (t != null) {
                return t;
            }
            return null;
        }
    
        public List<T> findAll() {
            String jpql = new StringBuilder("SELECT st").append(" FROM ").append(entityClass.getName()).append(" st").toString(); //数据组装的时候获得类名称
            EntityManager entityManager = JPAUtil.getEntityManager();
            Query query = entityManager.createQuery(jpql);
            List<T> lists = query.getResultList();
            return lists;
        }
    }

1.接着写关于cat的具体dao层实现类，继承baseDaoImpl类和实现对应的IDao方法

public class CatDaoImpl extends BaseDaoImpl<Cat> implements ICatDao {
    
        public CatDaoImpl() {
            super(Cat.class);  //使用父类的构造方法，将对应的domian 这里是cat的类信息存入
        }
    
    }

2.接着写关于dog的具体dao层实现类，继承baseDaoImpl类和实现对应的IDao方法

public class DogDaoImpl extends BaseDaoImpl<Dog> implements IDogDao {
    
        public DogDaoImpl() {
            super(Dog.class);
        }
    
    }

# 3.测试 #

1.编写两个domian 的测试方法

第一个是cat的（dog的和cat的测试方法一致 我就不写了）

public class CatDaoTest {
    
        @Before
        public void catSaveTest() throws IllegalAccessException, InstantiationException {
            IBaseDao iBaseDao = new CatDaoImpl();
            Cat cat = Cat.class.newInstance();
            cat.setCatName("tianyuanmao");
            iBaseDao.save(cat);
        }
    
        @Test
        public void catFindOneTest() {
            IBaseDao iBaseDao = new CatDaoImpl();
            Object o = iBaseDao.findOne(1L);
            if (o != null || o instanceof Cat) {
                Cat cat = (Cat) o;
                System.out.println(cat.toString());
            }
        }
    
        @Test
        public void catUpdateTest() {
            IBaseDao iBaseDao = new CatDaoImpl();
            Object o = iBaseDao.findOne(1L);
            if (o != null || o instanceof Cat) {
                Cat cat = (Cat) o;
                System.out.println(cat.toString());
                cat.setCatName("lieluomao");
                iBaseDao.update(cat);
            }
        }
    
        @Test
        public void catDeleteTest() {
            IBaseDao iBaseDao = new CatDaoImpl();
            iBaseDao.delete(1L);
        }
    
        @Test
        public void catListTest() {
            IBaseDao iBaseDao = new CatDaoImpl();
            System.out.println(iBaseDao.findAll().size());
        }
    
    
    }

试试测试方法。

saveTest()和catFindOneTest()

![20191016164537307.png][]这是插入进去的。

![20191016164605406.png][]这是查询到的数据

catUpdateTest()方法

![20191016164742860.png][]执行插入后的数据

然后走到update方法

![20191016164812431.png][]后台显示了更新语句，也在数据库更新了![20191016164859332.png][]

catDeleteTest()方法

![20191016164742860.png][]执行删除的数据

![20191016165013653.png][]，数据库也没了![20191016165030653.png][]

catListTest()

![20191016164742860.png][]后添加一些数据进去。

![20191016165247970.png][]一共8条数据

执行查询所有的列

![20191016165317729.png][]后台显示查询到了8条 说明没问题

测试完毕，，，，，，，，，，，，

**本章主要记录的是在baseDaoImpl中关于类名的使用方法**

**在执行构造函数的时候需要将domain类带入，并且在jpql语句注意类名称。**

以上。

[20191016164537307.png]: /images/20230531/8a15fe1565a943d987eab75df7c64a38.png
[20191016164605406.png]: /images/20230531/9d9634192b194a9eba5c94378f165e66.png
[20191016164742860.png]: /images/20230531/e273df428c5a4c2abd67f6defa498eb9.png
[20191016164812431.png]: https://img-blog.csdnimg.cn/20191016164812431.png
[20191016164859332.png]: /images/20230531/aee4be4f149d42e3ae5d921ca9d44d7a.png
[20191016165013653.png]: https://img-blog.csdnimg.cn/20191016165013653.png
[20191016165030653.png]: /images/20230531/a85663bb88c34638b7aa65b6a8b99354.png
[20191016165247970.png]: /images/20230531/8e470a7da9184eec966cbf1497a1aa88.png
[20191016165317729.png]: /images/20230531/63f27fbfa2e24e12a7b0f534c37479ca.png