4 * Copyright (c) 2010 - 2015 Samsung Electronics Co., Ltd. All rights reserved.
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
10 * http://www.apache.org/licenses/LICENSE-2.0
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.
20 #include "ctsvc_internal.h"
21 #include "ctsvc_db_schema.h"
22 #include "ctsvc_db_sqlite.h"
23 #include "ctsvc_normalize.h"
24 #include "ctsvc_localize_utils.h"
25 #include "ctsvc_db_init.h"
26 #include "ctsvc_db_query.h"
27 #include "ctsvc_db_plugin_name_helper.h"
28 #include "ctsvc_record.h"
29 #include "ctsvc_server_setting.h"
30 #include "ctsvc_notification.h"
38 static inline void __ctsvc_make_name_lookup(int op_code, const char *name_first,
39 const char *name_last, char **name_lookup)
41 if (name_first && NULL == name_last) {
42 *name_lookup = SAFE_STRDUP(name_first);
43 } else if (NULL == name_first && name_last) {
44 *name_lookup = SAFE_STRDUP(name_last);
46 if (CONTACTS_NAME_DISPLAY_ORDER_FIRSTLAST == op_code) {
47 *name_lookup = calloc(1, SAFE_STRLEN(name_first) + SAFE_STRLEN(name_last) + 3);
48 if (NULL == *name_lookup) {
52 snprintf(*name_lookup, SAFE_STRLEN(name_first) + SAFE_STRLEN(name_last) + 3, "%s %c%s",
53 SAFE_STR(name_first), 0x7E, SAFE_STR(name_last));
55 *name_lookup = calloc(1, SAFE_STRLEN(name_first) + SAFE_STRLEN(name_last) + 5);
56 if (NULL == *name_lookup) {
60 snprintf(*name_lookup, SAFE_STRLEN(name_first) + SAFE_STRLEN(name_last) + 5, "%s,%c %c%s",
61 SAFE_STR(name_last), 0x7E, 0x7E, SAFE_STR(name_first));
66 static inline int __ctsvc_name_bind_stmt(cts_stmt stmt, ctsvc_name_s *name, int start_cnt)
68 ctsvc_stmt_bind_int(stmt, start_cnt, name->is_default);
69 ctsvc_stmt_bind_int(stmt, start_cnt+1, name->language_type);
71 sqlite3_bind_text(stmt, start_cnt+2, name->first,
72 strlen(name->first), SQLITE_STATIC);
74 sqlite3_bind_text(stmt, start_cnt+3, name->last,
75 strlen(name->last), SQLITE_STATIC);
77 sqlite3_bind_text(stmt, start_cnt+4, name->addition,
78 strlen(name->addition), SQLITE_STATIC);
80 sqlite3_bind_text(stmt, start_cnt+5, name->prefix,
81 strlen(name->prefix), SQLITE_STATIC);
83 sqlite3_bind_text(stmt, start_cnt+6, name->suffix,
84 strlen(name->suffix), SQLITE_STATIC);
85 if (name->phonetic_first)
86 sqlite3_bind_text(stmt, start_cnt+7, name->phonetic_first,
87 strlen(name->phonetic_first), SQLITE_STATIC);
88 if (name->phonetic_middle)
89 sqlite3_bind_text(stmt, start_cnt+8, name->phonetic_middle,
90 strlen(name->phonetic_middle), SQLITE_STATIC);
91 if (name->phonetic_last)
92 sqlite3_bind_text(stmt, start_cnt+9, name->phonetic_last,
93 strlen(name->phonetic_last), SQLITE_STATIC);
95 sqlite3_bind_text(stmt, start_cnt+10, name->lookup,
96 strlen(name->lookup), SQLITE_STATIC);
97 if (name->reverse_lookup)
98 sqlite3_bind_text(stmt, start_cnt+11, name->reverse_lookup,
99 strlen(name->reverse_lookup), SQLITE_STATIC);
100 return CONTACTS_ERROR_NONE;
103 static int __ctsvc_normalize_name(ctsvc_name_s *src, char *dest[])
105 int ret = CONTACTS_ERROR_NO_DATA;
106 int language_type = 0;
109 ret = ctsvc_normalize_str(src->first, &dest[CTSVC_NN_FIRST]);
110 RETVM_IF(ret < CONTACTS_ERROR_NONE, ret, "ctsvc_normalize_str() Fail(%d)", ret);
115 ret = ctsvc_normalize_str(src->last, &dest[CTSVC_NN_LAST]);
116 RETVM_IF(ret < CONTACTS_ERROR_NONE, ret, "ctsvc_normalize_str() Fail(%d)", ret);
117 if (language_type < ret)
120 return language_type;
123 int ctsvc_db_name_insert(contacts_record_h record, int contact_id, bool is_my_profile, int *id)
126 cts_stmt stmt = NULL;
127 ctsvc_name_s *name = (ctsvc_name_s*)record;
128 char query[CTS_SQL_MAX_LEN] = {0};
129 char *normal_name[CTSVC_NN_MAX] = {NULL}; /* insert name search info */
130 char *temp_normal_first = NULL;
131 char *temp_normal_last = NULL;
132 int len_normal_first = 0;
133 int len_normal_last = 0;
135 RETV_IF(NULL == name, CONTACTS_ERROR_INVALID_PARAMETER);
137 RETVM_IF(contact_id <= 0, CONTACTS_ERROR_INVALID_PARAMETER,
138 "contact_id(%d) is mandatory field to insert name record ", name->contact_id);
139 RETVM_IF(0 < name->id, CONTACTS_ERROR_INVALID_PARAMETER,
140 "id(%d), This record is already inserted", name->id);
142 if (name->first || name->last || name->addition || name->prefix || name->suffix
143 || name->phonetic_first || name->phonetic_middle || name->phonetic_last) {
145 * If name record already exists, delete current name record
146 * If user update record with out-of-date record, name record can be two
148 snprintf(query, sizeof(query),
149 "DELETE FROM "CTS_TABLE_DATA" "
150 "WHERE contact_id = %d AND datatype=%d "
151 "AND is_my_profile = %d",
152 contact_id, CTSVC_DATA_NAME, is_my_profile);
153 ret = ctsvc_query_exec(query);
154 if (CONTACTS_ERROR_NONE != ret) {
155 ERR("ctsvc_query_exec() Faild(%d)", ret);
159 snprintf(query, sizeof(query),
160 "INSERT INTO "CTS_TABLE_DATA"(contact_id, is_my_profile, datatype, is_default, data1, data2, data3, "
161 "data4, data5, data6, data7, data8, data9, data10, data11, data12) "
162 "VALUES(%d, %d, %d, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)",
163 contact_id, is_my_profile, CTSVC_DATA_NAME);
165 ret = ctsvc_query_prepare(query, &stmt);
166 RETVM_IF(NULL == stmt, ret, "ctsvc_query_prepare() Fail(%d)", ret);
168 ret = __ctsvc_normalize_name(name, normal_name);
169 WARN_IF(ret < CONTACTS_ERROR_NONE, "__ctsvc_normalize_name() Fail(%d)", ret);
172 case CTSVC_LANG_KOREAN:
173 len_normal_first = SAFE_STRLEN(normal_name[CTSVC_NN_FIRST]);
174 len_normal_last = SAFE_STRLEN(normal_name[CTSVC_NN_LAST]);
175 temp_normal_first = calloc(1, len_normal_first + len_normal_last + 1);
176 if (normal_name[CTSVC_NN_LAST]) {
177 len = snprintf(temp_normal_first, len_normal_first + len_normal_last + 1,
178 "%s", normal_name[CTSVC_NN_LAST]);
180 if (normal_name[CTSVC_NN_FIRST]) {
181 snprintf(temp_normal_first+len, len_normal_first + len_normal_last + 1 - len,
182 "%s", normal_name[CTSVC_NN_FIRST]);
184 temp_normal_last = NULL;
186 case CTSVC_LANG_ENGLISH:
188 if (normal_name[CTSVC_NN_FIRST] && normal_name[CTSVC_NN_FIRST][0])
189 temp_normal_first = SAFE_STRDUP(normal_name[CTSVC_NN_FIRST]);
191 if (normal_name[CTSVC_NN_LAST] && normal_name[CTSVC_NN_LAST][0])
192 temp_normal_last = SAFE_STRDUP(normal_name[CTSVC_NN_LAST]);
198 if (ctsvc_get_primary_sort() == ret)
199 name->language_type = CTSVC_LANG_DEFAULT;
200 else if (ctsvc_get_secondary_sort() == ret)
201 name->language_type = CTSVC_LANG_SECONDARY;
203 name->language_type = ret;
206 __ctsvc_make_name_lookup(CONTACTS_NAME_DISPLAY_ORDER_FIRSTLAST,
207 temp_normal_first, temp_normal_last, &name->lookup);
209 __ctsvc_make_name_lookup(CONTACTS_NAME_DISPLAY_ORDER_LASTFIRST,
210 temp_normal_first, temp_normal_last, &name->reverse_lookup);
212 free(temp_normal_first);
213 free(temp_normal_last);
214 free(normal_name[CTSVC_NN_FIRST]);
215 free(normal_name[CTSVC_NN_LAST]);
217 __ctsvc_name_bind_stmt(stmt, name, 1);
219 ret = ctsvc_stmt_step(stmt);
220 if (CONTACTS_ERROR_NONE != ret) {
221 ERR("ctsvc_stmt_step() Fail(%d)", ret);
222 ctsvc_stmt_finalize(stmt);
226 /* name->id = ctsvc_db_get_last_insert_id(); */
228 *id = ctsvc_db_get_last_insert_id();
229 name->contact_id = contact_id;
230 ctsvc_stmt_finalize(stmt);
232 if (false == is_my_profile)
233 ctsvc_set_name_noti();
236 /* update search index table */
237 return CONTACTS_ERROR_NONE;
241 int ctsvc_db_name_get_value_from_stmt(cts_stmt stmt, contacts_record_h *record, int start_count)
247 ret = contacts_record_create(_contacts_name._uri, (contacts_record_h*)&name);
248 RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "contacts_record_create Fail(%d)", ret);
250 name->id = ctsvc_stmt_get_int(stmt, start_count++);
251 name->contact_id = ctsvc_stmt_get_int(stmt, start_count++);
252 name->is_default = ctsvc_stmt_get_int(stmt, start_count++);
253 name->language_type = ctsvc_stmt_get_int(stmt, start_count++);
254 temp = ctsvc_stmt_get_text(stmt, start_count++);
255 name->first = SAFE_STRDUP(temp);
256 temp = ctsvc_stmt_get_text(stmt, start_count++);
257 name->last = SAFE_STRDUP(temp);
258 temp = ctsvc_stmt_get_text(stmt, start_count++);
259 name->addition = SAFE_STRDUP(temp);
260 temp = ctsvc_stmt_get_text(stmt, start_count++);
261 name->prefix = SAFE_STRDUP(temp);
262 temp = ctsvc_stmt_get_text(stmt, start_count++);
263 name->suffix = SAFE_STRDUP(temp);
264 temp = ctsvc_stmt_get_text(stmt, start_count++);
265 name->phonetic_first = SAFE_STRDUP(temp);
266 temp = ctsvc_stmt_get_text(stmt, start_count++);
267 name->phonetic_middle = SAFE_STRDUP(temp);
268 temp = ctsvc_stmt_get_text(stmt, start_count++);
269 name->phonetic_last = SAFE_STRDUP(temp);
270 temp = ctsvc_stmt_get_text(stmt, start_count++);
271 name->lookup = SAFE_STRDUP(temp);
272 temp = ctsvc_stmt_get_text(stmt, start_count++);
273 name->reverse_lookup = SAFE_STRDUP(temp);
275 *record = (contacts_record_h)name;
277 return CONTACTS_ERROR_NONE;
280 int ctsvc_db_name_update(contacts_record_h record, bool is_my_profile)
285 GSList *cursor = NULL;
286 GSList *bind_text = NULL;
287 ctsvc_name_s *name = (ctsvc_name_s*)record;
288 char *tmp_first, *tmp_last;
289 char *normal_name[CTSVC_NN_MAX] = {NULL};
290 char *temp_normal_first = NULL;
291 char *temp_normal_last = NULL;
292 char query[CTS_SQL_MIN_LEN] = {0};
294 RETVM_IF(0 == name->id, CONTACTS_ERROR_INVALID_PARAMETER, "name of contact has no ID.");
295 RETVM_IF(CTSVC_PROPERTY_FLAG_DIRTY != (name->base.property_flag & CTSVC_PROPERTY_FLAG_DIRTY), CONTACTS_ERROR_NONE, "No update");
297 snprintf(query, sizeof(query),
298 "SELECT id FROM "CTS_TABLE_DATA" WHERE id = %d", name->id);
299 ret = ctsvc_query_get_first_int_result(query, &id);
300 RETV_IF(ret != CONTACTS_ERROR_NONE, ret);
302 tmp_first = name->first;
303 tmp_last = name->last;
305 ret = __ctsvc_normalize_name(name, normal_name);
306 if (ret < CONTACTS_ERROR_NONE) {
307 ERR("cts_normalize_name() Fail(%d)", ret);
312 case CTSVC_LANG_KOREAN:
313 temp_normal_first = calloc(1, SAFE_STRLEN(normal_name[CTSVC_NN_LAST]) + SAFE_STRLEN(normal_name[CTSVC_NN_LAST]) + 1);
314 if (normal_name[CTSVC_NN_LAST]) {
315 len = snprintf(temp_normal_first, SAFE_STRLEN(normal_name[CTSVC_NN_LAST]) + SAFE_STRLEN(normal_name[CTSVC_NN_LAST]) + 1,
316 "%s", normal_name[CTSVC_NN_LAST]);
318 if (normal_name[CTSVC_NN_FIRST]) {
319 snprintf(temp_normal_first+len, SAFE_STRLEN(normal_name[CTSVC_NN_LAST]) + SAFE_STRLEN(normal_name[CTSVC_NN_LAST]) + 1 - len,
320 "%s", normal_name[CTSVC_NN_FIRST]);
322 temp_normal_last = NULL;
324 case CTSVC_LANG_ENGLISH:
326 if (normal_name[CTSVC_NN_FIRST] && normal_name[CTSVC_NN_FIRST][0])
327 temp_normal_first = SAFE_STRDUP(normal_name[CTSVC_NN_FIRST]);
331 if (normal_name[CTSVC_NN_LAST] && normal_name[CTSVC_NN_LAST][0])
332 temp_normal_last = SAFE_STRDUP(normal_name[CTSVC_NN_LAST]);
338 if (ctsvc_get_primary_sort() == ret)
339 name->language_type = CTSVC_LANG_DEFAULT;
340 else if (ctsvc_get_secondary_sort() == ret)
341 name->language_type = CTSVC_LANG_SECONDARY;
343 name->language_type = ret;
345 name->first = tmp_first;
346 name->last = tmp_last;
348 __ctsvc_make_name_lookup(CONTACTS_NAME_DISPLAY_ORDER_FIRSTLAST,
349 temp_normal_first, temp_normal_last, &name->lookup);
351 __ctsvc_make_name_lookup(CONTACTS_NAME_DISPLAY_ORDER_LASTFIRST,
352 temp_normal_first, temp_normal_last, &name->reverse_lookup);
354 free(temp_normal_first);
355 free(temp_normal_last);
356 free(normal_name[CTSVC_NN_FIRST]);
357 free(normal_name[CTSVC_NN_LAST]);
360 char query_set[CTS_SQL_MAX_LEN] = {0};
361 if (CONTACTS_ERROR_NONE != (ret = ctsvc_db_create_set_query(record, &set, &bind_text))) break;
362 snprintf(query_set, sizeof(query_set), "%s, is_default=%d, data1=%d, data11=?, data12=?",
363 set, name->is_default, name->language_type);
364 bind_text = g_slist_append(bind_text, strdup(SAFE_STR(name->lookup)));
365 bind_text = g_slist_append(bind_text, strdup(SAFE_STR(name->reverse_lookup)));
366 if (CONTACTS_ERROR_NONE != (ret = ctsvc_db_update_record_with_set_query(query_set, bind_text, CTS_TABLE_DATA, name->id))) break;
368 if (false == is_my_profile)
369 ctsvc_set_name_noti();
372 CTSVC_RECORD_RESET_PROPERTY_FLAGS((ctsvc_record_s*)record);
376 for (cursor = bind_text; cursor; cursor = cursor->next) {
380 g_slist_free(bind_text);
383 return CONTACTS_ERROR_NONE;
386 int ctsvc_db_name_delete(int id, bool is_my_profile)
389 char query[CTS_SQL_MIN_LEN] = {0};
391 snprintf(query, sizeof(query), "DELETE FROM "CTS_TABLE_DATA" WHERE id = %d", id);
393 ret = ctsvc_query_exec(query);
394 RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "ctsvc_query_exec() Fail(%d)", ret);
396 if (false == is_my_profile)
397 ctsvc_set_name_noti();
399 return CONTACTS_ERROR_NONE;