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
|
#ifndef DBSQLITE_H
#define DBSQLITE_H
#include "db.h"
#include "../returncode.h"
#include "sqlerror.h"
#include "sqlresults.h"
#include "../dialect.h"
#include <QObject>
#include <QSqlDatabase>
#include <QVariant>
#include <QList>
#include <QMap>
#include <QHash>
#include <QMutex>
#include <QRunnable>
class AsyncQueryRunner;
class DbSqlite : public Db
{
Q_OBJECT
public:
virtual ~DbSqlite();
static DbPtr getInstance(const QString &name, const QString& path,
const QString &options = QString::null);
QString getName();
QString getPath();
quint8 getVersion();
virtual QString driver() = 0;
Dialect getDialect();
quint32 asyncExec(const QString& query, const QVariant& arg1 = QVariant(),
const QVariant& arg2 = QVariant(), const QVariant& arg3 = QVariant());
quint32 asyncExecStr(const QString& query, const QVariant& arg1 = QVariant(),
const QVariant& arg2 = QVariant(), const QVariant& arg3 = QVariant());
quint32 asyncExecArgs(const QString& query, const QList<QVariant>& args);
quint32 asyncExecArgs(const QString& query, const QMap<QString,QVariant>& args);
void begin();
bool commit();
void rollback();
QString getType();
SqlError lastError();
protected:
Db();
void cleanUp();
QString generateUniqueDbName();
bool isOpenNoLock();
quint32 asyncExec(AsyncQueryRunner* runner);
SqlResultsPtr execInternal(const QString& query, const QList<QVariant>& args,
bool singleCell);
SqlResultsPtr execInternal(const QString& query, const QMap<QString,QVariant>& args,
bool singleCell);
bool init();
QSqlDatabase db;
quint8 version = 0;
public slots:
bool openQuiet();
bool closeQuiet();
};
#endif // DBSQLITE_H
|
