5 Commits

22 changed files with 448 additions and 523 deletions

5
.gitmodules vendored
View File

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

View File

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

View File

@@ -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
}

View File

@@ -3,19 +3,19 @@ import qbs
Project { Project {
name: "opds++" name: "opds++"
qbsSearchPaths: [ qbsSearchPaths: [
"qbs", "redkitty/qbs",
// "redkitty/qbs",
// // "guiness/qbs",
// // "prerequisites/qbs",
// // "report/qbs",
"redkbuild", "redkbuild",
// // "ext_libs/openssl/qbs", "redkitty/lib/redkit-gen-integration/qbs",
// "redkitty/lib/redkit-gen-integration/qbs", "prerequisites/qbs",
] ]
references: [ references: [
"redkitty/lib/rsc/libs_impl/rdbaseimpl/rdbaseimpl.qbs",
"redkitty/lib/rcore/rcore.qbs",
"src/cpp-opds.qbs", "src/cpp-opds.qbs",
"src/database/database.qbs", "src/database/database.qbs",
"src/model/model.qbs",
"src/restapi/restapi.qbs", "src/restapi/restapi.qbs",
] ]
} }

View File

@@ -1,65 +0,0 @@
import qbs
import qbs.FileInfo
Module {
Depends { name: "cpp" }
Depends { name: "Qt.core" }
FileTagger {
patterns: "*.hxx"
fileTags: ["odb"]
}
Rule {
inputs: ["odb"]
Artifact {
// filePath: FileInfo.baseName(input.fileName)+ "-odb.hxx"
filePath: FileInfo.cleanPath(input.filePath + "/../" ) + "/" + FileInfo.baseName(input.fileName) + "-odb.hxx"
fileTags: ["hpp"]
}
Artifact {
// filePath: FileInfo.baseName(input.fileName) + "-odb.cxx"
filePath: {
// console.error("THIS ART "+FileInfo.cleanPath(input.filePath + "/../") + "/" + FileInfo.baseName(input.fileName) + "-odb.cxx")
return FileInfo.cleanPath(input.filePath + "/../") + "/" + FileInfo.baseName(input.fileName) + "-odb.cxx"}
fileTags: ["cpp"]
}
prepare: {
var cmd = new Command("odb", [
"--std", "c++11",
"-d", "sqlite",
"--generate-query",
"--generate-schema",
"--generate-prepared",
// "--include-prefix", FileInfo.cleanPath(input.filePath + "/../"),
// "--output-dir", product.Qt.core.qmDir,
"--output-dir", FileInfo.cleanPath(input.filePath + "/../"),
"-I/home/uzver/qt5.15/include",
input.filePath,
]);
cmd.description = "Generating ODB files for " + input.fileName;
console.error(cmd.arguments)
return [cmd];
}
}
cpp.includePaths: [
project.sourceDirectory,
product.Qt.core.qmDir,
"/usr/include", // Общие заголовки
"/usr/include/odb" // Заголовки ODB
]
// Подключаем библиотеки ODB
cpp.libraryPaths: [
"/usr/lib" // Путь к библиотекам
]
cpp.dynamicLibraries: [
"odb",
"odb-sqlite"
]
}

1
redkitty Submodule

Submodule redkitty added at 2316ddea72

View File

