javachatcode.txt

小小的java聊天室源代码 希望对初学者有帮助！

  ls_1="select nick from lt_user where userid = '"+as_userid+"'";
  try{
   Statement s = con.createStatement();
   res=s.executeQuery(ls_1);
   while(res.next()){
    ls_nickname = res.getString(1);    
   }
  } catch (Exception s) {
   ls_nickname=null;
  }
  return ls_nickname; 
 }
 public Boolean check_user_regsuc(String as_userid){
  ResultSet res=null;
  String ls_1="";
  String ls_regsuc=null;
  int count=0;
  ls_1="select regsuc from lt_user where userid = '"+as_userid+"'";
  try{
   Statement s = con.createStatement();
   res=s.executeQuery(ls_1);
   while(res.next()){
    ls_regsuc = res.getString(1);    
   }
  } catch (Exception s) {
   ls_regsuc=null;
  }
  if (ls_regsuc.equals("1")){
   return true; 
  }else{
   return false;
  }
  
 }
 public int set_user_succ_reg(String as_userid,String as_suc){
  /**
   * 设置是否通过验证或者将已通过验证的用户设为未通过.
   * 参数:as_userid   --用户ID
   *      as_suc  --是否通过验证
   *    '0'未通过 '1'通过验证.
   */
  if (as_suc!="0" && as_suc!="1"){
   return -1;
  }
  int suc=0;
  int updatereply;
  try{
   con.setAutoCommit(true);
   String ls_1 = "update lt_user set regsuc='"+as_suc+"' where userid = '"+as_userid+"' and regsuc<>'"+as_suc+"'";
   Statement s = con.createStatement();
   updatereply=s.executeUpdate(ls_1);
   if (updatereply==0){
    System.out.println("No row is updated.");
    suc=0;
   }
   else if(updatereply>=1){
    System.out.println("Row is updated.");
    suc=updatereply;
   }else{
    System.out.println("fail updated.");
    suc=-1;
   }
  } catch (Exception s) {
   try{
    con.rollback();
    con.setAutoCommit(true);
   }catch (Exception s2) {
    s2.printStackTrace();
   }
   s.printStackTrace();
   suc=-1;
  }

  return suc;
 }
 public int set_user_manager(String as_userid,String as_suc){
  /**
   * 设置是否为管理员.
   * 参数:as_userid   --用户ID
   *      as_suc  --是否通过验证
   *    '0'未通过 '1'通过验证.
   */
  if (as_suc!="0" && as_suc!="1"){
   return -1;
  }
  int suc=0;
  int updatereply;
  try{
   con.setAutoCommit(true);
   String ls_1 = "update lt_user set manager='"+as_suc+"' where userid = '"+as_userid+"' and manager<>'"+as_suc+"'";
   Statement s = con.createStatement();
   updatereply=s.executeUpdate(ls_1);
   if (updatereply==0){
    System.out.println("No row is updated.");
    suc=0;
   }
   else if(updatereply>=1){
    System.out.println("Row is updated.");
    suc=updatereply;
   }else{
    System.out.println("fail updated.");
    suc=-1;
   }
  } catch (Exception s) {
   try{
    con.rollback();
    con.setAutoCommit(true);
   }catch (Exception s2) {
    s2.printStackTrace();
   }
   s.printStackTrace();
   suc=-1;
  }

  return suc;
 }
 public boolean delele_user(String as_userid){
  /**
   * 删除用户信息
   * 参数:as_userid--用户ID
   */
  boolean suc=false;
  int updatereply;
  try{
   con.setAutoCommit(true);
   //PreparedStatement st = con.prepareStatement("insert into lt_user(userid, userpass,name,nick,sex,web,email,description) values(?,?,?,?,?,?,?,?)");
   String ls_1 = "delete lt_user where userid like '"+as_userid+"'";
   Statement s = con.createStatement();
   updatereply=s.executeUpdate(ls_1);
   if (updatereply==0){
    System.out.println("Table is empty.");
    suc=true;
   }
   else if(updatereply==1){
    System.out.println("Row is deleted.");
    suc=true;
   }
   else{
    System.out.println("not Row is deleted.");
    suc=false;
   }
   
  } catch (Exception s) {
   s.printStackTrace();
   suc=false;
  }
  return suc;
 }
 public ResultSet query_user(String as_userid,String as_regsuc){
  /**
   * 查询用户表信息
   * 参数:as_userid  --用户ID
   * 参数:as_regsucc
   *   '-1',表示全部信息显示,
   *  '0'表示未通过验证,
   *   '1'表示已通过验证.
   */
  if (as_regsuc!="0" && as_regsuc!="1" && as_regsuc!="-1"){
   return null;
  }
  ResultSet res;
  String ls_1;
  ls_1="select * from lt_user where (regsuc='"+as_regsuc+"'"+" or '-1'="+as_regsuc+") and userid like '"+as_userid+"'";
  try{
  Statement s = con.createStatement();
  res=s.executeQuery(ls_1);
  } catch (Exception s) {
   return null;
  }
  return res;
 }
 
 public boolean Check_user_pass(String as_userid,String as_userpassword,String as_manager){
  /**
   * 验证登陆信息是否正确,
   * 正确返回TRUE
   * 错误返回FALSE
   */
  ResultSet res=null;
  String ls_1="";
  
  boolean suc=false;
  int count=0;
  if (as_manager.equals("Manager")){
   ls_1="select count(*) from lt_user where manager=1 and userid = '"+as_userid+"' and userpass = '"+as_userpassword+"'";
  }else{
   ls_1="select count(*) from lt_user where userid = '"+as_userid+"' and userpass = '"+as_userpassword+"'";
  }
  try{
   Statement s = con.createStatement();
   res=s.executeQuery(ls_1);
   while(res.next()){
    count = res.getInt(1);    
   }
   if (count>0){
    suc=true;
   }
   else{
    suc=false;
   }
  } catch (Exception s) {
   suc=false;
  }
  return suc;
 }
 public int get_row_count(){
  ResultSet res=null;
  String ls_1="";
  boolean suc=false;
  int count=0;
  ls_1="select count(*) from lt_user";
  try{
   Statement s = con.createStatement();
   res=s.executeQuery(ls_1);
   while(res.next()){
    count = res.getInt(1);    
   }
  } catch (Exception s) {
   count=-1;
  }
  return count;
 }
 public boolean Check_same_userid(String as_userid){
  /**
   * 验证登陆信息是否正确,
   * 正确返回TRUE
   * 错误返回FALSE
   */
  ResultSet res=null;
  String ls_1="";
  boolean suc=false;
  int count=0;
  ls_1="select count(*) from lt_user where userid = '"+as_userid+"'";
  try{
   Statement s = con.createStatement();
   res=s.executeQuery(ls_1);
   while(res.next()){
    count = res.getInt(1);    
   }
   if (count>0){
    suc=true;
   }
   else{
    suc=false;
   }
  } catch (Exception s) {
   suc=false;
  }
  return suc;
 } 


}




