//说æè·¯:å¼å§ç解éäº,以为让ä¸ä¸ªæ件,åæä¸å¼ æ´ä½ç表..以åæ±å©æ好带ä¸æºæ件
//è´¹èå²äº.æä½ è¿ä¸ªå¾çå»è½¬æè¡¨æ ¼æ°æ®,ç¶ååæåæå 个å°ç»èè¡¨æ ¼...æ¼ç«å..
//ä¸è¿ä¹å¦å°ç¥è¯äº,csvæ件..
//è¿éæä¸ä¸ªé®é¢,å°±æ¯å并çæ件,并ä¸æ¯ä½ æ³è¦ç顺åº,å ä¸ºä½ çæ件å毫æ è§å¾,å¦ææè§å¾
//å并å,å°±ä¼æ¯æ顺åºç..æ¯å¦s1,s2,s3...好äºä¸ä»£ç :
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileWriter;
import java.io.FilenameFilter;
import java.io.IOException;
import java.io.PrintWriter;
import java.io.SequenceInputStream;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Enumeration;
public class CsvMerge {
private String path;// è·¯å¾;
private File dir, files[];// ç®å½,æ件æ°ç»;
private SequenceInputStream sis;//åºåæµ
private PrintWriter pw;// è¾åºæµ
private boolean flag;// æ è®°
private byte[] bys;//容å¨
public static void main(String[] args) {
new CsvMerge().init();//å¯å¨å并åè½;
}
private void init() {
path = "K:\\IOæµè¯\\å并Csvæ件";// ç¡®å®è·¯å¾;
dir = new File(path);// ç®å½ä½ç½®
flag = dir.exists();
if (!flag) {
System.out.println("ç®å½ä¸åå¨å«è´¹å²äº..");
return;
}
files = dir.listFiles(new FilenameFilter() {//æ«æç®å½,éè¦è¢«å并çç¢çæ件
@Override
public boolean accept(File dir, String name) {
return name.endsWith("csv");
}
});
ArrayList<FileInputStream> al = new ArrayList<FileInputStream>();// å建æ件读åæµéå;
try {
for (int i = 0; i < files.length; i++) // å建åæ¯æµ
al.add(new FileInputStream(files[i].getAbsoluteFile()));
} catch (FileNotFoundException e) {
e.printStackTrace();
}
Enumeration<FileInputStream> en=Collections.enumeration(al);//æ¿å°æ举对象;
sis=new SequenceInputStream(en);//åå§åå并æµ;
bys=new byte[1024];
try {
File file=new File(dir,"Mer.csv");//ç®æ å并æ件;
if(file.exists()) {
System.out.println("æ件已ç»åå¨...");
return;
}
pw=new PrintWriter(new FileWriter(file),true);
for(int a=sis.read(bys);a!=-1;a=sis.read(bys)) {
pw.println(new String(bys,0,a));
}
} catch (FileNotFoundException e) {
e.printStackTrace();
}catch(Exception e) {
e.printStackTrace();
}finally {
if(sis!=null) {
try {
sis.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}
//æ è®°çæ¯å并åçæ件,ç¢çæ件,éä¾¿ä½ æ¾,å¦ææ³æç
§é¡ºåº,å°±æåååçæ顺åº
![](https://video.ask-data.xyz/img.php?b=https://iknow-pic.cdn.bcebos.com/4610b912c8fcc3ce0a7409cf9e45d688d53f2092?x-bce-process=image%2Fresize%2Cm_lfit%2Cw_600%2Ch_800%2Climit_1%2Fquality%2Cq_85%2Fformat%2Cf_auto)
![](https://video.ask-data.xyz/img.php?b=https://iknow-pic.cdn.bcebos.com/77094b36acaf2eddd53e8915811001e93801937b?x-bce-process=image%2Fresize%2Cm_lfit%2Cw_600%2Ch_800%2Climit_1%2Fquality%2Cq_85%2Fformat%2Cf_auto)
追é®ä½ ç代ç è¿è¡åºæ¥ï¼åªæ¯æä¸ä¸ªæ件åå¨ä¸èµ·äºï¼å¹¶æ²¡ææ表éåå¨ä¸å¼ 表é