Tizen应用开发数据控制:特定的应用程序之间的数据交换

流星悟语

本教程演示了如何获取、设置添加和删除地图数据,和插入、选择、更新和删除SQL数据。

热身

熟悉数据控制API通过学习基本知识:

初始化数据控件

初始化数据控件使用。

处理映射类型数据控件

使用映射类型数据控件。

使用sql类型数据控件

使用sql类型数据控件。

初始化数据控件

初始化数据控件:

• 使用功能和数据类型的数据(在控制API mobile和 可穿戴应用程序),包括 < data_control.h > 头文件在您的应用程序:
  1. #include <data_control.h>
     
  2. 
     
  3. #include <sqlite3.h>
     
  4. #include <stdlib.h>
     
  5. #include <glib.h>
     
  6. #include <string.h>

  复制代码
  执行这个应用程序, < sqlite3.h > , < stdlib.h > , < glib.h > , < string.h > 头文件必须包括。
• 数据控制用例运行2应用程序。 每个应用程序中扮演着不同的角色:一个消费者,另一个提供者。
  

• 用户应用程序,添加 http : / /tizen.org/privilege/datasharing 和 http : / /tizen.org/privilege/appManager.launch 应用程序的权限清单文件。
• 对于提供者应用程序,在IDE中,双击 tizen-manifest.xml ,Tizen清单编辑器中去 先进>数据控制>添加 。 添加 读 和 写访问权限都 SQL 和 地图 类型。
  

处理映射类型数据控件

,添加、删除和使用数据控制API映射类型数据集:

• 实现提供者应用程序。
  提供者应用程序商店和消费者应用程序提供数据。 提供者应用程序有4个操作:get、添加、删除和设置。使用映射类型数据控制API,这四个操作必须实现回调。
  1. add_value_request_cb(int request_id, data_control_h provider, const char *key,
     
  2.                      const char *value, void *user_data)
     
  3. {
     
  4.    map_data_s* map_data = (map_data_s*)g_hash_table_lookup(map_repository_test, key);
     
  5. 
     
  6.    if (map_data == NULL)
     
  7.    {
     
  8.       map_data = (map_data_s*)(g_malloc(sizeof(*map_data)));
     
  9.       map_data->arr_size = 0;
     
  10.       map_data->str_arr = (char**) calloc(1, sizeof(char*));
      
  11.       map_data->str_arr[0] = g_strdup(value);
      
  12.       g_hash_table_insert(map_repository_test, g_strdup(key), map_data);
      
  13.    }
      
  14.    else
      
  15.    {
      
  16.       char **new_arr = (char**) calloc(map_data->arr_size+2, sizeof(char*));
      
  17.       for (int i = 0; i < map_data->arr_size; i++)
      
  18.       {
      
  19.          new_arr[i] = g_strdup(map_data->str_arr[i]);
      
  20.       }
      
  21.       free(map_data->str_arr);
      
  22.       new_arr[map_data->arr_size] = g_strdup(value);
      
  23.       map_data->str_arr = g_strdupv(new_arr);
      
  24.       free(new_arr);
      
  25.    }
      
  26.    map_data->arr_size += 1;
      
  27. 
      
  28.    int ret = data_control_provider_send_map_result(request_id);
      
  29.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  30.    {
      
  31.       dlog_print(DLOG_ERROR, LOG_TAG, "send_map_result failed with error: %d", ret);
      
  32.    }
      
  33.    else
      
  34.    {
      
  35.       dlog_print(DLOG_INFO, LOG_TAG, "Add value success request_id: %d %d %s",
      
  36.                  request_id, map_data->arr_size, map_data->str_arr[0]);
      
  37.    }
      
  38. }
      
  39. 
      
  40. void
      
  41. remove_value_request_cb(int request_id, data_control_h provider, const char *key,
      
  42.                         const char *value, void *user_data)
      
  43. {
      
  44.    map_data_s* map_data = (map_data_s*)g_hash_table_lookup(map_repository_test, key);
      
  45. 
      
  46.    if (map_data != NULL)
      
  47.    {
      
  48.       int size = map_data->arr_size;
      
  49.       for (int i = 0; i < size; i++)
      
  50.       {
      
  51.          if (strcmp(map_data->str_arr[i], value) == 0)
      
  52.          {
      
  53.             free(map_data->str_arr[i]);
      
  54.             map_data->arr_size--;
      
  55.          }
      
  56.       }
      
  57.       if (map_data->arr_size == 0)
      
  58.       {
      
  59.          if (!g_hash_table_remove(map_repository_test, key))
      
  60.          {
      
  61.             dlog_print(DLOG_ERROR, LOG_TAG, "remove value failed -%s", key);
      
  62. 
      
  63.             return;
      
  64.          }
      
  65.       }
      
  66.    }
      
  67. 
      
  68.    int ret = data_control_provider_send_map_result(request_id);
      
  69.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  70.    {
      
  71.       dlog_print(DLOG_ERROR, LOG_TAG, "send_map_result failed with error: %d", ret);
      
  72.    }
      
  73.    else
      
  74.    {
      
  75.       dlog_print(DLOG_INFO, LOG_TAG, "Remove value Success");
      
  76.    }
      
  77. }

  复制代码
  
  
