diff options
Diffstat (limited to 'native/ctsvc_db_init.c')
| -rw-r--r-- | native/ctsvc_db_init.c | 896 |
1 files changed, 896 insertions, 0 deletions
diff --git a/native/ctsvc_db_init.c b/native/ctsvc_db_init.c new file mode 100644 index 0000000..1d0441c --- /dev/null +++ b/native/ctsvc_db_init.c @@ -0,0 +1,896 @@ +/* + * Contacts Service + * + * Copyright (c) 2010 - 2012 Samsung Electronics Co., Ltd. All rights reserved. + * + * Contact: Dohyung Jin <dh.jin@samsung.com> + * Jongwon Lee <gogosing.lee@samsung.com> + * Donghee Ye <donghee.ye@samsung.com> + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ +#include <glib.h> + +#include "contacts.h" +#include "ctsvc_internal.h" +#include "ctsvc_schema.h" +#include "ctsvc_sqlite.h" +#include "ctsvc_db_init.h" +#include "ctsvc_utils.h" +#include "ctsvc_restriction.h" +#include "ctsvc_view.h" +#include "ctsvc_notification.h" + +#define MODULE_NAME_DB "DB" + +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_addressbook; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_contact; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_my_profile; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_simple_contact; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_group; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_person; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_phonelog; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_speeddial; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_sdn; + +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_activity; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_address; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_company; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_email; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_event; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_grouprelation; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_relationship; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_image; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_messenger; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_name; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_nickname; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_note; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_number; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_url; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_extension; +extern ctsvc_db_plugin_info_s ctsvc_db_plugin_profile; + + +static GHashTable *__ctsvc_db_view_hash_table = NULL; + +#ifdef _CONTACTS_IPC_SERVER +static bool __ctsvc_db_view_already_created = false; +#endif + +typedef struct { + char *view_uri; + const char * const table_name; +}db_table_info_s; + +static const db_table_info_s __db_tables[] = { + {CTSVC_VIEW_URI_ADDRESSBOOK, CTS_TABLE_ADDRESSBOOKS}, + {CTSVC_VIEW_URI_GROUP, CTS_TABLE_GROUPS}, + {CTSVC_VIEW_URI_PERSON, CTSVC_DB_VIEW_PERSON}, + {CTSVC_VIEW_URI_SIMPLE_CONTACT, CTSVC_DB_VIEW_CONTACT}, + {CTSVC_VIEW_URI_CONTACT, CTSVC_DB_VIEW_CONTACT}, + {CTSVC_VIEW_URI_MY_PROFILE, CTS_TABLE_MY_PROFILES}, + {CTSVC_VIEW_URI_ACTIVITY, CTSVC_DB_VIEW_ACTIVITY}, + {CTSVC_VIEW_URI_PHONELOG, CTS_TABLE_PHONELOGS}, + {CTSVC_VIEW_URI_SPEEDDIAL, CTSVC_DB_VIEW_SPEEDIDAL}, + {CTSVC_VIEW_URI_SDN, CTS_TABLE_SDN}, + + {CTSVC_VIEW_URI_NAME, CTSVC_DB_VIEW_NAME}, + {CTSVC_VIEW_URI_COMPANY, CTSVC_DB_VIEW_COMPANY}, + {CTSVC_VIEW_URI_NUMBER, CTSVC_DB_VIEW_NUMBER}, + {CTSVC_VIEW_URI_EMAIL, CTSVC_DB_VIEW_EMAIL}, + {CTSVC_VIEW_URI_URL, CTSVC_DB_VIEW_URL}, + {CTSVC_VIEW_URI_ADDRESS, CTSVC_DB_VIEW_ADDRESS}, + {CTSVC_VIEW_URI_PROFILE, CTSVC_DB_VIEW_PROFILE}, + {CTSVC_VIEW_URI_RELATIONSHIP, CTSVC_DB_VIEW_RELATIONSHIP}, + {CTSVC_VIEW_URI_IMAGE, CTSVC_DB_VIEW_IMAGE}, + {CTSVC_VIEW_URI_NOTE, CTSVC_DB_VIEW_NOTE}, + {CTSVC_VIEW_URI_NICKNAME, CTSVC_DB_VIEW_NICKNAME}, + {CTSVC_VIEW_URI_EVENT, CTSVC_DB_VIEW_EVENT}, + {CTSVC_VIEW_URI_MESSENGER, CTSVC_DB_VIEW_MESSENGER}, + {CTSVC_VIEW_URI_GROUP_RELATION, CTSVC_DB_VIEW_GROUP_RELATION}, + {CTSVC_VIEW_URI_EXTENSION, CTSVC_DB_VIEW_EXTENSION}, + +// Do not support get_all_records, get_records_with_query, get_count, get_count_with_query +// {CTSVC_VIEW_URI_GROUPS_UPDATED_INFO, CTSVC_DB_VIEW_GROUPS_UPDATED_INFO}, +// {CTSVC_VIEW_URI_GROUPS_MEMBER_UPDATED_INFO, CTSVC_DB_VIEW_GROUPS_MEMBER_UPDATED_INFO}, +// {CTSVC_VIEW_URI_CONTACTS_UPDATED_INFO, CTSVC_DB_VIEW_CONTACTS_UPDATED_INFO}, +// {CTSVC_VIEW_URI_GROUPRELS_UPDATED_INFO, NULL, NULL}, + + {CTSVC_VIEW_URI_READ_ONLY_PERSON_CONTACT, CTSVC_DB_VIEW_PERSON_CONTACT}, + {CTSVC_VIEW_URI_READ_ONLY_PERSON_NUMBER, CTSVC_DB_VIEW_PERSON_NUMBER}, + {CTSVC_VIEW_URI_READ_ONLY_PERSON_EMAIL, CTSVC_DB_VIEW_PERSON_EMAIL}, + {CTSVC_VIEW_URI_READ_ONLY_PERSON_GROUP, CTSVC_DB_VIEW_PERSON_GROUP}, + {CTSVC_VIEW_URI_READ_ONLY_PERSON_PHONELOG, CTSVC_DB_VIEW_PERSON_PHONELOG}, + {CTSVC_VIEW_URI_READ_ONLY_PERSON_USAGE, CTSVC_DB_VIEW_PERSON_USAGE}, + + {CTSVC_VIEW_URI_READ_ONLY_CONTACT_NUMBER, CTSVC_DB_VIEW_CONTACT_NUMBER}, + {CTSVC_VIEW_URI_READ_ONLY_CONTACT_EMAIL, CTSVC_DB_VIEW_CONTACT_EMAIL}, + {CTSVC_VIEW_URI_READ_ONLY_CONTACT_GROUP, CTSVC_DB_VIEW_CONTACT_GROUP}, + {CTSVC_VIEW_URI_READ_ONLY_CONTACT_ACTIVITY, CTSVC_DB_VIEW_CONTACT_ACTIVITY}, + + {CTSVC_VIEW_URI_READ_ONLY_PHONELOG_NUMBER, CTSVC_DB_VIEW_PHONELOG_NUMBER}, + {CTSVC_VIEW_URI_READ_ONLY_PHONELOG_STAT, CTS_TABLE_PHONELOG_STAT}, +}; + +// this function is called in mutex lock +int ctsvc_db_plugin_init() +{ + int i; +// pims_ipc_svc_init("/opt/CONTACT_SVC", getuid(), 0660); + + if (__ctsvc_db_view_hash_table) { + return CONTACTS_ERROR_NONE; + } + + __ctsvc_db_view_hash_table = g_hash_table_new(g_str_hash, g_str_equal); + + if (__ctsvc_db_view_hash_table) { + i = 0; + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_ADDRESSBOOK, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_GROUP, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_PERSON, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_SIMPLE_CONTACT, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_CONTACT, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_MY_PROFILE, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_ACTIVITY, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_PHONELOG, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_SPEEDDIAL, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_SDN, GINT_TO_POINTER(&(__db_tables[i++]))); + + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_NAME, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_COMPANY, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_NUMBER, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_EMAIL, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_URL, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_ADDRESS, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_PROFILE, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_RELATIONSHIP, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_IMAGE, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_NOTE, GINT_TO_POINTER(&(__db_tables[i++])) ); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_NICKNAME, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_EVENT, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_MESSENGER, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_GROUP_RELATION, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_EXTENSION, GINT_TO_POINTER(&(__db_tables[i++]))); + +// g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_GROUPS_UPDATED_INFO, GINT_TO_POINTER(&(__db_tables[i++])) ); +// g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_GROUPS_MEMBER_UPDATED_INFO, GINT_TO_POINTER(&(__db_tables[i++])) ); +// g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_CONTACTS_UPDATED_INFO, GINT_TO_POINTER(&(__db_tables[i++])) ); +// g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_GROUPRELS_UPDATED_INFO, GINT_TO_POINTER(&(__db_tables[i++])) ); + + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_PERSON_CONTACT, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_PERSON_NUMBER, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_PERSON_EMAIL, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_PERSON_GROUP, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_PERSON_PHONELOG, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_PERSON_USAGE, GINT_TO_POINTER(&(__db_tables[i++]))); + + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_CONTACT_NUMBER, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_CONTACT_EMAIL, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_CONTACT_GROUP, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_CONTACT_ACTIVITY, GINT_TO_POINTER(&(__db_tables[i++]))); + + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_PHONELOG_NUMBER, GINT_TO_POINTER(&(__db_tables[i++]))); + g_hash_table_insert(__ctsvc_db_view_hash_table, CTSVC_VIEW_URI_READ_ONLY_PHONELOG_STAT, GINT_TO_POINTER(&(__db_tables[i++]))); + } + return CONTACTS_ERROR_NONE; +} + +int ctsvc_db_plugin_deinit() +{ + if (!__ctsvc_db_view_hash_table) { + return CONTACTS_ERROR_NONE; + } + g_hash_table_destroy(__ctsvc_db_view_hash_table); + __ctsvc_db_view_hash_table = NULL; + + return CONTACTS_ERROR_NONE; +} + +int ctsvc_db_get_table_name(const char *view_uri, const char **out_table) +{ + db_table_info_s* db_view_info = NULL; + + if(__ctsvc_db_view_hash_table){ + db_view_info = g_hash_table_lookup(__ctsvc_db_view_hash_table, view_uri); + if (db_view_info) { + *out_table = db_view_info->table_name; + return CONTACTS_ERROR_NONE; + } + } + else + CTS_ERR("Please check contact_connect2()"); + + return CONTACTS_ERROR_INVALID_PARAMETER; +} + +ctsvc_db_plugin_info_s* ctsvc_db_get_plugin_info(ctsvc_record_type_e type) +{ + switch((int)type) { + case CTSVC_RECORD_ADDRESSBOOK: + return &ctsvc_db_plugin_addressbook; + case CTSVC_RECORD_GROUP: + return &ctsvc_db_plugin_group; + case CTSVC_RECORD_PERSON: + return &ctsvc_db_plugin_person; + case CTSVC_RECORD_CONTACT: + return &ctsvc_db_plugin_contact; + case CTSVC_RECORD_SIMPLE_CONTACT: + return &ctsvc_db_plugin_simple_contact; + case CTSVC_RECORD_NAME: + return &ctsvc_db_plugin_name; + case CTSVC_RECORD_COMPANY: + return &ctsvc_db_plugin_company; + case CTSVC_RECORD_NOTE: + return &ctsvc_db_plugin_note; + case CTSVC_RECORD_NUMBER: + return &ctsvc_db_plugin_number; + case CTSVC_RECORD_EMAIL: + return &ctsvc_db_plugin_email; + case CTSVC_RECORD_URL: + return &ctsvc_db_plugin_url; + case CTSVC_RECORD_EVENT: + return &ctsvc_db_plugin_event; + case CTSVC_RECORD_NICKNAME: + return &ctsvc_db_plugin_nickname; + case CTSVC_RECORD_ADDRESS: + return &ctsvc_db_plugin_address; + case CTSVC_RECORD_MESSENGER: + return &ctsvc_db_plugin_messenger; + case CTSVC_RECORD_GROUP_RELATION: + return &ctsvc_db_plugin_grouprelation; + case CTSVC_RECORD_ACTIVITY: + return &ctsvc_db_plugin_activity; + case CTSVC_RECORD_PROFILE: + return &ctsvc_db_plugin_profile; + case CTSVC_RECORD_RELATIONSHIP: + return &ctsvc_db_plugin_relationship; + case CTSVC_RECORD_IMAGE: + return &ctsvc_db_plugin_image; + case CTSVC_RECORD_EXTENSION: + return &ctsvc_db_plugin_extension; + case CTSVC_RECORD_PHONELOG: + return &ctsvc_db_plugin_phonelog; + case CTSVC_RECORD_SPEEDDIAL: + return &ctsvc_db_plugin_speeddial; + case CTSVC_RECORD_SDN: + return &ctsvc_db_plugin_sdn; + case CTSVC_RECORD_UPDATED_INFO: + case CTSVC_RECORD_RESULT: + default: + return NULL; + } +} + +#ifdef _CONTACTS_IPC_SERVER +static int __ctsvc_db_create_views() +{ + int ret; + char query[CTS_SQL_MAX_LEN] = {0}; + + if( __ctsvc_db_view_already_created ) + return CONTACTS_ERROR_NONE; + + // CTSVC_DB_VIEW_CONTACT + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_CONTACT" AS " + "SELECT * FROM "CTS_TABLE_CONTACTS" WHERE deleted = 0"); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_PERSON + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_PERSON" AS " + "SELECT persons.person_id, " + "display_name, reverse_display_name, " + "display_name_language, " + "sortkey, reverse_sortkey, " + "name_contact_id, " + "persons.ringtone_path, " + "persons.image_thumbnail_path, " + "persons.vibration, " + "status, " + "link_count, " + "account_id1, " + "account_id2, " + "account_id3, " + "addressbook_ids, " + "persons.has_phonenumber, " + "persons.has_email, " + "EXISTS(SELECT person_id FROM "CTS_TABLE_FAVORITES" WHERE person_id=persons.person_id) is_favorite, " + "(SELECT favorite_prio FROM "CTS_TABLE_FAVORITES" WHERE person_id=persons.person_id) favorite_prio " + "FROM "CTS_TABLE_CONTACTS", "CTS_TABLE_PERSONS" " + "ON (name_contact_id = contacts.contact_id) "); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_NAME + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_NAME" AS " + "SELECT id, " + "data.contact_id, " + "data2 first, " + "data3 last, " + "data4 addition, " + "data5 prefix, " + "data6 suffix, " + "data7 phonetic_first, " + "data8 phonetic_middle, " + "data9 phonetic_last " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_NAME); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_NUMBER + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_NUMBER" AS " + "SELECT id, " + "data.contact_id, " + "is_default, " + "data1 type, " + "data2 label, " + "data3 number, " + "data4 lookup " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_NUMBER); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_EMAIL + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_EMAIL" AS " + "SELECT id, " + "data.contact_id, " + "is_default, " + "data1 type, " + "data2 label, " + "data3 email " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_EMAIL); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_ADDRESS + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_ADDRESS" AS " + "SELECT id, " + "data.contact_id, " + "is_default, " + "data1 type, " + "data2 label, " + "data3 postbox, " + "data4 postal_code, " + "data5 region, " + "data6 locality, " + "data7 street, " + "data8 extend, " + "data9 country " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_POSTAL); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_URL + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_URL" AS " + "SELECT id, " + "data.contact_id, " + "data1 type, " + "data2 label, " + "data3 url " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_URL); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_EVENT + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_EVENT" AS " + "SELECT id, " + "data.contact_id, " + "data1 type, " + "data2 label, " + "data3 date " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_EVENT); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_GROUP_RELATION + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_GROUP_RELATION" AS " + "SELECT "CTS_TABLE_GROUP_RELATIONS".group_id, " + "contact_id, " + "group_name " + "FROM "CTS_TABLE_GROUP_RELATIONS", "CTS_TABLE_GROUPS" " + "ON "CTS_TABLE_GROUP_RELATIONS".group_id = "CTS_TABLE_GROUPS".group_id AND deleted = 0 " + "ORDER BY group_name COLLATE NOCASE"); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_RELATIONSHIP + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_RELATIONSHIP" AS " + "SELECT id, " + "data.contact_id, " + "data1 type, " + "data2 label, " + "data3 name " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_RELATIONSHIP); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_IMAGE + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_IMAGE" AS " + "SELECT id, " + "is_default, " + "data.contact_id, " + "data1 type, " + "data2 label, " + "data3 path " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_IMAGE); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_COMPANY + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_COMPANY" AS " + "SELECT id, " + "data.contact_id, " + "data1 type, " + "data2 label, " + "data3 name, " + "data4 department, " + "data5 job_title, " + "data6 assistant, " + "data7 role, " + "data8 logo, " + "data9 location, " + "data10 description, " + "data11 phonetic_name " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_COMPANY); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_NICKNAME + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_NICKNAME" AS " + "SELECT id, " + "data.contact_id, " + "data3 nickname " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_NICKNAME); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_MESSENGER + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_MESSENGER" AS " + "SELECT id, " + "data.contact_id, " + "data1 type, " + "data2 label, " + "data3 im_id " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_MESSENGER); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_NOTE + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_NOTE" AS " + "SELECT id, " + "data.contact_id, " + "data3 note " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_NOTE); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_PROFILE + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_PROFILE" AS " + "SELECT id, " + "data.contact_id, " + "data1 type, " + "data2 label, " + "data3 uid, " + "data4 text, " + "data5 profile_order, " + "data6 appsvc_op, " + "data7 data1, " + "data8 data2, " + "data9 data3, " + "data10 data4 " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_PROFILE); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_EXTENSION + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_EXTENSION" AS " + "SELECT id, " + "data.contact_id, " + "data1, " + "data2, " + "data3, " + "data4, " + "data5, " + "data6, " + "data7, " + "data8, " + "data9, " + "data10, " + "data11, " + "data12 " + "FROM "CTS_TABLE_DATA", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_DATA".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "WHERE datatype = %d AND is_my_profile = 0 ", + CTSVC_DATA_EXTENSION); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_ACTIVITY + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_ACTIVITY" AS " + "SELECT id, " + "activities.contact_id, " + "source_name, " + "status, " + "timestamp, " + "sync_data1, " + "sync_data2, " + "sync_data3, " + "sync_data4 " + "FROM "CTS_TABLE_ACTIVITIES", "CTSVC_DB_VIEW_CONTACT" " + "ON "CTS_TABLE_ACTIVITIES".contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id " + "ORDER BY timestamp DESC"); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_SPEEDIDAL + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_SPEEDIDAL" AS " + "SELECT persons.person_id, " + "name_contacts.display_name, name_contacts.reverse_display_name, " + "name_contacts.display_name_language, " + "name_contacts.sortkey, name_contacts.reverse_sortkey, " + "persons.image_thumbnail_path, " + "data.id number_id, " + "data.data1 type, " + "data.data2 label, " + "data.data3 number, " + "speeddials.speed_number " + "FROM "CTS_TABLE_PERSONS", "CTS_TABLE_CONTACTS" AS name_contacts, " + CTSVC_DB_VIEW_CONTACT" AS temp_contacts, " + CTS_TABLE_DATA", "CTS_TABLE_SPEEDDIALS" " + "ON (persons.name_contact_id = name_contacts.contact_id " + "AND persons.person_id = temp_contacts.person_id " + "AND temp_contacts.contact_id = data.contact_id " + "AND data.id = speeddials.number_id) " + "ORDER BY speeddials.speed_number"); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); +#if 0 + // CTSVC_DB_VIEW_CONTACTS_UPDATED_INFO + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_CONTACTS_UPDATED_INFO" AS " + "SELECT %d, contact_id, changed_ver version, addressbook_id " + "FROM "CTS_TABLE_CONTACTS" " + "WHERE changed_ver == created_ver " + "UNION SELECT %d, contact_id, changed_ver version, addressbook_id " + "FROM "CTS_TABLE_CONTACTS" " + "WHERE changed_ver > created_ver " + "UNION SELECT %d, contact_id, deleted_ver version, addressbook_id " + "FROM "CTS_TABLE_DELETEDS, + CONTACTS_CHANGE_INSERTED, CONTACTS_CHANGE_UPDATED, CONTACTS_CHANGE_DELETED); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_GROUPS_UPDATED_INFO + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_GROUPS_UPDATED_INFO" AS " + "SELECT %d, group_id, changed_ver version, addressbook_id " + "FROM "CTS_TABLE_GROUPS" " + "WHERE changed_ver == created_ver " + "UNION SELECT %d, group_id, changed_ver version, addressbook_id " + "FROM "CTS_TABLE_GROUPS" " + "WHERE changed_ver > created_ver " + "UNION SELECT %d, group_id, deleted_ver version, addressbook_id " + "FROM "CTS_TABLE_GROUP_DELETEDS, + CONTACTS_CHANGE_INSERTED, CONTACTS_CHANGE_UPDATED, CONTACTS_CHANGE_DELETED); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); +#endif + + // CTSVC_DB_VIEW_GROUPS_MEMBER_UPDATED_INFO + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_GROUPS_MEMBER_UPDATED_INFO" AS " + "SELECT group_id, member_changed_ver version, addressbook_id " + "FROM "CTS_TABLE_GROUPS); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_PERSON_CONTACT + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_PERSON_CONTACT" AS " + "SELECT * FROM "CTSVC_DB_VIEW_PERSON" " + "JOIN (SELECT contact_id, " + "addressbook_id, " + "person_id person_id_in_contact " + "FROM "CTSVC_DB_VIEW_CONTACT") temp_contacts " + "JOIN (SELECT addressbook_id addressbook_id_in_addressbooks, addressbook_name, mode addressbook_mode " + "FROM "CTS_TABLE_ADDRESSBOOKS") temp_addressbooks " + "ON temp_contacts.person_id_in_contact = "CTSVC_DB_VIEW_PERSON".person_id " + "AND addressbook_id = temp_addressbooks.addressbook_id_in_addressbooks"); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_PERSON_NUMBER + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_PERSON_NUMBER" AS " + "SELECT * FROM "CTSVC_DB_VIEW_PERSON_CONTACT" " + "JOIN (SELECT id number_id, " + "contact_id, " + "data1 type, " + "is_primary_default, " + "data2 label, " + "data3 number, " + "data4 normalized_number " + "FROM "CTS_TABLE_DATA" WHERE datatype = %d AND is_my_profile = 0) temp_data " + "ON temp_data.contact_id = "CTSVC_DB_VIEW_PERSON_CONTACT".contact_id", + CTSVC_DATA_NUMBER); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_PERSON_EMAIL + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_PERSON_EMAIL" AS " + "SELECT * FROM "CTSVC_DB_VIEW_PERSON_CONTACT" " + "JOIN (SELECT id email_id, " + "contact_id, " + "data1 type, " + "is_primary_default, " + "data2 label, " + "data3 email " + "FROM "CTS_TABLE_DATA" WHERE datatype = %d AND is_my_profile = 0) temp_data " + "ON temp_data.contact_id = "CTSVC_DB_VIEW_PERSON_CONTACT".contact_id", + CTSVC_DATA_EMAIL); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_PERSON_PHONELOG + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_PERSON_PHONELOG" AS " + "SELECT C.id phonelog_id, " + "F.display_name, F.reverse_display_name, " + "F.display_name_language, " + "F.sortkey, F.reverse_sortkey, " + "F.image_thumbnail_path, " + "C.number address, " + "C.log_type, " + "C.log_time, " + "C.data1, " + "C.data2, " + "C.person_id id, " + "C.number_type address_type " + "FROM (SELECT A.id, A.number, A.log_type, A.log_time, A.data1, A.data2, " + "MIN(B.person_id) person_id, B.data1 number_type " + "FROM "CTS_TABLE_PHONELOGS" A " + "LEFT JOIN (SELECT G.person_id person_id, G.contact_id contact_id, " + "H.datatype datatype, H.data1 data1, H.data4 data4 " + "FROM "CTSVC_DB_VIEW_CONTACT" G, "CTS_TABLE_DATA" H " + "ON H.datatype = %d AND G.contact_id = H.contact_id AND H.is_my_profile = 0 ) B " + "ON A.normal_num = B.data4 " + "AND (A.person_id = B.person_id " + "OR A.person_id IS NULL " + "OR NOT EXISTS (SELECT id FROM "CTS_TABLE_DATA" " + "WHERE datatype = %d AND is_my_profile = 0 " + "AND contact_id IN(SELECT contact_id " + "FROM "CTSVC_DB_VIEW_CONTACT" " + "WHERE person_id = A.person_id) " + "AND A.normal_num = data4)) " + "GROUP BY A.id) C " + "LEFT JOIN (SELECT D.person_id, D.display_name, D.reverse_display_name, " + "D.display_name_language, D.sortkey, D.reverse_sortkey, " + "E.image_thumbnail_path " + "FROM "CTS_TABLE_CONTACTS" D, "CTS_TABLE_PERSONS" E " + "ON E.name_contact_id = D.contact_id) F " + "ON C.person_id = F.person_id " + "ORDER BY C.log_time DESC", + CTSVC_DATA_NUMBER, CTSVC_DATA_NUMBER); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_PERSON_USAGE + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_PERSON_USAGE" AS " + "SELECT * FROM "CTSVC_DB_VIEW_PERSON" " + "LEFT JOIN (SELECT usage_type, " + "person_id, " + "times_used " + "FROM "CTS_TABLE_CONTACT_STAT") usage " + "ON usage.person_id = "CTSVC_DB_VIEW_PERSON".person_id " + "ORDER BY usage.times_used"); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_PERSON_GROUP + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_PERSON_GROUP" AS " + "SELECT * FROM "CTSVC_DB_VIEW_PERSON_CONTACT" " + "LEFT JOIN (SELECT group_relations.group_id, " + "group_name, " + "contact_id contact_id_in_group " + "FROM "CTS_TABLE_GROUP_RELATIONS", "CTS_TABLE_GROUPS" " + "ON group_relations.group_id = groups.group_id AND deleted = 0) temp_group " + "ON temp_group.contact_id_in_group = "CTSVC_DB_VIEW_PERSON_CONTACT".contact_id"); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_CONTACT_NUMBER + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_CONTACT_NUMBER" AS " + "SELECT * FROM "CTSVC_DB_VIEW_CONTACT" " + "JOIN (SELECT id number_id, " + "contact_id, " + "data1 type, " + "is_default, " + "data2 label, " + "data3 number, " + "data4 normalized_number " + "FROM "CTS_TABLE_DATA" WHERE datatype = %d AND is_my_profile = 0) temp_data " + "ON temp_data.contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id", + CTSVC_DATA_NUMBER); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_CONTACT_EMAIL + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_CONTACT_EMAIL" AS " + "SELECT * FROM "CTSVC_DB_VIEW_CONTACT" " + "JOIN (SELECT id email_id, " + "contact_id, " + "data1 type, " + "is_default, " + "data2 label, " + "data3 email " + "FROM "CTS_TABLE_DATA" WHERE datatype = %d AND is_my_profile = 0) temp_data " + "ON temp_data.contact_id = "CTSVC_DB_VIEW_CONTACT".contact_id", + CTSVC_DATA_EMAIL); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_CONTACT_GROUP + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_CONTACT_GROUP" AS " + "SELECT * FROM "CTSVC_DB_VIEW_CONTACT" " + "LEFT JOIN (SELECT group_relations.group_id, " + "group_name, " + "contact_id contact_id_in_group " + "FROM "CTS_TABLE_GROUP_RELATIONS", "CTS_TABLE_GROUPS" " + "ON group_relations.group_id = groups.group_id AND deleted = 0) temp_group " + "ON temp_group.contact_id_in_group = "CTSVC_DB_VIEW_CONTACT".contact_id"); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + // CTSVC_DB_VIEW_CONTACT_ACTIVITY + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_CONTACT_ACTIVITY" AS " + "SELECT A.contact_id, " + "A.display_name, " + "A.display_name_source, " + "A.reverse_display_name, " + "A.display_name_language, " + "A.sortkey, A.reverse_sortkey, " + "A.addressbook_id, " + "AB.account_id, " + "A.person_id, " + "A.ringtone_path, " + "A.image_thumbnail_path, " + "AC.id activity_id, " + "AC.source_name, " + "AC.status, " + "AC.timestamp, " + "AC.sync_data1, " + "AC.sync_data2, " + "AC.sync_data3, " + "AC.sync_data4 " + "FROM "CTSVC_DB_VIEW_CONTACT" A, "CTS_TABLE_ACTIVITIES" AC, "CTS_TABLE_ADDRESSBOOKS" AB " + "ON A.contact_id = AC.contact_id " + "AND A.addressbook_id = AB.addressbook_id " + "ORDER BY timestamp DESC"); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + //CTSVC_DB_VIEW_PHONELOG_NUMBER + snprintf(query, sizeof(query), + "CREATE VIEW IF NOT EXISTS "CTSVC_DB_VIEW_PHONELOG_NUMBER" AS " + "SELECT DISTINCT number FROM "CTS_TABLE_PHONELOGS" " + "WHERE log_type < %d", CONTACTS_PLOG_TYPE_EMAIL_RECEIVED); + ret = ctsvc_query_exec(query); + RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "DB error : ctsvc_query_exec() Failed(%d)", ret); + + __ctsvc_db_view_already_created = true; + + return CONTACTS_ERROR_NONE; +} +#endif + +int ctsvc_db_init() +{ + int ret = CONTACTS_ERROR_NONE; + ret = ctsvc_db_open(); + if (ret != CONTACTS_ERROR_NONE) { + CTS_ERR("ctsvc_db_open() Failed(%d)", ret); + return ret; + } + ret = ctsvc_restriction_init(); + if (ret != CONTACTS_ERROR_NONE) { + CTS_ERR("ctsvc_restriction_init() Failed(%d)", ret); + return ret; + } + +#ifdef _CONTACTS_IPC_SERVER + ret = __ctsvc_db_create_views(); +#endif + + return ret; +} + +int ctsvc_db_deinit() +{ + int ret = CONTACTS_ERROR_NONE; + ret = ctsvc_db_close(); + if (ret != CONTACTS_ERROR_NONE) { + CTS_ERR("ctsvc_db_close() Failed(%d)", ret); + return ret; + } + ctsvc_restriction_deinit(); + return CONTACTS_ERROR_NONE; +} + + |