dbtopwrite.java

一个小型的BBS系统

package bean.dbwrite;
import java.sql.*;
import bean.dbwrite.*;
import bean.condb.*;
public class DBTopWrite {
	Statement stmt;
	ResultSet rs;
	Connection con;
	
	public DBTopWrite(){
		Condb condb = new Condb();
		this.con = condb.con();
	}
	
	//置顶信息
	public void PutTop(String id,String lv,String number){//NUMBER需要事先计算好
		System.out.println("置顶执行");
		String title ="";
		String url ="";
		String author ="";
		String lastupdate ="";
		String count = "";
		String recount = "";
		String state = "";
		try{
			String sql="select * from bbsform1 where url ='"+id+"'";
			System.out.println(sql);
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);			
			rs = stmt.executeQuery(sql);
			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));
				state = rs.getString(8);
			}
	/*		sql = "insert into top values('"
					+title+"','"
					+url+"','"
					+author+"','"
					+lastupdate+"',"
					+number+","
					+count+","
					+recount+",'"
					+state+"',"
					+lv+")";*/
			sql="insert into toppost values('"
				+title+"','"
				+url+"','"
				+author+"','"
				+lastupdate+"',"
				+number+","
				+"0,0,'"
				+state+"',3)";
			System.out.println(sql);
			stmt.executeUpdate(sql);
			stmt.close();
	//		rs.close();
			
		
		}catch(SQLException s){
			System.out.println(s.toString());
		};
		
	}
	//获取number
	public int getNumber(String lv){
		int n=0;
		String sql="select number from bbsform1 where level ="+lv;
		ResultSet rs1;
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			System.out.println(sql);
			rs1 = stmt.executeQuery(sql);
			if(rs1!=null){
				while(rs1.next()){
					n = rs1.getInt(1);
				}	
			}
			stmt.close();
			return n;
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		return n;
	}
	//将bbsform1中相应帖子del位置2
	public void Top_level(String id,String lv,String n){
		
		String sql="update bbsform1 set [level] = "+lv+" where url ='"+id+"'";
		
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			System.out.println(sql);
			stmt.executeUpdate(sql);
			sql = "update bbsform1 set [number] = "+n+" where url ='"+id+"'";
			System.out.println(sql);
			stmt.executeUpdate(sql);
			stmt.close();
			
		}catch(SQLException s){
			System.out.println(s.toString());
		}
		
	}
	//修改其余各个帖子number
	public void ModifyNum(String id,String state){
		System.out.println("开始进行帖子排序");
		DBFormWrite dbfw = new DBFormWrite();
		int n = dbfw.getNumber(id);
		String sql;
		
		sql="UPDATE bbsform1 SET [number]=[number]-1 where number>"+n+" and state ='"+state+"' and level = 0";
		System.out.println(sql);
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			
			stmt.executeUpdate(sql);
		//	sql ="UPDATE bbsform1 SET [number]=1 where url='"+id+"'";
		//	System.out.println(sql);
		//	stmt.executeUpdate(sql);
			stmt.close();
		
		}catch(SQLException s){
			System.out.println("DBFormWrite_SortPost函数错误"+s.toString());
		}
	}
	//取消置顶 
	public void cancelTop(String id,String state){
		System.out.println("开始进行取消置顶函数");
		
		String sql;
		
		sql="update bbsform1 set [number] = [number]+1 where level =0 and state='"+state+"'";
		System.out.println(sql);
		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			
			stmt.executeUpdate(sql);
			sql ="UPDATE bbsform1 SET [level]=0,[number]=1 where url='"+id+"'";
			System.out.println(sql);
			stmt.executeUpdate(sql);
			stmt.close();
		
		}catch(SQLException s){
			System.out.println("DBTopWrite_cancelTop函数错误"+s.toString());
		}
	}
}