frmbrrydb.java

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

package myprojects.FrmBRRYDb ;
import java.sql.*;
import java.util.Date;
import java.text.SimpleDateFormat;
import java.lang.*;
public class FrmBRRYDb {
	public boolean bRecExists = false; 
	public ResultSet rs = null;
    String dbDriver = "sun.jdbc.odbc.JdbcOdbcDriver";
    String dbConn = "jdbc:odbc:DbServer";
    Connection con;
    Statement stmt;
    
    //连接数据库
public void getConnection() {
    try {
        //加载驱动程序
        Class.forName(dbDriver);
        //建立连接
        con = DriverManager.getConnection(dbConn);
        //关闭自动提交
        con.setAutoCommit(false);
        //设定事务级别
        con.setTransactionIsolation(con.TRANSACTION_SERIALIZABLE);
        //创建一个JDBC声明
        stmt = con.createStatement();
    }
    catch (Exception e) 
    {
        System.out.println(e.getMessage());
        e.printStackTrace();
    }
}
  
  
  
	//查询病人信息在BRXX,RCYJL表中
   public int BRXX(String BLH) {
   	int flg = -1;
   	try {
   		String strSQL="";
   		strSQL = "SELECT * FROM BRXX,RCYJL ";
   		strSQL =strSQL + "WHERE BRXX.BLH like '" + BLH + "%'"+"AND BRXX.BLH = RCYJL.BLH";
   		System.out.println(strSQL);
   		rs = stmt.executeQuery(strSQL);
   		if (!rs.next())
   		{flg=0;
   		
   		return flg;
   		
   			}
   		
   		}
   	catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
        flg = 0;
        
    }
    return flg;

}
   //查询病人信息在BRXX表中
   public int CheckBLH(String BLH) {
   	int flg = -1;
   	try {
   		String strSQL="";
   		strSQL = "SELECT * FROM BRXX ";
   		strSQL =strSQL + "WHERE BRXX.BLH = '" + BLH + "'";
   		System.out.println(strSQL);
   		rs = stmt.executeQuery(strSQL);
   		if (!rs.next())
   		{flg=0;
   		
   		return flg;
   		
   			}
   		
   		}
   	catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
        flg = 0;
        
    }
    return flg;

}
   
   //查询在院病人信息在表RCYJL,BRXX中
   public int ZYBRXX(String ZYH) {
   	int flg = -1;
   	try {
   		String strSQL="";
   		strSQL = "SELECT ZYH,ZYKS,isnull(BCH,'')as BCH,RYRQ,RCYJL.BLH,BRXM,SFZH,BRXB,CSNY,BRDH,BRDZ,LXRXM,LXRDH,LXRDZ FROM RCYJL,BRXX ";
   		strSQL =strSQL + "WHERE RCYJL.ZYH like '" + ZYH + "%'"+"AND BRXX.BLH = RCYJL.BLH AND"+" ISNULL(RCYJL.CYRQ,'')=''";
   		System.out.println(strSQL);
   		rs = stmt.executeQuery(strSQL);
   		if (!rs.next())
   		{flg=0;
   		
   		return flg;
   		
   			}
   		
   		}
   	catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
        flg = 0;
        
    }
    return flg;

}
 
 //查询在院病人信息在表RCYJL中
    public int CheckZYH(String ZYH) {
   	int flg = -1;
   	try {
   		String strSQL="";
   		strSQL = "SELECT * FROM RCYJL ";
   		strSQL =strSQL + "WHERE RCYJL.ZYH = '" + ZYH + "'";
   		System.out.println(strSQL);
   		rs = stmt.executeQuery(strSQL);
   		if (!rs.next())
   		{flg=0;
   		
   		return flg;
   		
   			}
   		
   		}
   	catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
        flg = 0;
        
    }
    return flg;

}
 
 
 //查询疾病信息
  public int JBXX(String ICD) {
   int flg = -1;
 	try {
 		String strSQL="";
 		strSQL = "SELECT * FROM JBDM ";
   		strSQL =strSQL+ "WHERE JBDM.ICD like '" + ICD + "%'";
   		System.out.println(strSQL);
   		rs = stmt.executeQuery(strSQL);
	   if (!rs.next())
	   		{flg=0;
	   		
	   		return flg;
	   		
	   			}
   		
   		}
   	catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
        flg = 0;
        
    }
    return flg;

}
   //查询诊断信息
  public int ZDXX(String BLH) {
   int flg = -1;
 	try {
 		String strSQL="";
 		strSQL = "SELECT * FROM ZDJL ";
   		strSQL =strSQL+ "WHERE ZDJL.BLH = '" + BLH + "'";
   		System.out.println(strSQL);
   		rs = stmt.executeQuery(strSQL);
	   if (!rs.next())
	   		{flg=0;
	   		
	   		return flg;
	   		
	   			}
   		
   		}
   	catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
        flg = 0;
        
    }
    return flg;

}
   
   
   //查询疾病信息
   
   public int CheckJBXX(String ICD) {
   int flg = -1;
   try {
  	String strSQL="";
  	strSQL = "SELECT * FROM JBDM ";
  	strSQL =strSQL + "WHERE JBDM.ICD = '" + ICD + "'";
    rs = stmt.executeQuery(strSQL);
      
    if (!rs.next())
	   		{flg=0;
	   		return flg;
	   	    }
    }
  catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
	flg=0;
	
	}
	return flg;
}
   //创建住院号
   public String CreateZYH() {
   String str1="";
   String str="";
   long a=0;
   try 
   {
   String strSQL="";
   strSQL = "SELECT MAX(ZYH) as Expr1 FROM RCYJL ";
   rs = stmt.executeQuery(strSQL);
   rs.next();
   str1=rs.getString("Expr1");
   if(str1.substring(0,8).equals(getNowDateYMD()))
   {a= Long.parseLong(str1)+1;
   str= String.valueOf(a);
   }
   else
   {str=getNowDateYMD()+"0001";}
   
   return str;
    }
   catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
	}
	return str;


}
  //创建病历号
  public String CreateBLH() {
   int a=0;
   String str="";
   String str1="";
   try 
   {
   
   String strSQL="";
   strSQL = "SELECT MAX(BLH) as Expr1 FROM BRXX ";
   
   rs = stmt.executeQuery(strSQL);
   rs.next();
   str1=rs.getString("Expr1");
   if(str1.substring(0,4).equals(getNowDateYYYY()))
   {a= Integer.parseInt(str1)+1;
   str= String.valueOf(a);
   }
   else
   {str=getNowDateYYYY()+"000001";}
   return str;
    }
   catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
	}
	return str;
}
  	
 
   //获取当前系统时间
   public  void getNowDate()
   {
   try 
   {String strSQL="";
   strSQL = "SELECT SUBSTRING(CONVERT(char(16), GETDATE(), 120), 1, 16) AS Expr1";
   rs = stmt.executeQuery(strSQL);
     rs.next();
   }
   catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
	}

}
   
   //获取当前系统时间年月日
   public String getNowDateYMD()
   {String strSQL="";
   	String strDate="";
   
   	try {
      	strSQL = "SELECT SUBSTRING(CONVERT(char(16), GETDATE(), 120), 1, 4) + SUBSTRING(CONVERT(char(16), GETDATE(), 120), 6, 2) + SUBSTRING(CONVERT(char(16), GETDATE(), 120), 9, 2) AS Expr1";
   		rs = stmt.executeQuery(strSQL);
   		rs.next();
   		strDate = rs.getString("Expr1");
   		
   		return strDate;
   
   
    }
   catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
	
	}
	return strDate;

}
  
  
   //获取当前系统时间年
 public String getNowDateYYYY()
   {
   String strSQL="";
   String strYYYY="";
   	try { 

   	strSQL = "SELECT SUBSTRING(CONVERT(char(16), GETDATE(), 120), 1, 4) AS Expr1";
   rs = stmt.executeQuery(strSQL);
   rs.next();
   strYYYY = rs.getString("Expr1");
   	
   	}
   catch (SQLException e) 
   	{
        System.out.println(e.getMessage());
        e.printStackTrace();
	}

   return strYYYY;
}
  
  //插入病人信息 
  public int insertBRXX(String BLH,String BRXM,String SFZH,String BRXB,String CSNY,String BRDH,
  							String BRDZ,String LXRXM,String LXRDH,String LXRDZ) 
   {
   	
   	try{
   		if(CheckBLH(BLH)==-1)
   		{
   		return 1;}
   		String sql="";
       sql="INSERT INTO BRXX(BLH,BRXM,SFZH,BRXB,CSNY,BRDH,BRDZ,LXRXM,LXRDH,LXRDZ) VALUES ('"+BLH+"','"+
   	   BRXM+"','"+SFZH+"','"+BRXB+"','"+CSNY+"','"+BRDH+"','"+BRDZ+"','"+LXRXM+"','"+LXRDH+"','"+LXRDZ+"')";
   	   
   	   System.out.println(sql + "-----sql");
	   stmt.executeUpdate(sql);
       con.commit();
       
       
       return -1;
    	  	}	
	catch(SQLException e)		
	  	{	
	     try {		
	            //数据库操作出错时回滚		
	            con.rollback();		
	        	return 0;
	        }		
	     catch(SQLException exp)		
	        {		
	  		System.out.println(e.getMessage());
	  		e.printStackTrace();
	  		return 0;}
	  	
	  	}	
	  		
	}		

   //插入在院病人信息
   public int insertRCYJL(String ZYH,String ZYKS,String BCH,String RYRQ,String BLH) 
   {
   	try{
   		if(CheckZYH(ZYH)==-1)
   		{
   		return 1;}
   	   String sql="";
       sql="INSERT INTO RCYJL(ZYH,ZYKS,BCH,RYRQ,BLH) VALUES ('"+ZYH+"','"+
   	   ZYKS+"','"+BCH+"','"+RYRQ+"','"+BLH+"')";
       //sql="INSERT INTO RCYJL(ZYH,ZYKS,BCH,RYRQ,BLH) VALUES ('2222222','2','3','" + RYRQ + "','2005000009')";

   	   System.out.println(sql + "-----sql");
   	   
   	   stmt.executeUpdate(sql);
       
       con.commit();
       
       return -1;
    	  	}	
	catch(SQLException e)		
	  	{	
	     try {		
	            //数据库操作出错时回滚		
	            con.rollback();		
	        	
	        	return 0;
	        }		
	     catch(SQLException exp)		
	        {		
	  		System.out.println(e.getMessage());
	  		e.printStackTrace();
	  		return 0;
	  		}
	  	
	  	}	
	 		
	}		
   //插入病人诊断信息
   public int insertZDJL(String BLH,String ZDRQ,String JBDM,String ZDYS,String ZD) 
   {
   	try{
   		
   	String sql="";
       sql="INSERT INTO ZDJL(BLH,ZDRQ,JBDM,ZDYS,ZD) VALUES ('"+BLH+"','"+
   	   ZDRQ+"','"+JBDM+"','"+ZDYS+"','"+ZD+"')";
   	   System.out.println(sql + "-----sql");
 	   stmt.executeUpdate(sql);
       con.commit();

    	  	}	
	catch(SQLException e)		
	  	{	
	     try {		
	           
	            //数据库操作出错时回滚		
	            con.rollback();		
	        	return 0;
	        	
	        }		
	     catch(SQLException exp)		
	        {		
	  		System.out.println(e.getMessage());
	  		e.printStackTrace();
	  		return 0;}
	  
	  	}	
	return -1;  		
	}		
   //修改病人信息 
  public int updataBRXX(String BLH,String BRXM,String SFZH,String BRXB,String CSNY,String BRDH,
  							String BRDZ,String LXRXM,String LXRDH,String LXRDZ) 
   {
   	try{
   	String sql="";
       sql="UPDATE BRXX SET BRXM = '"+BRXM+"',SFZH = '"+SFZH+"',BRXB = '"+BRXB+"',CSNY = '"+
       CSNY+"',BRDH = '"+BRDH+"',BRDZ = '"+BRDZ+"',LXRXM = '"+LXRXM+"',LXRDH = '"+LXRDH+"',LXRDZ = '"+
       LXRDZ+"' WHERE BLH= '"+BLH+"'";
   	   System.out.println(sql + "-----sql");
 	   stmt.executeUpdate(sql);
       con.commit();

    	  	}	
	catch(SQLException e)		
	  	{	
	     try {		
	            //数据库操作出错时回滚		
	            con.rollback();
	            return 0;		
	        }		
	     catch(SQLException exp)		
	        {		
	  		System.out.println(e.getMessage());
	  		e.printStackTrace();
	  		return 0;}
	  
	  	}	
	 return -1; 			
	}		
   
   //修改在院病人信息
   public int updataRCYJL(String ZYH,String ZYKS,String BCH,String RYRQ) 
   {
   	try{
   	String sql="";
       sql="UPDATE RCYJL SET ZYKS = '"+ZYKS+"',BCH = '"+BCH+"',RYRQ = '"+RYRQ+
       "' WHERE ZYH = '"+ZYH+"'";
   	   System.out.println(sql + "-----sql");
   	   stmt.executeUpdate(sql);
       con.commit();
       
      
    	  	}	
	catch(SQLException e)		
	  	{	
	     try {		
	            //数据库操作出错时回滚		
	            con.rollback();
	            return 0;		
	        }		
	     catch(SQLException exp)		
	        {		
	  		System.out.println(e.getMessage());
	  		e.printStackTrace();
	  		return 0;}
	  	
	  	}	
	 return -1; 		
	}	
   
   //修改病人诊断信息
   public int updataZDJL(String BLH,String ZDRQ,String JBDM,String ZDYS,String ZD) 
   {
   	try{
   	String sql="";
       sql="UPDATE ZDJL SET ZDYS = '"+ZDYS+"',ZD = '"+
       ZD+"',JBDM = '"+JBDM+"' WHERE BLH= '"+BLH+"' AND "+"ZDRQ= '"+ZDRQ+"'";
   	   System.out.println(sql + "-----sql");
   	   stmt.executeUpdate(sql);
       con.commit();
       
    	  	}	
	catch(SQLException e)		
	  	{	
	     try {		
	            //数据库操作出错时回滚		
	            con.rollback();	
	            return 0;	
	        }		
	     catch(SQLException exp)		
	        {		
	  		System.out.println(e.getMessage());
	  		e.printStackTrace();
	  		return 0;}
	  	
	  	}	
	  return -1;	
	}	
   	
   
   /*
    *关闭数据库连接
    */  
	public void closeDB()
	{
	    try
	    {
	        //在系统连接关闭之前，将所有未能及时提交的事务释放
	        con.commit();
	        //关闭连接
	        if (!con.isClosed())
	            con.close();
	    }
	    catch(SQLException se)
	    {
	        System.out.print(se.getMessage());
	        se.printStackTrace();
	    }
	}	  
  
}