checkmessage.java

一个小型的BBS系统

package bean.check;

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

import bean.condb.*;

public class CheckMessage {
	Statement stmt;
	ResultSet rs;
	Connection con;
	public CheckMessage(){
		Condb condb = new Condb();
		this.con = condb.con();
	}
	//返回未读短消息个数
	public int CheckUnReadMessage(String id){
		int i=0;
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select view from message where ID='"+id+"'";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				int view = rs.getInt(1);
				if(view==0) i++;
				
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return i;
	}
	//返回当前短消息数量
	public int CheckNumOfMessage(String id){
		int i=0;
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select num from message where ID='"+id+"'";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				i = rs.getInt(1);
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return i;
	}
	//返回标号
	public int CheckNumOfMessage(){
		int i=0;
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			String sql="select number from message order by number ASC";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				i = rs.getInt(1);
			}
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return i;
	}
}