1.Iam从服务器获取大量数据,并在android登录时插入本地数据库。
2.出于同步目的,我使用了改造库,同步和插入工作正常。
我的问题:当使用改造从服务器同步一组数据时,循环进度对话框变得冻结。
帮我解决这个问题。
编辑:1
在异步任务中调用了改进方法,仍然循环ProgressDialog以冻结
//调用异步任务
Asynctask_Getdata task=new Asynctask_Getdata(TokenType_StringValue,Access_Token_StringValue, ID_StringValue);
task.execute();
//异步任务方法
public class Asynctask_Getdata extends AsyncTask<String,Void,Void>
{
String TokenType_StringValueitem;
String Access_Token_StringValueitem;
String ID_StringValueitem;
public Asynctask_Getdata(String tokenType_StringValueitem, String access_Token_StringValueitem, String ID_StringValueitem) {
TokenType_StringValueitem = tokenType_StringValueitem;
Access_Token_StringValueitem = access_Token_StringValueitem;
ID_StringValueitem = ID_StringValueitem;
}
@Override
protected void onPreExecute()
{
super.onPreExecute();
if (!pDialog.isShowing())
{
pDialog.setIndeterminate(true);
pDialog.setCanceledOnTouchOutside(false);
pDialog.setMessage("Please Wait Getting Data...");
pDialog.show();
}
}
@Override
protected void onPostExecute(Void aVoid)
{
super.onPostExecute(aVoid);
}
@Override
protected Void doInBackground(String... params)
{
getLoginDataCall(TokenType_StringValueitem, Access_Token_StringValueitem, ID_StringValueitem );
return null;
}
}
private void getLoginDataCall(String TokenType_String, String Access_Token_StringValue, String RouteID_String) {
String Tokenadd = TokenType_String + " Access_Token_StringValue;
sisClient.getApi().getAllData(Tokenadd, RouteID_String,
new Callback<CommonResponse>() {
@Override
public void success(CommonResponse commonResponse, Response response) {
Timber.d("sendOtpAPICall%s", commonResponse.getStatusCode());
switch (commonResponse.getStatusCode()) {
case 200:
try {
JSONArray jsonarray = null;
try {
jsonarray = new JSONArray(commonResponse.getRouteMaster());
if (!commonResponse.getRouteMaster().equals("[]"))
{
for (int i = 0; i < jsonarray.length(); i++)
{
JSONObject jsonobject = jsonarray.getJSONObject(i);
RouteId_StringValue = jsonobject.getString("RouteId");
Asynxfor_Route_Master_insert(RouteId_StringValue);
}
} else {
System.out.println("ROute Master Is NULL ::" + commonResponse.getStatusMessage() + "\n");
}
} catch (Exception e) {
e.printStackTrace();
;
}
break;
case 404:
pDialog.dismiss();
Toast.makeText(LoginPage.this, R.string.wrong_Username_or_password, Toast.LENGTH_LONG).show();
break;
case 500:
pDialog.dismiss();
Toast.makeText(LoginPage.this, R.string.something_wrong, Toast.LENGTH_LONG).show();
break;
}
}
@Override
public void failure(RetrofitError error) {
try {
if (error != null) {
pDialog.dismiss();
Timber.i("sendOtpAPICall error %s", error.getResponse().getStatus());
String json = new String(((TypedByteArray) error.getResponse().getBody()).getBytes());
Timber.i("failure error %s", json.toString());
JSONObject json1 = new JSONObject(json.toString());
String json1string = json1.getString("StatusMessage");
switch (error.getResponse().getStatus()) {
case 404:
Toast.makeText(getApplicationContext(), R.string.wrong_Username_or_password, Toast.LENGTH_LONG).show();
break;
case 500:
Toast.makeText(LoginPage.this, R.string.something_wrong, Toast.LENGTH_LONG).show();
break;
default:
Toast.makeText(LoginPage.this, json1string, Toast.LENGTH_LONG).show();
break;
}
} else {
Timber.i("failure error %s", "Recieving error null rom server");
}
} catch (Exception e) {
e.printStackTrace();
Toast.makeText(LoginPage.this, R.string.something_wrong, Toast.LENGTH_LONG).show();
}
}
});
}
这是您的重新接口,您可以在其中定义要进行的调用
interface RestInterface {
String BASE_URL = "https://you_have_to_specify.com/if_anything/";
@GET("your_api")
Call<ModelResponse> getRouteId(@Query String valueItem);
}
这是实现类,从中可以调用
public class RestService {
private RestInterface restInterface;
private OkHttpClient okHttpClient;
public RestService() {
OkHttpClient.Builder clientBuilder = new OkHttpClient.Builder();
if (BuildConfig.DEBUG) {
HttpLoggingInterceptor httpLoggingInterceptor = new HttpLoggingInterceptor();
httpLoggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
clientBuilder.addInterceptor(httpLoggingInterceptor);
}
okHttpClient = clientBuilder.build();
Retrofit retrofit = new Retrofit.Builder()
.baseUrl(RestInterface.BASE_URL)
.client(okHttpClient)
.addConverterFactory(GsonConverterFactory.create())
.build();
restInterface = retrofit.create(RestInterface.class);
}
//this is the exposed method
public void getRoute(String valueId, Callback<ModelResponse> callback){
Call<ModelResponse> call = restInterface.getRouteId(valueId);
call.enque(callback);
}
}
该类应采用您收到的回复的格式
public class ModelResponse{
String RouteId;
public String getRouteId(){
return RouteId;
}
}
现在从您的活动(或您的首选类)中,创建一个RestService对象,并调用方法getRoute(),将您的查询字符串和一个匿名回调对象(改造2回调接口)作为参数传递。您将在匿名回调对象中获得结果作为响应。//稍后添加您的实现类
public class FromWhereYourApiIsCalled{
RestService restService = new RestService();
public void callRouteIdMethod(String value){
progressDialog.show();// define progress dialog before
restService.getRoute(value, new Callback<ModelResponse>() {
@Override
public void onResponse(Call<ModelResponse> call, Response<ModelResponse> response) {
progressDialog.dismiss();
Log.v("route Id", response.body().getRouteId());
}
@Override
public void onFailure(Call<ModelResponse> call, Throwable t) {
progressDialog.dismiss();
}
});
}
}
在这种情况下,没有很好的理由进行同步改造调用,您应该使用改造提供的现成异步调用。这很简单,您可以使用回调来管理ProgressBar状态。
在我看来,你根本不应该使用Asyncask。如果你想探索这个,看看这个,这个和这个。
示例代码从使用AsyncTask改装v1同步调用转换为改装2异步调用,在api类中进行管理,并使用Otto事件总线进行消息传递:
public class ApiService {
private static ApiService INSTANCE;
// thwart instantiation by protecting
protected ApiService() {
// nothing
}
public static ApiService getInstance() {
if (INSTANCE == null) {
INSTANCE = new ApiService();
}
return INSTANCE;
}
// -----------------------------------------------------------------------------------
private static final String BASE_URL = "http://api.service.com/";
private interface ApiServiceInterface {
@GET("your/endpoint")
Call<CommonResponse> postLogin(@Query("token_add") String tokenAdd, @Query("route_id") String RouteId);
}
private ApiServiceInterface apiServiceInterface = null;
private ApiServiceInterface getInterface() {
if (apiServiceInterface == null) {
HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor();
interceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
OkHttpClient client = new OkHttpClient.Builder()
.addInterceptor(interceptor)
.build();
Retrofit retrofit = new Retrofit.Builder()
.client(client)
.baseUrl(BASE_URL)
.addConverterFactory(GsonConverterFactory.create())
.build();
apiServiceInterface = retrofit.create(ApiServiceInterface.class);
}
return apiServiceInterface;
}
public void doGetData(Dialog pDialog, String TokenType_String, String Access_Token_StringValue, String RouteID_String) {
if (!pDialog.isShowing())
{
pDialog.setIndeterminate(true);
pDialog.setCanceledOnTouchOutside(false);
pDialog.setMessage("Please Wait Getting Data...");
pDialog.show();
}
String Tokenadd = TokenType_String + Access_Token_StringValue;
getInterface().postLogin(Tokenadd, RouteID_String)
.enqueue(new Callback<SocketCtrlResponse>() {
@Override
public void onResponse(Call<CommonResponse> call, Response<CommonResponse> response) {
Timber.d("sendOtpAPICall%s", commonResponse.getStatusCode());
switch (commonResponse.getStatusCode()) {
case 200:
JSONArray jsonarray = null;
try {
jsonarray = new JSONArray(commonResponse.getRouteMaster());
if (!commonResponse.getRouteMaster().equals("[]")) {
for (int i = 0; i < jsonarray.length(); i++) {
JSONObject jsonobject = jsonarray.getJSONObject(i);
RouteId_StringValue = jsonobject.getString("RouteId");
//Asynxfor_Route_Master_insert(RouteId_StringValue);
EventBus.getDefault().post(new GetDataResponseEvent(RouteId_StringValue));
}
} else {
System.out.println("ROute Master Is NULL ::" + commonResponse.getStatusMessage() + "\n");
}
} catch (Exception e) {
e.printStackTrace();
}
break;
case 404:
pDialog.dismiss();
Toast.makeText(LoginPage.this, R.string.wrong_Username_or_password, Toast.LENGTH_LONG).show();
EventBus.getDefault().post(new GetDataResponseEvent(""));
break;
case 500:
pDialog.dismiss();
Toast.makeText(LoginPage.this, R.string.something_wrong, Toast.LENGTH_LONG).show();
EventBus.getDefault().post(new GetDataResponseEvent(""));
break;
}
}
@Override
public void onFailure(Call<CommonResponse> call, Throwable t) {
t.printStackTrace();
pDialog.dismiss();
Toast.makeText(LoginPage.this, R.string.something_wrong, Toast.LENGTH_LONG).show();
EventBus.getDefault().post(new GetDataResponseEvent(""));
}
});
}
}
您需要一个事件类来包装希望从API返回的数据,例如:
public class GetDataResponseEvent {
private final String data;
public GetDataResponseEvent(String data) {
this.data = data;
}
public String getData() {
return data;
}
}
作为从活动调用服务的示例:
public class YourActivity extends Activity {
Dialog pDialog;
// ...
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
// init pDialog, content view, etc.
EventBus.getDefault().register(this);
// ...
}
// ...
public void getDataFromApi() {
ApiService.getInstance().doGetData(pDialog, TokenType_StringValue,Access_Token_StringValue, ID_StringValue);
}
// ...
public void onEvent(GetDataResponseEvent event) {
String data = event.getData();
Asynxfor_Route_Master_insert(data);
}
// ...
}
再次注意,您必须升级到改装2并使用Otto。我已经猜到了这个实现,所以它可能无法按原样工作,但应该是一个很好的草图,以获得它的感觉。
您不能使用pDialog.dismiss();
和Toast.make文本
。
您必须在可以访问UI线程的方法中执行此操作,例如onProgressUpdate()
和onPostExecute()
。
问题内容: 我需要每周将一个大型(3GB + / 40+个表)本地MySQL数据库同步到服务器数据库。这两个数据库完全相同。本地数据库会不断更新,每周大约需要用本地数据更新服务器数据库。您可以将其称为“镜像数据库”或“主服务器/主服务器”,但是我不确定这是否正确。 现在,数据库仅在本地存在。所以: 1)首先,我需要将数据库从本地复制到服务器。由于数据库大小和PHPMyAdmin的限制,使用PHPM
我想使用进度对话框与异步任务,我怎么能使用它。我试过了,但它在得到响应后向我显示对话框,这是我的调用函数。由于我预计我面临的问题是由于此应用程序响应 = reqClient.execute(.get();因为我还必须从此异步任务中获取返回值。因此,请参阅两个文件以进行折射 此功能用于发送请求 因此,请建议我该怎么做才能显示流程对话框。我尝试了堆栈溢出上的所有示例。但这一切都不适合我。请帮忙
问题内容: 我正在编写一个脚本,该脚本应该在一堆服务器周围运行,并从其中选择一堆数据,包括本地服务器。选择所需数据的SQL非常复杂,因此我正在编写临时视图,并使用OPENQUERY语句获取数据,因此最终我最终循环了如下语句: 但是,我听说在本地服务器上使用OPENQUERY是一种皱眉。有人能详细说明为什么吗? 问题答案: 尽管查询可能返回多个结果集,但OPENQUERY仅返回第一个结果集。 OPE
问题内容: 是否有使用freebase数据转储创建数据库的任何现有方法,类似于freebase所提供的,但是在您自己的服务器上?相当多的免费库,但不是通过API在本地进行的吗? 我想可以创建,但是已经有解决方案了吗?还是没有使用API的类似数据的其他替代解决方案?我也没有为dbpedia找到这个: 问题答案: 看一下Google Code上的freebase-quad-rdfize项目。它应该
试图通过改装将表单数据发送到服务器,但无法向服务器请求。我想用他们的数据发布一个图像数组。 我尝试了许多解决方案,但无法发布包含其数据的图像阵列。当我从addFormDataPart中删除provider\u文档时,效果很好。 如何发送array,它在上运行良好。 请求Api
问题内容: 我对AngularJS相当陌生,并且从模态对话框服务返回数据时遇到问题。基本上,我复制了Dan Wahlin的服务http://weblogs.asp.net/dwahlin/archive/2013/09/18/building-an- angularjs-modal- service.aspx, 并从我的控制器调用它。 然后我有我的部分,像这样: 这个模态被这样调用: 所以我的问题