Spring JdbcTemplate

1. 什么是JdbcTemplate：

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

2. 使用步骤：

1. 引入相关jar包

2. 在spring配置文件中配置数据库连接池

   jdbc.properties

   jdbc.driverClass=com.mysql.jdbc.Driver
   jdbc.url=jdbc:mysql://localhost:3306/spring
   jdbc.username=root
   jdbc.password=root

   bean1.xml

   <!-- 数据库连接池 -->
   <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close">
       <property name="driverClassName" value="${jdbc.driverClass}"></property>
       <property name="url" value="${jdbc.url}"></property>
       <property name="username" value="${jdbc.username}"></property>
       <property name="password" value="${jdbc.password}"></property>
   </bean>

3. 配置JdbcTemplate对象，注入DataSource

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

4. 创建service类、dao类，在dao中注入JdbcTemplate、在service中注入dao

   <!-- 组件扫描 -->
   <context:component-scan base-package="com.atguigu"></context:component-scan>
   
   
   @Service
   public class BookService {
       //注入 dao
       @Autowired
       private BookDao bookDao;
   }
   
   @Repository
   public class BookDaoImpl implements BookDao {
       //注入 JdbcTemplate
       @Autowired
       private JdbcTemplate jdbcTemplate;
   }

1. 添加

1. 对应数据库创建实体类

2. 编写service和dao

   @Repository
   public class BookDaoImpl implements BookDao {
       //注入 JdbcTemplate
       @Autowired
       private JdbcTemplate jdbcTemplate;
       //添加的方法
       @Override
       public void add(Book book) {
           //1 创建 sql 语句
           String sql = "insert into t_book values(?,?,?)";
           //2 调用方法实现
           Object[] args = {book.getUserId(), book.getUsername(),book.getUstatus()};
           int update = jdbcTemplate.update(sql,args);
           System.out.println(update);
       }
   }

2. 修改和删除

• 使用JdbcTemplate 模板所实现的 增删改都是调用了同一个 update方法

  // 1、修改
  @Override
  public void updateBook(Book book) {
  String sql = "update t_book set username=?,ustatus=? where user_id=?";
  Object[] args = {book.getUsername(), book.getUstatus(),book.getUserId()};
  int update = jdbcTemplate.update(sql, args);
  System.out.println(update);
  }

  // 2、删除
  @Override
  public void delete(String id) {
  String sql = "delete from t_book where user_id=?";
  int update = jdbcTemplate.update(sql, id);
  System.out.println(update);
  }

3. 查询返回某个值

• 查询表里又多少条记录，返回的是一个值
• 使用JdbcTemplate实现查询返回某个值

//查询表记录数
@Override
public int selectCount() {
    String sql = "select count(*) from t_book";
    //queryForObject方法中：第一个参数代表--sql语句；第二个参数代表--返回类型class
    Integer count = jdbcTemplate.queryForObject(sql, Integer.class);
    return count;
}

4. 查询返回对象

• 使用JdbcTemplate实现查询返回对象

//查询返回对象
@Override
public Book findBookInfo(String id) {
    String sql = "select * from t_book where user_id=?";
    //调用方法
    Book book = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<Book>(Book.class), id);
    return book;
}

5. 查询返回集合

• 使用JdbcTemplate实现查询返回集合

//所用场景：查询图书列表分页、、
//查询返回集合
@Override
public List<Book> findAllBook() {
    String sql = "select * from t_book";
    //调用方法
    List<Book> bookList = jdbcTemplate.query(sql, new BeanPropertyRowMapper<Book>(Book.class));
    return bookList;
}

6. 批量操作

• 概念：操作表里多条记录
• JdbcTemplate实现批量操作

//批量添加
@Override
public void batchAddBook(List<Object[]> batchArgs) {
    String sql = "insert into t_book values(?,?,?)";
    //batchUpdate方法 第一个参数：sql语句        第二个参数：List集合，添加多条记录数据
    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));
  }