userdaoimpl.java

来自「Spring企业级开发下......电子书籍..............」· Java 代码 · 共 56 行

package com.baobaotao.dao.jdbc;

import java.sql.ResultSet;
import java.sql.SQLException;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowCallbackHandler;

import com.baobaotao.dao.UserDao;
import com.baobaotao.domain.User;

public class UserDaoImpl implements UserDao {

	private JdbcTemplate jdbcTemplate;

	public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
		this.jdbcTemplate = jdbcTemplate;
	}

	public int getMatchCount(String userName, String password) {
		String sqlStr = " SELECT count(*) FROM t_user "
				+ " WHERE user_name =? and password=? ";
		return jdbcTemplate.queryForInt(sqlStr,
				new Object[]{userName, password});
	}

	public User findUserByUserName(final String userName) {
		String sqlStr = " SELECT user_id,user_name,credits "
				+ " FROM t_user WHERE user_name =? ";
		final User user = new User();
		jdbcTemplate.query(sqlStr, new Object[]{userName},
				new RowCallbackHandler() {
					public void processRow(ResultSet rs) throws SQLException {
						user.setUserId(rs.getInt("user_id"));
						user.setUserName(userName);
						user.setCredits(rs.getInt("credits"));
					}
				});
		return user;
	}

	public void updateLoginInfo(User user) {
		String sqlStr = " UPDATE t_user SET last_visit=?,last_ip=?,credits=? "
				+ " WHERE user_id =?";
		jdbcTemplate.update(sqlStr, new Object[]{user.getLastVisit(),
				user.getLastIp(), user.getCredits(), user.getUserId()});
	}

	public void save(User user) {
		String sqlStr = " INSERT INTO t_user(user_id,user_name,password) "
				+ " VALUES(?,?,?)";
		jdbcTemplate.update(sqlStr, new Object[]{user.getUserId(),
				user.getUserName(), user.getPassword()});
	}
}