persondaojdbc.java

Spring2.0宝典

package lee;

import java.sql.Statement;
import java.sql.ResultSet;
import java.util.List;
import java.util.ArrayList;
import java.sql.SQLException;

import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.support.JdbcDaoSupport;

/**
 * @author  yeeku.H.lee [e-mail]
 * @version  1.0
 * <br>Copyright (C), 2005-2008, yeeku.H.Lee
 * <br>This program is protected by copyright laws.
 * <br>Program Name:
 * <br>Date: 
 */
public class PersonDaoJdbc extends JdbcDaoSupport implements PersonDao
{

	public int createPerson(PersonBean p)
	{
		Object[] args = {p.getName() , new Integer(p.getAge()) };
		return getJdbcTemplate().update("insert into person_test(p_name,p_age) values(?,?)", args );
	}
	public PersonBean getPerson(int id)
	{
		Object[] args = {new Integer(id)};
		return (PersonBean)getJdbcTemplate().queryForObject("select p_name,p_age from person_test where p_id = ?", args, new PersonRowMapper());
	}
	public List findPersonsByName(String name)
	{
		return getJdbcTemplate().query("select * from person_test where p_name like '%" + name +"%'" , new PersonRowMapper());
	}
	public int deletePerson(int id)
	{
		Object[] args = {new Integer(id)};
		return getJdbcTemplate().update("delete from person_test where p_id = ", args);
	}
	public int deletePersonsByAge(int startAge , int EndAge)
	{
		Object[] args = {new Integer(startAge),new Integer(EndAge)};
		return getJdbcTemplate().update("delete from person_test where p_age between ? and ? " ,args);
	}
	public int updatePerson(PersonBean pb)
	{
		Object[] args = {pb.getName(),new Integer(pb.getAge()),new Integer(pb.getId())};
		return getJdbcTemplate().update("update person_test set p_name = ?, p_age=? where p_id =? " ,args);
	}

	private class PersonRowMapper implements RowMapper
	{
		public Object mapRow(ResultSet rs, int rowNumber) throws SQLException
		{
			PersonBean pb = new PersonBean(rs.getString("p_name"),rs.getInt("p_age"));
			return pb;
		}
	}
}