manager_ptdao.java

数学网

package math.users.usermanager.dao;

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

import javax.sql.DataSource;

import math.dao.DAO;
import math.users.usermanager.model.User;

public class Manager_ptDAO extends DAO {

	public Manager_ptDAO(DataSource ds) {
		super(ds);
	}
	public  List userList(int offset, int limit)throws SQLException{
		  
		  List list=new ArrayList();		  
		  Connection conn =null;
		  PreparedStatement  pstmt = null;
		  ResultSet rs =null;
		 try{
			 conn =ds.getConnection();
			 String sql= "select * " +
			 		"FROM users where users_grade=1";
			 pstmt =conn.prepareStatement(sql,
					 ResultSet.TYPE_SCROLL_INSENSITIVE,
	                 ResultSet.CONCUR_READ_ONLY);
			 
			 rs =pstmt.executeQuery();
			 
			 if (offset > 0) {
			      rs.absolute(offset);
			  }
			  int recCount = 0;
			  while ((recCount++ < limit) && rs.next()) {
			      User user = new User();
			      user.setId(rs.getInt("id"));
			      user.setReal_name(rs.getString("real_name"));
			      user.setUsername(rs.getString("username"));
			      user.setUsers_phone(rs.getString("users_phone"));
			      user.setUsers_email(rs.getString("users_email"));
			      if(rs.getInt("users_grade")==1)
			    	  user.setUsers_grade("普通用户");
			      list.add(user);
			  }
			 close(rs);
			 close(pstmt);
		 }catch(SQLException e){
			 close(rs);
			 close(pstmt);
			 rollback(conn);
			 e.printStackTrace();
		 }finally{
			 close(conn);
		 }
		  
		  
		  return list;
	  }
	public void deleteUsers(String[] id)
	{
		 Connection conn =null;
		  PreparedStatement  pstmt = null;
		  try{
			 conn =ds.getConnection();
			 String sql= "delete from users where id=?";
			 for(int i=0;i<id.length;i++){
			 pstmt =conn.prepareStatement(sql,
					 ResultSet.TYPE_SCROLL_INSENSITIVE,
	                 ResultSet.CONCUR_READ_ONLY);
			 pstmt.setInt(1,Integer.parseInt(id[i]));
			 pstmt.executeUpdate();			 
			 
			 
			 close(pstmt);
			 }
		 }catch(SQLException e){
			 
			 close(pstmt);
			 rollback(conn);
			 e.printStackTrace();
		 }finally{
			 close(conn);
		 }
	}
}