bundle_add_str(arg_list, AUL_K_NO_CANCEL, "1");
LOGI("caller_id %s, callee_id %s", caller_id, callee_id);
- // For DataControl CAPI
+ /* For DataControl CAPI */
bundle_add_str(arg_list, AUL_K_DATA_CONTROL_TYPE, "CORE");
do {
} map_response_cb_s;
static void *datacontrol_map_tree_root = NULL;
-static const int MAX_ARGUMENT_SIZE = 16384; // 16KB
+static const int MAX_ARGUMENT_SIZE = 16384; /* 16KB */
static GHashTable *__socket_pair_hash = NULL;
static void __map_call_cb(const char *provider_id, int request_id, datacontrol_request_type type,
__remove_map_request_info(request_id, map_dc);
- // result list
+ /* result list */
result_list = bundle_get_str_array(b, OSP_K_ARG, &result_list_len);
if (!result_list) {
LOGE("Invalid Bundle: arguement list is null");
return DATACONTROL_ERROR_INVALID_PARAMETER;
}
- p = result_list[0]; // result list[0] = provider_result
+ p = result_list[0]; /* result list[0] = provider_result */
if (!p) {
LOGE("Invalid Bundle: provider_result is null");
return DATACONTROL_ERROR_INVALID_PARAMETER;
provider_result = atoi(p);
- error_message = result_list[1]; // result list[1] = error
+ error_message = result_list[1]; /* result list[1] = error */
if (!error_message) {
LOGE("Invalid Bundle: error_message is null");
return DATACONTROL_ERROR_INVALID_PARAMETER;
return DATACONTROL_ERROR_INVALID_PARAMETER;
}
- // encoded bundle + encoded bundle size
+ /* encoded bundle + encoded bundle size */
buf = (char *)calloc(datalen + sizeof(datalen), sizeof(char));
if (buf == NULL) {
LOGE("Malloc failed!!");
if (socket_info == NULL) {
ret = _request_appsvc_run(caller_app_id, app_id);
- if(ret != DATACONTROL_ERROR_NONE)
+ if (ret != DATACONTROL_ERROR_NONE)
return ret;
socket_info = _get_socket_info(caller_app_id, app_id, "consumer", __recv_map_message, data);
LOGI("send data from consumer !!!");
ret = __datacontrol_send_map_async(socket_info->socket_fd, request_data, type, NULL);
- if(ret != DATACONTROL_ERROR_NONE)
+ if (ret != DATACONTROL_ERROR_NONE)
g_hash_table_remove(__socket_pair_hash, provider->provider_id);
else
break;
bundle_add_str_array(b, OSP_K_ARG, arg_list, 4);
- // Set the request id
+ /* Set the request id */
int reqId = _datacontrol_create_request_id();
*request_id = reqId;
bundle_add_str_array(b, OSP_K_ARG, arg_list, 4);
- // Set the request id
+ /* Set the request id */
int reqId = _datacontrol_create_request_id();
*request_id = reqId;
bundle_add_str_array(b, OSP_K_ARG, arg_list, 3);
- // Set the request id
+ /* Set the request id */
int reqId = _datacontrol_create_request_id();
*request_id = reqId;
bundle_add_str_array(b, OSP_K_ARG, arg_list, 3);
- // Set the request id
+ /* Set the request id */
int reqId = _datacontrol_create_request_id();
*request_id = reqId;
static GHashTable *__request_table = NULL;
static GHashTable *__socket_pair_hash = NULL;
-//static pthread_mutex_t provider_lock = PTHREAD_MUTEX_INITIALIZER;
+/* static pthread_mutex_t provider_lock = PTHREAD_MUTEX_INITIALIZER; */
struct datacontrol_s {
char *provider_id;
LOGI("__send_select_result");
- // In this function, the result set is written in socket as specific form.
- // [sizeof(int)] column count
- // [sizeof(int)] column type x N
- // [ variant ] (column name leng, column name) x N
- // [sieeof(int)] total size of column names
- // [sizeof(int)] row count
- // [ variant ] (type, size, content) x N
+ /*
+ In this function, the result set is written in socket as specific form.
+ [sizeof(int)] column count
+ [sizeof(int)] column type x N
+ [ variant ] (column name leng, column name) x N
+ [sieeof(int)] total size of column names
+ [sizeof(int)] row count
+ [ variant ] (type, size, content) x N
+ */
sqlite3_stmt *state = (sqlite3_stmt *)data;
int column_count = DATACONTROL_RESULT_NO_DATA;
return DATACONTROL_ERROR_NONE;
}
- // 1. column count
+ /* 1. column count */
column_count = sqlite3_column_count(state);
if (_write_socket(fd, &column_count, sizeof(int), &nb) != DATACONTROL_ERROR_NONE) {
LOGE("Writing a column_count to a file descriptor is failed. errno = %d", errno);
LOGI("Writing a column_count %d", column_count);
- // 2. column type x column_count
- // #define SQLITE_INTEGER 1
- // #define SQLITE_FLOAT 2
- // #define SQLITE_TEXT 3
- // #define SQLITE_BLOB 4
- // #define SQLITE_NULL 5
+ /*
+ 2. column type x column_count
+ #define SQLITE_INTEGER 1
+ #define SQLITE_FLOAT 2
+ #define SQLITE_TEXT 3
+ #define SQLITE_BLOB 4
+ #define SQLITE_NULL 5
+ */
for (i = 0; i < column_count; i++) {
int type = sqlite3_column_type(state, i);
if (_write_socket(fd, &type, sizeof(int), &nb) != DATACONTROL_ERROR_NONE) {
LOGI("Writing a column_type %d", type);
}
- // 3. column name x column_count
+ /* 3. column name x column_count */
for (i = 0; i < column_count; i++) {
column_name = (char *)sqlite3_column_name(state, i);
if (column_name == NULL) {
}
}
- // 4. total length of column names
+ /* 4. total length of column names */
if (_write_socket(fd, &total_len_of_column_names, sizeof(int), &nb) != DATACONTROL_ERROR_NONE) {
LOGI("Writing a total_len_of_column_names to a file descriptor is failed. errno = %d", errno);
return DATACONTROL_ERROR_IO_ERROR;
LOGI("page_number: %s, per_page: %s", page_number_str, count_per_page_str);
- // 5. type, size and value of each element
+ /* 5. type, size and value of each element */
if (page_number_str != NULL)
page_number = atoi(page_number_str);
else
++row_count;
} while (sqlite3_step(state) == SQLITE_ROW && row_count < count_per_page);
- // 6. row count
+ /* 6. row count */
if (_write_socket(fd, &row_count, sizeof(row_count), &nb) != DATACONTROL_ERROR_NONE) {
LOGI("Writing a row_count to a file descriptor is failed. errno = %d", errno);
return DATACONTROL_ERROR_IO_ERROR;
int remain_count = value_count - current_offset;
unsigned int nb;
- remain_count = (remain_count > 0) ? remain_count : 0; // round off to zero if the negative num is found
+ remain_count = (remain_count > 0) ? remain_count : 0; /* round off to zero if the negative num is found */
int add_value_count = (count_per_page > remain_count) ? remain_count : count_per_page;
return DATACONTROL_ERROR_OUT_OF_MEMORY;
}
- // encoded bundle + encoded bundle len
+ /* encoded bundle + encoded bundle len */
buf = (char *)calloc(datalen + 4, sizeof(char));
memcpy(buf, &datalen, sizeof(datalen));
memcpy(buf + sizeof(datalen), kb_data, datalen);
bundle *res = bundle_create();
- // Set the type
+ /* Set the type */
char type_str[MAX_LEN_DATACONTROL_REQ_TYPE] = {0,};
if (type == DATACONTROL_TYPE_UNDEFINED || type == DATACONTROL_TYPE_ERROR) {
bundle_add_str(res, OSP_K_DATACONTROL_REQUEST_TYPE, type_str);
- // Set the provider id
+ /* Set the provider id */
char *provider_id = (char *)bundle_get_val(b, OSP_K_DATACONTROL_PROVIDER);
bundle_add_str(res, OSP_K_DATACONTROL_PROVIDER, provider_id);
- // Set the data id
+ /* Set the data id */
char *data_id = (char *)bundle_get_val(b, OSP_K_DATACONTROL_DATA);
bundle_add_str(res, OSP_K_DATACONTROL_DATA, data_id);
- // Set the caller request id
+ /* Set the caller request id */
char *request_id = (char *)bundle_get_val(b, OSP_K_REQUEST_ID);
bundle_add_str(res, OSP_K_REQUEST_ID, request_id);
{
const char *list[3];
- list[PACKET_INDEX_REQUEST_RESULT] = "1"; // request result
+ list[PACKET_INDEX_REQUEST_RESULT] = "1"; /* request result */
list[PACKET_INDEX_ERROR_MSG] = DATACONTROL_EMPTY;
list[PACKET_INDEX_SELECT_RESULT_FILE] = DATACONTROL_EMPTY;
long long row_id = *(long long *)data;
const char *list[3];
- list[PACKET_INDEX_REQUEST_RESULT] = "1"; // request result
+ list[PACKET_INDEX_REQUEST_RESULT] = "1"; /* request result */
list[PACKET_INDEX_ERROR_MSG] = DATACONTROL_EMPTY;
- // Set the row value
+ /* Set the row value */
char row_str[ROW_ID_SIZE] = {0,};
snprintf(row_str, ROW_ID_SIZE, "%lld", row_id);
case DATACONTROL_TYPE_SQL_DELETE:
{
const char *list[2];
- list[PACKET_INDEX_REQUEST_RESULT] = "1"; // request result
+ list[PACKET_INDEX_REQUEST_RESULT] = "1"; /* request result */
list[PACKET_INDEX_ERROR_MSG] = DATACONTROL_EMPTY;
bundle_add_str_array(res, OSP_K_ARG, list, 2);
case DATACONTROL_TYPE_MAP_GET:
{
const char *list[4];
- list[PACKET_INDEX_REQUEST_RESULT] = "1"; // request result
+ list[PACKET_INDEX_REQUEST_RESULT] = "1"; /* request result */
list[PACKET_INDEX_ERROR_MSG] = DATACONTROL_EMPTY;
bundle_add_str_array(res, OSP_K_ARG, list, 2);
break;
}
- case DATACONTROL_TYPE_UNDEFINED: // DATACONTROL_TYPE_MAP_SET || ADD || REMOVE
+ case DATACONTROL_TYPE_UNDEFINED: /* DATACONTROL_TYPE_MAP_SET || ADD || REMOVE */
{
const char *list[2];
- list[PACKET_INDEX_REQUEST_RESULT] = "1"; // request result
+ list[PACKET_INDEX_REQUEST_RESULT] = "1"; /* request result */
list[PACKET_INDEX_ERROR_MSG] = DATACONTROL_EMPTY;
bundle_add_str_array(res, OSP_K_ARG, list, 2);
break;
}
- default: // Error
+ default: /* Error */
{
const char *list[2];
- list[PACKET_INDEX_REQUEST_RESULT] = "0"; // request result
- list[PACKET_INDEX_ERROR_MSG] = (char *)data; // error string
+ list[PACKET_INDEX_REQUEST_RESULT] = "0"; /* request result */
+ list[PACKET_INDEX_ERROR_MSG] = (char *)data; /* error string */
bundle_add_str_array(res, OSP_K_ARG, list, 2);
break;
return DATACONTROL_ERROR_INVALID_PARAMETER;
}
- // Get the request type
+ /* Get the request type */
datacontrol_request_type type = atoi(request_type);
if (type >= DATACONTROL_TYPE_SQL_SELECT && type <= DATACONTROL_TYPE_SQL_DELETE) {
if (provider_sql_cb == NULL) {
return DATACONTROL_ERROR_IO_ERROR;
}
- // Set the provider ID
+ /* Set the provider ID */
provider->provider_id = (char *)bundle_get_val(b, OSP_K_DATACONTROL_PROVIDER);
- // Set the data ID
+ /* Set the data ID */
provider->data_id = (char *)arg_list[PACKET_INDEX_DATAID];
- // Set the request ID
+ /* Set the request ID */
int provider_req_id = __provider_new_request_id();
LOGI("Provider ID: %s, data ID: %s, request type: %s", provider->provider_id, provider->data_id, request_type);
- // Add the data to the table
+ /* Add the data to the table */
int *key = malloc(sizeof(int));
if (key == NULL) {
LOGE("Out of memory. fail to malloc key");
{
int i = 1;
int current = 0;
- int column_count = atoi(arg_list[i++]); // Column count
+ int column_count = atoi(arg_list[i++]); /* Column count */
LOGI("SELECT column count: %d", column_count);
const char **column_list = (const char **)malloc(column_count * (sizeof(char *)));
}
while (current < column_count) {
- column_list[current++] = arg_list[i++]; // Column data
+ column_list[current++] = arg_list[i++]; /* Column data */
LOGI("Column %d: %s", current, column_list[current-1]);
}
- const char *where = arg_list[i++]; // where
- const char *order = arg_list[i++]; // order
+ const char *where = arg_list[i++]; /* where */
+ const char *order = arg_list[i++]; /* order */
LOGI("where: %s, order: %s", where, order);
if (strncmp(where, DATACONTROL_EMPTY, strlen(DATACONTROL_EMPTY)) == 0)
provider_sql_cb = callback;
provider_sql_user_data = user_data;
- // If the provider_map_cb was registered(not NULL), __datacontrol_handler_cb is set already.
+ /* If the provider_map_cb was registered(not NULL), __datacontrol_handler_cb is set already. */
if (provider_map_cb == NULL)
ret = aul_set_data_control_provider_cb(__datacontrol_handler_cb);
int datacontrol_provider_sql_unregister_cb(void)
{
- // When both SQL_cb and Map_cb are unregisted, unsetting the provider cb is possible.
+ /* When both SQL_cb and Map_cb are unregisted, unsetting the provider cb is possible. */
if (provider_map_cb == NULL)
aul_unset_data_control_provider_cb();
provider_map_cb = callback;
provider_map_user_data = user_data;
- // If the provider_sql_cb was registered(not NULL), __datacontrol_handler_cb is set already.
+ /* If the provider_sql_cb was registered(not NULL), __datacontrol_handler_cb is set already. */
if (provider_sql_cb == NULL)
ret = aul_set_data_control_provider_cb(__datacontrol_handler_cb);
int datacontrol_provider_map_unregister_cb(void)
{
- // When both SQL_cb and Map_cb are unregisted, unsetting the provider cb is possible.
+ /* When both SQL_cb and Map_cb are unregisted, unsetting the provider cb is possible. */
if (provider_sql_cb == NULL)
aul_unset_data_control_provider_cb();
{
int ret = 0;
if (cursor->resultset_current_row_count == (cursor->resultset_row_count - 1))
- return DATACONTROL_ERROR_NONE; // Already @ last row
+ return DATACONTROL_ERROR_NONE; /* Already @ last row */
if (!cursor->row_offset_list) {
- ret = datacontrol_sql_step_next(cursor); // make a first move
+ ret = datacontrol_sql_step_next(cursor); /* make a first move */
if (ret != DATACONTROL_ERROR_NONE)
return ret;
}
- // check if the rowOffsetList contains last row offset
+ /* check if the rowOffsetList contains last row offset */
if (cursor->row_offset_list && cursor->row_offset_list[cursor->resultset_row_count - 1] != 0) {
cursor->resultset_current_offset = cursor->row_offset_list[cursor->resultset_row_count - 1];
cursor->resultset_current_row_count = cursor->resultset_row_count - 1;
} else {
int i = 0;
- // Move till last row offset.
+ /* Move till last row offset. */
for (i = (cursor->resultset_current_row_count + 1); i < cursor->resultset_row_count; i++) {
- ret = datacontrol_sql_step_next(cursor); // move till last row data offset
+ ret = datacontrol_sql_step_next(cursor); /* move till last row data offset */
if (ret != DATACONTROL_ERROR_NONE)
return ret;
}
return DATACONTROL_ERROR_NONE;
}
- // MoveFirst is called for the first time before MoveNext() or MoveLast()
+ /* MoveFirst is called for the first time before MoveNext() or MoveLast() */
cursor->resultset_current_offset = 0;
return datacontrol_sql_step_next(cursor);
}
}
}
- memset(name, 0, strlen(col_name)); // To avoid copying newline
+ memset(name, 0, strlen(col_name)); /* To avoid copying newline */
memcpy(name, col_name, strlen(col_name) - 1);
LOGI("The column name is %s", name);
return DATACONTROL_ERROR_IO_ERROR;
}
- // move to column index
+ /* move to column index */
for (i = 0; i < column_index; i++) {
ret = read(fd, &type, sizeof(int));
if (ret == 0) {
return DATACONTROL_ERROR_IO_ERROR;
}
- // move to column index
+ /* move to column index */
for (i = 0; i < column_index; i++) {
ret = read(fd, &type, sizeof(int));
if (ret == 0) {
return DATACONTROL_ERROR_IO_ERROR;
}
- // move to column index
+ /* move to column index */
for (i = 0; i < column_index; i++) {
ret = read(fd, &type, sizeof(int));
if (ret == 0) {
ret = read(fd, &size, sizeof(int));
if (size > data_size) {
LOGE("size is more than the size requested");
- return DATACONTROL_ERROR_MAX_EXCEEDED; //overflow
+ return DATACONTROL_ERROR_MAX_EXCEEDED; /* overflow */
}
if (size > 0) {
return DATACONTROL_ERROR_IO_ERROR;
}
- // move to column index
+ /* move to column index */
for (i = 0; i < column_index; i++) {
ret = read(fd, &type, sizeof(int));
if (ret == 0) {
return DATACONTROL_ERROR_IO_ERROR;
}
- // move to column index
+ /* move to column index */
for (i = 0; i < column_index; i++) {
ret = read(fd, &type, sizeof(int));
if (ret == 0) {
return DATACONTROL_ERROR_IO_ERROR;
}
- // move to column index
+ /* move to column index */
for (i = 0; i < column_index; i++) {
ret = read(fd, &type, sizeof(int));
if (ret == 0) {
if (size > 0) {
char *data = (char *)malloc((size + 1) * (sizeof(char)));
- if(!data) {
+ if (!data) {
LOGE("unable to create buffer to read");
return DATACONTROL_ERROR_OUT_OF_MEMORY;
}
#include "data-control-internal.h"
#define REQUEST_PATH_MAX 512
-#define MAX_REQUEST_ARGUMENT_SIZE 1048576 // 1MB
+#define MAX_REQUEST_ARGUMENT_SIZE 1048576 /* 1MB */
struct datacontrol_s {
char *provider_id;
__remove_sql_request_info(request_id, sql_dc);
- // result list
+ /* result list */
result_list = appsvc_get_data_array(b, OSP_K_ARG, &result_list_len);
if (!result_list) {
LOGE("Invalid Bundle: arguement list is null");
return DATACONTROL_ERROR_INVALID_PARAMETER;
}
- p = result_list[0]; // result list[0] = provider_result
+ p = result_list[0]; /* result list[0] = provider_result */
if (!p) {
LOGE("Invalid Bundle: provider_result is null");
return DATACONTROL_ERROR_INVALID_PARAMETER;
provider_result = atoi(p);
- error_message = result_list[1]; // result list[1] = error
+ error_message = result_list[1]; /* result list[1] = error */
if (!error_message) {
LOGE("Invalid Bundle: error_message is null");
return DATACONTROL_ERROR_INVALID_PARAMETER;
{
LOGI("INSERT RESPONSE");
if (provider_result) {
- p = result_list[2]; // result list[2]
+ p = result_list[2]; /* result list[2] */
if (!p) {
LOGE("Invalid Bundle: insert row_id is null");
return DATACONTROL_ERROR_INVALID_PARAMETER;
cursor->resultset_col_count = column_count;
LOGI("column_count : %d", column_count);
- // no data check.
+ /* no data check. */
if (column_count == DATACONTROL_RESULT_NO_DATA) {
LOGE("No result");
return DATACONTROL_ERROR_NONE;
if (buf)
free(buf);
- if(((sql_response_cb_s *)data) != NULL) {
+ if (((sql_response_cb_s *)data) != NULL) {
LOGE("g_hash_table_remove");
g_hash_table_remove(__socket_pair_hash, ((sql_response_cb_s *)data)->provider_id);
g_hash_table_remove(__socket_pair_hash, sql_dc->provider_id);
GList *itr = g_list_first(sql_dc->request_info_list);
- while(itr != NULL) {
+ while (itr != NULL) {
datacontrol_consumer_request_info *request_info = (datacontrol_consumer_request_info *)itr->data;
__sql_call_cb(sql_dc->provider_id, request_info->request_id, request_info->type, sql_dc->data_id, false,
"provider IO Error", -1, NULL, data);
total_len = sizeof(datalen) + datalen + sizeof(extra_datalen) + extra_datalen;
- // encoded bundle + encoded bundle size
+ /* encoded bundle + encoded bundle size */
buf = (char *)calloc(total_len, sizeof(char));
if (buf == NULL) {
bundle_free_encoded_rawdata(&kb_data);
memcpy(buf, &datalen, sizeof(datalen));
memcpy(buf + sizeof(datalen), kb_data, datalen);
- if(extra_datalen > 0) {
+ if (extra_datalen > 0) {
memcpy(buf + sizeof(datalen) + datalen, &extra_datalen, sizeof(extra_datalen));
memcpy(buf + sizeof(datalen) + datalen + sizeof(extra_datalen), extra_kb_data, extra_datalen);
}
int ret = 0;
- // Check size of arguments
+ /* Check size of arguments */
long long arg_size = 0;
bundle_foreach((bundle *)insert_data, bundle_foreach_check_arg_size_cb, &arg_size);
arg_size += strlen(provider->data_id) * sizeof(wchar_t);
bundle_add_str_array(b, OSP_K_ARG, arg_list, 2);
- // Set the request id
+ /* Set the request id */
*request_id = _datacontrol_create_request_id();
LOGI("request id : %d", *request_id);
bundle_add_str_array(b, OSP_K_ARG, arg_list, 2);
- // Set the request id
+ /* Set the request id */
int reqId = _datacontrol_create_request_id();
*request_id = reqId;
LOGI("total arg count %d", total_arg_count);
- arg_list[0] = provider->data_id; // arg[0]: data ID
+ arg_list[0] = provider->data_id; /* arg[0]: data ID */
int i = 1;
if (column_list) {
char select_column_count[MAX_LEN_DATACONTROL_COLUMN_COUNT] = {0, };
}
- arg_list[i] = select_column_count; // arg[1]: selected column count
+ arg_list[i] = select_column_count; /* arg[1]: selected column count */
++i;
int select_col = 0;
} else
arg_list[i++] = DATACONTROL_EMPTY;
- if (where) // arg: where clause
+ if (where) /* arg: where clause */
arg_list[i++] = where;
else
arg_list[i++] = DATACONTROL_EMPTY;
- if (order)// arg: order clause
+ if (order) /* arg: order clause */
arg_list[i++] = order;
else
arg_list[i++] = DATACONTROL_EMPTY;
- arg_list[i++] = page; // arg: page number
+ arg_list[i++] = page; /* arg: page number */
- arg_list[i] = count_per_page_no; // arg: count per page
+ arg_list[i] = count_per_page_no; /* arg: count per page */
bundle_add_str_array(b, OSP_K_ARG, arg_list, total_arg_count);
free(arg_list);
int ret = 0;
- // Check size of arguments
+ /* Check size of arguments */
long long arg_size = 0;
bundle_foreach((bundle *)update_data, bundle_foreach_check_arg_size_cb, &arg_size);
arg_size += strlen(provider->data_id) * sizeof(wchar_t);
}
const char *arg_list[4];
- arg_list[0] = provider->data_id; // list(0): data ID
+ arg_list[0] = provider->data_id; /* list(0): data ID */
arg_list[1] = update_column_count;
arg_list[2] = where;
bundle_add_str_array(b, OSP_K_ARG, arg_list, 3);
#define LOG_TAG "CAPI_APPFW_DATA_CONTROL"
-#define _LOGE(fmt, arg...) LOGE(fmt,##arg)
+#define _LOGE(fmt, arg...) LOGE(fmt, ##arg)
#define _LOGD(fmt, arg...) LOGD(fmt, ##arg)
-int datacontrol_check_privilege(privilege_type check_type) {
+int datacontrol_check_privilege(privilege_type check_type)
+{
cynara *p_cynara;
static bool checked_privilege = FALSE;
- if (checked_privilege) {
+ if (checked_privilege)
return DATA_CONTROL_ERROR_NONE;
- }
ret = cynara_initialize(&p_cynara, NULL);
if (ret != CYNARA_API_SUCCESS) {
static const char *data_control_error_to_string(data_control_error_e error)
{
switch (error) {
- case DATA_CONTROL_ERROR_NONE:
- return "NONE";
- case DATA_CONTROL_ERROR_INVALID_PARAMETER:
- return "INVALID_PARAMETER";
- case DATA_CONTROL_ERROR_OUT_OF_MEMORY:
- return "OUT_OF_MEMORY";
- case DATA_CONTROL_ERROR_IO_ERROR:
- return "IO_ERROR";
- case DATA_CONTROL_ERROR_PERMISSION_DENIED:
- return "PERMISSION_DENIED";
- case DATA_CONTROL_ERROR_MAX_EXCEEDED:
- return "Too long argument";
- default:
- return "UNKNOWN";
+ case DATA_CONTROL_ERROR_NONE:
+ return "NONE";
+ case DATA_CONTROL_ERROR_INVALID_PARAMETER:
+ return "INVALID_PARAMETER";
+ case DATA_CONTROL_ERROR_OUT_OF_MEMORY:
+ return "OUT_OF_MEMORY";
+ case DATA_CONTROL_ERROR_IO_ERROR:
+ return "IO_ERROR";
+ case DATA_CONTROL_ERROR_PERMISSION_DENIED:
+ return "PERMISSION_DENIED";
+ case DATA_CONTROL_ERROR_MAX_EXCEEDED:
+ return "Too long argument";
+ default:
+ return "UNKNOWN";
}
}
int convert_to_tizen_error(datacontrol_error_e error)
{
switch (error) {
- case DATACONTROL_ERROR_NONE:
- return DATA_CONTROL_ERROR_NONE;
- case DATACONTROL_ERROR_INVALID_PARAMETER:
- return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- case DATACONTROL_ERROR_OUT_OF_MEMORY:
- return DATA_CONTROL_ERROR_OUT_OF_MEMORY;
- case DATACONTROL_ERROR_IO_ERROR:
- return DATA_CONTROL_ERROR_IO_ERROR;
- case DATACONTROL_ERROR_PERMISSION_DENIED:
- return DATA_CONTROL_ERROR_PERMISSION_DENIED;
- case DATACONTROL_ERROR_MAX_EXCEEDED:
- return DATA_CONTROL_ERROR_MAX_EXCEEDED;
- default:
- return error;
+ case DATACONTROL_ERROR_NONE:
+ return DATA_CONTROL_ERROR_NONE;
+ case DATACONTROL_ERROR_INVALID_PARAMETER:
+ return DATA_CONTROL_ERROR_INVALID_PARAMETER;
+ case DATACONTROL_ERROR_OUT_OF_MEMORY:
+ return DATA_CONTROL_ERROR_OUT_OF_MEMORY;
+ case DATACONTROL_ERROR_IO_ERROR:
+ return DATA_CONTROL_ERROR_IO_ERROR;
+ case DATACONTROL_ERROR_PERMISSION_DENIED:
+ return DATA_CONTROL_ERROR_PERMISSION_DENIED;
+ case DATACONTROL_ERROR_MAX_EXCEEDED:
+ return DATA_CONTROL_ERROR_MAX_EXCEEDED;
+ default:
+ return error;
}
}
data_control_map_response_cb *callback = (data_control_map_response_cb*)g_hash_table_lookup(response_table, provider->provider_id);
if (callback)
- {
callback->get_cb(request_id, (data_control_h)provider, result_value_list, result_value_count, provider_result, error, user_data);
- }
}
void
data_control_map_response_cb *callback = (data_control_map_response_cb*)g_hash_table_lookup(response_table, provider->provider_id);
if (callback)
- {
callback->set_cb(request_id, (data_control_h)provider, provider_result, error, user_data);
- }
}
void
data_control_map_response_cb *callback = (data_control_map_response_cb*)g_hash_table_lookup(response_table, provider->provider_id);
if (callback)
- {
callback->add_cb(request_id, (data_control_h)provider, provider_result, error, user_data);
- }
}
void
data_control_map_response_cb *callback = (data_control_map_response_cb*)g_hash_table_lookup(response_table, provider->provider_id);
if (callback)
- {
callback->remove_cb(request_id, (data_control_h)provider, provider_result, error, user_data);
- }
}
static void
__free_data(gpointer data)
{
- if (data)
- {
+ if (data) {
g_free(data);
data = NULL;
}
{
if (response_table == NULL)
- {
__initialize();
- }
if (callback == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
char *id = strdup(provider->provider_id);
if (id == NULL)
- {
return DATA_CONTROL_ERROR_OUT_OF_MEMORY;
- }
data_control_map_response_cb *cb
= (data_control_map_response_cb *)malloc(sizeof(data_control_map_response_cb));
- if (cb == NULL)
- {
+ if (cb == NULL) {
free(id);
return DATA_CONTROL_ERROR_OUT_OF_MEMORY;
}
data_control_map_unregister_response_cb(data_control_h provider)
{
if (provider->provider_id)
- {
g_hash_table_remove(response_table, provider->provider_id);
- }
return convert_to_tizen_error(datacontrol_map_unregister_response_cb((datacontrol_h)provider));
}
char *data_id;
};
-typedef struct
-{
+typedef struct {
int no_of_elements;
int length;
- char** keys;
- char** vals;
-}key_val_pair;
+ char **keys;
+ char **vals;
+} key_val_pair;
static data_control_provider_sql_cb sql_provider_callback;
static data_control_provider_map_cb map_provider_callback;
datacontrol_provider_sql_cb sql_internal_callback;
datacontrol_provider_map_cb map_internal_callback;
-void
-__sql_insert_request_cb(int request_id, datacontrol_h provider, bundle *insert_data, void *user_data)
+void __sql_insert_request_cb(int request_id, datacontrol_h provider, bundle *insert_data, void *user_data)
{
_LOGI("sql_insert_request");
if (sql_provider_callback.insert_cb)
- {
sql_provider_callback.insert_cb(request_id, (data_control_h)provider, insert_data, user_data);
- }
}
-void
-__sql_update_request_cb(int request_id, datacontrol_h provider, bundle *update_data, const char *where, void *user_data)
+void __sql_update_request_cb(int request_id, datacontrol_h provider, bundle *update_data, const char *where, void *user_data)
{
_LOGI("sql_update_request");
if (sql_provider_callback.update_cb)
- {
sql_provider_callback.update_cb(request_id, (data_control_h)provider, update_data, where, user_data);
- }
}
-void
-__sql_delete_request_cb(int request_id, datacontrol_h provider, const char *where, void *user_data)
+void __sql_delete_request_cb(int request_id, datacontrol_h provider, const char *where, void *user_data)
{
_LOGI("sql_delete_request");
if (sql_provider_callback.delete_cb)
- {
sql_provider_callback.delete_cb(request_id, (data_control_h)provider, where, user_data);
- }
}
-void
-__sql_select_request_cb(int request_id, datacontrol_h provider, const char **column_list, int column_count, const char *where, const char *order, void *user_data)
+void __sql_select_request_cb(int request_id, datacontrol_h provider, const char **column_list, int column_count, const char *where, const char *order, void *user_data)
{
_LOGI("sql_select_request");
if (sql_provider_callback.select_cb)
- {
sql_provider_callback.select_cb(request_id, (data_control_h)provider, column_list, column_count, where, order, user_data);
- }
}
-void
-__map_get_request_cb(int request_id, datacontrol_h provider, const char *key, void *user_data)
+void __map_get_request_cb(int request_id, datacontrol_h provider, const char *key, void *user_data)
{
_LOGI("map_get_request");
if (map_provider_callback.get_cb)
- {
map_provider_callback.get_cb(request_id, (data_control_h)provider, key, user_data);
- }
}
-void
-__map_set_request_cb(int request_id, datacontrol_h provider, const char *key, const char *old_value, const char *new_value, void *user_data)
+void __map_set_request_cb(int request_id, datacontrol_h provider, const char *key, const char *old_value, const char *new_value, void *user_data)
{
_LOGI("map_set_request");
if (map_provider_callback.set_cb)
- {
map_provider_callback.set_cb(request_id, (data_control_h)provider, key, old_value, new_value, user_data);
- }
}
-void
-__map_add_request_cb(int request_id, datacontrol_h provider, const char *key, const char *value, void *user_data)
+void __map_add_request_cb(int request_id, datacontrol_h provider, const char *key, const char *value, void *user_data)
{
_LOGI("map_add_request");
if (map_provider_callback.add_cb)
- {
map_provider_callback.add_cb(request_id, (data_control_h)provider, key, value, user_data);
- }
}
-void
-__map_remove_request_cb(int request_id, datacontrol_h provider, const char *key, const char *value, void *user_data)
+void __map_remove_request_cb(int request_id, datacontrol_h provider, const char *key, const char *value, void *user_data)
{
_LOGI("map_remove_request");
if (map_provider_callback.remove_cb)
- {
map_provider_callback.remove_cb(request_id, (data_control_h)provider, key, value, user_data);
- }
}
-EXPORT_API int
-data_control_provider_sql_register_cb(data_control_provider_sql_cb *callback, void *user_data)
+EXPORT_API int data_control_provider_sql_register_cb(data_control_provider_sql_cb *callback, void *user_data)
{
int retval = datacontrol_check_privilege(PRIVILEGE_PROVIDER);
return datacontrol_provider_sql_register_cb(&sql_internal_callback, user_data);
}
-EXPORT_API int
-data_control_provider_sql_unregister_cb(void)
+EXPORT_API int data_control_provider_sql_unregister_cb(void)
{
memset(&sql_provider_callback, 0, sizeof(data_control_provider_sql_cb));
return datacontrol_provider_sql_unregister_cb();
}
-EXPORT_API int
-data_control_provider_map_register_cb(data_control_provider_map_cb *callback, void *user_data)
+EXPORT_API int data_control_provider_map_register_cb(data_control_provider_map_cb *callback, void *user_data)
{
int retval = datacontrol_check_privilege(PRIVILEGE_PROVIDER);
return datacontrol_provider_map_register_cb(&map_internal_callback, user_data);
}
-EXPORT_API int
-data_control_provider_map_unregister_cb(void)
+EXPORT_API int data_control_provider_map_unregister_cb(void)
{
memset(&map_provider_callback, 0, sizeof(data_control_provider_map_cb));
return datacontrol_provider_map_unregister_cb();
}
-EXPORT_API int
-data_control_provider_get_client_appid(int request_id, char **appid)
+EXPORT_API int data_control_provider_get_client_appid(int request_id, char **appid)
{
return datacontrol_provider_get_client_appid(request_id, appid);
}
-EXPORT_API int
-data_control_provider_send_select_result(int request_id, void *db_handle)
+EXPORT_API int data_control_provider_send_select_result(int request_id, void *db_handle)
{
return datacontrol_provider_send_select_result(request_id, db_handle);
}
-EXPORT_API int
-data_control_provider_send_insert_result(int request_id, long long row_id)
+EXPORT_API int data_control_provider_send_insert_result(int request_id, long long row_id)
{
return datacontrol_provider_send_insert_result(request_id, row_id);
}
-EXPORT_API int
-data_control_provider_send_update_result(int request_id)
+EXPORT_API int data_control_provider_send_update_result(int request_id)
{
return datacontrol_provider_send_update_result(request_id);
}
-EXPORT_API int
-data_control_provider_send_delete_result(int request_id)
+EXPORT_API int data_control_provider_send_delete_result(int request_id)
{
return datacontrol_provider_send_delete_result(request_id);
}
-EXPORT_API int
-data_control_provider_send_error(int request_id, const char *error)
+EXPORT_API int data_control_provider_send_error(int request_id, const char *error)
{
return datacontrol_provider_send_error(request_id, error);
}
static void bundle_foreach_cb(const char *key, const int type, const bundle_keyval_t *kv, void *user_data)
{
if (!key || !kv || !user_data)
- {
return;
- }
- key_val_pair* pair = (key_val_pair *)user_data;
+ key_val_pair *pair = (key_val_pair *)user_data;
int index = pair->no_of_elements;
pair->keys[index] = strdup(key);
char *value = NULL;
size_t value_len = 0;
- bundle_keyval_get_basic_val((bundle_keyval_t *)kv, (void**)&value, &value_len);
+ bundle_keyval_get_basic_val((bundle_keyval_t *)kv, (void **)&value, &value_len);
pair->vals[index] = strdup(value);
pair->length += strlen(key) + value_len;
return;
}
-EXPORT_API char*
-data_control_provider_create_insert_statement(data_control_h provider, bundle *insert_map)
+EXPORT_API char *data_control_provider_create_insert_statement(data_control_h provider, bundle *insert_map)
{
int row_count = bundle_get_count(insert_map);
- if (provider == NULL || row_count == 0)
- {
+ if (provider == NULL || row_count == 0) {
set_last_result(DATA_CONTROL_ERROR_INVALID_PARAMETER);
return NULL;
}
key_val_pair *cols = (key_val_pair *) calloc(1, sizeof(key_val_pair));
- if (cols == NULL)
- {
+ if (cols == NULL) {
set_last_result(DATA_CONTROL_ERROR_OUT_OF_MEMORY);
return NULL;
}
cols->no_of_elements = 0;
cols->length = 0;
cols->keys = (char **) calloc(row_count, sizeof(char *));
- if (cols->keys == NULL)
- {
+ if (cols->keys == NULL) {
free(cols);
set_last_result(DATA_CONTROL_ERROR_OUT_OF_MEMORY);
return NULL;
}
cols->vals = (char **) calloc(row_count, sizeof(char *));
- if (cols->vals == NULL)
- {
+ if (cols->vals == NULL) {
free(cols->keys);
free(cols);
set_last_result(DATA_CONTROL_ERROR_OUT_OF_MEMORY);
}
int index = 0;
- bundle_foreach(insert_map, bundle_foreach_cb, (void*)(cols));
+ bundle_foreach(insert_map, bundle_foreach_cb, (void *)(cols));
char* data_id = NULL;
data_control_sql_get_data_id(provider, &data_id);
_LOGI("SQL statement length: %d", sql_len);
char* sql = (char *) calloc(sql_len, sizeof(char));
- if (sql == NULL)
- {
+ if (sql == NULL) {
free(data_id);
free(cols->keys);
free(cols->vals);
sprintf(sql, "INSERT INTO %s (", data_id);
free(data_id);
- for(index = 0; index < row_count - 1; index++)
- {
+ for (index = 0; index < row_count - 1; index++) {
strcat(sql, cols->keys[index]);
strcat(sql, ", ");
}
strcat(sql, cols->keys[index]);
strcat(sql, ") VALUES (");
- for(index = 0; index < row_count - 1; index++)
- {
+ for (index = 0; index < row_count - 1; index++) {
strcat(sql, cols->vals[index]);
strcat(sql, ", ");
}
_LOGI("SQL statement is: %s", sql);
- for(index = 0; index < row_count; index++)
- {
+ for (index = 0; index < row_count; index++) {
free(cols->keys[index]);
free(cols->vals[index]);
}
return sql;
}
-EXPORT_API char*
-data_control_provider_create_delete_statement(data_control_h provider, const char *where)
+EXPORT_API char *data_control_provider_create_delete_statement(data_control_h provider, const char *where)
{
- char* data_id = NULL;
+ char *data_id = NULL;
- if (provider == NULL)
- {
+ if (provider == NULL) {
set_last_result(DATA_CONTROL_ERROR_INVALID_PARAMETER);
return NULL;
}
_LOGI("SQL statement length: %d", sql_len);
- char* sql = (char *) calloc(sql_len, sizeof(char));
- if (sql == NULL)
- {
+ char *sql = (char *) calloc(sql_len, sizeof(char));
+ if (sql == NULL) {
free(data_id);
set_last_result(DATA_CONTROL_ERROR_OUT_OF_MEMORY);
return NULL;
memset(sql, 0, sql_len);
sprintf(sql, "DELETE FROM %s", data_id);
- if (where)
- {
+ if (where) {
strcat(sql, " WHERE ");
strcat(sql, where);
}
return sql;
}
-EXPORT_API char*
-data_control_provider_create_update_statement(data_control_h provider, bundle *update_map, const char *where)
+EXPORT_API char *data_control_provider_create_update_statement(data_control_h provider, bundle *update_map, const char *where)
{
int row_count = bundle_get_count(update_map);
- if (provider == NULL || row_count == 0)
- {
+ if (provider == NULL || row_count == 0) {
set_last_result(DATA_CONTROL_ERROR_INVALID_PARAMETER);
return NULL;
}
key_val_pair *cols = (key_val_pair *) calloc(1, sizeof(key_val_pair));
- if (cols == NULL)
- {
+ if (cols == NULL) {
set_last_result(DATA_CONTROL_ERROR_OUT_OF_MEMORY);
return NULL;
}
cols->no_of_elements = 0;
cols->length = 0;
cols->keys = (char **) calloc(row_count, sizeof(char *));
- if (cols->keys == NULL)
- {
+ if (cols->keys == NULL) {
free(cols);
set_last_result(DATA_CONTROL_ERROR_OUT_OF_MEMORY);
return NULL;
}
cols->vals = (char **) calloc(row_count, sizeof(char *));
- if (cols->vals == NULL)
- {
+ if (cols->vals == NULL) {
free(cols->keys);
free(cols);
set_last_result(DATA_CONTROL_ERROR_OUT_OF_MEMORY);
int index = 0;
bundle_foreach(update_map, bundle_foreach_cb, (void*)(cols));
- char* data_id = NULL;
+ char *data_id = NULL;
data_control_sql_get_data_id(provider, &data_id);
int cond_len = (where != NULL) ? (WHERE_COND_CONST_LEN + strlen(where)) : 0;
_LOGI("SQL statement length: %d", sql_len);
- char* sql = (char *) calloc(sql_len, sizeof(char));
- if (sql == NULL)
- {
+ char *sql = (char *) calloc(sql_len, sizeof(char));
+ if (sql == NULL) {
free(data_id);
free(cols->keys);
free(cols->vals);
sprintf(sql, "UPDATE %s SET ", data_id);
free(data_id);
- for(index = 0; index < row_count - 1; index++)
- {
+ for (index = 0; index < row_count - 1; index++) {
strcat(sql, cols->keys[index]);
strcat(sql, " = ");
strcat(sql, cols->vals[index]);
strcat(sql, " = ");
strcat(sql, cols->vals[index]);
- if (where)
- {
+ if (where) {
strcat(sql, " WHERE ");
strcat(sql, where);
}
_LOGI("SQL statement is: %s", sql);
- for(index = 0; index < row_count; index++)
- {
+ for (index = 0; index < row_count; index++) {
free(cols->keys[index]);
free(cols->vals[index]);
}
return sql;
}
-EXPORT_API char*
-data_control_provider_create_select_statement(data_control_h provider, const char **column_list, int column_count, const char *where, const char *order)
+EXPORT_API char *data_control_provider_create_select_statement(data_control_h provider, const char **column_list,
+ int column_count, const char *where, const char *order)
{
int index = 0;
int col_name_length = 0;
- if (provider == NULL)
- {
+ if (provider == NULL) {
set_last_result(DATA_CONTROL_ERROR_INVALID_PARAMETER);
return NULL;
}
- if (column_list)
- {
+ if (column_list) {
for (index = 0; index < column_count; index++)
- {
col_name_length += strlen(column_list[index]);
- }
+
if (column_count > 0)
- {
col_name_length += (column_count - 1) * 2;
- }
- }
- else
- {
+ } else {
col_name_length = 1;
}
- char* data_id = NULL;
+ char *data_id = NULL;
data_control_sql_get_data_id(provider, &data_id);
int cond_len = (where != NULL) ? (WHERE_COND_CONST_LEN + strlen(where)) : 0;
_LOGI("SQL statement length: %d", sql_len);
- char* sql = (char *) calloc(sql_len, sizeof(char));
- if (sql == NULL)
- {
+ char *sql = (char *) calloc(sql_len, sizeof(char));
+ if (sql == NULL) {
free(data_id);
set_last_result(DATA_CONTROL_ERROR_OUT_OF_MEMORY);
return NULL;
memset(sql, 0, sql_len);
strcpy(sql, "SELECT ");
- if (!column_list)
- {
+ if (!column_list) {
strcat(sql, "*");
- }
- else
- {
- for (index = 0; index < column_count - 1; index++)
- {
+ } else {
+ for (index = 0; index < column_count - 1; index++) {
strcat(sql, column_list[index]);
strcat(sql, ", ");
}
strcat(sql, " FROM ");
strcat(sql, data_id);
- if (where)
- {
+ if (where) {
strcat(sql, " WHERE ");
strcat(sql, where);
}
- if (order)
- {
+ if (order) {
strcat(sql, " ORDER BY ");
strcat(sql, order);
}
return sql;
}
-EXPORT_API bool
-data_control_provider_match_provider_id(data_control_h provider, const char *provider_id)
+EXPORT_API bool data_control_provider_match_provider_id(data_control_h provider, const char *provider_id)
{
int ret = DATA_CONTROL_ERROR_NONE;
- char* prov_id = NULL;
- if(provider == NULL || provider_id == NULL)
- {
+ char *prov_id = NULL;
+ if (provider == NULL || provider_id == NULL) {
set_last_result(DATA_CONTROL_ERROR_INVALID_PARAMETER);
return false;
}
ret = data_control_sql_get_provider_id(provider, &prov_id);
set_last_result(ret);
if (ret != DATA_CONTROL_ERROR_NONE)
- {
return false;
- }
- if (strcmp(prov_id, provider_id) == 0)
- {
+ if (strcmp(prov_id, provider_id) == 0) {
free(prov_id);
return true;
- }
- else
- {
+ } else {
free(prov_id);
return false;
}
}
-EXPORT_API bool
-data_control_provider_match_data_id(data_control_h provider, const char *data_id)
+EXPORT_API bool data_control_provider_match_data_id(data_control_h provider, const char *data_id)
{
int ret = DATA_CONTROL_ERROR_NONE;
- char* data = NULL;
- if(provider == NULL || data_id == NULL)
- {
+ char *data = NULL;
+ if (provider == NULL || data_id == NULL) {
set_last_result(DATA_CONTROL_ERROR_INVALID_PARAMETER);
return false;
}
ret = data_control_sql_get_data_id(provider, &data);
set_last_result(ret);
if (ret != DATA_CONTROL_ERROR_NONE)
- {
return false;
- }
- if (strcmp(data, data_id) == 0)
- {
+ if (strcmp(data, data_id) == 0) {
free(data);
return true;
- }
- else
- {
+ } else {
free(data);
return false;
}
data_control_sql_response_cb *callback = (data_control_sql_response_cb*)g_hash_table_lookup(response_table, provider->provider_id);
if (callback)
- {
callback->insert_cb(req_id, (data_control_h)provider, insert_rowid, provider_result, error, user_data);
- }
}
void
data_control_sql_response_cb *callback = (data_control_sql_response_cb*)g_hash_table_lookup(response_table, provider->provider_id);
if (callback)
- {
callback->update_cb(req_id, (data_control_h)provider, provider_result, error, user_data);
- }
}
void
data_control_sql_response_cb *callback = (data_control_sql_response_cb*)g_hash_table_lookup(response_table, provider->provider_id);
if (callback)
- {
callback->delete_cb(req_id, (data_control_h)provider, provider_result, error, user_data);
- }
}
void
data_control_sql_response_cb *callback = (data_control_sql_response_cb*)g_hash_table_lookup(response_table, provider->provider_id);
if (callback)
- {
callback->select_cb(req_id, (data_control_h)provider, (result_set_cursor)enumerator, provider_result, error, user_data);
- }
}
static void
__free_data(gpointer data)
{
- if (data)
- {
+ if (data) {
g_free(data);
data = NULL;
}
data_control_sql_register_response_cb(data_control_h provider, data_control_sql_response_cb* callback, void *user_data)
{
if (response_table == NULL)
- {
__initialize();
- }
if (callback == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
char *id = strdup(provider->provider_id);
if (id == NULL)
- {
return DATA_CONTROL_ERROR_OUT_OF_MEMORY;
- }
data_control_sql_response_cb *cb
= (data_control_sql_response_cb *)malloc(sizeof(data_control_sql_response_cb));
- if (cb == NULL)
- {
+ if (cb == NULL) {
free(id);
return DATA_CONTROL_ERROR_OUT_OF_MEMORY;
}
data_control_sql_unregister_response_cb(data_control_h provider)
{
if (provider->provider_id)
- {
g_hash_table_remove(response_table, provider->provider_id);
- }
return datacontrol_sql_unregister_response_cb((datacontrol_h)provider);
}
#include "data_control_sql_cursor.h"
-struct result_set_s
-{
+struct result_set_s {
int result_set_fd;
int result_set_row_count;
int result_set_col_count;
data_control_sql_step_next(result_set_cursor cursor)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_step_next((resultset_cursor*)cursor);
}
data_control_sql_step_last(result_set_cursor cursor)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_step_last((resultset_cursor*)cursor);
}
data_control_sql_step_first(result_set_cursor cursor)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_step_first((resultset_cursor*)cursor);
}
data_control_sql_step_previous(result_set_cursor cursor)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_step_previous((resultset_cursor*)cursor);
}
data_control_sql_get_column_count(result_set_cursor cursor)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_get_column_count((resultset_cursor*)cursor);
}
data_control_sql_get_column_name(result_set_cursor cursor, int column_index, char *name)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_get_column_name((resultset_cursor*)cursor, column_index, name);
}
data_control_sql_get_column_item_size(result_set_cursor cursor, int column_index)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_get_column_item_size((resultset_cursor*)cursor, column_index);
}
data_control_sql_get_column_item_type(result_set_cursor cursor, int column_index, data_control_sql_column_type_e* col_type)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_get_column_item_type((resultset_cursor*)cursor, column_index, (datacontrol_sql_column_type*)col_type);
}
data_control_sql_get_blob_data(result_set_cursor cursor, int column_index, void *buffer, int data_size)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_get_blob_data((resultset_cursor*)cursor, column_index, buffer, data_size);
}
data_control_sql_get_int_data(result_set_cursor cursor, int column_index, int *data)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_get_int_data((resultset_cursor*)cursor, column_index, data);
}
data_control_sql_get_int64_data(result_set_cursor cursor, int column_index, long long *data)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_get_int64_data((resultset_cursor*)cursor, column_index, data);
}
data_control_sql_get_double_data(result_set_cursor cursor, int column_index, double *data)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_get_double_data((resultset_cursor*)cursor, column_index, data);
}
data_control_sql_get_text_data(result_set_cursor cursor, int column_index, char *buffer)
{
if (cursor == NULL)
- {
return DATA_CONTROL_ERROR_INVALID_PARAMETER;
- }
return datacontrol_sql_get_text_data((resultset_cursor*)cursor, column_index, buffer);
}
projects / platform / core / appfw / data-control.git / commitdiff