@@ -3,7 +3,7 @@
\inherits Project \inherits Project
\brief Описание \brief Описание
*/ */
Application { PSApplication {
// CppApplication { // CppApplication {
cpp.defines: [ cpp.defines: [
// You can make your code fail to compile if it uses deprecated APIs. // You can make your code fail to compile if it uses deprecated APIs.
@@ -16,9 +16,12 @@ Application {
Depends { name: "Qt"; submodules: [ "core", "sql", "network" ] } Depends { name: "Qt"; submodules: [ "core", "sql", "network" ] }
Depends { name: "cpp" } Depends { name: "cpp" }
Depends { name: "database" } Depends { name: "database" }
Depends { name: "odbModule"} Depends { name: "odb.gen" }
Depends { name: "sqlite3" }
// Depends { name: "redkit_gen" } Depends { name: "restapi" }
Depends { name: "redkit_gen" }
Depends { name: "rdbase" }
Depends { name: "model" }
cpp.cxxLanguageVersion: "c++20" cpp.cxxLanguageVersion: "c++20"
@@ -29,6 +32,12 @@ Application {
] ]
} }
cpp.dynamicLibraries: [
"odb-sqlite",
"odb-qt",
"odb",
"sqlite3"
]
// } // }
} // Project } // Project

View File

@@ -1,48 +0,0 @@
// file : hello/person.hxx
// copyright : not copyrighted - public domain
#ifndef BOOK_S_H
#define BOOK_S_H
// #include <QtCore/QObject>
#include <memory>
#include <string>
#include <odb/core.hxx>
#include "author_s.h"
#pragma db object
class __attribute__((visibility("default"))) Book_S
{
public:
Book_S() = default;
Book_S(const std::string& name,
const std::shared_ptr<Author_S>& author,
const int year)
{
m_author = author;
m_name = name;
m_year = year;
};
unsigned long long id() const { return m_id; }
std::shared_ptr<Author_S> author() const { return m_author; }
std::string name() const { return m_name; }
int year() const { return m_year; }
private:
friend class odb::access;
private:
#pragma db id auto
unsigned long long m_id;
std::shared_ptr<Author_S> m_author;
std::string m_name;
int m_year;
};
#endif // BOOK_S_H

View File

@@ -13,99 +13,27 @@
#include <memory> // std::unique_ptr #include <memory> // std::unique_ptr
#include <string> #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 <filesystem>
#include <random>
struct testData #include "database_utils.h"
{
std::string first;
std::string last;
int age;
};
// Функция для генерации случайной строки (имени или фамилии) inline uDBase openDB(const std::string path_db)
std::string generate_random_string(const std::vector<std::string>& 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);
}
std::vector<testData> fillDB()
{
std::vector<std::string> 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"
};
std::vector<std::string> 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"
};
std::vector<testData> vecTest;
for (int i = 0; i < 50; ++i)
{
std::string first_name = generate_random_string(first_names);
std::string 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 std::unique_ptr<odb::database> openDB(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)) if (std::filesystem::is_regular_file(path_db))
return std::unique_ptr<odb::core::database>(new odb::sqlite::database(path_db, SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE)); return uDBase(db_ptr);
// И создать новую, если не существует // И создать новую, если не существует
std::unique_ptr<odb::core::database> db(new odb::sqlite::database(path_db, SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE)); uDBase db(db_ptr);
odb::core::connection_ptr connect_ptr(db->connection()); odb::connection_ptr connect_ptr(db->connection());
connect_ptr->execute("PRAGMA foreign_keys=OFF"); connect_ptr->execute("PRAGMA foreign_keys=OFF");
odb::core::transaction tans(db->begin()); odb::transaction tans(db->begin());
odb::core::schema_catalog::create_schema(*db); odb::schema_catalog::create_schema(*db);
tans.commit(); tans.commit();
connect_ptr->execute("PRAGMA foreign_keys=ON"); connect_ptr->execute("PRAGMA foreign_keys=ON");

View File

@@ -8,45 +8,33 @@ PSLibrary {
// You can make your code fail to compile if it uses deprecated APIs. // You can make your code fail to compile if it uses deprecated APIs.
// In order to do so, uncomment the following line. // In order to do so, uncomment the following line.
//"QT_DISABLE_DEPRECATED_BEFORE=0x060000" // disables all the APIs deprecated before Qt 6.0.0 //"QT_DISABLE_DEPRECATED_BEFORE=0x060000" // disables all the APIs deprecated before Qt 6.0.0
"DATABASE_SQLITE" "DATABASE_SQLITE",
"DATABASE_LIBRARY"
] ]
consoleApplication: true consoleApplication: true
Depends { name: "Qt"; submodules: [ "core", "sql", "network" ] } Depends { name: "Qt"; submodules: [ "core", "network" ] }
Depends { name: "cpp" } Depends { name: "cpp" }
Depends { name: "odbModule"}
cpp.cxxLanguageVersion: "c++20" Depends { name: "odb.gen" }
Depends { name: "rdbase" }
odb.gen.databases: "sqlite"
cpp.cxxLanguageVersion: "c++17"
Group { Group {
name: "cpp" name: "cpp"
files: [ files: [
"books.*", "**/*.h",
"databasemanager.*", "**/*.hxx",
"**/*.cpp",
] ]
} }
Group {
name: "odb"
files: [
"author_s.h",
"book_s.h",
]
fileTags: ["odb"]
}
cpp.includePaths: [
"/usr/include", // Общие заголовки
"/usr/include/odb" // Заголовки ODB
]
// Подключаем библиотеки ODB
cpp.libraryPaths: [
"/usr/lib" // Путь к библиотекам
]
cpp.dynamicLibraries: [ cpp.dynamicLibraries: [
"odb-sqlite",
"odb-qt",
"odb", "odb",
"odb-sqlite" "sqlite3"
] ]
} }

