root/BH13SPARQLBuilder/src/hozo/sparql/SeparatedValuesExporter.java @ 29

package hozo.sparql;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.util.List;
import java.util.Map;

import com.hp.hpl.jena.rdf.model.RDFNode;

/**
 * 繧ｻ繝代Ξ繝ｼ繧ｿ縺ｫ繧医▲縺ｦ蛹ｺ蛻�ｉ繧後◆蠖｢縺ｧ繝��繧ｿ繧偵お繧ｯ繧ｹ繝昴�繝医☆繧九◆繧√�繧ｯ繝ｩ繧ｹ
 * @author kato
 *
 */
public class SeparatedValuesExporter {
        
        private String separator;
        private List<Map<String, RDFNode>> data;
        
        public SeparatedValuesExporter(String separator, List<Map<String, RDFNode>> data){
                this.separator = separator;
                this.data = data;
        }

        public boolean export(File file) throws IOException{
                return export(new FileOutputStream(file));
        }

        public boolean export(OutputStream stream) throws IOException{
                
                PrintWriter pw = new PrintWriter(new OutputStreamWriter(stream));

                if (!outputHeader(pw, data.get(0))){
                        pw.flush();
                        pw.close();
                        return false;
                }
                
                for (Map<String, RDFNode> datum : data){
                        outputContent(pw, datum);
                }
                pw.flush();
                pw.close();
                
                return false;
        }
        
        private boolean outputHeader(PrintWriter stream, Map<String, RDFNode> columns){
                StringBuilder sb = new StringBuilder();
                
                int i = 0;
                for (String key : columns.keySet()){
                        sb.append(key);
                        if (++i != columns.keySet().size()){
                                sb.append(getSeparator());
                        }
                }
                
                outputLine(stream, sb.toString());
                
                return true;
        }

        private boolean outputContent(PrintWriter stream, Map<String, RDFNode> row){
                StringBuilder sb = new StringBuilder();
                
                int i = 0;
                for (String key : row.keySet()){
                        sb.append(row.get(key));
                        if (++i != row.keySet().size()){
                                sb.append(getSeparator());
                        }
                }
                
                outputLine(stream, sb.toString());
                
                return true;
        }

        private String getSeparator(){
                return this.separator;
        }
        
        private void outputLine(PrintWriter stream, String line){
                stream.println(line);
        }
        
}