Разнос по библиотекам + прикручиваем odb из redkitty

.gitignore

@@ -1,38 +1,87 @@
-# user ignore
-build
-opds.db
+# This file is used to ignore files which are generated
+# ----------------------------------------------------------------------------
 
-# ---> C++
-# Prerequisites
-*.d
-
-# Compiled Object files
-*.slo
-*.lo
+*~
+*.autosave
+*.a
+*.core
+*.moc
 *.o
 *.obj
-
-# Precompiled Headers
-*.gch
-*.pch
-
-# Compiled Dynamic libraries
+*.orig
+*.rej
 *.so
-*.dylib
-*.dll
-
-# Fortran module files
-*.mod
-*.smod
-
-# Compiled Static libraries
-*.lai
-*.la
-*.a
-*.lib
-
-# Executables
-*.exe
-*.out
+*.so.*
+*_pch.h.cpp
+*_resource.rc
+*.qm
+.#*
+*.*#
+core
+!core/
+tags
+.DS_Store
+.directory
+*.debug
+Makefile*
+*.prl
 *.app
+moc_*.cpp
+ui_*.h
+qrc_*.cpp
+Thumbs.db
+*.res
+*.rc
+/.qmake.cache
+/.qmake.stash
 
+# qtcreator generated files
+*.pro.user*
+*.qbs.user*
+CMakeLists.txt.user*
+
+# xemacs temporary files
+*.flc
+
+# Vim temporary files
+.*.swp
+
+# Visual Studio generated files
+*.ib_pdb_index
+*.idb
+*.ilk
+*.pdb
+*.sln
+*.suo
+*.vcproj
+*vcproj.*.*.user
+*.ncb
+*.sdf
+*.opensdf
+*.vcxproj
+*vcxproj.*
+
+# MinGW generated files
+*.Debug
+*.Release
+
+# Python byte code
+*.pyc
+
+# Binaries
+# --------
+*.dll
+*.exe
+
+# Directories with generated files
+.moc/
+.obj/
+.pch/
+.rcc/
+.uic/
+/build*/
+
+
+ccache.log
+
+*-odb.*xx

.gitmodules

@@ -0,0 +1,6 @@
+[submodule "redkbuild"]
+	path = redkbuild
+	url = ssh://git@gitea.redkit-lab.work:57322/redkit-lab/redkbuild.git
+[submodule "redkitty"]
+	path = redkitty
+	url = git@gitea.redkit-lab.work:redkit-lab/redkitty.git

CMakeLists.txt

@@ -1,58 +0,0 @@
-cmake_minimum_required(VERSION 3.16)
-project(cpp-opds)
-
-set(CMAKE_CXX_STANDARD 17)
-set(CMAKE_CXX_STANDARD_REQUIRED ON)
-
-set(ODB_INCLUDE_DIRS /usr/include)
-set(ODB_LIBRARY_DIRS /usr/lib/x86_64-linux-gnu)
-
-include_directories(${ODB_INCLUDE_DIRS})
-link_directories(${ODB_LIBRARY_DIRS})
-
-find_package(Qt6 REQUIRED COMPONENTS Core Sql Network)
-# find_package(ODB REQUIRED)
-# find_package(SQLite3 REQUIRED)
-
-find_library(ODB_LIBRARIES NAMES odb HINTS ${ODB_LIBRARY_DIRS})
-find_library(ODB_SQLITE_LIBRARIES NAMES odb-sqlite HINTS ${ODB_LIBRARY_DIRS})
-
-
-set(CMAKE_AUTOMOC ON)  # <-- Включаем автоматическую генерацию MOC-файлов
-
-# include_directories(${ODB_INCLUDE_DIRS} ${SQLite3_INCLUDE_DIRS})
-# link_directories(${ODB_LIBRARY_DIRS} ${SQLite3_LIBRARY_DIRS})
-
-# add_executable(cpp-opds
-#     src/main.cpp
-#     include/backend.cpp
-# )
-
-set(SOURCE_FILES
-    src/main.cpp
-    # src/database.cpp
-    # src/book.cpp
-    # src/author.hpp
-)
-
-set(ODB_SOURCES
-    src/book
-    src/author
-)
-
-# Генерация ODB файлов
-foreach(file ${ODB_SOURCES})
-    add_custom_command(
-        OUTPUT ${file}.odb.cpp ${file}.odb.hpp
-        COMMAND odb --generate-query --generate-schema --database sqlite ${file}.hpp
-        DEPENDS ${file}.hpp
-        COMMENT "Running ODB on ${file}.hpp"
-    )
-    list(APPEND SOURCE_FILES ${file}.odb.cpp)
-endforeach()
-
-add_executable(cpp-opds ${SOURCE_FILES})
-
-target_include_directories(cpp-opds PRIVATE include)
-# target_link_libraries(cpp-opds Qt6::Core Qt6::Sql Qt6::Network ${ODB_LIBRARIES} ${SQLite3_LIBRARIES})
-target_link_libraries(cpp-opds Qt6::Core Qt6::Sql Qt6::Network ${ODB_LIBRARIES} ${ODB_SQLITE_LIBRARIES})

include/backend.cpp

@@ -1,25 +0,0 @@
-#include "backend.h"
-#include <QtCore/QDebug>
-
-Backend::Backend(QObject* parent) :
-    QObject(parent)
-{
-    // Используем SQLite по умолчанию, для PostgreSQL потребуется изменить параметры подключения
-    db = QSqlDatabase::addDatabase("QSQLITE");
-    db.setDatabaseName("opds.db");
-
-    if (!db.open())
-    {
-        qDebug() << "Error: Unable to open database";
-    }
-}
-
-Backend::~Backend()
-{
-    qDebug() << "Backend stoped.";
-}
-
-void Backend::start()
-{
-    qDebug() << "Backend started.";
-}

