JPA学习（四）创建接口和实现类实现对数据的增删改查

清疚 2023-06-08 04:48 2阅读 0赞

配置文件还是和第一章的一样，没怎么变，用的策略是create的

**目录**

1.创建接口以及方法

2.每个对应的dao层的实现类实现接口的方法

3.测试

--------------------

大概流程是这样的：

# 1.创建接口以及方法 #

创建接口之前先将domian实现了。 实现了两个类 cat 和dog

1.cat类

@Entity
    @Table(name = "t_cat")
    public class Cat {
    
        @Id
        @GeneratedValue(strategy = GenerationType.IDENTITY)
        private Long id;
    
        @Column(name = "t_catname",length = 20)
        private String catName;
    
        public Long getId() {
            return id;
        }
    
        public void setId(Long id) {
            this.id = id;
        }
    
        public String getCatName() {
            return catName;
        }
    
        public void setCatName(String catName) {
            this.catName = catName;
        }
    
        @Override
        public String toString() {
            return "Cat{" +
                    "id=" + id +
                    ", catName='" + catName + '\'' +
                    '}';
        }
    }

2.dog的代码：

@Entity
    @Table(name = "t_dog")
    public class Dog {
    
        @Id
        @GeneratedValue(strategy = GenerationType.IDENTITY)
        private Long did;
    
        @Column(name = "t_dogname", length = 20)
        private String dogName;
    
        public Long getDid() {
            return did;
        }
    
        public void setDid(Long did) {
            this.did = did;
        }
    
        public String getDogName() {
            return dogName;
        }
    
        public void setDogName(String dogName) {
            this.dogName = dogName;
        }
    
        @Override
        public String toString() {
            return "Dog{" +
                    "did=" + did +
                    ", dogName='" + dogName + '\'' +
                    '}';
        }
    }

接着创建接口：

catDao的接口：

public interface ICatDao {
        void save(Cat cat);
    
        void update(Cat cat);
    
        void delete(Long id);
    
        Cat findOne(Long id);
    
        List<Cat> findAll();
    
    }

dogDao的接口

public interface IDogDao {
        void save(Dog dog);
    
        void update(Dog dog);
    
        void delete(Long id);
    
        Dog findOne(Long id);
    
        List<Dog> findAll();
    
    }

以上的domain和接口就创好了 我是这么放的。

![20191016151900309.png][]![20191016153805497.png][]

# 2.每个对应的dao层的实现类实现接口的方法 #

接着在dao层的impl的包下创建cat和dog的实现方法

1.catDao的实现类

public class CatDaoImpl implements ICatDao {
    
        public void save(Cat cat) {
    
            EntityManager entityManager = JPAUtil.getEntityManager();
            entityManager.getTransaction().begin();
            entityManager.persist(cat);
            entityManager.getTransaction().commit();
            entityManager.close();
        }
    
        public void update(Cat cat) {
    
            EntityManager entityManager = JPAUtil.getEntityManager();
            entityManager.getTransaction().begin();
            entityManager.merge(cat);
            entityManager.getTransaction().commit();
            entityManager.close();
    
        }
    
        public void delete(Long id) {
            EntityManager entityManager = JPAUtil.getEntityManager();
            entityManager.getTransaction().begin();
            entityManager.remove(entityManager.find(Cat.class, id));
            entityManager.getTransaction().commit();
            entityManager.close();
        }
    
        public Cat findOne(Long id) {
            EntityManager entityManager = JPAUtil.getEntityManager();
            Cat cat = entityManager.find(Cat.class, id);
            if (cat != null) {
                return cat;
            }
            return null;
    
        }
    
        public List<Cat> findAll() {
            String jpql = "SELECT cat FROM Cat cat";
            EntityManager entityManager = JPAUtil.getEntityManager();
            Query query = entityManager.createQuery(jpql);
            List<Cat> resultList = query.getResultList();
            return resultList;
        }
    }

2.dogDao的实现类 和 catDao的实现类差不多。所以后期可以改进一下 将通用方法抽象出来

public class DogDaoImpl implements IDogDao {
    
        public void save(Dog dog) {
    
            EntityManager entityManager = JPAUtil.getEntityManager();
            entityManager.getTransaction().begin();
            entityManager.persist(dog);
            entityManager.getTransaction().commit();
            entityManager.close();
        }
    