• 注册回调中 app_create () 生成的函数(IDE)使用 data_control_provider_map_register_cb () 功能:
  1. void
     
  2. __free_key(gpointer data)
     
  3. {
     
  4.    if (data)
     
  5.    {
     
  6.       g_free(data);
     
  7.       data = NULL;
     
  8.       dlog_print(DLOG_INFO, LOG_TAG, "Remove key");
     
  9.    }
     
  10. }
      
  11. 
      
  12. void
      
  13. __free_data(gpointer data)
      
  14. {
      
  15.    if (data)
      
  16.    {
      
  17.       g_free(data);
      
  18.       data = NULL;
      
  19.       dlog_print(DLOG_INFO, LOG_TAG, "Remove value");
      
  20.    }
      
  21. }
      
  22. 
      
  23. data_control_provider_map_cb map_callback;
      
  24. void
      
  25. initialize_datacontrol_provider()
      
  26. {
      
  27.    map_repository_test = g_hash_table_new_full(g_str_hash, g_str_equal, __free_key, __free_data);
      
  28. 
      
  29.    map_callback.get_cb = get_value_request_cb;
      
  30.    map_callback.add_cb = add_value_request_cb;
      
  31.    map_callback.remove_cb = remove_value_request_cb;
      
  32.    map_callback.set_cb = set_value_request_cb;
      
  33. 
      
  34.    int result = data_control_provider_map_register_cb(&map_callback);
      
  35.    if (result != DATA_CONTROL_ERROR_NONE)
      
  36.    {
      
  37.       dlog_print(DLOG_ERROR, LOG_TAG, "data_control_provider_map_register_cb failed with error: %d", result);
      
  38.    }
      
  39.    else
      
  40.    {
      
  41.       dlog_print(DLOG_INFO, LOG_TAG, "Provider map register success");
      
  42.    }
      
  43. }       
      
  44. 
      
  45. static bool
      
  46. app_create(void *data)
      
  47. {
      
  48.    // Take necessary actions before main event loop starts
      
  49.    // Initialize UI resources and application data
      
  50.    // If this function returns true, the main loop of application starts
      
  51.    // If this function returns false, the application is terminated
      
  52.    appdata_s *ad = data;
      
  53. 
      
  54.    create_base_gui(ad);
      
  55.    initialize_datacontrol_provider()
      
  56. 
      
  57.    return true;
      
  58. }

  复制代码
  
  
