useroperation.java

连接数据库并实现一系列的增删改查等等

package news;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;

import common.NewsConnection;
import entity.UserEntity;

public class UserOperation 
{
	public boolean addUser(UserEntity entity1)
	{
		boolean bool=false;
		try
		{
			NewsConnection newsCon=new NewsConnection();
			Connection con=newsCon.getConnection();			
			Statement stUser=con.createStatement();			
			int row=stUser.executeUpdate("insert into NEWSUSER values('"+entity1.getUserName()+"','"+entity1.getUserPwd()+"')");
			if(row>0)
			{
				bool=true;
			}
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
		return bool;
	}
	public boolean deleteUser(String id)
	{
		boolean bool=false;
		try
		{
			NewsConnection newsCon=new NewsConnection();
			Connection con=newsCon.getConnection();			
			Statement stUser=con.createStatement();			
			int row=stUser.executeUpdate("delete from NEWSUSER where userid="+id+"");
			if(row>0)
			{
				bool=true;
			}
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
		return bool;
	}
	public boolean updateUser(UserEntity entity1)
	{
		boolean bool=false;
		try
		{
			NewsConnection newsCon=new NewsConnection();
			Connection con=newsCon.getConnection();			
			Statement stUser=con.createStatement();			
			int row=stUser.executeUpdate("update newsuser set username='"+entity1.getUserName()+"',userpwd='"+entity1.getUserPwd()+"' where userid="+entity1.getId()+"");
			if(row>0)
			{
				bool=true;
			}
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
		return bool;
	}
	public int getRows()
	{
	
		int row=0;
		try
		{
			NewsConnection newsCon=new NewsConnection();
			Connection con=newsCon.getConnection();			
			Statement stUser=con.createStatement();			
			ResultSet rs=stUser.executeQuery("select count(*) from newsuser");
			if(rs.next())
			{
				row=rs.getInt(1);
			}
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
		return row;
	}
	public String[][] selectUser()
	{
		String [][]content=new String[this.getRows()][3];
		try
		{
			NewsConnection newsCon=new NewsConnection();
			Connection con=newsCon.getConnection();			
			Statement stUser=con.createStatement();	
			ResultSet rs=stUser.executeQuery("select * from newsuser");
			int index=0;
			while(rs.next())
			{
				content[index][0]=rs.getString(1);
				content[index][1]=rs.getString(2);
				content[index][2]=rs.getString(3);
				               
				++index;
			}
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
		return content;
	}

}