关于springboot:SpringBoot基础之JDBCTemplate

47次阅读

共计 3571 个字符，预计需要花费 9 分钟才能阅读完成。

第一步须要引入 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>

配置数据源，配置本人数据的地址账号密码信息

spring:
  datasource:
 url: jdbc:mysql://127.0.0.1:3306/springboot
 username: root
 password: 123456
 driver-class-name: com.mysql.jdbc.Driver

通过注入 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;
} 
}

通过 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;
}
}

另外能够通过 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());
}

更新数据办法

private Ride updateRide(Ride ride) {
jdbcTempleate.update("update ride set name = ?, duration = ? where id = ?",
      ride.getName(), ride.getDuration(), ride.getId());
return null;
}

批量更新办法，须要通过转化成 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);
}

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;
}

正文完