include/backend.h

@@ -1,21 +0,0 @@
-#ifndef BACKEND_H
-#define BACKEND_H
-
-#include <QObject>
-#include <QtSql>
-
-class Backend : public QObject
-{
-    Q_OBJECT
-
-public:
-    explicit Backend(QObject* parent = nullptr);
-    ~Backend() override;
-
-    void start();
-
-private:
-    QSqlDatabase db;
-};
-
-#endif // BACKEND_H

prerequisites/qbs/imports/SQLiteArtifactsExport.qbs

@@ -0,0 +1,8 @@
+import qbs
+
+Export {
+    Depends { name: "cpp" }
+    Depends { name: "rsc.sqlite.settings" }
+
+    rsc.sqlite.settings.includeRegexValues: exportingProduct.includeRegexValue
+}

prerequisites/qbs/modules/karchive/karchive.qbs

@@ -0,0 +1,53 @@
+import qbs
+
+Module {
+    id: karchive
+
+    readonly property string karchive_path: project.sourceDirectory + "/external_libs/karchive"
+    readonly property string libKF5ArchivePath: karchive.karchive_path + "/lib"
+                                                + (qbs.buildVariant == "release" ? "/Release" : "/Debug")
+    property bool installFiles: true
+
+    Depends { name: "glob" }
+    Depends { name: "cpp" }
+    Depends { name: "zlib" }
+
+    Properties
+    {
+        condition: qbs.targetOS.contains("linux") || qbs.targetOS.contains("astra")
+        cpp.includePaths: [ karchive.karchive_path + "/include/lin" ]
+        cpp.libraryPaths: [ karchive.libKF5ArchivePath + "/lin" ]
+        cpp.dynamicLibraries: "KF5Archive"
+    }
+
+    Properties {
+        condition: qbs.targetOS.contains("windows")
+        cpp.includePaths: [ karchive.karchive_path + "/include/win" ]
+        cpp.libraryPaths: [ karchive.libKF5ArchivePath + "/win" ]
+        cpp.dynamicLibraries: "KF5Archive"
+    }
+
+    InstallGroup {
+        name: "karchive_lin"
+        condition: qbs.targetOS.contains("linux") || qbs.targetOS.contains("astra")
+        files: [
+            karchive.libKF5ArchivePath + "/lin/libKF5Archive.so",
+            karchive.libKF5ArchivePath + "/lin/libKF5Archive.so.5",
+            karchive.libKF5ArchivePath + "/lin/libKF5Archive.so.5.108.0"
+        ]
+        qbs.install: karchive.installFiles
+        qbs.installDir: glob.binInstallPrefix
+    }
+
+    InstallGroup {
+        name: "karchive_win"
+        condition: qbs.targetOS.contains("windows")
+        files: [
+            karchive.libKF5ArchivePath + "/win/KF5Archive.dll",
+            karchive.libKF5ArchivePath + "/win/KF5Archive.lib"
+        ]
+        qbs.install: karchive.installFiles
+        qbs.installDir: glob.binInstallPrefix
+    }
+    zlib.installFiles: true
+}

project.qbs

@@ -0,0 +1,20 @@
+import qbs
+
+Project {
+    name: "opds++"
+    qbsSearchPaths: [
+        "redkitty/qbs",
+        "redkbuild",
+        "redkitty/lib/redkit-gen-integration/qbs",
+        "prerequisites/qbs",
+    ]
+
+    references: [
+        "redkitty/lib/rsc/libs_impl/rdbaseimpl/rdbaseimpl.qbs",
+        "redkitty/lib/rcore/rcore.qbs",
+
+        "src/cpp-opds.qbs",
+        "src/database/database.qbs",
+        "src/restapi/restapi.qbs",
+    ]
+}

src/author.hpp

@@ -1,13 +0,0 @@
-#pragma db object
-class Author {
-public:
-    Author() = default;
-    Author(const std::string& name) : name(name) {}
-
-    const std::string& getName() const { return name; }
-
-private:
-    #pragma db id auto
-    int id;
-    std::string name;
-};

src/book.hpp

@@ -1,22 +0,0 @@
-#pragma db object
-class Book {
-public:
-    Book() = default;
-    Book(const std::string& title, const std::string& author, const std::string& filePath, 
-         int fileSize, const std::string& format);
-
-    const std::string& getTitle() const { return title; }
-    const std::string& getAuthor() const { return author; }
-    const std::string& getFilePath() const { return filePath; }
-    int getFileSize() const { return fileSize; }
-    const std::string& getFormat() const { return format; }
-
-private:
-    #pragma db id auto
-    int id;
-    std::string title;
-    std::string author;
-    std::string filePath;
-    int fileSize;
-    std::string format;
-};

src/cpp-opds.qbs

@@ -0,0 +1,42 @@
+/*!
+    \qmltype cpp-opds
+    \inherits Project
+    \brief Описание
+*/
+PSApplication {
+    // CppApplication {
+        cpp.defines: [
+            // You can make your code fail to compile if it uses deprecated APIs.
+            // In order to do so, uncomment the following line.
+            //"QT_DISABLE_DEPRECATED_BEFORE=0x060000" // disables all the APIs deprecated before Qt 6.0.0
+            "DATABASE_SQLITE"
+        ]
+        consoleApplication: true
+
+        Depends { name: "Qt"; submodules: [ "core", "sql", "network" ] }
+        Depends { name: "cpp" }
+        Depends { name: "database" }
+        Depends { name: "odb.gen" }
+        Depends { name: "sqlite3" }
+        Depends { name: "restapi" }
+        Depends { name: "redkit_gen" }
+        Depends { name: "rdbase" }
+
+        cpp.cxxLanguageVersion: "c++20"
+
+        Group {
+            name: "cpp"
+            files: [
+                "main.cpp",
+            ]
+        }
+
+        cpp.dynamicLibraries: [
+            "odb-sqlite",
+            "odb-qt",
+            "odb",
+            "sqlite3"
+        ]
+
+    // }
+} // Project

