userdaoimp.java

struts标签库,中英文版,数据添删改查,验证等功能,自己写的.

package com.jackie.daoImp;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import com.jackie.beans.User;
import com.jackie.dao.UserDAO;
import com.jackie.util.DBConn;
import com.jackie.util.PageDivBean;

public class UserDAOImp implements UserDAO {
	Connection conn = null;
	Statement stmt = null;
	ResultSet rs = null;
	PageDivBean pdb = null;
	public int num=0;
	public UserDAOImp() {
		System.out.println("userdaoimp ....");
		conn = new DBConn().getConn();
	}

	@Override
	public void save(User user) {
		// TODO Auto-generated method stub
		try {
			System.out.println("save...");
			stmt = conn.createStatement();
			String sql = "insert into users(userName,password,email,city,address,postcode) values('"
					+ user.getUserName()
					+ "','"
					+ user.getPassword()
					+ "'"
					+ ",'"
					+ user.getEmail()
					+ "','"
					+ user.getCity()
					+ "','"
					+ user.getAddress() + "','" + user.getPostcode() + "')";
			stmt.execute(sql);
			System.out.println("save ok");
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

	@Override
	public List getAll() {
		// TODO Auto-generated method stub
		List<User> list = null;
		User user = null;
		try {
			stmt = conn.createStatement();
			String sql = "select * from users";
			rs = stmt.executeQuery(sql);
			list = new ArrayList<User>();
			System.out.println("daoimp geAll...");
			while (rs.next()) {
				System.out.println("username=" + rs.getString("userName"));
				user = new User(rs.getInt(1), rs.getString("userName"), rs
						.getString("city"), rs.getString("postcode"), rs
						.getString("address"), rs.getString("email"), rs
						.getString("password"));
				list.add(user);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}

	@Override
	public User findById(int userid) {
		User user = null;
		try {
			stmt = conn.createStatement();
			String sql = "select * from users where userid=" + userid;
			rs = stmt.executeQuery(sql);
			if (rs.next()) {
				user = new User(rs.getInt(1), rs.getString("userName"), rs
						.getString("city"), rs.getString("postcode"), rs
						.getString("address"), rs.getString("email"), rs
						.getString("password"));
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return user;
	}

	@Override
	public void update(User user) {
		// TODO Auto-generated method stub
		try {
			stmt = conn.createStatement();
			String sql = "update users set userName='" + user.getUserName()
					+ "'," + "password='" + user.getPassword() + "',"
					+ "email='" + user.getEmail() + "'," + "city='"
					+ user.getCity() + "'," + "address='" + user.getAddress()
					+ "'," + "postcode='" + user.getPostcode()
					+ "' where userid=" + user.getId();
			stmt.execute(sql);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	@Override
	public void delete(int id) {
		// TODO Auto-generated method stub
		try {
			stmt = conn.createStatement();
			String sql = "delete from users where userid=" + id;
			stmt.execute(sql);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			System.out.println("delete sucess!");
		}
	}

	public void close() {

		try {
			stmt.close();
			conn.close();

		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

	@Override
	public List findByParm(String tb_name, String tb_parm) {
		// TODO Auto-generated method stub
		List<User> list = null;
		User user = null;
		try {
			stmt = conn.createStatement();
			String sql = "select * from users where " + tb_name + " like '%"
					+ tb_parm + "%'";
			System.out.println("sql=" + sql);
			rs = stmt.executeQuery(sql);
			list = new ArrayList<User>();
			while (rs.next()) {
				System.out.println("username=" + rs.getString("userName"));
				user = new User(rs.getInt(1), rs.getString("userName"), rs
						.getString("city"), rs.getString("postcode"), rs
						.getString("address"), rs.getString("email"), rs
						.getString("password"));
				list.add(user);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}

	@Override
	public List getByPageAll(int reqPage) {
		// TODO Auto-generated method stub
		List<User> list = null;
		User user = null;
		pdb=new PageDivBean();
		pdb.setCon(conn);
		pdb.setReqPage(reqPage);
		pdb.setPageRecord(5);
		pdb.setTabName("users");
		rs = pdb.getRs();
		list = new ArrayList<User>();
		try {
			while (rs.next()) {
				System.out.println("username=" + rs.getString("userName"));
				user = new User(rs.getInt(1), rs.getString("userName"), rs
						.getString("city"), rs.getString("postcode"), rs
						.getString("address"), rs.getString("email"), rs
						.getString("password"));
				list.add(user);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		num=pdb.getTotalPages();
		return list;
	}

	@Override
	public int getpages() {
		// TODO Auto-generated method stub
		System.out.println("num= "+num);
		return num;
	}

}