📄 frmbrtfdb.java
字号:
package myprojects.FrmBRTFDb;
import java.sql.*;
public class FrmBRTFDb {
public boolean bRecExists = false;
public boolean flg = false;
public ResultSet rsBRXX = null;
public ResultSet rsFYMX = null;
public ResultSet rsZYH = null;
String dbDriver = "sun.jdbc.odbc.JdbcOdbcDriver";
String dbConn = "jdbc:odbc:Dbserver";
Connection con;
Statement stmtBRXX;
Statement stmtFYMX;
Statement stmtZYH;
String strSQLBRXX;
String strSQLFYMX;
//连接数据库
public void getConnection() {
try {
//加载驱动程序
Class.forName(dbDriver);
//建立连接
con = DriverManager.getConnection(dbConn);
//关闭自动提交
con.setAutoCommit(false);
//设定事务级别
con.setTransactionIsolation(con.TRANSACTION_SERIALIZABLE);
//创建JDBC声明
stmtBRXX = con.createStatement();
stmtFYMX = con.createStatement();
}
catch (Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
}
public boolean getBRXX(String sZYH) {
try {
strSQLBRXX = "SELECT ZYH,BRXM,BRXB,CSNY,ZYKS,BCH FROM View_ZYBR ";
strSQLBRXX = strSQLBRXX + "WHERE ZYH='"+ sZYH +"' ";
rsBRXX = stmtBRXX.executeQuery(strSQLBRXX);
}
catch (Exception se)
{
System.out.println(se.getMessage());
se.printStackTrace();
flg = true;
}
return flg;
}
public boolean getFYMX(String ssZYH) {
try {
strSQLFYMX = "SELECT ZYH,CFRQ,ZYKS,KMLB,KM,DJ,SL,ZFBL,JJDW,GG,CD,CJ FROM View_WJZFY ";
strSQLFYMX = strSQLFYMX + "WHERE ZYH ='"+ ssZYH +"' ";
rsFYMX = stmtFYMX.executeQuery(strSQLFYMX);
}
catch (Exception se)
{
System.out.println(se.getMessage());
se.printStackTrace();
flg = true;
}
return flg;
}
public int insertData(String[] dbstr) {
try {
String strSQL = "INSERT INTO CFD VALUES ('"+dbstr[0]+"',"+"CONVERT(smalldatetime,'"+dbstr[4]+"')"+ ",'"+dbstr[2]+"','"+dbstr[3]+"',null)";
int ret = stmtFYMX.executeUpdate(strSQL);
con.commit();
return ret;
}
catch (Exception se){
try{
con.rollback();
}
catch(Exception we){
System.out.println(we.getMessage());
se.printStackTrace();
return 0;
}
System.out.println(se.getMessage());
se.printStackTrace();
return 0;
}
}
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 + -