• 实现 用户应用程序。
  用户应用程序请求得到设置,添加和删除功能提供者应用程序和接收提供者应用程序的结果。
  实现回调函数的响应。 回调函数接收请求的响应结果与数据提供者。
  1. // Callback functions
     
  2. void
     
  3. map_get_response_cb(int request_id, data_control_h provider,
     
  4.                     char **ret_value_list, int ret_value_count, bool provider_ret,
     
  5.                     const char *error, void *user_data)
     
  6. {
     
  7.    if (provider_ret)
     
  8.    {
     
  9. 
     
  10.       dlog_print(DLOG_INFO, LOG_TAG, "The get operation is successful. Value count: %d ", ret_value_count);
      
  11.       for (int i = 0; i < ret_value_count; i++)
      
  12.          dlog_print(DLOG_INFO, LOG_TAG, "(%d) Return value: %s ", i, ret_value_list[i]);
      
  13. 
      
  14.    }
      
  15.    else
      
  16.    {
      
  17.       dlog_print(DLOG_ERROR, LOG_TAG, "The get operation for the request %d failed. error message: %s",
      
  18.                  request_id, error);
      
  19.    }
      
  20. }
      
  21. 
      
  22. void
      
  23. map_set_response_cb(int request_id, data_control_h provider, bool provider_ret,
      
  24.                     const char *error, void *user_data)
      
  25. {
      
  26.    if (provider_ret)
      
  27.    {
      
  28.       dlog_print(DLOG_INFO, LOG_TAG, "The set operation is successful");
      
  29.    }
      
  30.    else
      
  31.    {
      
  32.       dlog_print(DLOG_ERROR, LOG_TAG, "The set operation for the request %d failed. error message: %s",
      
  33.                  request_id, error);
      
  34.    }
      
  35. }
      
  36. 
      
  37. void
      
  38. map_add_response_cb(int request_id, data_control_h provider, bool provider_ret,
      
  39.                     const char *error, void *user_data)
      
  40. {
      
  41.    if (provider_ret)
      
  42.    {
      
  43.       dlog_print(DLOG_INFO, LOG_TAG, "The add operation is successful");
      
  44.    }
      
  45.    else
      
  46.    {
      
  47.       dlog_print(DLOG_ERROR, LOG_TAG, "The add operation for the request %d failed. error message: %s",
      
  48.                  request_id, error);
      
  49.    }
      
  50. }
      
  51. 
      
  52. void
      
  53. map_remove_response_cb(int request_id, data_control_h provider, bool provider_ret,
      
  54.                        const char *error, void *user_data)
      
  55. {
      
  56.    if (provider_ret)
      
  57.    {
      
  58.       dlog_print(DLOG_INFO, LOG_TAG, "The remove operation is successful");
      
  59.    }
      
  60.    else
      
  61.    {
      
  62.       dlog_print(DLOG_ERROR, LOG_TAG, "The remove operation for the request %d failed. error message: %s",
      
  63.                  request_id, error);
      
  64.    }
      
  65. }

  复制代码
  
  
• 确定供应商和数据,初始化数据控制处理程序。 必须在执行的初始化过程 app_create () 函数生成的IDE。
  1. data_control_map_response_cb map_callback;
     
  2. void
     
  3. initialize_datacontrol_consumer(appdata_s *ad)
     
  4. {
     
  5.    const char *provider_id = Your Provider ID;
     
  6.    const char *data_id = "table";
     
  7.    int ret;
     
  8. 
     
  9.    // Create data control handler
     
  10.    ret = data_control_map_create(&(ad->provider_h));
      
  11.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  12.    {
      
  13.       dlog_print(DLOG_ERROR, LOG_TAG, "creating data control provider failed with error: %d", ret);
      
  14.    }
      
  15.    ret = data_control_map_set_provider_id(ad->provider_h, provider_id);
      
  16.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  17.    {
      
  18.       dlog_print(DLOG_ERROR, LOG_TAG, "setting provider id failed with error: %d", ret);
      
  19.    }
      
  20.    ret = data_control_map_set_data_id(ad->provider_h, data_id);
      
  21.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  22.    {
      
  23.       dlog_print(DLOG_ERROR, LOG_TAG, "setting data id failed with error: %d", ret);
      
  24.    }
      
  25. 
      
  26.    // Set response callback
      
  27.    map_callback.get_cb = map_get_response_cb;
      
  28.    map_callback.set_cb = map_set_response_cb;
      
  29.    map_callback.add_cb = map_add_response_cb;
      
  30.    map_callback.remove_cb = map_remove_response_cb;
      
  31. 
      
  32.    // Register response callback
      
  33.    ret = data_control_map_register_response_cb(ad->provider_h, &map_callback, NULL);
      
  34.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  35.    {
      
  36.       dlog_print(DLOG_ERROR, LOG_TAG, "Registering the callback function failed with error: %d", ret);
      
  37. 
      
  38.       if (ret == DATA_CONTROL_ERROR_IO_ERROR)
      
  39.       {
      
  40.          dlog_print(DLOG_ERROR, LOG_TAG, "I/O error");
      
  41.       }
      
  42.       else
      
  43.       {
      
  44.          dlog_print(DLOG_ERROR, LOG_TAG, "Out of memory");
      
  45.       }
      
  46.    }
      
  47. 
      
  48.    int req_id = 0;
      
  49. 
      
  50.    // Add value
      
  51.    const char *key = "key";
      
  52.    const char *value = "value";
      
  53.    data_control_map_add(provider_map, key, value, &req_id);
      
  54. 
      
  55.    // Get value
      
  56.    data_control_map_get(provider_map, key, &req_id);
      
  57. 
      
  58.    // Set value
      
  59.    const char *old_value = "old value";
      
  60.    const char *new_value = "new value";
      
  61.    data_control_map_set(provider_map, key, old_value, new_value, &req_id);
      
  62.    
      
  63.    // Remove value
      
  64.    data_control_map_remove(provider_map, key, value, &req_id);
      
  65. }
      
  66. 
      
  67. static bool
      
  68. app_create(void *data)
      
  69. {
      
  70.    // Take necessary actions before main event loop starts
      
  71.    // Initialize UI resources and application data
      
  72.    // If this function returns true, the main loop of application starts
      
  73.    // If this function returns false, the application is terminated
      
  74.    appdata_s *ad = data;
      
  75. 
      
  76.    create_base_gui(ad);
      
  77.    initialize_datacontrol_consumer(ad);
      
  78. 
      
  79.    return true;
      
  80. }

  复制代码
  
  