src/database.cpp

@@ -1,13 +0,0 @@
-#include "database.h"
-#include <odb/sqlite/database.hxx>
-#include <odb/schema-catalog.hxx>
-#include "book-odb.hxx"
-#include "author-odb.hxx"
-
-std::unique_ptr<odb::sqlite::database> initializeDatabase(const std::string& dbPath) {
-    auto db = std::make_unique<odb::sqlite::database>(dbPath, SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE);
-    odb::transaction t(db->begin());
-    odb::schema_catalog::create_schema(*db);
-    t.commit();
-    return db;
-}

src/database/author_s.h

@@ -0,0 +1,64 @@
+// file      : hello/person.hxx
+// copyright : not copyrighted - public domain
+
+#ifndef AUTHOR_S_H
+#define AUTHOR_S_H
+
+#include "database_global.h"
+
+#include <QString>
+
+#include <odb/core.hxx>
+#include <odb/database.hxx>
+#include <odb/query.hxx>
+
+#pragma db object
+class DATABASE_EXPORT Author_S
+{
+public:
+    Author_S() = default;
+
+    Author_S(const QString& firstN,
+             const QString& lastN,
+             const unsigned short age) :
+        m_firstName(firstN),
+        m_lastName(lastN),
+        m_age(age)
+    {
+    }
+
+    unsigned long long id() const { return m_id; }
+    QString firstName() const { return m_firstName; }
+    QString lastName() const { return m_lastName; }
+    unsigned short age() const { return m_age; }
+
+    QString full_name() const { return m_firstName + " " + m_lastName; }
+
+    void age(unsigned short age) { m_age = age; }
+
+private:
+    friend class odb::access;
+
+private:
+#pragma db id auto
+    quint64 m_id;
+
+    QString m_firstName;
+    QString m_lastName;
+    quint8 m_age;
+};
+
+#pragma db view object(Author_S)
+struct person_stat
+{
+#pragma db column("count(" + Author_S::m_id + ")")
+    std::size_t count;
+
+#pragma db column("min(" + Author_S::m_age + ")")
+    unsigned short min_age;
+
+#pragma db column("max(" + Author_S::m_age + ")")
+    unsigned short max_age;
+};
+
+#endif // AUTHOR_S_H

src/database/book_s.h

@@ -0,0 +1,64 @@
+// file      : hello/person.hxx
+// copyright : not copyrighted - public domain
+
+#ifndef BOOK_S_H
+#define BOOK_S_H
+
+#include "database_global.h"
+
+#include <QSharedPointer>
+#include <QString>
+#include <odb/core.hxx>
+#include <rcore/smarttypes.h>
+
+#include "author_s.h"
+
+#pragma db object
+class DATABASE_EXPORT Book_S
+{
+public:
+    Book_S() = default;
+
+    Book_S(const QString& name,
+           const SH<Author_S>& author,
+           const int year)
+    {
+        m_author = author;
+        m_name = name;
+        m_year = year;
+    };
+
+    unsigned long long id() const { return m_id; }
+    SH<Author_S> author() const { return m_author; }
+    QString name() const { return m_name; }
+    int year() const { return m_year; }
+
+private:
+    friend class odb::access;
+
+private:
+#pragma db id auto
+    quint64 m_id;
+
+    SH<Author_S> m_author;
+    QString m_name;
+    quint8 m_year;
+};
+
+// #pragma db view object(Book_S) object(Author_S = author:Book_S::m_author)
+// struct BookByAuthorView
+// {
+// #pragma db column(Book_S::m_id)
+//     quint64 book_id;
+
+// #pragma db column(Book_S::m_name)
+//     QString book_name;
+
+// #pragma db column(Book_S::m_year)
+//     qint8 year;
+
+// #pragma db column(Author_S::m_first + " " + Author_S::m_last)
+//     QString author_full_name;
+// };
+
+#endif // BOOK_S_H

src/database/database.hxx