以下是user_ob.java类: 
package chatroom;

public class user_ob {
 String username;
 String nickname;
 public user_ob(String as_username,String as_nickname){
  username=as_username;
  nickname=as_nickname;
 }
 public String toString(){
  return nickname;
 }
 public String getnickname(){
  return nickname;
 }
 public String getUsername(){
  return username;
 }
}

以下是server_user_ob.java类:
package chatroom;
import java.net.*;
public class server_user_ob {
 Socket user_socket;
 String user_name;
 String nick_name;
 ClientThread client_thread;
 public server_user_ob(Socket ast_socket,String as_username,String as_nickname,ClientThread act){
  user_socket=ast_socket;
  user_name=as_username;
  nick_name=as_nickname;
  client_thread=act;
 }
 public String toString(){
  return user_name;
 }
 public String getUsername(){
  return user_name;
 }
 public String getNickname(){
  return nick_name;
 }
 public Socket getSocket(){
  return user_socket;
 }
 public void setUsername(String as_username){
  user_name=as_username;
 }
 public void setNickname(String as_nickname){
  nick_name=as_nickname;
 }
 public ClientThread getClientThread(){
  return client_thread;
 }
}



以下是聊天信息数据库操作类 chatmsg_db.java: 
package chatroom;

import java.sql.Connection;
import java.sql.Date;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;

