1 //******************************************************************
3 // Copyright 2016 Samsung Electronics All Rights Reserved.
5 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
7 // Licensed under the Apache License, Version 2.0 (the "License");
8 // you may not use this file except in compliance with the License.
9 // You may obtain a copy of the License a
11 // http://www.apache.org/licenses/LICENSE-2.0
13 // Unless required by applicable law or agreed to in writing, software
14 // distributed under the License is distributed on an "AS IS" BASIS,
15 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 // See the License for the specific language governing permissions and
17 // limitations under the License.
19 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
26 #include "ocpayload.h"
28 #include "oic_malloc.h"
29 #include "oic_string.h"
33 #define TAG "RD_DATABASE"
34 #define RD_PATH "RD.db"
36 static sqlite3 *gRDDB = NULL;
38 static const uint8_t device_index = 2;
39 static const uint8_t ttl_index = 3;
40 static const uint8_t address_index = 4;
42 static const uint8_t uri_index = 2;
43 static const uint8_t p_index = 5;
44 static const uint8_t mt_index = 7;
45 static const uint8_t d_index = 8;
47 static const uint8_t rt_value_index = 1;
48 static const uint8_t rt_link_id_index = 2;
50 static const uint8_t if_value_index = 1;
51 static const uint8_t if_link_id_index = 2;
53 static const uint8_t bind_index_value = 1;
55 #define VERIFY_SQLITE(arg) \
56 if (SQLITE_OK != (arg)) \
58 OIC_LOG_V(ERROR, TAG, "Error in " #arg ", Error Message: %s", sqlite3_errmsg(gRDDB)); \
59 sqlite3_exec(gRDDB, "ROLLBACK", NULL, NULL, NULL); \
60 return OC_STACK_ERROR; \
63 #define CHECK_DATABASE_INIT \
66 OIC_LOG(ERROR, TAG, "Database is not initialized."); \
67 return OC_STACK_ERROR; \
71 #define XSTR(a) STR(a)
74 "create table RD_DEVICE_LIST(ID INTEGER PRIMARY KEY AUTOINCREMENT, " \
75 XSTR(OC_RSRVD_DEVICE_ID) " UNIQUE NOT NULL, " \
76 XSTR(OC_RSRVD_TTL) " NOT NULL, " \
80 "create table RD_DEVICE_LINK_LIST("XSTR(OC_RSRVD_INS)" INTEGER PRIMARY KEY AUTOINCREMENT, " \
81 XSTR(OC_RSRVD_HREF) "," \
82 XSTR(OC_RSRVD_REL) "," \
83 XSTR(OC_RSRVD_TITLE) "," \
84 XSTR(OC_RSRVD_BITMAP)"," \
85 XSTR(OC_RSRVD_TTL) "," \
86 XSTR(OC_RSRVD_MEDIA_TYPE) "," \
87 "DEVICE_ID INT NOT NULL, " \
88 "FOREIGN KEY(DEVICE_ID) REFERENCES RD_DEVICE_LIST(ID) ON DELETE CASCADE );"
91 "create table RD_LINK_RT(" XSTR(OC_RSRVD_RESOURCE_TYPE) " NOT NULL, " \
92 "LINK_ID INT NOT NULL, "\
93 "FOREIGN KEY("XSTR(LINK_ID)") REFERENCES RD_DEVICE_LINK_LIST("XSTR(OC_RSRVD_INS)") " \
97 "create table RD_LINK_IF(" XSTR(OC_RSRVD_INTERFACE) " NOT NULL, " \
98 "LINK_ID INT NOT NULL, "\
99 "FOREIGN KEY("XSTR(LINK_ID)") REFERENCES RD_DEVICE_LINK_LIST("XSTR(OC_RSRVD_INS)") " \
100 "ON DELETE CASCADE);"
102 static void errorCallback(void *arg, int errCode, const char *errMsg)
107 OIC_LOG_V(ERROR, TAG, "SQLLite Error: %s : %d", errMsg, errCode);
110 OCStackResult OCRDDatabaseInit(const char *path)
112 if (SQLITE_OK == sqlite3_config(SQLITE_CONFIG_LOG, errorCallback))
114 OIC_LOG_V(INFO, TAG, "SQLite debugging log initialized.");
117 int sqlRet = sqlite3_open_v2(!path ? RD_PATH : path, &gRDDB, SQLITE_OPEN_READWRITE, NULL);
118 if (SQLITE_OK != sqlRet)
120 OIC_LOG(DEBUG, TAG, "RD database file did not open, as no table exists.");
121 OIC_LOG(DEBUG, TAG, "RD creating new table.");
122 sqlRet = sqlite3_open_v2(!path ? RD_PATH : path, &gRDDB,
123 SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE, NULL);
124 if (SQLITE_OK == sqlRet)
126 VERIFY_SQLITE(sqlite3_exec(gRDDB, RD_TABLE, NULL, NULL, NULL));
127 OIC_LOG(DEBUG, TAG, "RD created RD_DEVICE_LIST table.");
129 VERIFY_SQLITE(sqlite3_exec(gRDDB, RD_LL_TABLE, NULL, NULL, NULL));
130 OIC_LOG(DEBUG, TAG, "RD created RD_DEVICE_LINK_LIST table.");
132 VERIFY_SQLITE(sqlite3_exec(gRDDB, RD_RT_TABLE, NULL, NULL, NULL));
133 OIC_LOG(DEBUG, TAG, "RD created RD_LINK_RT table.");
135 VERIFY_SQLITE(sqlite3_exec(gRDDB, RD_IF_TABLE, NULL, NULL, NULL));
136 OIC_LOG(DEBUG, TAG, "RD created RD_LINK_IF table.");
141 if (sqlRet == SQLITE_OK)
143 sqlite3_stmt *stmt = 0;
144 VERIFY_SQLITE(sqlite3_prepare_v2 (gRDDB, "PRAGMA foreign_keys = ON;", -1, &stmt, NULL));
146 if (SQLITE_DONE != sqlite3_step(stmt))
148 sqlite3_finalize(stmt);
149 return OC_STACK_ERROR;
152 VERIFY_SQLITE(sqlite3_finalize(stmt));
158 OCStackResult OCRDDatabaseClose()
161 VERIFY_SQLITE(sqlite3_close_v2(gRDDB));
165 static int storeResourceType(char **link, size_t size, uint8_t rowid)
168 VERIFY_SQLITE(sqlite3_exec(gRDDB, "BEGIN TRANSACTION", NULL, NULL, NULL));
170 const char *insertRT = "INSERT INTO RD_LINK_RT VALUES(?, ?)";
171 sqlite3_stmt *stmtRT = 0;
173 for (size_t i = 0; i < size; i++)
175 VERIFY_SQLITE(sqlite3_prepare_v2(gRDDB, insertRT, strlen(insertRT) + 1, &stmtRT, NULL));
178 VERIFY_SQLITE(sqlite3_bind_text(stmtRT, rt_value_index, link[i],
179 strlen(link[i])+1, SQLITE_STATIC));
181 VERIFY_SQLITE(sqlite3_bind_int(stmtRT, rt_link_id_index, rowid));
183 if (SQLITE_DONE != sqlite3_step(stmtRT))
185 sqlite3_finalize(stmtRT);
190 VERIFY_SQLITE(sqlite3_finalize(stmtRT));
192 VERIFY_SQLITE(sqlite3_exec(gRDDB, "COMMIT", NULL, NULL, NULL));
199 static int storeInterfaceType(char **link, size_t size, uint8_t rowid)
203 VERIFY_SQLITE(sqlite3_exec(gRDDB, "BEGIN TRANSACTION", NULL, NULL, NULL));
205 const char *insertIF = "INSERT INTO RD_LINK_IF VALUES(?, ?)";
206 sqlite3_stmt *stmtIF = 0;
208 for (size_t i = 0; i < size; i++)
210 VERIFY_SQLITE(sqlite3_prepare_v2(gRDDB, insertIF, strlen(insertIF) + 1, &stmtIF, NULL));
214 VERIFY_SQLITE(sqlite3_bind_text(stmtIF, if_value_index, link[i], strlen(link[i])+1, SQLITE_STATIC));
215 VERIFY_SQLITE(sqlite3_bind_int(stmtIF, if_link_id_index, rowid));
217 if (SQLITE_DONE != sqlite3_step(stmtIF))
219 res = sqlite3_finalize(stmtIF);
223 VERIFY_SQLITE(sqlite3_finalize(stmtIF));
225 VERIFY_SQLITE(sqlite3_exec(gRDDB, "COMMIT", NULL, NULL, NULL));
231 static int storeLinkPayload(OCRepPayload *rdPayload, int64_t rowid)
233 OCRepPayload **links = NULL;
234 size_t dimensions[MAX_REP_ARRAY_DEPTH];
238 if (OCRepPayloadGetPropObjectArray(rdPayload, OC_RSRVD_LINKS, &links, dimensions))
240 const char *insertDeviceLLList = "INSERT INTO RD_DEVICE_LINK_LIST VALUES(?,?,?,?,?,?,?,?)";
241 sqlite3_stmt *stmt = 0;
243 for (size_t i = 0; i < dimensions[0]; i++)
245 VERIFY_SQLITE(sqlite3_prepare_v2(gRDDB, insertDeviceLLList, strlen(insertDeviceLLList) + 1, &stmt, NULL));
246 VERIFY_SQLITE(sqlite3_exec(gRDDB, "BEGIN TRANSACTION", NULL, NULL, NULL));
248 OCRepPayload *link = links[i];
250 if (OCRepPayloadGetPropString(link, OC_RSRVD_HREF, &uri))
252 VERIFY_SQLITE(sqlite3_bind_text(stmt, uri_index, uri, strlen(uri), SQLITE_STATIC));
255 OCRepPayload *p = NULL;
256 if (OCRepPayloadGetPropObject(link, OC_RSRVD_POLICY, &p))
259 if (OCRepPayloadGetPropInt(p, OC_RSRVD_BITMAP, &bm))
261 VERIFY_SQLITE(sqlite3_bind_int(stmt, p_index, bm));
265 size_t mtDim[MAX_REP_ARRAY_DEPTH] = {0};
266 char **mediaType = NULL;
267 if (OCRepPayloadGetStringArray(link, OC_RSRVD_MEDIA_TYPE, &mediaType, mtDim))
269 VERIFY_SQLITE(sqlite3_bind_text(stmt, mt_index, mediaType[0], mtDim[0], SQLITE_STATIC));
272 VERIFY_SQLITE(sqlite3_bind_int(stmt, d_index, rowid));
274 size_t rtDim[MAX_REP_ARRAY_DEPTH] = {0};
276 OCRepPayloadGetStringArray(link, OC_RSRVD_RESOURCE_TYPE, &rt, rtDim);
278 size_t itfDim[MAX_REP_ARRAY_DEPTH] = {0};
280 OCRepPayloadGetStringArray(link, OC_RSRVD_INTERFACE, &itf, itfDim);
282 if (SQLITE_DONE != sqlite3_step(stmt))
284 sqlite3_finalize(stmt);
287 VERIFY_SQLITE(sqlite3_exec(gRDDB, "COMMIT", NULL, NULL, NULL));
289 int64_t ins = sqlite3_last_insert_rowid(gRDDB);
290 VERIFY_SQLITE(storeResourceType(rt, rtDim[0], ins));
291 VERIFY_SQLITE(storeInterfaceType(itf, itfDim[0], ins));
293 OCPayloadDestroy((OCPayload *)p);
294 for (j = 0; j < mtDim[0]; j++)
296 OICFree(mediaType[j]);
300 for (j = 0; j < rtDim[0]; j++)
306 for (j = 0; j < itfDim[0]; j++)
314 VERIFY_SQLITE(sqlite3_finalize(stmt));
320 OCStackResult OCRDDatabaseStoreResources(OCRepPayload *payload, const OCDevAddr *address)
324 VERIFY_SQLITE(sqlite3_exec(gRDDB, "BEGIN TRANSACTION", NULL, NULL, NULL));
325 const char *insertDeviceList = "INSERT INTO RD_DEVICE_LIST VALUES(?,?,?,?)";
326 sqlite3_stmt *stmt = 0;
327 VERIFY_SQLITE(sqlite3_prepare_v2(gRDDB, insertDeviceList, strlen(insertDeviceList) + 1, &stmt, NULL));
329 char *deviceid = NULL;
330 if (OCRepPayloadGetPropString(payload, OC_RSRVD_DEVICE_ID, &deviceid))
332 VERIFY_SQLITE(sqlite3_bind_text(stmt, device_index, deviceid, strlen(deviceid) + 1, SQLITE_STATIC));
336 if (OCRepPayloadGetPropInt(payload, OC_RSRVD_DEVICE_TTL, &ttl))
338 VERIFY_SQLITE(sqlite3_bind_int(stmt, ttl_index, ttl));
341 char rdAddress[MAX_URI_LENGTH];
342 snprintf(rdAddress, MAX_URI_LENGTH, "%s:%d", address->addr, address->port);
343 OIC_LOG_V(DEBUG, TAG, "Address: %s", rdAddress);
344 VERIFY_SQLITE(sqlite3_bind_text(stmt, address_index, rdAddress, strlen(rdAddress) + 1, SQLITE_STATIC));
346 if (SQLITE_DONE != sqlite3_step(stmt))
348 sqlite3_finalize(stmt);
349 return OC_STACK_ERROR;
351 VERIFY_SQLITE(sqlite3_finalize(stmt));
353 VERIFY_SQLITE(sqlite3_exec(gRDDB, "COMMIT", NULL, NULL, NULL));
355 int64_t rowid = sqlite3_last_insert_rowid(gRDDB);
358 VERIFY_SQLITE(storeLinkPayload(payload, rowid));
364 OCStackResult OCRDDatabaseDeleteDevice(const char *deviceId)
367 VERIFY_SQLITE(sqlite3_exec(gRDDB, "BEGIN TRANSACTION", NULL, NULL, NULL));
369 sqlite3_stmt *stmt = 0;
370 char *delDevice = "DELETE FROM RD_DEVICE_LIST WHERE "XSTR(OC_RSRVD_DEVICE_ID)" = ?";
371 VERIFY_SQLITE(sqlite3_prepare_v2(gRDDB, delDevice, strlen(delDevice) + 1, &stmt, NULL));
373 VERIFY_SQLITE(sqlite3_bind_text(stmt, 1, deviceId, strlen(deviceId) + 1, SQLITE_STATIC));
375 if (SQLITE_DONE != sqlite3_step(stmt))
377 sqlite3_exec(gRDDB, "ROLLBACK", NULL, NULL, NULL);
378 sqlite3_finalize(stmt);
379 return OC_STACK_ERROR;
381 VERIFY_SQLITE(sqlite3_finalize(stmt));
382 VERIFY_SQLITE(sqlite3_exec(gRDDB, "COMMIT", NULL, NULL, NULL));