jdbcthread.java

注：语音聊天部分还未完成

/*
 * JDBCThread.java
 *
 * Created on 2006年8月13日, 下午2:28
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package com.gamvan.club.users.im.server;

import database.command.JDBCOperation;
import java.io.IOException;
import java.sql.Array;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Arrays;

/**
 *
 * @author Administer
 */
public class JDBCThread extends Thread {        
    /** Creates a new instance of JDBCThread */
    public static boolean isMember,isAdmin,isPassword; 
    private Connection con = null;
    private SingleUserMegData clientData = null;
    private String checkUserName = null;
    private String recevPassword;   
    public JDBCThread() {      
    }
    public void run(){           
        try {         
            check();      
        } catch (IOException ex) {
            ex.printStackTrace();
        }      
    }
    private void check() throws IOException{
         try {
            //获得到数据库的连接                                                       
            con= JDBCOperation.connection("net.sourceforge.jtds.jdbc.Driver",                                
                    "jdbc:jtds:sqlserver://127.0.0.1:1433/gamvantalk",                                 
                    "sa","123");         
            //查询会员信息
             isMember = JDBCOperation.search_Mem(checkUserName,recevPassword,con);              
             if(isMember){                
                     clientData.dataOut.writeObject("success");                 
                     clientData.dataOut.flush();                 
                     con.close();
                     Thread.interrupted();                                              
             }else{//如果不是会员在检查是否是管理员
               //再去管理员的表中查询是否是管理员  
                 isAdmin=JDBCOperation.search_Admin(checkUserName,recevPassword,con);
                 if(isAdmin){                                               
                     clientData.dataOut.writeObject("successAdmin");                                                              
                     clientData.dataOut.flush();                                                                   
                     con.close(); 
                     Thread.interrupted();
                    
                 }else{
                      clientData.dataOut.writeObject("fail");                
                      clientData.dataOut.flush();                
                      con.close();
                      Thread.interrupted();
                 }
                 
             }
           
        } catch (SQLException ex) {
            ex.printStackTrace();
        } catch (ClassNotFoundException ex) {
            ex.printStackTrace();
        }            
    }
    public void sendObject(SingleUserMegData clientData,String checkUserName,
            String recevPassword){
        this.clientData = clientData;
        this.checkUserName = checkUserName;
        this.recevPassword=recevPassword;
    }
    public static void main(String args[]){
        new JDBCThread().start();
       
    }
}