return MS_MEDIA_ERR_NONE;
}
-int _media_svc_sql_begin_trans(uid_t uid)
-{
- int ret = MS_MEDIA_ERR_NONE;
-
- media_svc_debug("Batch start(Transaction block version)");
-
- ret = media_db_request_update_db_batch_start("BEGIN IMMEDIATE;", uid);
-
- return ret;
-}
-
-int _media_svc_sql_end_trans(uid_t uid)
-{
- int ret = MS_MEDIA_ERR_NONE;
-
- media_svc_debug("Batch end(Transaction block version)");
-
- ret = media_db_request_update_db_batch_end("COMMIT;", uid);
-
- return ret;
-}
-
int _media_svc_sql_query_list(GList **query_list, uid_t uid)
{
int ret = MS_MEDIA_ERR_NONE;
}
if ((total_len + query_len) >= (sizeof(query_bundle) - 1)) {
- ret = media_db_request_update_db_batch(query_bundle, uid);
+ ret = media_db_request_update_db(query_bundle, uid);
if (ret != MS_MEDIA_ERR_NONE)
- media_svc_error("media_db_request_update_db_batch failed : %d", ret);
+ media_svc_error("media_db_request_update_db failed : %d", ret);
memset(query_bundle, 0, sizeof(query_bundle));
total_len = 0;
}
if (total_len > 0) {
- ret = media_db_request_update_db_batch(query_bundle, uid);
+ ret = media_db_request_update_db(query_bundle, uid);
if (ret != MS_MEDIA_ERR_NONE)
- media_svc_error("media_db_request_update_db_batch failed : %d", ret);
+ media_svc_error("media_db_request_update_db failed : %d", ret);
memset(query_bundle, 0, sizeof(query_bundle));
total_len = 0;
int _media_svc_list_query_do(media_svc_query_type_e query_type, uid_t uid)
{
int ret = MS_MEDIA_ERR_NONE;
- char *sql = NULL;
/* For multiples of 200, empty requests are possible */
switch (query_type) {
if (g_media_svc_update_list == NULL || g_list_length(g_media_svc_update_list) == 0)
return MS_MEDIA_ERR_NONE;
- if (g_list_length(g_media_svc_update_list) == 1) {
- sql = (char *)g_list_nth_data(g_media_svc_update_list, 0);
- if (STRING_VALID(sql)) {
- ret = _media_svc_sql_query(sql, uid);
- SQLITE3_SAFE_FREE(sql);
- }
- _media_svc_sql_query_release(&g_media_svc_update_list);
-
- return ret;
- }
-
- ret = _media_svc_sql_begin_trans(uid);
- media_svc_retv_if(ret != MS_MEDIA_ERR_NONE, ret);
-
ret = _media_svc_sql_query_list(&g_media_svc_update_list, uid);
- media_svc_retvm_if(ret != MS_MEDIA_ERR_NONE, ret, "Failed to request queries");
-
- ret = _media_svc_sql_end_trans(uid);
break;
case MEDIA_SVC_QUERY_SET_ITEM_VALIDITY:
ret = _media_svc_sql_query_list_direct(&g_media_svc_item_validity_query_list, uid);
int _media_svc_get_user_version(sqlite3 *db_handle, int *user_version);
int _media_svc_sql_prepare_to_step(sqlite3 *handle, const char *sql_str, sqlite3_stmt **stmt);
int _media_svc_sql_prepare_to_step_simple(sqlite3 *handle, const char *sql_str, sqlite3_stmt **stmt);
-int _media_svc_sql_begin_trans(uid_t uid);
-int _media_svc_sql_end_trans(uid_t uid);
int _media_svc_sql_query_list(GList **query_list, uid_t uid);
int _media_svc_sql_query_list_direct(GList **query_list, uid_t uid);
void _media_svc_sql_query_add(GList **query_list, char **query);