summaryrefslogtreecommitdiff
path: root/mg_db_gd_pg.h
blob: 10ba9c59fcb53805dc8f9b4b2938446ce7f8900c (plain)
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
/*!
 * \file   mg_db_gd_mysql.h
 * \brief  A capsule around giantdisc database access
 *
 * \version $Revision: 1.2 $
 * \date    $Date: 2005-04-13 17:42:54 +0100 (Thu, 13 Apr 2005) $
 * \author  Wolfgang Rohdewald
 * \author  Responsible author: $Author: wolfgang61 $
 */

#ifndef __MG_DB_GD_H
#define __MG_DB_GD_H

#include <string>
#include <tag.h>
#include <map>
#include <libpq-fe.h>

using namespace std;

#include "mg_db.h"

class mgDbServerPG : public mgDbServerImp
{
};

class mgSQLStringPG : public mgSQLStringImp
{
	public:
		mgSQLStringPG(const char* s);
		~mgSQLStringPG();
		char *unquoted() const;
	private:
		mutable char* m_unquoted;
};

class mgQueryPG : public mgQueryImp
{
	public:
		mgQueryPG(void* db,string sql,mgQueryNoise noise);
		~mgQueryPG();
		char ** Next();
	private:
		PGresult *m_table;
		PGconn *m_db;
		char *m_rowpointers[100];
};

class mgDbGd : public mgDb
{
	public:
		mgDbGd (bool SeparateThread=false);
		~mgDbGd();
		bool ServerConnect();
		bool ConnectDatabase();
		bool Creatable();
		bool Create();
		bool Clear();

		bool NeedGenre2();
		long thread_id() { return -1; }
		bool FieldExists(string table, string field);
		bool Threadsafe();
		const char* Options() const;
		const char* HelpText() const;
		const char *DecadeExpr();
		string Now() const { return "CURRENT_TIMESTAMP";}
		string Directory() const { return "substring(tracks.mp3file from '.*/(.*)')"; }
	protected:
		void StartTransaction();
		void Commit();
		void *ImplDbHandle() const { return (void*)m_db;}
	private:
		bool myCreate();
		PGconn *m_db;
		bool SetCharset();

};
#endif