Merge branch 'tizen' into feature/noti_exfeature/noti_ex

Conflicts:
	AUTHORS
	CMakeLists.txt
	LICENSE
	packaging/notification.spec

1 files changed, 229 insertions, 0 deletions

diff --git a/notification/src/notification_db.c b/notification/src/notification_db.c
new file mode 100644
index 0000000..485a207
--- /dev/null
+++ b/notification/src/notification_db.c
@@ -0,0 +1,229 @@
+/*
+ * Copyright (c) 2000 - 2017 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 <errno.h>
+#include <unistd.h>
+#include <stdio.h>
+#include <string.h>
+
+#include <sqlite3.h>
+#include <tizen.h>
+
+#include <notification_error.h>
+#include <notification_debug.h>
+#include <notification_db.h>
+#include "notification_db_query.h"
+
+static bool is_db_corrupted = false;
+
+/* LCOV_EXCL_START */
+static int __check_integrity_cb(void *pid, int argc, char **argv, char **notUsed)
+{
+	char *check_str = "ok";
+
+	if (strncmp(argv[0], check_str, strlen(check_str))) {
+		ERR("db integrity result : %s", argv[0]);
+		is_db_corrupted = true;
+		return -1;
+	}
+
+	INFO("db integrity result : %s", argv[0]);
+	return 0;
+}
+/* LCOV_EXCL_STOP */
+
+/* LCOV_EXCL_START */
+static int __recover_corrupted_db(sqlite3 *db)
+{
+	int ret = NOTIFICATION_ERROR_NONE;
+	int sql_ret;
+	char *errmsg = NULL;
+
+	INFO("DB is corrupted, start to recover corrupted db");
+	if (db)
+		sqlite3_close(db);
+	unlink(DBPATH);
+
+	sql_ret = sqlite3_open_v2(DBPATH, &db,
+				SQLITE_OPEN_CREATE | SQLITE_OPEN_READWRITE,
+				NULL);
+	if (sql_ret != SQLITE_OK) {
+		ERR("Failed to open db[%d]", sql_ret);
+		unlink(DBPATH);
+		ret = NOTIFICATION_ERROR_FROM_DB;
+		goto out;
+	}
+
+	sql_ret = sqlite3_exec(db, CREATE_NOTIFICATION_TABLE, NULL, NULL, &errmsg);
+	if (sql_ret != SQLITE_OK) {
+		ERR("Failed to exec query[%d][%s]", sql_ret, errmsg);
+		ret = NOTIFICATION_ERROR_FROM_DB;
+	}
+
+out:
+	if (errmsg)
+		sqlite3_free(errmsg);
+
+	return ret;
+}
+/* LCOV_EXCL_STOP */
+
+/* LCOV_EXCL_START */
+EXPORT_API int notification_db_init(void)
+{
+	int ret = NOTIFICATION_ERROR_NONE;
+	int sql_ret;
+	sqlite3 *db = NULL;
+	char *errmsg = NULL;
+
+	sql_ret = sqlite3_open_v2(DBPATH, &db,
+			SQLITE_OPEN_CREATE | SQLITE_OPEN_READWRITE, NULL);
+	if (sql_ret != SQLITE_OK) {
+		ERR("Failed to open db[%d]", ret);
+		ret = NOTIFICATION_ERROR_FROM_DB;
+		goto out;
+	}
+
+	sql_ret = sqlite3_exec(db, CREATE_NOTIFICATION_TABLE, NULL, NULL, &errmsg);
+	if (sql_ret != SQLITE_OK) {
+		ERR("Failed to exec sqlite[%d][%s]", ret, errmsg);
+		ret = NOTIFICATION_ERROR_FROM_DB;
+		goto out;
+	}
+
+	sql_ret = sqlite3_exec(db, "PRAGMA integrity_check",
+			       __check_integrity_cb, NULL, &errmsg);
+	if (sql_ret != SQLITE_OK || is_db_corrupted) {
+		ERR("Failed to exec query[%d][%s]", sql_ret, errmsg);
+		ret = NOTIFICATION_ERROR_FROM_DB;
+	}
+
+out:
+	if (sql_ret == SQLITE_CORRUPT || sql_ret == SQLITE_NOTADB || is_db_corrupted)
+		ret = __recover_corrupted_db(db);
+	if (errmsg)
+		sqlite3_free(errmsg);
+	if (db)
+		sqlite3_close(db);
+
+	return ret;
+}
+/* LCOV_EXCL_STOP */
+
+sqlite3 *notification_db_open()
+{
+	int ret = 0;
+	sqlite3 *db = 0;
+
+	ret = access(DBPATH, R_OK | W_OK);
+	if (ret != 0) {
+		/* LCOV_EXCL_START */
+		set_last_result(NOTIFICATION_ERROR_FROM_DB);
+		return NULL;
+		/* LCOV_EXCL_STOP */
+	}
+
+	ret = sqlite3_open_v2(DBPATH, &db, SQLITE_OPEN_READWRITE, NULL);
+	if (ret != SQLITE_OK) {
+		/* LCOV_EXCL_START */
+		if (ret == SQLITE_PERM)
+			set_last_result(NOTIFICATION_ERROR_PERMISSION_DENIED);
+		else
+			set_last_result(NOTIFICATION_ERROR_FROM_DB);
+
+		return NULL;
+		/* LCOV_EXCL_STOP */
+	}
+
+	return db;
+}
+
+int notification_db_close(sqlite3 **db)
+{
+	int ret = 0;
+
+	if (db == NULL || *db == NULL)
+		return NOTIFICATION_ERROR_INVALID_PARAMETER;
+
+	ret = sqlite3_close(*db);
+	if (ret != SQLITE_OK) {
+		/* LCOV_EXCL_START */
+		ERR("Failed to close db[%d]", ret);
+		return NOTIFICATION_ERROR_FROM_DB;
+		/* LCOV_EXCL_STOP */
+	}
+
+	*db = NULL;
+
+	return NOTIFICATION_ERROR_NONE;
+}
+
+int notification_db_exec(sqlite3 *db, const char *query, int *num_changes)
+{
+	int ret = NOTIFICATION_ERROR_NONE;
+	sqlite3_stmt *stmt = NULL;
+
+	if (db == NULL || query == NULL)
+		return NOTIFICATION_ERROR_INVALID_PARAMETER;
+
+	ret = sqlite3_prepare_v2(db, query, strlen(query), &stmt, NULL);
+	if (ret != SQLITE_OK) {
+		/* LCOV_EXCL_START */
+		ERR("Sqlite3 err[%d][%s]", ret, sqlite3_errmsg(db));
+		return NOTIFICATION_ERROR_FROM_DB;
+		/* LCOV_EXCL_STOP */
+	}
+
+	ret = sqlite3_step(stmt);
+	if (ret == SQLITE_OK || ret == SQLITE_DONE) {
+		if (num_changes != NULL)
+			*num_changes = sqlite3_changes(db);
+
+		ret = NOTIFICATION_ERROR_NONE;
+	} else {
+		/* LCOV_EXCL_START */
+		ERR("Sqlite err[%d][%s]", ret, sqlite3_errmsg(db));
+		ret = NOTIFICATION_ERROR_FROM_DB;
+		/* LCOV_EXCL_STOP */
+	}
+
+	sqlite3_finalize(stmt);
+
+	return ret;
+}
+
+char *notification_db_column_text(sqlite3_stmt *stmt, int col)
+{
+	const unsigned char *col_text = NULL;
+
+	col_text = sqlite3_column_text(stmt, col);
+	if (col_text == NULL || col_text[0] == '\0')
+		return NULL;
+
+	return strdup((char *)col_text);
+}
+
+bundle *notification_db_column_bundle(sqlite3_stmt *stmt, int col)
+{
+	const unsigned char *col_bundle = NULL;
+
+	col_bundle = sqlite3_column_text(stmt, col);
+	if (col_bundle == NULL || col_bundle[0] == '\0')
+		return NULL;
+
+	return bundle_decode(col_bundle, strlen((char *)col_bundle));
+}
+