blob: cf26c84708925dc5cde390a1b7550d239247b9b1 (
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
|
/*
* db_funcs.h
*
* Created on: 11.01.2022
* Author: michi
*/
#ifndef DB_FUNCS_H_
#define DB_FUNCS_H_
//#include "schrank_ant_pcb.h"
#include <vector>
#include <iostream>
#include <string>
#include "SimplePgSQL.h"
class TpgConnection { // rows
public:
TpgConnection();
~TpgConnection();
int db_connect(const char *pg_server_ip, int pg_port, const char *s_db_name, const char *s_db_user, const char *s_db_passwd, const char *s_db_charset);
int db_disconnect(void);
void db_loop(void);
PGconnection *PGconn;
int last_pgError;
};
//int db_query(const char *sql);
class TResSetRows { // 1 entry is a collection of string fields
public:
TResSetRows(); //constructor
~TResSetRows(); //destructor
std::vector<std::string> Spalte;
int numCols;
int CurrCol;
};
class TResultSet { // rows
public:
TResultSet(PGconnection *PGconnFromCon);
~TResultSet();
std::vector<TResSetRows> Zeile;
int CurrentRow;
int db_query(const char *sql);
int db_exec(const char *sql);
int NumRows;
int NumCols;
private:
PGconnection *PGconn;
void process_db_row(void);
void process_db_col(void);
void process_db_summary(void);
void process_db_haveMsg(void);
void process_db_ready(void);
void process_db_cmd_send(void);
void process_db_have_error(void);
void process_db_have_notice(void);
};
#endif /* DB_FUNCS_H_ */
|