public class chatmsg_db {
 private Connection con = null;
 public linkdb myDbTest;
 public boolean con_db(){
  myDbTest = new linkdb();
  con=myDbTest.getConnection();
  if(con!=null){
   return true;
   
  }
  else {
   System.out.println("Error: No active Connection");
   return false;
  }
   
 }
 public boolean con_db(String as_ServerName,String as_portnumber,String as_databaseName,String as_userName,String as_password){
  /**
   * 连接到数据库
   */
  myDbTest = new linkdb(as_ServerName,as_portnumber,as_databaseName,as_userName,as_password);
  con=myDbTest.getConnection();
  if(con!=null){
   return true;
  }
  else {
   System.out.println("Error: No active Connection");
   return false;
  }
   
 } 
 public void close_db(){
  try {
   if(con!=null){
    con.close();
   }
  }catch (Exception s) {
   s.printStackTrace();
  }
   
 }
 
 public void displaylinkdetail(){
  myDbTest.displayDbProperties();
 }
 public boolean insert_msg(String as_userid,
       String as_touserid,
       String as_chatmsg,
       String as_chataction){
  boolean suc=false;
  try{
   con.setAutoCommit(false);
   String ls_1 = "insert into lt_chatmsg(userid, touserid,chatmsg,chataction) " +
     "values('"+as_userid+"','"+as_touserid+"','"+as_chatmsg+"','"+as_chataction+"')";
   Statement s = con.createStatement();
   s.executeUpdate(ls_1);
   con.commit();
   System.out.println("insert succ");
   suc=true;
   con.setAutoCommit(true);
  } catch (Exception s) {
   // System.out.println("Table all ready exists!");
   try{
    con.rollback();
    con.setAutoCommit(true);
   }catch (Exception s2) {
    s2.printStackTrace();
   }
   s.printStackTrace();
   suc=false;
  }

  return suc;
 }
 public int get_row_count(){
  ResultSet res=null;
  String ls_1="";
  boolean suc=false;
  int count=0;
  ls_1="select count(*) from lt_chatmsg";
  try{
   Statement s = con.createStatement();
   res=s.executeQuery(ls_1);
   while(res.next()){
    count = res.getInt(1);    
   }
  } catch (Exception s) {
   count=-1;
  }
  return count;
 }
 public boolean update_msg(String as_userid,
   String as_chatdt,
   String as_touserid,
   String as_chatmsg,
   String as_chataction){
  boolean suc=false;
  try{
   con.setAutoCommit(false);
   String ls_1 = "update lt_chatmsg set touserid='"+as_touserid+"',chatmsg='"+as_chatmsg+"',chataction='"+as_chataction+"' where userid = '"+as_userid+"' and chatdt='"+as_chatdt+"'";
   Statement s = con.createStatement();
   s.executeUpdate(ls_1);
   con.commit();
   System.out.println("update succ");
   suc=true;
   con.setAutoCommit(true);
  } catch (Exception s) {
   try{
    con.rollback();
    con.setAutoCommit(true);
   }catch (Exception s2) {
    s2.printStackTrace();
   }
   s.printStackTrace();
   suc=false;
  }

  return suc;
 }
 public boolean delele_msg(int ai_chatmsg_id){
  /**
   * 删除对话信息
   * @param ai_chatmsg_id 信息ID
   */
  boolean suc=false;
  String as_chatmsg_id=String.valueOf(ai_chatmsg_id);
  int updatereply;
  try{
   con.setAutoCommit(true);
   String ls_1 = "delete lt_chatmsg where chatmsg_id = "+as_chatmsg_id + "or '0'='"+as_chatmsg_id+"'";
   Statement s = con.createStatement();
   updatereply=s.executeUpdate(ls_1);
   if (updatereply==0){
    System.out.println("Table is empty.");
    suc=true;
   }
   else if(updatereply==1){
    System.out.println("Row is deleted.");
    suc=true;
   }
   else{
    System.out.println("not Row is deleted.");
    suc=false;
   }
   
  } catch (Exception s) {
   s.printStackTrace();
   suc=false;
  }
  return suc;
 }
 public ResultSet query_msg(int ai_chatmsg_id){
  /**
   * 查询对话信息
   */
  ResultSet res;
  String ls_1;
  String as_chatmsg_id;
  as_chatmsg_id=String.valueOf(ai_chatmsg_id);
  ls_1="select * from lt_chatmsg where chat