dbread.java

一个小型的BBS系统

package bean.readdb;
import java.sql.*;
import java.util.*;
import bean.condb.*;

public class DBRead {
	Statement stmt;
	ResultSet rs;
	Connection con;
	public DBRead(){
		Condb condb = new Condb();
		this.con = condb.con();
	}
	//读取框架
	public Vector DBReader(String state){
		Vector a = new Vector();
		String title ="";
		String url = "";
		String author = "";
		String lastupdate = "";
		String number = "";
		String count = "";
		String recount = ""; 
		int del = -1;
		int lv =0;
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select * from bbsform1 where state = '"+state+"'";//读取指定版块的帖子
			System.out.println(sql);
			rs = stmt.executeQuery(sql);
			if(rs==null){
				stmt.close();
				
				return a;
			}
			else{
				while(rs.next()){
					title = rs.getString(1);
					url = rs.getString(2);
					author = rs.getString(3);
					lastupdate = rs.getString(4);
					number = String.valueOf(rs.getInt(5));
					count = String.valueOf(rs.getInt(6));
					recount = String.valueOf(rs.getInt(7));
					del = rs.getInt(9);
					lv = rs.getInt(10);
					if(lv==0){//只有该贴为非置顶帖才加载
					
						a.addElement(title);//读取title
						a.addElement(url);//读取url(id)
						a.addElement(author);//读取author	
						a.addElement(lastupdate);//读取lastupdate
						
						a.addElement(number);//读取number
						a.addElement(count);//读取count
						a.addElement(recount);//读取recount
						a.addElement(String.valueOf(del));//读取del
						a.addElement(String.valueOf(lv));//读取lv
					}
				}
				stmt.close();
				System.out.println("读取到的信息长度为"+a.size()/8);
				return a;
			}
		}catch(SQLException s){
			System.out.println(s.toString()+"读取框架错误");
		}
		return a;
	}
	//读取置顶帖
	public Vector DBReader_top(String state){
		Vector a = new Vector();
		System.out.println("开始读取置顶帖");
		//按置顶级别分批读取置顶帖
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			for(int i=3; i>=1; i--){
				rs =null;
				String sql="select * from bbsform1 where state = '"+state+"' and level="+String.valueOf(i);//读取指定版块的帖子
				System.out.println(sql);
				rs = stmt.executeQuery(sql);
				if(rs!=null){
					while(rs.next()){
						a.addElement(rs.getString(1));//读取title
						a.addElement(rs.getString(2));//读取url(id)
						a.addElement(rs.getString(3));//读取author	
						a.addElement(rs.getString(4));//读取lastupdate
						String number = String.valueOf(rs.getInt(5));//读取
						a.addElement(number);//读取number
						a.addElement(String.valueOf(rs.getInt(6)));//读取count
						a.addElement(String.valueOf(rs.getInt(7)));//读取recount
						a.addElement(String.valueOf(rs.getInt(9)));//读取del
						a.addElement(String.valueOf(rs.getInt(10)));//读取level
					}
				}
				System.out.println("第"+i+"此读取置顶共获取"+a.size()/9+"个帖子");
			}
			stmt.close();	
			System.out.println("READ函数获取当前置顶贴总容量为"+a.size()/9);
			return a;
		}catch(SQLException s){
			System.out.println(s.toString()+"读取置顶错误");
		}
		return a;
	}
	
	//获取相应author--name
	public String DBReader_author(String id){
		String author="";
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select name from UserID where ID='"+id+"'";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				author = rs.getString(1);
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return author;
	}
	//获取相应id--author
	public String DBReader_id(String author){
		String id="";
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select ID from UserID where name='"+author+"'";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				id = rs.getString(1);
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return id;
	}
	//获取自己帖子的楼号
	public Vector DBRead_modifty(String id,String author){
		Vector a = new Vector();
		String sql="";
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			
			
			
			sql="select floor from formcontent where url ='"+id+"' and author='"+author+"'";
			rs = stmt.executeQuery(sql);
			if(rs==null){
				stmt.close();	
				return a;
			}
			else{
				while(rs.next()){
					a.addElement(String.valueOf(rs.getInt(1)));
				}
				stmt.close();
				
				return a;
			}
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return a;
	}
	//读取内容
	public Vector DBReader_Content(String id){
		Vector b = new Vector();
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			ResultSet rs1 ;
			String name="";
			int head =0;
			String sql="";
			
			sql="select author,title,floor,content,del,time from formcontent where url='"+id+"'";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				
				
				b.addElement(rs.getString(1));
				b.addElement(rs.getString(2));
				b.addElement(String.valueOf(rs.getInt(3)));
				b.addElement(rs.getString(4));
				b.addElement(String.valueOf(rs.getInt(5)));
				b.addElement(rs.getString(6));
				
				
				
			}
			
			stmt.close();
			
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return b;
	}
	//读取对应head
	public int DBReader_Head(String id,String floor){
		String name="";
		String sql="";
		int head =0;
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			sql = "select author from formcontent where url = '"+id+"' and floor="+floor;
			rs =stmt.executeQuery(sql);
			while(rs.next()){
				name = rs.getString(1);
			}
			sql = "select head from UserID where name ='"+name+"'";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				head = rs.getInt(1);
			}
			System.out.println("读取内容时获取head值为:"+head);
			
			
			
			
			
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return head;
	}
	
	//读取user
	public Vector DBReader_User(){
		Vector user = new Vector();
		String ID;
		
		int Control;
		String state;
		int post;
		int score;
		String name;
		
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select ID,Control,state,post,score,name from UserID";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				Control = rs.getInt(2);
				System.out.println(Control+rs.getString(1));
				if(Control!=2){
					user.addElement(rs.getString(1));
				//	user.addElement(rs.getString(2));
					user.addElement(String.valueOf(rs.getInt(2)));
					user.addElement(rs.getString(3));
					user.addElement(String.valueOf(rs.getInt(4)));
					user.addElement(String.valueOf(rs.getInt(5)));
					user.addElement(rs.getString(6));
				}
			}
			stmt.close();
			
		}catch(SQLException s){
			System.out.println(s.toString()+"用户读取出错");
		}
		return user;
	}
	//只读取用户ID
	public Vector DBReader_UserIDOnly(){
		Vector user = new Vector();
		String ID;
		
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select ID from UserID";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				ID = rs.getString(1);
				user.addElement(ID);
			}
			stmt.close();
			
		}catch(SQLException s){
			System.out.println(s.toString()+"用户读取出错");
		}
		return user;
	}
	//读取版块信息
	public Vector DBReader_State(){
		Vector state = new Vector();	
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select bbs_entry,name from bbsstate";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				state.addElement(rs.getString(1));
				state.addElement(rs.getString(2));
				
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return state;
	}
	//读取指定帖子
	public Vector DBReader_OnePost(String id,String floor){
		Vector post = new Vector();
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select * from formcontent where url='"+id+"' and floor = "+floor;
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				post.addElement(rs.getString(1));	//添加id
				post.addElement(rs.getString(2));	//添加作者
				post.addElement(rs.getString(3));	//添加题目
				post.addElement(String.valueOf(rs.getString(4)));
				post.addElement(rs.getString(5));
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return post;
	}
	
	//读取控制版主并判断版主是否是本版版主
	public String DBReader_Master(String id){
		
			String state = "";	
			try{
				stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
				String sql="select state from UserID where ID='"+id+"'";
				rs = stmt.executeQuery(sql);
				while(rs.next()){
					state = rs.getString(1);	
				}
				stmt.close();
			
			}catch(SQLException s){
				System.out.println(s.toString());
			}
			return state;
	}
	//读取内容image字段
	public int DBReader_Image(String id,String floor){
		int image=0;
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select image from formcontent where url='"+id+"' and floor ="+floor;
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				image = rs.getInt(1);	
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return image;
	}
	//读取post
	public int DBReader_Post(String name){
		int post=0;
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select post from UserID where name='"+name+"'";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				post = rs.getInt(1);	
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return post;
	}
	//读取score
	public int DBReader_Score(String name){
		int score=0;
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select score from UserID where name='"+name+"'";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				score = rs.getInt(1);	
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return score;
	}
	//读取版块
	public Vector DBReader_bbsstate(){
		Vector state = new Vector();
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select bbs_entry,del,name from bbsstate";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				state.addElement(rs.getString(1));
				state.addElement(String.valueOf(rs.getInt(2)));
				state.addElement(rs.getString(3));
			//	state.addElement(rs.getString(4));
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return state;
	}
	//读取用户信息
	public Vector DBReader_UserInfo(String id){
		Vector user = new Vector();
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select PWD,head,question,answer from UserID where ID='"+id+"'";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				user.addElement(rs.getString(1));
				user.addElement(String.valueOf(rs.getInt(2)));
				
				user.addElement(rs.getString(3));
				user.addElement(rs.getString(4));
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return user;
	}
	//读取短消息
	public Vector DBReader_Message(String id){
		Vector message = new Vector();
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select * from message where ID='"+id+"'";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				message.addElement(rs.getString(1));
				message.addElement(rs.getString(2));
				message.addElement(rs.getString(3));
				message.addElement(rs.getString(4));
				message.addElement(String.valueOf(rs.getInt(5)));
				message.addElement(rs.getString(6));
				message.addElement(String.valueOf(rs.getInt(7)));
				
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return message;
	}
	//读取置顶消息
	public Vector DBReader_OneMessage(String id,String time){
		Vector message = new Vector();
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select * from message where ID='"+id+"' and time='"+time+"'";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				message.addElement(rs.getString(1));
				message.addElement(rs.getString(2));
				message.addElement(rs.getString(3));
				message.addElement(rs.getString(4));
				message.addElement(String.valueOf(rs.getInt(5)));
				message.addElement(rs.getString(6));
				message.addElement(String.valueOf(rs.getInt(7)));
				
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return message;
	}
}