battinf的增删改的备份操作

81041

2018-12-07 1594f396ec47c23294d386df055536850573ff73

battinf的增删改的备份操作

 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表中数据进行增删改的操作时，先备份db_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;

    }



}


 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;

    }

    //根据维护区和机房名称查询电池组信息(电池组信息配置)


 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;