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;
    
//連接數(shù)據(jù)庫(kù)

public int getConnection() {
    try {
        //加載驅(qū)動(dòng)程序
        Class.forName(dbDriver);
        //建立連接
        con = DriverManager.getConnection(dbConn);
        //關(guān)閉自動(dòng)提交
        con.setAutoCommit(false);
        //設(shè)定事務(wù)級(jí)別
        con.setTransactionIsolation(con.TRANSACTION_SERIALIZABLE);
        //創(chuàng)建一個(gè)JDBC聲明
        stmt = con.createStatement();
        //數(shù)據(jù)庫(kù)連接成功返回1
        a=1;
        return a;
    }
    catch (Exception e) 
    {
        System.out.println(e.getMessage());
        e.printStackTrace();
        //數(shù)據(jù)庫(kù)連接失敗返回0
        a=0;
        return a;
    }
    
}

//修改數(shù)據(jù)函數(shù)
public int updateData(String UserId,String UserPW,String newPW,String cpw)	
	{	
	 try{//修改語(yǔ)句
	     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 {		
	     //數(shù)據(jù)庫(kù)操作出錯(cuò)時(shí)回滾		
	     con.rollback();		
	        }		
	     catch(SQLException exp)
	     { }			
	        		
	  	 System.out.println(e.getMessage());
	  		e.printStackTrace();
	  		//修改失敗返回0
	  		return 0;
	  	
	  	}	
	  		
	}		
//修改當(dāng)前標(biāo)記
public void updateDataDQBJ(String UserId)	
	{	
	 try{//修改語(yǔ)句
	     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{//修改語(yǔ)句
	     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();
	  	 
	  	}			
	}		
//身份驗(yàn)證函數(shù)	
public boolean checkUser(String userID,String userPW) {
      try {
      	 //查詢(xún)語(yǔ)句
         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 {
         //用戶(hù)名和密碼不匹配
         return false;
        }
        
        }
      catch (SQLException e) 
        {
         System.out.println(e.getMessage());
         e.printStackTrace();
         //查詢(xún)出錯(cuò)
         fig = true;
         return fig;
    }
}
}