chatuserdb.java~48~

1． 消息即时通信 2． 消息发送实现一对一、一对多等多种发送模式 3． 发送的消息实现多彩文本编辑

package chat;
import java.sql.*;
public class ChatUserDB {
  Connection con=null;
  Statement sql=null;
  ResultSet rs=null;
  String name=null;
  String pd=null;
  public ChatUserDB(){
    try{
      //驱动类型＋目标数据库IP＋数据库端口
     String address="jdbc:microsoft:sqlserver://localhost:1433";
     //数据库用户密码
     String user="sa";
     //口令
     String passwd="workhard";
     //目标数据库
     String database="chat";
     //驱动申明
     Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
     //建立链接
     con=DriverManager.getConnection(address,user,passwd);
     //确定目标数据库
     con.setCatalog(database);
     //建立描述，设定结果集支持滚动光标且敏感，不可编辑
     sql=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet. CONCUR_READ_ONLY);
     //查询语句
     //String selCode="SELECT username,userkey FROM usertable";
     //结果集
    // ResultSet rs=smt.executeQuery(selCode);
    }catch(Exception e){
      e.printStackTrace();
    }
  }

  public boolean checkUser(String name,String key){
    this.name=name;
    this.pd=key;
    boolean b=false;
    try{
      String selCode="select * from usertable where username ="+"'"+name+"'"+"and userkey="+"'"+pd+"'";
      rs=sql.executeQuery(selCode);
     if(rs.next()){
       b=true;
     }
     rs.close();
     sql.close();
     con.close();
    }catch(SQLException e){
      e.printStackTrace();
    }
    return b;
  }
  public byte registerUser(String userId,String key,String name,String email){
    byte sucessed=0;
    try{
      String selCode="select * from usertable where username ="+"'"+userId+"'";
      rs=sql.executeQuery(selCode);
      if(rs.next()){
        return -1;
      }else{
        //selCode="insert into usertable  values("+"'"+userId+"','"+key+"','"+name+"','"+email+"')";
        selCode="insert  usertable values('s','s','s','s')";
        System.out.println(selCode);
        rs=sql.executeQuery(selCode);
        sucessed=1;
      }
    }catch(SQLException e){
      e.printStackTrace();
    }
    return sucessed;
  }

  public static void main(String[] args) {
    ChatUserDB db=new ChatUserDB();
    db.registerUser("e","e","e","e");
    /*if(db.checkUser("user2","2")){
      System.out.println("ok");
    }*/
  }
}