学生资助管理系统-毕业设计.zip

package com.fh.util; import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.OutputStreamWriter; import java.net.Socket; import java.sql.Connection; import java.sql.DatabaseMetaData; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Properties; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; /** * 说明：用于备份、还原数据库、在线编辑SQL * 创建人：FH Q313596790 * 修改时间：2016年3月29日 * @version */ public class DbFH{ private static Log logger = LogFactory.getLog(DbFH.class); private static Properties pros = getPprVue(); public static Map<String, String> backUpTableList = new ConcurrentHashMap<String, String>(); public static Map<String, String> recoverTableList = new ConcurrentHashMap<String, String>(); private static DbFH dbFH = new DbFH(); public static void main(String[] arg){ try { String str = DbFH.getDbFH().backup("").toString();//调用数据库备份 System.out.println(FileUtil.getFilesize(str)); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } public static DbFH getDbFH(){ return dbFH; } /**执行数据库备份入口 * @param tableName 表名 * @return * @throws InterruptedException * @throws ExecutionException */ public Object backup(String tableName) throws InterruptedException, ExecutionException { if(null != backUpTableList.get(tableName)) return null; backUpTableList.put(tableName, tableName); // 标记已经用于备份(防止同时重复备份,比如备份一个表的线程正在运行，又发来一个备份此表的命令) ExecutorService pool = Executors.newFixedThreadPool(2); Callable<Object> fhc = new DbBackUpCallable(tableName); //创建一个有返回值的线程 Future<Object> f1 = pool.submit(fhc); //启动线程 String backstr = f1.get().toString(); //获取线程执行完毕的返回值 pool.shutdown(); //关闭线程 return backstr; } /**执行数据库还原入口 * @param tableName 表名 * @param sqlFilePath 备份文件存放完整路径 * @return * @throws InterruptedException * @throws ExecutionException */ public Object recover(String tableName,String sqlFilePath) throws InterruptedException, ExecutionException { if(null != recoverTableList.get(tableName)) return null; recoverTableList.put(tableName, tableName); // 标记已经用于还原(防止同时重复还原,比如还原一个表的线程正在运行，又发来一个还原此表的命令) ExecutorService pool = Executors.newFixedThreadPool(2); Callable<Object> fhc = new DbRecoverCallable(tableName,sqlFilePath); //创建一个有返回值的线程 Future<Object> f1 = pool.submit(fhc); //启动线程 String backstr = f1.get().toString(); //获取线程执行完毕的返回值 pool.shutdown(); //关闭线程 return backstr; } /**获取本数据库的所有表名(通过PageData) * @return * @throws SQLException * @throws ClassNotFoundException */ public static Object[] getTables(PageData pd) throws ClassNotFoundException, SQLException{ String dbtype = pd.getString("dbtype"); //数据库类型 String username = pd.getString("username"); //用户名 String password = pd.getString("password"); //密码 String address = pd.getString("dbAddress"); //数据库连接地址 String dbport = pd.getString("dbport"); //端口 String databaseName = pd.getString("databaseName"); //数据库名 Connection conn = DbFH.getCon(dbtype,username,password,address+":"+dbport,databaseName); if("oracle".equals(dbtype)){databaseName = username.toUpperCase();} Object[] arrOb = {databaseName,DbFH.getTablesByCon(conn, "sqlserver".equals(dbtype)?null:databaseName),dbtype}; return arrOb; } /**获取本数据库的所有表名(通过配置文件) * @return * @throws SQLException * @throws ClassNotFoundException */ public static Object[] getTables() throws ClassNotFoundException, SQLException{ String dbtype = pros.getProperty("dbtype"); //数据库类型 String username = pros.getProperty("username"); //用户名 String password = pros.getProperty("password"); //密码 String address = pros.getProperty("dbAddress"); //数据库连接地址 String dbport = pros.getProperty("dbport"); //端口 String databaseName = pros.getProperty("databaseName"); //数据库名 Connection conn = DbFH.getCon(dbtype,username,password,address+":"+dbport,databaseName); if("oracle".equals(dbtype)){databaseName = username.toUpperCase();} Object[] arrOb = {databaseName,DbFH.getTablesByCon(conn, "sqlserver".equals(dbtype)?null:databaseName),dbtype}; return arrOb; } /** * @return 获取conn对象(通过配置文件) * @throws ClassNotFoundException * @throws SQLException */ public static Connection getFHCon() throws ClassNotFoundException, SQLException{ String dbtype = pros.getProperty("dbtype"); //数据库类型 String username = pros.getProperty("username"); //用户名 String password = pros.getProperty("password"); //密码 String address = pros.getProperty("dbAddress"); //数据库连接地址 String dbport = pros.getProperty("dbport"); //端口 String databaseName = pros.getProperty("databaseName"); //数据库名 return DbFH.getCon(dbtype,username,password,address+":"+dbport,databaseName); } /** * @return 获取conn对象(通过PageData) * @throws ClassNotFoundException * @throws SQLException */ public static Connection getFHCon(PageData pd) throws ClassNotFoundException, SQLException{ String dbtype = pd.getString("dbtype"); //数据库类型 String username = pd.getString("username"); //用户名 String password = pd.getString("password"); //密码 String address = pd.getString("dbAddress"); //数据库连接地址 String dbport = pd.getString("dbport"); //端口 String databaseName = pd.getString("databaseName"); //数据库名 return DbFH.getCon(dbtype,username,password,address+":"+dbport,databaseName); } /** * @param dbtype 数据库类型 * @param username 用户名 * @param password 密码 * @param dburl 数据库连接地址:端口 * @param databaseName 数据库名 * @return * @throws SQLException * @throws ClassNotFoundException */ public static Connection getCon(String dbtype,String username,String password,String dburl,String databaseName) throws SQLException, ClassNotFoundException{ if("mysql".equals(dbtype)){ Class.forName("com.mysql.jdbc.Driver"); return DriverManager.getConnection("jdbc:mysql://"+dburl+"/"+databaseName+"?user="+username+"&password="+password); }else if("oracle".equals(dbtype)){ Class.forName("oracle.jdbc.driver.OracleDriver"); return DriverManager.getConnection("jdbc:oracle:thin:@"+dburl+":"+databaseName, username, password); }else if("sqlserver".equals(dbtype)){ Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); return DriverManager.getConnection("jdbc:sqlserver://"+dburl+"; DatabaseName="+databaseName, username, password); }else{ return null; } } /**获取某个conn下的所有表 * @param conn 数据库连接对象 * @param schema mysql:数