@@ -0,0 +1,183 @@
+// file      : hello/database.hxx
+// copyright : not copyrighted - public domain
+
+//
+// Create concrete database instance based on the DATABASE_* macros.
+//
+
+#ifndef DATABASE_HXX
+#define DATABASE_HXX
+
+#include <cstdlib> // std::exit
+#include <iostream>
+#include <memory> // std::unique_ptr
+#include <string>
+
+#include <odb/database.hxx>
+
+#if defined(DATABASE_MYSQL)
+#include <odb/mysql/database.hxx>
+#elif defined(DATABASE_SQLITE)
+#include <odb/connection.hxx>
+#include <odb/schema-catalog.hxx>
+#include <odb/sqlite/database.hxx>
+#include <odb/transaction.hxx>
+#elif defined(DATABASE_PGSQL)
+#include <odb/pgsql/database.hxx>
+#elif defined(DATABASE_ORACLE)
+#include <odb/oracle/database.hxx>
+#elif defined(DATABASE_MSSQL)
+#include <odb/mssql/database.hxx>
+#else
+#error unknown database; did you forget to define the DATABASE_* macros?
+#endif
+
+#include <filesystem>
+#include <random>
+#include <rcore/smarttypes.h>
+
+using oDBase = odb::sqlite::database;
+using uDBase = U<oDBase>;
+
+struct testData
+{
+    QString first;
+    QString last;
+    int age;
+};
+
+// Функция для генерации случайной строки (имени или фамилии)
+QString generate_random_string(const QVector<QString>& pool)
+{
+    static std::random_device rd;
+    static std::mt19937 gen(rd());
+    std::uniform_int_distribution<> dis(0, pool.size() - 1);
+    return pool[dis(gen)];
+}
+
+// Функция для генерации случайного года
+int generate_random_year(int min_year = 1900, int max_year = 2020)
+{
+    static std::random_device rd;
+    static std::mt19937 gen(rd());
+    std::uniform_int_distribution<> dis(min_year, max_year);
+    return dis(gen);
+}
+
+QVector<testData> fillDB()
+{
+    QVector<QString> first_names = {
+        "John", "Jane", "Alex", "Chris", "Robert", "Emily", "James", "Linda", "David", "Sarah",
+        "Michael", "Elizabeth", "Daniel", "Samantha", "William", "Olivia", "Ethan", "Sophia", "Joshua", "Charlotte",
+        "Daniel", "Grace", "Benjamin", "Isabella", "Matthew", "Victoria", "Henry", "Abigail", "Samuel", "Megan",
+        "Lucas", "Lily", "Andrew", "Madison", "Jackson", "Chloe", "Aiden", "Amelia", "Thomas", "Natalie",
+        "Ryan", "Zoe", "Jack", "Harper", "Elijah", "Ava", "Isaac", "Mia", "Caleb", "Ella"
+    };
+    QVector<QString> last_names = {
+        "Doe", "Smith", "Johnson", "Williams", "Jones", "Brown", "Davis", "Miller", "Wilson", "Moore",
+        "Taylor", "Anderson", "Thomas", "Jackson", "White", "Harris", "Martin", "Thompson", "Garcia", "Martinez",
+        "Roberts", "Clark", "Lewis", "Walker", "Young", "Allen", "King", "Wright", "Scott", "Adams",
+        "Baker", "Gonzalez", "Nelson", "Carter", "Mitchell", "Perez", "Robinson", "Hughes", "Flores", "Cook",
+        "Rogers", "Gutierrez", "Ramirez", "Diaz", "Perez", "Ross", "Sanders", "Price", "Howard", "Cooper"
+    };
+
+    QVector<testData> vecTest;
+
+    for (int i = 0; i < 50; ++i)
+    {
+        QString first_name = generate_random_string(first_names);
+        QString last_name = generate_random_string(last_names);
+        int birth_year = generate_random_year(1900, 2000);
+
+        vecTest.push_back({ first_name, last_name, birth_year });
+    }
+
+    return vecTest;
+}
+
+inline uDBase openDB(const std::string path_db)
+{
+    // Открыть БД, если она существует
+    auto db_ptr = new oDBase(path_db, SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE);
+
+    if (std::filesystem::is_regular_file(path_db))
+        return uDBase(db_ptr);
+
+    // И создать новую, если не существует
+    uDBase db(db_ptr);
+
+    odb::connection_ptr connect_ptr(db->connection());
+
+    connect_ptr->execute("PRAGMA foreign_keys=OFF");
+
+    odb::transaction tans(db->begin());
+    odb::schema_catalog::create_schema(*db);
+    tans.commit();
+
+    connect_ptr->execute("PRAGMA foreign_keys=ON");
+
+    return db;
+}
+
+inline std::unique_ptr<odb::database> create_database(int& argc, char* argv[])
+{
+    using namespace std;
+    using namespace odb::core;
+
+    if (argc > 1 && argv[1] == string("--help"))
+    {
+        cout << "Usage: " << argv[0] << " [options]" << endl
+             << "Options:" << endl;
+
+#if defined(DATABASE_MYSQL)
+        odb::mysql::database::print_usage(cout);
+#elif defined(DATABASE_SQLITE)
+        odb::sqlite::database::print_usage(cout);
+#elif defined(DATABASE_PGSQL)
+        odb::pgsql::database::print_usage(cout);
+#elif defined(DATABASE_ORACLE)
+        odb::oracle::database::print_usage(cout);
+#elif defined(DATABASE_MSSQL)
+        odb::mssql::database::print_usage(cout);
+#endif
+
+        exit(0);
+    }
+
+#if defined(DATABASE_MYSQL)
+    unique_ptr<database> db(new odb::mysql::database(argc, argv));
+#elif defined(DATABASE_SQLITE)
+
+    unique_ptr<database> db(new odb::sqlite::database(argc,
+                                                      argv,
+                                                      false,
+                                                      SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE));
+
+    // Create the database schema. Due to bugs in SQLite foreign key
+    // support for DDL statements, we need to temporarily disable
+    // foreign keys.
+    //
+    {
+        connection_ptr connect_ptr(db->connection());
+
+        connect_ptr->execute("PRAGMA foreign_keys=OFF");
+
+        transaction tans(connect_ptr->begin());
+        schema_catalog::create_schema(*db);
+        tans.commit();
+
+        connect_ptr->execute("PRAGMA foreign_keys=ON");
+    }
+#elif defined(DATABASE_PGSQL)
+    unique_ptr<database> db(new odb::pgsql::database(argc, argv));
+#elif defined(DATABASE_ORACLE)
+    unique_ptr<database> db(new odb::oracle::database(argc, argv));
+#elif defined(DATABASE_MSSQL)
+    unique_ptr<database> db(
+    new odb::mssql::database(argc, argv, false, "TrustServerCertificate=yes"));
+#endif
+
+    return db;
+}
+
+#endif // DATABASE_HXX

