您的位置：首页 > 数据库

文件上传与下载之数据库实现

2017-11-10 11:14 211 查看

文件上传与下载之数据库实现

一、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 }/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>

<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> 
</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

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航