XxlJobInfoDaoImpl.java 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374
  1. package com.xxl.job.dao.impl;
  2. import java.util.HashMap;
  3. import java.util.List;
  4. import javax.annotation.Resource;
  5. import org.mybatis.spring.SqlSessionTemplate;
  6. import org.springframework.stereotype.Repository;
  7. import com.xxl.job.core.model.XxlJobInfo;
  8. import com.xxl.job.dao.IXxlJobInfoDao;
  9. /**
  10. * job info
  11. * @author xuxueli 2016-1-12 18:03:45
  12. */
  13. @Repository
  14. public class XxlJobInfoDaoImpl implements IXxlJobInfoDao {
  15. @Resource
  16. public SqlSessionTemplate sqlSessionTemplate;
  17. @Override
  18. public List<XxlJobInfo> pageList(int offset, int pagesize, String jobGroup, String jobName) {
  19. HashMap<String, Object> params = new HashMap<String, Object>();
  20. params.put("offset", offset);
  21. params.put("pagesize", pagesize);
  22. params.put("jobGroup", jobGroup);
  23. params.put("jobName", jobName);
  24. return sqlSessionTemplate.selectList("XxlJobInfoMapper.pageList", params);
  25. }
  26. @Override
  27. public int pageListCount(int offset, int pagesize, String jobGroup, String jobName) {
  28. HashMap<String, Object> params = new HashMap<String, Object>();
  29. params.put("offset", offset);
  30. params.put("pagesize", pagesize);
  31. params.put("jobGroup", jobGroup);
  32. params.put("jobName", jobName);
  33. return sqlSessionTemplate.selectOne("XxlJobInfoMapper.pageListCount", params);
  34. }
  35. @Override
  36. public int save(XxlJobInfo info) {
  37. return sqlSessionTemplate.insert("XxlJobInfoMapper.save", info);
  38. }
  39. @Override
  40. public XxlJobInfo load(String jobGroup, String jobName) {
  41. HashMap<String, Object> params = new HashMap<String, Object>();
  42. params.put("jobGroup", jobGroup);
  43. params.put("jobName", jobName);
  44. return sqlSessionTemplate.selectOne("XxlJobInfoMapper.load", params);
  45. }
  46. @Override
  47. public int update(XxlJobInfo item) {
  48. return sqlSessionTemplate.update("XxlJobInfoMapper.update", item);
  49. }
  50. @Override
  51. public int delete(String jobGroup, String jobName) {
  52. HashMap<String, Object> params = new HashMap<String, Object>();
  53. params.put("jobGroup", jobGroup);
  54. params.put("jobName", jobName);
  55. return sqlSessionTemplate.update("XxlJobInfoMapper.delete", params);
  56. }
  57. }