2012-01-28 45 views
2

我試圖通過其REST API使用Java爲特定用戶的Meetings模塊中的條目查詢Sugar,即當前登錄的用戶。當查詢某個特定用戶的會議時,Sugar get_entry_list返回「無效會話ID」

我正在嘗試這幾天已經搜索asolution搜索。

我做了一個登錄()調用,我得到了一個會話ID,比我打電話給get_user_id()。使用返回的用戶標識,我嘗試使用get_entry_list()來查詢Meetings模塊。

要獲得分配給它的工作原理與下面的查詢字符串,其中mUserId持有get_user_id的)返回的用戶ID(用戶ID的會議:

queryString = "meetings.assigned_user_id='"+mUserId+"'"; 

但我不僅想要得到的會議,其中一個用戶被分配到,但他參加的所有會議。爲此,我在查詢中試試了會議用戶表上的子查詢。

這是我嘗試過的查詢字符串,這些操作系統在MySQL提示符下工作。但是當我在REST上試用時,它會返回「無效會話ID」:

queryString = "meetings.id IN (SELECT meetings_users.meeting_id FROM meetings_users WHERE meetings_users.user_id = '"+mUserId+"')"; 

有沒有人對此有暗示?哪些條件導致「無效的會話ID」呢?

什麼也不起作用,例如正在追加「和刪除='0'」到第一個規定的查詢:

queryString = "meetings.assigned_user_id='"+mUserId+"' and deleted = '0'"; 

也失敗。

如這裏要求是完整的代碼示例,平臺是Android的,API等級8:

private JSONArray getEntryList(String moduleName, 
     String selectFields[], String queryString, String orderBy, int max_results) throws JSONException, IOException, KeyManagementException, NoSuchAlgorithmException 
{ 
    JSONArray jsoSub = new JSONArray(); 
    if (selectFields.length > 0) 
    { 
     for (int i = 0; i < selectFields.length; i++) 
     { 
      jsoSub.put(selectFields[i]); 
     } 
    } 

      // get_entry_list expects parameters to be ordered, JSONObject does 
      // not provide this, so I built my JSON String on my own 
    String sessionIDPrefix = "{\"session\":\""+ mSessionId+ "\"," + 
      "\"modulename\":\""+ moduleName+ "\"," + 
      "\"query\":\""+ queryString + "\"," + 
      "\"order_by\":\""+ orderBy + "\"," + 
      "\"offset\":\""+ mNextOffset+ "\"," + 
      "\"select_fields\":["+ jsoSub.toString().substring(
        1, jsoSub.toString().length()-2)+ "\"],"+ 
      "\"max_results\":\""+ 20 + "\"}"; 

    String restData = sessionIDPrefix; 
    Log.d(TAG, restData); 

    String data = null; 
    String baseurl = mUrl + REST_URI_APPEND; 

    data = httpPost(baseurl+"?method=get_entry_list&input_type=json&response_type=json&rest_data="+restData); 

    Log.d(TAG, data); 
    JSONObject jsondata = new JSONObject(data); 

    mResultCount = jsondata.getInt("result_count"); 
    mNextOffset = jsondata.getInt("next_offset"); 

    return jsondata.getJSONArray("entry_list"); 
} 

private String httpPost(String urlStr) throws IOException{ 
    String urlSplitted [] = urlStr.split("/", 4); 
    String hostPort[] = urlSplitted[2].split(":"); 
    String hostname = hostPort[0]; 
    int port = 80; 
    if (hostPort.length > 1) 
     port = new Integer(hostPort[1]); 

    String file = "/"+urlSplitted[3]; 

    Log.d(TAG, hostname + ", " + port + ", " +file); 

    URL url = null; 
    try { 
     url = new URL("http", hostname, port, file); 
    } catch (MalformedURLException e) { 
     throw new IOException(mContext.getText(R.string.error_malformed_url).toString()); 
    } 

    Log.d(TAG, "URL "+url.toString()); 
    HttpURLConnection conn = null; 
    try { 
     conn = (HttpURLConnection) url.openConnection(); 
    } catch (IOException e) { 
     throw new IOException(mContext.getText(R.string.error_conn_creat).toString()); 
    } 
    conn.setConnectTimeout(60 * 1000); 
    conn.setReadTimeout(60 * 1000); 
    try { 
     conn.setRequestMethod("POST"); 
    } catch (ProtocolException e) { 
     throw new IOException(mContext.getText(R.string.error_post).toString()); 
    } 
    conn.setDoOutput(true); 
    conn.setDoInput(true); 
    conn.setUseCaches(false); 
    conn.setAllowUserInteraction(false); 
    conn.setRequestProperty("Content-Type", 
    "application/x-www-form-urlencoded"); 

    try { 
     conn.connect(); 
    } catch (IOException e) { 
     throw new IOException(mContext.getText(R.string.error_conn_open).toString() 
       + "\n" + e.getMessage()); 
    } 

    int response = 0; 
    String responseMessage = null; 
    try { 
     response = conn.getResponseCode(); 
     responseMessage = conn.getResponseMessage(); 
    } catch (IOException e) { 
     conn.disconnect(); 
     throw new IOException(mContext.getText(R.string.error_resp_io).toString()); 
    } 
    Log.d(TAG, "Exception Response "+ response); 
    if (response != 200) { 
     conn.disconnect(); 
     throw new IOException(mContext.getText(R.string.error_http).toString() 
       + "\n" + response + " " + responseMessage); 
    } 

    StringBuilder sb = null; 
    try { 
     BufferedReader rd = new BufferedReader(
     new InputStreamReader(conn.getInputStream())); 
     sb = new StringBuilder(); 
     String line; 
     while ((line = rd.readLine()) != null) { 
      Log.d(TAG,"line " + line); 
      sb.append(line); 
     } 
     rd.close(); 
    } catch (IOException e) { 
     conn.disconnect(); 
     throw new IOException(mContext.getText(R.string.error_resp_read).toString()); 
    } 

    conn.disconnect(); 

    if (sb.toString() == null) 
    { 
     throw new IOException(mContext.getText(R.string.error_resp_empty).toString()); 
    } 

    return sb.toString(); 
} 

調用上面的代碼:

 if (login() != OK) 
    return null; 

    mResultCount = -1; 
    mNextOffset = 0; 

    mUserId = getUserId(); 

    String fields[] = new String [] { 
     "id", 
     "name", 
     "description", 
     "location", 
     "date_start", 
     "date_end", 
     "status", 
     "type", 
     "reminder_time", 
     "parent_type", 
     "parent_id", 
     "deleted", 
     "date_modified" 
    }; 

    String queryString = null; 
    if (syncAllUsers) 
     queryString = ""; 
    else 
    { 
     queryString = "meetings.assigned_user_id = 'seed_sarah_id' and meetings.deleted = '0'"; 
     //queryString = "meetings.id IN (SELECT meeting_id FROM meetings_users WHERE user_id ='"+mUserId+"'"; 
    } 

    entryList.clear(); 

    while (mResultCount != 0) 
    { 
     if (!seamless_login()) 
      return null; 

     JSONArray serverEntryList = getEntryList( 
       "Meetings", fields, queryString, "date_start", 0); 

     //... do sth with data 
     } 
     totalContactsResults += mResultCount; 
    } 
    logout(); 

登錄()返回有效的會話ID,並getUserId ()返回正確的ID。整個代碼已經可以用於獲取聯繫人,並且還可以用於上面所述的簡單查詢。

在此先感謝

馬克

回答

1

經過進一步測試,我意識到,查詢字符串中的空格是問題。它們導致包含空白的URL。爲了避免某種URL編碼必須完成。

我沒有成功編碼整個URL在我的httpPost方法(似乎沒有必要)。但在查詢字符串「+」替代空間爲我工作:

queryString = "meetings.id+IN+(SELECT+meetings_users.meeting_id+FROM meetings_users+WHERE+meetings_users.user_id='"+mUserId+"')"; 

如果任何人有這樣做的更優雅的方法,請讓我知道。

1

你可能會更好使用get_relationships Web服務調用。

SugarRest.call('get_relationships', [SugarRest.session, 'Users', SugarRest.user_id, 'meetings', '', ['name'], 0, '']) 

這應該是你所需要的。在「會議」之後的參數中,您還可以傳入額外的過濾器。