dbstatewrite.java

一个小型的BBS系统

package bean.dbwrite;
import java.sql.*;

import bean.condb.*;
public class DBStateWrite {
	Statement stmt;
	ResultSet rs;
	Connection con;
	public DBStateWrite(){
		Condb condb = new Condb();
		this.con = condb.con();
	}
	//更新版主信息
	public int DBUpdateState(String master,String formstate){
		String sql0 = "select bbs_entry,master from bbsstate where bbs_entry = '"+formstate+"'";
		System.out.println(sql0);
		String tempmaster ="";
		String tempstate = "";
		String stateid="";
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			//获取原master
			rs = stmt.executeQuery(sql0);
			while(rs.next()){
				
				stateid = rs.getString(1);//获取要提升版块的ID
				tempmaster = rs.getString(2);
			}
			//如果未曾出现
			if(tempmaster.indexOf(master)!=-1){
				System.out.println(tempmaster+" "+tempmaster.indexOf(master));
				return 0;//已经是版主
			}
			else{
				String sql="";
				//更新
				if(tempmaster.equals("*"))
					sql="update bbsstate set [master] = '"+master+"' where bbs_entry ='"+formstate+"'";
				else
					sql="update bbsstate set [master] = [master]+'  "+master+"' where bbs_entry ='"+formstate+"'";
				System.out.println(sql);
				stmt.executeUpdate(sql);//更新bbsstate表中的版主字段
				//获取UserID中的state字段
				sql0 ="select state from UserID where name ='"+master+"'";
				rs = stmt.executeQuery(sql0);
				while(rs.next()){
					tempstate = rs.getString(1);
				}
				if(tempstate.equals("*"))
					sql = "update UserID set [state] = '"+stateid+"' where name='"+master+"'";
				else
					sql = "update UserID set [state] = [state] + '  "+stateid+"' where name='"+master+"'";
				System.out.println(sql);
				stmt.executeUpdate(sql);//更新UserID表中的版块字段
				sql0 = "select Control from UserID where name='"+master+"'";
				rs = stmt.executeQuery(sql0);
				int c=-1;//临时控制位
				while(rs.next()){
					c = rs.getInt(1);
				}
				if(c==0){
					sql = "update UserID set [Control] = 1 where name = '"+master+"'";
					stmt.executeUpdate(sql);//更新UserID中的控制位
				}
				stmt.close();
			}
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return 1;
	}
	//更新版块名称
	public void UpdateStateName(String name,String newname){
		String sql= "update bbsstate set [name] = '"+newname+"' where bbs_entry ='"+name+"'";
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			stmt.executeUpdate(sql);
		
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
	}
	//添加版块
	public void AddState(String name){
		String sql="";
		String id="0";
		
					
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			sql="select bbs_entry from bbsstate ";
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				id = rs.getString(1);
			}
			if(id.equals("0"))
				id = "1";
			else
				id = String.valueOf(Integer.parseInt(id)+1);
			sql= "insert into bbsstate values('"+id+"',0,'*','?action=bbsform1',0,'"+name+"')";
			stmt.executeUpdate(sql);
		
			stmt.close();
		
		}catch(SQLException s){
			System.out.println(s.toString());
		}
	}
	//查找statename
	public String FindStateName(String bbs_entry){
		String statename="";
		String sql= "select name from bbsstate where bbs_entry ='"+bbs_entry+"'";
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				statename = rs.getString(1);
			}
			
			stmt.close();
			return statename;
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return statename;
	}
	
}