JPA原生SQL实现增删改查的示例详解

@Test
    public void getSingle() {
        EntityManager entityManager = JPAEntityFactory.getEntityManager();// 等同于 获取连接 
        String sql = "select cid, cname, credit, end, num, start " +
                "from yootk.course where cid = ?1";
        Query query = entityManager.createNativeQuery(sql); // 预处理sql
        query.setParameter(1, 1);
        Course course = (Course) query.getSingleResult();
        loggerFactory.info("【执行结果】：{}",course ); // 执行sql
        JPAEntityFactory.close();// 关闭连接
    }

@Test
public void getAllCourse() {
    EntityManager entityManager = JPAEntityFactory.getEntityManager();// 等同于 获取连接
    String sql = "select cid, cname, credit, end, num, start " +
            "from yootk.course ";
    Query query = entityManager.createNativeQuery(sql); // 预处理sql
    List list = query.getResultList();// 执行sql
    for (Object o : list) {
        loggerFactory.info("【执行结果】：{}", o);
    }
    JPAEntityFactory.close();// 关闭连接
}

@Test
    public void getAllCourseSplit() {
        int current = 2;
        int lineSize = 3;
        String keyWord = "%Spring%";
        EntityManager entityManager = JPAEntityFactory.getEntityManager();// 等同于 获取连接
        String sql = "select cid, cname, credit, end, num, start " +
                "from yootk.course where cname like :k1";
        Query query = entityManager.createNativeQuery(sql); // 预处理sql
        query.setFirstResult((current - 1) * lineSize); // 等同于 limit ?
        query.setMaxResults(lineSize); //  // 等同于 limit ?,?
        query.setParameter("k1", keyWord);
        List list = query.getResultList();// 执行sql
        for (Object o : list) {
            loggerFactory.info("【执行结果】：{}", o);
        }
        JPAEntityFactory.close();// 关闭连接

//  统计行数
    @Test
    public void getAllCourseCount() {
        String keyWord = "%Spring%";
        EntityManager entityManager = JPAEntityFactory.getEntityManager();// 等同于 获取连接
        String sql = "select count(*) from yootk.course where cname like :k1";
        Query query = entityManager.createNativeQuery(sql); // 预处理sql
        query.setParameter("k1", keyWord);
        loggerFactory.info("【执行结果】：{}", query.getSingleResult());// 执行sql
        JPAEntityFactory.close();// 关闭连接
    }

@Test
    public void getUpdateCourse() {
        // 例如:我们想把学分小于5的课程全部提高到5
        EntityManager entityManager = JPAEntityFactory.getEntityManager();// 等同于 获取连接
        //entityManager.getTransaction().begin(); // 开启事务
        String sql = "update yootk.course as c set c.credit = ?1 where c.credit <?2";
        Query query = entityManager.createNativeQuery(sql); // 预处理sql
        query.setParameter(1, 5);
        query.setParameter(2, 5);
        loggerFactory.info("【执行结果】：{}", query.executeUpdate());// 执行sql
        //entityManager.getTransaction().commit(); // 提交事务
        JPAEntityFactory.close();// 关闭连接
    }

// 删除指定id
    @Test
    public void deleteById() {
        EntityManager entityManager = JPAEntityFactory.getEntityManager(); // 等同于 获取连接
        entityManager.getTransaction().begin(); // 开启事务
        String deleteSql = "delete from yootk.course where cid = ?1";
        Query query = entityManager.createNativeQuery(deleteSql);
        query.setParameter(1, 1); // 预处理sql 赋值
        loggerFactory.info("【执行结果】：{}", query.executeUpdate());// 执行sql
        entityManager.getTransaction().commit(); // 提交事务
        JPAEntityFactory.close();// 关闭连接
    }

@Test
    public void addCourse() {
        EntityManager entityManager = JPAEntityFactory.getEntityManager();// 等同于获取连接
        entityManager.getTransaction().begin(); //开启事务
        String addSql = "insert into yootk.course(cname, credit, end, num, start) " +
                "value(:cname,:credit,:end,:num,:start )";
        Query query = entityManager.createNativeQuery(addSql);
        query.setParameter("cname", "java就业课程实战"); // 对预处理参数赋值
        query.setParameter("credit", 10); // 对预处理参数赋值
        query.setParameter("start", DateUtil.stringToDate("2021-10-01")); // 对预处理参数赋值
        query.setParameter("end", DateUtil.stringToDate("2022-10-01")); // 对预处理参数赋值
        query.setParameter("num", 999); // 对预处理参数赋值
        query.executeUpdate(); // 执行最终sql
        entityManager.getTransaction().commit();// 提交事务
    }