@Repository public class bookDAOImpl implements bookDAO{ //注入jdbcTemplate @Autowired private JdbcTemplate jdbcTemplate; //添加的方法 @Override public void add(Book book) { String sql = "insert into book values(?,?,?)"; int update = jdbcTemplate.update(sql, book.getUserId(), book.getUsername(), book.getUstatus()); if (update == 1){ System.out.println("添加成功"); }else { System.out.println("添加失败"); } }
@Override public void update(Book book) { String sql = "update book set username = ?,usatus = ? where user_id = ?"; int update = jdbcTemplate.update(sql, book.getUsername(), book.getUstatus(), book.getUserId()); if (update == -1){ System.out.println("修改成功"); }else { System.out.println("修改失败"); } }
@Override public void delById(String Id) { String sql = "delete from book where user_id = ?";
int update = jdbcTemplate.update(sql, Id); if (update == 1){ System.out.println("删除成功"); }else { System.out.println("删除失败"); }
}
@Override public int selectCount() { String sql = "select count(*) from book"; Integer integer = jdbcTemplate.queryForObject(sql, Integer.class); return integer;
}
@Override public Book selectBook(String id) { String sql = "select * from book where user_id = ?"; Book book = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper(Book.class), id);
return book; }
@Override public List findList() { String sql = " select * from book"; List bookList = jdbcTemplate.query(sql, new BeanPropertyRowMapper(Book.class)); return bookList; }
@Override public void addBatchList(List list) { String sql = "insert into book values(?,?,?)"; int[] ints = jdbcTemplate.batchUpdate(sql,list); System.out.println(Arrays.toString(ints)); }
@Override public void batchUpdateBook(List lists) { String sql = "update book set username =?,usatus = ? where user_id = ?"; int[] ints = jdbcTemplate.batchUpdate(sql, lists); System.out.println(Arrays.toString(ints)); }
@Override public void batchDel(List list) { String sql ="delete from book where user_id = ?"; int[] ints = jdbcTemplate.batchUpdate(sql, list); System.out.println(Arrays.toString(ints)); } } service层:
@Service public class BookService { //注入dao @Autowired private bookDAO bookdao; //添加 public void addBook(Book book){ bookdao.add(book); } //修改 public void update(Book book){ bookdao.update(book); } //删除 public void delById(String Id){ bookdao.delById(Id); } //查询返回某个值 public int FindCount(){ return bookdao.selectCount(); } //查询返回某个对象 public Book findBook(String id){ return bookdao.selectBook(id); } //返回多个对象 public List findList(){ return bookdao.findList(); } //批量添加 public void BatchAdd(List list){ bookdao.addBatchList(list);
} //批量修改 public void batchUpdateBook(List lists){ bookdao.batchUpdateBook(lists); } //批量删除 public void batchDel(List list){ bookdao.batchDel(list);
} }
entiry层:
package com.entiry;
public class Book { private String userId; private String username; private String ustatus;