mysql将查询部分数据导出到外部文件的脚本，文件格式替换

mysql将查询部分数据导出到外部文件的脚本：

mysql -u root -p222222 -e "use ccbdj2014;SELECT A.CERT_NO 证件号码,A.CUST_NAME 客户姓名,A.MOBEL 联系电话,MOBEL_NUM 交易笔数 FROM CUST_INFO A WHERE CHANEL='02' ORDER BY A.MOBEL_NUM;">/tmp/ccbdj.txt

说明：root：用户名，222222：密码，ccbdj2014：数据库名称  ， >/tmp/ccbdj.txt：导出到tmp下的ccbdj文件中

注意：脚本文件编码应该与数据库编码格式一致！

生成文件格式：证件号码客户姓名
联系电话交易笔数

将文件格式替换为：证件号码，客户姓名，联系电话，交易笔数
 格式代码如下：

package test;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;

/**
*
* @author xlhu
* CCBDJ2013生成全量数据、部分数据，数据格式为：证件号码，客户姓名，联系电话，交易笔数
*
*/
public class FileTest {
/**
* 全量数据
* @throws Exception
*/
private static void runAll() throws Exception{
File file = new File("F:/feiqiu文件/ccbjd.txt");
String date = "0303";
File foutPath = new File("F:\\Work\\CCBDJ2013\\2014每周数据\\"+date);
if(!foutPath.exists()){
foutPath.mkdir();
}
File fout = new File(foutPath,"全量数据"+date+".txt");
if(!fout.exists()){
fout.createNewFile();
}
String strLine = null;
if(!file.exists()){
System.out.println("源文件不存在！");
return;
}else{
String lineRead = null;
BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(file), "UTF-8"));
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(fout),"GBK"));
long allLine = 1;
while((lineRead = br.readLine()) != null){
strLine = lineRead.replaceAll("	", ",");
strLine = strLine+"\n";
bw.write(strLine);
allLine++;
}
bw.close();
br.close();
System.out.println("总计行数："+allLine);
}

}
/**
* 全量数据
* @throws Exception
*/
private static void runSome() throws Exception{
File file = new File("F:/feiqiu文件/ccbjd.txt");
String date = "0303";
File foutPath = new File("F:\\Work\\CCBDJ2013\\2014每周数据\\"+date);
if(!foutPath.exists()){
foutPath.mkdir();
}
File fout = new File(foutPath,"部分数据"+date+".txt");
if(!fout.exists()){
fout.createNewFile();
}
String strLine = null;
if(!file.exists()){
System.out.println("源文件不存在！");
return;
}else{
String lineRead = null;
BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(file), "UTF-8"));
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(fout),"GBK"));
long allLine = 1;
while((lineRead = br.readLine()) != null){
strLine = lineRead.replaceAll("	", ",");
if(strLine.charAt(strLine.length()-1) == '0'){
continue;
}else{
strLine = strLine+"\n";
bw.write(strLine);
allLine++;
}
}
bw.close();
br.close();
System.out.println("总计行数："+allLine);
}

}
public static void main(String[] args) {
try {
//全量数据
runAll();
//部分数据
runSome();
} catch (Exception e) {
e.printStackTrace();
}

}

}