seismograph.java

package com.socrata.school.api;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.socrata.api.Connection;
import com.socrata.api.HttpConnection;
import com.socrata.api.RequestException;
import com.socrata.data.View;
import com.socrata.data.View.NewRow;

public class Seismograph {

	/**
	 * @param args
	 * @throws RequestException 
	 */
	public static void main(String[] args) throws RequestException {
		Connection c = new HttpConnection("soda.demo.socrata.com", "[email protected]", "******", "*************");
		View v = View.find("3dy7-ihbd", c);
		
		List<NewRow> update = new ArrayList<View.NewRow>();
		
		// New earthquake in Seattle
		NewRow row = new NewRow();
		row.putDataField(v.getColumnByApiIdentifier("source"), "socrata");
		row.putDataField(v.getColumnByApiIdentifier("earthquake_id"), "1234567890");
		row.putDataField(v.getColumnByApiIdentifier("reported_at"), new Date());
		row.putDataField(v.getColumnByApiIdentifier("magnitude"), 1.2);
		row.putDataField(v.getColumnByApiIdentifier("depth"), 112);
		row.putDataField(v.getColumnByApiIdentifier("number_of_stations"), 1);
		row.putDataField(v.getColumnByApiIdentifier("region"), "Seattle, WA (That was just a truck...)");
		
		Map<String, Double> location = new HashMap<String, Double>();
		location.put("latitude", 47.60356369780794);
		location.put("longitude", -122.32944013500594);
		
		row.putDataField(v.getColumnByApiIdentifier("location"), location);
		update.add(row);
		
		System.out.println("Pushing updates...");
		View.BulkResults results = v.upsert(update, c);
		
	    System.out.println("Updates: " + results.getRowsUpdated());
        System.out.println("Creates: " + results.getRowsCreated());
        System.out.println("Deleted: " + results.getRowsDeleted());
        System.out.println("Errors: " + results.getErrors());
	}

}