From 1594f396ec47c23294d386df055536850573ff73 Mon Sep 17 00:00:00 2001
From: 81041 <81041@192.168.10.26>
Date: 星期五, 07 十二月 2018 13:42:52 +0800
Subject: [PATCH] battinf的增删改的备份操作
---
gx_tieta/src/com/fgkj/dao/BattinfGroupFactory.java | 29 ++++++++++++++
gx_tieta/src/com/fgkj/dao/impl/Database_backupImpl.java | 32 +++++++++++++++
gx_tieta/src/com/fgkj/dao/impl/BattInfImpl.java | 40 ++++++++++++--------
3 files changed, 84 insertions(+), 17 deletions(-)
diff --git a/gx_tieta/src/com/fgkj/dao/BattinfGroupFactory.java b/gx_tieta/src/com/fgkj/dao/BattinfGroupFactory.java
index 2259cf5..5024dc6 100644
--- a/gx_tieta/src/com/fgkj/dao/BattinfGroupFactory.java
+++ b/gx_tieta/src/com/fgkj/dao/BattinfGroupFactory.java
@@ -5,7 +5,9 @@
import com.fgkj.dao.impl.BattInfImpl;
import com.fgkj.dao.impl.Batt_rtstateDAOImpl;
+import com.fgkj.dao.impl.Database_backupImpl;
import com.fgkj.dto.BattInf;
+import com.fgkj.dto.Database_backup;
public class BattinfGroupFactory {
//灏嗗悓涓�stationame涓殑2v,6v,12v鏁版嵁鏁村悎
@@ -116,4 +118,31 @@
int station_next=station_max+1;
return station_next;
}
+
+ //褰撳battinf琛ㄤ腑鏁版嵁杩涜澧炲垹鏀圭殑鎿嶄綔鏃讹紝鍏堝浠絛b_battinf.tb_battinf
+ public static boolean backup_battinf(){
+ boolean en=false;
+ {
+ Database_backup baseup=new Database_backup();
+ baseup.setBackup_en(1);
+ baseup.setDatabase_name("db_battinf");
+ baseup.setTable_name("tb_battinf");
+ (new Database_backupImpl()).update(baseup);
+ for (int i = 0; i < 20; i++) {
+ boolean b=(new Database_backupImpl()).serchTable_en(baseup);
+ if(b){
+ en=true;
+ }else{
+ try {
+ Thread.sleep(250);
+ } catch (InterruptedException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+ }
+ };//鍑虹幇鍒犻櫎鎿嶄綔鏃讹紝鍏堝浠芥暟鎹簱琛�
+ return en;
+ }
+
}
diff --git a/gx_tieta/src/com/fgkj/dao/impl/BattInfImpl.java b/gx_tieta/src/com/fgkj/dao/impl/BattInfImpl.java
index df1f70b..95f876a 100644
--- a/gx_tieta/src/com/fgkj/dao/impl/BattInfImpl.java
+++ b/gx_tieta/src/com/fgkj/dao/impl/BattInfImpl.java
@@ -12,6 +12,7 @@
import javax.persistence.Id;
import javax.sql.ConnectionEvent;
+import javax.swing.text.StyledEditorKit.BoldAction;
import sun.security.action.GetBooleanAction;
@@ -94,7 +95,13 @@
}
}
}
- boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
+ Boolean bl=false;
+ boolean en=BattinfGroupFactory.backup_battinf();
+ if(en){
+ bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
+ }else{
+ return false;
+ }
(new User_logService()).addPro(listU);//灏嗙敤鎴风殑鎿嶄綔璁板綍涓嬫潵
return bl;
@@ -132,8 +139,16 @@
}
}
}
+
+
+ Boolean bl=false;
+ boolean en=BattinfGroupFactory.backup_battinf();
+ if(en){
+ bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
+ }else{
+ return false;
+ }
(new User_logService()).addPro(listU);//灏嗙敤鎴风殑鎿嶄綔璁板綍涓嬫潵
- Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
return bl;
}
//淇敼鐢垫睜淇℃伅閰嶇疆(ip鍦板潃,鎺╃爜鍜岀綉鍏�)
@@ -152,19 +167,6 @@
}
//鍒犻櫎鐢垫睜缁�(澶氫釜)
public boolean del(Object obj) {
- {
- Database_backup baseup=new Database_backup();
- baseup.setBackup_en(1);
- baseup.setDatabase_name("db_battinf");
- baseup.setTable_name("tb_battinf");
- (new Database_backupImpl()).update(baseup);
- try {
- Thread.sleep(1000*3);
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- };//鍑虹幇鍒犻櫎鎿嶄綔鏃讹紝鍏堝浠芥暟鎹簱琛�
List<BattInf> list=(List<BattInf>) obj;
ArrayList sql_str=new ArrayList();
List<User_log> listU=new ArrayList<User_log>();//瀛樻斁user_log
@@ -180,8 +182,14 @@
}
}
}
+ Boolean bl=false;
+ boolean en=BattinfGroupFactory.backup_battinf();
+ if(en){
+ bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
+ }else{
+ return false;
+ }
(new User_logService()).addPro(listU);//灏嗙敤鎴风殑鎿嶄綔璁板綍涓嬫潵
- Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
return bl;
}
//鏍规嵁缁存姢鍖哄拰鏈烘埧鍚嶇О鏌ヨ鐢垫睜缁勪俊鎭�(鐢垫睜缁勪俊鎭厤缃�)
diff --git a/gx_tieta/src/com/fgkj/dao/impl/Database_backupImpl.java b/gx_tieta/src/com/fgkj/dao/impl/Database_backupImpl.java
index f71a1ca..915cb23 100644
--- a/gx_tieta/src/com/fgkj/dao/impl/Database_backupImpl.java
+++ b/gx_tieta/src/com/fgkj/dao/impl/Database_backupImpl.java
@@ -222,7 +222,37 @@
}
return number;
}
-
+ //鏌ヨ鍏蜂綋鏌愬紶琛ㄦ槸鍚﹀凡缁忓畬鎴愬浠�
+ public boolean serchTable_en(Object obj){
+ Database_backup baseup=(Database_backup) obj;
+ boolean bl=false;
+ String sql="select backup_en from web_site.tb_database_backup " +
+ " where database_name=? and table_name=? limit 1 ";
+ List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{baseup.getDatabase_name(),baseup.getTable_name()}, new CallBack() {
+
+ public List getResults(ResultSet rs) {
+ List list=new ArrayList();
+ try {
+ while(rs.next()){
+ list.add(rs.getInt("backup_en"));
+ }
+ } catch (SQLException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ return list;
+ }
+ });
+ if(list!=null&&list.size()>0){
+ int backup_en=(Integer) list.get(list.size()-1);
+ if (backup_en==2) {
+ bl=true;
+ } else {
+ bl=false;
+ }
+ }
+ return bl;
+ }
public List serchByInfo(Object obj) {
// TODO Auto-generated method stub
return null;
--
Gitblit v1.9.1