?? frmbrrydb.java
字號:
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();
}
}
} ?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -