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 "history.h"
History::History(QString storage, quint32 my_id)
: me_(my_id)
{
dbconn=QSqlDatabase::addDatabase("QSQLITE");
dbconn.setDatabaseName(storage);
if (!dbconn.open())
{
lasterr=dbconn.lastError();
return;
}
QSqlQuery query;
query.exec("PRAGMA foreign_keys=ON;");
//check result, if foreign keys support is on
}
void History::Add(quint32 peer_id, QString message, bool is_me)
{
QSqlQuery query;
query.prepare("insert into history (contact_id, account_id, timestamp, is_me, is_delivered, message) \
values (:peer_id, :me, strftime('%s','now'), :is_me, :is_delivered, :message)");
query.bindValue(":peer_id", peer_id);
query.bindValue(":me", me_);
if (is_me)
{
query.bindValue(":is_me", 1);
query.bindValue(":is_delivered", 0);
}
else
{
query.bindValue(":is_me", 0);
query.bindValue(":is_delivered", 1);
}
query.bindValue(":message", message);
query.exec();
lasterr=query.lastError();
}
void History::SetDelivered(quint32 peer_id)
{
QSqlQuery query;
query.prepare("update history set is_delivered=1 where id in \
(select id from history where \
is_delivered=0 and is_me=1 and contact_id=:peer_id and account_id=:me order by id asc limit 1)"
);
query.bindValue(":peer_id", peer_id);
query.bindValue(":me", me_);
query.exec();
lasterr=query.lastError();
}
QList<History::HistoryRecord> History::GetMessages(quint32 peer_id, quint32 start_timestamp, quint32 end_timestamp)
{
QList<HistoryRecord> L;
HistoryRecord r;
QSqlQuery query;
query.setForwardOnly(true);
query.prepare("select contact_id, is_me, is_delivered, timestamp, message from history \
where contact_id=:peer_id and account_id=:me and timestamp >= :start and timestamp <=:end order by id"
);
query.bindValue(":peer_id", peer_id);
query.bindValue(":me", me_);
query.bindValue(":start", start_timestamp);
query.bindValue(":end", end_timestamp);
query.exec();
lasterr=query.lastError();
if (lasterr.isValid())
return L;
while(query.next())
{
r.peer_id = query.value(0).toUInt();
r.is_me = query.value(1).toBool();
r.is_delivered = query.value(2).toBool();
r.timestamp = query.value(3).toUInt();
r.message = query.value(4).toString();
L<<r;
}
return L;
}
QMap<quint32, QList<QString> > History::GetUndeliveredMessages()
{
QMap<quint32, QList<QString> > M;
QSqlQuery query;
query.setForwardOnly(true);
query.prepare("select contact_id, message from history \
where account_id=:me and is_delivered=0 and is_me=1 order by id"
);
query.bindValue(":me", me_);
query.exec();
lasterr=query.lastError();
if (lasterr.isValid())
return M;
while(query.next())
{
M[query.value(0).toUInt()] << query.value(1).toString();
}
return M;
}
|