使用sql类型数据控件

选择插入,更新和删除sql类型数据使用数据控制API:

• 实现提供者应用程序。
  提供者应用程序商店和消费者应用程序提供数据。 提供者应用程序有4个操作:插入、选择、更新和删除。 使用sql类型数据控制API,这些操作必须实现回调。
  Z2z">

  1. data_control_provider_sql_cb *sql_callback;
     
  2. static sqlite3* db;
     
  3. void
     
  4. insert_request_cb(int request_id, data_control_h provider, bundle *insert_data, void *user_data)
     
  5. {
     
  6.    char* command = data_control_provider_create_insert_statement(provider, insert_data);
     
  7.    int ret = sqlite3_exec(db, command, NULL, NULL, NULL);
     
  8. 
     
  9.    if (ret != SQLITE_OK)
     
  10.    {
      
  11.       data_control_provider_send_error(request_id, sqlite3_errmsg(db));
      
  12.       free(command);
      
  13. 
      
  14.       return;
      
  15.    }
      
  16.    dlog_print(DLOG_INFO, LOG_TAG, "[insert_request_cb] insert success");
      
  17. 
      
  18.    long long inserted_row_id = sqlite3_last_insert_rowid(db);
      
  19.    ret = data_control_provider_send_insert_result(request_id, inserted_row_id);
      
  20.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  21.    {
      
  22.       dlog_print(DLOG_ERROR, LOG_TAG, "insert_send_result failed with error: %d", ret);
      
  23.    }
      
  24.    dlog_print(DLOG_INFO, LOG_TAG, "[insert_request_cb] send result success");
      
  25. 
      
  26.    free(command);
      
  27. }
      
  28. 
      
  29. void
      
  30. delete_request_cb(int request_id, data_control_h provider, const char *where, void *user_data)
      
  31. {
      
  32.    dlog_print(DLOG_INFO, LOG_TAG, "[delete_request_cb] request_id(%d)", request_id);
      
  33.    char* command = data_control_provider_create_delete_statement(provider, where);
      
  34.    int ret = sqlite3_exec(db, command, NULL, NULL, NULL);
      
  35.    if (ret != SQLITE_OK)
      
  36.    {
      
  37.       data_control_provider_send_error(request_id, sqlite3_errmsg(db));
      
  38.       free(command);
      
  39. 
      
  40.       return;
      
  41.    }       
      
  42. 
      
  43.    ret = data_control_provider_send_delete_result(request_id);
      
  44.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  45.    {
      
  46.       dlog_print(DLOG_ERROR, LOG_TAG, "delete_send_result failed with error: %d", ret);
      
  47.    }
      
  48.    dlog_print(DLOG_INFO, LOG_TAG, "[delete_request_cb] delete success");
      
  49. 
      
  50.    free(command);
      
  51. }
      
  52. 
      
  53. void
      
  54. select_request_cb(int request_id, data_control_h provider, const char **column_list,
      
  55.                   int column_count, const char *where, const char *order, void *user_data)
      
  56. {
      
  57.    sqlite3_stmt* sql_stmt = NULL;
      
  58. 
      
  59.    char* command = data_control_provider_create_select_statement(provider, column_list,
      
  60.                                                                  column_count, where, order);
      
  61.    int ret = sqlite3_prepare_v2(db, command, strlen(command), &sql_stmt, NULL);
      
  62.    if (ret != SQLITE_OK)
      
  63.    {
      
  64.       data_control_provider_send_error(request_id, sqlite3_errmsg(db));
      
  65.       free(command);
      
  66. 
      
  67.       return;
      
  68.    }       
      
  69. 
      
  70.    ret = data_control_provider_send_select_result(request_id, (void *)sql_stmt);
      
  71.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  72.    {
      
  73.       dlog_print(DLOG_ERROR, LOG_TAG, "select_send_result failed with error: %d", ret);
      
  74.    }
      
  75.    dlog_print(DLOG_INFO, LOG_TAG, "[select_request_cb] send result success");
      
  76. 
      
  77.    sqlite3_finalize(sql_stmt);
      
  78.    free(command);
      
  79. }
      
  80. 
      
  81. void
      
  82. update_request_cb(int request_id, data_control_h provider, bundle *update_data,
      
  83.                   const char *where, void *user_data)
      
  84. {
      
  85.    char* command = data_control_provider_create_update_statement(provider, update_data, where);
      
  86.    int ret = sqlite3_exec(db, command, NULL, NULL, NULL);
      
  87.    if (ret != SQLITE_OK)
      
  88.    {
      
  89.       data_control_provider_send_error(request_id, sqlite3_errmsg(db));
      
  90.       free(command);
      
  91. 
      
  92.       return;
      
  93.    }
      
  94. 
      
  95.    ret = data_control_provider_send_update_result(request_id);
      
  96.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  97.    {
      
  98.       dlog_print(DLOG_ERROR, LOG_TAG, "update_send_result failed with error: %d", ret);
      
  99.    }
      
  100.    dlog_print(DLOG_INFO, LOG_TAG, "[update_request_cb] send result success");
       
  101. 
       
  102.    free(command);
       
  103. }

  复制代码
  
  
