dbformwrite.java

一个小型的BBS系统

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

import bean.condb.*;
public class DBFormWrite {
	Statement stmt;
	ResultSet rs;
	Connection con;
	String id = "-1";
	public DBFormWrite(){
		Condb condb = new Condb();
		this.con = condb.con();
	}
	//获取ID
	public String getID(String author){
		System.out.println("开始获取帖子位置");
		try{
			String sql="select url from bbsform1 where author='"+author+"'";
			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()){
				id = rs.getString(1);
			}
			
			stmt.close();
	//		rs.close();
			System.out.println("当前帖子所在位置:"+id);
			return id;
		
		}catch(SQLException s){
			System.out.println(s.toString());
		};
		System.out.println("当前帖子所在位置:"+id);
		return id;
	}
	//返回帖子位置
	public int getNumber(String id){
		int number=0;
		try{
			String sql="select number 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()){
				number = rs.getInt(1);
			}
			
			stmt.close();
	//		rs.close();
			
		
		}catch(SQLException s){
			System.out.println(s.toString());
		};
		return number;
	}
	//帖子排序
	public void SortPost(String id,String state,String lv){
		System.out.println("开始进行帖子排序");
		int n = getNumber(id);
		System.out.println("当前帖子所在位置:"+n);
		String sql;
		if(n!=1)
			sql="UPDATE bbsform1 SET [number]=[number]+1 where number<"+n+" and state ='"+state+"' and level =0";
		else 
			sql ="UPDATE bbsform1 SET [number]=[number]+1 where state ='"+state+"' and level=0";

		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+"' and level =0";
			System.out.println(sql);
			stmt.executeUpdate(sql);
			stmt.close();
		
		}catch(SQLException s){
			System.out.println("DBFormWrite_SortPost函数错误"+s.toString());
		}
	}
	
	//写入数据库
	public void DBFW(String title,String url,String author,String lastupdate,int number,String state){
		String sql="insert into bbsform1 values('"
					+title+"','"
					+url+"','"
					+author+"','"
					+lastupdate+"',"
					+number+","
					+"0,0,'"
					+state+"',0,0)";
		System.out.println(sql);
		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 UpdateStateNum(String state){
		
		String sql1="update bbsstate set [num] = [num]+1 where bbs_entry ='"+state+"'";

		try{
			stmt=con.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY);
			
			stmt.executeUpdate(sql1);
			stmt.close();

		}catch(SQLException s){
			System.out.println(s.toString());
		}
	}
	//更新最后跟帖人
	public void UpdateFormLastupdate(String id,String author){
		String sql="update bbsform1 set [lastupdate]='"+author+"' where url='"+id+"'";
		

		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 UpdateCount(String id){
		String sql="update bbsform1 set [count]=[count]+1 where url='"+id+"'";
		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 UpdateReCount(String id){
		String sql="update bbsform1 set [recount]=[recount]+1 where url='"+id+"'";
		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());
		}
	}
}