項(xiàng)目開發(fā)過程中 服務(wù)器出現(xiàn)了一些問題 很多的程序都不能用了 其中就有一個(gè)功能需要從一個(gè)sql server的數(shù)據(jù)庫中取數(shù)據(jù) 再錄入到oracle的庫中 過程中也出現(xiàn)了一些小問題 記錄一下
-
因?yàn)槭菍?duì)兩個(gè)不同的數(shù)據(jù)庫進(jìn)行操作 所以先要將兩個(gè)庫的jar包引入扼褪，需要注意jdk1.8需要使用sqljdbc4.jar，使用sqljdbc.jar會(huì)報(bào)錯(cuò)建峭。
image.png 創(chuàng)建連接類
DB2
import java.sql.*;
public class DB2 {
protected final String URL2="jdbc:sqlserver://172.xx.xxx.xx:xxxx;DatabaseName=xxxx";
protected final String URL="jdbc:oracle:thin:@xxx.xx.xxx.xx:1521:ORCL";
protected final String USER="xxxx";
protected final String USER2="xx";
protected final String USER3="xx";
protected final String PWD="xxxx";
protected final String PWD2="xxxxx";
protected final String PWD3="xxxx";
protected Connection conn;
protected PreparedStatement ps;
protected ResultSet rs;
public Connection getconn(){
try {
// Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
Class.forName("oracle.jdbc.driver.OracleDriver");
conn=DriverManager.getConnection(URL,USER,PWD);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return conn;
}
public void getconn2(){
try {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
conn=DriverManager.getConnection(URL2,USER2,PWD2);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void getconn3(){
try {
// Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
Class.forName("oracle.jdbc.driver.OracleDriver");
conn=DriverManager.getConnection(URL,USER3,PWD3);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void close(){
try {
if(rs!=null){
rs.close();
}
if(ps!=null){
ps.close();
}
if(conn!=null){
conn.close();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
其中把自己對(duì)應(yīng)的數(shù)據(jù)庫信息錄入就可以 可以看到第一個(gè)
getconn方法是有返回值的呼伸。是因?yàn)橄虢oinsert方法添加上事務(wù)旅赢。后邊會(huì)具體說。
- 然后新建了一個(gè)任務(wù)類
import java.sql.Connection;
import java.sql.SQLException;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.Timer;
import java.util.TimerTask;
/**
* Created with IntelliJ IDEA.
* User: employeeeee
* Date: 2019/12/16
* Time: 11:13
* Description: No Description
*/
public class Task {
SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
public void delete(){
DB2 db=new DB2();
db.getconn();
String sql="delete from t_realdata where systype=7";
try{
db.ps=db.conn.prepareStatement(sql);
db.ps.executeUpdate();
}catch(SQLException e){
e.printStackTrace();
}
db.close();
}
public void seletAllWellVC(DB2 db2) {
int count = 6000;
DecimalFormat fg = new DecimalFormat("#,###,00");
DB2 db = new DB2();
db.getconn2();
String sql = "select t.id,t.Point_name,t.value,t.Date_,zhsw.dbo.fun_getPY(t.Point_code) as Point_code from zhsw.dbo.t_data_huaxu t where point_name like '%*_%' ESCAPE '*' and point_name like '%井%電壓'\n" +
"union all\n" +
"select t.id,t.Point_name,t.value,t.Date_,zhsw.dbo.fun_getPY(t.Point_code) as Point_code from zhsw.dbo.t_data_huaxu t where point_name like '%*_%' ESCAPE '*' and point_name like '%井%電流'";
try {
db.ps = db.conn.prepareStatement(sql);
db.rs = db.ps.executeQuery();
while (db.rs.next()) {
count++;
String code = db.rs.getString("Point_code");
String datatime = db.rs.getString("Date_");
datatime = datatime.substring(0, 19);
double flow = db.rs.getDouble("value");
insert(count,code,datatime,flow,db2);
}
} catch (SQLException e) {
e.printStackTrace();
}
db.close();
}
public void insert(Integer count,String code,String datatime,double flow,DB2 db){
String sqls="insert into t_realdata(ID,POINTCODE,VALUE,INSERTTIME,SYSTYPE) values(?,?,?,TO_DATE(?,'YYYY-MM-DD HH24:MI:SS'),7)";
try{
db.ps=db.conn.prepareStatement(sqls);
db.ps.setInt(1,count);
db.ps.setString(2,code);
db.ps.setString(3,flow+"");
db.ps.setString(4,datatime);
db.ps.executeUpdate();
//如果不加會(huì)導(dǎo)致游標(biāo)報(bào)錯(cuò)
db.ps.close();
}catch(SQLException e){
e.printStackTrace();
}
}
public Task(){
Timer timer = new Timer();
DB2 db=new DB2();
Connection connection = db.getconn();
try {
connection.setAutoCommit(false);
int delay = 1000;//ms
// 一秒一運(yùn)行
int period = 1000*60;//ms
timer.schedule(new TimerTask() {
int i = 1;
public void run() {
delete();
seletAllWellVC(db);
try {
//事務(wù)提交
connection.commit();
} catch (SQLException e) {
e.printStackTrace();
}
i++;
System.out.println(i);
}
}, delay, period);
} catch (SQLException e) {
try {
connection.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
e.printStackTrace();
}
}
}
只寫了兩個(gè)方法，一個(gè)是查詢方法蜈亩，一個(gè)是存儲(chǔ)的方法。
存儲(chǔ)的方法還是有點(diǎn)問題的前翎，因?yàn)榘裪nsert寫到了循環(huán)的方法中稚配。如果不在insert的方法之后添加一個(gè)ps的close的話就會(huì)出現(xiàn)游標(biāo)的報(bào)錯(cuò)。
而且最開始的時(shí)候沒有添加事務(wù) 會(huì)導(dǎo)致數(shù)據(jù)沒有錄入完成就進(jìn)行了刪除 導(dǎo)致會(huì)出現(xiàn)id重復(fù)的報(bào)錯(cuò)港华，建議還是把方法修改為批量加入的方法道川。當(dāng)然也是要加上事務(wù)的。
并且寫了一個(gè)定時(shí)任務(wù) 一分鐘執(zhí)行一次 保證實(shí)時(shí)數(shù)據(jù)的展示。
然后通過main方法執(zhí)行就可以了
/**
* Created with IntelliJ IDEA.
* User: employeeeee
* Date: 2019/12/16
* Time: 11:23
* Description: No Description
*/
public class Main {
public static void main(String[] args) {
new Task();
}
}
- 最后打jar包的時(shí)候 出現(xiàn)了
java.lang.SecurityException: Invalid signature file digest for Manifest main attributes的報(bào)錯(cuò)
最后通過
zip -d your.jar 'META-INF/.SF' 'META-INF/.RSA' 'META-INF/*SF'
解決問題
