package com.nova.common;
import java.io.File;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.Reader;
import java.sql.CallableStatement;
import java.sql.Clob;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
* Servlet implementation class DataSync
*/
@WebServlet("/dataSync")
public class DataSync extends HttpServlet {
private static final long serialVersionUID = 1L;
private Connection conn;
private String filePath;
private String orgProvinceId;
private String orgCityId;
private String orgDistrictId;
private String orgTownId;
private String orgVillageId;
/**
* @see HttpServlet#HttpServlet()
*/
public DataSync() {
super();
// TODO Auto-generated constructor stub
}
/**
* @param path
* @see HttpServlet#service(HttpServletRequest request, HttpServletResponse
* response)
*/
protected void service(HttpServletRequest request,
HttpServletResponse response) throws ServletException, IOException {
// TODO Auto-generated method stub
PrintWriter out=response.getWriter();
out.print("1323443554qqqqqqqqqqq");
// orgProvinceId
orgProvinceId = request.getParameter("orgProvinceId");
// orgCityId
orgCityId = request.getParameter("orgCityId");
// orgDistrictId
orgDistrictId = request.getParameter("orgDistrictId");
// orgTownId
orgTownId = request.getParameter("orgTownId");
// orgVillageId
orgVillageId = request.getParameter("orgVillageId");
String fileName = orgProvinceId + orgCityId + orgDistrictId + orgTownId
+ orgVillageId+".sql";
filePath=request.getRealPath("/") + "/" + fileName;
filePath = new String(filePath.getBytes("ISO-8859-1"), "utf-8");
download(filePath, request, response);
}
private void getDBData() {
try {
Properties props = new Properties();
props.load(DataSync.class
.getResourceAsStream("/configs/database/oracle.properties"));
String driver = props.getProperty("db_driver");
String url = props.getProperty("db_url");
String username = props.getProperty("db_user_name");
String password = props.getProperty("db_password");
Class.forName(driver);
conn = DriverManager.getConnection(url, username, password);
String sql = "{call out_file(?,?,?,?,?,?)}";
CallableStatement cst = conn.prepareCall(sql);
// 输入参数的调用
cst.setString(1, orgProvinceId);
cst.setString(2, orgCityId);
cst.setString(3, orgDistrictId);
cst.setString(4, orgTownId);
cst.setString(5, orgVillageId);
// 输出参数的调用
cst.registerOutParameter(6, java.sql.Types.CLOB);
// 执行存储过程
cst.execute();
// 得到存储过程的输出参数值
Clob syncContent =cst.getClob(6);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
public HttpServletResponse download(String path,
HttpServletRequest request, HttpServletResponse response) {
Reader reader = null;
OutputStreamWriter writerClient = null;
try {
// path是指欲下载的文件的路径。
File file = new File(request.getRealPath("/") + "/" + path);
// 取得文件名。
String filename = file.getName();
// 以流的形式下载文件。
InputStream fis = new BufferedInputStream(new FileInputStream(path));
byte[] buffer = new byte[fis.available()];
fis.read(buffer);
fis.close();
// 清空response
response.reset();
// 设置response的Header
response.addHeader("Content-Disposition", "attachment;filename=" + new String(filename.getBytes()));
response.addHeader("Content-Length", "" + file.length());
OutputStream toClient = new BufferedOutputStream(response.getOutputStream());
response.setContentType("application/octet-stream");
toClient.write(buffer);
// 清空response
response.reset();
// 设置response的Header
response.addHeader("Content-Disposition", "attachment;filename="
+ new String(filename.getBytes("utf-8"), "ISO-8859-1"));
response.addHeader("Content-Length", "" + file.length());
response.setContentType("application/octet-stream");
Clob syncContent = getDBData();
reader = syncContent.getCharacterStream();
char[] buffer = new char[1024];
int length = 0;
writerClient = new OutputStreamWriter(response.getOutputStream());
while ((length = reader.read(buffer)) != -1) {
System.out.println(buffer);
writerClient.write(buffer, 0, length);
}
writerClient.flush();
} catch (IOException ex) {
ex.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
try {
writerClient.close();
reader.close();
conn.close();
} catch (Exception ex) {
ex.printStackTrace();
}
}
return response;
}
// <a href="fileDownLoadServlet?filename=通讯录.xls">哈哈,测试文件下载</a>
}
分享到:
相关推荐
datasync
DataSync 一个基于Rocket MQ的不同数据库之间数据实时同步的平台 watcher为监视数据更新的windows service 配置文件: 1.\Config\producerconfig.json -- rocket mq的生产者配置,用来将从数据库查询出来的数据推送...
TR Data Sync是用于文件夹同步的应用程序。
利用C#写的数据同步源代码。利用C#写的数据同步源代码。
数据同步映射器 在数据同步读取器和写入器之间映射数据。工作正在进行中这只是一个占位符,不久之后还会有更多。入门要安装该模块,请在命令行中运行以下命令: npm i datasync-mapper --save 在您的应用程序中与...
数据同步阅读器 用于数据同步的基础阅读器。 工作正在进行中 这只是一个占位符,不久之后还会有更多。 入门 要安装该模块,请在命令行中运行以下命令: npm i datasync-reader --save 在您的应用程序中与以下...
数据同步写入器 数据同步基础作家工作正在进行中这只是一个占位符,不久之后还会有更多。入门要安装该模块,请在命令行中运行以下命令: npm i datasync-writer --save 在您的应用程序中与以下JavaScript行一起使用...
该软件功能类似于360云盘同步版,但无需网络的支持,具体见文件内说明。可以供初学JAVA的同学参考。^_^
PubNub Data Sync 可以与 PubNub Data Streams 协同工作,因此开发人员可以在每个设备上同步和共享结构化对象,同时还可以使用我们的实时发布/订阅消息层,所有这些都封装在一个安全和访问控制模型中。这个演示有...
数据同步必须遵循以下顺序-1.设施,2.提供者,3.约会,4.患者 同步的数据必须存储在内存中,并将输出日志输出到stdout 如果已知数据,则必须提供一种比较2种版本的方法,使医院版本始终胜出 依存关系 您将获得一个...
Socrata数据同步 上次更新时间:2017年6月2日 寻找最新版本? 在这里获取: : 一般信息 DataSync是可执行的Java应用程序,用作在Socrata平台上自动发布数据的通用解决方案。 它可以通过易于使用的图形界面或作为...
对两台机器的数据同步,针对特定的应用使用
通用的oracle数据库数据同步程序,支持根据配置的SQL自动导出文件,插入表
利用Quartz.net+Topshel 开发的数据同步服务
BMP会把相关用户数据同步到SCP上 目前BMP与SCP之间通过LDS方案来同步,LDS即轻量级数据同步组件(Light Data Sync),提供向其他多个系统同步数据的传输通道,支持路由管理和模型转换机制。
Access同步SQLServer 或 SQLServer 同步Access 操作简单,配置参数即可使用 并解决 ID非数字自增问题
Navicat 实现同步sqlserver表结构到mysql操作手册 --Create By 卞中明 201610141.选中对应mysql数据库,在表对象页面
用于数据同步,将实现与企业LDAP或微软AD系统目录同步功能.
体积小巧的数据同步和备份工具。保证您的数据不会丢失。 备份的方法:第一步:general options,让你输入备份的名字,备份形式,是否需要打包成zip; 第二步:data to backup,选择需备份的文件夹; 第三步:...
SQLite DBSync是开源嵌入式数据库SQLite的数据同步引擎,实现了SQLite与SQLite数据库之间以及SQLite与异构数据库Oracle、MySQL、SQLServer之间的增量的、双向的数据同步功能。在文章中对SQLite DBSync 的体系结构、...