package cn.tzy.mongodb;
import java.io.File;
import java.io.IOException;
import java.io.StringWriter;
import org.bson.Document;
import org.geotools.data.FileDataStore;
import org.geotools.data.FileDataStoreFinder;
import org.geotools.data.simple.SimpleFeatureIterator;
import org.geotools.data.simple.SimpleFeatureSource;
import org.geotools.geojson.feature.FeatureJSON;
import org.opengis.feature.simple.SimpleFeature;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
public class MongoEx {
public static void main(String[] args) throws IOException {
final String IP_ADDRESS =
"127.0.0.1"
;
final String DB_NAME =
"SpatialFeatures"
;
final String COLLECTION_NAME =
"continents"
;
final String SHAPE_FILE =
"/home/theone/Data/World/continent.shp"
;
MongoClient client =
new
MongoClient(IP_ADDRESS, 27017);
MongoDatabase db = client.getDatabase(DB_NAME);
db.createCollection(COLLECTION_NAME);
MongoCollection<Document> coll = db.getCollection(COLLECTION_NAME);
File shapeFile =
new
File(SHAPE_FILE);
FileDataStore store = FileDataStoreFinder.getDataStore(shapeFile);
SimpleFeatureSource sfSource = store.getFeatureSource();
SimpleFeatureIterator sfIter = sfSource.getFeatures().features();
while
(sfIter.hasNext()) {
SimpleFeature feature = (SimpleFeature) sfIter.next();
FeatureJSON fjson =
new
FeatureJSON();
StringWriter writer =
new
StringWriter();
fjson.writeFeature(feature, writer);
String sjson = writer.toString();
Document doc = Document.parse(sjson);
coll.insertOne(doc);
}
client.close();
}
}