文件上传与下载之数据库实现
程序员文章站
2022-06-18 17:48:44
...
文件上传与下载之数据库实现
一、Javabean与数据库设计
1、javabean设计
为了实现文件上传与下载的功能，我们把文件相关的信息封装到FileUploadDownload对象中，方便操作和管理文件的信息
private String id;
private Stringuuidname; //上传文件的名称，文件的uuid名
private String filename;//上传文件的真实名称
private Stringsavepath; //记住文件的位置
private Dateuploadtime; //文件的上传时间
private Stringdescription; //文件的描述
private String username;
2、数据库fileChange与表file
文件相关信息对象：FileUploadDownload里的信息存在file表中
--数据库 建库建表语句
create database fileChange;
use fileChange;
create table file(
id varchar(100) primary key,
uuidname varchar(100),
filename varchar(100),
savepath varchar(100),
uploadtime Timestamp,
description varchar(100),
username varchar(30)
二、项目准备环境
组织包结构 , 导入jar包, javabean, 工具类
（1）组织包结构:
（2）导入jar包:
Beanutils(2个jar)+c3p0(1jar,1配置文件)+dbutils(1个jar)+ mysql驱动(1个)+commons-fileupload(2jar)
（3）Javabean:
三、项目代码实现
1、项目使用说明
访问index.jsp页面，选择上传文件或者查看文件列表
（1）选择上传文件
此时跳转访问上传表单页面upload.jsp，然后用户自己选择上传文件，并填写相关信息，然后提交表单；（页面）
提交表单之后，访问UploadServlet，UploadServlet通过调用工具类WebUtils，进行上传文件，并且获得上传文件信息；（web层）
然后web层调用service层【FileService】的insert方法，进行保存文件相关的信息；（service层）
最后，service层【FileService】通过调用dao层的insert方法进行插入。至此，上传完成（dao层）
注意：此处的dao层与service是进行了解耦合的，通过
FileDao（dao接口）+FileDaoFactory （dao工厂）+ FileDaoImpl （dao实现类）+dao.properties（dao配置文件） 完成解耦合。
service实际上调用的FileDaoFactory（dao工厂）的静态方法，加上反射技术和配置文件的引用，使得dao工厂读取配置文件就可以创建dao接口对应的实现类的实例。从而实现解耦合的操作。
（2）选择查看文件列表
此时跳转访问ListFileServlet（web层），然后调用service层的list方法，最后调用dao层的list方法，返回文件查询列表，保存并显示在 listFile.jsp页面，
然后用户根据自己的需要，选择自己要下载的文件，点击文件名进行下载，跳转访问DownloadServlet（层），通过先后调用service层和dao层的select(id)方法看看要下载的文件是否存在，如果不存在，则进行提示；如果存在，则进行下载文件
2、项目结构图
3、上传代码
（1）页面：index.jsp+upload.jsp+message.jsp
【1】index.jsp
<%@ page language="java" import="java.util.*"pageEncoding="UTF-8"%>
<!DOCTYPE HTML PUBLIC "-//W3C//DTDHTML 4.01 Transitional//EN">
<html>
<head>
</head>
<body>
<!--写法错误 -->
<!-- <a href="${PageContext.request.contextPath}/upload.jsp">上传文件</a><br/> -->
<a href="${pageContext.request.contextPath }/upload.jsp">上传文件</a><br/>
<!-- <a href="/file_upload_download/upload.jsp">上传文件</a><br/> -->
<a href="${pageContext.request.contextPath }/listFile">查询文件</a><br/>
</body>
</html>【2】upload.jsp
<%@ page language="java" import="java.util.*"pageEncoding="UTF-8"%>
<!DOCTYPE HTML PUBLIC "-//W3C//DTDHTML 4.01 Transitional//EN">
<html>
<head>
</head>
<body>
<h1> 文件上传</h1>
<!--
privateString savepath; //记住文件的位置
privateDate uploadtime; //文件的上传时间
privateString description; //文件的描述
-->
<form action="${pageContext.request.contextPath}/upload" enctype="multipart/form-data"method="post">
<table>
<tr>
<td>上传文件名</td><td><input type="file"name="filename"></td>
</tr>
<tr>
<td>上传者</td><td><input type="text"name="username"></td>
</tr>
<tr>
<td>上传描述</td><td><textarea name="description"rows="5" cols="30"></textarea></td>
</tr>
<tr>
<tr>
<td colspan="2"align="center"><input type="submit"value="提交" > <input type="reset"value="重置"></td>
</tr>
</table>
</form>
</body>
</html>【3】message.jsp
<%@ page language="java" import="java.util.*"pageEncoding="UTF-8"%>
<!DOCTYPE HTML PUBLIC "-//W3C//DTDHTML 4.01 Transitional//EN">
<html>
<head>
</head>
<body>
${message }
</body>
</html>
（2）web层: UploadServlet
package file.web;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URLEncoder;
import java.util.List;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadBase.FileSizeLimitExceededException;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import file.domain.FileUploadDownload;
import file.service.FileService;
import file.utils.WebUtils;
public class UploadServlet extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
if (!ServletFileUpload.isMultipartContent(request)) {
request.setAttribute("message", "不是请求的信息表单，请确认表单属性是否正确");
request.getRequestDispatcher("/message.jsp").forward(request,
response);
return;
}
try {
//调用工具类，获得上传文件信息
FileUploadDownload fud=WebUtils.doFileUpload(request);
FileService service=new FileService();
service.insert(fud);//保存上传文件信息
request.setAttribute("message", "上传文件成功");
request.getRequestDispatcher("/message.jsp").forward(request,response);
} catch (FileSizeLimitExceededException e) {
request.setAttribute("message", "对不起，您上传的文件大小超过了大小的限制");
request.getRequestDispatcher("/message.jsp").forward(request,response);
}
}
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doGet(request, response);
}
}（3）service层：FileService
package file.service;
import java.util.List;
import file.dao.FileDao;
import file.daoFactory.FileDaoFactory;
import file.domain.FileUploadDownload;
//上传文件的业务层
public class FileService {
//FileDaoImpl实现类实例
FileDao f= FileDaoFactory.getInstance().createDao(FileDao.class);
//上传文件
public void insert(FileUploadDownload fud) {
f.insert(fud);//调用dao层进行添加
}
//查询文件
public List<FileUploadDownload> list() {
List<FileUploadDownload> list=f.list();
return list;
}
//通过id获得文件对象的全部信息
public FileUploadDownload select(String id) {
FileUploadDownload fud=f.select(id);
return fud;
}
}（4）dao层：FileDao+FileDaoFactory+FileDaoImpl+ dao.properties
【1】FileDao
package file.dao;
import java.util.List;
import file.domain.FileUploadDownload;
//dao接口
public interface FileDao {
public void insert(FileUploadDownload fud);//上传文件
public List<FileUploadDownload> list();//查询文件
public FileUploadDownload select(String id);//通过id获得文件的全部信息
}【2】FileDaoFactory
package file.daoFactory;
import java.util.ResourceBundle;
//dao工厂
public class FileDaoFactory {
private FileDaoFactory(){};//不能构造
private static FileDaoFactory factory=new FileDaoFactory();
//获取工厂实例
public static FileDaoFactory getInstance(){
return factory;
}
//用于返回传进来的一个类的实例对象
/*
* 1、传进来FileDao.class
* 2、读取dao.properties文件，获取FileDao对应的实现类
* 3、FileDao对应的实现类实例
*/
public<T> T createDao(Class<T> t){
//1、FileDao.class-->FileDao
String simpleName=t.getSimpleName();
//2、读取配置文件，获取FileDao对应的实现类
//FileDao=file.daoImpl.FileDaoImpl
String calzzName=ResourceBundle.getBundle("dao").getString(simpleName);
try {
//3、FileDao对应的实现类实例
T instance=(T) Class.forName(calzzName).newInstance();
return instance;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
}【3】FileDaoImpl
package file.daoImpl;
import java.sql.SQLException;
import java.util.List;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import file.dao.FileDao;
import file.domain.FileUploadDownload;
import file.utils.JDBCUtils;
//dao实现类
public class FileDaoImpl implements FileDao {
QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
@Override
public void insert(FileUploadDownload fud) {// 上传文件
/*
*
* private String id; private String uuidname; //上传文件的名称，文件的uuid名
* private String filename; //上传文件的真实名称 private String savepath;
* //记住文件的位置 private Date uploadtime; //文件的上传时间 private String
* description; //文件的描述 private String username;
*/
Object[] param = { fud.getId(), fud.getUuidname(), fud.getFilename(),
fud.getSavepath(), fud.getDescription(), fud.getUsername() };// 没有时间：fud.getUploadtime()
try {
qr.update("insert into file values(?,?,?,?,null,?,?)", param);
} catch (SQLException e) {
throw new RuntimeException(e);
}
}
@Override
public List<FileUploadDownload> list() {// 查询文件
try {
List<FileUploadDownload> list = qr.query("select * from file",
new BeanListHandler(FileUploadDownload.class));
return list;
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
@Override
public FileUploadDownload select(String id) {//通过id获得文件的全部信息
try {
FileUploadDownload fud=qr.query("select * from file where id=?",new BeanHandler(FileUploadDownload.class),id);
return fud;
} catch (SQLException e) {
e.printStackTrace();
return null;
}
}
}【4】dao.properties
FileDao=file.daoImpl.FileDaoImpl
（5）上传工具类：WebUtils
package file.utils;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URLEncoder;
import java.util.Arrays;
import java.util.List;
import java.util.UUID;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadBase;
import org.apache.commons.fileupload.FileUploadBase.FileSizeLimitExceededException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import file.domain.FileUploadDownload;
/*
* 上传文件的工具类
*/
public class WebUtils {
public static FileUploadDownload doFileUpload(HttpServletRequest request) throws FileSizeLimitExceededException {
FileUploadDownload fud = new FileUploadDownload();// 文件信息对象
try {
DiskFileItemFactory factory = new DiskFileItemFactory();
// 临时文件夹temp
factory.setRepository(new File(request.getSession().getServletContext().getContextPath()+"/temp"));
// factory.setRepository(new File("/temp"));// 临时文件夹temp
factory.setSizeThreshold(1024 * 1024);// 临时缓冲区大小为1M
ServletFileUpload parse = new ServletFileUpload(factory);// 解析器
//上传文件大小
parse.setFileSizeMax(1024 * 1024 * 2);// 单个文件大小限制为2M
parse.setSizeMax(1024 * 1024 * 20);// 总的文件大小限制为20M
//解决中文文件名的乱码
parse.setHeaderEncoding("utf-8");
List<FileItem> list = parse.parseRequest(request);
for (FileItem fileItem : list) {
// 普通表单
if (fileItem.isFormField()) {
String fieldName = fileItem.getFieldName();
// String value = fileItem.getString();
String value = fileItem.getString("utf-8");// 解决字段的中文乱码问题
System.out.println("fieldName:" + fieldName);
System.out.println("value:" + value);
// 将当前字段封装到fud对象中对应的字段中去
//普通字段都通过这个保存到fud中
BeanUtils.setProperty(fud, fieldName, value);
}
// 文件
else {
String filename = fileItem.getName();// 获取文件名
//文件名：aa.txt 与c:\a\b\c\aa.txt的处理 统一
int index=filename.lastIndexOf("\\");
if(index!=-1){
filename=filename.substring(index+1);
}
String realPath=request.getSession().getServletContext().getRealPath("/WEB_INF/upload");
//生成随机文件夹
String savePath=generateSavePath(realPath,filename);
//生成唯一的文件名
String uuidname=generateUUIDName(filename);
// 上传文件
InputStream in = fileItem.getInputStream();// 获取文件读取流
// OutputStream out = new FileOutputStream("d:/" + name);
//保存文件夹：savePath 唯一文件名：uuidname
OutputStream out = new FileOutputStream(new File(savePath,uuidname));
byte[] buf = new byte[1024];
int len = 0;
while ((len = in.read(buf)) != -1) {
out.write(buf, 0, len);
}
in.close();
out.close();
//删除临时文件
fileItem.delete();
fud.setFilename(filename);//文件名
fud.setUuidname(uuidname);//唯一文件名
fud.setSavepath(savePath);//保存路径
fud.setId(UUID.randomUUID().toString());//id
}
}
return fud;//返回文件信息封装对象
} catch (FileUploadBase.FileSizeLimitExceededException e) {
// e.printStackTrace();//仅仅只是打印异常错误信息
//使用失败，因为此处并没有response
// request.setAttribute("message", "对不起，您上传的文件大小超过了大小的限制");
// request.getRequestDispatcher("/message.jsp").forward(request,response);
//怎么办？
//抛出一个异常出去 实际上异常也是一个返回值
//抛异常【编译时异常 还是 运行时异常】
//编译时异常
throw e;//记得抛出异常要在方法中进行声明
}
catch(Exception e){
throw new RuntimeException(e);//抛出运行时异常
}
}
//生成唯一的文件名
private static String generateUUIDName(String filename) {
return UUID.randomUUID().toString()+"_"+filename;
}
//生成随机文件夹
private static String generateSavePath(String realPath, String filename) {
int hashCode=filename.hashCode();
//通过位运算，计算出一级和二级目录的数字
int first=hashCode & (0xf);//以及目录
int second=(hashCode>>4)&(0xf);//二级目录
String savePath=realPath+"/"+first+"/"+second;
File f=new File(savePath);
if(!f.exists()){
f.mkdirs();//创建多级目录
}
return savePath;//保存路径
}
}
（6）数据库相关：JDBCUtils工具类+c3p0-config.xml配置文件【通用】
【1】JDBCUtils工具类
package file.utils;
import java.sql.Connection;
import java.sql.SQLException;
import javax.sql.DataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource;
/**
* 工具类 提供数据库连接池 和数据库连接
*
* @author zhanglei
*
*/
public class JDBCUtils {
private static DataSource dataSource = new ComboPooledDataSource();
public static DataSource getDataSource() {
return dataSource;
}
/**
* 当DBUtils需要手动控制事务时，调用该方法获得一个连接
*
* @return
* @throws SQLException
*/
public static Connection getConnection() throws SQLException {
return dataSource.getConnection();
}
}
【2】c3p0-config.xml配置文件
<?xml version="1.0"encoding="UTF-8"?>
<c3p0-config>
<default-config>
<property name="user">root</property>
<property name="password">1234</property>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost/fileChange?useSSL=false</property>
</default-config> <!-- This app is massive! -->
</c3p0-config>（7）web配置文件web.xml【通用】
<?xml version="1.0"encoding="UTF-8"?>
<web-app version="3.0"
xmlns="http://java.sun.com/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaeehttp://java.sun.com/xml/ns/javaee/web-app_3_0.xsd">
<servlet>
<servlet-name>UploadServlet</servlet-name>
<servlet-class>file.web.UploadServlet</servlet-class>
</servlet>
<servlet>
<servlet-name>ListFileServlet</servlet-name>
<servlet-class>file.web.ListFileServlet</servlet-class>
</servlet>
<servlet>
<servlet-name>DownloadServlet</servlet-name>
<servlet-class>file.web.DownloadServlet</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>UploadServlet</servlet-name>
<url-pattern>/upload</url-pattern>
</servlet-mapping>
<servlet-mapping>
<servlet-name>ListFileServlet</servlet-name>
<url-pattern>/listFile</url-pattern>
</servlet-mapping>
<servlet-mapping>
<servlet-name>DownloadServlet</servlet-name>
<url-pattern>/download</url-pattern>
</servlet-mapping>
</web-app>4、查询文件代码
（1）页面（查询文件结果显示）：ListFile.jsp
<%@ page language="java" import="java.util.*"pageEncoding="UTF-8"%>
<%@taglib uri="http://java.sun.com/jsp/jstl/core"prefix="c" %>
<!DOCTYPE HTML PUBLIC "-//W3C//DthHTML 4.01 Transitional//EN">
<html>
<head>
</head>
<body>
<table align="center"border="1">
<tr>
<th>上传者</th><th>上传文件名</th><th>上传时间</th><th>文件位置</th><th>文件描述</th><th>下载</th>
</tr>
<c:forEach var="file"items="${list }">
<tr>
<td>${file.username }</td>
<td>${file.filename }</td>
<td>${file.uploadtime }</td>
<td>${file.savepath }</td>
<td>${file.description }</td>
<td><font color="red"><a href="${pageContext.request.contextPath}/download?id=${file.id}">下载</a></font></td>
</tr>
</c:forEach>
</table>
</body>
</html>
（2）web层：ListFileServlet
package file.web;
import java.io.IOException;
import java.util.List;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import file.domain.FileUploadDownload;
import file.service.FileService;
public class ListFileServlet extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
//查询显示所有的数据到页面
FileService service=new FileService();
List<FileUploadDownload> list=service.list();
request.setAttribute("list", list);//保留查询结果
request.getRequestDispatcher("/listFile.jsp").forward(request, response);
}
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doGet(request, response);
}
}（3）说明
其它service层和dao层代码，已经在3、上传代码中提供
5、下载文件代码
（1）web层：DownloadServlet
package file.web;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URLEncoder;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import file.domain.FileUploadDownload;
import file.service.FileService;
public class DownloadServlet extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
//得到id参数
String id = request.getParameter("id");
FileService service=new FileService();
FileUploadDownload fud=service.select(id);//通过id获取文件相关信息
String path=fud.getSavepath();//保存路径
String uuidname=fud.getUuidname();//保存文件名
File f=new File(path,uuidname);//要下载的文件的存放位置 path/name
//健壮性判断
if(!f.exists()){
request.setAttribute("message", "对不起，当前文件已删除");
request.getRequestDispatcher("/message.jsp").forward(request, response);
}
//将中文的文件名编码后再放到http的响应头中去，编码之后浏览器收到后会自动解码
String filename=URLEncoder.encode(fud.getFilename(),"utf-8");
//设置参数，使得浏览器可以以下载的方式打开文件。
response.setHeader("content-disposition", "attachement;filename="+filename);
//将要下载的文件当做一个inputStream读取进来
InputStream in=new FileInputStream(f);
//读进来后，再写到response.getOutputStream()去就可以了
//相应的数据
OutputStream out=response.getOutputStream();
byte[] buf=new byte[1024];
int len=0;
while((len=in.read(buf))!=-1){
out.write(buf, 0, len);
}
in.close();
out.close();
System.out.println("下载文件成功");
}
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doGet(request, response);
}
}（2）说明
其它service层和dao层代码，已经在3、上传代码中提供
四、项目效果图
1、主页
2、上传文件
3、查询和下载文件
4、下载文件
五、实现源码
可看本人的github项目地址：
https://github.com/Forever99/file_upload_download