dx字段。
接下来就是数据转储代码了：
TransformData.java
package net.csdn.blog.chaijunkun;
import java.net.UnknownHostException;
import net.csdn.blog.chaijunkun.entities.CSDNData;
import com.google.code.morphia.Datastore;
import com.google.code.morphia.Key;
import com.google.code.morphia.Morphia;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
public class TransformData {
public static void main(String[] args) throws UnknownHostException, MongoException{
Mongo connection= new Mongo("localhost", 27017);
Morphia morphia= new Morphia();
Datastore ds= morphia.createDatastore(connection, "csdn");
File dataFile= new File("D:\\www.csdn.net.txt");
FileReader fr;
Integer idx=1;
try {
fr = new FileReader(dataFile);
BufferedReader br=new BufferedReader(fr);
String currentLine= null;
try {
while((currentLine= br.readLine())!=null){
//读取操作
if (currentLine.trim().equals("")){
continue;
}
String[] record= currentLine.split("#");
if (record.length>=3){
CSDNData csdnData= new CSDNData();
csdnData.setIdx(idx);
csdnData.setUserName(record[0].trim());
csdnData.setPassword(record[1].trim());
csdnData.setEmail(record[2].trim());
Key key= ds.save(csdnData);
System.out.println("已存入:"+ key.getId() + ",文档序列:"+ idx);
}else{
System.out.println("文档序列"+ idx+ "发生错误:"+currentLine);
break;
}
idx++;
}
} catch (UnsupportedEncodingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} catch (FileNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
package net.csdn.blog.chaijunkun;
import java.net.UnknownHostException;
import net.csdn.blog.chaijunkun.entities.CSDNData;
import com.google.code.morphia.Datastore;
import com.google.code.morphia.Key;
import com.google.code.morphia.Morphia;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
public class TransformData {
public sta |