userdaoimpl.java

j2ee程序。 spring、xml、 实现增加内容选项。

package com.gc.dao.impl;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.gc.action.User;
import com.gc.dao.UserDAO;
import com.gd.jdbc.impl.GdDbCommon;

public class UserDAOImpl extends GdDbCommon implements UserDAO {
	/**
	 * 构造函数
	 * @param conn
	 */
	public UserDAOImpl(Connection conn) {
		super(conn);
	}
	/**
	 * 根据Object实现新增
	 */
	public int createUser(User user) throws SQLException{
		String sql = "insert into user (username, password) values(?, ?)";
		this.PreparedStatement(sql);
		this.setString(1, user.getUsername());
		this.setString(2, user.getPassword());
		return this.executeUpdate();
	}
	/**
	 * 根据Object实现修改
	 */
	public int updateUser(User user) throws SQLException {
		String sql = "update user set password = ? where username = ? ";
		this.PreparedStatement(sql);
		this.setString(1, user.getPassword());
		this.setString(2, user.getUsername());
		return this.executeUpdate();
	}
	/**
	 * 根据Object实现删除
	 */
	public int deleteUser(User user)  throws SQLException{
		String sql = "delete from user where username = ?";
		this.PreparedStatement(sql);
		this.setString(1, user.getUsername());
		return this.executeUpdate();
	}
	/**
	 * 根据id查询Object
	 */
	public User queryUser(int id) throws SQLException{
		String sql = "select * from user where id = ?";
		this.PreparedStatement(sql);
		this.setInt(1, id);
		return (User)this.queryObj();
	}
	/**
	 * 根据Object实现批量新增
	 */
	public int createListUser(List list) throws SQLException{
		String sql = "insert into user (username, password) values(?, ?)";
		this.PreparedStatement(sql);
		User user = null;
		int counts = 0;
		for (int i = 0; list != null && list.size() > i; i++) {
			user = (User)list.get(i);
			this.setString(1, user.getUsername());
			this.setString(2, user.getPassword());
			counts += this.executeUpdate();
		}
		
		return counts;
	}
	
	/**
	 * 根据Object实现批量新增,使用batch方式
	 */
	public int[] createBatchListUser(List list) throws SQLException{
		String sql = "insert into user (username, password) values(?, ?)";
		this.PreparedStatement(sql);
		User user = null;
		int counts = 0;
		for (int i = 0; list != null && list.size() > i; i++) {
			user = (User)list.get(i);
			this.setString(1, user.getUsername());
			this.setString(2, user.getPassword());
			this.addBatch();
		}
		return this.executeBatch();
	}
}