diff options
| author | Michele Calgaro <michele.calgaro@yahoo.it> | 2025-12-06 17:33:43 +0900 |
|---|---|---|
| committer | Michele Calgaro <michele.calgaro@yahoo.it> | 2025-12-07 11:57:25 +0900 |
| commit | 5a863a8932d14b99c5f838c4efa1618070d71b29 (patch) | |
| tree | 000bd50b5c488635f9663b16b7fbfe5380435a04 /src/sql/drivers/ibase/tqsql_ibase.cpp | |
| parent | 771af909e74927126fba90ec6e0298dc68d5bf4f (diff) | |
| download | tqt-5a863a8932d14b99c5f838c4efa1618070d71b29.tar.gz tqt-5a863a8932d14b99c5f838c4efa1618070d71b29.zip | |
Signed-off-by: Michele Calgaro <michele.calgaro@yahoo.it>
Diffstat (limited to 'src/sql/drivers/ibase/tqsql_ibase.cpp')
| -rw-r--r-- | src/sql/drivers/ibase/tqsql_ibase.cpp | 140 |
1 files changed, 70 insertions, 70 deletions
diff --git a/src/sql/drivers/ibase/tqsql_ibase.cpp b/src/sql/drivers/ibase/tqsql_ibase.cpp index 425d0e311..f7e29999d 100644 --- a/src/sql/drivers/ibase/tqsql_ibase.cpp +++ b/src/sql/drivers/ibase/tqsql_ibase.cpp @@ -46,13 +46,13 @@ public: static bool getIBaseError(TQString& msg, ISC_STATUS* status, long &sqlcode) { if (status[0] != 1 || status[1] <= 0) - return FALSE; + return false; sqlcode = isc_sqlcode(status); char buf[512]; isc_sql_interprete(sqlcode, buf, 512); msg = TQString::fromUtf8(buf); - return TRUE; + return true; } static void createDA(XSQLDA *&sqlda) @@ -227,10 +227,10 @@ public: TQString imsg; long sqlcode; if (!getIBaseError(imsg, status, sqlcode)) - return FALSE; + return false; q->setLastError(TQSqlError(msg, imsg, typ, (int)sqlcode)); - return TRUE; + return true; } public: @@ -252,10 +252,10 @@ public: TQString imsg; long sqlcode; if (!getIBaseError(imsg, status, sqlcode)) - return FALSE; + return false; q->setLastError(TQSqlError(msg, imsg, typ, (int)sqlcode)); - return TRUE; + return true; } bool transaction(); @@ -356,7 +356,7 @@ bool TQIBaseResultPrivate::isSelect() char qType = isc_info_sql_stmt_type; isc_dsql_sql_info(status, &stmt, 1, &qType, sizeof(acBuffer), acBuffer); if (isError("Could not get query info", TQSqlError::Statement)) - return FALSE; + return false; int iLength = isc_vax_integer(&acBuffer[1], 2); queryType = isc_vax_integer(&acBuffer[3], iLength); return (queryType == isc_info_sql_stmt_select); @@ -365,19 +365,19 @@ bool TQIBaseResultPrivate::isSelect() bool TQIBaseResultPrivate::transaction() { if (trans) - return TRUE; + return true; if (db->d->trans) { - localTransaction = FALSE; + localTransaction = false; trans = db->d->trans; - return TRUE; + return true; } - localTransaction = TRUE; + localTransaction = true; isc_start_transaction(status, &trans, 1, &ibase, 0, NULL); if (isError("Could not start transaction", TQSqlError::Statement)) - return FALSE; + return false; - return TRUE; + return true; } // does nothing if the transaction is on the @@ -385,10 +385,10 @@ bool TQIBaseResultPrivate::transaction() bool TQIBaseResultPrivate::commit() { if (!trans) - return FALSE; + return false; // don't commit driver's transaction, the driver will do it for us if (!localTransaction) - return TRUE; + return true; isc_commit_transaction(status, &trans); trans = 0; @@ -413,33 +413,33 @@ bool TQIBaseResult::prepare(const TQString& query) { //tqDebug("prepare: %s", query.ascii()); if (!driver() || !driver()->isOpen() || driver()->isOpenError()) - return FALSE; + return false; d->cleanup(); - setActive(FALSE); + setActive(false); setAt(TQSql::BeforeFirst); createDA(d->sqlda); createDA(d->inda); if (!d->transaction()) - return FALSE; + return false; isc_dsql_allocate_statement(d->status, &d->ibase, &d->stmt); if (d->isError("Could not allocate statement", TQSqlError::Statement)) - return FALSE; + return false; isc_dsql_prepare(d->status, &d->trans, &d->stmt, 0, query.utf8().data(), 3, d->sqlda); if (d->isError("Could not prepare statement", TQSqlError::Statement)) - return FALSE; + return false; isc_dsql_describe_bind(d->status, &d->stmt, 1, d->inda); if (d->isError("Could not describe input statement", TQSqlError::Statement)) - return FALSE; + return false; if (d->inda->sqld > d->inda->sqln) { enlargeDA(d->inda, d->inda->sqld); isc_dsql_describe_bind(d->status, &d->stmt, 1, d->inda); if (d->isError("Could not describe input statement", TQSqlError::Statement)) - return FALSE; + return false; } initDA(d->inda); if (d->sqlda->sqld > d->sqlda->sqln) { @@ -448,7 +448,7 @@ bool TQIBaseResult::prepare(const TQString& query) isc_dsql_describe(d->status, &d->stmt, 1, d->sqlda); if (d->isError("Could not describe statement", TQSqlError::Statement)) - return FALSE; + return false; } initDA(d->sqlda); @@ -458,21 +458,21 @@ bool TQIBaseResult::prepare(const TQString& query) d->sqlda = 0; } - return TRUE; + return true; } bool TQIBaseResult::exec() { if (!driver() || !driver()->isOpen() || driver()->isOpenError()) - return FALSE; - setActive(FALSE); + return false; + setActive(false); setAt(TQSql::BeforeFirst); if (d->inda && extension()->index.count() > 0) { TQMap<int, TQString>::ConstIterator it; if ((int)extension()->index.count() > d->inda->sqld) { tqWarning("TQIBaseResult::exec: Parameter mismatch, expected %d, got %d parameters", d->inda->sqld, extension()->index.count()); - return FALSE; + return false; } int para = 0; for (it = extension()->index.constBegin(); it != extension()->index.constEnd(); ++it, ++para) { @@ -530,7 +530,7 @@ bool TQIBaseResult::exec() memcpy(d->inda->sqlvar[para].sqldata + sizeof(short), str.data(), buflen); break; } case SQL_TEXT: { - TQCString str(val.toString().utf8().leftJustify(d->inda->sqlvar[para].sqllen, ' ', TRUE)); + TQCString str(val.toString().utf8().leftJustify(d->inda->sqlvar[para].sqllen, ' ', true)); memcpy(d->inda->sqlvar[para].sqldata, str.data(), d->inda->sqlvar[para].sqllen); break; } case SQL_BLOB: @@ -545,39 +545,39 @@ bool TQIBaseResult::exec() if (colCount()) { isc_dsql_free_statement(d->status, &d->stmt, DSQL_close); if (d->isError("Unable to close statement")) - return FALSE; + return false; cleanup(); } if (d->sqlda) init(d->sqlda->sqld); isc_dsql_execute2(d->status, &d->trans, &d->stmt, 1, d->inda, 0); if (d->isError("Unable to execute query")) - return FALSE; + return false; - setActive(TRUE); - return TRUE; + setActive(true); + return true; } bool TQIBaseResult::reset (const TQString& query) { // tqDebug("reset: %s", query.ascii()); if (!driver() || !driver()->isOpen() || driver()->isOpenError()) - return FALSE; + return false; d->cleanup(); - setActive(FALSE); + setActive(false); setAt(TQSql::BeforeFirst); createDA(d->sqlda); if (!d->transaction()) - return FALSE; + return false; isc_dsql_allocate_statement(d->status, &d->ibase, &d->stmt); if (d->isError("Could not allocate statement", TQSqlError::Statement)) - return FALSE; + return false; isc_dsql_prepare(d->status, &d->trans, &d->stmt, 0, query.utf8().data(), 3, d->sqlda); if (d->isError("Could not prepare statement", TQSqlError::Statement)) - return FALSE; + return false; if (d->sqlda->sqld > d->sqlda->sqln) { // need more field descriptors @@ -589,7 +589,7 @@ bool TQIBaseResult::reset (const TQString& query) isc_dsql_describe(d->status, &d->stmt, 1, d->sqlda); if (d->isError("Could not describe statement", TQSqlError::Statement)) - return FALSE; + return false; } initDA(d->sqlda); @@ -604,14 +604,14 @@ bool TQIBaseResult::reset (const TQString& query) isc_dsql_execute(d->status, &d->trans, &d->stmt, 1, 0); if (d->isError("Unable to execute query")) - return FALSE; + return false; // commit non-select queries (if they are local) if (!isSelect() && !d->commit()) - return FALSE; + return false; - setActive(TRUE); - return TRUE; + setActive(true); + return true; } bool TQIBaseResult::gotoNext(TQtSqlCachedResult::RowCache* row) @@ -621,12 +621,12 @@ bool TQIBaseResult::gotoNext(TQtSqlCachedResult::RowCache* row) if (stat == 100) { // no more rows setAt(TQSql::AfterLast); - return FALSE; + return false; } if (d->isError("Could not fetch next item", TQSqlError::Statement)) - return FALSE; + return false; if (!row) // not interested in actual values - return TRUE; + return true; Q_ASSERT(row); Q_ASSERT((int)row->size() == d->sqlda->sqld); @@ -691,7 +691,7 @@ bool TQIBaseResult::gotoNext(TQtSqlCachedResult::RowCache* row) } } - return TRUE; + return true; } int TQIBaseResult::size() @@ -768,8 +768,8 @@ TQIBaseDriver::TQIBaseDriver(void *connection, TQObject *parent, const char *nam { d = new TQIBaseDriverPrivate(this); d->ibase = (isc_db_handle)(long int)connection; - setOpen(TRUE); - setOpenError(FALSE); + setOpen(true); + setOpenError(false); } TQIBaseDriver::~TQIBaseDriver() @@ -786,9 +786,9 @@ bool TQIBaseDriver::hasFeature(DriverFeature f) const case PositionalPlaceholders: case Unicode: case BLOB: - return TRUE; + return true; default: - return FALSE; + return false; } } @@ -830,12 +830,12 @@ bool TQIBaseDriver::open(const TQString & db, ldb += db; isc_attach_database(d->status, 0, (char*)ldb.latin1(), &d->ibase, i, ba.data()); if (d->isError("Error opening database", TQSqlError::Connection)) { - setOpenError(TRUE); - return FALSE; + setOpenError(true); + return false; } - setOpen(TRUE); - return TRUE; + setOpen(true); + return true; } void TQIBaseDriver::close() @@ -843,20 +843,20 @@ void TQIBaseDriver::close() if (isOpen()) { isc_detach_database(d->status, &d->ibase); d->ibase = 0; - setOpen(FALSE); - setOpenError(FALSE); + setOpen(false); + setOpenError(false); } } bool TQIBaseDriver::ping() { if ( !isOpen() ) { - return FALSE; + return false; } // FIXME // Implement ping if available - return TRUE; + return true; } TQSqlQuery TQIBaseDriver::createQuery() const @@ -867,9 +867,9 @@ TQSqlQuery TQIBaseDriver::createQuery() const bool TQIBaseDriver::beginTransaction() { if (!isOpen() || isOpenError()) - return FALSE; + return false; if (d->trans) - return FALSE; + return false; isc_start_transaction(d->status, &d->trans, 1, &d->ibase, 0, NULL); return !d->isError("Could not start transaction", TQSqlError::Transaction); @@ -878,9 +878,9 @@ bool TQIBaseDriver::beginTransaction() bool TQIBaseDriver::commitTransaction() { if (!isOpen() || isOpenError()) - return FALSE; + return false; if (!d->trans) - return FALSE; + return false; isc_commit_transaction(d->status, &d->trans); d->trans = 0; @@ -890,9 +890,9 @@ bool TQIBaseDriver::commitTransaction() bool TQIBaseDriver::rollbackTransaction() { if (!isOpen() || isOpenError()) - return FALSE; + return false; if (!d->trans) - return FALSE; + return false; isc_rollback_transaction(d->status, &d->trans); d->trans = 0; @@ -926,7 +926,7 @@ TQStringList TQIBaseDriver::tables(const TQString& typeName) const typeFilter.prepend("where "); TQSqlQuery q = createQuery(); - q.setForwardOnly(TRUE); + q.setForwardOnly(true); if (!q.exec("select rdb$relation_name from rdb$relations " + typeFilter)) return res; while(q.next()) @@ -942,7 +942,7 @@ TQSqlRecord TQIBaseDriver::record(const TQString& tablename) const return rec; TQSqlQuery q = createQuery(); - q.setForwardOnly(TRUE); + q.setForwardOnly(true); q.exec("SELECT a.RDB$FIELD_NAME, b.RDB$FIELD_TYPE " "FROM RDB$RELATION_FIELDS a, RDB$FIELDS b " @@ -964,7 +964,7 @@ TQSqlRecordInfo TQIBaseDriver::recordInfo(const TQString& tablename) const return rec; TQSqlQuery q = createQuery(); - q.setForwardOnly(TRUE); + q.setForwardOnly(true); q.exec("SELECT a.RDB$FIELD_NAME, b.RDB$FIELD_TYPE, b.RDB$FIELD_LENGTH, b.RDB$FIELD_SCALE, " "b.RDB$FIELD_PRECISION, a.RDB$NULL_FLAG " @@ -991,7 +991,7 @@ TQSqlIndex TQIBaseDriver::primaryIndex(const TQString &table) const return index; TQSqlQuery q = createQuery(); - q.setForwardOnly(TRUE); + q.setForwardOnly(true); q.exec("SELECT a.RDB$INDEX_NAME, b.RDB$FIELD_NAME, d.RDB$FIELD_TYPE " "FROM RDB$RELATION_CONSTRAINTS a, RDB$INDEX_SEGMENTS b, RDB$RELATION_FIELDS c, RDB$FIELDS d " "WHERE a.RDB$CONSTRAINT_TYPE = 'PRIMARY KEY' " @@ -1060,7 +1060,7 @@ TQString TQIBaseDriver::formatValue(const TQSqlField* field, bool trimStrings) c TQString::number(datetime.time().hour()) + ":" + TQString::number(datetime.time().minute()) + ":" + TQString::number(datetime.time().second()) + "." + - TQString::number(datetime.time().msec()).rightJustify(3, '0', TRUE) + "'"; + TQString::number(datetime.time().msec()).rightJustify(3, '0', true) + "'"; else return "NULL"; } @@ -1070,7 +1070,7 @@ TQString TQIBaseDriver::formatValue(const TQSqlField* field, bool trimStrings) c return "'" + TQString::number(time.hour()) + ":" + TQString::number(time.minute()) + ":" + TQString::number(time.second()) + "." + - TQString::number(time.msec()).rightJustify(3, '0', TRUE) + "'"; + TQString::number(time.msec()).rightJustify(3, '0', true) + "'"; else return "NULL"; } |
