database.java

来自「联系方式 [e-mail]」· Java 代码 · 共 70 行

/*
 * DataBase.java
 *
 * Created on 2008年4月27日, 上午10:34
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package happychat;

import java.sql.*;

/**
 *
 * @author Administrator
 */
public class DataBase {
    
   public static boolean isLogin(String n,String p) throws SQLException{               
        String url = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=happychat";
        try{
        Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
        }catch(Exception e){
            System.out.println("数据库连接失败！");           
        } 
        Connection conn = DriverManager.getConnection(url,"sa","123456");        
        Statement sql = conn.createStatement();         
        MD5 md5 = new MD5();
        String p1 = md5.toMD5(p);        
        String str = "select * from users where u_name='"+n+"' and"+" u_pass='"+p1+"'";
        ResultSet rs = sql.executeQuery(str);
        //conn.close();
        if(rs.next())     
            return true; 
        else
            return false;
     }

 public static boolean isRegister(String n,String p,String s,int a,String e) throws SQLException,NullPointerException {  
        ResultSet rs = null;
        java.sql.CallableStatement sql; 
        int result=0;        
        String url = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=happychat";
        try{
        Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
        Connection conn = DriverManager.getConnection(url,"sa","123456");  
        MD5 md5 = new MD5();
        String p1 = md5.toMD5(p);
        sql = conn.prepareCall("{call update_proc(?,?,?,?,?,?)}"); 
        sql.setString(1,n); 
        sql.setString(2,p1);
        sql.setString(3,s);        
        sql.setInt(4,a);
        sql.setString(5,e);        
        sql.registerOutParameter(6,java.sql.Types.INTEGER);
        sql.execute();   
        result = sql.getInt(6);
        //conn.close();
       }catch(Exception ex){
           System.out.println("数据库连接失败！");           
        }        
        if(result==1)
            return true;
        else 
            return false;
      }       
    
}