Geek asks and answers

Waiting for a string, but BEGIN_OBJECT: JsonReader

There are several other answers to this question here, but not sure how to make them work with my code.

I have a lot of JSON to transmit, so I need to pass it, and not do it all at once. I cannot get errors from code. Here is my code:

HttpGet request = new HttpGet(getUri + "&"
                + credentials.getOauthStructure());
        HttpResponse response = client.execute(request);

        ICustomerDAO customerDAO = (ICustomerDAO) DAOFactory.getDAO(
                ICustomerDAO.class.getName(), context);
        customerDAO.open();

        Gson gson = new GsonBuilder().serializeNulls()
                .excludeFieldsWithoutExposeAnnotation().create();

        Reader streamReader = new InputStreamReader(response
                .getEntity().getContent());
        JsonReader reader = new JsonReader(streamReader);
        reader.beginArray();

        while (reader.hasNext()) {
            //Do the JSON parsing and data saving here
            Customer customer = gson.fromJson(reader.nextString(), Customer.class);<-----error here
            customerDAO.saveCustomer(customer);
        }
        reader.endArray();
        reader.close();
        customerDAO.close();

I get an error message:

Waiting for a line, but BEGIN_OBJECT:

In the marked line in the above code.

EDIT: the value of "reader" is "JsonReader next to [{" Action ": null," Addr "). Therefore, it seems to be disabled near the start of JSON.

I used JSON as follows:

HttpGet request = new HttpGet(getUri + "&"
                + credentials.getOauthStructure());
        String content = client.execute(request, new BasicResponseHandler());

But he returned a large amount of json, so he changed it the way I use now, trying to pass it.

Edit 2: My source code:

public class CustomerSync implements ICustomerSync {
    public static final int QUANTITY = 0;
    private long offset;
    private ProgressDialog progressDialog;
    private Context context;
    private HttpClient client;
    private final String HTTPS_GET_CUSTOMERS = "https://plcloud.c6.ixsecure.com/PLService.svc/GetCustomers";
    private final String GET_URL = "{0}?quant={1}&offset={2}";
    private final String HTTPS_SYNC_CUSTOMERS = "https://plcloud.c6.ixsecure.com/PLService.svc/SyncCustomers";

    private CustomerSync() {
        client = new DefaultHttpClient();
    }

    public CustomerSync(Context context, ProgressDialog progressDialog) {
        this();
        this.context = context;
        this.progressDialog = progressDialog;
    }

    public Customer[] initCustomersFromJson(Credentials credentials)
            throws ClientProtocolException, IOException, URISyntaxException {
        String getUri;
        getUri = MessageFormat.format(GET_URL, HTTPS_GET_CUSTOMERS,
                QUANTITY + "", offset + "");

        credentials.initGetOAuthStructure(HTTPS_GET_CUSTOMERS);

        HttpGet request = new HttpGet(getUri + "&"
                + credentials.getOauthStructure());
        String content = client.execute(request, new BasicResponseHandler());

        Gson gson = new GsonBuilder().serializeNulls()
                .excludeFieldsWithoutExposeAnnotation().create();
        return gson.fromJson(content, Customer[].class);
    }

    @Override
    public void getCustomers(Credentials credentials)
            throws ClientProtocolException, IOException, URISyntaxException {
        ICustomerDAO customerDAO = (ICustomerDAO) DAOFactory.getDAO(
                ICustomerDAO.class.getName(), context);
        customerDAO.open();

        Customer[] customers;

        //do {
            customers = initCustomersFromJson(credentials);
            progressDialog.setMax(customers.length);
            progressDialog.setProgress(0);
            customerDAO.saveCustomers(customers, progressDialog);

            if (customers.length > 0) {
                offset = customers[customers.length - 1].getId();
            }
        //} while (customers.length > 0);

        customerDAO.close();

        Settings.getInstance().setLastSyncCustomerDatetime(new Date());
    }

But this did not lead to data flow, which caused memory problems.

-1
1

HTTP-:

URL url = new URL(sUrl);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();


String sResult = null;
InputStream in = new BufferedInputStream(conn.getInputStream());
BufferedReader reader = new BufferedReader(new InputStreamReader(in));
try 
{
    StringBuilder out = new StringBuilder();
    String line;
    while ((line = reader.readLine()) != null) {
        out.append(line);
    }
    sResult = out.toString();
}   
finally 
{
    // Do cleanup
    try{
        in.close();
        reader.close();
    } catch (IOException e) {
        Log.wtf(AsyncRestHelper.class.getSimpleName(), "Could not close Input Stream!");
        e.printStackTrace();
    }
}

sResult Customers GSON,

0

More articles:


All Articles