dbaselt.java

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

/*
 * 创建日期 2004-9-26
 *
 * 更改所生成文件模板为
 * 窗口 > 首选项 > Java > 代码生成 > 代码和注释
 */
package javabean;
import java.sql.*;
import java.util.Vector;
/**
 * @author jk011
 *
 * 更改所生成类型注释的模板为
 * 窗口 > 首选项 > Java > 代码生成 > 代码和注释
 */
public class DBaseLT {
	private Connection con=null;
	private Statement sql=null;
	private ResultSet rs=null;
	public DBaseLT(Connection con)
	{
		this.con=con;
	}
	public Vector getLuntan1DB(int page,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((page-1)*pagesize+1);
			while(count>0)
			{
				Luntan1DB DBase=new Luntan1DB();
				DBase.setCode(rs.getInt("code"));
				DBase.setUuid(rs.getString("uuid"));
				DBase.setTitle(rs.getString("title"));
				DBase.setMessage(rs.getString("message"));
				DBase.setPubdate(rs.getString("pubdate"));
				DBase.setPhoto(rs.getString("photo"));
				DBase.setHuifu(rs.getInt("huifu"));
				DBase.setLiulan(rs.getInt("liulan"));
				DBase.setUpload(rs.getString("upload"));
				DBase.setGrant1(rs.getInt("grant1"));
				DBase.setQuanxuan(rs.getString("quanxuan"));
				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 getLastPubdate(int code)
	{
		String str="select pubdate from luntan2 where code="+code+" order by id desc";
		String date=null;
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
			if(rs.next())
				date=rs.getString("pubdate");
			else
				date="no";
			if(rs!=null)
				rs.close();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException e){return "no";}
		return date;
	}
	public String getLastUuid(int code)
	{
		String str="select uuid from luntan2 where code="+code+" order by id desc";
		String name=null;
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
			if(rs.next())
				name=rs.getString("uuid");
			else
				name="no";
			if(rs!=null)
				rs.close();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException e){return "no";}
		return name;
	}
	public int getMaxcode()
	{	
		int count=0;
		String str="select code from luntan1 order by code desc";
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
			if(rs.next())
				count=rs.getInt("code");
			else 
				count=0;
			if(rs!=null)
				rs.close();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException e){}
		return count;
	}
	public int getMaxid(int code)
	{	
		int count=0;
		String str="select id from luntan2 where code="+code+" order by id desc";
			try
			{
				sql=con.createStatement();
				rs=sql.executeQuery(str);
				if(rs.next())
					count=rs.getInt("id");
				else 
					count=0;
				if(rs!=null)
					rs.close();
				if(sql!=null)
					sql.close();
			}
			catch(SQLException e){}
			return count;
		}
	public void Insert(String str)
	{
		try
		{
			sql=con.createStatement();
			sql.executeUpdate(str);
			con.commit();
			if(rs!=null)
				rs.close();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException ex)
		{
			try
			{
				con.rollback();
			}
			catch(Exception e){}
		}
	}
	public void Updateliulan(int code)
	{
		String str="update luntan1 set liulan=liulan+1 where code="+code;
		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 Updatehuifu(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 Vector getLuntan2DB(int code)
	{
		Vector vec=new Vector();
		String str="select * from luntan2 where code="+code+" order by id";
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
			while(rs.next())
			{
				Luntan2DB luntandb=new Luntan2DB();
				luntandb.setId(rs.getInt("id"));
				luntandb.setUuid(rs.getString("uuid"));
				luntandb.setMessage(rs.getString("message"));
				luntandb.setPubdate(rs.getString("pubdate"));
				luntandb.setPhoto(rs.getString("photo"));
				luntandb.setUpload(rs.getString("upload"));
				luntandb.setQuanxuan(rs.getString("quanxuan"));
				vec.add(luntandb);
			}
			if(rs!=null)
				rs.close();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException ex){return null;}
		return vec;
	}
	public String Query(String str)
	{
		String path="no";
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
			if(rs.next())
				path=rs.getString("upload");
			if(rs!=null)
				rs.close();
			if(sql!=null)
				sql.close();
		}
		catch(SQLException ex){}
		return path;
	}
	public ResultSet querylook(String str)
	{
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
		}
		catch(SQLException e){}
		return rs;
	}
	public MemberDB QueryMember(String uuid)
	{
		MemberDB member=new MemberDB();
		String str="select * from member where uuid='"+uuid+"'";
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
			while(rs.next())
			{
				
				member.setRname(rs.getString("rname"));
				member.setCompany(rs.getString("company"));
				member.setUser_address(rs.getString("user_address"));
				member.setUser_post_code(rs.getString("user_post_code"));
				member.setUser_province(rs.getString("user_province"));
				member.setUser_city(rs.getString("user_city"));
				member.setUser_mobileph(rs.getString("user_mobileph"));
				member.setUser_homeph(rs.getString("user_homeph"));
				member.setUser_officeph(rs.getString("user_officeph"));
				member.setEmail(rs.getString("email"));
			}
		}
		catch(SQLException e)
		{
			return null;
		}
		return member;
	}
	public AdminDB QueryAdmin(String uuid)
	{
		AdminDB admin=new AdminDB();
		String str="select am_rname,email from admin where am_uid='"+uuid+"'";
		try
		{
			sql=con.createStatement();
			rs=sql.executeQuery(str);
			while(rs.next())
			{
				
				admin.setAm_rname(rs.getString("am_rname"));
				admin.setEmail(rs.getString("email"));
			}
		}
		catch(SQLException e)
		{
			return null;
		}
		return admin;
	}
	
}