Spring篇-JdbcTemplate

你的名字 2021-06-10 20:40 527阅读 0赞

# JdbcTemplate #

> Spring 框架对 JDBC 进行封装，使用 JdbcTemplate 方便实现对数据库操作

## 使用前的准备 ##

*  引入相关 jar 包

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NDA4Mzkw_size_16_color_FFFFFF_t_70]

*  在 spring 配置文件配置数据库连接池

<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close">
            <property name="url" value="jdbc:mysql://localhost:3306/test" />
            <property name="username" value="root" />
            <property name="password" value="cVzhanshi" />
            <property name="driverClassName" value="com.mysql.jdbc.Driver" />
        </bean>

*  配置 JdbcTemplate 对象，注入 DataSource

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            
            <property name="dataSource" ref="dataSource"></property>
        </bean>

*  创建 service 类，创建 dao 类，在 dao 注入 jdbcTemplate 对象 ,在service注入dao

/*DAO*/
    @Repository
    public class UserDaoImpl implements UserDao{ 
    
        @Autowired
        private JdbcTemplate jdbcTemplate;
        ...
     }
     
     
     /*service*/
     @Service
    public class UserService { 
    
        @Autowired
        private UserDao userDao;
        ...
    }

## JdbcTemplate 操作数据库（添加） ##

*  创建实体类User

public class User { 
    
        private String userId;
        private String userName;
        private String passWord;
        private String addRess;
        private String phone;
    	...
    }

*  编写 service 和 dao

调用 JdbcTemplate 对象里面 update 方法实现添加操作

![在这里插入图片描述][20210416235242450.png]

有两个参数

*  第一个参数：sql 语句
 *  第二个参数：可变参数，设置 sql 语句值

代码实现:

/*service*/
    public int insertUser(User user){ 
        int i = userDao.addUser(user);
        return i;
    }
    
    /*dao*/
    //插入
    @Override
    public int addUser(User user) { 
        String sql = "insert into user values(?,?,?,?,?)";
        int update = jdbcTemplate.update(sql, user.getUserId(), user.getUserName(), user.getPassWord(), user.getAddRess(), user.getPhone());
        return update;
    }

## JdbcTemplate 操作数据库（修改和删除） ##

> 修改、删除与插入类似，用的方法相同

### 修改 ###

/*service*/
    public int updateUser(User user){ 
            int i = userDao.updateUser(user);
            return i;
        }
    
    //修改
        @Override
        public int updateUser(User user) { 
            String sql = "update user set name=?,address=? where id=?";
            int update = jdbcTemplate.update(sql, user.getUserName(), user.getAddRess(), user.getUserId());
            return update;
        }

### 删除 ###

/*service*/
    public int deleteUser(String id){ 
            int i = userDao.deleteUser(id);
            return i;
        }
    
    //删除
    @Override
    public int deleteUser(String id) { 
        String sql = "delete from user where id=?";
        int update = jdbcTemplate.update(sql, id);
        return update;
    }

## JdbcTemplate 操作数据库（查询返回某个值） ##

> 类似于“ 查询表里面有多少条记录，返回是某个值 ”这样的要求

使用 JdbcTemplate 实现查询返回某个值代码 ![在这里插入图片描述][20210416235329321.png]

![在这里插入图片描述][20210416235311931.png]  
有两个参数

*  第一个参数：sql 语句
 *  第二个参数：返回类型 Class

//sevice
    public int selcetCount(){ 
        int count = userDao.selectCount();
        return count;
    }
    
    //dao
    @Override
    public int selectCount() { 
        String sql = "select count(*) from user";
        Integer count = jdbcTemplate.queryForObject(sql, Integer.class);
        return count;
    }

## JdbcTemplate 操作数据库（查询返回对象） ##

> 场景：查询用户详情

JdbcTemplate 实现查询返回对象

![在这里插入图片描述][20210416235334966.png]

有三个参数

*  第一个参数：sql 语句
 *  第二个参数：RowMapper 是接口，针对返回不同类型数据，使用这个接口里面实现类完成 数据封装
 *  第三个参数：sql 语句值

