VisitorDaoImpl.java 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  1. package com.happy.dao.impl;
  2. import com.happy.Model.Visitor;
  3. import com.happy.dao.VisitorDao;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.jdbc.core.BeanPropertyRowMapper;
  6. import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
  7. import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
  8. import org.springframework.stereotype.Repository;
  9. import java.util.List;
  10. @Repository("Visitor")
  11. public class VisitorDaoImpl implements VisitorDao {
  12. @Autowired
  13. private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
  14. public NamedParameterJdbcTemplate getNamedParameterJdbcTemplate() {
  15. return namedParameterJdbcTemplate;
  16. }
  17. public void setNamedParameterJdbcTemplate(
  18. NamedParameterJdbcTemplate namedParameterJdbcTemplate) {
  19. this.namedParameterJdbcTemplate = namedParameterJdbcTemplate;
  20. }
  21. public List<Visitor> combGetInfoList(String sqlx, int page, int rows){
  22. int start = (page - 1) * rows;// 每页的起始下标
  23. String sql="select * from info " + sqlx + " limit :start,:rows ";
  24. MapSqlParameterSource sps = new MapSqlParameterSource();
  25. sps.addValue("start", start);
  26. sps.addValue("rows", rows);
  27. List<Visitor> list=namedParameterJdbcTemplate.query(sql, sps,new BeanPropertyRowMapper<Visitor>(Visitor.class));
  28. if(list != null && list.size() >0){
  29. return list;
  30. }
  31. return null;
  32. }
  33. public int findCombPageTotal(String sqlx) {
  34. String sql = "select count(*) from info " + sqlx;
  35. MapSqlParameterSource sps = new MapSqlParameterSource();
  36. return namedParameterJdbcTemplate.queryForInt(sql, sps);
  37. }
  38. public int findInfoTotal() {
  39. String sql = "select count(*) from info ";
  40. MapSqlParameterSource sps = new MapSqlParameterSource();
  41. sps.addValue("fake", 0);
  42. return namedParameterJdbcTemplate.queryForInt(sql, sps);
  43. }
  44. // 根据当前页和每页条数查询所有员工
  45. public List<Visitor> getlist(int page, int rows) {
  46. int start = (page - 1) * rows;// 每页的起始下标
  47. String sql = "select * from info order by id desc limit :start,:rows ";
  48. MapSqlParameterSource sps = new MapSqlParameterSource();
  49. sps.addValue("start", start);
  50. sps.addValue("rows", rows);
  51. List<Visitor> list = namedParameterJdbcTemplate.query(sql, sps,
  52. new BeanPropertyRowMapper<Visitor>(Visitor.class));
  53. return list;
  54. }
  55. public int insertInfo(Visitor visitor){
  56. String sql = "insert into info(visitor_name, visitor_phone, reason, status, status_with_time, card_number, visited_at, id_card_img, created_time, visit_start_time, visit_end_time, member_name, member_phone, member_org, car_number, time) values(:visitor_name, :visitor_phone, :reason, :status, :status_with_time, :card_number, :visited_at, :id_card_img, :created_time, :visit_start_time, :visit_end_time, :member_name, :member_phone, :member_org, :car_number, :time)";
  57. MapSqlParameterSource sps = new MapSqlParameterSource();
  58. sps.addValue("visitor_name", visitor.getVisitor_name());
  59. sps.addValue("visitor_phone", visitor.getVisitor_phone());
  60. sps.addValue("reason", visitor.getReason());
  61. sps.addValue("status", visitor.getStatus());
  62. sps.addValue("status_with_time", visitor.getStatus_with_time());
  63. sps.addValue("card_number", visitor.getCard_number());
  64. sps.addValue("visited_at", visitor.getVisited_at());
  65. sps.addValue("id_card_img", visitor.getId_card_img());
  66. sps.addValue("created_time", visitor.getCreated_time());
  67. sps.addValue("visit_start_time", visitor.getVisit_start_time());
  68. sps.addValue("visit_end_time", visitor.getVisit_end_time());
  69. sps.addValue("member_name", visitor.getMember_name());
  70. sps.addValue("member_phone", visitor.getMember_phone());
  71. sps.addValue("member_org", visitor.getMember_org());
  72. sps.addValue("car_number", visitor.getCar_number());
  73. sps.addValue("time", visitor.getTime());
  74. int num = 0;
  75. try{
  76. num = namedParameterJdbcTemplate.update(sql, sps);
  77. }
  78. catch(Exception e){
  79. e.printStackTrace();
  80. }
  81. return num;
  82. }
  83. public int delInfo(String sql){
  84. MapSqlParameterSource sps = new MapSqlParameterSource();
  85. int num = 0;
  86. try{
  87. num = namedParameterJdbcTemplate.update(sql, sps);
  88. }
  89. catch(Exception e){
  90. e.printStackTrace();
  91. }
  92. return num;
  93. }
  94. public List<Visitor> queryById(Integer id){
  95. String sql = "select * from info where id=:id ";
  96. MapSqlParameterSource sps = new MapSqlParameterSource();
  97. sps.addValue("id", id);
  98. List<Visitor> list = namedParameterJdbcTemplate.query(sql, sps,
  99. new BeanPropertyRowMapper<Visitor>(Visitor.class));
  100. if (list != null && list.size() > 0) {
  101. return list;
  102. }
  103. return null;
  104. }
  105. }