jdbcoperation.java

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

/*
 * JDBCOperation.java
 *
 * Created on 2006年8月12日, 上午10:41
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package database.command;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 *主要是一些常用的数据库操作，利用的jtds驱动程序
 * @author 幽梦还乡
 */
public class JDBCOperation {
    
    /** Creates a new instance of JDBCOperation */
    public JDBCOperation() {
        
    }
    /*
     *获得数据库的连接
     *dirverName:数据库驱动程序的名称
     *JDBCURL：服务器路径
     *username：数据库的用户名
     *password：密码
     */
    public static Connection connection(String driverName,String JDBCURL,
            String userName,String password) 
            throws ClassNotFoundException, SQLException{
        Connection con = null;
        Class.forName(driverName);              
        con = java.sql.DriverManager.getConnection(JDBCURL,                        
                userName,password);  
       return con;
    }
    /*
     *添加一个表,用于字符串类
     *SQL：一个sql语句，创建表格以及添加一些比那两
     *con:与数据库连接的变量
     */
    public static void addTable(String SQL, Connection con) throws SQLException{
          
        Statement stmt = con.createStatement();     
        stmt.execute(SQL);
        stmt.close();
    }
  
    /*
     *删除一个表格
     *tabelName:要删除的表格的名称
     */
    public static void deleteTable(String tableName,Connection con) throws SQLException{             
        Statement stmt = con.createStatement();
        stmt.execute("drop table " + tableName);
        stmt.close();
    }
    /*
     *向数据库中插入数据
     */
    public static String insertValue(String tableName,String username,String password,String trueName,
            String country,String fav,String tel,Connection con) throws SQLException{
        String sql="insert into "+tableName+" values("+ "\'"+username+"\'"+",\'"+password
                +"\'"+",\'"+trueName+"\'"+",\'"+country+"\'"+",\'"+fav+"\'"+",\'"+tel+"\'"+")";
        Statement stmt=con.createStatement();
        stmt.execute(sql);
        return "success";
        
    }
/*
 *查找用户的ID
 */
   public static boolean search_Mem(String ID,String password ,Connection con) throws SQLException{
       boolean isRegister = false;
       String sql = "select username,password from member where username =  " + "\'"+ ID +"\'"
               +"and password="+"\'"+password+"\'";
       //String sqltest = "select * from Userinformation";
       Statement stmt = con.createStatement();
       ResultSet rst = stmt.executeQuery(sql);
      if(rst.next()){        
           isRegister = true;
       }else{                       
           isRegister = false;                   
       }
       return isRegister;
   }
   public static boolean search_Mem(String ID,Connection con) throws SQLException{
         boolean isRegister = false;
       String sql = "select username,password from member where username =  " + "\'"+ ID +"\'";
       //String sqltest = "select * from Userinformation";
       Statement stmt = con.createStatement();
       ResultSet rst = stmt.executeQuery(sql);      
       if(rst.next()){        
           isRegister = true;
       }else{                       
           isRegister = false;                   
       }
       return isRegister;
   }
   public static boolean search_Admin(String ID,String password,Connection con) throws SQLException{
       boolean isAdmin = false;
       String sql = "select username,password from admin where username ="+"\'"+ID +"\'"
               +"and password="+"\'"+password+"\'";
       Statement stmt = con.createStatement();
       ResultSet rst = stmt.executeQuery(sql);       
       if(rst.next()){
           isAdmin = true;
           //System.out.println(rst.getString("password"));
       }else{
           isAdmin = false;
       }
       return isAdmin;
   }
   /*
    *用来返回数据据库中注册用户的密码
    *并且编成字符数组来返回
    */
   public static String get_Mem_Password(String username,String tableName,
          Connection con) throws SQLException{          
       String result=null;
       String sql = "select password from "+tableName+" where username =" +"\'"+username 
               +"\'";
       Statement stmt=con.createStatement();
       ResultSet rst=stmt.executeQuery(sql);
       if(rst.next()){            
           result=rst.getString("password");
       }
       return result;
   }
   public static void main(String args[]){
        Connection con;
        try {
            con = JDBCOperation.connection("net.sourceforge.jtds.jdbc.Driver", 
                    "jdbc:jtds:sqlserver://127.0.0.1:1433/gamvantalk",
                    "sa", "123");
            System.out.println(JDBCOperation.insertValue("member","ccc","456","eee","中国","123","789",con));
        } catch (ClassNotFoundException ex) {
            ex.printStackTrace();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
      
   }
}