src/database/database.qbs

@@ -0,0 +1,55 @@
+/*!
+    \qmltype cpp-opds
+    \inherits Project
+    \brief Описание
+*/
+PSLibrary {
+    cpp.defines: [
+        // You can make your code fail to compile if it uses deprecated APIs.
+        // In order to do so, uncomment the following line.
+        //"QT_DISABLE_DEPRECATED_BEFORE=0x060000" // disables all the APIs deprecated before Qt 6.0.0
+        "DATABASE_SQLITE",
+        "DATABASE_LIBRARY"
+    ]
+    consoleApplication: true
+
+    Depends { name: "Qt"; submodules: [ "core", "sql", "network" ] }
+    Depends { name: "cpp" }
+
+    Depends { name: "odb.gen" }
+    Depends { name: "rdbase" }
+
+    Depends { name: "redkit_gen" }
+    redkit_gen.includeModules: ["JsonSerializer"]
+
+    odb.gen.databases: "sqlite"
+    cpp.cxxLanguageVersion: "c++17"
+
+    Group {
+        name: "cpp"
+        files: [
+            "databasemanager.*",
+            "*.cpp",
+            "*.h",
+            "*.hxx",
+        ]
+        excludeFiles: odbs.files
+    }
+
+    Group {
+        id: odbs
+        name: "odb"
+        files: [
+            "author_s.h",
+            "book_s.h",
+        ]
+        fileTags: ["hpp", "odbxx"]
+    }
+
+    cpp.dynamicLibraries: [
+        "odb-sqlite",
+        "odb-qt",
+        "odb",
+        "sqlite3"
+    ]
+}

src/database/database_global.h

@@ -0,0 +1,12 @@
+#ifndef DATABASE_GLOBAL_H
+#define DATABASE_GLOBAL_H
+
+#include <QtCore/qglobal.h>
+
+#if defined(DATABASE_LIBRARY)
+#define DATABASE_EXPORT Q_DECL_EXPORT
+#else
+#define DATABASE_EXPORT Q_DECL_IMPORT
+#endif
+
+#endif // DATABASE_GLOBAL_H

src/database/databasemanager.cpp

@@ -0,0 +1,118 @@
+#include "databasemanager.h"
+
+// Singleton instance
+DatabaseManager& DatabaseManager::instance()
+{
+    static DatabaseManager instance;
+    return instance;
+}
+
+// Конструктор: создаем подключение
+DatabaseManager::DatabaseManager()
+{
+    db = QSqlDatabase::addDatabase("QSQLITE");
+    db.setDatabaseName("mydatabase.db");
+
+    if (!db.open())
+    {
+        qDebug() << "Ошибка открытия БД:" << db.lastError().text();
+    }
+    else
+    {
+        qDebug() << "База данных успешно открыта";
+    }
+}
+
+// Деструктор: закрываем подключение
+DatabaseManager::~DatabaseManager()
+{
+    if (db.isOpen())
+    {
+        db.close();
+    }
+}
+
+// Возвращает ссылку на объект БД
+QSqlDatabase& DatabaseManager::database()
+{
+    return db;
+}
+
+// Выполняет SQL-запрос (без параметров)
+bool DatabaseManager::executeQuery(const QString& query)
+{
+    QSqlQuery q;
+    if (!q.exec(query))
+    {
+        qDebug() << "Ошибка выполнения запроса:" << q.lastError().text();
+        return false;
+    }
+    return true;
+}
+
+// Выполняет подготовленный SQL-запрос с параметрами
+bool DatabaseManager::executePreparedQuery(const QString& query, const QStringList& values)
+{
+    QSqlQuery q;
+    q.prepare(query);
+
+    for (const auto& value : values)
+        q.addBindValue(value);
+
+    if (!q.exec())
+    {
+        qDebug() << "Ошибка выполнения подготовленного запроса:" << q.lastError().text();
+        return false;
+    }
+    return true;
+}
+
+QList<QVariantList> DatabaseManager::executeSelectQuery(const QString& query, const QStringList& values)
+{
+    QSqlQuery q;
+    q.prepare(query);
+
+    for (const auto& value : values)
+        q.addBindValue(value);
+
+    if (!q.exec())
+    {
+        qDebug() << "Ошибка выполнения SELECT запроса:" << q.lastError().text();
+        return {};
+    }
+
+    QList<QVariantList> results;
+    while (q.next())
+    {
+        QVariantList row;
+        for (int i = 0; i < q.record().count(); ++i)
+            row.append(q.value(i));
+        results.append(row);
+    }
+
+    return results;
+}
+
+QList<QVariantList> DatabaseManager::executeSelect(const SelectBuilder& selectBuilder)
+{
+    const auto queryString = selectBuilder.getSelect();
+    qDebug() << "Подготовленный запрос: " << queryString;
+
+    QSqlQuery q;
+    if (!q.prepare(queryString))
+        qDebug() << "Ошибка при подготовке запроса:" << q.lastError().text();
+
+    if (!q.exec())
+        qDebug() << "Ошибка при выполнении запроса:" << q.lastError().text();
+
+    QList<QVariantList> results;
+    while (q.next()) // Проходимся по строкам
+    {
+        QVariantList row;
+        for (int i = 0; i < q.record().count(); ++i) // Проходимся по столбцам
+            row.append(q.value(i));
+        results.append(row);
+    }
+
+    return results;
+}

src/database/databasemanager.h

