static void ReplyAsync(int callbackId, bool isSuccess,
picojson::object* param) {
+ LoggerD("Enter");
(*param)["callbackId"] = picojson::value(static_cast<double>(callbackId));
(*param)["status"] = picojson::value(isSuccess ? "success" : "error");
static bool SQLColumnName(result_set_cursor cursor, int columnIndex,
picojson::value& name) {
+ LoggerD("Enter");
char buffer[4096];
int result = data_control_sql_get_column_name(cursor, columnIndex, buffer);
if (result != DATA_CONTROL_ERROR_NONE) {
static bool SQLColumnValue(result_set_cursor cursor, int columnIndex,
picojson::value& val) {
+ LoggerD("Enter");
data_control_sql_column_type_e type = DATA_CONTROL_SQL_COLUMN_TYPE_UNDEFINED;
int result =
data_control_sql_get_column_item_type(cursor, columnIndex, &type);
static void MAPAddResponseCallback(int requestId, data_control_h handle,
bool providerResult,
const char *error, void *user_data) {
+ LoggerD("Enter");
DatacontrolInformation *info = IdMap[requestId];
if (info == NULL) {
LoggerE("Invalid context");
static void MAPSetResponseCallback(int requestId, data_control_h handle,
bool providerResult,
const char *error, void *user_data) {
+ LoggerD("Enter");
DatacontrolInformation *info = IdMap[requestId];
if (info == NULL) {
LoggerE("Invalid context");
int result_value_count,
bool providerResult,
const char *error, void *user_data) {
+ LoggerD("Enter");
DatacontrolInformation *info = IdMap[requestId];
if (info == NULL) {
LoggerE("Invalid context");
static void MAPRemoveReponseCallback(int requestId, data_control_h handle,
bool providerResult,
const char *error, void *user_data) {
+ LoggerD("Enter");
DatacontrolInformation *info = IdMap[requestId];
if (info == NULL) {
LoggerE("Invalid context");
result_set_cursor cursor,
bool providerResult,
const char *error, void *user_data) {
+ LoggerD("Enter");
DatacontrolInformation *info = IdMap[requestId];
if (info == NULL) {
LoggerE("Invalid context");
int64_t inserted_row_id,
bool providerResult,
const char *error, void *user_data) {
+ LoggerD("Enter");
DatacontrolInformation *info = IdMap[requestId];
if (info == NULL) {
LoggerE("Invalid context");
static void SQLUpdateResponseCallback(int requestId, data_control_h handle,
bool providerResult,
const char *error, void *user_data) {
+ LoggerD("Enter");
DatacontrolInformation *info = IdMap[requestId];
if (info == NULL) {
LoggerE("Invalid context");
static void SQLDeleteResponseCallback(int requestId, data_control_h handle,
bool providerResult,
const char *error, void *user_data) {
+ LoggerD("Enter");
DatacontrolInformation *info = IdMap[requestId];
if (info == NULL) {
LoggerE("Invalid context");
int callbackId,
int userRequestId,
DataControlJob job) {
+ LoggerD("Enter");
int result = DATA_CONTROL_ERROR_NONE;
std::unique_ptr<DatacontrolInformation> info {new DatacontrolInformation()};
info->callbackId = callbackId;
int callbackId,
int userRequestId,
DataControlJob job) {
+ LoggerD("Enter");
int result = DATA_CONTROL_ERROR_NONE;
std::unique_ptr<DatacontrolInformation> info {new DatacontrolInformation()};
info->callbackId = callbackId;
void DatacontrolInstance::DataControlManagerGetdatacontrolconsumer(
const picojson::value& args, picojson::object& out) {
+ LoggerD("Enter");
CHECK_EXIST(args, "providerId", out)
CHECK_EXIST(args, "dataId", out)
}
void DatacontrolInstance::SQLDataControlConsumerInsert(
const picojson::value& args, picojson::object& out) {
+ LoggerD("Enter");
CHECK_EXIST(args, "callbackId", out)
CHECK_EXIST(args, "reqId", out)
CHECK_EXIST(args, "providerId", out)
}
void DatacontrolInstance::SQLDataControlConsumerUpdate(
const picojson::value& args, picojson::object& out) {
+ LoggerD("Enter");
CHECK_EXIST(args, "callbackId", out)
CHECK_EXIST(args, "reqId", out)
CHECK_EXIST(args, "where", out)
[&updateData, &where](
data_control_h& handle,
int *requestId) -> int {
+ LoggerD("Enter");
picojson::array columns = updateData["columns"].get<picojson::array>();
picojson::array values = updateData["values"].get<picojson::array>();
void DatacontrolInstance::SQLDataControlConsumerRemove(
const picojson::value& args, picojson::object& out) {
+ LoggerD("Enter");
CHECK_EXIST(args, "callbackId", out)
CHECK_EXIST(args, "reqId", out)
CHECK_EXIST(args, "where", out)
void DatacontrolInstance::SQLDataControlConsumerSelect(
const picojson::value& args, picojson::object& out) {
+ LoggerD("Enter");
CHECK_EXIST(args, "callbackId", out)
CHECK_EXIST(args, "reqId", out)
CHECK_EXIST(args, "columns", out)
[&columns, &where, page, maxNumberPerPage](
data_control_h& handle,
int *requestId) -> int {
+ LoggerD("Enter");
std::vector<const char*> temp;
for (auto& s : columns) temp.push_back(s.get<std::string>().c_str());
int columnCount = static_cast<int>(temp.size());
void DatacontrolInstance::MappedDataControlConsumerAddvalue(
const picojson::value& args,
picojson::object& out) {
+ LoggerD("Enter");
CHECK_EXIST(args, "callbackId", out)
CHECK_EXIST(args, "reqId", out)
CHECK_EXIST(args, "key", out)
}
void DatacontrolInstance::MappedDataControlConsumerRemovevalue(
const picojson::value& args, picojson::object& out) {
+ LoggerD("Enter");
CHECK_EXIST(args, "callbackId", out)
CHECK_EXIST(args, "reqId", out)
CHECK_EXIST(args, "key", out)
}
void DatacontrolInstance::MappedDataControlConsumerGetvalue(
const picojson::value& args, picojson::object& out) {
+ LoggerD("Enter");
CHECK_EXIST(args, "callbackId", out)
CHECK_EXIST(args, "reqId", out)
CHECK_EXIST(args, "key", out)
}
void DatacontrolInstance::MappedDataControlConsumerUpdatevalue(
const picojson::value& args, picojson::object& out) {
+ LoggerD("Enter");
CHECK_EXIST(args, "callbackId", out)
CHECK_EXIST(args, "reqId", out)
CHECK_EXIST(args, "key", out)