View File

@@ -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

View File

@@ -0,0 +1,57 @@
#include "database_utils.h"
#include <random>
namespace
{
// Функция для генерации случайной строки (имени или фамилии)
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);
}
} // namespace
QVector<testData> fillAuthorDB()
{
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;
}

View File

@@ -0,0 +1,37 @@
#include <QString>
#include <QVector>
#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 <rcore/smarttypes.h>
#include "database_global.h"
using oDBase = odb::sqlite::database;
using uDBase = U<oDBase>;
struct testData
{
QString first;
QString last;
int age;
};
QVector<testData> DATABASE_EXPORT fillAuthorDB();

View File

@@ -1,118 +0,0 @@
#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;
}

View File

@@ -1,59 +0,0 @@
#ifndef DATABASEMANAGER_H
#define DATABASEMANAGER_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 Q_DECL_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

View File

@@ -1,47 +1,50 @@
#include <QCoreApplication> #include <QCoreApplication>
#include <QPointer>
#include <QSharedPointer>
#include <QString>
#include <QVector>
#include <restapi/restapiserver.h> #include <restapi/restapiserver.h>
/* Опыты с odb */ /* Опыты с odb */
#include <database/author_s-odb.hxx> // Должен быть здесь #include <model/author_s-odb.hxx> // Должен быть здесь
#include <database/author_s.h> #include <model/author_s.h>
#include <database/book_s-odb.hxx> // Должен быть здесь #include <model/book_s-odb.hxx> // Должен быть здесь
#include <database/book_s.h> #include <model/book_s.h>
#include <database/database.hxx> // create_database #include <database/database.hxx> // create_database
#include <odb/database.hxx> #include <odb/database.hxx>
#include <iostream> #include <iostream>
using unidb = std::unique_ptr<odb::database>; void fillBooksBD(uDBase& db)
void fillBooksBD(unidb& db)
{ {
try try
{ {
std::vector<std::shared_ptr<Author_S>> authors = { QVector<SH<Author_S>> authors = {
std::make_shared<Author_S>("George", "Orwell", 142), SH<Author_S>::create("George", "Orwell", 142),
std::make_shared<Author_S>("J.K.", "Rowling", 56), SH<Author_S>::create("J.K.", "Rowling", 56),
std::make_shared<Author_S>("J.R.R.", "Tolkien", 81), SH<Author_S>::create("J.R.R.", "Tolkien", 81),
std::make_shared<Author_S>("Leo", "Tolstoy", 189), SH<Author_S>::create("Leo", "Tolstoy", 189),
std::make_shared<Author_S>("Fyodor", "Dostoevsky", 174), SH<Author_S>::create("Fyodor", "Dostoevsky", 174),
std::make_shared<Author_S>("Mark", "Twain", 183), SH<Author_S>::create("Mark", "Twain", 183),
std::make_shared<Author_S>("Charles", "Dickens", 208), SH<Author_S>::create("Charles", "Dickens", 208),
std::make_shared<Author_S>("Virginia", "Woolf", 134), SH<Author_S>::create("Virginia", "Woolf", 134),
std::make_shared<Author_S>("Ernest", "Hemingway", 122), SH<Author_S>::create("Ernest", "Hemingway", 122),
std::make_shared<Author_S>("Gabriel", "García Márquez", 98), SH<Author_S>::create("Gabriel", "García Márquez", 98),
std::make_shared<Author_S>("Franz", "Kafka", 100), SH<Author_S>::create("Franz", "Kafka", 100),
std::make_shared<Author_S>("Harper", "Lee", 64), SH<Author_S>::create("Harper", "Lee", 64),
std::make_shared<Author_S>("William", "Shakespeare", 459), SH<Author_S>::create("William", "Shakespeare", 459),
std::make_shared<Author_S>("Oscar", "Wilde", 155), SH<Author_S>::create("Oscar", "Wilde", 155),
std::make_shared<Author_S>("Aldous", "Huxley", 123), SH<Author_S>::create("Aldous", "Huxley", 123),
std::make_shared<Author_S>("Jane", "Austen", 210), SH<Author_S>::create("Jane", "Austen", 210),
std::make_shared<Author_S>("John", "Steinbeck", 116), SH<Author_S>::create("John", "Steinbeck", 116),
std::make_shared<Author_S>("Agatha", "Christie", 124), SH<Author_S>::create("Agatha", "Christie", 124),
std::make_shared<Author_S>("Isaac", "Asimov", 105) SH<Author_S>::create("Isaac", "Asimov", 105)
}; };
// Список книг // Список книг
std::vector<Book_S> books = { QVector<Book_S> books = {
Book_S("1984", authors[0], 1949), Book_S("1984", authors[0], 1949),
Book_S("Harry Potter and the Philosopher's Stone", authors[1], 1997), Book_S("Harry Potter and the Philosopher's Stone", authors[1], 1997),
Book_S("The Hobbit", authors[2], 1937), Book_S("The Hobbit", authors[2], 1937),
@@ -98,7 +101,7 @@ void fillBooksBD(unidb& db)
{ {
odb::core::transaction t(db->begin()); odb::core::transaction t(db->begin());
for (auto& author : authors) for (auto& author : authors)
db->persist(author.get()); // Используем get() для получения сырого указателя db->persist(author);
t.commit(); t.commit();
} }
@@ -123,47 +126,26 @@ int main(int argc, char* argv[])
QCoreApplication a(argc, argv); QCoreApplication a(argc, argv);
const std::string dbPath = "test_db.sqlite"; const std::string dbPath = "test_db.sqlite";
std::unique_ptr<odb::database> db(openDB(dbPath)); uDBase db(openDB(dbPath));
// fillBooksBD(db); // TODO Как-то нужно выполнять лишь раз
fillBooksBD(db);
// Сохранение дополнителньых авторов в базу данных
{
auto authors = fillAuthorDB();
odb::core::transaction t(db->begin());
for (auto& author : authors)
{
SH<Author_S> tempAuthor = SH<Author_S>::create(author.first, author.last, author.age);
db->persist(tempAuthor);
}
t.commit();
}
RestApiServer server(*db); RestApiServer server(*db);
server.start(8080); 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. // Set up code that uses the Qt event loop here.
// Call a.quit() or a.exit() to quit the application. // Call a.quit() or a.exit() to quit the application.
// A not very useful example would be including // A not very useful example would be including

View File

@@ -4,49 +4,48 @@
#ifndef AUTHOR_S_H #ifndef AUTHOR_S_H
#define AUTHOR_S_H #define AUTHOR_S_H
// #include <QtCore/QObject> #include "model_global.h"
#include <cstddef> // std::size_t #include <QString>
#include <memory>
#include <string>
#include <odb/core.hxx> #include <odb/core.hxx>
#include <odb/database.hxx> #include <odb/database.hxx>
#include <odb/query.hxx> #include <odb/query.hxx>
#pragma db object #pragma db object
class __attribute__((visibility("default"))) Author_S class MODEL_EXPORT Author_S
{ {
public: public:
Author_S() = default; Author_S() = default;
Author_S(const std::string& first, Author_S(const QString& firstN,
const std::string& last, const QString& lastN,
const unsigned short age) : const unsigned short age) :
m_first(first), m_firstName(firstN),
m_last(last), m_lastName(lastN),
m_age(age) m_age(age)
{ {
} }
unsigned long long id() const { return m_id; } unsigned long long id() const { return m_id; }
std::string first() const { return m_first; } QString firstName() const { return m_firstName; }
std::string last() const { return m_last; } QString lastName() const { return m_lastName; }
unsigned short age() const { return m_age; } unsigned short age() const { return m_age; }
std::string full_name() const { return m_first + " " + m_last; } QString full_name() const { return m_firstName + " " + m_lastName; }
void age(unsigned short age) { m_age = age; } void age(unsigned short age) { m_age = age; }
private: private:
friend class odb::access; friend class odb::access;
private:
#pragma db id auto #pragma db id auto
unsigned long long m_id; quint64 m_id;
std::string m_first; QString m_firstName;
std::string m_last; QString m_lastName;
unsigned short m_age; quint64 m_age;
}; };
#pragma db view object(Author_S) #pragma db view object(Author_S)

64
src/model/book_s.h Normal file
View File

@@ -0,0 +1,64 @@
// file : hello/person.hxx
// copyright : not copyrighted - public domain
#ifndef BOOK_S_H
#define BOOK_S_H
#include "model_global.h"
#include <QSharedPointer>
#include <QString>
#include <odb/core.hxx>
#include <rcore/smarttypes.h>
#include "author_s.h"
#pragma db object
class MODEL_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

43
src/model/model.qbs Normal file
View File

@@ -0,0 +1,43 @@
/*!
\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",
"MODEL_LIBRARY"
]
consoleApplication: true
Depends { name: "Qt"; submodules: [ "core", "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 {
id: odbs
name: "odb"
files: [
"**/*.h",
]
fileTags: ["hpp", "odbxx", "rgen"]
}
cpp.dynamicLibraries: [
"odb-sqlite",
"odb-qt",
"odb",
"sqlite3"
]
}

12
src/model/model_global.h Normal file
View File

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

View File

@@ -3,7 +3,7 @@
\inherits Project \inherits Project
\brief Описание \brief Описание
*/ */
PSLibrary { WPSLibrary {
cpp.defines: [ cpp.defines: [
// You can make your code fail to compile if it uses deprecated APIs. // You can make your code fail to compile if it uses deprecated APIs.
// In order to do so, uncomment the following line. // In order to do so, uncomment the following line.
@@ -15,10 +15,10 @@ PSLibrary {
Depends { name: "Qt"; submodules: [ "core", "sql", "network" ] } Depends { name: "Qt"; submodules: [ "core", "sql", "network" ] }
Depends { name: "cpp" } Depends { name: "cpp" }
Depends { name: "database" } Depends { name: "database" }
Depends { name: "odbModule"} Depends { name: "odb.gen" }
Depends { name: "redkit_gen" }
Depends { name: "rdbase" }
// Depends { name: "redkit_gen" } Depends { name: "model" }
cpp.cxxLanguageVersion: "c++20" cpp.cxxLanguageVersion: "c++20"
@@ -28,4 +28,12 @@ PSLibrary {
"restapiserver.*", "restapiserver.*",
] ]
} }
cpp.dynamicLibraries: [
"odb-sqlite",
"odb-qt",
"odb",
"sqlite3"
]
} // Project } // Project

View File

@@ -5,14 +5,17 @@
#include <QJsonObject> #include <QJsonObject>
#include <QJsonValue> #include <QJsonValue>
#include <database/book_s.h> #include <model/author_s-odb.hxx> // Должен быть здесь
#include <model/author_s.h>
#include "database/book_s-odb.hxx" #include <model/book_s-odb.hxx> // Должен быть здесь
#include <model/book_s.h>
#include <odb/core.hxx> #include <odb/core.hxx>
#include <odb/database.hxx> #include <odb/database.hxx>
#include <odb/query.hxx> #include <odb/query.hxx>
#include <redkit-gen-modules/json_serializer.h>
RestApiServer::RestApiServer(odb::database& db, QObject* parent) : RestApiServer::RestApiServer(odb::database& db, QObject* parent) :
QTcpServer(parent), m_db(db) {} QTcpServer(parent), m_db(db) {}
@@ -24,7 +27,8 @@ void RestApiServer::start(quint16 port)
} }
else else
{ {
qDebug() << "REST API сервер запущен на порту:" << port; qDebug() << "REST API сервер запущен по адресу:";
qDebug() << QString("http://127.0.0.1:%1").arg(port);
} }
} }
@@ -35,6 +39,8 @@ void RestApiServer::incomingConnection(qintptr socketDescriptor)
connect(socket, &QTcpSocket::readyRead, this, &RestApiServer::handleRequest); connect(socket, &QTcpSocket::readyRead, this, &RestApiServer::handleRequest);
connect(socket, &QTcpSocket::disconnected, socket, &QTcpSocket::deleteLater); connect(socket, &QTcpSocket::disconnected, socket, &QTcpSocket::deleteLater);
qWarning() << "Есть входящее подключение" << socket->socketDescriptor();
} }
void RestApiServer::handleRequest() void RestApiServer::handleRequest()
@@ -53,28 +59,36 @@ void RestApiServer::handleRequest()
QByteArray RestApiServer::processRequest(const QString& request) QByteArray RestApiServer::processRequest(const QString& request)
{ {
// qWarning() << request << "\n\n";
if (request.startsWith("GET /books/author/")) if (request.startsWith("GET /books/author/"))
{ {
QString author = request.section(' ', 1, 1).section('/', 3, 3).replace("%20", " "); QString author = request.section(' ', 1, 1).section('/', 3, 3).replace("%20", " ");
quint64 ageReq = author.toInt();
// Books books; QStringList nameParts = author.split(' ');
// QList<BookRecord> results = books.getBooksByAuthor(author); QString firstName = nameParts.size() > 0 ? nameParts[0] : "";
QString lastName = nameParts.size() > 1 ? nameParts[1] : "";
QByteArray jsonResponse = "{ \"books\": ["; odb::transaction t(m_db.begin());
// for (const BookRecord& book : results)
// {
// jsonResponse += QString("{ \"id\": %1, \"title\": \"%2\", \"author\": \"%3\", \"year\": %4 },")
// .arg(book.id)
// .arg(book.title)
// .arg(book.author)
// .arg(book.year)
// .toUtf8();
// }
// if (results.size() > 0)
// jsonResponse.chop(1); // Убираем последнюю запятую
// jsonResponse += "] }";
return "HTTP/1.1 200 OK\r\nContent-Type: application/json\r\n\r\n" + jsonResponse; 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")) if (request.startsWith("GET /books"))
@@ -83,20 +97,18 @@ QByteArray RestApiServer::processRequest(const QString& request)
odb::result<Book_S> res(m_db.query<Book_S>()); odb::result<Book_S> res(m_db.query<Book_S>());
QJsonArray jArray; QJsonArray jArray;
for (auto it = res.begin(); it != res.end(); ++it) for (auto it = res.begin(); it != res.end(); ++it)
{ {
const auto& book = *it; const auto& book = *it;
QJsonObject j; QJsonObject j;
j["id"] = QString::number(book.id()); j["id"] = QString::number(book.id());
j["title"] = QString::fromStdString(book.name()); j["title"] = book.name();
j["author"] = QString::fromStdString(book.author()->full_name()); j["author"] = book.author()->full_name();
j["year"] = book.year(); j["year"] = book.year();
jArray.push_back(j); jArray.push_back(j);
} }
auto jDoc = QJsonDocument(jArray); auto jDoc = QJsonDocument(jArray);
t.commit(); 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 200 OK\r\nContent-Type: application/json\r\n\r\n" + jDoc.toJson(QJsonDocument::Indented);
@@ -108,21 +120,20 @@ QByteArray RestApiServer::processRequest(const QString& request)
odb::result<Author_S> res(m_db.query<Author_S>()); odb::result<Author_S> res(m_db.query<Author_S>());
QJsonArray jArray; QJsonArray jArray;
for (auto it = res.begin(); it != res.end(); ++it) for (auto it = res.begin(); it != res.end(); ++it)
{ {
const auto& author = *it; const auto& author = *it;
QJsonObject j; QJsonObject j;
j["id"] = QString::number(author.id()); j["id"] = QString::number(author.id());
j["first"] = QString::fromStdString(author.first()); j["first"] = author.firstName();
j["last"] = QString::fromStdString(author.last()); j["last"] = author.lastName();
j["age"] = author.age(); j["age"] = author.age();
jArray.push_back(j); jArray.push_back(j);
} }
auto jDoc = QJsonDocument(jArray); auto jDoc = QJsonDocument(jArray);
t.commit(); 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 200 OK\r\nContent-Type: application/json\r\n\r\n" + jDoc.toJson(QJsonDocument::Indented);
} }