@@ -0,0 +1,61 @@
+#ifndef DATABASEMANAGER_H
+#define DATABASEMANAGER_H
+
+#include "database_global.h"
+
+#include <QDebug>
+#include <QtSql>
+
+struct SelectBuilder
+{
+    QString tableName;
+    QStringList rows = { "*" };
+    QString where;
+
+    QString getSelect() const
+    {
+        QString allRows;
+
+        auto ri = rows.begin();
+        while (ri != rows.end())
+        {
+            allRows += (*ri++);
+
+            if (ri != rows.end())
+                allRows += ", ";
+        }
+
+        QString queryString = QString("SELECT %1").arg(allRows);
+
+        queryString += QString(" FROM %1").arg(tableName);
+
+        if (!where.isEmpty())
+            queryString += QString(" WHERE %1").arg(where);
+
+        queryString += ';';
+        return queryString;
+    }
+};
+
+class DATABASE_EXPORT DatabaseManager
+{
+public:
+    static DatabaseManager& instance(); // Singleton
+
+    QSqlDatabase& database();
+
+    bool executeQuery(const QString& query);
+    bool executePreparedQuery(const QString& query, const QStringList& values);
+
+    QList<QVariantList> executeSelectQuery(const QString& query, const QStringList& values = {});
+
+    QList<QVariantList> executeSelect(const SelectBuilder& selectBuilder);
+
+private:
+    DatabaseManager();
+    ~DatabaseManager();
+
+    QSqlDatabase db;
+};
+
+#endif // DATABASEMANAGER_H

src/main.cpp

@@ -1,12 +1,183 @@
 #include <QCoreApplication>
-#include "backend.h"
 
-int main(int argc, char *argv[])
+#include <QPointer>
+#include <QSharedPointer>
+#include <QString>
+#include <QVector>
+
+#include <restapi/restapiserver.h>
+
+/* Опыты с odb */
+#include <database/author_s-odb.hxx> // Должен быть здесь
+#include <database/author_s.h>
+#include <database/book_s-odb.hxx> // Должен быть здесь
+#include <database/book_s.h>
+#include <database/database.hxx> // create_database
+#include <odb/database.hxx>
+
+#include <iostream>
+
+void fillBooksBD(uDBase& db)
+{
+    try
+    {
+        QVector<SH<Author_S>> authors = {
+            SH<Author_S>::create("George", "Orwell", 142),
+            SH<Author_S>::create("J.K.", "Rowling", 56),
+            SH<Author_S>::create("J.R.R.", "Tolkien", 81),
+            SH<Author_S>::create("Leo", "Tolstoy", 189),
+            SH<Author_S>::create("Fyodor", "Dostoevsky", 174),
+            SH<Author_S>::create("Mark", "Twain", 183),
+            SH<Author_S>::create("Charles", "Dickens", 208),
+            SH<Author_S>::create("Virginia", "Woolf", 134),
+            SH<Author_S>::create("Ernest", "Hemingway", 122),
+            SH<Author_S>::create("Gabriel", "García Márquez", 98),
+            SH<Author_S>::create("Franz", "Kafka", 100),
+            SH<Author_S>::create("Harper", "Lee", 64),
+            SH<Author_S>::create("William", "Shakespeare", 459),
+            SH<Author_S>::create("Oscar", "Wilde", 155),
+            SH<Author_S>::create("Aldous", "Huxley", 123),
+            SH<Author_S>::create("Jane", "Austen", 210),
+            SH<Author_S>::create("John", "Steinbeck", 116),
+            SH<Author_S>::create("Agatha", "Christie", 124),
+            SH<Author_S>::create("Isaac", "Asimov", 105)
+        };
+
+        // Список книг
+        QVector<Book_S> books = {
+            Book_S("1984", authors[0], 1949),
+            Book_S("Harry Potter and the Philosopher's Stone", authors[1], 1997),
+            Book_S("The Hobbit", authors[2], 1937),
+            Book_S("War and Peace", authors[3], 1869),
+            Book_S("Crime and Punishment", authors[4], 1866),
+            Book_S("Adventures of Huckleberry Finn", authors[5], 1884),
+            Book_S("A Tale of Two Cities", authors[6], 1859),
+            Book_S("Mrs. Dalloway", authors[7], 1925),
+            Book_S("The Old Man and the Sea", authors[8], 1952),
+            Book_S("One Hundred Years of Solitude", authors[9], 1967),
+            Book_S("The Trial", authors[10], 1925),
+            Book_S("To Kill a Mockingbird", authors[11], 1960),
+            Book_S("Macbeth", authors[12], 1606),
+            Book_S("The Picture of Dorian Gray", authors[13], 1890),
+            Book_S("Brave New World", authors[14], 1932),
+            Book_S("Pride and Prejudice", authors[15], 1813),
+            Book_S("The Brothers Karamazov", authors[4], 1880),
+            Book_S("The Grapes of Wrath", authors[16], 1939),
+            Book_S("Murder on the Orient Express", authors[17], 1934),
+            Book_S("I, Robot", authors[18], 1950),
+            Book_S("Animal Farm", authors[0], 1945),
+            Book_S("Harry Potter and the Chamber of Secrets", authors[1], 1998),
+            Book_S("The Lord of the Rings: The Fellowship of the Ring", authors[2], 1954),
+            Book_S("Anna Karenina", authors[3], 1878),
+            Book_S("The Idiot", authors[4], 1869),
+            Book_S("The Adventures of Tom Sawyer", authors[5], 1876),
+            Book_S("Oliver Twist", authors[6], 1837),
+            Book_S("To the Lighthouse", authors[7], 1927),
+            Book_S("For Whom the Bell Tolls", authors[8], 1940),
+            Book_S("Love in the Time of Cholera", authors[9], 1985),
+            Book_S("The Metamorphosis", authors[10], 1915),
+            Book_S("Go Set a Watchman", authors[11], 2015),
+            Book_S("King Lear", authors[12], 1605),
+            Book_S("The Importance of Being Earnest", authors[13], 1895),
+            Book_S("Brave New World Revisited", authors[14], 1958),
+            Book_S("Emma", authors[15], 1815),
+            Book_S("The Double", authors[4], 1846),
+            Book_S("Of Mice and Men", authors[16], 1937),
+            Book_S("And Then There Were None", authors[17], 1939),
+            Book_S("The Foundation Trilogy", authors[18], 1951),
+            Book_S("Down and Out in Paris and London", authors[0], 1933),
+            Book_S("Harry Potter and the Prisoner of Azkaban", authors[1], 1999),
+            Book_S("The Lord of the Rings: The Two Towers", authors[2], 1954),
+            Book_S("War and Peace", authors[3], 1869),
+            Book_S("The Brothers Karamazov", authors[4], 1880),
+            Book_S("The Prince and the Pauper", authors[5], 1881),
+            Book_S("David Copperfield", authors[6], 1850),
+            Book_S("The Waves", authors[7], 1931),
+            Book_S("A Farewell to Arms", authors[8], 1929),
+            Book_S("Chronicle of a Death Foretold", authors[9], 1981)
+        };
+
+        // Сохранение авторов в базу данных
+        {
+            odb::core::transaction t(db->begin());
+            for (auto& author : authors)
+                db->persist(author); // Используем get() для получения сырого указателя
+            t.commit();
+        }
+
+        // Сохранение книг в базу данных
+        {
+            odb::core::transaction t(db->begin());
+            for (auto& book : books)
+                db->persist(book);
+            t.commit();
+        }
+
+        std::cout << "Test data added successfully." << std::endl;
+    }
+    catch (const odb::exception& e)
+    {
+        std::cerr << "Error adding test data: " << e.what() << std::endl;
+    }
+}
+
+int main(int argc, char* argv[])
 {
     QCoreApplication a(argc, argv);
 
-    Backend backend;
-    backend.start();
+    const std::string dbPath = "test_db.sqlite";
+    uDBase db(openDB(dbPath));
+
+    // TODO Как-то нужно выполнять лишь раз
+    // fillBooksBD(db);
+
+    RestApiServer server(*db);
+    server.start(8080);
+
+    /* Опыты с odb */
+
+    // const std::string dbPath = "test_db.sqlite";
+
+    // std::vector<Author_S> authors;
+
+    // odb::core::transaction trans(db->begin());
+    // for (auto data : fillDB())
+    // {
+    //     auto a = Author_S(data.first, data.last, data.age);
+    //     db->persist(a);
+    // }
+    // trans.commit();
+
+    // try
+    // {
+    //     odb::core::transaction tr(db->begin());
+    //     odb::query<Author_S> query;
+    //     odb::result<Author_S> result;
+
+    //     odb::result<Author_S> r(db->query<Author_S>(odb::query<Author_S>::age >= 2000));
+
+    //     for (const auto& author : r)
+    //     {
+    //         std::cout << "First: " << author.first() << ", Last: " << author.last() << ", Year: " << author.age() << std::endl;
+    //     }
+
+    //     tr.commit();
+    // }
+    // catch (const odb::exception& e)
+    // {
+    //     std::cerr << "ODB error: " << e.what() << std::endl;
+    //     return 1;
+    // }
+    // Set up code that uses    the Qt event loop here.
+    // Call a.quit() or a.exit() to quit the application.
+    // A not very useful example would be including
+    // #include <QTimer>
+    // near the top of the file and calling
+    // QTimer::singleShot(5000, &a, &QCoreApplication::quit);
+    // which quits the application after 5 seconds.
+
+    // If you do not need a running Qt event loop, remove the call
+    // to a.exec() or use the Non-Qt Plain C++ Application template.
 
     return a.exec();
 }

