server/db/ctsvc_db_plugin_address_helper.c

   1 /*
   2  * Contacts Service
   3  *
   4  * Copyright (c) 2010 - 2015 Samsung Electronics Co., Ltd. All rights reserved.
   5  *
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  * http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  *
  18  */
  19 #include "contacts.h"
  20 #include "ctsvc_internal.h"
  21 #include "ctsvc_db_schema.h"
  22 #include "ctsvc_db_sqlite.h"
  23 #include "ctsvc_db_init.h"
  24 #include "ctsvc_db_query.h"
  25 #include "ctsvc_db_plugin_address_helper.h"
  26 #include "ctsvc_record.h"
  27 #include "ctsvc_notification.h"
  28
  29 int ctsvc_db_address_get_value_from_stmt(cts_stmt stmt, contacts_record_h *record, int start_count)
  30 {
  31         int ret;
  32         char *temp;
  33         ctsvc_address_s *address;
  34
  35         ret = contacts_record_create(_contacts_address._uri, (contacts_record_h*)&address);
  36         RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "contacts_record_create Fail(%d)", ret);
  37
  38         address->id = ctsvc_stmt_get_int(stmt, start_count++);
  39         address->contact_id = ctsvc_stmt_get_int(stmt, start_count++);
  40         address->is_default = ctsvc_stmt_get_int(stmt, start_count++);
  41         address->type = ctsvc_stmt_get_int(stmt, start_count++);
  42         temp = ctsvc_stmt_get_text(stmt, start_count++);
  43         address->label = SAFE_STRDUP(temp);
  44         temp = ctsvc_stmt_get_text(stmt, start_count++);
  45         address->pobox = SAFE_STRDUP(temp);
  46         temp = ctsvc_stmt_get_text(stmt, start_count++);
  47         address->postalcode = SAFE_STRDUP(temp);
  48         temp = ctsvc_stmt_get_text(stmt, start_count++);
  49         address->region = SAFE_STRDUP(temp);
  50         temp = ctsvc_stmt_get_text(stmt, start_count++);
  51         address->locality = SAFE_STRDUP(temp);
  52         temp = ctsvc_stmt_get_text(stmt, start_count++);
  53         address->street = SAFE_STRDUP(temp);
  54         temp = ctsvc_stmt_get_text(stmt, start_count++);
  55         address->extended = SAFE_STRDUP(temp);
  56         temp = ctsvc_stmt_get_text(stmt, start_count++);
  57         address->country = SAFE_STRDUP(temp);
  58
  59         *record = (contacts_record_h)address;
  60         return CONTACTS_ERROR_NONE;
  61 }
  62
  63 static int __ctsvc_db_address_reset_default(int address_id, int contact_id)
  64 {
  65         int ret;
  66         char query[CTS_SQL_MAX_LEN] = {0};
  67
  68         snprintf(query, sizeof(query),
  69                         "UPDATE "CTS_TABLE_DATA" SET is_default = 0, is_primary_default = 0 "
  70                         "WHERE id != %d AND contact_id = %d AND datatype = %d",
  71                         address_id, contact_id, CONTACTS_DATA_TYPE_POSTAL);
  72         ret = ctsvc_query_exec(query);
  73         WARN_IF(CONTACTS_ERROR_NONE != ret, "ctsvc_query_exec() Fail(%d)", ret);
  74         return ret;
  75 }
  76
  77 int ctsvc_db_address_insert(contacts_record_h record, int contact_id, bool is_my_profile, int *id)
  78 {
  79         int ret;
  80         int address_id;
  81         cts_stmt stmt = NULL;
  82         ctsvc_address_s *address = (ctsvc_address_s*)record;
  83         char query[CTS_SQL_MAX_LEN] = {0};
  84
  85         RETVM_IF(contact_id <= 0, CONTACTS_ERROR_INVALID_PARAMETER,
  86                         "contact_id(%d) is mandatory field to insert address record ", address->contact_id);
  87         RETVM_IF(0 < address->id, CONTACTS_ERROR_INVALID_PARAMETER,
  88                         "id(%d), This record is already inserted", address->id);
  89
  90         if (address->pobox || address->postalcode || address->region || address->locality
  91                         || address->street || address->extended || address->country) {
  92                 snprintf(query, sizeof(query),
  93                                 "INSERT INTO "CTS_TABLE_DATA"(contact_id, is_my_profile, datatype, is_default, data1, data2, data3, "
  94                                 "data4, data5, data6, data7, data8, data9) "
  95                                 "VALUES(%d, %d, %d, %d, %d, ?, ?, ?, ?, ?, ?, ?, ?)",
  96                                 contact_id, is_my_profile, CONTACTS_DATA_TYPE_POSTAL, address->is_default, address->type);
  97
  98                 ret = ctsvc_query_prepare(query, &stmt);
  99                 RETVM_IF(NULL == stmt, ret, "ctsvc_query_prepare() Fail(%d)", ret);
 100
 101                 if (address->label)
 102                         ctsvc_stmt_bind_text(stmt, 1, address->label);
 103                 if (address->pobox)
 104                         ctsvc_stmt_bind_text(stmt, 2, address->pobox);
 105                 if (address->postalcode)
 106                         ctsvc_stmt_bind_text(stmt, 3, address->postalcode);
 107                 if (address->region)
 108                         ctsvc_stmt_bind_text(stmt, 4, address->region);
 109                 if (address->locality)
 110                         ctsvc_stmt_bind_text(stmt, 5, address->locality);
 111                 if (address->street)
 112                         ctsvc_stmt_bind_text(stmt, 6, address->street);
 113                 if (address->extended)
 114                         ctsvc_stmt_bind_text(stmt, 7, address->extended);
 115                 if (address->country)
 116                         ctsvc_stmt_bind_text(stmt, 8, address->country);
 117
 118                 ret = ctsvc_stmt_step(stmt);
 119                 if (CONTACTS_ERROR_NONE != ret) {
 120                         /* LCOV_EXCL_START */
 121                         ERR("ctsvc_stmt_step() Fail(%d)", ret);
 122                         ctsvc_stmt_finalize(stmt);
 123                         return ret;
 124                         /* LCOV_EXCL_STOP */
 125                 }
 126                 address_id = ctsvc_db_get_last_insert_id();
 127                 if (id)
 128                         *id = address_id;
 129                 ctsvc_stmt_finalize(stmt);
 130
 131                 if (ctsvc_record_check_property_flag((ctsvc_record_s*)record, _contacts_address.is_default, CTSVC_PROPERTY_FLAG_DIRTY)) {
 132                         if (address->is_default)
 133                                 __ctsvc_db_address_reset_default(address_id, contact_id);
 134                 }
 135
 136                 if (false == is_my_profile)
 137                         ctsvc_set_address_noti();
 138         }
 139
 140         return CONTACTS_ERROR_NONE;
 141 }
 142
 143 int ctsvc_db_address_update(contacts_record_h record, bool is_my_profile)
 144 {
 145         int id;
 146         int ret = CONTACTS_ERROR_NONE;
 147         char *set = NULL;
 148         GSList *bind_text = NULL;
 149         GSList *cursor = NULL;
 150         ctsvc_address_s *address = (ctsvc_address_s*)record;
 151         char query[CTS_SQL_MAX_LEN] = {0};
 152
 153         RETVM_IF(address->id <= 0, CONTACTS_ERROR_INVALID_PARAMETER,
 154                         "id(%d), This record is already inserted", address->id);
 155         RETVM_IF(CTSVC_PROPERTY_FLAG_DIRTY != (address->base.property_flag & CTSVC_PROPERTY_FLAG_DIRTY), CONTACTS_ERROR_NONE, "No update");
 156         RETVM_IF(NULL == address->pobox && NULL == address->postalcode && address->region
 157                         && address->locality && address->street && address->extended && address->country,
 158                         CONTACTS_ERROR_INVALID_PARAMETER, "address is NULL");
 159
 160         snprintf(query, sizeof(query),
 161                         "SELECT id FROM "CTS_TABLE_DATA" WHERE id = %d", address->id);
 162         ret = ctsvc_query_get_first_int_result(query, &id);
 163         RETV_IF(ret != CONTACTS_ERROR_NONE, ret);
 164
 165         if (ctsvc_record_check_property_flag((ctsvc_record_s*)record, _contacts_address.is_default, CTSVC_PROPERTY_FLAG_DIRTY)) {
 166                 if (address->is_default)
 167                         __ctsvc_db_address_reset_default(address->id, address->contact_id);
 168         }
 169
 170         do {
 171                 if (CONTACTS_ERROR_NONE != (ret = ctsvc_db_create_set_query(record, &set, &bind_text))) break;
 172                 if (CONTACTS_ERROR_NONE != (ret = ctsvc_db_update_record_with_set_query(set, bind_text, CTS_TABLE_DATA, address->id))) break;
 173                 if (false == is_my_profile)
 174                         ctsvc_set_address_noti();
 175         } while (0);
 176
 177         CTSVC_RECORD_RESET_PROPERTY_FLAGS((ctsvc_record_s*)record);
 178         free(set);
 179
 180         if (bind_text) {
 181                 for (cursor = bind_text; cursor; cursor = cursor->next) {
 182                         free(cursor->data);
 183                         cursor->data = NULL;
 184                 }
 185                 g_slist_free(bind_text);
 186         }
 187
 188         return ret;
 189 }
 190
 191 int ctsvc_db_address_delete(int id, bool is_my_profile)
 192 {
 193         int ret;
 194         char query[CTS_SQL_MIN_LEN] = {0};
 195
 196         snprintf(query, sizeof(query), "DELETE FROM "CTS_TABLE_DATA" WHERE datatype = %d AND id = %d",
 197                         CONTACTS_DATA_TYPE_POSTAL, id);
 198
 199         ret = ctsvc_query_exec(query);
 200         RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "ctsvc_query_exec() Fail(%d)", ret);
 201
 202         if (false == is_my_profile)
 203                 ctsvc_set_address_noti();
 204
 205         return ret;
 206 }