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
|
//////////////////////////////////////////////////////////////////////////
//
// pgScript - PostgreSQL Tools
//
// Copyright (C) 2002 - 2014, The pgAdmin Development Team
// This software is released under the PostgreSQL Licence
//
//////////////////////////////////////////////////////////////////////////
#ifndef PGSTHREAD_H_
#define PGSTHREAD_H_
#include "pgscript/pgScript.h"
#include "pgscript/objects/pgsVariable.h"
#include <wx/thread.h>
class pgConn;
class pgsApplication;
class pgsStmtList;
class pgsThread : public wxThread
{
private:
/** Symbol table (memory variables). */
pgsVarMap &m_vars;
/** In order to have only one thread at once. */
wxSemaphore &m_mutex;
/** Connection to the database. */
pgConn *m_connection;
/** Either the file to parse or the string. */
wxString m_data;
/** Where to write the output. */
pgsOutputStream &m_out;
/** The calling application. */
pgsApplication &m_app;
/** If set it is the encoding used in the file to parse. */
wxMBConv *m_conv;
/** Location of the last error if there was one otherwise -1 */
int m_last_error_line;
public:
/** Parses a file with the provided encoding. */
pgsThread(pgsVarMap &vars, wxSemaphore &mutex, pgConn *connection,
const wxString &file, pgsOutputStream &out,
pgsApplication &app, wxMBConv *conv);
/** Parses a wxString. */
pgsThread(pgsVarMap &vars, wxSemaphore &mutex, pgConn *connection,
const wxString &string, pgsOutputStream &out, pgsApplication &app);
/** Destructor. */
~pgsThread();
/** Thread main code. */
virtual void *Entry();
/** Retrieves the connection to the database. */
pgConn *connection();
/** Gets a lock on the output stream. */
void LockOutput();
/** Releases the lock on the output stream. */
void UnlockOutput();
/** Set the position (line) of the last error. */
void last_error_line(int line);
/** Get the position (line) of the last error. */
int last_error_line() const;
private:
pgsThread(const pgsThread &that);
pgsThread &operator=(const pgsThread &that);
};
#endif /*PGSTHREAD_H_*/
|
