people.java

dwr学习 dwr学习 dwr学习

package com.jack.dwr.simple;

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

/**
 * A container for a set of people
 * 
 * @author jackzhangyunjie
 */
public class People {
	private Connection conn;

	/**
	 * 构造函数，同时初始化建立与数据库的连接
	 */
	public People() {
		try {
			conn = DBConnection.getConnectionMySqlDB("3306", "jackdemo",
					"root", "root");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * 删除一个用户
	 * 
	 * @param person
	 *            要删除的用户
	 * 
	 */
	public void deletePerson(Person person) throws Exception {
		String sql = "delete from jackdemo1 where id=?";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setInt(1, person.getId());
		//更新数据库操作
		pstmt.executeUpdate();
		//关闭预编译和数据库连接
		pstmt.close();
		conn.close();
	}

	/**
	 * 更新用户信息
	 * @param person　要进行更新的用户对象
	 * @throws Exception
	 */
	public void updatePerson(Person person) throws Exception {
		String sql = "update jackdemo1 set name=?,age=?,address=? where id=?";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setString(1, person.getName());
		pstmt.setInt(2, person.getAge());
		pstmt.setString(3, person.getAddress());
		pstmt.setInt(4, person.getId());
		//更新数据库操作
		pstmt.executeUpdate();
		//关闭预编译和数据库连接
		pstmt.close();
		conn.close();
	}

	/**
	 * 得到全部的人员信息
	 * 
	 * @return 返回一个包含人员的List
	 * @throws SQLException
	 */
	@SuppressWarnings("unchecked")
	public List getAllPerson() throws SQLException {
		List list = new ArrayList();
		String sql = "select * from jackdemo1";
		Statement st = conn.createStatement();
		//查询数据库，得到所有人员信息
		ResultSet rs = st.executeQuery(sql);
		while (rs.next()) {
			Person person = new Person();
			person.setId(rs.getInt("id"));
			person.setName(rs.getString("name"));
			person.setAge(rs.getInt("age"));
			person.setAddress(rs.getString("address"));
			list.add(person);
		}
		return list;
	}

	/**
	 * 添加人员
	 * 
	 * @param person
	 *            要添加的人员的信息
	 */
	public void addPerson(Person person) throws Exception {
		String sql = "insert into jackdemo1(name,age,address) values(?,?,?)";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		//设置人员信息
		pstmt.setString(1, person.getName());
		pstmt.setInt(2, person.getAge());
		pstmt.setString(3, person.getAddress());
		//更新数据库操作
		pstmt.executeUpdate();
		//关闭预编译和数据库连接
		pstmt.close();
		conn.close();
	}

}