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

流星悟语 · 发表于 2016-5-7 23:51:20

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

热身

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

初始化数据控件

初始化数据控件使用。

处理映射类型数据控件

使用映射类型数据控件。

使用sql类型数据控件

使用sql类型数据控件。

初始化数据控件

初始化数据控件:

使用功能和数据类型的数据(在控制API mobile和可穿戴应用程序),包括 < data_control.h > 头文件在您的应用程序:
1. #include <data_control.h>
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);
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;
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. }
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);
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);
63. return;
64. }
65. }
66. }
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. }
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. }
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);
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;
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. }
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;
54. create_base_gui(ad);
55. initialize_datacontrol_provider()
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. {
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]);
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. }
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. }
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. }
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;
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. }
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;
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);
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. }
48. int req_id = 0;
50. // Add value
51. const char *key = "key";
52. const char *value = "value";
53. data_control_map_add(provider_map, key, value, &req_id);
55. // Get value
56. data_control_map_get(provider_map, key, &req_id);
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);
63. // Remove value
64. data_control_map_remove(provider_map, key, value, &req_id);
65. }
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;
76. create_base_gui(ad);
77. initialize_datacontrol_consumer(ad);
79. return true;
80. }
复制代码

使用sql类型数据控件

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

实现提供者应用程序。
提供者应用程序商店和消费者应用程序提供数据。提供者应用程序有4个操作:插入、选择、更新和删除。使用sql类型数据控制API,这些操作必须实现回调。
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);
9. if (ret != SQLITE_OK)
10. {
11. data_control_provider_send_error(request_id, sqlite3_errmsg(db));
12. free(command);
14. return;
15. }
16. dlog_print(DLOG_INFO, LOG_TAG, "[insert_request_cb] insert success");
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");
26. free(command);
27. }
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);
40. return;
41. }
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");
50. free(command);
51. }
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;
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);
67. return;
68. }
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");
77. sqlite3_finalize(sql_stmt);
78. free(command);
79. }
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);
92. return;
93. }
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");
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");
6. int open_flags = (SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE);
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);
13. return ret;
14. }
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.");
24. return ret;
25. }
27. void
28. initialize_datacontrol_provider()
29. {
30. dlog_print(DLOG_INFO, LOG_TAG, "initialize_datacontrol_provider");
32. int result = create_database();
33. if (result != SQLITE_OK)
34. return;
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. }
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. }
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. }
45. while (data_control_sql_step_next(cursor) == DATA_CONTROL_ERROR_NONE)
46. {
48. char word[32] = {0,};
49. char word_desc[32] = {0,};
50. long long word_number = -1;
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);
56. dlog_print(DLOG_INFO, LOG_TAG, "Word: %s, Word DESC: %s, Word NUM: %ld ",
57. word, word_desc, word_number);
58. }
59. }
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;
7. const char *provider_id = Your Provider ID;
8. const char *data_id = "Dictionary";
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. }
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. }
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. }
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;
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. }
39. dlog_print(DLOG_INFO, LOG_TAG, "Init data control success");
41. int req_id = 0;
43. // Insert row
44. bundle *b = bundle_create();
45. bundle_add_str(b, "WORD", "'test'");
46. bundle_add_str(b, "WORD_DESC", "'test desc'");
48. data_control_sql_insert(provider_sql, b, &req_id);
50. // Select row
51. char *column_list[2];
52. column_list[0] = "WORD";
53. column_list[1] = "WORD_DESC";
55. const char *where = "WORD = 'test'";
56. const char *order = "WORD ASC";
58. data_control_sql_select(provider_sql, column_list, 2, where, order, &req_id);
60. // Add row
61. bundle_add_str(b, "WORD", "'test_new'");
62. data_control_sql_update(provider_sql, b, where, &req_id);
64. // Delete row
65. const char *where_delete = "WORD = 'test'";
66. result = data_control_sql_delete(provider_sql, where_delete, &req_id);
68. // Free memory
69. bundle_free(b);
70. }
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;
81. create_base_gui(ad);
82. initialize_datacontrol_consumer(ad);
84. return true;
85. }
复制代码

		自动登录	找回密码
密码			立即注册

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

相关帖子