Examples of com.socrata.api.Soda2Producer.upsert()

com.socrata.api.Soda2Producer.upsert()
"Upserts" a list of objects. What this means is that it will:
1. Add the objects in the list.
2. If an object already exists with this value, it will update it.
3. If the object has a :deleted=true value, the object will be deleted.
In order to delete objects using the Upsert function, use the DeleteRecord object to map ":deleted" to an :id. @param resourceId unique id or resource name of the dataset @param objects list of objects to upsert @return result of objects added, removed and modified. @throws SodaError thrown if there is an error. Investigate the structure for more information. @throws InterruptedException throws is the thread is interrupted.

        //TestCase.assertTrue(EqualsBuilder.reflectionEquals(nominationUpdate, updatedNomination));


        List l = Lists.newArrayList(new DeleteRecord(objectMetadata.getId(), true));
        ObjectMapper m = new ObjectMapper();
        System.out.println(m.writeValueAsString(l));
        UpsertResult result = producer.upsert(UPDATE_DATA_SET, l);
        try {
            final Nomination deletedNomination = producer.getById(UPDATE_DATA_SET, objectMetadata.getId(), Nomination.class);
            TestCase.fail();
        } catch (DoesNotExistException e) {
            //Expected Condition

View Full Code Here


        JobStatus logStatus = JobStatus.SUCCESS;
        String errorMessage = "";
        boolean noPublishExceptions = false;
        try {
            producer.upsert(logDatasetID, upsertObjects);
            noPublishExceptions = true;
        }
        catch (SodaError sodaError) {
            errorMessage = sodaError.getMessage();
        }

View Full Code Here

        newCols.put("DataSyncVersion", VersionProvider.getThisVersion());
        upsertObjects.add(ImmutableMap.copyOf(newCols));


        String logPublishingErrorMessage = null;
        try {
            producer.upsert(logDatasetID, upsertObjects);
        }
        catch (SodaError | InterruptedException e) {
            e.printStackTrace();
            logPublishingErrorMessage = e.getMessage();
        }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.