最根底的数据库操作,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 {@Autowiredprivate 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类
@Overridepublic 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>{@Overridepublic 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;}