frmlogindb.java

用JAVA SWT编写的住院管理系统。用SQLServer数据库

package myprojects.FrmLoginDb;

import java.sql.*;


public class FrmLoginDb {
	public ResultSet rs = null;
	public boolean fig =false;
    String dbDriver = "sun.jdbc.odbc.JdbcOdbcDriver";
    String dbConn = "jdbc:odbc:Dbserver";
    Connection con;
    Statement stmt;
    int a;
    
//连接数据库

public int getConnection() {
    try {
        //加载驱动程序
        Class.forName(dbDriver);
        //建立连接
        con = DriverManager.getConnection(dbConn);
        //关闭自动提交
        con.setAutoCommit(false);
        //设定事务级别
        con.setTransactionIsolation(con.TRANSACTION_SERIALIZABLE);
        //创建一个JDBC声明
        stmt = con.createStatement();
        //数据库连接成功返回1
        a=1;
        return a;
    }
    catch (Exception e) 
    {
        System.out.println(e.getMessage());
        e.printStackTrace();
        //数据库连接失败返回0
        a=0;
        return a;
    }
    
}

//修改数据函数
public int updateData(String UserId,String UserPW,String newPW,String cpw)	
	{	
	 try{//修改语句
	     String sql="";
	     sql="UPDATE SFUser SET ";
	     sql=sql + "UserPW = '" + newPW + "'";
	     sql= sql + "where UserID = '" + UserId + "'";	
	     System.out.println(sql + "-----sql");	
	     int count = stmt.executeUpdate(sql);	
	     //提交	
	     con.commit();
	     //修改成功返回1	
         return 1;		
	  	}	
	 catch(SQLException e)		
	  	{	
	     try {		
	     //数据库操作出错时回滚		
	     con.rollback();		
	        }		
	     catch(SQLException exp)
	     { }			
	        		
	  	 System.out.println(e.getMessage());
	  		e.printStackTrace();
	  		//修改失败返回0
	  		return 0;
	  	
	  	}	
	  		
	}		
//修改当前标记
public void updateDataDQBJ(String UserId)	
	{	
	 try{//修改语句
	     String sql="";
	     sql="UPDATE SFUser SET ";
	     sql=sql + "DQBJ = '" + 0 + "'";
	     stmt.executeUpdate(sql);
	     con.commit();
	     	
         		
	  	}	
	 catch(SQLException e)		
	  	{	
	     
	  	 System.out.println(e.getMessage());
	  		e.printStackTrace();
	  	 
	  	}	
	  try{//修改语句
	     String sql="";
	     sql="UPDATE SFUser SET ";
	     sql=sql + "DQBJ = '" + 1 + "'";
	     sql= sql + "where UserID = '" + UserId + "'";	
	     stmt.executeUpdate(sql);
	     con.commit();
	     	
         		
	  	}	
	 catch(SQLException e)		
	  	{	
	     
	  	 System.out.println(e.getMessage());
	  		e.printStackTrace();
	  	 
	  	}			
	}		
//身份验证函数	
public boolean checkUser(String userID,String userPW) {
      try {
      	 //查询语句
         String strSQL;
         strSQL = "SELECT * FROM SFUser WHERE ";
         strSQL = strSQL + "UserID = '" + userID + "'";
         strSQL = strSQL + "AND UserPW = '" + userPW + "'";
         
         rs = stmt.executeQuery(strSQL);
         int count = 0;
         while(rs.next()){
         count++; 
        
          }
      if (count > 0) {
         //登录成功
         return true;
               }
         else {
         //用户名和密码不匹配
         return false;
        }
        
        }
      catch (SQLException e) 
        {
         System.out.println(e.getMessage());
         e.printStackTrace();
         //查询出错
         fig = true;
         return fig;
    }
}
}