package com.fgkj.dao.impl;
|
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.dto.Database_backup;
|
|
public class Database_backupImpl implements CallBack,BaseDAO{
|
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Database_backup baseup=new Database_backup();
|
baseup.setNum(rs.getInt("num"));
|
baseup.setDatabase_name(rs.getString("database_name"));
|
baseup.setTable_name(rs.getString("table_name"));
|
baseup.setBackup_en(rs.getInt("backup_en"));
|
baseup.setBackup_flag(rs.getInt("backup_flag"));
|
baseup.setNote(rs.getString("note"));
|
list.add(baseup);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
|
public boolean add(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
//添加多条记录
|
public boolean addPro(Object obj) {
|
List<Database_backup> list=(List) obj;
|
ArrayList sql_strs=new ArrayList();
|
for (Database_backup baseup : list) {
|
String sql="insert into web_site.tb_database_backup(database_name,table_name) values('"+baseup.getDatabase_name()+"','"+baseup.getTable_name()+"')";
|
sql_strs.add(sql);
|
}
|
boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_strs);
|
return bl;
|
}
|
//根据数据库名和表名修改备份数据库的使能
|
public boolean update(Object obj) {
|
Database_backup baseup=(Database_backup) obj;
|
String sql="update web_site.tb_database_backup set backup_en=? where database_name=? and table_name=? ";
|
boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{baseup.getBackup_en(),baseup.getDatabase_name(),baseup.getTable_name()});
|
return bl;
|
}
|
//根据数据库名和表名修改备份数据库的使能(多笔记录可以选择几个表的)
|
public boolean updatePro(Object obj) {
|
List<Database_backup> list=(List) obj;
|
ArrayList sql_strs=new ArrayList();
|
if(list!=null&&list.size()>0){
|
for (Database_backup baseup : list) {
|
String sql="update web_site.tb_database_backup set backup_en="+baseup.getBackup_en()+" where database_name='"+baseup.getDatabase_name()+"' and table_name='"+baseup.getTable_name()+"' ";
|
sql_strs.add(sql);
|
}
|
}
|
boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_strs);
|
return bl;
|
}
|
|
//根据数据库名和表名修改备份数据库的使能(一键修改)
|
public boolean updateProAll() {
|
String sql="update web_site.tb_database_backup set backup_en=1 ";
|
boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, null);
|
return bl;
|
}
|
public boolean del(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
//查询所有数据库备份信息
|
public List searchAll() {
|
String sql="select num,database_name,table_name,backup_en,note from web_site.tb_database_backup ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Database_backup baseup=new Database_backup();
|
baseup.setNum(rs.getInt("num"));
|
baseup.setDatabase_name(rs.getString("database_name"));
|
baseup.setTable_name(rs.getString("table_name"));
|
baseup.setBackup_en(rs.getInt("backup_en"));
|
baseup.setBackup_flag(rs.getInt("backup_flag"));
|
baseup.setNote(rs.getString("note"));
|
list.add(baseup);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//根据数据库名查询该数据库下的表
|
public List serchByCondition(Object obj) {
|
Database_backup baseup=(Database_backup) obj;
|
String sql="select num,database_name,table_name,backup_en,note from web_site.tb_database_backup " +
|
" where database_name like ?";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+baseup.getDatabase_name()+"%"} , new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Database_backup baseup=new Database_backup();
|
baseup.setNum(rs.getInt("num"));
|
baseup.setDatabase_name(rs.getString("database_name"));
|
baseup.setTable_name(rs.getString("table_name"));
|
baseup.setBackup_en(rs.getInt("backup_en"));
|
baseup.setBackup_flag(rs.getInt("backup_flag"));
|
baseup.setNote(rs.getString("note"));
|
list.add(baseup);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//查询数据库备份表中所有的数据库
|
public List searchAllDatabase(){
|
String sql="select distinct database_name from web_site.tb_database_backup ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
list.add(rs.getString("database_name"));
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//根据数据库名查询所有的表
|
public List searchAllTable(Object obj){
|
Database_backup baseup=(Database_backup) obj;
|
String sql="select distinct table_name from web_site.tb_database_backup " +
|
" where database_name=?";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{baseup.getDatabase_name()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
list.add(rs.getString("table_name"));
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//查询个数
|
public int searchNum(Object obj){
|
Database_backup baseup=(Database_backup) obj;
|
String sql=" select count(num) as number from web_site.tb_database_backup " +
|
" where ";
|
//全部
|
String allSqlT=" num!=?";
|
//处于备份的个数
|
String allSqlF=" backup_en=?";
|
if(baseup.getNum()==0){
|
sql+=allSqlT;
|
}else{
|
sql+=allSqlF;
|
}
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{baseup.getNum()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
int number=rs.getInt("number");
|
list.add(number);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
int number=0;//最后的返回结果
|
if(list!=null&&list.size()>0){
|
number=(Integer) list.get(list.size()-1);
|
}
|
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;
|
}
|
public static void main(String[] args) {
|
/*String sql1="show databases ";
|
List<String> list1=DAOHelper.executeQuery(sql1, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
if(!rs.getString("database").equals("information_schema")
|
&&!rs.getString("database").equals("mysql")
|
&&!rs.getString("database").equals("performance_schema")
|
&&!rs.getString("database").equals("sys")){
|
list.add(rs.getString("database"));
|
}
|
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
System.out.println("list1:"+list1.size());
|
List list3=new ArrayList();
|
if(list1!=null&&list1.size()>0){
|
for (String database_name : list1) {
|
String sql2="select table_name from information_schema.tables where table_schema='"+database_name+"'";
|
List<String> list2=DAOHelper.executeQuery(sql2, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
list.add(rs.getString("table_name"));
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
System.out.println("list2:"+list2.size());
|
if(list2!=null&&list2.size()>0){
|
for (String table_name : list2) {
|
Database_backup baseup=new Database_backup();
|
baseup.setDatabase_name(database_name);
|
baseup.setTable_name(table_name);
|
list3.add(baseup);
|
}
|
}
|
}
|
}
|
System.out.println("list3:"+list3.size());
|
Database_backupImpl dimpl=new Database_backupImpl();
|
boolean bl=dimpl.addPro(list3);
|
System.out.println(bl);*/
|
Database_backupImpl dimpl=new Database_backupImpl();
|
dimpl.updateProAll();
|
}
|
}
|
