usersdao.java

在本系统中

package jin.dao;

import java.sql.*;
import java.util.*;

import jin.bean.*;
import jin.config.*;
import jin.conn.*;

public class UsersDAO
{
	private Connection conn=null;
	
	//查询
	public ArrayList excuteQuery(String sql)
	{
		Statement stat=null;
		ResultSet rs=null;
		ArrayList logins=new ArrayList(20);
		LoginBean loginBean=null;
		
		try
		{
			if(conn==null)
			{
				conn=new DBConnection().getConnection(new TextParser());
				if(conn==null)
				{
					System.out.println("连接失败");
				}
				
				else
					System.out.println("连接成功");	
			}
			stat=conn.createStatement(ResultSet.TYPE_FORWARD_ONLY,ResultSet.CONCUR_READ_ONLY);
			rs=stat.executeQuery(sql);
			
			while(rs.next())
			{
				loginBean=new LoginBean();
				//userBean.setUserID(rs.getString(0));
 				loginBean.setId(rs.getString("id"));
				loginBean.setPassword(rs.getString("password"));
				loginBean.setRole(Integer.parseInt(rs.getString("role")));
				loginBean.setDelRecord(rs.getString("delRecord"));
				logins.add(loginBean);
							
			}			
		}
		
		catch(SQLException sqle)
		{
			sqle.printStackTrace();
		}
		
		return logins;
	}
	
	//增加
	public boolean insert(String sql)
	{
		Statement stat=null;
		int returnValue=0;
		
		try
		{
			if(conn==null)
			{
				conn=new DBConnection().getConnection(new TextParser());
			}
			stat=conn.createStatement();
			returnValue=stat.executeUpdate(sql);
			
		}
		catch(SQLException sqle)
		{
			sqle.printStackTrace();
		}
		
		if(returnValue>0)
		{
			return true;
		}
		else
		{
			return false;
		}
	}
	
	//删除
	public boolean delete(String sql)
	{
		return insert(sql);
	}
	
	//更新
	public boolean update(String sql)
	{
		return insert(sql);
	}
	
	public boolean update(String id,String password,int role,String flag)
	{
		PreparedStatement ps=null;
		boolean returnValue=false;
		String sql=null;
		
		sql="update login set id=? where password=? where role=? where flag=?";		
		try
		{
			if(conn==null)
			{
				conn=new DBConnection().getConnection(new TextParser());
			}
			ps=conn.prepareStatement(sql);
			ps.setString(1,id);
			ps.setString(2,password);
			ps.setInt(3,role);
			returnValue=ps.execute();
		}
		catch(SQLException sqle)
		{
			sqle.printStackTrace();
		}
				
		return !returnValue;		
	}
	
	/*
	public boolean search(String sql)
	{
		Statement stat=null;
		
		try
		{
			if(conn==null)
			{
				conn=new DBConnection().getConnection(new TextParser());
			}
			stat=conn.createStatement();
			
		}
		catch(SQLException sqle)
		{
			sqle.printStackTrace();
		}
		finally
		{
			try
			{
				return stat.execute(sql);			
			}
			catch(SQLException sqle)
			{
				sqle.printStackTrace();
			}
		}
		return stat.execute(sql);					
	}
	*/
}