Tizen 2.0 Releasesubmit/tizen_2.0/20130216.100704accepted/tizen_2.0/20130216.0940012.0_releasetizen_2.0

1 files changed, 382 insertions, 0 deletions

diff --git a/native/ctsvc_db_plugin_name.c b/native/ctsvc_db_plugin_name.c
new file mode 100644
index 0000000..15ac142
--- /dev/null
+++ b/native/ctsvc_db_plugin_name.c
@@ -0,0 +1,382 @@
+/*
+ * Contacts Service
+ *
+ * Copyright (c) 2010 - 2012 Samsung Electronics Co., Ltd. All rights reserved.
+ *
+ * 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 "contacts.h"
+#include "ctsvc_internal.h"
+#include "ctsvc_schema.h"
+#include "ctsvc_sqlite.h"
+#include "ctsvc_utils.h"
+#include "ctsvc_normalize.h"
+#include "ctsvc_db_init.h"
+#include "ctsvc_db_query.h"
+#include "ctsvc_db_plugin_contact_helper.h"
+#include "ctsvc_db_plugin_name_helper.h"
+#include "ctsvc_record.h"
+#include "ctsvc_list.h"
+
+static int __ctsvc_db_name_insert_record( contacts_record_h record, int *id );
+static int __ctsvc_db_name_get_record( int id, contacts_record_h* out_record );
+static int __ctsvc_db_name_update_record( contacts_record_h record );
+static int __ctsvc_db_name_delete_record( int id );
+static int __ctsvc_db_name_get_all_records( int offset, int limit, contacts_list_h* out_list );
+static int __ctsvc_db_name_get_records_with_query( contacts_query_h query, int offset, int limit, contacts_list_h* out_list );
+//static int __ctsvc_db_name_insert_records(const contacts_list_h in_list, int **ids);
+//static int __ctsvc_db_name_update_records(const contacts_list_h in_list);
+//static int __ctsvc_db_name_delete_records( int ids[], int count);
+
+ctsvc_db_plugin_info_s ctsvc_db_plugin_name = {
+	.is_query_only = false,
+	.insert_record = __ctsvc_db_name_insert_record,
+	.get_record = __ctsvc_db_name_get_record,
+	.update_record = __ctsvc_db_name_update_record,
+	.delete_record = __ctsvc_db_name_delete_record,
+	.get_all_records = __ctsvc_db_name_get_all_records,
+	.get_records_with_query = __ctsvc_db_name_get_records_with_query,
+	.insert_records = NULL,//__ctsvc_db_name_insert_records,
+	.update_records = NULL,//__ctsvc_db_name_update_records,
+	.delete_records = NULL,//__ctsvc_db_name_delete_records
+	.get_count = NULL,
+	.get_count_with_query = NULL,
+	.replace_record = NULL,
+	.replace_records = NULL,
+};
+
+static int __ctsvc_db_name_insert_record( contacts_record_h record, int *id )
+{
+	int ret;
+	int contact_id;
+	char query[CTS_SQL_MAX_LEN] = {0};
+	ctsvc_name_s *name = (ctsvc_name_s *)record;
+
+	ret = ctsvc_begin_trans();
+	if (CONTACTS_ERROR_NONE != ret) {
+		CTS_ERR("DB error : ctsvc_begin_trans() Failed(%d)", ret);
+		return ret;
+	}
+
+	snprintf(query, sizeof(query),
+			"SELECT contact_id FROM "CTSVC_DB_VIEW_CONTACT" WHERE contact_id = %d", name->contact_id);
+	ret = ctsvc_query_get_first_int_result(query, &contact_id);
+	if (CONTACTS_ERROR_NONE != ret) {
+		CTS_ERR("No data : contact_id (%d) is not exist", contact_id);
+		ctsvc_end_trans(false);
+		return CONTACTS_ERROR_INVALID_PARAMETER;
+	}
+
+	ret = ctsvc_db_name_insert(record, name->contact_id, false, id);
+	if (CONTACTS_ERROR_NONE != ret) {
+		CTS_ERR("DB error : ctsvc_begin_trans() Failed(%d)", ret);
+		ctsvc_end_trans(false);
+		return ret;
+	}
+
+	// TODO ; contact name update
+	ret = ctsvc_db_contact_update_changed_time(name->contact_id);
+	if (CONTACTS_ERROR_NONE != ret) {
+		CTS_ERR("DB error : ctsvc_query_exec() Failed(%d)", ret);
+		ctsvc_end_trans(false);
+		return ret;
+	}
+
+	ret = ctsvc_end_trans(true);
+	if (ret < CONTACTS_ERROR_NONE)
+	{
+		CTS_ERR("DB error : ctsvc_end_trans() Failed(%d)", ret);
+		return ret;
+	}
+	else
+		return CONTACTS_ERROR_NONE;
+}
+
+static int __ctsvc_db_name_get_record( int id, contacts_record_h* out_record )
+{
+	int ret;
+	int len;
+	cts_stmt stmt = NULL;
+	char query[CTS_SQL_MAX_LEN] = {0};
+
+	RETV_IF(NULL == out_record, CONTACTS_ERROR_INVALID_PARAMETER);
+	*out_record = NULL;
+
+	len = snprintf(query, sizeof(query),
+			"SELECT id, data.contact_id, is_default, 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 id = %d AND datatype = %d ",
+				id, CTSVC_DATA_NAME);
+
+	stmt = cts_query_prepare(query);
+	RETVM_IF(NULL == stmt, CONTACTS_ERROR_DB, "DB error : cts_query_prepare() Failed");
+
+	ret = cts_stmt_step(stmt);
+	if (1 /*CTS_TRUE*/ != ret) {
+		CTS_ERR("cts_stmt_step() Failed(%d)", ret);
+		cts_stmt_finalize(stmt);
+		return CONTACTS_ERROR_NO_DATA;
+	}
+
+	ctsvc_db_name_get_value_from_stmt(stmt, out_record, 0);
+	cts_stmt_finalize(stmt);
+
+	return CONTACTS_ERROR_NONE;
+}
+
+static int __ctsvc_db_name_update_record( contacts_record_h record )
+{
+	int ret;
+	int contact_id;
+	char query[CTS_SQL_MAX_LEN] = {0};
+	ctsvc_name_s *name = (ctsvc_name_s *)record;
+
+	ret = ctsvc_begin_trans();
+	if (CONTACTS_ERROR_NONE != ret) {
+		CTS_ERR("DB error : ctsvc_begin_trans() Failed(%d)", ret);
+		return ret;
+	}
+
+	snprintf(query, sizeof(query),
+			"SELECT contact_id FROM "CTSVC_DB_VIEW_CONTACT" WHERE contact_id = %d", name->contact_id);
+	ret = ctsvc_query_get_first_int_result(query, &contact_id);
+	if (CONTACTS_ERROR_NONE != ret) {
+		CTS_ERR("No data : contact_id (%d) is not exist", contact_id);
+		ctsvc_end_trans(false);
+		return CONTACTS_ERROR_INVALID_PARAMETER;
+	}
+
+	ret = ctsvc_db_name_update(record, name->contact_id, false);
+	if (CONTACTS_ERROR_NONE != ret) {
+		CTS_ERR("DB error : ctsvc_begin_trans() Failed(%d)", ret);
+		ctsvc_end_trans(false);
+		return ret;
+	}
+
+	// TODO ; contact display name update
+	ret = ctsvc_db_contact_update_changed_time(name->contact_id);
+	if (CONTACTS_ERROR_NONE != ret) {
+		CTS_ERR("DB error : ctsvc_query_exec() Failed(%d)", ret);
+		ctsvc_end_trans(false);
+		return ret;
+	}
+
+	ret = ctsvc_end_trans(true);
+	if (ret < CONTACTS_ERROR_NONE)
+	{
+		CTS_ERR("DB error : ctsvc_end_trans() Failed(%d)", ret);
+		return ret;
+	}
+	else
+		return CONTACTS_ERROR_NONE;
+}
+
+
+static int __ctsvc_db_name_delete_record( int id )
+{
+	int ret;
+	int contact_id;
+	char query[CTS_SQL_MAX_LEN] = {0};
+
+	ret = ctsvc_begin_trans();
+	if (CONTACTS_ERROR_NONE != ret) {
+		CTS_ERR("DB error : ctsvc_begin_trans() Failed(%d)", ret);
+		return ret;
+	}
+
+	snprintf(query, sizeof(query),
+			"SELECT contact_id FROM "CTSVC_DB_VIEW_CONTACT " "
+			"WHERE contact_id = (SELECT contact_id FROM "CTS_TABLE_DATA" WHERE id = %d)", id);
+	ret = ctsvc_query_get_first_int_result(query, &contact_id);
+	if( ret != CONTACTS_ERROR_NONE ) {
+		CTS_ERR("The id(%d) is Invalid(%d)", id, ret);
+		ctsvc_end_trans(false);
+		return contact_id;
+	}
+
+	ret = ctsvc_db_name_delete(id);
+	if (CONTACTS_ERROR_NONE != ret) {
+		CTS_ERR("DB error : ctsvc_begin_trans() Failed(%d)", ret);
+		ctsvc_end_trans(false);
+		return ret;
+	}
+
+	// TODO ; contact name update
+	ret = ctsvc_db_contact_update_changed_time(contact_id);
+	if (CONTACTS_ERROR_NONE != ret) {
+		CTS_ERR("DB error : ctsvc_query_exec() Failed(%d)", ret);
+		ctsvc_end_trans(false);
+		return ret;
+	}
+
+	ret = ctsvc_end_trans(true);
+	if (ret < CONTACTS_ERROR_NONE)
+	{
+		CTS_ERR("DB error : ctsvc_end_trans() Failed(%d)", ret);
+		return ret;
+	}
+	else
+		return CONTACTS_ERROR_NONE;
+}
+
+static int __ctsvc_db_name_get_all_records( int offset, int limit, contacts_list_h* out_list )
+{
+	int len;
+	int ret;
+	contacts_list_h list;
+	ctsvc_name_s *name;
+	cts_stmt stmt = NULL;
+	char query[CTS_SQL_MAX_LEN] = {0};
+
+	len = snprintf(query, sizeof(query),
+			"SELECT id, data.contact_id, is_default, 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_NAME);
+	if (0 < limit) {
+		len += snprintf(query+len, sizeof(query)-len, " LIMIT %d", limit);
+		if (0 < offset)
+			len += snprintf(query+len, sizeof(query)-len, " OFFSET %d", offset);
+	}
+
+	stmt = cts_query_prepare(query);
+	RETVM_IF(NULL == stmt, CONTACTS_ERROR_DB, "DB error : cts_query_prepare() Failed");
+
+	contacts_list_create(&list);
+	while ((ret = cts_stmt_step(stmt))) {
+		if (1 != ret) {
+			CTS_ERR("DB error : cts_stmt_step Failed(%d)", ret);
+			cts_stmt_finalize(stmt);
+			contacts_list_destroy(list, true);
+			return ret;
+		}
+		ctsvc_db_name_get_value_from_stmt(stmt, (contacts_record_h*)&name, 0);
+		ctsvc_list_prepend(list, (contacts_record_h)name);
+	}
+
+	cts_stmt_finalize(stmt);
+	ctsvc_list_reverse(list);
+
+	*out_list = list;
+	return CONTACTS_ERROR_NONE;
+}
+
+static int __ctsvc_db_name_get_records_with_query( contacts_query_h query, int offset,
+		int limit, contacts_list_h* out_list )
+{
+	int ret;
+	int i;
+	int field_count;
+	ctsvc_query_s *s_query;
+	cts_stmt stmt;
+	contacts_list_h list;
+	ctsvc_name_s *name;
+
+	RETV_IF(NULL == query, CONTACTS_ERROR_INVALID_PARAMETER);
+	s_query = (ctsvc_query_s *)query;
+
+	ret = ctsvc_db_make_get_records_query_stmt(s_query, offset, limit, &stmt);
+	RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "ctsvc_db_make_get_records_query_stmt fail(%d)", ret);
+
+	contacts_list_create(&list);
+	while ((ret = cts_stmt_step(stmt))) {
+		contacts_record_h record;
+		if (1 != ret) {
+			CTS_ERR("DB error : cts_stmt_step Failed(%d)", ret);
+			cts_stmt_finalize(stmt);
+			contacts_list_destroy(list, true);
+			return ret;
+		}
+
+		contacts_record_create(_contacts_name._uri, &record);
+		name = (ctsvc_name_s*)record;
+		if (0 == s_query->projection_count)
+			field_count = s_query->property_count;
+		else {
+			field_count = s_query->projection_count;
+			ret = ctsvc_record_set_projection_flags(record, s_query->projection,
+					s_query->projection_count, s_query->property_count);
+
+			if( CONTACTS_ERROR_NONE !=  ret)
+				ASSERT_NOT_REACHED("To set projection is failed.\n");
+		}
+
+		for(i=0;i<field_count;i++) {
+			char *temp;
+			int property_id;
+			if (0 == s_query->projection_count)
+				property_id = s_query->properties[i].property_id;
+			else
+				property_id = s_query->projection[i];
+
+			switch(property_id) {
+			case CTSVC_PROPERTY_NAME_ID:
+				name->id = ctsvc_stmt_get_int(stmt, i);
+				break;
+			case CTSVC_PROPERTY_NAME_CONTACT_ID:
+				name->contact_id = ctsvc_stmt_get_int(stmt, i);
+				break;
+			case CTSVC_PROPERTY_NAME_FIRST:
+				temp = ctsvc_stmt_get_text(stmt, i);
+				name->first = SAFE_STRDUP(temp);
+				break;
+			case CTSVC_PROPERTY_NAME_LAST:
+				temp = ctsvc_stmt_get_text(stmt, i);
+				name->last = SAFE_STRDUP(temp);
+				break;
+			case CTSVC_PROPERTY_NAME_ADDITION:
+				temp = ctsvc_stmt_get_text(stmt, i);
+				name->addition = SAFE_STRDUP(temp);
+				break;
+			case CTSVC_PROPERTY_NAME_SUFFIX:
+				temp = ctsvc_stmt_get_text(stmt, i);
+				name->suffix = SAFE_STRDUP(temp);
+				break;
+			case CTSVC_PROPERTY_NAME_PREFIX:
+				temp = ctsvc_stmt_get_text(stmt, i);
+				name->prefix = SAFE_STRDUP(temp);
+				break;
+			case CTSVC_PROPERTY_NAME_PHONETIC_FIRST:
+				temp = ctsvc_stmt_get_text(stmt, i);
+				name->phonetic_first = SAFE_STRDUP(temp);
+				break;
+			case CTSVC_PROPERTY_NAME_PHONETIC_MIDDLE:
+				temp = ctsvc_stmt_get_text(stmt, i);
+				name->phonetic_middle = SAFE_STRDUP(temp);
+				break;
+			case CTSVC_PROPERTY_NAME_PHONETIC_LAST:
+				temp = ctsvc_stmt_get_text(stmt, i);
+				name->phonetic_last = SAFE_STRDUP(temp);
+				break;
+			default:
+				break;
+			}
+		}
+		ctsvc_list_prepend(list, record);
+	}
+	cts_stmt_finalize(stmt);
+	ctsvc_list_reverse(list);
+
+	*out_list = list;
+	return CONTACTS_ERROR_NONE;
+}
+
+//static int __ctsvc_db_name_insert_records(const contacts_list_h in_list, int **ids) { return CONTACTS_ERROR_NONE; }
+//static int __ctsvc_db_name_update_records(const contacts_list_h in_list) { return CONTACTS_ERROR_NONE; }
+//static int __ctsvc_db_name_delete_records( int ids[], int count) { return CONTACTS_ERROR_NONE; }