• 注册回调函数和创建数据库:
  1. int
     
  2. create_database()
     
  3. {
     
  4.    dlog_print(DLOG_INFO, LOG_TAG, "%s%s", app_get_data_path(), "test.db");
     
  5. 
     
  6.    int open_flags = (SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE);
     
  7. 
     
  8.    int ret = sqlite3_open_v2(Your DB Path, &db, open_flags, NULL);
     
  9.    if (ret != SQLITE_OK)
     
  10.    {
      
  11.       dlog_print(DLOG_ERROR, LOG_TAG, "database creation failed with error: %d", ret);
      
  12. 
      
  13.       return ret;
      
  14.    }
      
  15. 
      
  16.    char* sql_command = "CREATE TABLE IF NOT EXISTS Dictionary (WORD VARCHAR(30), WORD_DESC TEXT, WORD_NUM INT, Point INT)";
      
  17.    ret = sqlite3_exec(db, sql_command, NULL, NULL, NULL);
      
  18.    if (ret != SQLITE_OK)
      
  19.    {
      
  20.       dlog_print(DLOG_ERROR, LOG_TAG, "database table creation failed with error: %d", ret);
      
  21.    }
      
  22.    dlog_print(DLOG_INFO, LOG_TAG, "DB init Success.");
      
  23. 
      
  24.    return ret;
      
  25. }
      
  26. 
      
  27. void
      
  28. initialize_datacontrol_provider()
      
  29. {
      
  30.    dlog_print(DLOG_INFO, LOG_TAG, "initialize_datacontrol_provider");
      
  31. 
      
  32.    int result = create_database();
      
  33.    if (result != SQLITE_OK)
      
  34.       return;
      
  35. 
      
  36.    sql_callback = (data_control_provider_sql_cb *) malloc(sizeof(data_control_provider_sql_cb));
      
  37.    sql_callback->select_cb = select_request_cb;
      
  38.    sql_callback->insert_cb = insert_request_cb;
      
  39.    sql_callback->delete_cb = delete_request_cb;
      
  40.    sql_callback->update_cb = update_request_cb;
      
  41.    result = data_control_provider_sql_register_cb(sql_callback, NULL);
      
  42.    if (result != DATA_CONTROL_ERROR_NONE)
      
  43.    {
      
  44.       dlog_print(DLOG_ERROR, "data_control_sql_response_c failed with error: %d", result);
      
  45.    }
      
  46.    else
      
  47.    {
      
  48.       dlog_print(DLOG_INFO, LOG_TAG, "Provider SQL register success");
      
  49.    }
      
  50. }               

  复制代码
  
  