src/restapi/restapi.qbs

@@ -0,0 +1,38 @@
+/*!
+    \qmltype cpp-opds
+    \inherits Project
+    \brief Описание
+*/
+WPSLibrary {
+    cpp.defines: [
+        // You can make your code fail to compile if it uses deprecated APIs.
+        // In order to do so, uncomment the following line.
+        //"QT_DISABLE_DEPRECATED_BEFORE=0x060000" // disables all the APIs deprecated before Qt 6.0.0
+        "DATABASE_SQLITE"
+    ]
+    consoleApplication: true
+
+    Depends { name: "Qt"; submodules: [ "core", "sql", "network" ] }
+    Depends { name: "cpp" }
+    Depends { name: "database" }
+    Depends { name: "odb.gen" }
+    Depends { name: "redkit_gen" }
+    Depends { name: "rdbase" }
+
+    cpp.cxxLanguageVersion: "c++20"
+
+    Group {
+        name: "cpp"
+        files: [
+            "restapiserver.*",
+        ]
+    }
+
+    cpp.dynamicLibraries: [
+        "odb-sqlite",
+        "odb-qt",
+        "odb",
+        "sqlite3"
+    ]
+
+} // Project

src/restapi/restapiserver.cpp

@@ -0,0 +1,149 @@
+#include "restapiserver.h"
+
+#include <QJsonArray>
+#include <QJsonDocument>
+#include <QJsonObject>
+#include <QJsonValue>
+
+#include <database/author_s-odb.hxx> // Должен быть здесь
+#include <database/author_s.h>
+#include <database/book_s-odb.hxx> // Должен быть здесь
+#include <database/book_s.h>
+
+#include <odb/core.hxx>
+#include <odb/database.hxx>
+#include <odb/query.hxx>
+
+#include <redkit-gen-modules/json_serializer.h>
+
+RestApiServer::RestApiServer(odb::database& db, QObject* parent) :
+    QTcpServer(parent), m_db(db) {}
+
+void RestApiServer::start(quint16 port)
+{
+    if (!this->listen(QHostAddress::Any, port))
+    {
+        qWarning() << "Ошибка запуска сервера!";
+    }
+    else
+    {
+        QString addrs = "http://127.0.0.1:" + QString::number(this->serverPort());
+        qDebug() << "REST API сервер запущен по адресу:" << addrs;
+    }
+}
+
+void RestApiServer::incomingConnection(qintptr socketDescriptor)
+{
+    QTcpSocket* socket = new QTcpSocket(this);
+    socket->setSocketDescriptor(socketDescriptor);
+
+    connect(socket, &QTcpSocket::readyRead, this, &RestApiServer::handleRequest);
+    connect(socket, &QTcpSocket::disconnected, socket, &QTcpSocket::deleteLater);
+
+    qWarning() << "Есть входящее подключение" << socket->socketDescriptor();
+}
+
+void RestApiServer::handleRequest()
+{
+    QTcpSocket* socket = qobject_cast<QTcpSocket*>(sender());
+    if (!socket)
+        return;
+
+    QString request = QString::fromUtf8(socket->readAll());
+    QByteArray response = processRequest(request);
+
+    socket->write(response);
+    socket->flush();
+    socket->disconnectFromHost();
+}
+
+QByteArray RestApiServer::processRequest(const QString& request)
+{
+    qWarning() << request << "\n\n";
+
+    if (request.startsWith("GET /books/author/"))
+    {
+        QString author = request.section(' ', 1, 1).section('/', 3, 3).replace("%20", " ");
+        quint64 ageReq = author.toInt();
+
+        QStringList nameParts = author.split(' ');
+        QString firstName = nameParts.size() > 0 ? nameParts[0] : "";
+        QString lastName = nameParts.size() > 1 ? nameParts[1] : "";
+
+        qWarning()
+        << "author:" << author << "\n"
+        << "firstName:" << firstName << "\n"
+        << "lastName:" << lastName << "\n";
+
+        odb::transaction t(m_db.begin());
+
+        auto books = m_db.query<Book_S>(odb::query<Book_S>::author->id == ageReq);
+
+        QJsonArray jArray;
+        for (const auto& book : books)
+        {
+            QJsonObject j;
+            j["id"] = QString::number(book.id());
+            j["name"] = book.name();
+            j["author"] = book.author()->full_name();
+            j["year"] = book.year();
+            jArray.push_back(j);
+        }
+        auto jDoc = QJsonDocument(jArray);
+
+        t.commit();
+
+        return "HTTP/1.1 200 OK\r\nContent-Type: application/json\r\n\r\n" + jDoc.toJson(QJsonDocument::Indented);
+    }
+
+    if (request.startsWith("GET /books"))
+    {
+        odb::transaction t(m_db.begin());
+        odb::result<Book_S> res(m_db.query<Book_S>());
+
+        QJsonArray jArray;
+
+        for (auto it = res.begin(); it != res.end(); ++it)
+        {
+            const auto& book = *it;
+
+            QJsonObject j;
+            j["id"] = QString::number(book.id());
+            j["title"] = book.name();
+            j["author"] = book.author()->full_name();
+            j["year"] = book.year();
+            jArray.push_back(j);
+        }
+        auto jDoc = QJsonDocument(jArray);
+
+        t.commit();
+
+        return "HTTP/1.1 200 OK\r\nContent-Type: application/json\r\n\r\n" + jDoc.toJson(QJsonDocument::Indented);
+    }
+
+    if (request.startsWith("GET /author"))
+    {
+        odb::transaction t(m_db.begin());
+        odb::result<Author_S> res(m_db.query<Author_S>());
+
+        QJsonArray jArray;
+
+        for (auto it = res.begin(); it != res.end(); ++it)
+        {
+            const auto& author = *it;
+
+            QJsonObject j;
+            j["id"] = QString::number(author.id());
+            j["first"] = author.firstName();
+            j["last"] = author.lastName();
+            j["age"] = author.age();
+            jArray.push_back(j);
+        }
+        auto jDoc = QJsonDocument(jArray);
+
+        t.commit();
+        return "HTTP/1.1 200 OK\r\nContent-Type: application/json\r\n\r\n" + jDoc.toJson(QJsonDocument::Indented);
+    }
+
+    return "HTTP/1.1 404 Not Found\r\nContent-Type: text/plain\r\n\r\nNot Found";
+}

src/restapi/restapiserver.h

@@ -0,0 +1,29 @@
+#ifndef RESTAPISERVER_H
+#define RESTAPISERVER_H
+
+#include <odb/database.hxx>
+
+#include <QObject>
+#include <QTcpServer>
+#include <QTcpSocket>
+
+class Q_DECL_EXPORT RestApiServer : public QTcpServer
+{
+    Q_OBJECT
+public:
+    explicit RestApiServer(odb::core::database& db, QObject* parent = nullptr);
+    void start(quint16 port = 8080);
+
+protected:
+    void incomingConnection(qintptr socketDescriptor) override;
+
+private slots:
+    void handleRequest();
+
+private:
+    QByteArray processRequest(const QString& request);
+
+    odb::core::database& m_db;
+};
+
+#endif // RESTAPISERVER_H

test/requests/all_books.http

@@ -0,0 +1 @@
+GET http://localhost:8080/books/

test/requests/autor_books.http

@@ -0,0 +1 @@
+GET http://localhost:8080/books/author/George%20Orwell