database_suggest.java

这个程序是花了好几十万请人开发的

/*
 * 创建日期 2004-9-26
 *
 * 更改所生成文件模板为
 * 窗口 > 首选项 > Java > 代码生成 > 代码和注释
 */
package javabean;
import java.sql.*;
import java.util.Vector;
/**
 * @author jk011
 *
 * 更改所生成类型注释的模板为
 * 窗口 > 首选项 > Java > 代码生成 > 代码和注释
 */
public class Database_suggest {
	Connection con=null;
	Statement sql=null;
	ResultSet rs=null;
	public Database_suggest(Connection con)
	{
		this.con=con;
	}
	public Vector getData(int code,int pagesize,String str)
	{
		int count=pagesize;
		Vector vec=new Vector();
		try
		{
			sql=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
			rs=sql.executeQuery(str);
			rs.absolute((code-1)*pagesize+1);
			while(count>0)
			{
				HYJYdbase_suggest DBase=new HYJYdbase_suggest();
				DBase.setId(rs.getInt("id"));
				DBase.setUuid(rs.getString("uuid"));
				DBase.setPubdate(rs.getString("pubdate"));
				DBase.setTitle(rs.getString("title"));
				DBase.setFlag(rs.getString("flag").trim());
				vec.add(DBase);
				count--;
				if(!rs.next())
					break;
			}
			if(rs!=null)
				rs.close();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException ex){return null;}
		return vec;
	}
	
	public String getMessage(int id)
	{
		String message=null;
		String str="select message from HYJY where id="+id;
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
			if(rs.next())
				message=rs.getString("message");
			if(rs!=null)
				rs.close();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException ex){}
		return message;
	}
	
	public String getTitle(int id)
	{
		String title=null;
		String str="select title from HYJY where id="+id;
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
			if(rs.next())
				title=rs.getString("title");
			if(rs!=null)
				rs.close();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException ex){}
		return title;
	}

	public int getMemberID(int id)
	{	
		int MemberID=0;
		String str="select id from MEMBER where uuid =(select uuid from HYJY where id="+id+")";
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
			if(rs.next())
				MemberID=rs.getInt("id");
			if(rs!=null)
				rs.close();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException ex){}
		return MemberID;
	}
	public boolean InsertData(String str)
	{
		try
		{
			sql=con.createStatement();
			sql.executeUpdate(str);
			con.commit();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException ex)
		{
			try
			{
				con.rollback();
			}
			catch(Exception e){}
			return false;
		}
		return true;
	}
	public int getMaxID(String str)
	{
		int max=0;
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
			if(rs.next())
				max=rs.getInt("id");
			if(rs!=null)
				rs.close();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException e){}
		return max;
	}
	public void updateFlag(String str)
	{
		try
		{
			sql=con.createStatement();
			sql.executeUpdate(str);
			con.commit();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException ex)
		{
			try
			{
				con.rollback();
			}
			catch(Exception e){}
		}
	}
	public void Delete(String str)
	{
		try
		{
			sql=con.createStatement();
			sql.executeUpdate(str);
			con.commit();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException ex)
		{
			try
			{
				con.rollback();
			}
			catch(Exception e){}
		}
	}
}