dedupe: DBCache.hpp annotate

annotate DBCache.hpp @ 16:06166d6c083b

Add configuration processing. Cache DB values Add a custom RBTree to save space. Track multiple DB connections properly. More testing. Add ValueExistsException.

author	Tom Fredrik Blenning Klaussen <bfg@blenning.no>
date	Tue, 28 Aug 2012 18:58:02 +0200
parents
children	5d14d8c2c299

rev	line source
16 06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	1 #ifndef DBCACHE_HPP
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	2 #define DBCACHE_HPP
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	3
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	4 #include <QtSql/QSqlDatabase>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	5 #include <QtSql/QSqlQuery>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	6 #include <QtSql/QSqlError>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	7 #include <QtSql/QSqlRecord>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	8
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	9 #include <QtCore/QDebug>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	10 #include <QtCore/QStringList>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	11 #include <cassert>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	12 #include "OrderedPair.hpp"
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	13
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	14 #include <boost/optional.hpp>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	15
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	16 #include "ThreadSafeLookup.hpp"
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	17 #include "UniqueString.hpp"
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	18
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	19
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	20 template<typename T>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	21 struct SQLGenerator
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	22 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	23 };
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	24
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	25 template<>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	26 struct SQLGenerator<int>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	27 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	28 static QString fieldName(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	29 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	30 return QString("%1_Int").arg(prefix);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	31 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	32
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	33 static QString createFields(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	34 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	35 return QString("%1 INTEGER").arg(fieldName(prefix));
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	36 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	37
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	38 static QString valueString(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	39 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	40 return QString(":") + fieldName(prefix);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	41 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	42
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	43 static void bindValue(QSqlQuery& query, int value, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	44 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	45 query.bindValue(valueString(prefix), value);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	46 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	47
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	48 static void bindValues(QSqlQuery& query, const QVariantList& values, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	49 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	50 query.bindValue(valueString(prefix), values);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	51 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	52
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	53 static void bindValues(QSqlQuery& query, const QList<int>& values, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	54 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	55 QVariantList list;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	56 foreach(int value, values) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	57 list << value;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	58 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	59 bindValues(query, list, prefix);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	60 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	61
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	62 static boost::optional<int> extract(QSqlQuery& query, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	63 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	64 int fieldNo = query.record().indexOf(fieldName(prefix));
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	65 if (query.at() >= 0)
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	66 return query.value(fieldNo).toInt();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	67 else
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	68 return boost::optional<int>();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	69 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	70
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	71 };
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	72
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	73 template<>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	74 struct SQLGenerator<QString>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	75 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	76 static QString fieldName(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	77 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	78 return QString("%1_QString").arg(prefix);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	79 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	80
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	81 static QString createFields(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	82 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	83 return QString("%1 TEXT").arg(fieldName(prefix));
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	84 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	85
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	86 static QString valueString(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	87 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	88 return QString(":") + fieldName(prefix);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	89 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	90
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	91 static QString restrict(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	92 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	93 return QString("%1 = %2").arg(fieldName(prefix)).arg(valueString(prefix));
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	94 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	95
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	96 static void bindValue(QSqlQuery& query, const QString& value, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	97 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	98 query.bindValue(valueString(prefix), value);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	99 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	100
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	101 static void bindValues(QSqlQuery& query, const QVariantList& value, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	102 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	103 query.bindValue(valueString(prefix), value);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	104 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	105
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	106 static void bindValues(QSqlQuery& query, const QList<QString>& values, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	107 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	108 QVariantList list;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	109 foreach(const QString& value, values) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	110 list << value;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	111 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	112 bindValues(query, list, prefix);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	113 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	114
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	115 static boost::optional<QString> extract(QSqlQuery& query, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	116 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	117 int fieldNo = query.record().indexOf(fieldName(prefix));
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	118 if (query.at() >= 0)
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	119 return query.value(fieldNo).toString();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	120 else
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	121 return boost::optional<QString>();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	122 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	123
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	124
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	125 };
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	126
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	127 template<>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	128 struct SQLGenerator<UniqueString>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	129 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	130 static QString fieldName(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	131 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	132 return QString("%1_QString").arg(prefix);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	133 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	134
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	135 static QString createFields(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	136 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	137 return QString("%1 TEXT").arg(fieldName(prefix));
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	138 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	139
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	140 static QString valueString(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	141 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	142 return QString(":") + fieldName(prefix);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	143 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	144
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	145 static QString restrict(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	146 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	147 return QString("%1 = %2").arg(fieldName(prefix)).arg(valueString(prefix));
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	148 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	149
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	150 static void bindValue(QSqlQuery& query, const QString& value, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	151 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	152 query.bindValue(valueString(prefix), value);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	153 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	154
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	155 static void bindValues(QSqlQuery& query, const QVariantList& value, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	156 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	157 query.bindValue(valueString(prefix), value);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	158 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	159
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	160 static void bindValues(QSqlQuery& query, const QList<UniqueString>& values, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	161 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	162 QVariantList list;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	163 foreach(const QString& value, values) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	164 list << value;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	165 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	166 bindValues(query, list, prefix);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	167 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	168
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	169 static boost::optional<QString> extract(QSqlQuery& query, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	170 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	171 int fieldNo = query.record().indexOf(fieldName(prefix));
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	172 if (query.at() >= 0)
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	173 return query.value(fieldNo).toString();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	174 else
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	175 return boost::optional<QString>();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	176 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	177
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	178
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	179 };
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	180
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	181 template<typename T>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	182 struct SQLGenerator<OrderedPair<T> >
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	183 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	184 static QString fieldName(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	185 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	186 return SQLGenerator<T>::fieldName(prefix + "_1") + ", " +
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	187 SQLGenerator<T>::fieldName(prefix + "_2");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	188 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	189
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	190 static QString createFields(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	191 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	192 return SQLGenerator<T>::createFields(prefix + "_1") + ", " +
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	193 SQLGenerator<T>::createFields(prefix + "_2");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	194 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	195
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	196 static QString restriction(const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	197 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	198 return SQLGenerator<T>::restrict(prefix + "_1") + " AND " +
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	199 SQLGenerator<T>::restrict(prefix + "_2");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	200 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	201
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	202 static QString valueString(const QString &prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	203 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	204 return SQLGenerator<T>::valueString(prefix + "_1") + ", " +
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	205 SQLGenerator<T>::valueString(prefix + "_2");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	206 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	207
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	208 static void bindValue(QSqlQuery& query, const OrderedPair<T>& value, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	209 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	210 SQLGenerator<T>::bindValue(query, value.first, prefix + "_1");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	211 SQLGenerator<T>::bindValue(query, value.second, prefix + "_2");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	212 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	213
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	214 static void bindValues(QSqlQuery& query, const QList<OrderedPair<T> >& values, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	215 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	216 QList<T> first;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	217 QList<T> second;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	218 foreach(OrderedPair<T> value, values) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	219 first << value.first;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	220 second << value.second;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	221 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	222 SQLGenerator<T>::bindValues(query, first, prefix + "_1");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	223 SQLGenerator<T>::bindValues(query, second, prefix + "_2");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	224 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	225
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	226 static boost::optional<OrderedPair<T> > extract(QSqlQuery& query, const QString& prefix = QString())
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	227 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	228 if (query.at() >= 0)
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	229 return OrderedPair<T> (*SQLGenerator<T>::extract(query, prefix + "_1"),
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	230 *SQLGenerator<T>::extract(query, prefix + "_2"));
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	231 else
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	232 return boost::optional<OrderedPair<T> >();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	233 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	234
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	235
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	236 };
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	237
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	238 template<typename Key, typename Value, bool memoryMapped = false>
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	239 class DBCache
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	240 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	241 private:
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	242 ThreadSafeLookup<Key, Value> memoryMap;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	243 QList<Key> unsyncedKeys;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	244
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	245 void setup(const QSqlDatabase& db, const QString& dictName)
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	246 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	247 this->dictName = dictName;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	248 if (!db.tables().contains(dictName)) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	249 QString keyFields = SQLGenerator<Key>::createFields("key");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	250 QString valueFields = SQLGenerator<Value>::createFields("value");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	251 QString createQuery = QString("CREATE TABLE %1(%2, %3);").arg(dictName).arg(keyFields).arg(valueFields);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	252 QSqlQuery query(db);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	253 query.exec(createQuery);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	254 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	255 if (!db.tables().contains(dictName)) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	256 qDebug()<<"No database";
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	257 exit(1);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	258 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	259 if (memoryMapped) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	260 QString keyFields = SQLGenerator<Key>::fieldName("key");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	261 QString valueFields = SQLGenerator<Value>::fieldName("value");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	262 QString repopulateQuery = QString("SELECT %1, %2 FROM %3;").arg(keyFields).arg(valueFields).arg(dictName);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	263 QSqlQuery query(db);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	264 if (!query.exec(repopulateQuery)) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	265 qDebug() << query.lastError() << repopulateQuery;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	266 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	267 while (query.next()) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	268 Key key = *SQLGenerator<Key>::extract(query, "key");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	269 Value value = *SQLGenerator<Value>::extract(query, "value");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	270 memoryMap.insert(key, value);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	271 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	272 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	273 QString queryString = QString("INSERT into %1 (%2, %3) VALUES(%4, %5);")
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	274 .arg(dictName)
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	275 .arg(SQLGenerator<Key>::fieldName("key"))
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	276 .arg(SQLGenerator<Value>::fieldName("value"))
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	277 .arg(SQLGenerator<Key>::valueString("key"))
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	278 .arg(SQLGenerator<Value>::valueString("value"));
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	279 insertQuery = QSqlQuery(db);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	280 insertQuery.prepare(queryString);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	281 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	282
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	283 void syncInsert()
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	284 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	285 SQLGenerator<Key>::bindValues(insertQuery, unsyncedKeys, "key");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	286 QList<Value> values;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	287 foreach(Key key, unsyncedKeys) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	288 values << *memoryMap.value(key);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	289 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	290 SQLGenerator<Value>::bindValues(insertQuery, values, "value");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	291 if (!insertQuery.exec()) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	292 qDebug() << insertQuery.lastError() << insertQuery.lastQuery();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	293 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	294 insertQuery.finish();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	295 unsyncedKeys.clear();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	296 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	297
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	298 public:
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	299 DBCache(const QString& dbName, const QString& dictName)
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	300 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	301 db = QSqlDatabase::addDatabase("QSQLITE", "dictName");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	302 db.setDatabaseName(dbName);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	303 bool ok = db.open();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	304 assert(ok);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	305 setup(db, dictName);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	306 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	307
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	308 DBCache(const QSqlDatabase& db, const QString& dictName)
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	309 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	310 setup(db, dictName);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	311 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	312
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	313 boost::optional<Value> value(const Key& key) const
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	314 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	315 if (memoryMapped) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	316 return memoryMap.value(key);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	317 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	318 else {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	319 QString queryString = QString("SELECT %1 FROM %2 WHERE %3")
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	320 .arg(SQLGenerator<Value>::fieldName("value"))
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	321 .arg(dictName)
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	322 .arg(SQLGenerator<Key>::restriction("key"));
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	323 QSqlQuery query(db);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	324 query.prepare(queryString);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	325 SQLGenerator<Key>::bindValue(query, key, "key");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	326 if (!query.exec()) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	327 qDebug() << query.lastError() << queryString;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	328 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	329 query.next();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	330 return SQLGenerator<Value>::extract(query, "value");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	331 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	332 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	333
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	334 void insert(const Key& key, const Value& value)
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	335 {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	336 if (memoryMapped) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	337 memoryMap.insert(key, value);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	338 unsyncedKeys.append(key);
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	339 if (unsyncedKeys.size() > 1024) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	340 syncInsert();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	341 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	342 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	343 else {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	344 SQLGenerator<Key>::bindValue(insertQuery, key, "key");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	345 SQLGenerator<Value>::bindValue(insertQuery, value, "value");
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	346 if (!insertQuery.exec()) {
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	347 qDebug() << insertQuery.lastError() << insertQuery.lastQuery();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	348 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	349 insertQuery.finish();
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	350 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	351
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	352 }
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	353
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	354 private:
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	355 QSqlDatabase db;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	356 QString dictName;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	357 QSqlQuery insertQuery;
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	358 };
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	359
06166d6c083b Add configuration processing. Tom Fredrik Blenning Klaussen <bfg@blenning.no> parents: diff changeset	360 #endif //DBCACHE_HPP

Mercurial > dedupe

annotate DBCache.hpp @ 16:06166d6c083b