        public void update(Dog dog) {
    
            EntityManager entityManager = JPAUtil.getEntityManager();
            entityManager.getTransaction().begin();
            entityManager.merge(dog);
            entityManager.getTransaction().commit();
            entityManager.close();
    
        }
    
        public void delete(Long id) {
            EntityManager entityManager = JPAUtil.getEntityManager();
            entityManager.getTransaction().begin();
            entityManager.remove(entityManager.find(Dog.class, id));
            entityManager.getTransaction().commit();
            entityManager.close();
        }
    
        public Dog findOne(Long id) {
            EntityManager entityManager = JPAUtil.getEntityManager();
            Dog dog = entityManager.find(Dog.class, id);
            if (dog != null) {
                return dog;
            }
            return null;
    
        }
    
        public List<Dog> findAll() {
            String jpql = "SELECT dog FROM Dog dog";
            EntityManager entityManager = JPAUtil.getEntityManager();
            Query query = entityManager.createQuery(jpql);
            List<Dog> resultList = query.getResultList();
            return resultList;
        }
    }

# 3.测试 #

1.创建CatDaoTest 将几个方法实现一下。

public class CatDaoTest {
    
        @Before
        public void catSaveTest() {
            ICatDao iCatDao = new CatDaoImpl();
            Cat cat = new Cat();
            cat.setCatName("cat1");
            iCatDao.save(cat); //存入数据 每次执行
        }
    
        @Test
        public void catFindOneTest() {
            ICatDao iCatDao = new CatDaoImpl();
            Cat cat = iCatDao.findOne(1L);
            System.out.println(cat.toString()); //查询id为1的数据
        }
    
        @Test
        public void catUpdateTest() {
            ICatDao iCatDao = new CatDaoImpl();
            Cat cat = iCatDao.findOne(1L);
            cat.setCatName("cat2222");
            iCatDao.update(cat);  //修改数据
        }
    
        @Test
        public void catDeleteTest() {
            ICatDao iCatDao = new CatDaoImpl();
            iCatDao.delete(1L);  //删除数据
        }
    
        @Test
        public void catListest() {
            ICatDao iCatDao = new CatDaoImpl();
            iCatDao.findAll(); //查询所有数据
        }
    
    
    }

第一个插入数据：

![20191016153555436.png][]，数据库已经插入进去了

第二个查询数据

![20191016153631760.png][]说明查询也是对的

第三个更新数据：

![2019101615372236.png][] 可以看到是修改成功的，后台也是显示了更新语句：

![20191016153744407.png][]

第四个 删除当前数据

![20191016153857640.png][]，后台数据sql语句,![20191016153913287.png][]

第五个 查询list的数量

我在后台先添加了几个：

![20191016154538983.png][]然后看看查询后显示的个数

![20191016154705778.png][]

说明查询方法也没问题。

2.创建DogDaoTest 将几个方法实现一下。

和CatDaoTest几乎一致的，就不写查询结果和代码了。

**但是这样有个问题 代码复用太高，除了传输的类不一样 其他几乎都是一样的，所以需要再一次将方法进行抽象。**

**放到下一个记录中**

[20191016151900309.png]: https://img-blog.csdnimg.cn/20191016151900309.png
[20191016153805497.png]: /images/20230531/7c2a5f3638954f6b868b351344353558.png
[20191016153555436.png]: /images/20230531/5875fb775bcd4e78ab55a6b13eed1212.png
[20191016153631760.png]: /images/20230531/ce1090d1d75141cdbb35deb3d214b8dd.png
[2019101615372236.png]: /images/20230531/9dd0542c8a7b4f7d86e425345d1a1736.png
[20191016153744407.png]: /images/20230531/9e55dd7deeef400d851bcbcce9910382.png
[20191016153857640.png]: https://img-blog.csdnimg.cn/20191016153857640.png
[20191016153913287.png]: /images/20230531/a4fecde2c0da4c66af00689cb8f71e16.png
[20191016154538983.png]: /images/20230531/3fb9591158d64304a1e6cb526700e6cb.png
[20191016154705778.png]: /images/20230531/58fd3db6c2c9443bbcfb7215573161e7.png