Changeset View
Changeset View
Standalone View
Standalone View
src/drivers/postgresql/PostgresqlConnection_p.h
Show All 38 Lines | |||||
39 | class PostgresqlConnectionInternal : public KDbConnectionInternal | 39 | class PostgresqlConnectionInternal : public KDbConnectionInternal | ||
40 | { | 40 | { | ||
41 | public: | 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) | 139 | public: | |||
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 |