Skip to content

L
litepal

zhaoyufei133 / litepal
与 Fork 源项目一致

从无法访问的项目Fork

通知 4
Star 0
Fork 0
L
litepal

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

提交 18da95e0 编写于 作者: guolin's avatar guolin
浏览文件
操作

Callback to main thread when async operation finished.

上级 b7806a1f
隐藏空白更改
内联 并排
Showing with 212 addition and 157 deletion
litepal/src/main/java/org/litepal/LitePal.java
浏览文件 @ 18da95e0
......@@ -18,6 +18,8 @@ package org.litepal;
import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.os.Handler;
import android.os.Looper;
import android.text.TextUtils;
import org.litepal.parser.LitePalAttr;
......@@ -41,6 +43,8 @@ import java.io.File;
*/
public class LitePal {
private static Handler handler = new Handler(Looper.getMainLooper());
/**
* Initialize to make LitePal ready to work. If you didn't configure LitePalApplication
* in the AndroidManifest.xml, make sure you call this method as soon as possible. In
......@@ -62,6 +66,14 @@ public class LitePal {
return Connector.getDatabase();
}
/**
* Get the main thread handler. You don't need this method. It's used by framework only.
* @return Main thread handler.
*/
public static Handler getHandler() {
return handler;
}
/**
* Switch the using database to the one specified by parameter.
* @param litePalDB
......
litepal/src/main/java/org/litepal/crud/ClusterQuery.java
浏览文件 @ 18da95e0
......@@ -18,6 +18,7 @@ package org.litepal.crud;
import java.util.List;
import org.litepal.LitePal;
import org.litepal.crud.async.AverageExecutor;
import org.litepal.crud.async.CountExecutor;
import org.litepal.crud.async.FindExecutor;
......@@ -246,9 +247,14 @@ public class ClusterQuery {
@Override
public void run() {
synchronized (DataSupport.class) {
List<T> t = find(modelClass, isEager);
final List<T> t = find(modelClass, isEager);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -325,9 +331,14 @@ public class ClusterQuery {
@Override
public void run() {
synchronized (DataSupport.class) {
T t = findFirst(modelClass, isEager);
final T t = findFirst(modelClass, isEager);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -405,9 +416,14 @@ public class ClusterQuery {
@Override
public void run() {
synchronized (DataSupport.class) {
T t = findLast(modelClass, isEager);
final T t = findLast(modelClass, isEager);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -485,9 +501,14 @@ public class ClusterQuery {
@Override
public void run() {
synchronized (DataSupport.class) {
int count = count(tableName);
final int count = count(tableName);
if (executor.getListener() != null) {
executor.getListener().onFinish(count);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(count);
}
});
}
}
}
......@@ -571,9 +592,14 @@ public class ClusterQuery {
@Override
public void run() {
synchronized (DataSupport.class) {
double average = average(tableName, column);
final double average = average(tableName, column);
if (executor.getListener() != null) {
executor.getListener().onFinish(average);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(average);
}
});
}
}
}
......@@ -667,9 +693,14 @@ public class ClusterQuery {
@Override
public void run() {
synchronized (DataSupport.class) {
T t = max(tableName, columnName, columnType);
final T t = max(tableName, columnName, columnType);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -763,9 +794,14 @@ public class ClusterQuery {
@Override
public void run() {
synchronized (DataSupport.class) {
T t = min(tableName, columnName, columnType);
final T t = min(tableName, columnName, columnType);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -859,9 +895,14 @@ public class ClusterQuery {
@Override
public void run() {
synchronized (DataSupport.class) {
T t = sum(tableName, columnName, columnType);
final T t = sum(tableName, columnName, columnType);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......
litepal/src/main/java/org/litepal/crud/DataSupport.java
浏览文件 @ 18da95e0
......@@ -20,13 +20,13 @@ import android.content.ContentValues;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import org.litepal.LitePal;
import org.litepal.crud.async.AverageExecutor;
import org.litepal.crud.async.CountExecutor;
import org.litepal.crud.async.SaveExecutor;
import org.litepal.crud.async.UpdateOrDeleteExecutor;
import org.litepal.crud.async.FindBySQLExecutor;
import org.litepal.crud.async.FindExecutor;
import org.litepal.crud.async.FindMultiExecutor;
import org.litepal.crud.async.SaveExecutor;
import org.litepal.crud.async.UpdateOrDeleteExecutor;
import org.litepal.exceptions.DataSupportException;
import org.litepal.tablemanager.Connector;
import org.litepal.util.BaseUtility;
......@@ -292,9 +292,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
int count = count(tableName);
final int count = count(tableName);
if (executor.getListener() != null) {
executor.getListener().onFinish(count);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(count);
}
});
}
}
}
......@@ -378,9 +383,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
double average = average(tableName, column);
final double average = average(tableName, column);
if (executor.getListener() != null) {
executor.getListener().onFinish(average);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(average);
}
});
}
}
}
......@@ -474,9 +484,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
T t = max(tableName, columnName, columnType);
final T t = max(tableName, columnName, columnType);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -570,9 +585,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
T t = min(tableName, columnName, columnType);
final T t = min(tableName, columnName, columnType);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -666,9 +686,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
T t = sum(tableName, columnName, columnType);
final T t = sum(tableName, columnName, columnType);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -751,9 +776,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
T t = find(modelClass, id, isEager);
final T t = find(modelClass, id, isEager);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -825,9 +855,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
T t = findFirst(modelClass, isEager);
final T t = findFirst(modelClass, isEager);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -899,9 +934,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
T t = findLast(modelClass, isEager);
final T t = findLast(modelClass, isEager);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -995,9 +1035,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
List<T> t = findAll(modelClass, isEager, ids);
final List<T> t = findAll(modelClass, isEager, ids);
if (executor.getListener() != null) {
executor.getListener().onFinish(t);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(t);
}
});
}
}
}
......@@ -1040,31 +1085,6 @@ public class DataSupport {
return Connector.getDatabase().rawQuery(sql[0], selectionArgs);
}
/**
* Basically same as {@link #findBySQL(String...)} but pending to a new thread for executing.
*
* @param sql
* First parameter is the SQL clause to apply. Second to the last
* parameters will replace the place holders.
* @return A FindBySQLExecutor instance.
*/
public static FindBySQLExecutor findBySQLAsync(final String... sql) {
final FindBySQLExecutor executor = new FindBySQLExecutor();
Runnable runnable = new Runnable() {
@Override
public void run() {
synchronized (DataSupport.class) {
Cursor cursor = findBySQL(sql);
if (executor.getListener() != null) {
executor.getListener().onFinish(cursor);
}
}
}
};
executor.submit(runnable);
return executor;
}
/**
* Deletes the record in the database by id.<br>
* The data in other tables which is referenced with the record will be
......@@ -1111,9 +1131,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
int rowsAffected = delete(modelClass, id);
final int rowsAffected = delete(modelClass, id);
if (executor.getListener() != null) {
executor.getListener().onFinish(rowsAffected);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(rowsAffected);
}
});
}
}
}
......@@ -1172,9 +1197,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
int rowsAffected = deleteAll(modelClass, conditions);
final int rowsAffected = deleteAll(modelClass, conditions);
if (executor.getListener() != null) {
executor.getListener().onFinish(rowsAffected);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(rowsAffected);
}
});
}
}
}
......@@ -1236,9 +1266,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
int rowsAffected = deleteAll(tableName, conditions);
final int rowsAffected = deleteAll(tableName, conditions);
if (executor.getListener() != null) {
executor.getListener().onFinish(rowsAffected);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(rowsAffected);
}
});
}
}
}
......@@ -1291,9 +1326,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
int rowsAffected = update(modelClass, values, id);
final int rowsAffected = update(modelClass, values, id);
if (executor.getListener() != null) {
executor.getListener().onFinish(rowsAffected);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(rowsAffected);
}
});
}
}
}
......@@ -1419,9 +1459,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
int rowsAffected = updateAll(tableName, values, conditions);
final int rowsAffected = updateAll(tableName, values, conditions);
if (executor.getListener() != null) {
executor.getListener().onFinish(rowsAffected);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(rowsAffected);
}
});
}
}
}
......@@ -1490,8 +1535,14 @@ public class DataSupport {
} catch (Exception e) {
success = false;
}
final boolean result = success;
if (executor.getListener() != null) {
executor.getListener().onFinish(success);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(result);
}
});
}
}
}
......@@ -1570,9 +1621,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
int rowsAffected = delete();
final int rowsAffected = delete();
if (executor.getListener() != null) {
executor.getListener().onFinish(rowsAffected);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(rowsAffected);
}
});
}
}
}
......@@ -1626,9 +1682,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
int rowsAffected = update(id);
final int rowsAffected = update(id);
if (executor.getListener() != null) {
executor.getListener().onFinish(rowsAffected);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(rowsAffected);
}
});
}
}
}
......@@ -1696,9 +1757,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
int rowsAffected = updateAll(conditions);
final int rowsAffected = updateAll(conditions);
if (executor.getListener() != null) {
executor.getListener().onFinish(rowsAffected);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(rowsAffected);
}
});
}
}
}
......@@ -1752,9 +1818,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
boolean success = save();
final boolean success = save();
if (executor.getListener() != null) {
executor.getListener().onFinish(success);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(success);
}
});
}
}
}
......@@ -1893,9 +1964,14 @@ public class DataSupport {
@Override
public void run() {
synchronized (DataSupport.class) {
boolean success = saveOrUpdate(conditions);
final boolean success = saveOrUpdate(conditions);
if (executor.getListener() != null) {
executor.getListener().onFinish(success);
LitePal.getHandler().post(new Runnable() {
@Override
public void run() {
executor.getListener().onFinish(success);
}
});
}
}
}
......
litepal/src/main/java/org/litepal/crud/async/FindBySQLExecutor.java 已删除 100644 → 0
浏览文件 @ b7806a1f
/*
* Copyright (C) Tony Green, LitePal Framework Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.litepal.crud.async;
import org.litepal.crud.callback.FindBySQLCallback;
/**
* Executor for find by sql in background.
*
* @author Tony Green
* @since 2017/2/22
*/
public class FindBySQLExecutor extends AsyncExecutor {
private FindBySQLCallback cb;
/**
* Register a callback listener and async task will start executing right away.
* @param callback
* Callback for find by sql in background.
*/
public void listen(FindBySQLCallback callback) {
cb = callback;
execute();
}
public FindBySQLCallback getListener() {
return cb;
}
}
\ No newline at end of file
litepal/src/main/java/org/litepal/crud/callback/FindBySQLCallback.java 已删除 100644 → 0
浏览文件 @ b7806a1f
/*
* Copyright (C) Tony Green, LitePal Framework Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.litepal.crud.callback;
import android.database.Cursor;
/**
* Callback for find by sql in background.
*
* @author Tony Green
* @since 2017/2/22
*/
public interface FindBySQLCallback {
void onFinish(Cursor cursor);
}
\ No newline at end of file
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或