1 spring-jdbc
- core JdbcTemplate 等相关核心接口和类（核心）
- datesource 数据源相关的辅助类（内嵌数据源的初始化）
- object 将基本的JDBC操作封装成对象
- support 错误码等其他辅助工具
2.在学习之前先了解一下如何去通过注解实现一个Bean
- @Component 通用注解 用来注解一个通用的Bean 一般作为一个工具Bean
- @Repository 数据操作的一个仓库
- @Service 服务业务
- @Controller SpringMVC
- @RestController
3.简单的JDBC 操作
- query
- queryForObject
- queryForList
- update 实现插入和修改删除
- execute
4. 代码上手操作
新建一个UserRepository 使用@Repository注解注释为一个数据操作的仓库
@Autowired private JdbcTemplate jdbcTemplate; /*** * 插入数据 * * @Author MRC * @Date 2019年6月4日 上午11:12:56 */ public void insertData() { Arrays.asList("123","456").forEach(bar -> { jdbcTemplate.update("insert into user(id,username,password) values(?,?,?)", bar,bar,bar); }); }
2.查询数据
public void listData() { //查询单个 System.out.println(jdbcTemplate.queryForObject("select count(id) from user", Long.class)); //查询list List<String> list = jdbcTemplate.queryForList("select id from user",String.class); list.forEach(id -> { System.out.println("id--->"+id); }); //查询出来的数据与对象进行关联 List<User> users = jdbcTemplate.query("select * from user", new RowMapper<User>() { @Override public User mapRow(ResultSet arg0, int arg1) throws SQLException { return new User(arg0.getString("id"), arg0.getString("username"), arg0.getString("password")); } }); users.forEach(user -> { System.out.println("user--->"+user); }); }
3.使用SimpleJdbcInsert 代替JdbcTemplate 实现最基本的查询
@Autowired private SimpleJdbcInsert simpleJdbcInstall; //注入两个对象 @Bean @Autowired public SimpleJdbcInsert simpleJdbcInsert(JdbcTemplate jdbcTemplate) { //将User表与SimpleJdbcInsert关联到一起 return new SimpleJdbcInsert(jdbcTemplate).withTableName("user").usingGeneratedKeyColumns("id"); } @Bean @Autowired public NamedParameterJdbcTemplate namedParameterJdbcTemplate(DataSource dataSource) { return new NamedParameterJdbcTemplate(dataSource); }
3.1 使用SimpleJdbcTemplate
HashMap<String, String> row = new HashMap<>();
//id会自动生成 采用自增长主键
row.put("username", "ddd"); row.put("password", "345"); Number id = simpleJdbcInstall.executeAndReturnKey(row); System.out.println(id);
5. SQL批处理
JdbcTemplate
- batchUpdate
- BatchPreparedStatementSetter
NamedParameterJdbcTemplate
- batchUpdate
- SqlParameterSourceUtils.createBatch
5.1 使用JdbcTemplate.batchUpdate 实现一个SQL批处理
public void batchInsert() { //使用Jdbc批量操作数据 jdbcTemplate.batchUpdate("insert into user(username,password) values(?,?)", new BatchPreparedStatementSetter() { //sql语句里面的？进行一个赋值 @Override public void setValues(PreparedStatement ps, int i) throws SQLException { ps.setString(1, "user-"+i); ps.setString(2, "pass-"+i); } //批量操作次数 @Override public int getBatchSize() { return 5; } }); }
5.2使用 NamedParamterJdbcTemplate 实现一个SQL批处理
@Autowired private NamedParameterJdbcTemplate namedParameterJdbcTemplate; public void batchInsert2() { List<User> users = new ArrayList<>();
//主键自增长 所以不写 users.add(new User("", "user-11", "pass-11")); users.add(new User("", "user-12", "pass-12")); users.add(new User("", "user-13", "pass-13")); namedParameterJdbcTemplate.batchUpdate("insert into user(username,password) values(:username,:password)", SqlParameterSourceUtils.createBatch(users)); }