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
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
|
/*
Copyright 2007 - 2008 MySQL AB, 2008 - 2010 Sun Microsystems, Inc. All rights reserved.
The MySQL Connector/C++ is licensed under the terms of the GPL
<http://www.gnu.org/licenses/old-licenses/gpl-2.0.html>, like most
MySQL Connectors. There are special exceptions to the terms and
conditions of the GPL as it is applied to this software, see the
FLOSS License Exception
<http://www.mysql.com/about/legal/licensing/foss-exception.html>.
*/
#ifndef _MYSQL_PS_RESULTSET_H_
#define _MYSQL_PS_RESULTSET_H_
#include <boost/scoped_ptr.hpp>
#include <boost/shared_ptr.hpp>
#include <cppconn/resultset.h>
#include <config.h>
#include "nativeapi/mysql_private_iface.h"
namespace sql
{
namespace mysql
{
class MySQL_Prepared_Statement;
class MySQL_DebugLogger;
class MySQL_PreparedResultSetMetaData;
class MySQL_ResultBind;
namespace NativeAPI
{
class NativeStatementWrapper;
}
class MySQL_Prepared_ResultSet : public sql::ResultSet
{
private:
MYSQL_ROW row;
boost::shared_ptr< NativeAPI::NativeStatementWrapper > proxy;
mutable int last_queried_column; // this is updated by calls to getInt(int), getString(int), etc...
unsigned int num_fields;
uint64_t num_rows;
uint64_t row_position;
typedef std::map< sql::SQLString, unsigned int > FieldNameIndexMap;
FieldNameIndexMap field_name_to_index_map;
bool was_null;
const MySQL_Prepared_Statement * parent;
bool is_valid;
boost::shared_ptr< MySQL_DebugLogger > logger;
boost::scoped_ptr< MySQL_PreparedResultSetMetaData > rs_meta;
boost::shared_ptr< MySQL_ResultBind > result_bind;
sql::ResultSet::enum_type resultset_type;
protected:
void checkValid() const;
void checkScrollable() const;
bool isScrollable() const;
void closeIntern();
bool isBeforeFirstOrAfterLast() const;
void seek();
int64_t getInt64_intern(const uint32_t columnIndex, bool cutTooBig) const;
uint64_t getUInt64_intern(const uint32_t columnIndex, bool cutTooBig) const;
public:
MySQL_Prepared_ResultSet(boost::shared_ptr< NativeAPI::NativeStatementWrapper > & s,
boost::shared_ptr< MySQL_ResultBind > & r_bind, sql::ResultSet::enum_type rset_type,
MySQL_Prepared_Statement * par, boost::shared_ptr< MySQL_DebugLogger > &l);
virtual ~MySQL_Prepared_ResultSet();
bool absolute(int row);
void afterLast();
void beforeFirst();
void cancelRowUpdates();
void clearWarnings();
void close();
uint32_t findColumn(const sql::SQLString& columnLabel) const;
bool first();
std::istream * getBlob(uint32_t columnIndex) const;
std::istream * getBlob(const sql::SQLString& columnLabel) const;
bool getBoolean(uint32_t columnIndex) const;
bool getBoolean(const sql::SQLString& columnLabel) const;
int getConcurrency();
SQLString getCursorName();
long double getDouble(uint32_t columnIndex) const;
long double getDouble(const sql::SQLString& columnLabel) const;
int getFetchDirection();
size_t getFetchSize();
int getHoldability();
int32_t getInt(uint32_t columnIndex) const;
int32_t getInt(const sql::SQLString& columnLabel) const;
uint32_t getUInt(uint32_t columnIndex) const;
uint32_t getUInt(const sql::SQLString& columnLabel) const;
int64_t getInt64(uint32_t columnIndex) const;
int64_t getInt64(const sql::SQLString& columnLabel) const;
uint64_t getUInt64(uint32_t columnIndex) const;
uint64_t getUInt64(const sql::SQLString& columnLabel) const;
sql::ResultSetMetaData * getMetaData() const;
size_t getRow() const;
sql::RowID * getRowId(uint32_t columnIndex);
sql::RowID * getRowId(const sql::SQLString & columnLabel);
const sql::Statement * getStatement() const;
SQLString getString(uint32_t columnIndex) const;
SQLString getString(const sql::SQLString& columnLabel) const;
sql::ResultSet::enum_type getType() const;
void getWarnings();
bool isAfterLast() const;
bool isBeforeFirst() const;
bool isClosed() const;
void insertRow();
bool isFirst() const;
bool isLast() const;
bool isNull(uint32_t columnIndex) const;
bool isNull(const sql::SQLString& columnLabel) const;
bool last();
void moveToCurrentRow();
void moveToInsertRow();
bool next();
bool previous();
void refreshRow();
bool relative(int rows);
bool rowDeleted();
bool rowInserted();
bool rowUpdated();
size_t rowsCount() const;
void setFetchSize(size_t rows);
bool wasNull() const;
};
} /* namespace mysql*/
} /* namespace sql*/
#endif // _MYSQL_PS_RESULTSET_H_
/*
* Local variables:
* tab-width: 4
* c-basic-offset: 4
* End:
* vim600: noet sw=4 ts=4 fdm=marker
* vim<600: noet sw=4 ts=4
*/
|
