Analyser JSON et les enregistrer dans la base de données SQLite
J'ai utilisé pour avoir ce genre de simples données JSON et j'ai pu analyser correctement les attributs et les enregistrer dans une Base de données SQLite.
[
{
"project_title" : " ",
"organization_title" : " ",
"website": "",
"address": "",
"keyword" : "",
"short_code" : "",
"project_description" : "",
"smallImageUrl" : "",
"bigImageUrl" : "",
"price" : "",
"country" : "",
"donationAmount" : "",
"categories" : "",
"campaign_id" : "",
"currency_isoname": "",
"paypal_email" : "",
"elv_available" : ""
}
]
mais maintenant, j'ai un peu plus compliqué fichier JSON:
[
{
"location": {
"deleted_at": "null",
"documentary_video_length": "81",
"id": "15",
"latitude": "52.4134145988286",
"longitude": "13.0904620846177",
"position": "5",
"updated_at": "2011-08-26T15:30:27+02:00",
"name": "Glienicker Br\u00fccke",
"text": "",
"documentary_video_url": "",
"documentary_thumbnail_url": "",
"audio_text_url": "",
"footages": [
{
"id": "31",
"latitude": "52.4134145988286",
"longitude": "13.0904620846177",
"position": "12",
"name": "Glienicker Br\u00fccke 1933",
"text": "sdcs",
"thumbnail_url": "",
"video_url": "",
"video_length": "2",
"time_period": {
"id": "24",
"name": "1933"
}
},
{
"id": "32",
"latitude": "52.4134145988286",
"longitude": "13.0904620846177",
"position": "12",
"name": "Glienicker Br\u00fccke 1985",
"text": "fvd",
"thumbnail_url": "",
"video_url": "",
"video_length": 35,
"time_period": {
"id": 30,
"name": "1985"
}
},
{
"id": "33",
"latitude": "52.4134145988286",
"longitude": "13.0904620846177",
"position": "12",
"name": "Glienicker Br\u00fccke 1989",
"text": "fghg",
"thumbnail_url": "",
"video_url": "",
"video_length": "41",
"time_period": {
"id": "12",
"name": "1989"
}
}
]
}
}
]
Ce sont les Classes, j'ai utilisé pour parser le JSON et enregistrer leurs attributs dans une Base de données SQLite.
IntentService Classe
public class Sync extends IntentService {
public Sync() {
super("Sync");
}
@Override
protected void onHandleIntent(Intent intent) {
Database.OpenHelper dbhelper = new Database.OpenHelper(getBaseContext());
SQLiteDatabase db = dbhelper.getWritableDatabase();
DefaultHttpClient httpClient = new DefaultHttpClient();
db.beginTransaction();
HttpGet request = new HttpGet(
"https://....");
try {
HttpResponse response = httpClient.execute(request);
if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
InputStream instream = response.getEntity().getContent();
BufferedReader r = new BufferedReader(new InputStreamReader(
instream, "UTF-8"), 8000);
StringBuilder total = new StringBuilder();
String line;
while ((line = r.readLine()) != null) {
total.append(line);
}
instream.close();
String bufstring = total.toString();
JSONArray arr = new JSONArray(bufstring);
Database.Tables tab = Database.Tables.AllTables
.get(Database.Project.NAME);
tab.DeleteAll(db);
for (int i = 0; i < arr.length(); i++) {
tab.InsertJSON(db, (JSONObject) arr.get(i));
}
db.setTransactionSuccessful();
}
} catch (Exception e) {
e.printStackTrace();
}
db.endTransaction();
db.close();
getContentResolver().notifyChange(
Uri.withAppendedPath(Provider.CONTENT_URI,
Database.Project.NAME), null);
}
}
De Base De Données SQLite Classe
public class Database {
final OpenHelper openHelper;
static final String DATABASE_NAME = "mydb";
static final int DATABASE_VERSION = 6;
public Database(Context context) throws Exception {
openHelper = new OpenHelper(context);
}
public void Destroy() {
openHelper.close();
}
public static enum ColumnsTypes {
integer, varchar, guid, datetime, numeric
};
static final String COLLATE = "COLLATE LOCALIZED";
static final String EMPTY = "";
public static interface Project {
public static final String NAME = "Project";
public static String C_PROJECTTITLE = "project_title";
public static String C_ORGANIZATIONTITLE = "organization_title";
public static String C_WEBSITE = "website";
public static String C_ADDRESS = "address";
public static String C_KEYWORD = "keyword";
public static String C_SHORTCODE = "short_code";
public static String C_PROJECTDESCRIPTION = "project_description";
public static String C_SMALLIMAGE = "smallImageUrl";
public static String C_BIGIMAGE = "bigImageUrl";
public static String C_PRICE = "price";
public static String C_COUNTRY = "country";
public static String C_DONATIONAMOUNT = "donationAmount";
public static String C_CATEGORIES = "categories";
public static String C_CAMPAIGNID = "campaign_id";
public static String C_PAYPALEMAIL = "paypal_email";
public static String C_ELVAVAILABLE = "elv_available";
public static String C_CURRENCY = "currency_isoname";
public final static String[] C = new String[] { C_PROJECTTITLE,
C_ORGANIZATIONTITLE, C_WEBSITE, C_ADDRESS, C_KEYWORD, C_SHORTCODE,
C_PROJECTDESCRIPTION, C_SMALLIMAGE, C_BIGIMAGE, C_PRICE,
C_COUNTRY, C_DONATIONAMOUNT, C_CATEGORIES, C_CAMPAIGNID, C_PAYPALEMAIL, C_ELVAVAILABLE, C_CURRENCY };
public final static ColumnsTypes[] CT = new ColumnsTypes[] {
ColumnsTypes.varchar, ColumnsTypes.varchar,
ColumnsTypes.varchar, ColumnsTypes.varchar,
ColumnsTypes.varchar, ColumnsTypes.varchar,
ColumnsTypes.varchar, ColumnsTypes.varchar,
ColumnsTypes.varchar,ColumnsTypes.varchar, ColumnsTypes.varchar,
ColumnsTypes.varchar,ColumnsTypes.varchar,
ColumnsTypes.varchar,ColumnsTypes.varchar, ColumnsTypes.varchar, ColumnsTypes.varchar};
public final static boolean[] CN = new boolean[] { false, false, false,
false, false, false, false, false, false, false, false, false, false, false, false, false,false };
public final static String[] CS = new String[] { COLLATE, COLLATE,
COLLATE, COLLATE, COLLATE, COLLATE, COLLATE, COLLATE, COLLATE, COLLATE, COLLATE, COLLATE, COLLATE, COLLATE, COLLATE, COLLATE, COLLATE };
}
public static class Tables {
String[] columns = null;
ColumnsTypes[] columnsTypes = null;
String[] columnsSpecials = null;
String name = null;
boolean[] columnsNullable = null;
Tables(String name, String[] columns, ColumnsTypes[] columnsTypes,
String[] columnsSpecials, boolean[] columnsNullable) {
this.name = name;
this.columns = columns;
this.columnsTypes = columnsTypes;
this.columnsSpecials = columnsSpecials;
this.columnsNullable = columnsNullable;
}
public String DropStatment() {
return "DROP TABLE IF EXISTS " + name;
}
public void DeleteAll(SQLiteDatabase db) {
db.delete(name, null,null);
}
public long InsertJSON(SQLiteDatabase db, JSONObject obj)
throws JSONException {
ContentValues vals = new ContentValues();
for (String col : columns) {
vals.put(col, obj.getString(col));
}
return db.insert(name, null, vals);
}
public String CreateStatment() {
StringBuilder sb = new StringBuilder("CREATE TABLE ");
sb.append(name);
sb.append(" ([");
for (int i = 0; i < columns.length; i++) {
sb.append(columns[i]);
sb.append("] ");
sb.append(columnsTypes[i].name());
sb.append(' ');
sb.append(columnsSpecials[i]);
if (!columnsNullable[i])
sb.append(" NOT NULL ");
sb.append(", [");
}
sb.append("_id] INTEGER PRIMARY KEY AUTOINCREMENT);");
return sb.toString();
}
public final static Map<String, Tables> AllTables;
static {
HashMap<String, Tables> aMap = new HashMap<String, Tables>();
aMap.put(Project.NAME, new Tables(Project.NAME, Project.C,
Project.CT, Project.CS, Project.CN));
AllTables = Collections.unmodifiableMap(aMap);
}
}
public static class OpenHelper extends SQLiteOpenHelper {
public OpenHelper(Context context) {
super(context, DATABASE_NAME, null, DATABASE_VERSION);
}
@Override
public void onCreate(SQLiteDatabase db) {
try {
for (Tables table : Tables.AllTables.values()) {
String create = table.CreateStatment();
db.execSQL(create);
}
} catch (Exception e) {
Log.e("Exception", e.toString());
}
}
public OpenHelper Recreate() {
onUpgrade(getWritableDatabase(), 1, 2);
return this;
}
@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
for (Tables table : Tables.AllTables.values()) {
db.execSQL(table.DropStatment());
}
onCreate(db);
}
}
}
ContentProvider Classe
public class Provider extends ContentProvider {
@Override
public int delete(Uri arg0, String arg1, String[] arg2) {
return 0;
}
private static final int PROJECTS = 1;
private static final int PROJECT = 2;
public static final String PROJECTS_MIME_TYPE = ContentResolver.CURSOR_DIR_BASE_TYPE
+ "/Project";
public static final String PROJECT_MIME_TYPE = ContentResolver.CURSOR_ITEM_BASE_TYPE
+ "/Project";
public static final String AUTHORITY = "spendino.de";
public static final Uri CONTENT_URI = Uri.parse("content://" + AUTHORITY);
static final UriMatcher matcher = new UriMatcher(UriMatcher.NO_MATCH);
static final HashMap<String, String> map = new HashMap<String, String>();
static {
matcher.addURI(AUTHORITY, "Project", PROJECTS);
matcher.addURI(AUTHORITY, "Project/#", PROJECT);
map.put(BaseColumns._ID, BaseColumns._ID);
map.put(Database.Project.C_BIGIMAGE, Database.Project.C_BIGIMAGE);
map.put(Database.Project.C_COUNTRY, Database.Project.C_COUNTRY);
map.put(Database.Project.C_KEYWORD, Database.Project.C_KEYWORD);
map.put(Database.Project.C_ORGANIZATIONTITLE,
Database.Project.C_ORGANIZATIONTITLE);
map.put(Database.Project.C_PRICE, Database.Project.C_PRICE);
map.put(Database.Project.C_PROJECTDESCRIPTION,
Database.Project.C_PROJECTDESCRIPTION);
map.put(Database.Project.C_PROJECTTITLE,
Database.Project.C_PROJECTTITLE);
map.put(Database.Project.C_SHORTCODE, Database.Project.C_SHORTCODE);
map.put(Database.Project.C_SMALLIMAGE, Database.Project.C_SMALLIMAGE);
map.put(Database.Project.C_DONATIONAMOUNT, Database.Project.C_DONATIONAMOUNT);
map.put(Database.Project.C_WEBSITE, Database.Project.C_WEBSITE);
map.put(Database.Project.C_ADDRESS, Database.Project.C_ADDRESS);
map.put(Database.Project.C_CATEGORIES, Database.Project.C_CATEGORIES);
map.put(Database.Project.C_CAMPAIGNID, Database.Project.C_CAMPAIGNID);
map.put(Database.Project.C_PAYPALEMAIL, Database.Project.C_PAYPALEMAIL);
map.put(Database.Project.C_ELVAVAILABLE, Database.Project.C_ELVAVAILABLE);
map.put(Database.Project.C_CURRENCY, Database.Project.C_CURRENCY);
}
@Override
public String getType(Uri uri) {
switch (matcher.match(uri)) {
case PROJECTS:
return PROJECTS_MIME_TYPE;
case PROJECT:
return PROJECT_MIME_TYPE;
default:
throw new IllegalArgumentException("Unknown URL " + uri);
}
}
@Override
public Uri insert(Uri arg0, ContentValues arg1) {
//TODO Auto-generated method stub
return null;
}
private Database.OpenHelper mDB;
@Override
public boolean onCreate() {
try {
mDB = new Database.OpenHelper(getContext());
} catch (Exception e) {
Log.e("Exception", e.getLocalizedMessage());
return false;
}
return true;
}
@Override
public Cursor query(Uri uri, String[] projection, String selection,
String[] selectionArgs, String sortOrder) {
SQLiteQueryBuilder builder = new SQLiteQueryBuilder();
switch (matcher.match(uri)) {
case PROJECTS:
String table = uri.getPathSegments().get(0);
builder.setTables(table);
break;
case PROJECT:
table = uri.getPathSegments().get(0);
builder.setTables(table);
selection = "_id=?";
selectionArgs = new String[] { uri.getPathSegments().get(1) };
break;
default:
throw new IllegalArgumentException("Unknown URL " + uri);
}
builder.setProjectionMap(map);
Cursor cursor = builder.query(mDB.getReadableDatabase(), projection, selection,
selectionArgs, null, null, sortOrder);
if (cursor == null) {
return null;
}
cursor.setNotificationUri(getContext().getContentResolver(), uri);
return cursor;
}
public int update(Uri uri, ContentValues cv, String selection, String[] selectionArgs) {
String table = null;
SQLiteQueryBuilder builder = new SQLiteQueryBuilder();
switch (matcher.match(uri)) {
case PROJECTS:
table = uri.getPathSegments().get(0);
builder.setTables(table);
break;
case PROJECT:
table = uri.getPathSegments().get(0);
builder.setTables(table);
selection = "_id=?";
selectionArgs = new String[] { uri.getPathSegments().get(1) };
break;
default:
throw new IllegalArgumentException("Unknown URL " + uri);
}
return mDB.getWritableDatabase().update(table, cv, selection, selectionArgs);
}
}
De quoi ai-je besoin de changer mes Classes ci-dessus afin de rendre le nouveau fichier JSON analysé et enregistré dans la Base de données SQLite?
Je parle ici car il n'y a pas de Tableau sur mon ancien fichier JSON, mais je veux le ré-utiliser les classes j'ai déjà. Je sais que j'ai besoin de changer les noms de colonnes et de personnaliser les Chaînes selon mon JSON attributs sur ma Base de données SQLite et Fournisseur de Classe
Merci
source d'informationauteur hectichavana
Vous devez vous connecter pour publier un commentaire.
Vous pouvez utiliser Gson ou Jackson. Ces bibliothèques vous permet d'analyser/produire JSON d'entrée/de sortie facilement la construction de votre classe "haricots".
Par exemple dans Gson, si vous avez une classe nommée Voiture construite de cette façon:
... et que vous souhaitez analyser un tableau de voitures, vous pouvez facilement gonfler votre JSON de cette façon:
Le très cool, c'est qu'il est en mesure de comprendre que vous avez le contenu des tableaux d'une analyse sans problèmes (je fais référence à votre entrée).
Cheers,
Simone
Essayez de GSON -
Et essayez de changer votre conception de code, j'espère qu'elle vous aidera.
Si votre question est, comment analyser la nouvelle chaîne JSON, c'est assez simple...
Pour analyser un tableau JSON (tout ce qui est enfermé dans
[]
), vous utilisez...et à analyser un objet JSON (tout ce qui est enfermé dans
{}
), vous utilisez...Maintenant, pour analyser la chaîne JSON que vous avez spécifié ci-dessus, il serait quelque chose comme...
pour obtenir le
footages
élément...Ensuite, vous pouvez parcourir le
footages
tableau et de faire de votre traitement.Autant que de stocker les données de la base de données va, Il peut être une bonne idée de stocker le
footages
comme une chaîne JSON dans la base de données puisque c'est un tableau JSON.