Differential D5771 Diff 14293 src/drivers/mysql/MysqlConnection_p.h

Changeset View

Standalone View

View Options

src/drivers/mysql/MysqlConnection_p.h

Show First 20 Lines • Show All 57 Lines • ▼ Show 20 Line(s)46public:
58 58​
59 //! Disconnects from the database 59​ //! Disconnects from the database
60 bool db_disconnect(); 60​ bool db_disconnect();
61 61​
62 //! Selects a database that is about to be used 62​ //! Selects a database that is about to be used
63 bool useDatabase(const QString &dbName = QString()); 63​ bool useDatabase(const QString &dbName = QString());
64 64​
65 //! Executes query for a raw SQL statement @a sql using mysql_real_query() 65​ //! Executes query for a raw SQL statement @a sql using mysql_real_query()
66 bool executeVoidSQL(const KDbEscapedString& sql); 66​ bool executeSql(const KDbEscapedString& sql);
67 67​
68 static QString serverResultName(MYSQL *mysql); 68​ static QString serverResultName(MYSQL *mysql);
69 69​
70 void storeResult(KDbResult *result); 70​ void storeResult(KDbResult *result);
71 71​
72 MYSQL *mysql; 72​ MYSQL *mysql;
73 bool mysql_owned; //!< true if mysql pointer should be freed on destruction 73​ bool mysql_owned; //!< true if mysql pointer should be freed on destruction
74 int res; //!< result code of last operation on server 74​ int res; //!< result code of last operation on server
▲ Show 20 Lines • Show All 99 Lines • ▼ Show 20 Line(s)171 if (!fields) {
174 } 174​ }
175 fields = mysql_fetch_fields(data); 175​ fields = mysql_fetch_fields(data);
176 } 176​ }
177 return new MysqlSqlField(fields + index); 177​ return new MysqlSqlField(fields + index);
178 } 178​ }
179 179​
180 KDbField *createField(const QString &tableName, int index) override Q_REQUIRED_RESULT; 180​ KDbField *createField(const QString &tableName, int index) override Q_REQUIRED_RESULT;
181 181​
182 inline KDbSqlRecord* fetchRecord() override Q_REQUIRED_RESULT { 182​ inline QSharedPointer<KDbSqlRecord> fetchRecord() override Q_REQUIRED_RESULT {
183​ QSharedPointer<KDbSqlRecord> record;
183 MYSQL_ROW row = data ? mysql_fetch_row(data) : nullptr; 184​ MYSQL_ROW row = data ? mysql_fetch_row(data) : nullptr;
184 if (!row) { 185​ if (!row) {
185 return nullptr; 186​ return record;
186 } 187​ }
187 unsigned long* lengths = mysql_fetch_lengths(data); 188​ unsigned long* lengths = mysql_fetch_lengths(data);
188 return new MysqlSqlRecord(row, lengths); 189​ record.reset(new MysqlSqlRecord(row, lengths));
190​ return record;
189 } 191​ }
190 192​
191 inline KDbResult lastResult() override { 193​ inline KDbResult lastResult() override {
192 KDbResult res; 194​ KDbResult res;
193 const int err = mysql_errno(conn->d->mysql); 195​ const int err = mysql_errno(conn->d->mysql);
194 if (err != 0) { 196​ if (err != 0) {
195 res.setCode(ERR_OTHER); 197​ res.setCode(ERR_OTHER);
196 res.setServerErrorCode(err); 198​ res.setServerErrorCode(err);
Show All 31 Lines