HouseImplDao.java 5.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145
  1. package com.happy.dao.impl;
  2. import com.happy.Model.Admin;
  3. import com.happy.Model.House;
  4. import com.happy.Model.House;
  5. import com.happy.Until.UUIDUtil;
  6. import com.happy.dao.HouseDao;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.jdbc.core.BeanPropertyRowMapper;
  9. import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
  10. import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
  11. import org.springframework.stereotype.Repository;
  12. import java.util.List;
  13. @Repository("HouseDao")
  14. public class HouseImplDao implements HouseDao {
  15. @Autowired
  16. private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
  17. public NamedParameterJdbcTemplate getNamedParameterJdbcTemplate() {
  18. return namedParameterJdbcTemplate;
  19. }
  20. public void setNamedParameterJdbcTemplate(
  21. NamedParameterJdbcTemplate namedParameterJdbcTemplate) {
  22. this.namedParameterJdbcTemplate = namedParameterJdbcTemplate;
  23. }
  24. @Override
  25. public int insertHouse(House house) {
  26. String sql = "INSERT INTO house (id, h_name, h_areas, price, number, h_config, remark, create_id, create_date, status) VALUES (:id, :h_name, :h_areas, :price, :number, :h_config, :remark, :create_id, :create_date, :status)";
  27. MapSqlParameterSource sps = new MapSqlParameterSource();
  28. sps.addValue("h_name",house.gethName());
  29. sps.addValue("h_areas",house.gethAreas());
  30. sps.addValue("price",house.getPrice());
  31. sps.addValue("number",house.getNumber());
  32. sps.addValue("h_config",house.gethConfig());
  33. sps.addValue("remark",house.getRemark());
  34. sps.addValue("create_id",house.getCreateId());
  35. sps.addValue("create_date",house.getCreateDate());
  36. sps.addValue("status",house.getStatus());
  37. if(house.getId()==null){
  38. sps.addValue("id", UUIDUtil.generateID());
  39. }else{
  40. sps.addValue("id", house.getId());
  41. }
  42. int num = 0;
  43. try{
  44. num = namedParameterJdbcTemplate.update(sql, sps);
  45. }
  46. catch(Exception e){
  47. e.printStackTrace();
  48. }
  49. return num;
  50. }
  51. @Override
  52. public int updateHouse(House house) {
  53. String sql = "UPDATE house SET h_name = :h_name, h_areas = :h_areas, price = :price, number = :number, h_config = :h_config, remark = :remark, modify_date = :modify_date, status = :status WHERE id = :id";
  54. MapSqlParameterSource sps = new MapSqlParameterSource();
  55. sps.addValue("h_name",house.gethName());
  56. sps.addValue("h_areas",house.gethAreas());
  57. sps.addValue("price",house.getPrice());
  58. sps.addValue("number",house.getNumber());
  59. sps.addValue("h_config",house.gethConfig());
  60. sps.addValue("remark",house.getRemark());
  61. sps.addValue("modify_date",house.getModifyDate());
  62. sps.addValue("status",house.getStatus());
  63. sps.addValue("id",house.getId());
  64. int num = 0;
  65. try{
  66. num = namedParameterJdbcTemplate.update(sql, sps);
  67. }
  68. catch(Exception e){
  69. e.printStackTrace();
  70. }
  71. return num;
  72. }
  73. @Override
  74. public int delHouse(int id) {
  75. String sql = "update `house` set status=0 where id=:id";
  76. MapSqlParameterSource sps = new MapSqlParameterSource();
  77. sps.addValue("id",id);
  78. int num = 0;
  79. try{
  80. num = namedParameterJdbcTemplate.update(sql, sps);
  81. }catch (Exception e){
  82. e.printStackTrace();
  83. }
  84. return num;
  85. }
  86. @Override
  87. public House getById(int id) {
  88. String sql = "SELECT * FROM `house` WHERE id = :id ";
  89. MapSqlParameterSource sps = new MapSqlParameterSource();
  90. sps.addValue("id",id);
  91. List<House> list = null;
  92. try{
  93. list = namedParameterJdbcTemplate.query(sql, sps,
  94. new BeanPropertyRowMapper<>(House.class));
  95. }catch (Exception e){
  96. e.printStackTrace();
  97. }
  98. if(list != null && list.size()>0) return list.get(0);
  99. return null;
  100. }
  101. @Override
  102. public List<House> queryPage(String sqlx, int page, int rows) {
  103. int start = (page - 1) * rows;// 每页的起始下标
  104. String sql = "SELECT * FROM `house` WHERE status=1 "+sqlx+" ORDER BY id DESC limit :start,:rows ";
  105. MapSqlParameterSource sps = new MapSqlParameterSource();
  106. sps.addValue("start", start);
  107. sps.addValue("rows", rows);
  108. List<House> list = namedParameterJdbcTemplate.query(sql, sps,
  109. new BeanPropertyRowMapper<>(House.class));
  110. if (list != null && list.size() > 0) return list;
  111. return null;
  112. }
  113. @Override
  114. public int queryTotal(String sqlx) {
  115. String sql = "SELECT count(*) FROM`house` where status=1 "+sqlx;
  116. MapSqlParameterSource sps = new MapSqlParameterSource();
  117. return namedParameterJdbcTemplate.queryForInt(sql, sps);
  118. }
  119. @Override
  120. public List<House> queryList(String sqlx) {
  121. String sql = "SELECT * FROM `house` WHERE status=1 "+sqlx;
  122. List<House> list = null;
  123. try{
  124. list = namedParameterJdbcTemplate.query(sql, new BeanPropertyRowMapper<>(House.class));
  125. }catch (Exception e){
  126. e.printStackTrace();
  127. }
  128. if(list != null && list.size()>0) return list;
  129. return null;
  130. }
  131. }