Spring3 JDBC 通用DAO封装2 dao层 后续不断更新
public interface UsersDao extends BaseDao<Users, Long> {
// 添加一个用户
public Users addUser(final Users users);
// 显示全部用户
public List<Users> getUsers(Pager pager);
// 按ID查找某个用户
public Users getUserByid(Object value);
// 按某个字段查找用户 返回一个用户
public Users getUserByColunm(String columnName, Object value);
// 按某个字段查找用户 返回多个用户
public List<Users> getUserByColunmList(String columnName, Object value);
/**
* 更新数据的方法
*
* @param user
*/
public void update(Users user);
/**
* 删除数据的方法
*
* @param id
*/
public void delete(String id);
public int countAll();
}
package com.dahua.admin.users.dao;
/**
* 用户管理
* User: szj
* Date: 2012-04-01
* Time: 14:09:44
*/
import java.util.List;
import org.springframework.stereotype.Repository;
import com.dahua.core.BaseDaoImpl;
import com.dahua.core.page.LimitPageHepler;
import com.dahua.core.page.Pager;
import com.dahua.admin.users.vo.Users;
@Repository("usersDao")
public class UsersDaoImpl extends BaseDaoImpl<Users, Long> implements UsersDao{
//添加一个用户
public Users addUser(final Users users){
users.setId(saveAndReturnKey(users).intValue());
return users;
}
//显示全部用户
public List<Users> getUsers(Pager pager) {
//return getJdbcTemplate().query("select * from users", new BeanPropertyRowMapper(Users.class));
String sql="select * from users";
//PagerHepler pagerHepler=new PagerHepler();
sql=LimitPageHepler.getLimitPage(sql, pager);
//sql=pagerHepler.getPageSQL(sql,pager.getCurrentPage(),pager.getPageSize());
return getList(sql,Users.class);
}
//按ID查找某个用户
public Users getUserByid(Object value) {
return (Users) findByid(Users.class,value);
}
//按某个字段查找用户 返回一个用户
public Users getUserByColunm(String columnName, Object value) {
return (Users) findBycolumnName(Users.class,columnName,value);
}
//按某个字段查找用户 返回多个用户
public List<Users> getUserByColunmList(String columnName, Object value) {
return findBycolumnNameList(Users.class,columnName,value);
}
/**
* 更新数据的方法
* @param user
*/
public void update(Users user){
String sql = "update suser set LOGINNAME=?,LOGINPASS=? where id=?";
update(sql, user);
//getJdbcTemplate().update(sql,user);
}
/**
* 删除数据的方法
* @param id
*/
public void delete(String id){
String sql = "delete from users where id=?";
//update(sql, id);
//getJdbcTemplate().update(sql, id);
}
private static final String COUNT_ALL_SQL = "select count(*) from users";
public int countAll() {
return getJdbcTemplate().queryForInt(COUNT_ALL_SQL);
}
}