java 从数据库取数据并存入本地文本中

Question

已经解决了！！！！大家可以不用来围观啦

要求如下：

1.连接数据库，取数据，weibo表中取出 uid和text

2.判断 uid是否相同，如果相同，则把其对应的text存入路径为D:\data1的同一文件中，并且以此uid命名文件。格式如下：

3.表的样式如下：

4.我自己已经写了连接数据库，取数据，weibo表中取出 uid和text这部分了，我用的是Map暂存数据，如下：

  public HashMap<String, String> selectFromDb() throws SQLException, UnsupportedEncodingException{
           sql = "select * from weibo";
           Connection conn = getConnect();
           res = new HashMap<String, String>();//存uid的字符串map     
           try{
               statement = conn.createStatement();//statement用来执行SQL语句
               ResultSet rs = statement.executeQuery(sql);
               String user_id = null;
               String text = null;            
               while(rs.next()){                      
                    user_id = rs.getString("uid");//选择uid这列数据
                    text = rs.getString("text");//选择text这列数据                    
                    //首先使用ISO-8859-1字符集将name解码为字节序列并将结果存储新的字节数组中。
                    //然后使用GB2312字符集解码指定的字节数组
                    user_id = new String(user_id.getBytes("GBK"),"GB2312");
                    text = new String(text.getBytes("GBK"),"GB2312");
                    res.put(user_id, text);                 
                    //System.out.println(rs.getString("uid")+"\t"+topic+"\t"+text); //输出结果                                                                           
               }              
               rs.close();
               statement.close();
               conn.close();               
           }catch(SQLException e){
               e.printStackTrace();
           }          
           return res;         
       }

5.现在就是要判断并且按uid存在本地文件中，希望大家给完整的代码，连接数据库的不需要了。

Answer 1

你从数据库获取数据的代码有问题，应该用List先获取到所有的数据，然后在遍历这个List，提前userId相同的账户问题信息。
我给你完整代码如下：你只需要修改queryData过程将ResultSet的数据存入list中返回即可。你可以先运行看结果，再修改。祝好。
代码如下：

 import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

public class WeiboDataExtract {
    public  List<WeiboData> queryData(){
        List<WeiboData> list = new ArrayList<WeiboData>();
        list.add(new WeiboData("1","hello"));
        list.add(new WeiboData("1","world"));
        list.add(new WeiboData("1","I want to change you!"));

        list.add(new WeiboData("2","Haha"));
        return list;
    }

    public void extract(List<WeiboData>datas){
        Map<String,StringBuffer> map = new HashMap<String,StringBuffer>();
        //遍历数据
        for(WeiboData data:datas){
            StringBuffer buffer = map.get(data.getUserId());
            //map中没有该微博账户，新建数据并存储
            if(buffer==null){
                buffer= new StringBuffer();
                map.put(data.getUserId(), buffer);
            }
            //将该账户的文本信息收集起来
            buffer.append(data.getText()+"\r\n");
        }

        //遍历map输出到文件
        for(Entry<String, StringBuffer> entry:map.entrySet()){
            String userId = entry.getKey();
            StringBuffer value = entry.getValue();
            writeToFile("d:/"+userId+".txt",value.toString(),true,"GB2312");
        }
    }

    /**
     * 将字符串以指定的编码方式写入文件
     * @param fileName   待写入的文件
     * @param content    待写入的文本
     * @param append     是否追加
     * @param charset    文件输出编码格式，默认为UTF-8
     */
    public  void writeToFile(String fileName, String content,boolean append,String charset){
        if(fileName==null||"".equals(fileName)){
            return;
        }

        if(content==null||"".equals(content)){
            return;
        }

        //默认编码格式为UTF-8
        if(charset==null){
            charset = "UTF-8";
        }

        //将字符串写入到文件输出流中
        OutputStreamWriter osw = null;
        try {
            osw = new OutputStreamWriter(new FileOutputStream(fileName, append), charset);
            osw.write(content + "\r\n");
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            if(osw!=null){
                try {
                    osw.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    public static void main(String[] args) {
        WeiboDataExtract d = new WeiboDataExtract();
        d.extract(d.queryData());
    }
}

用到的一个类如下：

 public class WeiboData {
    private String userId;
    private String text;

    public WeiboData(String userId, String text) {
        super();
        this.userId = userId;
        this.text = text;
    }

    public String getUserId() {
        return userId;
    }

    public void setUserId(String userId) {
        this.userId = userId;
    }

    public String getText() {
        return text;
    }

    public void setText(String text) {
        this.text = text;
    }

}