• 实现 用户应用程序。
  用户应用程序请求插入、选择、更新和删除功能提供者应用程序提供者应用程序并接收结果。
  实现回调函数的响应。 回调函数接收请求的响应结果与数据提供者。
  1. void
     
  2. sql_delete_response_cb(int request_id, data_control_h provider, bool provider_result,
     
  3.                        const char *error, void *user_data)
     
  4. {
     
  5.    if (provider_result)
     
  6.    {
     
  7.       dlog_print(DLOG_INFO, LOG_TAG, "The delete operation is successful");
     
  8.    }
     
  9.    else
     
  10.    {
      
  11.       dlog_print(DLOG_ERROR, LOG_TAG, "The delete operation for the request %d failed. error message: %s",
      
  12.                  request_id, error);
      
  13.    }
      
  14. }
      
  15. 
      
  16. void
      
  17. sql_insert_response_cb(int request_id, data_control_h provider, long long inserted_row_id,
      
  18.                        bool provider_result, const char *error, void *user_data)
      
  19. {
      
  20.    if (provider_result)
      
  21.    {
      
  22.       dlog_print(DLOG_INFO, LOG_TAG, "The insert operation is successful");
      
  23.    }
      
  24.    else
      
  25.    {
      
  26.       dlog_print(DLOG_ERROR, LOG_TAG, "The insert operation for the request %d failed. error message: %s",
      
  27.                  request_id, error);
      
  28.    }
      
  29. }
      
  30. 
      
  31. void
      
  32. sql_select_response_cb(int request_id, data_control_h provider, result_set_cursor cursor,
      
  33.                        bool provider_result, const char *error, void *user_data)
      
  34. {
      
  35.    if (provider_result)
      
  36.    {
      
  37.       dlog_print(DLOG_INFO, LOG_TAG, "The select operation is successful");
      
  38.    }
      
  39.    else
      
  40.    {
      
  41.       dlog_print(DLOG_ERROR, LOG_TAG, "The select operation for the request %d failed. error message: %s",
      
  42.                  request_id, error);
      
  43.    }
      
  44. 
      
  45.    while (data_control_sql_step_next(cursor) == DATA_CONTROL_ERROR_NONE)
      
  46.    {
      
  47. 
      
  48.       char word[32] = {0,};
      
  49.       char word_desc[32] = {0,};
      
  50.       long long word_number = -1;
      
  51. 
      
  52.       data_control_sql_get_text_data(cursor, 0, word);
      
  53.       data_control_sql_get_text_data(cursor, 1, word_desc);
      
  54.       data_control_sql_get_int64_data(cursor, 2, &word_number);
      
  55. 
      
  56.       dlog_print(DLOG_INFO, LOG_TAG, "Word: %s, Word DESC: %s, Word NUM: %ld ",
      
  57.                  word, word_desc, word_number);
      
  58.    }
      
  59. }
      
  60. 
      
  61. void
      
  62. sql_update_response_cb(int request_id, data_control_h provider, bool provider_result,
      
  63.                        const char *error, void *user_data)
      
  64. {
      
  65.    if (provider_result)
      
  66.    {
      
  67.       dlog_print(DLOG_INFO, LOG_TAG, "The update operation is successful");
      
  68.    }
      
  69.    else
      
  70.    {
      
  71.       dlog_print(DLOG_ERROR, LOG_TAG, "The update operation for the request %d failed. error message: %s",
      
  72.                  request_id, error);
      
  73.    }
      
  74. }

  复制代码
  
  
