dbwrite.java

一个小型的BBS系统

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

import bean.condb.Condb;
public class DBWrite {
	Statement stmt;
	ResultSet rs;
	Connection con;
	public DBWrite(){
		Condb condb = new Condb();
		this.con = condb.con();
	}
	//用户注册信息写入数据库（UserID表）
	public void DBRegisterWriter(Connection con,String name,String pwd,String tname,String head,String question,String answer){
		String sql="insert into UserID values('"+name+"','"+pwd+"',0,'*',0,0,'"+tname+"',"+head+",'"+question+"','"+answer+"')";
		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 UserAddScore(String author,int score){
		System.out.println("开始执行加分");
		String sql="update UserID set [score] = [score] +"+score+ " where name='"+author+"'";
		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());
		}
	}
	//发帖数+1
	public void UpdateUserPost(String author){
		System.out.println("开始执行加分");
		String sql="update UserID set [post] = [post] +1 where name='"+author+"'";
		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 UpdateUserModify(String id,String pwd,String head){
		System.out.println("开始执行用户信息修改");
		String sql="update UserID set [PWD] = '"+pwd+"',[head]="+head+" where ID='"+id+"'";
		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 UpdateUserPwd(String id,String pwd){
		System.out.println("开始执行用户密码重置");
		String sql="update UserID set [PWD] = '"+pwd+"' where ID='"+id+"'";
		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());
		}
	}
	//将消息view置1
	public void UpdateMessageView(String id,String time){
		System.out.println("开始执行消息view置1");
		String sql="update message set [view] = 1 where ID='"+id+"' and time ='"+time+"'";
		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 WriteMessage(String ID,String title,String content,String time,String whosend,int num,int number){
		System.out.println("开始执行写短消息");
		String sql="insert into message values('"+ID+"','"
					+title+"','"
					+content+"','"
					+time+"',"
					+0+",'"
					+whosend+"',"
					+num+","
					+number+")";
		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());
		}
	}
}