//service
    public int selcetCount(){ 
        int count = userDao.selectCount();
        return count;
    }
    
    //dao
    //查询一个用户
    @Override
    public User findBookInfo(String id) { 
        String sql = "select id userId,name userName,password,address,phone from user where id=?";
        User user = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<User>(User.class), id);
        return user;
    }

## JdbcTemplate 操作数据库（查询返回集合） ##

> 场景：查询图书列表分页

调用 JdbcTemplate 方法实现查询返回集合

![在这里插入图片描述][2021041623534619.png]

有三个参数

*  第一个参数：sql 语句
 *  第二个参数：RowMapper 是接口，针对返回不同类型数据，使用这个接口里面实现类完成 数据封装
 *  第三个参数：sql 语句值

//service
    public List<User> findBookList(){ 
        List<User> list = userDao.getBeanList();
        return list;
    }
    
    //dao
    @Override
    public List<User> getBeanList() { 
        String sql = "select id userId,name userName,password,address,phone from user";
        List<User> query = jdbcTemplate.query(sql, new BeanPropertyRowMapper<User>(User.class));
        return query;
    }

## JdbcTemplate 操作数据库（批量操作） ##

> 批量操作：操作表里面多条记录

### 批量添加 ###

JdbcTemplate 实现批量添加操作

![在这里插入图片描述][20210416235357353.png]

原理:

> 将list中的每组数据执行sql语句，实现了批量操作

有两个参数

*  第一个参数：sql 语句
 *  第二个参数：List 集合，添加多条记录数据

//批量添加
    @Override
    public void batchAddBook(List<Object[]> batchArgs) { 
     String sql = "insert into t_book values(?,?,?)";
     int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);
     System.out.println(Arrays.toString(ints));
    }
    //批量添加测试
    List<Object[]> batchArgs = new ArrayList<>();
    Object[] o1 = { "3","java","a"};
    Object[] o2 = { "4","c++","b"};
    Object[] o3 = { "5","MySQL","c"};
    batchArgs.add(o1);
    batchArgs.add(o2);
    batchArgs.add(o3);
    //调用批量添加
    bookService.batchAdd(batchArgs);

### 批量修改 ###

//批量修改
    @Override
    public void batchUpdateBook(List<Object[]> batchArgs) {
     String sql = "update t_book set username=?,ustatus=? where user_id=?";
     int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);
     System.out.println(Arrays.toString(ints));
    }
    //批量修改
    List<Object[]> batchArgs = new ArrayList<>();
    Object[] o1 = {"java0909","a3","3"};
    Object[] o2 = {"c++1010","b4","4"};
    Object[] o3 = {"MySQL1111","c5","5"};
    batchArgs.add(o1);
    batchArgs.add(o2);
    batchArgs.add(o3);
    //调用方法实现批量修改
    bookService.batchUpdate(batchArgs);

### 批量删除 ###

//批量删除
    @Override
    public void batchDeleteBook(List<Object[]> batchArgs) {
     String sql = "delete from t_book where user_id=?";
     int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);
     System.out.println(Arrays.toString(ints));
    }
    //批量删除
    List<Object[]> batchArgs = new ArrayList<>();Object[] o1 = {"3"};
    Object[] o2 = {"4"};
    batchArgs.add(o1);
    batchArgs.add(o2);
    //调用方法实现批量删除
    bookService.batchDelete(batchArgs);

## 附录:完整代码 ##

UserDaoImpl.java

