Example Program on how to insert JSON data to MongoDB and query from MongoDB using Java and Spark.

• Database name: test-db
• Collection name: test-collection
• User: admin
• Password: superadmin
• _id: country-city (example: canada-vancouver, united_states-las_vegas)

args[0]

{
  "user": "MongoDB user",
  "password": "MongoDB password",
  "ip": "MongoDB IP address",
  "port": "MongoDB port",
  "database": "Database name",
  "collection": "Collection name"
}

args[1]: path to JSON file

args[0]

{
  "user": "MongoDB user",
  "password": "MongoDB password",
  "ip": "MongoDB IP address",
  "port": "MongoDB port",
  "database": "Database name",
  "collection": "Collection name"
}

args[1]: query

mvn install

spark-submit --class com.reza.dev.learn.main.Main_Write --master local[2] target/SparkMongo-1.0-SNAPSHOT-jar-with-dependencies.jar '{"user":"admin","password":"superadmin","ip":"192.168.20.99","port":"27017","database":"test-db","collection":"test-collection"}' '/home/data/city_attributes.json'

spark-submit --class com.reza.dev.learn.main.Main_Read --master local[2] target/SparkMongo-1.0-SNAPSHOT-jar-with-dependencies.jar '{"user":"admin","password":"superadmin","ip":"192.168.20.99","port":"27017","database":"test-db","collection":"test-collection"}' '{ $match: { country: "Canada" } }'