关于springboot:SpringBoot基础之JDBCTemplate

9次阅读

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

最根底的数据库操作,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>
  2. 配置数据源,配置本人数据的地址账号密码信息

    spring:
      datasource:
     url: jdbc:mysql://127.0.0.1:3306/springboot
     username: root
     password: 123456
     driver-class-name: com.mysql.jdbc.Driver
  3. 通过注入 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;
    } 
    }  
  4. 通过 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;
    }
    }
  5. 另外能够通过 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());
    }
  6. 更新数据办法

    private Ride updateRide(Ride ride) {
    jdbcTempleate.update("update ride set name = ?, duration = ? where id = ?",
          ride.getName(), ride.getDuration(), ride.getId());
    return null;
    }
  7. 批量更新办法,须要通过转化成 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);
    }
  8. 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;
    }
正文完
 0