"where payload_name = ?"
*/
+#define SELECT_PAYLOAD_DEVICE "SELECT device_number FROM payloads " \
+ "where primary_key = ? AND secondary_key = ? AND device_uid = ?"
+#define SELECT_PAYLOAD_NUMBER "SELECT payload_number FROM payloads " \
+ "where primary_key = ? AND secondary_key = ? AND device_uid = ?"
+
#define INSERT_PAYLOAD "insert into payloads (primary_key, " \
"secondary_key, device_uid, device_icon, device_number)" \
"values (?, ?, ?, ?, ?)"
/* SELECT statements */
//static sqlite3_stmt *select_all_payloads;
//static sqlite3_stmt *select_payload;
+static sqlite3_stmt *select_payload_device;
+static sqlite3_stmt *select_payload_number;
/* UPDATE statements */
//static sqlite3_stmt *update_cycle;
// FINALIZE(select_all_payloads);
// FINALIZE(select_payload);
+ FINALIZE(select_payload_device);
+ FINALIZE(select_payload_number);
FUNC_EXIT;
}
// SELECT_ALL_PAYLOADS, __uam_payload_finalize_select);
// PREPARE_QUERY(rc, db, select_payload,
// SELECT_PAYLOAD, __uam_payload_finalize_select);
+ PREPARE_QUERY(rc, db, select_payload_device,
+ SELECT_PAYLOAD_DEVICE, __uam_payload_finalize_select);
+ PREPARE_QUERY(rc, db, select_payload_number,
+ SELECT_PAYLOAD_NUMBER, __uam_payload_finalize_select);
initialized = 1;
FUNC_EXIT;
return error_code;
}
-/*
-int _uam_db_update_payload_info(uam_db_payload_info_t *svc)
+int _uam_db_get_payload_device_number(uam_ble_payload_s *payload,
+ int *device_number)
{
FUNC_ENTRY;
int error_code = UAM_ERROR_NONE;
- sqlite3_stmt *stmt = update_payload_info;
+ sqlite3_stmt *stmt = select_payload_device;
int sql_ret = SQLITE_OK;
- retv_if(NULL == svc->name, UAM_ERROR_INVALID_PARAMETER);
-
- UAM_INFO("%s-%d-%d-%d", svc->name, svc->cycle, svc->presence_threshold,
- svc->absence_threshold);
+ retv_if(NULL == payload, UAM_ERROR_INVALID_PARAMETER);
- DB_ACTION(sqlite3_bind_int(stmt, 1, svc->presence_threshold),
+ DB_ACTION(sqlite3_bind_text(stmt, 1, &(payload->primary_key), 1, SQLITE_TRANSIENT),
error_code, handle_error);
- DB_ACTION(sqlite3_bind_int(stmt, 2, svc->absence_threshold),
+ DB_ACTION(sqlite3_bind_text(stmt, 2, &(payload->secondary_key), 1, SQLITE_TRANSIENT),
error_code, handle_error);
- DB_ACTION(sqlite3_bind_text(stmt, 3, svc->name, -1, SQLITE_TRANSIENT),
+ DB_ACTION(sqlite3_bind_text(stmt, 3, payload->device_uid, UAM_BLE_PAYLOAD_DEVICE_UID_LEN + 1, SQLITE_TRANSIENT),
error_code, handle_error);
- sql_ret = sqlite3_step(stmt);
- if (sql_ret != SQLITE_DONE) {
- UAM_ERR("Failed to update payload info [%d:%s]",
- sql_ret, sqlite3_errmsg(database_handle));
- error_code = UAM_ERROR_DB_FAILED;
- goto handle_error;
- }
+ do {
+ sql_ret = sqlite3_step(stmt);
- UAM_DBG("Payload info updated");
+ switch (sql_ret) {
+ case SQLITE_DONE:
+ break;
+ case SQLITE_ROW:
+ UAM_DBG("Device number info found");
+ *device_number = sqlite3_column_int(stmt, 0);
+ UAM_INFO("device_number %d", *device_number);
+ break;
+ case SQLITE_ERROR:
+ default:
+ UAM_ERR("Failed to select payload device number [%d:%s]",
+ sql_ret, sqlite3_errmsg(database_handle));
+ }
+ } while (sql_ret == SQLITE_ROW);
handle_error:
sqlite3_reset(stmt);
return error_code;
}
-int _uam_db_delete_payload_info(const char *payload_name)
+int _uam_db_get_payload_number(uam_ble_payload_s *payload,
+ int *payload_number)
{
FUNC_ENTRY;
int error_code = UAM_ERROR_NONE;
- sqlite3_stmt *stmt = delete_payload_info;
+ sqlite3_stmt *stmt = select_payload_number;
int sql_ret = SQLITE_OK;
- error_code = _uam_db_delete_device_payload(payload_name);
- if (UAM_ERROR_NONE != error_code) {
- UAM_ERR("_uam_db_delete_device_payload failed");
- return error_code;
- }
+ retv_if(NULL == payload, UAM_ERROR_INVALID_PARAMETER);
- DB_ACTION(sqlite3_bind_text(stmt, 1, payload_name, -1, SQLITE_STATIC),
+ DB_ACTION(sqlite3_bind_text(stmt, 1, &(payload->primary_key), 1, SQLITE_TRANSIENT),
error_code, handle_error);
+ DB_ACTION(sqlite3_bind_text(stmt, 2, &(payload->secondary_key), 1, SQLITE_TRANSIENT),
+ error_code, handle_error);
+ DB_ACTION(sqlite3_bind_text(stmt, 3, payload->device_uid, UAM_BLE_PAYLOAD_DEVICE_UID_LEN + 1, SQLITE_TRANSIENT),
+ error_code, handle_error);
+
+ do {
+ sql_ret = sqlite3_step(stmt);
+
+ switch (sql_ret) {
+ case SQLITE_DONE:
+ break;
+ case SQLITE_ROW:
+ UAM_DBG("Payload number info found");
+ *payload_number = sqlite3_column_int(stmt, 0);
+ UAM_INFO("payload number: %d", *payload_number);
+ break;
+ case SQLITE_ERROR:
+ default:
+ UAM_ERR("Failed to select payload device number [%d:%s]",
+ sql_ret, sqlite3_errmsg(database_handle));
+ }
+ } while (sql_ret == SQLITE_ROW);
+
+handle_error:
+ sqlite3_reset(stmt);
+ FUNC_EXIT;
+ return error_code;
+}
+
+
+int _uam_payload_db_clear(void)
+{
+ int error_code = UAM_ERROR_NONE;
+ sqlite3_stmt *stmt = delete_all_payloads;
+ int sql_ret = SQLITE_OK;
sql_ret = sqlite3_step(stmt);
if (sql_ret != SQLITE_DONE) {
- UAM_ERR("Failed to delete payload info [%d:%s]",
+ UAM_ERR("Failed to delete payload data [%d:%s]",
sql_ret, sqlite3_errmsg(database_handle));
error_code = UAM_ERROR_DB_FAILED;
- } else
- UAM_DBG("Payload info deleted");
+ goto handle_error;
+ }
+
+ UAM_DBG("Payload data deleted ");
handle_error:
+
sqlite3_reset(stmt);
- FUNC_EXIT;
return error_code;
}
-int _uam_db_update_payload_cycle(const char *payload_name, int cycle)
+/*
+int _uam_db_update_payload_info(uam_db_payload_info_t *svc)
{
+ FUNC_ENTRY;
int error_code = UAM_ERROR_NONE;
- sqlite3_stmt *stmt = update_cycle;
+ sqlite3_stmt *stmt = update_payload_info;
int sql_ret = SQLITE_OK;
- retv_if(NULL == payload_name, UAM_ERROR_INVALID_PARAMETER);
+ retv_if(NULL == svc->name, UAM_ERROR_INVALID_PARAMETER);
- DB_ACTION(sqlite3_bind_int64(stmt, 1, cycle),
+ UAM_INFO("%s-%d-%d-%d", svc->name, svc->cycle, svc->presence_threshold,
+ svc->absence_threshold);
+
+ DB_ACTION(sqlite3_bind_int(stmt, 1, svc->presence_threshold),
error_code, handle_error);
- DB_ACTION(sqlite3_bind_text(stmt, 2, payload_name, -1, SQLITE_TRANSIENT),
+ DB_ACTION(sqlite3_bind_int(stmt, 2, svc->absence_threshold),
+ error_code, handle_error);
+ DB_ACTION(sqlite3_bind_text(stmt, 3, svc->name, -1, SQLITE_TRANSIENT),
error_code, handle_error);
sql_ret = sqlite3_step(stmt);
if (sql_ret != SQLITE_DONE) {
- UAM_ERR("Failed to update payload cycle [%d:%s]",
+ UAM_ERR("Failed to update payload info [%d:%s]",
sql_ret, sqlite3_errmsg(database_handle));
-
error_code = UAM_ERROR_DB_FAILED;
goto handle_error;
}
- UAM_DBG("Payload cycle updated [%d]", cycle);
+ UAM_DBG("Payload info updated");
handle_error:
sqlite3_reset(stmt);
+ FUNC_EXIT;
return error_code;
}
-int _uam_db_get_payload_info(const char *payload_name, db_payload_info_t *info)
+int _uam_db_delete_payload_info(const char *payload_name)
{
FUNC_ENTRY;
- int error_code = UAM_ERROR_NOT_FOUND;
- sqlite3_stmt *stmt = select_payload;
+ int error_code = UAM_ERROR_NONE;
+ sqlite3_stmt *stmt = delete_payload_info;
int sql_ret = SQLITE_OK;
- retv_if(!payload_name, UAM_ERROR_INVALID_PARAMETER);
- retv_if(!info, UAM_ERROR_INVALID_PARAMETER);
-
- UAM_INFO("Payload Name: %s", payload_name);
+ error_code = _uam_db_delete_device_payload(payload_name);
+ if (UAM_ERROR_NONE != error_code) {
+ UAM_ERR("_uam_db_delete_device_payload failed");
+ return error_code;
+ }
DB_ACTION(sqlite3_bind_text(stmt, 1, payload_name, -1, SQLITE_STATIC),
error_code, handle_error);
- do {
- sql_ret = sqlite3_step(stmt);
- switch (sql_ret) {
- case SQLITE_DONE:
- break;
- case SQLITE_ROW:
- UAM_DBG("Payload info found");
- info->payload_number = sqlite3_column_int(stmt, 0);
- g_strlcpy(info->payload_name, (char *)sqlite3_column_text(stmt, 1),
- UAM_PAYLOAD_MAX_STRING_LEN);
- info->cycle = sqlite3_column_int(stmt, 2);
- info->presence_threshold = sqlite3_column_int(stmt, 3);
- info->absence_threshold = sqlite3_column_int(stmt, 4);
-
- UAM_INFO("%d-%s-%d", info->payload_number, info->payload_name, info->cycle);
- error_code = UAM_ERROR_NONE;
- break;
- case SQLITE_ERROR:
- default:
- UAM_ERR("Failed to enumerate device info [%d:%s]",
- sql_ret, sqlite3_errmsg(database_handle));
- error_code = UAM_ERROR_DB_FAILED;
- }
- } while (sql_ret == SQLITE_ROW);
+ sql_ret = sqlite3_step(stmt);
+ if (sql_ret != SQLITE_DONE) {
+ UAM_ERR("Failed to delete payload info [%d:%s]",
+ sql_ret, sqlite3_errmsg(database_handle));
+ error_code = UAM_ERROR_DB_FAILED;
+ } else
+ UAM_DBG("Payload info deleted");
handle_error:
sqlite3_reset(stmt);
return payload_list;
}
*/
-
-int _uam_payload_db_clear(void)
-{
- int error_code = UAM_ERROR_NONE;
- sqlite3_stmt *stmt = delete_all_payloads;
- int sql_ret = SQLITE_OK;
-
- sql_ret = sqlite3_step(stmt);
- if (sql_ret != SQLITE_DONE) {
- UAM_ERR("Failed to delete payload data [%d:%s]",
- sql_ret, sqlite3_errmsg(database_handle));
- error_code = UAM_ERROR_DB_FAILED;
- goto handle_error;
- }
-
- UAM_DBG("Payload data deleted ");
-
-handle_error:
-
- sqlite3_reset(stmt);
- return error_code;
-}
projects / platform / core / connectivity / ua-manager.git / blobdiff