• 确定供应商和数据,初始化数据控制处理程序。 必须在执行的初始化过程 app_create () 函数生成的IDE。
  1. data_control_sql_response_cb sql_callback;
     
  2. void
     
  3. initialize_datacontrol_consumer(appdata_s *ad)
     
  4. {
     
  5.    int ret;
     
  6. 
     
  7.    const char *provider_id = Your Provider ID;
     
  8.    const char *data_id = "Dictionary";
     
  9. 
     
  10.    ret = data_control_sql_create(&(ad->provider_h));
      
  11.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  12.    {
      
  13.       dlog_print(DLOG_ERROR, LOG_TAG, "creating data control provider failed with error: %d", ret);
      
  14.    }
      
  15. 
      
  16.    ret = data_control_sql_set_provider_id(ad->provider_h, provider_id);
      
  17.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  18.    {
      
  19.       dlog_print(DLOG_ERROR, LOG_TAG, "setting provider id failed with error: %d", ret);
      
  20.    }
      
  21. 
      
  22.    ret = data_control_sql_set_data_id(ad->provider_h, data_id);
      
  23.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  24.    {
      
  25.       dlog_print(DLOG_ERROR, LOG_TAG, "setting data id failed with error: %d", ret);
      
  26.    }
      
  27. 
      
  28.    sql_callback.delete_cb = sql_delete_response_cb;
      
  29.    sql_callback.insert_cb = sql_insert_response_cb;
      
  30.    sql_callback.select_cb = sql_select_response_cb;
      
  31.    sql_callback.update_cb = sql_update_response_cb;
      
  32. 
      
  33.    ret = data_control_sql_register_response_cb(ad->provider_h, &sql_callback, NULL);
      
  34.    if (ret != DATA_CONTROL_ERROR_NONE)
      
  35.    {
      
  36.       dlog_print(DLOG_ERROR, LOG_TAG, "Registering the callback function failed with error: %d", ret);
      
  37.    }
      
  38. 
      
  39.    dlog_print(DLOG_INFO, LOG_TAG, "Init data control success");
      
  40. 
      
  41.    int req_id = 0;
      
  42.    
      
  43.    // Insert row
      
  44.    bundle *b = bundle_create();
      
  45.    bundle_add_str(b, "WORD", "'test'");
      
  46.    bundle_add_str(b, "WORD_DESC", "'test desc'");
      
  47. 
      
  48.    data_control_sql_insert(provider_sql, b, &req_id);
      
  49. 
      
  50.    // Select row
      
  51.    char *column_list[2];
      
  52.    column_list[0] = "WORD";
      
  53.    column_list[1] = "WORD_DESC";
      
  54.    
      
  55.    const char *where = "WORD = 'test'";
      
  56.    const char *order = "WORD ASC";
      
  57. 
      
  58.    data_control_sql_select(provider_sql, column_list, 2, where, order, &req_id);
      
  59. 
      
  60.    // Add row
      
  61.    bundle_add_str(b, "WORD", "'test_new'");
      
  62.    data_control_sql_update(provider_sql, b, where, &req_id);
      
  63. 
      
  64.    // Delete row
      
  65.    const char *where_delete = "WORD = 'test'";
      
  66.    result = data_control_sql_delete(provider_sql, where_delete, &req_id);
      
  67. 
      
  68.    // Free memory
      
  69.    bundle_free(b);
      
  70. }
      
  71. 
      
  72. static bool
      
  73. app_create(void *data)
      
  74. {
      
  75.    // Take necessary actions before main event loop starts
      
  76.    // Initialize UI resources and application data
      
  77.    // If this function returns true, the main loop of application starts
      
  78.    // If this function returns false, the application is terminated
      
  79.    appdata_s *ad = data;
      
  80. 
      
  81.    create_base_gui(ad);
      
  82.    initialize_datacontrol_consumer(ad);
      
  83. 
      
  84.    return true;
      
  85. }

  复制代码