SpringBoot基础之JDBCTemplate

最基础的数据库操作,SpringBoot省去了那一堆创建Connection,连接关闭操作,现在使用起来不能更方便了。

  1. 第一步需要引入maven包,由于我的是mysql所以,引入了mysql的包
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
  1. 配置数据源,配置自己数据的地址账号密码信息
spring:
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/springboot
    username: root
    password: 123456
    driver-class-name: com.mysql.jdbc.Driver
  1. 通过注入JdbcTemplate来托管了一起数据库的连接释放等操作。第一种jdbcTemplate直接通过insert方法写入语句执行,但是此时返回的结果只是执行成功还是失败。
    如果需要等到生成的ID的值,需要通过SimpleJdbcInsert的executeAndReturnKey方法来获取结果。
@Repository("rideRepository")
public class RideRepositoryImpl implements RideRepository {
  @Autowired
  private JdbcTemplate jdbcTempleate; 
  public Ride createRide(Ride ride){
      //第一种不返回插入的数据自动生成的ID值
     jdbcTempleate.update("insert into ride (name,duration) values (?,?)", ride.getName(), ride.getDuration());
     //第二种可以获取到生成的id值
     SimpleJdbcInsert insert = new SimpleJdbcInsert(jdbcTempleate);
     List<String> columns = new ArrayList<>();
     columns.add("name");
     columns.add("duration");
     insert.setTableName("ride");
     insert.setColumnNames(columns);
     Map<String, Object> data = new HashMap<>();
     data.put("name", ride.getName());
     data.put("duration", ride.getDuration());
     insert.setGeneratedKeyName("id");
     Number key = insert.executeAndReturnKey(data);
     return null;
  } 
}  
  1. 通过jdbcTemplate可以获取到查询结果,通过RowMapper对应到具体的bean,以及可以将RowMapper抽象成自定义的RideRowMapper类
@Override
public List<Ride> getRides() {
   List<Ride> rides = jdbcTempleate.query("select * from ride", new RowMapper<Ride>() {
      @Override
      public Ride mapRow(ResultSet resultSet, int i) throws SQLException {
         Ride ride = new Ride();
         ride.setId(resultSet.getInt("id"));
         ride.setName(resultSet.getString("name"));
         ride.setDuration(resultSet.getInt("duration"));
         return ride;
      }
   });
   return rides;
}

class RideRowMapper implements RowMapper<Ride>{
   @Override
   public Ride mapRow(ResultSet resultSet, int i) throws SQLException {
      Ride ride = new Ride();
      ride.setId(resultSet.getInt("id"));
      ride.setName(resultSet.getString("name"));
      ride.setDuration(resultSet.getInt("duration"));
      return ride;
   }
}
  1. 另外可以通过KeyHolder获取插入的字增长的id值,需要通过PreparedStatementCreator来实现
public Ride createRide(Ride ride){
      KeyHolder keyHolder = new GeneratedKeyHolder();
      jdbcTempleate.update(new PreparedStatementCreator() {
         @Override
         public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
            PreparedStatement ps = connection.prepareStatement("insert into ride (name,duration) values (?,?)", new String[] {"id"});
            ps.setString(1,ride.getName());
            ps.setInt(2, ride.getDuration());
            return ps;
         }
      }, keyHolder);
      Number id = keyHolder.getKey();
      return getRide(id.intValue());
   }
   private Ride getRide(int id) {
      return jdbcTempleate.queryForObject("select * from ride", new RideRowMapper());
   }
  1. 更新数据方法
private Ride updateRide(Ride ride) {
   jdbcTempleate.update("update ride set name = ?, duration = ? where id = ?",
         ride.getName(), ride.getDuration(), ride.getId());
   return null;
}
  1. 批量更新方法,需要通过转化成list以及内部是数组格式,要按照和sql语句的位置相同的数据格式
public void batch(){
   List<Ride> rides = this.getRides();
   List<Object[]> pairs = new ArrayList<>();
   for(Ride ride : rides){
      Object[] tmp = {new Date(), ride.getId()};
      pairs.add(tmp);
   }
   this.updateRides(pairs);
}

public void updateRides(List<Object[]> pairs) {
   jdbcTempleate.batchUpdate("update ride set ride_date = ? where id = ?", pairs);
}
  1. delete数据方法
public Ride deleteRide(int id) {
    //直接通过jdbcTemplate处理,参数为问号
   jdbcTempleate.update("delete from ride where id = ?", id);
    //通过NamedParameterJdbcTemplate来处理,参数放在map中,问好被替换为“:id”
   NamedParameterJdbcTemplate namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(jdbcTempleate);
   Map<String,Object> paramMap = new HashMap();
   paramMap.put("id", id);
   namedParameterJdbcTemplate.update("delete from ride where id = :id", paramMap);
   return null;
}
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容