package com.github.andlyticsproject.db;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import android.content.ContentProvider;
import android.content.ContentUris;
import android.content.ContentValues;
import android.content.Context;
import android.content.UriMatcher;
import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import android.database.sqlite.SQLiteQueryBuilder;
import android.net.Uri;
import android.util.Log;
private static final String TAG = "AndlyticsContentProvider";
private static final int DATABASE_VERSION = 16;
private static final String DATABASE_NAME = "andlytics";
private static final int ID_TABLE_STATS = 0;
private static final int ID_TABLE_APPINFO = 1;
private static final int ID_TABLE_COMMENTS = 2;
private static final int ID_TABLE_ADMOB = 3;
private static final int ID_APP_VERSION_CHANGE = 4;
private static final int ID_UNIQUE_PACKAGES = 5;
public static final String AUTHORITY = "com.github.andlyticsproject.db.AndlyticsContentProvider";
private static final UriMatcher sUriMatcher;
public static final String APP_VERSION_CHANGE = "appVersionChange";
super(context, DATABASE_NAME, null, DATABASE_VERSION);
}
@Override
public void onCreate(SQLiteDatabase db) {
Log.d(TAG, "Creating databse");
db.execSQL(AppInfoTable.TABLE_CREATE_APPINFO);
db.execSQL(AppStatsTable.TABLE_CREATE_STATS);
db.execSQL(CommentsTable.TABLE_CREATE_COMMENTS);
db.execSQL(AdmobTable.TABLE_CREATE_ADMOB);
}
@Override
public void onUpgrade(SQLiteDatabase db,
int oldVersion,
int newVersion) {
Log.w(TAG, "Upgrading database from version " + oldVersion + " to " + newVersion + ".");
if (oldVersion < 9) {
Log.w(TAG, "Old version < 9 - drop all tables & recreate");
db.execSQL("DROP TABLE IF EXISTS " + AppInfoTable.DATABASE_TABLE_NAME);
db.execSQL("DROP TABLE IF EXISTS " + AppStatsTable.DATABASE_TABLE_NAME);
db.execSQL(AppInfoTable.TABLE_CREATE_APPINFO);
db.execSQL(AppStatsTable.TABLE_CREATE_STATS);
}
if (oldVersion == 9) {
Log.w(TAG, "Old version = 9 - add ghost column");
db.execSQL("ALTER table " + AppInfoTable.DATABASE_TABLE_NAME + " add "
+ AppInfoTable.KEY_APP_GHOST + " integer");
}
if (oldVersion > 8 && oldVersion < 11) {
Log.w(TAG, "Old version = 10 or 9 - add rating expand column");
db.execSQL("ALTER table " + AppInfoTable.DATABASE_TABLE_NAME + " add "
+ AppInfoTable.KEY_APP_RATINGS_EXPANDED + " integer");
}
if (oldVersion < 12) {
Log.w(TAG, "Old version < 12 - add comments table");
db.execSQL(CommentsTable.TABLE_CREATE_COMMENTS);
}
if (oldVersion < 13) {
Log.w(TAG, "Old version < 13 - add skip notification");
db.execSQL("ALTER table " + AppInfoTable.DATABASE_TABLE_NAME + " add "
+ AppInfoTable.KEY_APP_SKIP_NOTIFICATION + " integer");
}
if (oldVersion < 14) {
Log.w(TAG, "Old version < 14 - add admob table");
db.execSQL(AdmobTable.TABLE_CREATE_ADMOB);
}
if (oldVersion < 15) {
Log.w(TAG, "Old version < 15 - add version name");
db.execSQL("ALTER table " + AppInfoTable.DATABASE_TABLE_NAME + " add "
+ AppInfoTable.KEY_APP_VERSION_NAME + " text");
}
if (oldVersion < 16) {
Log.w(TAG, "Old version < 16 - add new comments colums");
db.execSQL("ALTER table " + CommentsTable.DATABASE_TABLE_NAME + " add "
+ CommentsTable.KEY_COMMENT_APP_VERSION + " text");
db.execSQL("ALTER table " + CommentsTable.DATABASE_TABLE_NAME + " add "
+ CommentsTable.KEY_COMMENT_DEVICE + " text");
}
}
}
private DatabaseHelper dbHelper;
@Override
public int delete(Uri uri, String where, String[] whereArgs) {
SQLiteDatabase db = dbHelper.getWritableDatabase();
int count;
switch (sUriMatcher.match(uri)) {
case ID_TABLE_STATS:
count = db.delete(AppStatsTable.DATABASE_TABLE_NAME, where, whereArgs);
break;
case ID_TABLE_APPINFO:
count = db.delete(AppInfoTable.DATABASE_TABLE_NAME, where, whereArgs);
break;
case ID_TABLE_COMMENTS:
count = db.delete(CommentsTable.DATABASE_TABLE_NAME, where, whereArgs);
break;
case ID_TABLE_ADMOB:
count = db.delete(AdmobTable.DATABASE_TABLE_NAME, where, whereArgs);
break;
default:
throw new IllegalArgumentException("Unknown URI " + uri);
}
getContext().getContentResolver().notifyChange(uri, null);
return count;
}
@Override
switch (sUriMatcher.match(uri)) {
case ID_TABLE_STATS:
return AppStatsTable.CONTENT_TYPE;
case ID_TABLE_APPINFO:
return AppInfoTable.CONTENT_TYPE;
case ID_TABLE_COMMENTS:
return CommentsTable.CONTENT_TYPE;
case ID_TABLE_ADMOB:
return AdmobTable.CONTENT_TYPE;
case ID_APP_VERSION_CHANGE:
return APP_VERSION_CHANGE;
default:
throw new IllegalArgumentException("Unknown URI " + uri);
}
}
@Override
public Uri
insert(Uri uri, ContentValues initialValues) {
ContentValues values;
if (initialValues != null) {
values = new ContentValues(initialValues);
} else {
values = new ContentValues();
}
SQLiteDatabase db = dbHelper.getWritableDatabase();
long rowId = -1;
switch (sUriMatcher.match(uri)) {
case ID_TABLE_STATS:
rowId = getAppStatsIdByDate(
values.getAsString(AppStatsTable.KEY_STATS_PACKAGENAME),
parseDate(values.getAsString(AppStatsTable.KEY_STATS_REQUESTDATE)), db);
if (rowId > -1) {
db.update(AppStatsTable.DATABASE_TABLE_NAME, values, AppStatsTable.KEY_ROWID
+ "=" + rowId, null);
} else {
rowId = db.insert(AppStatsTable.DATABASE_TABLE_NAME, null, values);
}
if (rowId > 0) {
Uri noteUri = ContentUris.withAppendedId(AppStatsTable.CONTENT_URI, rowId);
getContext().getContentResolver().notifyChange(noteUri, null);
return noteUri;
}
case ID_TABLE_APPINFO:
Cursor mCursor = db.query(AppInfoTable.DATABASE_TABLE_NAME, new String[] {
AppInfoTable.KEY_ROWID, AppInfoTable.KEY_APP_ACCOUNT,
AppInfoTable.KEY_APP_PACKAGENAME }, AppInfoTable.KEY_APP_PACKAGENAME + "='"
+ values.getAsString(AppInfoTable.KEY_APP_PACKAGENAME) + "'", null, null,
null, null);
if (mCursor != null && mCursor.moveToFirst()) {
rowId = mCursor.getInt(mCursor.getColumnIndex(AppInfoTable.KEY_ROWID));
}
mCursor.close();
if (rowId > -1) {
db.update(AppInfoTable.DATABASE_TABLE_NAME, initialValues,
AppInfoTable.KEY_ROWID + "=" + rowId, null);
} else {
rowId = db.insert(AppInfoTable.DATABASE_TABLE_NAME, null, values);
}
if (rowId > 0) {
Uri noteUri = ContentUris.withAppendedId(AppInfoTable.CONTENT_URI, rowId);
getContext().getContentResolver().notifyChange(noteUri, null);
return noteUri;
}
case ID_TABLE_COMMENTS:
rowId = db.insert(CommentsTable.DATABASE_TABLE_NAME, null, values);
if (rowId > 0) {
Uri noteUri = ContentUris.withAppendedId(CommentsTable.CONTENT_URI, rowId);
getContext().getContentResolver().notifyChange(noteUri, null);
return noteUri;
}
case ID_TABLE_ADMOB:
rowId = db.insert(AdmobTable.DATABASE_TABLE_NAME, null, values);
if (rowId > 0) {
Uri noteUri = ContentUris.withAppendedId(AdmobTable.CONTENT_URI, rowId);
getContext().getContentResolver().notifyChange(noteUri, null);
return noteUri;
}
}
throw new SQLException("Failed to insert row into " + uri);
}
@Override
dbHelper = new DatabaseHelper(getContext());
return true;
}
@Override
public Cursor
query(Uri uri, String[] projection, String selection, String[] selectionArgs,
String sortOrder) {
SQLiteQueryBuilder qb = new SQLiteQueryBuilder();
String groupBy = null;
switch (sUriMatcher.match(uri)) {
case ID_TABLE_STATS:
qb.setTables(AppStatsTable.DATABASE_TABLE_NAME);
groupBy = AppStatsTable.KEY_STATS_REQUESTDATE;
qb.setProjectionMap(AppStatsTable.PROJECTION_MAP);
break;
case ID_TABLE_APPINFO:
qb.setTables(AppInfoTable.DATABASE_TABLE_NAME);
groupBy = AppInfoTable.KEY_APP_PACKAGENAME;
qb.setProjectionMap(AppInfoTable.PROJECTION_MAP);
break;
case ID_TABLE_COMMENTS:
qb.setTables(CommentsTable.DATABASE_TABLE_NAME);
qb.setProjectionMap(CommentsTable.PROJECTION_MAP);
break;
case ID_TABLE_ADMOB:
qb.setTables(AdmobTable.DATABASE_TABLE_NAME);
qb.setProjectionMap(AdmobTable.PROJECTION_MAP);
break;
case ID_APP_VERSION_CHANGE:
qb.setTables(AppStatsTable.DATABASE_TABLE_NAME);
qb.setProjectionMap(AppStatsTable.PROJECTION_MAP);
break;
case ID_UNIQUE_PACKAGES:
qb.setTables(AppInfoTable.DATABASE_TABLE_NAME);
qb.setProjectionMap(AppInfoTable.PACKAGE_NAMES_MAP);
qb.setDistinct(true);
break;
default:
throw new IllegalArgumentException("Unknown URI " + uri);
}
SQLiteDatabase db = dbHelper.getReadableDatabase();
Cursor c = null;
if (sUriMatcher.match(uri) == ID_APP_VERSION_CHANGE) {
c = qb.query(db, projection, selection, selectionArgs,
AppStatsTable.KEY_STATS_VERSIONCODE, null, sortOrder);
} else {
c = qb.query(db, projection, selection, selectionArgs, groupBy, null, sortOrder);
}
c.setNotificationUri(getContext().getContentResolver(), uri);
return c;
}
@Override
public int update(Uri uri, ContentValues values, String where, String[] whereArgs) {
SQLiteDatabase db = dbHelper.getWritableDatabase();
int count;
switch (sUriMatcher.match(uri)) {
case ID_TABLE_STATS:
count = db.update(AppStatsTable.DATABASE_TABLE_NAME, values, where, whereArgs);
break;
case ID_TABLE_APPINFO:
count = db.update(AppInfoTable.DATABASE_TABLE_NAME, values, where, whereArgs);
break;
case ID_TABLE_COMMENTS:
count = db.update(CommentsTable.DATABASE_TABLE_NAME, values, where, whereArgs);
break;
case ID_TABLE_ADMOB:
count = db.update(AdmobTable.DATABASE_TABLE_NAME, values, where, whereArgs);
break;
default:
throw new IllegalArgumentException("Unknown URI " + uri);
}
getContext().getContentResolver().notifyChange(uri, null);
return count;
}
static {
sUriMatcher = new UriMatcher(UriMatcher.NO_MATCH);
sUriMatcher.addURI(AUTHORITY, AppStatsTable.DATABASE_TABLE_NAME, ID_TABLE_STATS);
sUriMatcher.addURI(AUTHORITY, AppInfoTable.DATABASE_TABLE_NAME, ID_TABLE_APPINFO);
sUriMatcher.addURI(AUTHORITY, AppInfoTable.UNIQUE_PACKAGE_NAMES, ID_UNIQUE_PACKAGES);
sUriMatcher.addURI(AUTHORITY, CommentsTable.DATABASE_TABLE_NAME, ID_TABLE_COMMENTS);
sUriMatcher.addURI(AUTHORITY, AdmobTable.DATABASE_TABLE_NAME, ID_TABLE_ADMOB);
sUriMatcher.addURI(AUTHORITY, APP_VERSION_CHANGE, ID_APP_VERSION_CHANGE);
}
throws SQLException {
long result = -1;
SimpleDateFormat dateFormatStart = new SimpleDateFormat("yyyy-MM-dd 00:00:00");
SimpleDateFormat dateFormatEnd = new SimpleDateFormat("yyyy-MM-dd 23:59:59");
Cursor mCursor = db.query(
AppStatsTable.DATABASE_TABLE_NAME,
new String[] { AppStatsTable.KEY_ROWID, AppStatsTable.KEY_STATS_REQUESTDATE },
AppStatsTable.KEY_STATS_PACKAGENAME + "='" + packagename + "' and "
+ AppStatsTable.KEY_STATS_REQUESTDATE + " BETWEEN '"
+ dateFormatStart.format(date) + "' and '" + dateFormatEnd.format(date)
+ "'", null, null, null, null);
if (mCursor != null && mCursor.moveToFirst()) {
result = mCursor.getInt(mCursor.getColumnIndex(AppStatsTable.KEY_ROWID));
}
mCursor.close();
return result;
}
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
try {
return dateFormat.parse(string);
} catch (ParseException e) {
return null;
}
}
}
