liuyan.java

基于Java实现的聊天室功能

package liuyan;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

public class Liuyan {
	private Conn conn = new Conn();
	private Statement stmt;
	private ResultSet rs;
	
	public Liuyan(){}
	
	public boolean adminLogin(String sql){
		boolean result = false;
		stmt = conn.getStmt();
		try{
			rs = stmt.executeQuery(sql);
			if(rs.next())
				result = true;
		}catch(SQLException e){
			e.printStackTrace();
		}
		conn.close();
		return result;
	}
	
	public boolean executeUpdate(String sql){
		boolean result = false;
		stmt = conn.getStmt();
		try{
			stmt.executeUpdate(sql);
			result = true;
		}catch(SQLException e){
			e.printStackTrace();
		}
		conn.close();
		return result;
	}
	
	public ArrayList<LiuyanBean> getLiuyanList(String sql){
		ArrayList<LiuyanBean> list = new ArrayList<LiuyanBean>();
		stmt = conn.getStmt();
		try{
			rs = stmt.executeQuery(sql);
			LiuyanBean liuyan = null;
			while(rs.next()){
				liuyan = new LiuyanBean();
				liuyan.setId(rs.getString("id"));
				liuyan.setName(rs.getString("name"));
				liuyan.setSex(rs.getString("sex"));
				liuyan.setComefrom(rs.getString("comefrom"));
				liuyan.setLianxi(rs.getString("lianxi"));
				liuyan.setQQ(rs.getString("qq"));
				liuyan.setEmail(rs.getString("email"));
				liuyan.setZhuye(rs.getString("zhuye"));
				liuyan.setOther(rs.getString("other"));
				liuyan.setLyTime(rs.getString("lytime"));
				liuyan.setLastTime(rs.getString("lasttime"));
				liuyan.setReplyTime(rs.getString("replytime"));
				liuyan.setBq(rs.getString("bq"));
				liuyan.setTitle(rs.getString("title"));
				liuyan.setContent(rs.getString("content"));
				liuyan.setReplyContent(rs.getString("replycontent"));
				liuyan.setIsok(rs.getString("isok"));
				list.add(liuyan);
			}
		}catch(SQLException e){
			e.printStackTrace();
		}
		conn.close();
		return list;
	}
	
	public int getTotal(String sql){
		int total = 0;
		stmt = conn.getStmt();
		try{
			rs = stmt.executeQuery(sql);
			if(rs.next())total = rs.getInt(1);
		}catch(SQLException e){
			e.printStackTrace();
		}
		conn.close();
		return total;
	}
}