/** * @author cVzhanshi * @create 2021-04-16 21:27 */
    @Repository
    public class UserDaoImpl implements UserDao{ 
    
        @Autowired
        private JdbcTemplate jdbcTemplate;
    
    
        //插入
        @Override
        public int addUser(User user) { 
            String sql = "insert into user values(?,?,?,?,?)";
            int update = jdbcTemplate.update(sql, user.getUserId(), user.getUserName(), user.getPassWord(), user.getAddRess(), user.getPhone());
            return update;
        }
    
        //修改
        @Override
        public int updateUser(User user) { 
            String sql = "update user set name=?,address=? where id=?";
            int update = jdbcTemplate.update(sql, user.getUserName(), user.getAddRess(), user.getUserId());
            return update;
        }
    
        //删除
        @Override
        public int deleteUser(String id) { 
            String sql = "delete from user where id=?";
            int update = jdbcTemplate.update(sql, id);
            return update;
        }
    
        //查询一个用户
        @Override
        public User findBookInfo(String id) { 
            String sql = "select id userId,name userName,password,address,phone from user where id=?";
            User user = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<User>(User.class), id);
            return user;
        }
    	//获取记录数
        @Override
        public int selectCount() { 
            String sql = "select count(*) from user";
            Integer count = jdbcTemplate.queryForObject(sql, Integer.class);
            return count;
        }
    	//获取用户列表
        @Override
        public List<User> getBeanList() { 
            String sql = "select id userId,name userName,password,address,phone from user";
            List<User> query = jdbcTemplate.query(sql, new BeanPropertyRowMapper<User>(User.class));
            return query;
        }
    }

UserService.java

/** * @author cVzhanshi * @create 2021-04-16 21:27 */
    @Service
    public class UserService { 
    
        @Autowired
        private UserDao userDao;
    
        public int insertUser(User user){ 
            int i = userDao.addUser(user);
            return i;
        }
    
        public int updateUser(User user){ 
            int i = userDao.updateUser(user);
            return i;
        }
        public int deleteUser(String id){ 
            int i = userDao.deleteUser(id);
            return i;
        }
        public int selcetCount(){ 
            int count = userDao.selectCount();
            return count;
        }
    
        public User findBookInfo(String id){ 
            User user = userDao.findBookInfo(id);
            return user;
        }
        public List<User> findBookList(){ 
            List<User> list = userDao.getBeanList();
            return list;
        }
    }

UserDao.java

/** * @author cVzhanshi * @create 2021-04-16 21:27 */
    public interface UserDao { 
        int addUser(User user);
    
        int updateUser(User user);
    
        int deleteUser(String id);
    
        int selectCount();
    
        User findBookInfo(String id);
    
        List<User> getBeanList();
    }

Test.java

/**
     * @author cVzhanshi
     * @create 2021-04-16 21:32
     */
    public class JDBCTest {
    
        private UserService userService;
        //读取配置文件 获取service对象
        @Before
        public  void before(){
            ApplicationContext context = new ClassPathXmlApplicationContext("bean.xml");
            userService = context.getBean("userService", UserService.class);
        }
    
        @Test
        public void insert(){
            int i = userService.insertUser(new User("6", "cVzhanshi", "root", "jiangxi", "10086"));
            System.out.println(i);
        }
        @Test
        public void update(){
            int i = userService.updateUser(new User("6", "cV展示", null, "beijin", null));
            System.out.println(i);
        }
        @Test
        public void delete(){
            int i = userService.deleteUser("5");
            System.out.println(i);
        }
        @Test
        public void count(){
            int i = userService.selcetCount();
            System.out.println(i);
        }
        @Test
        public void getBean(){
            User bookInfo = userService.findBookInfo("6");
            System.out.println(bookInfo);
        }
        @Test
        public void getBeanList(){
            List<User> bookList = userService.findBookList();
            System.out.println(bookList);
        }
    
    
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NDA4Mzkw_size_16_color_FFFFFF_t_70]: /images/20210516/364ae293050d4cac8238decbe72bf8df.png
[20210416235242450.png]: /images/20210516/6911c0bdaf11426baaa9714f76a94b86.png
[20210416235329321.png]: /images/20210516/ae2fe7f63a82415dbe4326b159e5d7be.png
[20210416235311931.png]: /images/20210516/ddf74f18fde6479fa4b0bbf06f277954.png
[20210416235334966.png]: /images/20210516/c89b1cfadc7f499ea9346472ae8c0e2b.png
[2021041623534619.png]: /images/20210516/0186e57dcb99488d8a84524feb23ff64.png
[20210416235357353.png]: /images/20210516/273d3b5e6d564dd5b6353fac1c09e586.png