自己写了一个聊天室 后来觉得没有那么多的必要也能聊天 不知道错在哪里了
package com.cqwu.chat.bean;
import java.sql.*;
public class DBBean {
private Connection con;
private Statement stmt;
private ResultSet rs;
public DBBean(){}
public Connection getConnection()throws Exception
{
String url ="jdbc:mysql://localhost/user";
String dbuser ="root";
String dbpass="root";
if(con==null)
{
Class.forName("com.mysql.jdbc.Driver");
con=DriverManager.getConnection(url, dbuser, dbpass);
}
return con;
}
//
public ResultSet executeQuery(String sql)throws Exception
{
if(con==null)throw new Exception("没有连接对象可用");
stmt = con.createStatement();
rs = stmt.executeQuery(sql);
return rs;
}
//更新
public int excuteUpdate(String sql)throws Exception{
if(con==null)throw new Exception("没有连接对象");
stmt = con.createStatement();
return stmt.executeUpdate(sql);
}
public void close(){
try{if(rs!=null)rs.close();}catch(Exception e){}
try{stmt.close();}catch(Exception e){}
try{con.close();}catch(Exception e){}
}
}
===================================================================
package com.cqwu.chat.bean;
import java.sql.*;
public class UserBean {
private String userid;
private String userpass;
private String userrepass;
private String usertype="0";
public String getUserid() {
return userid;
}
public void setUserid(String userid) {
this.userid = userid;
}
public String getUserpass() {
return userpass;
}
public void setUserpass(String userpass) {
this.userpass = userpass;
}
public String getUserrepass() {
return userrepass;
}
public void setUserrepass(String userrepass) {
this.userrepass = userrepass;
}
public String getUsertype() {
return usertype;
}
public void setUsertype(String usertype) {
this.usertype = usertype;
}
//添加用户
public boolean add(String userid,String userpass,String userrepass,String usertype) throws Exception
{
Connection con=null;
DBBean db = new DBBean();
StringBuffer sql =new StringBuffer();
sql.append("insert into usertable values('");
sql.append(userid);
sql.append("','");
sql.append(userpass);
sql.append("','");
sql.append(usertype);
sql.append("')");
try{
con =db.getConnection();
db.excuteUpdate(sql.toString());
}catch(Exception e)
{
System.out.println(e.toString());
}
finally{
db.close();
}
return true;
}
//查询用户
public int validate(String userid,String userpass,String usertype)
{
int find =0;
Connection con =null;
ResultSet rs =null;
DBBean db = new DBBean();
StringBuffer sql =new StringBuffer();
sql.append("select from usertable where userid='");
sql.append(userid);
sql.append("'");
try{
con =db.getConnection();
db.excuteUpdate(sql.toString());
if(rs.next())
{
String tmpuserid=rs.getString(1);
tmpuserid = new String(tmpuserid.getBytes("8859_1"));
String tmpuserpass=rs.getString(2);
tmpuserpass = new String(tmpuserpass.getBytes("8859_1"));
String tmpusertype=rs.getString(3);
tmpusertype= new String(tmpusertype.getBytes("8859_1"));
//
UserBean user =new UserBean();
user.setUserid(tmpuserid);
user.setUserpass(tmpuserpass);
user.setUsertype(tmpusertype);
if(userpass.equals(tmpuserpass)&&userid.equals(tmpuserid)&&usertype.equals(tmpusertype)){
find= 1;
}
if(userpass.equals(tmpuserpass)&&userid.equals(tmpuserid)&&!usertype.equals(tmpusertype)){
find= 2;
}
else{find=3;}
}
}catch(Exception e)
{
System.out.println(e.toString());
}
finally{
db.close();
}
return find;
}
//删除用户
public int delete(String username)throws Exception
{
Connection con=null;
DBBean db = new DBBean();
StringBuffer sql =new StringBuffer();
sql.append("delete from usertable where userid='");
sql.append(userid);
sql.append("'");
try{
con =db.getConnection();
db.excuteUpdate(sql.toString());
}catch(Exception e)
{
System.out.println(e.toString());
}
finally{
db.close();
}
return 0;
}
//
}
=========================================================================
package com.cqwu.chat.contoller;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.ArrayList;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import com.cqwu.chat.service.MessageService;
import com.cqwu.chat.vo.Message;
public class AddMessageServlet extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
//取出用户信息
HttpSession session =request.getSession(true);
String userid=(String)session.getAttribute("userid");
//取出新增聊天信息
String info=request.getParameter("info");
info=new String(info.getBytes("8859_1"));
//取出所有聊天信息
ServletContext application = this.getServletContext();
ArrayList<Message>allMessage = (ArrayList<Message>)application.getAttribute("allMessage");
//创建消息对象
Message message =new Message(info, userid);
//创建业务对象
MessageService service = new MessageService(allMessage);
//调用业务逻辑
service.addMessage(message);
//保存更新后的信息
application.setAttribute("allMessage", service.getAllMessage());
//转向聊天界面
response.sendRedirect("content.jsp");
}
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doGet(request,response);
}
} |
|
收藏
淘帖
踩
