File indexing completed on 2024-10-13 12:38:21

 /* This file is part of the KDE project
    Copyright (C) 2003-2018 Jarosław Staniek <staniek@kde.org>
 
    This program is free software; you can redistribute it and/or
    modify it under the terms of the GNU Library General Public
    License as published by the Free Software Foundation; either
    version 2 of the License, or (at your option) any later version.
 
    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
    Library General Public License for more details.
 
    You should have received a copy of the GNU Library General Public License
    along with this program; see the file COPYING.  If not, write to
    the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
  * Boston, MA 02110-1301, USA.
 */
 
 #include "KDbDriver.h"
 #include "KDbAdmin.h"
 #include "KDbConnectionData.h"
 #include "KDbConnection.h"
 #include "KDbConnectionOptions.h"
 #include "KDbDriverManager_p.h"
 #include "KDbDriverMetaData.h"
 #include "KDbDriver_p.h"
 #include "KDbDriverBehavior.h"
 #include "KDbError.h"
 #include "KDbExpression.h"
 #include "kdb_debug.h"
 
 #include <algorithm>
 
 /*! @internal Used in KDbDriver::defaultSqlTypeName(int)
  when we do not have KDbDriver instance yet, or when we cannot get one */
 static const char* const KDb_defaultSqlTypeNames[] = {
     "InvalidType",
     "Byte",
     "ShortInteger",
     "Integer",
     "BigInteger",
     "Boolean",
     "Date",
     "DateTime",
     "Time",
     "Float",
     "Double",
     "Text",
     "LongText",
     "BLOB"
 };
 
 //---------------------------------------------
 
 KDbDriver::KDbDriver(QObject *parent, const QVariantList &args)
  : QObject(parent)
  , d(new KDbDriverPrivate(this))
 {
     Q_UNUSED(args);
     d->driverBehavior.typeNames.resize(KDbField::LastType + 1);
 }
 
 KDbDriver::~KDbDriver()
 {
     // make a copy because d->connections will be touched by ~KDbConnection
     QSet<KDbConnection*> connections(d->connections);
     qDeleteAll(connections);
     d->connections.clear();
     delete d;
 // kdbDebug() << "ok";
 }
 
 KDbDriverBehavior *KDbDriver::behavior()
 {
     return &d->driverBehavior;
 }
 
 const KDbDriverBehavior *KDbDriver::behavior() const
 {
     return &d->driverBehavior;
 }
 
 bool KDbDriver::isValid()
 {
     clearResult();
     QString inv_impl(tr("Invalid database driver's \"%1\" implementation.").arg(metaData()->name()));
     QString not_init(tr("Value of \"%1\" is not initialized for the driver."));
     if (d->driverBehavior.ROW_ID_FIELD_NAME.isEmpty()) {
         m_result = KDbResult(ERR_INVALID_DRIVER_IMPL,
                           inv_impl + QLatin1Char(' ')
                           + not_init.arg(QLatin1String("KDbDriverBehavior::ROW_ID_FIELD_NAME")));
         return false;
     }
     return true;
 }
 
 const QSet<KDbConnection*> KDbDriver::connections() const
 {
     return d->connections;
 }
 
 const KDbDriverMetaData* KDbDriver::metaData() const
 {
     return d->metaData;
 }
 
 int KDbDriver::features() const
 {
     return d->driverBehavior.features;
 }
 
 bool KDbDriver::transactionsSupported() const
 {
     return d->driverBehavior.features & (SingleTransactions | MultipleTransactions);
 }
 
 KDbAdminTools& KDbDriver::adminTools() const
 {
     if (!d->adminTools)
         d->adminTools = drv_createAdminTools();
     return *d->adminTools;
 }
 
 KDbAdminTools* KDbDriver::drv_createAdminTools() const
 {
     return new KDbAdminTools(); //empty impl.
 }
 
 QString KDbDriver::sqlTypeName(KDbField::Type type, const KDbField &field) const
 {
     Q_UNUSED(field);
     if (type > KDbField::InvalidType && type <= KDbField::LastType) { /*sanity*/
         return d->driverBehavior.typeNames[type];
     }
     return d->driverBehavior.typeNames[KDbField::InvalidType];
 }
 
 KDbConnection *KDbDriver::createConnection(const KDbConnectionData& connData,
                                            const KDbConnectionOptions &options)
 {
     clearResult();
     if (!isValid())
         return nullptr;
 
     KDbConnection *conn = drv_createConnection(connData, options);
 
 //! @todo needed? connData->setDriverId(id());
     d->connections.insert(conn);
     return conn;
 }
 
 KDbConnection *KDbDriver::createConnection(const KDbConnectionData& connData)
 {
     return createConnection(connData, KDbConnectionOptions());
 }
 
 KDbConnection* KDbDriver::removeConnection(KDbConnection *conn)
 {
     clearResult();
     if (d->connections.remove(conn))
         return conn;
     return nullptr;
 }
 
 QString KDbDriver::defaultSqlTypeName(KDbField::Type type)
 {
     if (type > KDbField::LastType)
         return QLatin1String("Null");
     return QLatin1String(KDb_defaultSqlTypeNames[type]);
 }
 
 bool KDbDriver::isKDbSystemObjectName(const QString& name)
 {
     if (!name.startsWith(QLatin1String("kexi__"), Qt::CaseInsensitive))
         return false;
     return KDbConnection::kdbSystemTableNames().contains(name, Qt::CaseInsensitive);
 }
 
 bool KDbDriver::isSystemFieldName(const QString& name) const
 {
     if (!d->driverBehavior.ROW_ID_FIELD_NAME.isEmpty()
         && 0 == name.compare(d->driverBehavior.ROW_ID_FIELD_NAME, Qt::CaseInsensitive))
     {
         return true;
     }
     return drv_isSystemFieldName(name);
 }
 
 KDbEscapedString valueToSqlInternal(const KDbDriver *driver, KDbField::Type ftype, const QVariant& v)
 {
     if (v.isNull() || ftype == KDbField::Null) {
         return KDbEscapedString("NULL");
     }
     switch (ftype) {
     case KDbField::Text:
     case KDbField::LongText: {
         return driver ? driver->escapeString(v.toString())
                       : KDbEscapedString(KDb::escapeString(v.toString()));
     }
     case KDbField::Byte:
     case KDbField::ShortInteger:
     case KDbField::Integer:
     case KDbField::BigInteger:
         return KDbEscapedString(v.toByteArray());
     case KDbField::Float:
     case KDbField::Double: {
         if (v.type() == QVariant::String) {
             //workaround for values stored as string that should be casted to floating-point
             KDbEscapedString s(v.toByteArray());
             return s.replace(',', '.');
         }
         return KDbEscapedString(v.toByteArray());
     }
 //! @todo here special encoding method needed
     case KDbField::Boolean:
         return driver
             ? KDbEscapedString(v.toInt() == 0 ? KDbDriverPrivate::behavior(driver)->BOOLEAN_FALSE_LITERAL
                                               : KDbDriverPrivate::behavior(driver)->BOOLEAN_TRUE_LITERAL)
             : KDbEscapedString(v.toInt() == 0 ? "FALSE" : "TRUE");
     case KDbField::Time:
         return driver ? driver->timeToSql(v) : KDb::timeToSql(v);
     case KDbField::Date:
         return driver ? driver->dateToSql(v) : KDb::dateToSql(v);
     case KDbField::DateTime:
         return driver ? driver->dateTimeToSql(v) : KDb::dateTimeToSql(v);
     case KDbField::BLOB: {
         if (v.toByteArray().isEmpty()) {
             return KDbEscapedString("NULL");
         }
         if (v.type() == QVariant::String) {
             return driver ? driver->escapeBLOB(v.toString().toUtf8())
                           : KDbEscapedString(KDb::escapeBLOB(v.toString().toUtf8(), KDb::BLOBEscapingType::ZeroXHex));
         }
         return driver ? driver->escapeBLOB(v.toByteArray())
                       : KDbEscapedString(KDb::escapeBLOB(v.toByteArray(), KDb::BLOBEscapingType::ZeroXHex));
     }
     case KDbField::InvalidType:
         return KDbEscapedString("!INVALIDTYPE!");
     default:
         kdbDebug() << KDbEscapedString("UNKNOWN!");
     }
     return KDbEscapedString();
 }
 
 KDbEscapedString KDbDriver::valueToSql(KDbField::Type ftype, const QVariant& v) const
 {
     //! @note it was compatible with SQLite: https://www.sqlite.org/lang_datefunc.html
     return valueToSqlInternal(this, ftype, v);
 }
 
 KDbEscapedString KDbDriver::dateToSql(const QVariant &v) const
 {
     return KDb::dateToIsoString(v);
 }
 
 KDbEscapedString KDbDriver::timeToSql(const QVariant& v) const
 {
     return KDb::timeToIsoString(v);
 }
 
 KDbEscapedString KDbDriver::dateTimeToSql(const QVariant& v) const
 {
     return KDb::dateTimeToIsoString(v);
 }
 
 KDbEscapedString KDbDriver::dateTimeToSql(const QDateTime& v) const
 {
     return dateTimeToSql(QVariant(v));
 }
 
 QString KDbDriver::escapeIdentifier(const QString& str) const
 {
     return QLatin1Char(d->driverBehavior.OPENING_QUOTATION_MARK_BEGIN_FOR_IDENTIFIER)
             + drv_escapeIdentifier(str)
             + QLatin1Char(d->driverBehavior.CLOSING_QUOTATION_MARK_BEGIN_FOR_IDENTIFIER);
 }
 
 QByteArray KDbDriver::escapeIdentifier(const QByteArray& str) const
 {
     return d->driverBehavior.OPENING_QUOTATION_MARK_BEGIN_FOR_IDENTIFIER
             + drv_escapeIdentifier(str)
             + d->driverBehavior.CLOSING_QUOTATION_MARK_BEGIN_FOR_IDENTIFIER;
 }
 
 KDbUtils::Property KDbDriver::internalProperty(const QByteArray& name) const
 {
     return d->driverBehavior.properties.property(name);
 }
 
 QList<QByteArray> KDbDriver::internalPropertyNames() const
 {
     QList<QByteArray> names(d->driverBehavior.properties.names());
     std::sort(names.begin(), names.end());
     return names;
 }
 
 void KDbDriver::initDriverSpecificKeywords(const char* const* keywords)
 {
     d->driverSpecificSqlKeywords.setStrings(keywords);
 }
 
 KDbEscapedString KDbDriver::addLimitTo1(const KDbEscapedString& sql, bool add)
 {
     return add ? (sql + " LIMIT 1") : sql;
 }
 
 bool KDbDriver::isDriverSpecificKeyword(const QByteArray& word) const
 {
     return d->driverSpecificSqlKeywords.contains(word);
 }
 
 void KDbDriver::setMetaData(const KDbDriverMetaData *metaData)
 {
     d->metaData = metaData;
     d->driverBehavior.initInternalProperties();
 }
 
 KDbEscapedString KDbDriver::hexFunctionToString(
                                        const KDbNArgExpression &args,
                                        KDbQuerySchemaParameterValueListIterator* params,
                                        KDb::ExpressionCallStack* callStack) const
 {
     return KDbFunctionExpression::toString(QLatin1String("HEX"), this, args, params, callStack);
 }
 
 KDbEscapedString KDbDriver::ifnullFunctionToString(
                                           const KDbNArgExpression &args,
                                           KDbQuerySchemaParameterValueListIterator* params,
                                           KDb::ExpressionCallStack* callStack) const
 {
     return KDbFunctionExpression::toString(QLatin1String("IFNULL"), this, args, params, callStack);
 }
 
 KDbEscapedString KDbDriver::lengthFunctionToString(
                                           const KDbNArgExpression &args,
                                           KDbQuerySchemaParameterValueListIterator* params,
                                           KDb::ExpressionCallStack* callStack) const
 {
     return KDbFunctionExpression::toString(QLatin1String("LENGTH"), this, args, params, callStack);
 }
 
 KDbEscapedString KDbDriver::greatestOrLeastFunctionToString(
                                             const QString &name,
                                             const KDbNArgExpression &args,
                                             KDbQuerySchemaParameterValueListIterator* params,
                                             KDb::ExpressionCallStack* callStack) const
 {
     return KDbFunctionExpression::toString(name, this, args, params, callStack);
 }
 
 KDbEscapedString KDbDriver::randomFunctionToString(
                                             const KDbNArgExpression &args,
                                             KDbQuerySchemaParameterValueListIterator* params,
                                             KDb::ExpressionCallStack* callStack) const
 {
     static QLatin1String randomStatic("()");
     if (!args.isNull() || args.argCount() < 1 ) {
         return KDbEscapedString(d->driverBehavior.RANDOM_FUNCTION + randomStatic);
     }
     if (args.argCount() != 2) {
         return KDbEscapedString();
     }
     const KDbEscapedString x(args.arg(0).toString(this, params, callStack));
     const KDbEscapedString y(args.arg(1).toString(this, params, callStack));
     static KDbEscapedString floorRandomStatic("+FLOOR(");
     static KDbEscapedString floorRandomStatic2("()*(");
     static KDbEscapedString floorRandomStatic3(")))");
     return KDbEscapedString('(') + x + floorRandomStatic + d->driverBehavior.RANDOM_FUNCTION
             + floorRandomStatic2 + y + QLatin1Char('-') + x + floorRandomStatic3;
 }
 
 KDbEscapedString KDbDriver::ceilingOrFloorFunctionToString(
                                                 const QString &name,
                                                 const KDbNArgExpression &args,
                                                 KDbQuerySchemaParameterValueListIterator* params,
                                                 KDb::ExpressionCallStack* callStack) const
 {
     return KDbFunctionExpression::toString(name, this, args, params, callStack);
 }
 
 KDbEscapedString KDbDriver::unicodeFunctionToString(
                                         const KDbNArgExpression &args,
                                         KDbQuerySchemaParameterValueListIterator* params,
                                         KDb::ExpressionCallStack* callStack) const
 {
     return KDbFunctionExpression::toString(QLatin1String("UNICODE"), this, args, params, callStack);
 }
 
 KDbEscapedString KDbDriver::concatenateFunctionToString(const KDbBinaryExpression &args,
                                                KDbQuerySchemaParameterValueListIterator* params,
                                                KDb::ExpressionCallStack* callStack) const
 {
     return args.left().toString(this, params, callStack) + KDbEscapedString("||")
             + args.right().toString(this, params, callStack);
 }
 
 //---------------
 
 Q_GLOBAL_STATIC_WITH_ARGS(
     KDbUtils::StaticSetOfStrings,
     KDb_kdbSqlKeywords,
     (KDbDriverPrivate::kdbSQLKeywords) )
 
 KDB_EXPORT bool KDb::isKDbSqlKeyword(const QByteArray& word)
 {
     return KDb_kdbSqlKeywords->contains(word.toUpper());
 }
 
 KDB_EXPORT QString KDb::escapeIdentifier(const KDbDriver* driver,
                                          const QString& str)
 {
     return driver ? driver->escapeIdentifier(str)
                   : KDb::escapeIdentifier(str);
 }
 
 KDB_EXPORT QByteArray KDb::escapeIdentifier(const KDbDriver* driver,
                                             const QByteArray& str)
 {
     return driver ? driver->escapeIdentifier(str)
                   : KDb::escapeIdentifier(str);
 }