AMPLI-SYNC

h1. InitializeSubscriber JAVA

<pre><code class="java">

/**

 * Recreate database schema from remote server for specific subscriber

 * @param subscriberId id of subscriber

 * @throws Exception

 */

public void initializeSubscriber(String subscriberId) throws Exception {

    HttpURLConnection connection = null;

    InputStream resultStream = null;

    String resultString = null;

    Map<String, String> schema = null;

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

    try {

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

        int status = connection.getResponseCode();

        switch (status){

            case HttpURLConnection.HTTP_OK:

                resultStream = connection.getInputStream();

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

                schema = new Gson().fromJson(resultString, new TypeToken<Map<String, String>>(){}.getType());

                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();

        }

    }

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

    Set<String> keySet = schema.keySet();

    for(String key : keySet){

        keys.add(key);

    }

    Collections.sort(keys);

    SQLiteDatabase db = openOrCreateDatabase(_dbFileName, null);

    try{

        db.beginTransaction();

        for (String key : keys) {

            if(!key.startsWith("00000")){

                db.execSQL(schema.get(key));

            }

        }

        db.setTransactionSuccessful();

    }

    finally {

        db.endTransaction();

        db.close();

    }

}

</code></pre>