Differential D5771 Diff 14293 src/drivers/postgresql/PostgresqlConnection_p.h

Changeset View

Standalone View

View Options

src/drivers/postgresql/PostgresqlConnection_p.h

Show All 38 Lines
39class PostgresqlConnectionInternal : public KDbConnectionInternal 39​class PostgresqlConnectionInternal : public KDbConnectionInternal
40{ 40​{
41public: 41​public:
42 explicit PostgresqlConnectionInternal(KDbConnection *connection); 42​ explicit PostgresqlConnectionInternal(KDbConnection *connection);
43 43​
44 virtual ~PostgresqlConnectionInternal(); 44​ virtual ~PostgresqlConnectionInternal();
45 45​
46 //! Executes query for a raw SQL statement @a sql on the database 46​ //! Executes query for a raw SQL statement @a sql on the database
47 PGresult* executeSQL(const KDbEscapedString& sql); 47​ PGresult* executeSql(const KDbEscapedString& sql);
48 48​
49 static QString serverResultName(int resultCode); 49​ static QString serverResultName(int resultCode);
50 50​
51 void storeResultAndClear(KDbResult *result, PGresult **pgResult, ExecStatusType execStatus); 51​ void storeResultAndClear(KDbResult *result, PGresult **pgResult, ExecStatusType execStatus);
52 52​
53 void storeResult(KDbResult *result); 53​ void storeResult(KDbResult *result);
54 54​
55 //! @return true if status of connection is "OK". 55​ //! @return true if status of connection is "OK".
▲ Show 20 Lines • Show All 100 Lines • ▼ Show 20 Line(s)139public:
156 } 156​ }
157 157​
158 inline KDbSqlField *field(int index) override Q_REQUIRED_RESULT { 158​ inline KDbSqlField *field(int index) override Q_REQUIRED_RESULT {
159 return new PostgresqlSqlField(result, index); 159​ return new PostgresqlSqlField(result, index);
160 } 160​ }
161 161​
162 KDbField *createField(const QString &tableName, int index) override Q_REQUIRED_RESULT; 162​ KDbField *createField(const QString &tableName, int index) override Q_REQUIRED_RESULT;
163 163​
164 inline KDbSqlRecord* fetchRecord() override Q_REQUIRED_RESULT { 164​ inline QSharedPointer<KDbSqlRecord> fetchRecord() override Q_REQUIRED_RESULT
165 return recordToFetch < recordsCount 165​ {
166​ return QSharedPointer<KDbSqlRecord>(recordToFetch < recordsCount
166 ? new PostgresqlSqlRecord(result, recordToFetch++) 167​ ? new PostgresqlSqlRecord(result, recordToFetch++)
167 : nullptr; 168​ : nullptr);
168 } 169​ }
169 170​
170 inline KDbResult lastResult() override { 171​ inline KDbResult lastResult() override {
171 KDbResult r; 172​ KDbResult r;
172 if (resultStatus == PGRES_TUPLES_OK || resultStatus == PGRES_COMMAND_OK) { 173​ if (resultStatus == PGRES_TUPLES_OK || resultStatus == PGRES_COMMAND_OK) {
173 return r; 174​ return r;
174 } 175​ }
175 QByteArray msg(PQresultErrorMessage(result)); 176​ QByteArray msg(PQresultErrorMessage(result));
Show All 29 Lines