import java.util.List;

/***
 * 基本接口
 *
 * @author xyq
 * @param
 *
 */
public interface BaseDaoInf {

 /***
  * 查询接口
  *
  * @return
  */
 public List find(String sql, Object[] parameters, Class cl);

 /***
  *  添加，更新，删除接口
  * @param sql
  * @param id
  * @param cl
  * @return
  */
 public int addOrUpdateOrDelete(String sql,Object[] parameters, Class cl);
}

import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;

import javax.annotation.Resource;

import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.PreparedStatementSetter;

import com.xyq.all.dao.inf.BaseDaoInf;

public class BaseDaoImpl implements BaseDaoInf {

 /**
  *
  */
 private static final long serialVersionUID = 1L;
 /***
  * 数据库连接对象
  */
 @Resource(name = "jdbcTemplate")
 private JdbcTemplate jt;

 /***
  * 查询接口
  */

 @Override
 public List find(String sql, Object[] parameters, Class cl) {

  List resultList = null;
  try {
   if (parameters != null && parameters.length > 0)
    resultList = jt.query(sql, parameters,
      new BeanPropertyRowMapper(cl));
   else
    // BeanPropertyRowMapper是自动映射实体类的
    resultList = jt.query(sql, new BeanPropertyRowMapper(cl));
  } catch (Exception e) {
   e.printStackTrace();
  }
  return resultList;
 }

 /***
  * 添加，更新，删除的实现，返回1,0,-1
  */
 @Override
 public int addOrUpdateOrDelete(String sql, final Object[] parameters,
   Class cl) {

  int num = 0;
  try {
   if (parameters == null || parameters.length == 0)
    num = jt.update(sql);
   else
    num = jt.update(sql, new PreparedStatementSetter() {

     @Override
     public void setValues(PreparedStatement ps)
       throws SQLException {

      for (int i = 0; i < parameters.length; i++)
       ps.setObject(i + 1, parameters[i]);
     }
    });
  } catch (Exception e) {
   e.printStackTrace();
   num = -1;
  }
  return num;
 }
}

/**
 * 用户操作接口
 * @author xyq
 *
 */
public interface UserInfoDaoInf {

 /***
  * 查询是否有用户
  * @param user
  * @return
  */
 public UserInfo findUser(UserInfo user);

 /***
  * 删除用户
  * @param user
  * @return
  */
 public int deleteUserById(UserInfo user);

 /***
  * 添加用户
  * @param user
  * @return
  */
 public int addUser(UserInfo user);

 /***
  * 更新用户
  * @param user
  * @return
  */
 public int updateUser(UserInfo user);
}

import java.util.List;

import org.springframework.stereotype.Repository;

import com.xyq.all.dao.inf.UserInfoDaoInf;
import com.xyq.all.entity.UserInfo;

@Repository("userDao")
public class UserInfoDaoImpl extends BaseDaoImpl implements
  UserInfoDaoInf {

 /***
  * 查找用户信息
  */
 @Override
 public UserInfo findUser(UserInfo user) {

  List list = null;
  String sql = "select * from userInfo where username=? and password =? ";
  list = super.find(sql,
    new String[] { user.getUserName(), user.getPassword() },
    UserInfo.class);
  if (list != null && list.size() > 0)
   return list.get(0);
  return null;
 }

 /***
  * 删除用户
  */
 @Override
 public int deleteUserById(UserInfo user) {

  String sql = "delete from userInfo where userid = ?";
  return super.addOrUpdateOrDelete(sql, new Integer[] { user.getUserId() },
    UserInfo.class);
 }

 /***
  * 添加用户
  */
 @Override
 public int addUser(UserInfo user) {

  String sql = "insert into userInfo values(null,?,?,?)";

  return super.addOrUpdateOrDelete(
    sql,
    new Object[] { user.getUserName(), user.getPassword(),
      user.getSecondPassword() }, UserInfo.class);
 }

 /***
  * 更新用户
  */
 @Override
 public int updateUser(UserInfo user) {

  String sql = "update userInfo set userName=?,password = ?,secondPassword = ? where userid=?";
  return super.addOrUpdateOrDelete(
    sql,
    new Object[] { user.getUserName(), user.getPassword(),
      user.getSecondPassword(), user.getUserId() },
    UserInfo.class);
 }