共计 3571 个字符,预计需要花费 9 分钟才能阅读完成。
最根底的数据库操作,SpringBoot 省去了那一堆创立 Connection,连贯敞开操作,当初应用起来不能更不便了。
-
第一步须要引入 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; }
正文完
发表至: springboot
2021-12-04