userdao.java

该源码包括了基于J2EE的数据持久层设计,设计中使用了DAO,Service,等模式,并在Struts下进行了测试．

package org.conference.datapersistence.Dao;

import java.io.Serializable;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;

import javax.sql.DataSource;

import org.conference.datapersistence.Bo.UserVO;
import org.javawing.component.dao.DataAccessException;
import org.javawing.component.jdbc.core.RowCallbackHandler;
import org.javawing.component.jdbc.core.support.JdbcDaoSupport;

public class UserDao extends JdbcDaoSupport implements Serializable {
	private static final long serialVersionUID = 1L;

	public UserDao(DataSource dataSource) {
		this.setDataSource(dataSource);
	}

	public String doFindbyuserid(String userid) {
		return (String) this.getJdbcTemplate().queryForObject(
				"select upassword from user where uname='" + userid + "'",
				String.class);
	}

	public Object doFindbyuserName(final String name) {
		final UserVO user = new UserVO();
		String Query = "select uid,gender,email from user where uname='" + name
				+ "'";
		this.getJdbcTemplate().query(Query, new RowCallbackHandler() {
			public void processRow(ResultSet rs) throws SQLException {
				user.setUserid(rs.getInt("uid"));
				user.setName(name);
				user.setGender(rs.getString("gender"));
				user.setEmail(rs.getString("email"));
			}
		});
		return user;
	}

	public int doStore(UserVO user) throws DataAccessException {
		String storeQuery = null;
		storeQuery = "insert into `user`(uname,upassword,gender,email)values('"
				+ user.getName() + "','" + user.getPassword() + "','"
				+ user.getGender() + "','" + user.getEmail() + "')";
		return this.getJdbcTemplate().update(storeQuery);
	}

	public int doFindUseridbyName(String name) {
		String userid = (String) this.getJdbcTemplate()
				.queryForObject(
						"select uid from user where uname='" + name + "'",
						String.class);
		return Integer.parseInt(userid);
	}
	public String doFindUsernamebyUid(int userid) {
		String username = (String) this.getJdbcTemplate()
				.queryForObject(
						"select uname from user where uid=" + userid,
						String.class);
		return username;
	}

	public int doFindMaxuserid() {
		String userid = (String) this.getJdbcTemplate().queryForObject(
				"select max(uid) from user", String.class);
		return (Integer.parseInt(userid)) + 1;
	}

	public int doUpdatebyId(UserVO user) throws DataAccessException {
		String updateQuery = null;
		updateQuery = "update user set upassword='" + user.getPassword() +"',email='" + user.getEmail()
				+ "' where uid=" + user.getUserid();
		System.out.println("\n" + updateQuery);
		return this.getJdbcTemplate().update(updateQuery);
	}

	public String doFindusername(String name) {
		final UserVO user = new UserVO();
		String Query = "select uname from user where uname='" + name + "'";
		this.getJdbcTemplate().query(Query, new RowCallbackHandler() {
			public void processRow(ResultSet rs) throws SQLException {
				user.setName(rs.getString("uname"));
			}
		});
		return user.getName();
	}
}