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
127
128
129
130
131
132
133
|
/***************************************************************************
* Copyright (C) 2004-2005 Mark Kretschmann <markey@web.de> *
* 2004 Christian Muehlhaeuser <chris@chris.de> *
* 2004 Sami Nieminen <sami.nieminen@iki.fi> *
* 2005 Ian Monroe <ian@monroe.nu> *
* *
* This program is free software; you can redistribute it and/or modify *
* it under the terms of the GNU General Public License as published by *
* the Free Software Foundation; either version 2 of the License, or *
* (at your option) any later version. *
* *
* This program is distributed in the hope that it will be useful, *
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
* GNU General Public License for more details. *
* *
* You should have received a copy of the GNU General Public License *
* along with this program; if not, write to the *
* Free Software Foundation, Inc., *
* 51 Franklin Steet, Fifth Floor, Boston, MA 02110-1301, USA. *
***************************************************************************/
#ifndef AMAROK_DBENGINEBASE_H
#define AMAROK_DBENGINEBASE_H
#include "plugin/plugin.h" //baseclass
#include <tqobject.h> //baseclass
class DbConfig
{};
class DbConnection : public TQObject, public amaroK::Plugin
{
public:
enum DbConnectionType { sqlite = 0, mysql = 1, postgresql = 2 };
DbConnection( DbConfig* /* config */ );
virtual ~DbConnection() = 0;
virtual TQStringList query( const TQString& /* statement */ ) = 0;
virtual int insert( const TQString& /* statement */, const TQString& /* table */ ) = 0;
const bool isInitialized() const { return m_initialized; }
virtual bool isConnected() const = 0;
virtual const TQString lastError() const { return "None"; }
protected:
bool m_initialized;
DbConfig *m_config;
};
class QueryBuilder
{
public:
//attributes:
enum qBuilderTables { tabAlbum = 1, tabArtist = 2, tabGenre = 4, tabYear = 8, tabSong = 32, tabStats = 64, tabDummy = 0 };
enum qBuilderOptions { optNoCompilations = 1, optOnlyCompilations = 2, optRemoveDuplicates = 4, optRandomize = 8 };
enum qBuilderValues { valID = 1, valName = 2, valURL = 4, valTitle = 8, valTrack = 16, valScore = 32, valComment = 64,
valBitrate = 128, valLength = 256, valSamplerate = 512, valPlayCounter = 1024,
valCreateDate = 2048, valAccessDate = 4096, valPercentage = 8192, valArtistID = 16384, valAlbumID = 32768,
valYearID = 65536, valGenreID = 131072, valDummy = 0 };
enum qBuilderFunctions { funcCount = 1, funcMax = 2, funcMin = 4, funcAvg = 8, funcSum = 16 };
enum qBuilderFilter { modeNormal = 0, modeFuzzy = 1 };
QueryBuilder();
TQString escapeString( TQString string )
{
return
#ifdef USE_MYSQL
// We have to escape "\" for mysql, but can't do so for sqlite
(m_dbConnType == DbConnection::mysql)
? string.replace("\\", "\\\\").replace( '\'', "''" )
:
#endif
string.replace( '\'', "''" );
}
void addReturnValue( int table, int value );
void addReturnFunctionValue( int function, int table, int value);
uint countReturnValues();
void addURLFilters( const TQStringList& filter );
void addFilter( int tables, const TQString& filter, int mode = modeNormal );
void addFilters( int tables, const TQStringList& filter );
void excludeFilter( int tables, const TQString& filter );
void addMatch( int tables, const TQString& match );
void addMatch( int tables, int value, const TQString& match );
void addMatches( int tables, const TQStringList& match );
void excludeMatch( int tables, const TQString& match );
void exclusiveFilter( int tableMatching, int tableNotMatching, int value );
void setOptions( int options );
void sortBy( int table, int value, bool descending = false );
void sortByFunction( int function, int table, int value, bool descending = false );
void groupBy( int table, int value );
void setLimit( int startPos, int length );
void initSQLDrag();
void buildQuery();
TQString getQuery();
TQString query() { buildQuery(); return m_query; };
void clear();
TQStringList run();
private:
TQString tableName( int table );
TQString valueName( int value );
TQString functionName( int value );
void linkTables( int tables );
TQString m_query;
TQString m_values;
TQString m_tables;
TQString m_join;
TQString m_where;
TQString m_sort;
TQString m_group;
TQString m_limit;
int m_linkTables;
uint m_returnValues;
};
#endif /*AMAROK_DBENGINEBASE_H*/
|
