AMPLI-SYNC

h1. Send JAVA

<pre><code class="java">

/**

 * Send local changes to webservice

 * @param subscriberId id of subscriber

 * @throws Exception

 */

private void sendLocalChanges(String subscriberId) throws Exception {

    String query;

    Cursor cursor = null;

    SQLiteDatabase db = null;

    StringBuilder builder = new StringBuilder();

    try {

        db = openOrCreateDatabase(_dbFileName, null);

        List<String> tables = new ArrayList<String>();

        query = "select tbl_Name from sqlite_master where type='table' and sql like '%RowId%'  and tbl_Name != 'android_metadata';";

        cursor = db.rawQuery(query, null);

        while (cursor.moveToNext()) {

            tables.add(cursor.getString(0));

        }

        cursor.close();

        builder.append("<?xml version=\"1.0\" encoding=\"utf-8\"?><SyncData xmlns=\"urn:sync-schema\">");

        for (String tableName : tables) {

            if (!tableName.equalsIgnoreCase("MergeDelete")) {

                builder.append(String.format("<tab n=\"%1$s\">", tableName));

                builder.append("<ins>");

                query = String.format("select * from %1$s where RowId is null;", tableName);

                cursor = db.rawQuery(query, null);

                while (cursor.moveToNext()) {

                    builder.append("<r>");

                    for (int i = 0; i < cursor.getColumnCount(); i++) {

                        if (!cursor.getColumnName(i).equalsIgnoreCase("MergeUpdate")) {

                            builder.append(

                                    String.format("<%1$s><![CDATA[%2$s]]></%1$s>",

                                            cursor.getColumnName(i),

                                            cursor.getString(i)));

                        }

                    }

                    builder.append("</r>");

                }

                cursor.close();

                builder.append("</ins>");

                builder.append("<upd>");

                query = String.format("select * from %1$s where MergeUpdate > 0 and RowId is not null;", tableName);

                cursor = db.rawQuery(query, null);

                while (cursor.moveToNext()) {

                    builder.append("<r>");

                    for (int i = 0; i < cursor.getColumnCount(); i++) {

                        if (!cursor.getColumnName(i).equalsIgnoreCase("MergeUpdate")) {

                            builder.append(

                                    String.format("<%1$s><![CDATA[%2$s]]></%1$s>",

                                            cursor.getColumnName(i),

                                            cursor.getString(i)));

                        }

                    }

                    builder.append("</r>");

                }

                cursor.close();

                builder.append("</upd>");

                builder.append("</tab>");

            }

        }

        builder.append("<delete>");

        query = String.format("select TableId,RowId from MergeDelete;");

        cursor = db.rawQuery(query, null);

        while (cursor.moveToNext()) {

            builder.append(

                    String.format("<r><tb>%1$s</tb><id>%2$s</id></r>",

                            cursor.getString(0),

                            cursor.getString(1)));

        }

        cursor.close();

        builder.append("</delete>");

        builder.append("</SyncData>");

    }

    finally {

        if(cursor != null && !cursor.isClosed()){

            cursor.close();

        }

        if(db != null && db.isOpen()){

            db.close();

        }

    }

    HttpURLConnection connection = null;

    InputStream resultStream = null;

    String resultString = null;

    String requestUrl = String.format("%s/Send", _serverURL);

    JSONObject inputObject = new JSONObject();

    try {

        inputObject.put("subscriber", subscriberId);

        inputObject.put("content", builder.toString());

        inputObject.put("version", "3");

        byte[] requestBytes = inputObject.toString().getBytes("UTF-8");

        connection = (HttpURLConnection) new URL(requestUrl).openConnection();

        connection.setRequestMethod("POST");

        connection.setRequestProperty("Content-Type", "application/json");

        connection.setRequestProperty("charset", "utf-8");

        connection.setRequestProperty("Content-Length", Integer.toString(requestBytes.length));

        DataOutputStream wr = new DataOutputStream(connection.getOutputStream());

        wr.write(requestBytes);

        wr.flush();

        wr.close();

        int status = connection.getResponseCode();

        switch (status){

            case HttpURLConnection.HTTP_OK:

                resultStream = connection.getInputStream();

                resultString = IOUtils.toString(resultStream, "UTF-8");

                break;

            case HttpURLConnection.HTTP_NO_CONTENT:

                break;

            default:

                resultStream = connection.getErrorStream();

                resultString = IOUtils.toString(resultStream, "UTF-8");

                throw new Exception(resultString);

        }

    }

    finally {

        if (resultStream != null) {

            try {

                resultStream.close();

            } catch (IOException e) { }

        }

        if (connection != null) {

            connection.disconnect();

        }

    }

}

</code></pre>