notes_estom/Spring/Spring5/03 JDBCTemplate.md

Data Access

简介

概述

DataAccess模块主要包括

• JDBC
• ORM
• OXM

JDBCTemplate对JDBC进行封装，很方便的实现对数据库进行操作。

自己开发项目也应该这样做。 首先进行设计，把接口、实现、属性、方法定义好。遵循从上到下的设计。 然后进行开发，根据具体的业务逻辑实现方法的内容。遵循从下到上的开发。

准备工作

1. 引入相关的jar包

2. 数据库连接池

    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
        <property name="url" value="jdbc:mysql://localhost:3310/user"></property>
        <property name="username" value="root"></property>
        <property name="password" value="123456"></property>
    </bean>

3. 配置jdbcTemplate对象，注入dataSource

    <!--创建jdbctemplate对象-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <!--注入参数-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>

4. 创建Service和dao。在service注入dao，在dao中注入jdbcTemplate

@Repository
public class UserDaoImpl implements UserDao {
    
    @Autowired
    private JdbcTemplate jdbcTemplate;
    
    
    @Override
    public int addUser(User user) {
        System.out.println("add 方法执行了");
        return 1;
    }
}


public class UserService {
    @Autowired
    private UserDao userDao;

    public void addUser(User user){
        userDao.addUser(user);
    }


}

编写业务逻辑

1. 在dao中进行数据库添加操作。在jdbcTemplate对象里面update方法实现添加操作

    @Override
    public int addUser(User user) {
        String sql = "insert into user values(?,?,?)";
        Object[] args = {user.getUserId(),user.getUsername(),user.getUserStatus()};


        int update = jdbcTemplate.update(sql,args);
        System.out.println(update);
        return update;
    }

2. 在service中完成业务逻辑

@Service
public class UserService {
    @Autowired
    private UserDao userDao;

    public void addUser(User user){
        userDao.addUser(user);
    }
}

3. 在test中进行测试和验证

    @Test
    public void testJDBC(){
        ApplicationContext context = new ClassPathXmlApplicationContext("bean01.xml");
        UserService userService = context.getBean("userService",UserService.class);
        User user = new User();
        user.setUserId("123");
        user.setUsername("yinkanglong");
        user.setUserStatus("up");
        userService.addUser(user);
    }

2 增删查改业务的实现

基本业务实现

• 增 jdbcTemplate.update()
• 删 jdbcTemplate.update()
• 改 jdbcTemplate.update()
• 查
  • 数量返回值 jdbcTemplate.queryForObject
  • 单挑记录 jdbcTemplate.queryForObject
  • 多条记录 jdbcTemplate.query

@Repository
public class UserDaoImpl implements UserDao {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Override
    public int addUser(User user) {
        String sql = "insert into user values(?,?,?)";
        Object[] args = {user.getUserId(),user.getUsername(),user.getUserStatus()};

        int update = jdbcTemplate.update(sql,args);
        System.out.println(update);
        return update;
    }

    @Override
    public void updateUser(User user) {
        String sql = "update user set username=?,userstatus=? where userid=?";
        Object[] args = {user.getUsername(),user.getUserStatus(),user.getUserId()};

        int update = jdbcTemplate.update(sql,args);
        System.out.println(update);
        return ;
    }

    @Override
    public void delete(String id) {
        String sql = "delete from user where userid=?";
        Object[] args = {id,};

        int update = jdbcTemplate.update(sql,args);
        System.out.println(update);
        return ;
    }


    /**
     * 查询返回整数
     * @return
     */
    @Override
    public int selectCount(){
        String sql = "select count(*) from user";
        Integer count = jdbcTemplate.queryForObject(sql,Integer.class);
        return count;
    }

    /**
     * 查询返回单个记录
     * @param id
     * @return
     */
    @Override
    public User findUserInfo(String id){
        String sql = "select * from user where userid=?";
        User user = jdbcTemplate.queryForObject(sql,new BeanPropertyRowMapper<User>(User.class),id);
        return user;
    }

    @Override
    public List<User> findAll() {
        String sql = "select * from user";
        List<User> users = jdbcTemplate.query(sql, new BeanPropertyRowMapper<User>(User.class));
        return users;
    }
}

批量操作

• 批量操作，依次遍历集合中的值，调用添加操作。

    @Override
    public void batchAdd(List<Object[]> batchArgs) {
        String sql = "insert into user values(?,?,?)";
        int [] ints = jdbcTemplate.batchUpdate(sql,batchArgs);
        System.out.println(Arrays.toString(ints));
    }