隐藏

JAVA入门[18]-JdbcTemplate简单实例

发布:2021/7/29 15:03:39作者:管理员 来源:本站 浏览次数:1790

一、关于JdbcTemplate


JdbcTemplate是最基本的Spring JDBC模板,这个模板支持简单的JDBC数据库访问功能以及基于索引参数的查询。


Spring数据访问模板:在数据库操作过程中,有很大一部分重复工作,比如事务控制、管理资源以及处理异常等,Spring的模板类处理这些固定部分。同时,应用程序相关的数据访问在回调的实现中处理,包括语句、绑定参数以及整理结果等。这样一来,我们只需关心自己的数据访问逻辑即可。


Image(6)


Spring的JDBC框架承担了资源管理和异常处理的工作,从而简化了JDBC代码,我们只需要编写从数据库读写数据的必需代码就万事大吉了。

二、Spring JdbcTemplate实例


我们的学习目标就是动手写一个demo,实现对Category的CRUD操作。


1.创建表


mysql新建数据库store,然后执行如下sql:

复制代码


create table Category (

Id int not null,

Name varchar(80) null,

constraint pk_category primary key (Id)

);


INSERT INTO category(id,Name) VALUES (1,'女装');

INSERT INTO category(id,Name) VALUES (2,'美妆');

INSERT INTO category(id,Name) VALUES (3,'书籍');


复制代码


2.我用的IDE是IdeaIU,通过maven构建项目,通过xml配置spring。完成后的代码结构为:


Image(7)


3.创建实体类Category



public class Category{

   private int cateId;


   private String cateName;


   public int getCateId() {

       return cateId;

   }


   public void setCateId(int cateId) {

       this.cateId = cateId;

   }


   public String getCateName() {

       return cateName;

   }


   public void setCateName(String cateName) {

       this.cateName = cateName;

   }


   @Override

   public String toString() {

       return "id="+cateId+" name="+cateName;

   }

}




4.修改pom.xml,引入相关依赖。



<dependencies>

   <dependency>

       <groupId>junit</groupId>

       <artifactId>junit</artifactId>

       <version>4.12</version>

   </dependency>


   <!-- Mysql数据库链接jar包 -->

   <dependency>

       <groupId>mysql</groupId>

       <artifactId>mysql-connector-java</artifactId>

       <version>5.1.21</version>

       <scope>runtime</scope>

   </dependency>

</dependencies>




5.配置applicationContext.xml


需要配置dataSource作为jdbcTemplate的数据源。然后配置CategoryDao bean,构造注入了jdbcTemplate对象。完整的applicationContext.xml如下:



<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

   <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">

       <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>

       <property name="url" value="jdbc:mysql://localhost:3306/store"></property>

       <property name="username" value="root"></property>

       <property name="password" value="root"></property>

   </bean>


   <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">

       <property name="dataSource" ref="dataSource"></property>

   </bean>

   

   <bean id="categoryDao" class="CategoryDao">

       <constructor-arg ref="jdbcTemplate"></constructor-arg>

   </bean>

</beans>




6.数据访问实现类CategoryDao


CategoryDao构造函数包含了参数jdbcTemplate,然后实现了常用的数据访问操作。可以看到,我们只要关注具体的sql语句就可以了。另外,在getById()和getAll()方法中使用了lambda语法。



import org.springframework.jdbc.core.JdbcTemplate;

import org.springframework.jdbc.core.RowMapper;


import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.List;

import java.util.Map;


/**

* Created by 陈敬 on 2017/6/6.

*/

public class CategoryDao {

   private JdbcTemplate jdbcTemplate;


   public CategoryDao(JdbcTemplate jdbcTemplate) {

       this.jdbcTemplate = jdbcTemplate;

   }


   public int add(Category category) {

       String sql = "INSERT INTO category(id,name)VALUES(?,?)";

       return jdbcTemplate.update(sql, category.getCateId(), category.getCateName());

   }


   public int update(Category category) {

       String sql = "UPDATE Category SET Name=? WHERE Id=?";

       return jdbcTemplate.update(sql, category.getCateName(), category.getCateId());

   }


   public int delete(int id) {

       String sql = "DELETE FROM Category WHERE Id=?";

       return jdbcTemplate.update(sql, id);

   }


   public int count(){

       String sql="SELECT COUNT(0) FROM Category";

       return jdbcTemplate.queryForObject(sql,Integer.class);

   }


   public Category getById(int id) {

       String sql = "SELECT Id,Name FROM Category WHERE Id=?";

       return jdbcTemplate.queryForObject(sql, (ResultSet rs, int rowNumber) -> {

           Category category = new Category();

           category.setCateId(rs.getInt("Id"));

           category.setCateName(rs.getString("Name"));

           return category;

       }, id);

   }


   public List<Category> getAll(){

       String sql="SELECT Id,Name FROM Category";


       List<Category> result=jdbcTemplate.query(sql, (resultSet, i) -> {

           Category category = new Category();

           category.setCateId(resultSet.getInt("Id"));

           category.setCateName(resultSet.getString("Name"));

           return category;

       });


       return result;

   }

}




7.测试



@ContextConfiguration(locations = "classpath:applicationContext.xml")

@RunWith(SpringJUnit4ClassRunner.class)

public class testCategoryDao {

   @Autowired

   private CategoryDao categoryDao;


   @Test

   public void testAdd() {

       Category category = new Category();

       category.setCateId(4);

       category.setCateName("母婴");


       int result = categoryDao.add(category);

       System.out.println(result);

   }


   @Test

   public void testUpdate() {

       Category category = new Category();

       category.setCateId(4);

       category.setCateName("男装");


       int result = categoryDao.update(category);

       System.out.println(result);

   }



   @Test

   public void testGetById() {

       int id = 4;

       Category category = categoryDao.getById(id);

       System.out.println(category.toString());

   }


   @Test

   public void testGetAll() {

       List<Category> categories = categoryDao.getAll();

       for (Category item : categories) {

           System.out.println(item);

       }

   }


   @Test

   public void testCount() {

       int count = categoryDao.count();

       System.out.println(count);

   }


   @Test

   public void testDelete() {

       int id = 4;

       int result = categoryDao.delete(id);

       System.out.println(result);

   }

}




完整代码:https://github.com/cathychen00/learnjava/tree/master/DemoJdbcTemplate