package com.test.dao.file_dir;
import java.io.File;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
import java.util.Stack;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
import javax.swing.Icon;
import javax.swing.ImageIcon;
import javax.swing.JOptionPane;
import com.test.db.DBManage;
import com.test.tools.Tools;
import com.test.ui.FilePanel;
/**
* 文件操作管理类
* @author asus
*
*/
public class FileManager {
// 文件分割
public FileSeperate fileSeperate ;
// 文件合并
public FileCombination fileCombination ;
// 删除文件时用到的栈
private Stack<Integer> deleteFileStack = new Stack<Integer>() ;
// 数据库操作
public DBManage dbmanage ;
public Connection connection ;
public PreparedStatement preparedStatement ;
public ResultSet resultSet ;
public HdfsTools hdfsTool ;
public FileManager(DBManage dbmanage) {
this.dbmanage = dbmanage ;
this.hdfsTool = new HdfsTools() ;
}
public FileManager() {
this.dbmanage = new DBManage() ;
this.hdfsTool = new HdfsTools() ;
}
// 显示文件列表
public void showFile(Icon icon , String fileName) {
Tools.loginSuccess.filePanel = new FilePanel(icon , fileName) ;
Tools.loginSuccess.fileBottomPanel.add(Tools.loginSuccess.filePanel) ;
Tools.loginSuccess.repaint() ;
}
// 显示文件列表
public void showFileList(int parentId , int userId) {
try {
String showFile = "select * from file where parent_id = ? and u_id = ? order by f_type DESC" ;
this.connection = this.dbmanage.getConnection() ;
// this.preparedStatement = this.dbmanage.getPreparedStatement(Tools.SHOW_FILE) ;
this.preparedStatement = this.dbmanage.getPreparedStatement(showFile) ;
this.preparedStatement.setInt(1, parentId) ;
this.preparedStatement.setInt(2, userId) ;
this.resultSet = this.preparedStatement.executeQuery() ;
while(this.resultSet.next()) {
// 取得文件名
String fileName = this.resultSet.getString("f_name") ;
String filetype = this.resultSet.getString("f_type") ;
// 显示文件图标
if(filetype.equals("文件")) {
this.showFile(new ImageIcon("image/file.png") , fileName) ;
}else if(filetype.equals("文件夹")) {
this.showFile(new ImageIcon("image/dir.png") , fileName) ;
}
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
// 关闭连接
if(this.resultSet != null) {
try {
this.resultSet.close() ;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
this.dbmanage.closeLink() ;
}
}
// 创建文件夹
public void createDir() {
//随机产生1000以内的命名规则
String filename = "新建文件夹"+ (int)(Math.random()*1000);
Date date = new Date();
String type = "文件夹";
long size = 0 ;
//随机产生的文件名若重名，则继续随机产生，知道不重名为止
while (!checkFileName(filename)) {
filename = "新建文件夹"+ (int)(Math.random()*1000);
}
try {
String createDir = "insert into File (u_id , f_name , f_date , f_type , f_size , parent_id) values(? , ? , ? , ? , ? , ?)" ;
this.connection = this.dbmanage.getConnection() ;
// this.preparedStatement = this.dbmanage.getPreparedStatement(Tools.CREATE_DIR) ;
this.preparedStatement = this.dbmanage.getPreparedStatement(createDir) ;
this.preparedStatement.setInt(1, Tools.userId) ;
this.preparedStatement.setString(2, filename) ;
this.preparedStatement.setString(3, date.toString()) ;
this.preparedStatement.setString(4, type) ;
this.preparedStatement.setLong(5, size) ;
this.preparedStatement.setInt(6, Tools.parentIdStack.lastElement()) ;
this.preparedStatement.execute() ;
// 新建的文件夹在界面上显示出来
Tools.loginSuccess.filePanel = new FilePanel(new ImageIcon("image/dir.png") , filename) ;
Tools.loginSuccess.fileBottomPanel.add(Tools.loginSuccess.filePanel) ;
Tools.loginSuccess.repaint();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
// 关闭连接
if(this.resultSet != null) {
try {
this.resultSet.close() ;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
this.dbmanage.closeLink() ;
}
}
/**
* 检查文件是否重名,通过文件类型和文件名查询
*/
public boolean checkFileName(String filename) {
try {
String checkFileName = "select * from File where u_id = ? and f_name = ? and parent_id = ?" ;
this.connection = this.dbmanage.getConnection() ;
// this.preparedStatement = this.dbmanage.getPreparedStatement(Tools.CHECK_FILE_NAME) ;
this.preparedStatement = this.dbmanage.getPreparedStatement(checkFileName) ;
this.preparedStatement.setInt(1, Tools.userId) ;
this.preparedStatement.setString(2, filename) ;
this.preparedStatement.setInt(3, Tools.parentIdStack.lastElement()) ;
this.resultSet = this.preparedStatement.executeQuery() ;
while(this.resultSet.next()) {
return false ;
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
return false ;
} finally {
// 关闭连接
if(this.resultSet != null) {
try {
this.resultSet.close() ;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
this.dbmanage.closeLink() ;
}
return true ;
}
/**
* 检查文件是否重名,通过文件ID号查询
*/
public boolean checkPasteFileName() {
try {
String checkPasteFileName = "select * from File where f_name = (select f_name from File where f_id = ?) and u_id = ? and parent_id = ?" ;
this.connection = this.dbmanage.getConnection() ;
// this.preparedStatement = this.dbmanage.getPreparedStatement(Tools.CHECK_PASTE_FILE_NAME) ;
this.preparedStatement = this.dbmanage.getPreparedStatement(checkPasteFileName) ;
this.preparedStatement.setInt(1, Tools.cutFileId) ;
this.preparedStatement.setInt(2, Tools.userId) ;
this.preparedStatement.setInt(3, Tools.parentIdStack.lastElement()) ;
this.resultSet = this.preparedStatement.executeQuery() ;
if(this.resultSet.next()) {
JOptionPane.showMessageDialog(null, "该文件夹已存在，不能粘贴", "警告信息", 1);
return false ;
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
return false ;
} finally {
// 关闭连接
if(this.resultSet != null) {
try {
this.resultSet.close() ;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
this.dbmanage.closeLink() ;
}
return true ;
}
/**
* 打开文件夹
*/
public boolean openDir(String filename) {
try {
String queryFileId = "select * from File where u_id = ? and f_name = ? and parent_id = ?" ;
this.connection = this.dbmanage.getConnection() ;
// this.preparedStatement = this.dbmanage.getPreparedStatement(Tools.QUERY_FILE_ID) ;
this.preparedStatement = this.dbmanage.getPreparedStatement(queryFileId) ;
this.preparedStatement.setInt(1, Tools.userId) ;
this.preparedStatement.setString(2, filename) ;
this.preparedStatement.setInt(3, Tools.parentIdStack.lastElement()) ;
this.resultSet = this.preparedStatement.executeQuery() ;
int fileId = -1;
String filetype = null ;
if(this.resultSet.next()) {
fileId = this.resultSet.getInt("f_id") ;
filetype = this.resultSet.getString("f_type") ;
}
// 双击打开文件夹
if(filetype != null && filetype.equals("文件夹")) {
Tools.parentIdStack.add(fileId) ;
Tools.loginSuccess.fileBottomPanel.removeAll() ;
this.showFileList(Tools.parentIdStack.lastElement(), Tools.userId) ;
Tools.loginSuccess.fileBottomPanel.repaint() ;
// 设置文件路径
String context = Tools.loginSuccess.search.getText() ;
Tools.loginSuccess.search.setText(context + "\\" + filename) ;
}else if(filet
基于Hadoop的分布式文件系统，使用Java语言开发实现了一个本地文件管理系统+源代码+文档说明 （191个子文件） 
FileManager.class 27KB User.class 10KB FileUpload.class 9KB LoginSuccess.class 8KB FilePanelEvent.class 8KB HdfsTools.class 8KB LoginSuccessEvent.class 7KB HadoopHDFS.class 6KB FileDelete.class 6KB FileSeperate.class 6KB UploadTableManager.class 5KB LoginFrame.class 5KB FileDownload.class 5KB FindPassword.class 5KB FileBlockEncrypt.class 4KB Register.class 4KB FileCombination.class 4KB FileBlockDecrypt.class 4KB ChangePassword.class 4KB CloseWindowOperation.class 3KB DownloadListTableThread.class 3KB UploadListTableThread.class 3KB DownloadTableManager.class 3KB FilePanel.class 3KB LoginEvent.class 3KB MD5.class 2KB AddHdfsNode.class 2KB JTextField2.class 2KB DBManage.class 2KB AddHdfsEvent.class 1KB RegisterEvent.class 1KB ChangePasswordEvent.class 1KB FindPasswordEvent.class 1KB Tools.class 1KB LoginSuccess$1.class 1015B Start.class 799B LoginSuccess$4.class 747B LoginSuccess$3.class 745B LoginSuccess$2.class 735B ShowMessage.class 714B HdfsNodesListThread.class 704B JFileChooser2.class 308B .classpath 8KB variablesAndContainers.dat 115B .fatjar 319B properties.index 57B version.ini 26B
hadoop-hdfs-2.6.0.jar 7.46MB hadoop-common-2.6.0.jar 3.15MB guava-11.0.2.jar 1.57MB commons-math3-3.1.1.jar 1.53MB mockito-all-1.8.5.jar 1.35MB xercesImpl-2.9.1.jar 1.17MB netty-3.6.2.Final.jar 1.14MB snappy-java-1.0.4.1.jar 973KB jaxb-impl-2.2.3-1.jar 869KB mysql-connector-java-5.1.20-bin.jar 784KB zookeeper-3.4.6.jar 774KB jackson-mapper-asl-1.9.13.jar 762KB jersey-server-1.9.jar 696KB apacheds-kerberos-codec-2.0.0-M15.jar 675KB commons-collections-3.2.1.jar 562KB jetty-6.1.26.jar 527KB jets3t-0.9.0.jar 527KB protobuf-java-2.5.0.jar 521KB beautyeye_lnf.jar 480KB log4j-1.2.17.jar 478KB jersey-core-1.9.jar 448KB httpclient-4.2.5.jar 423KB emma.jar 418KB jasper-compiler-5.5.23.jar 399KB commons-httpclient-3.1.jar 298KB avro-1.7.4.jar 296KB commons-configuration-1.6.jar 292KB commons-lang-2.6.jar 278KB commons-net-3.1.jar 267KB curator-recipes-2.6.0.jar 242KB junit-4.11.jar 239KB commons-compress-1.4.1.jar 236KB jackson-core-asl-1.9.13.jar 227KB httpcore-4.2.5.jar 222KB commons-beanutils-core-1.8.0.jar 201KB xml-apis-1.3.04.jar 190KB gson-2.2.4.jar 186KB commons-beanutils-1.7.0.jar 184KB jsch-0.1.42.jar 181KB curator-framework-2.6.0.jar 181KB commons-io-2.4.jar 181KB jetty-util-6.1.26.jar 173KB jersey-json-1.9.jar 144KB commons-digester-1.8.jar 140KB commons-el-1.0.jar 110KB jaxb-api-2.2.2.jar 103KB servlet-api-2.5.jar 103KB jsp-api-2.1.jar 98KB xz-1.0.jar 92KB json.jar 92KB api-util-1.0.0-M20.jar 78KB jasper-runtime-5.5.23.jar 75KB curator-client-2.6.0.jar 67KB共 191 条
- 1
- 2
资源评论
