查询数据库保存成CSV格式
作者:网络转载 发布时间:[ 2016/7/20 11:01:42 ] 推荐标签:数据库 CSV
package cn.com.atmb.gfs.work.Bookdemo;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import cn.com.atmb.configureFiles.propertityUtil;
import cn.com.atmb.gfs.database.implementations.DAOTool;
import cn.com.atmb.gfs.database.interfaces.BaseDAO;
/**
*
* CSV文件导出工具类
*/
public class CSVUtil {
static propertityUtil pro = propertityUtil.getInstance("path.properties");
static String PATH=pro.getProperty("PATH");
static String FILENAME=pro.getProperty("FILENAME");
/**
* CSV文件生成方法
*
* @param head 头部标题
* @param dataList 内容
* @param outPutPath 文件路径
* @param filename 文件名称
* @return
*/
public static File createCSVFile(List<Object> head,List<List<Object>> dataList, String outPutPath, String filename) {
File csvFile = null;
BufferedWriter csvWtriter = null;
try {
//文件储存位置
csvFile = new File(outPutPath + File.separator + filename + ".csv");
File parent = csvFile.getParentFile();
if (parent != null && !parent.exists()) {
parent.mkdirs();
}
csvFile.createNewFile();
// GB2312使正确读取分隔符","
csvWtriter = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(csvFile), "GB2312"), 1024);
// 写入文件头部
writeRow(head, csvWtriter);
// 写入文件内容
for (List<Object> row : dataList) {
writeRow(row, csvWtriter);
}
csvWtriter.flush();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
csvWtriter.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return csvFile;
}
/**
* 写一行数据方法
*
* @param row
* @param csvWriter
* @throws IOException
*/
private static void writeRow(List<Object> row, BufferedWriter csvWriter)
throws IOException {
// 写入文件头部
for (Object data : row) {
// StringBuffer sb = new StringBuffer();
String rowStr="";
// rowStr= sb.append(""").append(data).append("",").toString();
if(data.toString().contains(""")){
rowStr="""+data.toString().replaceAll(""","""")+"",";
}else{
rowStr="""+data.toString()+"",";
}
csvWriter.write(rowStr);
}
csvWriter.newLine();
}
/**
* 拼装数据方法
* @param retList 数据库查询结果集合
*/
public static void AssembledData(List<Map<String,Object>> retList) {
if(retList==null||retList.size()==0){
//
}else{
List<Object> head=new ArrayList<Object>();
List<List<Object>> dataList=new ArrayList<List<Object>>();
for (Map<String, Object> map : retList) {
List<Object> date=new ArrayList<Object>();
for(Object key:map.keySet()){
date.add(map.get(key));
}
dataList.add(date);
}
for(Object ob:retList.get(0).keySet()){
head.add(ob);
}
System.out.println(head);
System.out.println(dataList);
createCSVFile(head,dataList,PATH,FILENAME);
}
}
public static void run(){
//querySql查询数据库方法
List<Map<String,Object>> retList=querySql();
AssembledData(retList);
}
}
相关推荐
更新发布
功能测试和接口测试的区别
2023/3/23 14:23:39如何写好测试用例文档
2023/3/22 16:17:39常用的选择回归测试的方式有哪些?
2022/6/14 16:14:27测试流程中需要重点把关几个过程?
2021/10/18 15:37:44性能测试的七种方法
2021/9/17 15:19:29全链路压测优化思路
2021/9/14 15:42:25性能测试流程浅谈
2021/5/28 17:25:47常见的APP性能测试指标
2021/5/8 17:01:11