1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
#include "stdafx.h"
void CDbxSQLite::InitContacts()
{
sqlite3_stmt *stmt = nullptr;
sqlite3_prepare_v2(m_db, "SELECT contacts.id, COUNT(es.id) FROM contacts LEFT JOIN events_srt es ON es.contact_id = contacts.id GROUP BY contacts.id;", -1, &stmt, nullptr);
int rc = 0;
while ((rc = sqlite3_step(stmt)) == SQLITE_ROW) {
if (MCONTACT hContact = sqlite3_column_int64(stmt, 0)) {
DBCachedContact *cc = m_cache->AddContactToCache(hContact);
cc->m_count = sqlite3_column_int64(stmt, 1);
}
}
logError(rc, __FILE__, __LINE__);
sqlite3_finalize(stmt);
m_system.m_count = GetContactEventCount(0);
}
int CDbxSQLite::GetContactEventCount(MCONTACT hContact)
{
auto *stmt = InitQuery("SELECT COUNT(1) FROM events_srt WHERE contact_id = ?;", qCntCountEvents);
sqlite3_bind_int64(stmt, 1, hContact);
logError(sqlite3_step(stmt), __FILE__, __LINE__);
int count = sqlite3_column_int64(stmt, 0);
sqlite3_reset(stmt);
return count;
}
int CDbxSQLite::GetContactCount()
{
mir_cslock lock(m_csDbAccess);
sqlite3_stmt *stmt = InitQuery("SELECT COUNT(1) FROM contacts LIMIT 1;", qCntCount);
int rc = sqlite3_step(stmt);
logError(rc, __FILE__, __LINE__);
int count = sqlite3_column_int(stmt, 0);
sqlite3_reset(stmt);
return count;
}
MCONTACT CDbxSQLite::AddContact()
{
MCONTACT hContact = INVALID_CONTACT_ID;
{
mir_cslock lock(m_csDbAccess);
sqlite3_stmt *stmt = InitQuery("INSERT INTO contacts VALUES (null);", qCntAdd);
int rc = sqlite3_step(stmt);
logError(rc, __FILE__, __LINE__);
sqlite3_reset(stmt);
if (rc != SQLITE_DONE)
return INVALID_CONTACT_ID;
hContact = sqlite3_last_insert_rowid(m_db);
DBFlush();
}
DBCachedContact *cc = m_cache->AddContactToCache(hContact);
if (cc == nullptr)
return INVALID_CONTACT_ID;
NotifyEventHooks(g_hevContactAdded, hContact);
return hContact;
}
int CDbxSQLite::DeleteContact(MCONTACT hContact)
{
// global contact cannot be removed
if (hContact == 0)
return 1;
DBCachedContact *cc = m_cache->GetCachedContact(hContact);
if (cc == nullptr)
return 1;
NotifyEventHooks(g_hevContactDeleted, hContact);
mir_cslockfull lock(m_csDbAccess);
sqlite3_stmt *stmt = InitQuery("DELETE FROM events WHERE contact_id = ?;", qCntDelEvents);
sqlite3_bind_int64(stmt, 1, hContact);
int rc = sqlite3_step(stmt);
logError(rc, __FILE__, __LINE__);
sqlite3_reset(stmt);
if (rc != SQLITE_DONE)
return 1;
stmt = InitQuery("DELETE FROM events_srt WHERE contact_id = ?;", qCntDelEventSrt);
sqlite3_bind_int64(stmt, 1, hContact);
rc = sqlite3_step(stmt);
logError(rc, __FILE__, __LINE__);
sqlite3_reset(stmt);
if (rc != SQLITE_DONE)
return 1;
stmt = InitQuery("DELETE FROM settings WHERE contact_id = ?;", qCntDelSettings);
sqlite3_bind_int64(stmt, 1, hContact);
rc = sqlite3_step(stmt);
logError(rc, __FILE__, __LINE__);
sqlite3_reset(stmt);
if (rc != SQLITE_DONE)
return 1;
stmt = InitQuery("DELETE FROM contacts WHERE id = ?;", qCntDel);
sqlite3_bind_int64(stmt, 1, hContact);
rc = sqlite3_step(stmt);
logError(rc, __FILE__, __LINE__);
sqlite3_reset(stmt);
if (rc != SQLITE_DONE)
return 1;
m_cache->FreeCachedContact(hContact);
lock.unlock();
DBFlush();
return 0;
}
BOOL CDbxSQLite::IsDbContact(MCONTACT hContact)
{
DBCachedContact *cc = m_cache->GetCachedContact(hContact);
return (cc != nullptr);
}
int CDbxSQLite::GetContactSize(void)
{
return sizeof(DBCachedContact);
}
|
