Compare commits
17 Commits
3c2b8e7cf4
...
Новые-табл
| Author | SHA1 | Date | |
|---|---|---|---|
| 7406bcec21 | |||
| b4fa718be6 | |||
| 78b01bc0b1 | |||
| b993116e09 | |||
| 4568ef65db | |||
| c151fdd8d1 | |||
| d01c789b06 | |||
| 34fcabc04e | |||
| 89b43f5aad | |||
| 8cb56837f5 | |||
| 96bdf1e5e8 | |||
| 0198f6d022 | |||
| 905dd309d0 | |||
| 65059351f7 | |||
| 594b3a936f | |||
| f8e504bb07 | |||
| b16ae39263 |
8
.gitmodules
vendored
8
.gitmodules
vendored
@@ -1,3 +1,9 @@
|
|||||||
[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
|
||||||
|
[submodule "external_libs/quazip"]
|
||||||
|
path = external_libs/quazip
|
||||||
|
url = https://github.com/stachenov/quazip.git
|
||||||
|
|||||||
34
external_libs/quazip.qbs
Normal file
34
external_libs/quazip.qbs
Normal file
@@ -0,0 +1,34 @@
|
|||||||
|
import qbs
|
||||||
|
|
||||||
|
PSLibrary {
|
||||||
|
name: "quazip"
|
||||||
|
|
||||||
|
property string quazipPath: path + "/quazip" // Путь к исходникам QuaZip
|
||||||
|
property string noname: {
|
||||||
|
console.error("noname" + exportedIncludePaths)
|
||||||
|
return "noname"
|
||||||
|
}
|
||||||
|
|
||||||
|
Depends { name: "zlib" }
|
||||||
|
|
||||||
|
Group {
|
||||||
|
name: "h"
|
||||||
|
id: qh
|
||||||
|
files: [
|
||||||
|
quazipPath + "/quazip/*.h",
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|
||||||
|
Group {
|
||||||
|
name: "cpp"
|
||||||
|
files: [
|
||||||
|
quazipPath + "/quazip/*.cpp",
|
||||||
|
quazipPath + "/quazip/*.c"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|
||||||
|
// Export {
|
||||||
|
// Depends { name:"cpp" }
|
||||||
|
// cpp.includePaths: qh
|
||||||
|
// }
|
||||||
|
}
|
||||||
8
prerequisites/qbs/imports/SQLiteArtifactsExport.qbs
Normal file
8
prerequisites/qbs/imports/SQLiteArtifactsExport.qbs
Normal file
@@ -0,0 +1,8 @@
|
|||||||
|
import qbs
|
||||||
|
|
||||||
|
Export {
|
||||||
|
Depends { name: "cpp" }
|
||||||
|
Depends { name: "rsc.sqlite.settings" }
|
||||||
|
|
||||||
|
rsc.sqlite.settings.includeRegexValues: exportingProduct.includeRegexValue
|
||||||
|
}
|
||||||
53
prerequisites/qbs/modules/karchive/karchive.qbs
Normal file
53
prerequisites/qbs/modules/karchive/karchive.qbs
Normal 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
|
||||||
|
}
|
||||||
18
project.qbs
18
project.qbs
@@ -3,19 +3,23 @@ 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",
|
||||||
|
"src/utils/utils.qbs",
|
||||||
|
"src/repository/repository.qbs",
|
||||||
|
|
||||||
|
"external_libs/quazip.qbs",
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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
1
redkitty
Submodule
Submodule redkitty added at 47579f9e2e
@@ -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,14 @@ 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" }
|
||||||
|
Depends { name: "quazip" }
|
||||||
|
Depends { name: "utils" }
|
||||||
|
|
||||||
cpp.cxxLanguageVersion: "c++20"
|
cpp.cxxLanguageVersion: "c++20"
|
||||||
|
|
||||||
@@ -29,6 +34,12 @@ Application {
|
|||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|
||||||
|
cpp.dynamicLibraries: [
|
||||||
|
"odb-sqlite",
|
||||||
|
"odb-qt",
|
||||||
|
"odb",
|
||||||
|
"sqlite3"
|
||||||
|
]
|
||||||
|
|
||||||
// }
|
// }
|
||||||
} // Project
|
} // Project
|
||||||
|
|||||||
@@ -1,65 +0,0 @@
|
|||||||
// file : hello/person.hxx
|
|
||||||
// copyright : not copyrighted - public domain
|
|
||||||
|
|
||||||
#ifndef AUTHOR_S_H
|
|
||||||
#define AUTHOR_S_H
|
|
||||||
|
|
||||||
// #include <QtCore/QObject>
|
|
||||||
|
|
||||||
#include <cstddef> // std::size_t
|
|
||||||
#include <memory>
|
|
||||||
#include <string>
|
|
||||||
|
|
||||||
#include <odb/core.hxx>
|
|
||||||
#include <odb/database.hxx>
|
|
||||||
#include <odb/query.hxx>
|
|
||||||
|
|
||||||
#pragma db object
|
|
||||||
class __attribute__((visibility("default"))) Author_S
|
|
||||||
{
|
|
||||||
public:
|
|
||||||
Author_S() = default;
|
|
||||||
|
|
||||||
Author_S(const std::string& first,
|
|
||||||
const std::string& last,
|
|
||||||
const unsigned short age) :
|
|
||||||
m_first(first),
|
|
||||||
m_last(last),
|
|
||||||
m_age(age)
|
|
||||||
{
|
|
||||||
}
|
|
||||||
|
|
||||||
unsigned long long id() const { return m_id; }
|
|
||||||
std::string first() const { return m_first; }
|
|
||||||
std::string last() const { return m_last; }
|
|
||||||
unsigned short age() const { return m_age; }
|
|
||||||
|
|
||||||
std::string full_name() const { return m_first + " " + m_last; }
|
|
||||||
|
|
||||||
void age(unsigned short age) { m_age = age; }
|
|
||||||
|
|
||||||
private:
|
|
||||||
friend class odb::access;
|
|
||||||
|
|
||||||
#pragma db id auto
|
|
||||||
unsigned long long m_id;
|
|
||||||
|
|
||||||
std::string m_first;
|
|
||||||
std::string m_last;
|
|
||||||
unsigned short 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
|
|
||||||
@@ -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
|
|
||||||
@@ -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");
|
||||||
|
|||||||
@@ -8,45 +8,35 @@ 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
|
|
||||||
|
|
||||||
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" }
|
||||||
|
Depends { name: "model" }
|
||||||
|
|
||||||
|
Depends { name: "redkit_gen" }
|
||||||
|
|
||||||
|
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"
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|||||||
12
src/database/database_global.h
Normal file
12
src/database/database_global.h
Normal 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
|
||||||
55
src/database/database_utils.cpp
Normal file
55
src/database/database_utils.cpp
Normal file
@@ -0,0 +1,55 @@
|
|||||||
|
#include "database_utils.h"
|
||||||
|
|
||||||
|
void addBook(oDBase& db, const QString title, const QVector<QString>& authors)
|
||||||
|
{
|
||||||
|
odb::transaction t(db.begin());
|
||||||
|
try
|
||||||
|
{
|
||||||
|
// 1. Создаем/получаем книгу
|
||||||
|
auto books = db.query<Book_S>(odb::query<Book_S>::title == title);
|
||||||
|
SH<Book_S> book;
|
||||||
|
|
||||||
|
if (books.empty())
|
||||||
|
{
|
||||||
|
book = SH<Book_S>::create();
|
||||||
|
book->setTitle(title);
|
||||||
|
|
||||||
|
db.persist(book);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
book = books.begin().load(); // Берем первую найденную книгу
|
||||||
|
}
|
||||||
|
|
||||||
|
// 2. Обрабатываем авторов
|
||||||
|
for (const auto& name : authors)
|
||||||
|
{
|
||||||
|
auto authors = db.query<Author_S>(odb::query<Author_S>::fullName == name);
|
||||||
|
SH<Author_S> author = authors.empty() ? SH<Author_S>::create() : authors.begin().load();
|
||||||
|
|
||||||
|
if (authors.empty())
|
||||||
|
{
|
||||||
|
author->setFullName(name);
|
||||||
|
db.persist(author);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Проверяем и создаем связь
|
||||||
|
|
||||||
|
auto links = db.query<AuthorBook_S>(
|
||||||
|
odb::query<AuthorBook_S>::author->id == author->id()
|
||||||
|
&& odb::query<AuthorBook_S>::book->id == book->id());
|
||||||
|
|
||||||
|
if (links.empty())
|
||||||
|
{
|
||||||
|
db.persist(SH<AuthorBook_S>::create(author, book));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
t.commit();
|
||||||
|
}
|
||||||
|
catch (...)
|
||||||
|
{
|
||||||
|
t.rollback();
|
||||||
|
throw;
|
||||||
|
}
|
||||||
|
}
|
||||||
38
src/database/database_utils.h
Normal file
38
src/database/database_utils.h
Normal file
@@ -0,0 +1,38 @@
|
|||||||
|
#include <QDebug>
|
||||||
|
#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>;
|
||||||
|
|
||||||
|
#include <model/books/author_book_s-odb.hxx>
|
||||||
|
#include <model/books/author_book_s.h>
|
||||||
|
#include <model/books/author_s-odb.hxx>
|
||||||
|
#include <model/books/author_s.h>
|
||||||
|
#include <model/books/book_s-odb.hxx>
|
||||||
|
#include <model/books/book_s.h>
|
||||||
|
|
||||||
|
void DATABASE_EXPORT addBook(oDBase& db, const QString title, const QVector<QString>& authors);
|
||||||
@@ -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;
|
|
||||||
}
|
|
||||||
@@ -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
|
|
||||||
227
src/main.cpp
227
src/main.cpp
@@ -1,114 +1,106 @@
|
|||||||
#include <QCoreApplication>
|
#include <QCoreApplication>
|
||||||
|
|
||||||
|
#include <QDataStream>
|
||||||
|
#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 <database/author_s.h>
|
|
||||||
#include <database/book_s-odb.hxx> // Должен быть здесь
|
|
||||||
#include <database/book_s.h>
|
|
||||||
#include <database/database.hxx> // create_database
|
#include <database/database.hxx> // create_database
|
||||||
|
#include <database/database_utils.h>
|
||||||
#include <odb/database.hxx>
|
#include <odb/database.hxx>
|
||||||
|
|
||||||
#include <iostream>
|
#include <iostream>
|
||||||
|
|
||||||
using unidb = std::unique_ptr<odb::database>;
|
#include <utils/fb2extractor.h>
|
||||||
|
#include <utils/zipwrapper.h>
|
||||||
|
|
||||||
void fillBooksBD(unidb& db)
|
void fillBooksBD(uDBase& db)
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
std::vector<std::shared_ptr<Author_S>> authors = {
|
QVector<Author_S> authors = {
|
||||||
std::make_shared<Author_S>("George", "Orwell", 142),
|
Author_S("George Orwell"),
|
||||||
std::make_shared<Author_S>("J.K.", "Rowling", 56),
|
Author_S("J.K. Rowling"),
|
||||||
std::make_shared<Author_S>("J.R.R.", "Tolkien", 81),
|
Author_S("J.R.R. Tolkien"),
|
||||||
std::make_shared<Author_S>("Leo", "Tolstoy", 189),
|
Author_S("Leo Tolstoy"),
|
||||||
std::make_shared<Author_S>("Fyodor", "Dostoevsky", 174),
|
Author_S("Fyodor Dostoevsky"),
|
||||||
std::make_shared<Author_S>("Mark", "Twain", 183),
|
Author_S("Mark Twain"),
|
||||||
std::make_shared<Author_S>("Charles", "Dickens", 208),
|
Author_S("Charles Dickens"),
|
||||||
std::make_shared<Author_S>("Virginia", "Woolf", 134),
|
Author_S("Virginia Woolf"),
|
||||||
std::make_shared<Author_S>("Ernest", "Hemingway", 122),
|
Author_S("Ernest Hemingway"),
|
||||||
std::make_shared<Author_S>("Gabriel", "García Márquez", 98),
|
Author_S("Gabriel García Márquez"),
|
||||||
std::make_shared<Author_S>("Franz", "Kafka", 100),
|
Author_S("Franz Kafka"),
|
||||||
std::make_shared<Author_S>("Harper", "Lee", 64),
|
Author_S("Harper Lee"),
|
||||||
std::make_shared<Author_S>("William", "Shakespeare", 459),
|
Author_S("William Shakespeare"),
|
||||||
std::make_shared<Author_S>("Oscar", "Wilde", 155),
|
Author_S("Oscar Wilde"),
|
||||||
std::make_shared<Author_S>("Aldous", "Huxley", 123),
|
Author_S("Aldous Huxley"),
|
||||||
std::make_shared<Author_S>("Jane", "Austen", 210),
|
Author_S("Jane Austen"),
|
||||||
std::make_shared<Author_S>("John", "Steinbeck", 116),
|
Author_S("John Steinbeck"),
|
||||||
std::make_shared<Author_S>("Agatha", "Christie", 124),
|
Author_S("Agatha Christie"),
|
||||||
std::make_shared<Author_S>("Isaac", "Asimov", 105)
|
Author_S("Isaac Asimov"),
|
||||||
};
|
};
|
||||||
|
|
||||||
// Список книг
|
addBook(*db, "Очень странная книжка", { "Автор 1", "Автор 2", "Авторк 3" });
|
||||||
std::vector<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)
|
|
||||||
};
|
|
||||||
|
|
||||||
// Сохранение авторов в базу данных
|
addBook(*db, "1984", { authors[0].fullName() });
|
||||||
{
|
addBook(*db, "Harry Potter and the Philosopher's Stone", { authors[1].fullName() });
|
||||||
odb::core::transaction t(db->begin());
|
addBook(*db, "The Hobbit", { authors[2].fullName() });
|
||||||
for (auto& author : authors)
|
addBook(*db, "War and Peace", { authors[3].fullName() });
|
||||||
db->persist(author.get()); // Используем get() для получения сырого указателя
|
addBook(*db, "Crime and Punishment", { authors[4].fullName() });
|
||||||
t.commit();
|
addBook(*db, "Adventures of Huckleberry Finn", { authors[5].fullName() });
|
||||||
}
|
addBook(*db, "A Tale of Two Cities", { authors[6].fullName() });
|
||||||
|
addBook(*db, "Mrs. Dalloway", { authors[7].fullName() });
|
||||||
|
addBook(*db, "The Old Man and the Sea", { authors[8].fullName() });
|
||||||
|
addBook(*db, "One Hundred Years of Solitude", { authors[9].fullName() });
|
||||||
|
addBook(*db, "The Trial", { authors[10].fullName() });
|
||||||
|
addBook(*db, "To Kill a Mockingbird", { authors[11].fullName() });
|
||||||
|
addBook(*db, "Macbeth", { authors[12].fullName() });
|
||||||
|
addBook(*db, "The Picture of Dorian Gray", { authors[13].fullName() });
|
||||||
|
addBook(*db, "Brave New World", { authors[14].fullName() });
|
||||||
|
addBook(*db, "Pride and Prejudice", { authors[15].fullName() });
|
||||||
|
addBook(*db, "The Brothers Karamazov", { authors[4].fullName() });
|
||||||
|
addBook(*db, "The Grapes of Wrath", { authors[16].fullName() });
|
||||||
|
addBook(*db, "Murder on the Orient Express", { authors[17].fullName() });
|
||||||
|
addBook(*db, "I, Robot", { authors[18].fullName() });
|
||||||
|
addBook(*db, "Animal Farm", { authors[0].fullName() });
|
||||||
|
addBook(*db, "Harry Potter and the Chamber of Secrets", { authors[1].fullName() });
|
||||||
|
addBook(*db, "The Lord of the Rings: The Fellowship of the Ring", { authors[2].fullName() });
|
||||||
|
addBook(*db, "Anna Karenina", { authors[3].fullName() });
|
||||||
|
addBook(*db, "The Idiot", { authors[4].fullName() });
|
||||||
|
addBook(*db, "The Adventures of Tom Sawyer", { authors[5].fullName() });
|
||||||
|
addBook(*db, "Oliver Twist", { authors[6].fullName() });
|
||||||
|
addBook(*db, "To the Lighthouse", { authors[7].fullName() });
|
||||||
|
addBook(*db, "For Whom the Bell Tolls", { authors[8].fullName() });
|
||||||
|
addBook(*db, "Love in the Time of Cholera", { authors[9].fullName() });
|
||||||
|
addBook(*db, "The Metamorphosis", { authors[10].fullName() });
|
||||||
|
addBook(*db, "Go Set a Watchman", { authors[11].fullName() });
|
||||||
|
addBook(*db, "King Lear", { authors[12].fullName() });
|
||||||
|
addBook(*db, "The Importance of Being Earnest", { authors[13].fullName() });
|
||||||
|
addBook(*db, "Brave New World Revisited", { authors[14].fullName() });
|
||||||
|
addBook(*db, "Emma", { authors[15].fullName() });
|
||||||
|
addBook(*db, "The Double", { authors[4].fullName() });
|
||||||
|
addBook(*db, "Of Mice and Men", { authors[16].fullName() });
|
||||||
|
addBook(*db, "And Then There Were None", { authors[17].fullName() });
|
||||||
|
addBook(*db, "The Foundation Trilogy", { authors[18].fullName() });
|
||||||
|
addBook(*db, "Down and Out in Paris and London", { authors[0].fullName() });
|
||||||
|
addBook(*db, "Harry Potter and the Prisoner of Azkaban", { authors[1].fullName() });
|
||||||
|
addBook(*db, "The Lord of the Rings: The Two Towers", { authors[2].fullName() });
|
||||||
|
addBook(*db, "War and Peace", { authors[3].fullName() });
|
||||||
|
addBook(*db, "The Brothers Karamazov", { authors[4].fullName() });
|
||||||
|
addBook(*db, "The Prince and the Pauper", { authors[5].fullName() });
|
||||||
|
addBook(*db, "David Copperfield", { authors[6].fullName() });
|
||||||
|
addBook(*db, "The Waves", { authors[7].fullName() });
|
||||||
|
addBook(*db, "A Farewell to Arms", { authors[8].fullName() });
|
||||||
|
addBook(*db, "Chronicle of a Death Foretold", { authors[9].fullName() });
|
||||||
|
|
||||||
// Сохранение книг в базу данных
|
addBook(*db, "1984", { "George Orwell" });
|
||||||
{
|
addBook(*db, "Harry Potter and the Philosopher's Stone", { "J.K. Rowling" });
|
||||||
odb::core::transaction t(db->begin());
|
|
||||||
for (auto& book : books)
|
addBook(*db, "Очень странная книжка 2", { "Автор 4", "Авторк 3" });
|
||||||
db->persist(book);
|
|
||||||
t.commit();
|
|
||||||
}
|
|
||||||
|
|
||||||
std::cout << "Test data added successfully." << std::endl;
|
std::cout << "Test data added successfully." << std::endl;
|
||||||
}
|
}
|
||||||
@@ -123,47 +115,31 @@ 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));
|
||||||
|
|
||||||
|
// TODO Как-то нужно выполнять лишь раз
|
||||||
// fillBooksBD(db);
|
// fillBooksBD(db);
|
||||||
|
|
||||||
RestApiServer server(*db);
|
RestApiServer server(*db);
|
||||||
server.start(8080);
|
server.start(8080);
|
||||||
|
|
||||||
/* Опыты с odb */
|
QString zipArzh = "/home/alex/repos/exp/cpp-opds/f.fb2-631519-634744.zip";
|
||||||
|
|
||||||
// const std::string dbPath = "test_db.sqlite";
|
auto z = ZipWrapper(zipArzh);
|
||||||
|
const auto books = z.work();
|
||||||
|
|
||||||
// std::vector<Author_S> authors;
|
for (const auto& book : books)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
addBook(*db, book.title, book.authors);
|
||||||
|
}
|
||||||
|
catch (const odb::exception& e)
|
||||||
|
{
|
||||||
|
std::cerr << "Error adding test data: " << e.what() << std::endl;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// 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
|
||||||
@@ -175,5 +151,6 @@ int main(int argc, char* argv[])
|
|||||||
// If you do not need a running Qt event loop, remove the call
|
// 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.
|
// to a.exec() or use the Non-Qt Plain C++ Application template.
|
||||||
|
|
||||||
|
// qWarning() << "S EXIT";
|
||||||
return a.exec();
|
return a.exec();
|
||||||
}
|
}
|
||||||
|
|||||||
47
src/model/books/author_book_s.h
Normal file
47
src/model/books/author_book_s.h
Normal file
@@ -0,0 +1,47 @@
|
|||||||
|
#ifndef AUTHOR_BOOK_H
|
||||||
|
#define AUTHOR_BOOK_H
|
||||||
|
|
||||||
|
#include <model/model_global.h>
|
||||||
|
|
||||||
|
#include "author_s.h"
|
||||||
|
#include "book_s.h"
|
||||||
|
|
||||||
|
#pragma db object
|
||||||
|
class MODEL_EXPORT AuthorBook_S
|
||||||
|
{
|
||||||
|
private:
|
||||||
|
AuthorBook_S() = default;
|
||||||
|
|
||||||
|
public:
|
||||||
|
AuthorBook_S(SH<Author_S> author,
|
||||||
|
SH<Book_S> book) :
|
||||||
|
m_author(author),
|
||||||
|
m_book(book) {}
|
||||||
|
|
||||||
|
quint64 id() const { return m_id; }
|
||||||
|
void setId(quint64 newId) { m_id = newId; }
|
||||||
|
|
||||||
|
SH<Author_S> author() const { return m_author; }
|
||||||
|
void setAuthor(const SH<Author_S>& newAuthor) { m_author = newAuthor; }
|
||||||
|
|
||||||
|
SH<Book_S> book() const { return m_book; }
|
||||||
|
void setBook(const SH<Book_S>& newBook) { m_book = newBook; }
|
||||||
|
|
||||||
|
private:
|
||||||
|
friend class odb::access;
|
||||||
|
|
||||||
|
private:
|
||||||
|
public:
|
||||||
|
#pragma db id auto
|
||||||
|
quint64 m_id;
|
||||||
|
|
||||||
|
#pragma db not_null
|
||||||
|
SH<Author_S> m_author;
|
||||||
|
|
||||||
|
#pragma db not_null
|
||||||
|
SH<Book_S> m_book;
|
||||||
|
|
||||||
|
#pragma db index("author_book_unique") member(m_author) member(m_book) unique
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // AUTHOR_BOOK_H
|
||||||
42
src/model/books/author_s.h
Normal file
42
src/model/books/author_s.h
Normal file
@@ -0,0 +1,42 @@
|
|||||||
|
#ifndef AUTHOR_S_H
|
||||||
|
#define AUTHOR_S_H
|
||||||
|
|
||||||
|
#include <model/model_global.h>
|
||||||
|
|
||||||
|
#pragma db object
|
||||||
|
class MODEL_EXPORT Author_S
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
Author_S() = default;
|
||||||
|
Author_S(const QString& fullName) :
|
||||||
|
m_fullName(fullName) {}
|
||||||
|
|
||||||
|
quint64 id() const { return m_id; }
|
||||||
|
void setId(quint64 newId) { m_id = newId; }
|
||||||
|
|
||||||
|
QString fullName() const { return m_fullName; }
|
||||||
|
void setFullName(const QString& newFullName) { m_fullName = newFullName; }
|
||||||
|
|
||||||
|
QString langCode() const { return m_langCode; }
|
||||||
|
void setLangCode(const QString& newLangCode) { m_langCode = newLangCode; }
|
||||||
|
|
||||||
|
private:
|
||||||
|
friend class odb::access;
|
||||||
|
|
||||||
|
private:
|
||||||
|
public:
|
||||||
|
#pragma db id auto
|
||||||
|
quint64 m_id;
|
||||||
|
|
||||||
|
QString m_fullName;
|
||||||
|
QString m_langCode;
|
||||||
|
};
|
||||||
|
|
||||||
|
#pragma db view object(Author_S)
|
||||||
|
struct person_stat
|
||||||
|
{
|
||||||
|
#pragma db column("count(" + Author_S::m_id + ")")
|
||||||
|
std::size_t count;
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // AUTHOR_S_H
|
||||||
43
src/model/books/book_s.h
Normal file
43
src/model/books/book_s.h
Normal file
@@ -0,0 +1,43 @@
|
|||||||
|
#ifndef BOOK_S_H
|
||||||
|
#define BOOK_S_H
|
||||||
|
|
||||||
|
#include <model/model_global.h>
|
||||||
|
|
||||||
|
#include <QDateTime>
|
||||||
|
|
||||||
|
#pragma db object
|
||||||
|
class MODEL_EXPORT Book_S
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
Book_S() = default;
|
||||||
|
|
||||||
|
quint64 id() const { return m_id; }
|
||||||
|
void setId(const quint64& newId) { m_id = newId; }
|
||||||
|
|
||||||
|
QString title() const { return m_title; }
|
||||||
|
void setTitle(const QString& newTitle) { m_title = newTitle; }
|
||||||
|
|
||||||
|
quint8 year() const { return m_year; }
|
||||||
|
void setYear(const quint8& newYear) { m_year = newYear; }
|
||||||
|
|
||||||
|
QDateTime lastModified() const { return m_lastModified; }
|
||||||
|
void setLastModified(const QDateTime& newLastModified) { m_lastModified = newLastModified; }
|
||||||
|
|
||||||
|
QString lang() const { return m_lang; }
|
||||||
|
void setLang(const QString& newLang) { m_lang = newLang; }
|
||||||
|
|
||||||
|
private:
|
||||||
|
friend class odb::access;
|
||||||
|
|
||||||
|
private:
|
||||||
|
public:
|
||||||
|
#pragma db id auto
|
||||||
|
quint64 m_id;
|
||||||
|
|
||||||
|
QString m_title;
|
||||||
|
quint8 m_year;
|
||||||
|
QDateTime m_lastModified;
|
||||||
|
QString m_lang;
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // BOOK_S_H
|
||||||
46
src/model/books/genre_book_s.h
Normal file
46
src/model/books/genre_book_s.h
Normal file
@@ -0,0 +1,46 @@
|
|||||||
|
#ifndef GENRE_BOOK_S_H
|
||||||
|
#define GENRE_BOOK_S_H
|
||||||
|
|
||||||
|
#include <model/model_global.h>
|
||||||
|
|
||||||
|
#include "book_s.h"
|
||||||
|
#include "genre_s.h"
|
||||||
|
|
||||||
|
#pragma db object
|
||||||
|
class GenreBook_S
|
||||||
|
{
|
||||||
|
private:
|
||||||
|
GenreBook_S() = default;
|
||||||
|
|
||||||
|
public:
|
||||||
|
GenreBook_S(const SH<Genre_S>& genreId, const SH<Book_S>& bookId) :
|
||||||
|
m_genreId(genreId),
|
||||||
|
m_bookId(bookId) {}
|
||||||
|
|
||||||
|
quint64 id() const { return m_id; }
|
||||||
|
void setId(quint64 newId) { m_id = newId; }
|
||||||
|
|
||||||
|
SH<Genre_S> genreId() const { return m_genreId; }
|
||||||
|
void setGenreId(const SH<Genre_S>& newGenreId) { m_genreId = newGenreId; }
|
||||||
|
|
||||||
|
SH<Book_S> bookId() const { return m_bookId; }
|
||||||
|
void setBookId(const SH<Book_S>& newBookId) { m_bookId = newBookId; }
|
||||||
|
|
||||||
|
private:
|
||||||
|
friend class odb::access;
|
||||||
|
|
||||||
|
private:
|
||||||
|
public:
|
||||||
|
#pragma db id auto
|
||||||
|
quint64 m_id;
|
||||||
|
|
||||||
|
#pragma db not_null
|
||||||
|
SH<Genre_S> m_genreId;
|
||||||
|
|
||||||
|
#pragma db not_null
|
||||||
|
SH<Book_S> m_bookId;
|
||||||
|
|
||||||
|
#pragma db index("genre_book_unique") member(m_genreId) member(m_bookId) unique
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // GENRE_BOOK_S_H
|
||||||
29
src/model/books/genre_s.h
Normal file
29
src/model/books/genre_s.h
Normal file
@@ -0,0 +1,29 @@
|
|||||||
|
#ifndef GENRE_H
|
||||||
|
#define GENRE_H
|
||||||
|
|
||||||
|
#include <model/model_global.h>
|
||||||
|
|
||||||
|
#pragma db object
|
||||||
|
class MODEL_EXPORT Genre_S
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
Genre_S() = default;
|
||||||
|
|
||||||
|
quint64 id() const { return m_id; }
|
||||||
|
void setId(const quint64& newId) { m_id = newId; }
|
||||||
|
|
||||||
|
QString name() const { return m_name; }
|
||||||
|
void setName(const QString& newName) { m_name = newName; }
|
||||||
|
|
||||||
|
private:
|
||||||
|
friend class odb::access;
|
||||||
|
|
||||||
|
private:
|
||||||
|
public:
|
||||||
|
#pragma db id auto
|
||||||
|
quint64 m_id;
|
||||||
|
|
||||||
|
QString m_name;
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // GENRE_H
|
||||||
10
src/model/books/manutomanybase.h
Normal file
10
src/model/books/manutomanybase.h
Normal file
@@ -0,0 +1,10 @@
|
|||||||
|
#ifndef MANUTOMANYBASE_H
|
||||||
|
#define MANUTOMANYBASE_H
|
||||||
|
|
||||||
|
class ManuToManyBase
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
ManuToManyBase();
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // MANUTOMANYBASE_H
|
||||||
46
src/model/books/series_book_s.h
Normal file
46
src/model/books/series_book_s.h
Normal file
@@ -0,0 +1,46 @@
|
|||||||
|
#ifndef SERIES_BOOK_S_H
|
||||||
|
#define SERIES_BOOK_S_H
|
||||||
|
|
||||||
|
#include <model/model_global.h>
|
||||||
|
|
||||||
|
#include "book_s.h"
|
||||||
|
#include "series_s.h"
|
||||||
|
|
||||||
|
#pragma db object
|
||||||
|
class MODEL_EXPORT SeriesBook_S
|
||||||
|
{
|
||||||
|
private:
|
||||||
|
SeriesBook_S() = default;
|
||||||
|
|
||||||
|
public:
|
||||||
|
SeriesBook_S(const SH<Series_S>& serieId, const SH<Book_S>& bookId) :
|
||||||
|
m_serieId(serieId),
|
||||||
|
m_bookId(bookId) {}
|
||||||
|
|
||||||
|
quint64 id() const { return m_id; }
|
||||||
|
void setId(quint64 newId) { m_id = newId; }
|
||||||
|
|
||||||
|
SH<Series_S> serieId() const { return m_serieId; }
|
||||||
|
void setSerieId(const SH<Series_S>& newSerieId) { m_serieId = newSerieId; }
|
||||||
|
|
||||||
|
SH<Book_S> bookId() const { return m_bookId; }
|
||||||
|
void setBookId(const SH<Book_S>& newBookId) { m_bookId = newBookId; }
|
||||||
|
|
||||||
|
private:
|
||||||
|
friend class odb::access;
|
||||||
|
|
||||||
|
private:
|
||||||
|
public:
|
||||||
|
#pragma db id auto
|
||||||
|
quint64 m_id;
|
||||||
|
|
||||||
|
#pragma db not_null
|
||||||
|
SH<Series_S> m_serieId;
|
||||||
|
|
||||||
|
#pragma db not_null
|
||||||
|
SH<Book_S> m_bookId;
|
||||||
|
|
||||||
|
#pragma db index("series_book_unique") member(m_serieId) member(m_bookId) unique
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // SERIES_BOOK_S_H
|
||||||
29
src/model/books/series_s.h
Normal file
29
src/model/books/series_s.h
Normal file
@@ -0,0 +1,29 @@
|
|||||||
|
#ifndef SERIES_H
|
||||||
|
#define SERIES_H
|
||||||
|
|
||||||
|
#include <model/model_global.h>
|
||||||
|
|
||||||
|
#pragma db object
|
||||||
|
class MODEL_EXPORT Series_S
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
Series_S() = default;
|
||||||
|
|
||||||
|
quint64 id() const { return m_id; }
|
||||||
|
void setId(const quint64& newId) { m_id = newId; }
|
||||||
|
|
||||||
|
QString name() const { return m_serName; }
|
||||||
|
void setName(const QString& newSerName) { m_serName = newSerName; }
|
||||||
|
|
||||||
|
private:
|
||||||
|
friend class odb::access;
|
||||||
|
|
||||||
|
private:
|
||||||
|
public:
|
||||||
|
#pragma db id auto
|
||||||
|
quint64 m_id;
|
||||||
|
|
||||||
|
QString m_serName;
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // SERIES_H
|
||||||
53
src/model/model.qbs
Normal file
53
src/model/model.qbs
Normal file
@@ -0,0 +1,53 @@
|
|||||||
|
/*!
|
||||||
|
\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: [redkit_gen.module.JsonSerializer,
|
||||||
|
redkit_gen.module.SettingsSerializer,]
|
||||||
|
|
||||||
|
odb.gen.databases: "sqlite"
|
||||||
|
cpp.cxxLanguageVersion: "c++17"
|
||||||
|
|
||||||
|
Group {
|
||||||
|
id: headers
|
||||||
|
name: "headers"
|
||||||
|
files: [
|
||||||
|
"model_global.h",
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|
||||||
|
Group {
|
||||||
|
id: odbs
|
||||||
|
name: "odb"
|
||||||
|
files: [
|
||||||
|
"**/*.h",
|
||||||
|
]
|
||||||
|
excludeFiles: headers.files
|
||||||
|
fileTags: ["hpp", "odbxx", "rgen"]
|
||||||
|
}
|
||||||
|
|
||||||
|
cpp.dynamicLibraries: [
|
||||||
|
"odb-sqlite",
|
||||||
|
"odb-qt",
|
||||||
|
"odb",
|
||||||
|
"sqlite3"
|
||||||
|
]
|
||||||
|
}
|
||||||
15
src/model/model_global.h
Normal file
15
src/model/model_global.h
Normal file
@@ -0,0 +1,15 @@
|
|||||||
|
#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
|
||||||
|
|
||||||
|
#include <odb/core.hxx>
|
||||||
|
#include <rcore/smarttypes.h>
|
||||||
|
|
||||||
|
#endif // MODEL_GLOBAL_H
|
||||||
23
src/model/settings/settings.h
Normal file
23
src/model/settings/settings.h
Normal file
@@ -0,0 +1,23 @@
|
|||||||
|
#ifndef SETTINGS_S_H
|
||||||
|
#define SETTINGS_S_H
|
||||||
|
|
||||||
|
#include <model/model_global.h>
|
||||||
|
|
||||||
|
#pragma db object
|
||||||
|
class MODEL_EXPORT Settings_S
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
Settings_S() = default;
|
||||||
|
|
||||||
|
quint64 id() const { return m_id; }
|
||||||
|
void setId(const quint64& newId) { m_id = newId; }
|
||||||
|
|
||||||
|
private:
|
||||||
|
friend class odb::access;
|
||||||
|
|
||||||
|
private:
|
||||||
|
#pragma db id auto
|
||||||
|
quint64 m_id;
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // SETTINGS_S_H
|
||||||
81
src/repository/authorrepository.cpp
Normal file
81
src/repository/authorrepository.cpp
Normal file
@@ -0,0 +1,81 @@
|
|||||||
|
#include "authorrepository.h"
|
||||||
|
|
||||||
|
#include <model/books/author_book_s-odb.hxx>
|
||||||
|
#include <model/books/author_book_s.h>
|
||||||
|
#include <model/books/author_s-odb.hxx>
|
||||||
|
#include <model/books/author_s.h>
|
||||||
|
#include <model/books/book_s-odb.hxx>
|
||||||
|
#include <model/books/book_s.h>
|
||||||
|
|
||||||
|
#include <odb/core.hxx>
|
||||||
|
#include <odb/database.hxx>
|
||||||
|
#include <odb/query.hxx>
|
||||||
|
|
||||||
|
namespace repository
|
||||||
|
{
|
||||||
|
|
||||||
|
AuthorRepository::AuthorRepository(odb::core::database& db) :
|
||||||
|
m_db(db)
|
||||||
|
{}
|
||||||
|
|
||||||
|
QVector<Author_S> AuthorRepository::findAll()
|
||||||
|
{
|
||||||
|
odb::transaction t(m_db.begin());
|
||||||
|
odb::result<Author_S> res(m_db.query<Author_S>());
|
||||||
|
|
||||||
|
QVector<Author_S> authors;
|
||||||
|
|
||||||
|
for (auto it = res.begin(); it != res.end(); ++it)
|
||||||
|
{
|
||||||
|
const auto& author = *it;
|
||||||
|
authors.push_back(author);
|
||||||
|
}
|
||||||
|
|
||||||
|
t.commit();
|
||||||
|
|
||||||
|
return authors;
|
||||||
|
}
|
||||||
|
|
||||||
|
Author_S AuthorRepository::findById(int id)
|
||||||
|
{
|
||||||
|
odb::transaction t(m_db.begin());
|
||||||
|
odb::result<Author_S> res(m_db.query<Author_S>(odb::query<Author_S>::id == id));
|
||||||
|
|
||||||
|
Author_S author;
|
||||||
|
res.value(author);
|
||||||
|
|
||||||
|
t.commit();
|
||||||
|
|
||||||
|
return author;
|
||||||
|
}
|
||||||
|
|
||||||
|
QVector<Author_S> AuthorRepository::findByBook(const int& bookId)
|
||||||
|
{
|
||||||
|
odb::transaction t(m_db.begin());
|
||||||
|
|
||||||
|
QVector<Author_S> authors;
|
||||||
|
|
||||||
|
using ABQuery = odb::query<AuthorBook_S>;
|
||||||
|
using ABResult = odb::result<AuthorBook_S>;
|
||||||
|
ABResult abResult(m_db.query<AuthorBook_S>(ABQuery::book == bookId));
|
||||||
|
|
||||||
|
for (const AuthorBook_S& ab : abResult)
|
||||||
|
{
|
||||||
|
// Загружаем каждую книгу по ID
|
||||||
|
SH<Author_S> author(m_db.load<Author_S>(ab.author()->id()));
|
||||||
|
authors.push_back(*author.data());
|
||||||
|
}
|
||||||
|
t.commit();
|
||||||
|
|
||||||
|
return authors;
|
||||||
|
}
|
||||||
|
|
||||||
|
QVector<Author_S> AuthorRepository::findByBook(const QString& book_name)
|
||||||
|
{
|
||||||
|
odb::transaction t(m_db.begin());
|
||||||
|
auto book_s = m_db.query<Book_S>(odb::query<Book_S>::title == book_name).one();
|
||||||
|
|
||||||
|
return findByBook(book_s->id());
|
||||||
|
}
|
||||||
|
|
||||||
|
} // namespace repository
|
||||||
41
src/repository/authorrepository.h
Normal file
41
src/repository/authorrepository.h
Normal file
@@ -0,0 +1,41 @@
|
|||||||
|
#ifndef AUTHORREPOSITORY_H
|
||||||
|
#define AUTHORREPOSITORY_H
|
||||||
|
|
||||||
|
#include "repository_global.h"
|
||||||
|
|
||||||
|
#include <model/books/author_s.h>
|
||||||
|
|
||||||
|
#include <QString>
|
||||||
|
#include <QVector>
|
||||||
|
|
||||||
|
namespace repository
|
||||||
|
{
|
||||||
|
|
||||||
|
class REPOSITORY_EXPORT AuthorRepository
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
AuthorRepository(odb::core::database& db);
|
||||||
|
|
||||||
|
// Получить всех авторов
|
||||||
|
QVector<Author_S> findAll();
|
||||||
|
|
||||||
|
// Найти автора по id
|
||||||
|
Author_S findById(int id);
|
||||||
|
|
||||||
|
// Сохранить книгу (создать или обновить)
|
||||||
|
// void save(const Book_S& book);
|
||||||
|
|
||||||
|
// Удалить автора
|
||||||
|
// void remove(int id);
|
||||||
|
|
||||||
|
// Найти авторов по книге
|
||||||
|
QVector<Author_S> findByBook(const int& book_id);
|
||||||
|
QVector<Author_S> findByBook(const QString& bookName);
|
||||||
|
|
||||||
|
private:
|
||||||
|
odb::core::database& m_db;
|
||||||
|
};
|
||||||
|
|
||||||
|
} // namespace repository
|
||||||
|
|
||||||
|
#endif // AUTHORREPOSITORY_H
|
||||||
96
src/repository/bookrepository.cpp
Normal file
96
src/repository/bookrepository.cpp
Normal file
@@ -0,0 +1,96 @@
|
|||||||
|
#include "bookrepository.h"
|
||||||
|
|
||||||
|
#include <QDebug>
|
||||||
|
|
||||||
|
#include <model/books/author_book_s-odb.hxx>
|
||||||
|
#include <model/books/author_book_s.h>
|
||||||
|
#include <model/books/author_s-odb.hxx>
|
||||||
|
#include <model/books/author_s.h>
|
||||||
|
#include <model/books/book_s-odb.hxx>
|
||||||
|
#include <model/books/book_s.h>
|
||||||
|
|
||||||
|
#include <odb/core.hxx>
|
||||||
|
#include <odb/database.hxx>
|
||||||
|
#include <odb/query.hxx>
|
||||||
|
|
||||||
|
namespace repository
|
||||||
|
{
|
||||||
|
|
||||||
|
BookRepository::BookRepository(odb::core::database& db) :
|
||||||
|
m_db(db)
|
||||||
|
{}
|
||||||
|
|
||||||
|
QVector<Book_S> BookRepository::findAll()
|
||||||
|
{
|
||||||
|
odb::transaction t(m_db.begin());
|
||||||
|
odb::result<Book_S> res(m_db.query<Book_S>());
|
||||||
|
|
||||||
|
QVector<Book_S> books;
|
||||||
|
|
||||||
|
for (auto it = res.begin(); it != res.end(); ++it)
|
||||||
|
{
|
||||||
|
const auto& book = *it;
|
||||||
|
books.push_back(book);
|
||||||
|
}
|
||||||
|
|
||||||
|
t.commit();
|
||||||
|
|
||||||
|
return books;
|
||||||
|
}
|
||||||
|
|
||||||
|
Book_S BookRepository::findById(int id)
|
||||||
|
{
|
||||||
|
odb::transaction t(m_db.begin());
|
||||||
|
odb::result<Book_S> res(m_db.query<Book_S>(odb::query<Book_S>::id == id));
|
||||||
|
|
||||||
|
Book_S book;
|
||||||
|
res.value(book);
|
||||||
|
|
||||||
|
t.commit();
|
||||||
|
|
||||||
|
return book;
|
||||||
|
}
|
||||||
|
|
||||||
|
// void BookRepository::save(const Book_S& book)
|
||||||
|
// {
|
||||||
|
// }
|
||||||
|
|
||||||
|
void BookRepository::remove(int id)
|
||||||
|
{
|
||||||
|
odb::transaction t(m_db.begin());
|
||||||
|
odb::result<Book_S> res(m_db.query<Book_S>(odb::query<Book_S>::id == id));
|
||||||
|
res.one().reset();
|
||||||
|
t.commit();
|
||||||
|
}
|
||||||
|
|
||||||
|
QVector<Book_S> BookRepository::findByAuthor(const int& authorId)
|
||||||
|
{
|
||||||
|
odb::transaction t(m_db.begin());
|
||||||
|
|
||||||
|
QVector<Book_S> books;
|
||||||
|
|
||||||
|
using ABQuery = odb::query<AuthorBook_S>;
|
||||||
|
using ABResult = odb::result<AuthorBook_S>;
|
||||||
|
ABResult abResult(m_db.query<AuthorBook_S>(ABQuery::author == authorId));
|
||||||
|
|
||||||
|
for (const AuthorBook_S& ab : abResult)
|
||||||
|
{
|
||||||
|
// Загружаем каждую книгу по ID
|
||||||
|
SH<Book_S> book(m_db.load<Book_S>(ab.book()->id()));
|
||||||
|
books.push_back(*book.data());
|
||||||
|
}
|
||||||
|
|
||||||
|
t.commit();
|
||||||
|
|
||||||
|
return books;
|
||||||
|
}
|
||||||
|
|
||||||
|
QVector<Book_S> BookRepository::findByAuthor(const QString& author)
|
||||||
|
{
|
||||||
|
odb::transaction t(m_db.begin());
|
||||||
|
auto author_s = m_db.query<Author_S>(odb::query<Author_S>::fullName == author).one();
|
||||||
|
|
||||||
|
return findByAuthor(author_s->id());
|
||||||
|
}
|
||||||
|
|
||||||
|
} // namespace repository
|
||||||
41
src/repository/bookrepository.h
Normal file
41
src/repository/bookrepository.h
Normal file
@@ -0,0 +1,41 @@
|
|||||||
|
#ifndef BOOKREPOSITORY_H
|
||||||
|
#define BOOKREPOSITORY_H
|
||||||
|
|
||||||
|
#include "repository_global.h"
|
||||||
|
|
||||||
|
#include <model/books/book_s.h>
|
||||||
|
|
||||||
|
#include <QString>
|
||||||
|
#include <QVector>
|
||||||
|
|
||||||
|
namespace repository
|
||||||
|
{
|
||||||
|
|
||||||
|
class REPOSITORY_EXPORT BookRepository
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
BookRepository(odb::core::database& db);
|
||||||
|
|
||||||
|
// Получить все книги
|
||||||
|
QVector<Book_S> findAll();
|
||||||
|
|
||||||
|
// Найти книгу по ID
|
||||||
|
Book_S findById(int id);
|
||||||
|
|
||||||
|
// Сохранить книгу (создать или обновить)
|
||||||
|
// void save(const Book_S& book);
|
||||||
|
|
||||||
|
// Удалить книгу
|
||||||
|
void remove(int id);
|
||||||
|
|
||||||
|
// Найти книги по автору
|
||||||
|
QVector<Book_S> findByAuthor(const QString& authorName);
|
||||||
|
QVector<Book_S> findByAuthor(const int& authorId);
|
||||||
|
|
||||||
|
private:
|
||||||
|
odb::core::database& m_db;
|
||||||
|
};
|
||||||
|
|
||||||
|
} // namespace repository
|
||||||
|
|
||||||
|
#endif // BOOKREPOSITORY_H
|
||||||
33
src/repository/repository.qbs
Normal file
33
src/repository/repository.qbs
Normal file
@@ -0,0 +1,33 @@
|
|||||||
|
/*!
|
||||||
|
\qmltype cpp-opds
|
||||||
|
\inherits Project
|
||||||
|
\brief Описание
|
||||||
|
*/
|
||||||
|
PSLibrary {
|
||||||
|
name: "repository"
|
||||||
|
cpp.defines: [
|
||||||
|
"REPOSITORY_LIBRARY"
|
||||||
|
]
|
||||||
|
|
||||||
|
Depends { name: "Qt"; submodules: [ "core" ] }
|
||||||
|
Depends { name: "model" }
|
||||||
|
|
||||||
|
Depends { name: "rdbase" }
|
||||||
|
Depends { name: "odb.gen" }
|
||||||
|
Depends { name: "database" }
|
||||||
|
|
||||||
|
Group {
|
||||||
|
name: "cpp"
|
||||||
|
files: [
|
||||||
|
"**/*.h",
|
||||||
|
"**/*.cpp",
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|
||||||
|
cpp.dynamicLibraries: [
|
||||||
|
"odb-sqlite",
|
||||||
|
"odb-qt",
|
||||||
|
"odb",
|
||||||
|
"sqlite3"
|
||||||
|
]
|
||||||
|
}
|
||||||
12
src/repository/repository_global.h
Normal file
12
src/repository/repository_global.h
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
#ifndef REPOSITORY_GLOBAL_H
|
||||||
|
#define REPOSITORY_GLOBAL_H
|
||||||
|
|
||||||
|
#include <QtCore/qglobal.h>
|
||||||
|
|
||||||
|
#if defined(REPOSITORY_LIBRARY)
|
||||||
|
#define REPOSITORY_EXPORT Q_DECL_EXPORT
|
||||||
|
#else
|
||||||
|
#define REPOSITORY_EXPORT Q_DECL_IMPORT
|
||||||
|
#endif
|
||||||
|
|
||||||
|
#endif // REPOSITORY_GLOBAL_H
|
||||||
@@ -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,11 @@ 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" }
|
||||||
|
Depends { name: "repository" }
|
||||||
|
|
||||||
cpp.cxxLanguageVersion: "c++20"
|
cpp.cxxLanguageVersion: "c++20"
|
||||||
|
|
||||||
@@ -28,4 +29,12 @@ PSLibrary {
|
|||||||
"restapiserver.*",
|
"restapiserver.*",
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|
||||||
|
cpp.dynamicLibraries: [
|
||||||
|
"odb-sqlite",
|
||||||
|
"odb-qt",
|
||||||
|
"odb",
|
||||||
|
"sqlite3"
|
||||||
|
]
|
||||||
|
|
||||||
} // Project
|
} // Project
|
||||||
|
|||||||
@@ -5,14 +5,20 @@
|
|||||||
#include <QJsonObject>
|
#include <QJsonObject>
|
||||||
#include <QJsonValue>
|
#include <QJsonValue>
|
||||||
|
|
||||||
#include <database/book_s.h>
|
#include <model/books/author_s-odb.hxx> // Должен быть здесь
|
||||||
|
#include <model/books/author_s.h>
|
||||||
|
#include <model/books/book_s-odb.hxx> // Должен быть здесь
|
||||||
|
#include <model/books/book_s.h>
|
||||||
|
|
||||||
#include "database/book_s-odb.hxx"
|
#include <repository/authorrepository.h>
|
||||||
|
#include <repository/bookrepository.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 +30,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 +42,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,76 +62,119 @@ 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/"))
|
||||||
{
|
{
|
||||||
|
repository::BookRepository b(m_db);
|
||||||
|
|
||||||
QString author = request.section(' ', 1, 1).section('/', 3, 3).replace("%20", " ");
|
QString author = request.section(' ', 1, 1).section('/', 3, 3).replace("%20", " ");
|
||||||
|
qWarning() << author;
|
||||||
// Books books;
|
auto books = b.findByAuthor(author);
|
||||||
// QList<BookRecord> results = books.getBooksByAuthor(author);
|
|
||||||
|
|
||||||
QByteArray jsonResponse = "{ \"books\": [";
|
|
||||||
// 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;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (request.startsWith("GET /books"))
|
|
||||||
{
|
|
||||||
odb::transaction t(m_db.begin());
|
|
||||||
odb::result<Book_S> res(m_db.query<Book_S>());
|
|
||||||
|
|
||||||
QJsonArray jArray;
|
QJsonArray jArray;
|
||||||
|
for (const auto& book : books)
|
||||||
for (auto it = res.begin(); it != res.end(); ++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.title();
|
||||||
j["author"] = QString::fromStdString(book.author()->full_name());
|
|
||||||
j["year"] = book.year();
|
|
||||||
jArray.push_back(j);
|
jArray.push_back(j);
|
||||||
}
|
}
|
||||||
auto jDoc = QJsonDocument(jArray);
|
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/id"))
|
||||||
|
{
|
||||||
|
repository::BookRepository b(m_db);
|
||||||
|
|
||||||
|
QString book_id = request.section(' ', 1, 1).section('/', 3, 3).replace("%20", " ");
|
||||||
|
qWarning() << book_id;
|
||||||
|
|
||||||
|
auto book = b.findById(book_id.toInt());
|
||||||
|
|
||||||
|
QJsonObject j;
|
||||||
|
j["id"] = QString::number(book.id());
|
||||||
|
QJsonArray authors;
|
||||||
|
|
||||||
|
repository::AuthorRepository a(m_db);
|
||||||
|
|
||||||
|
for (const auto& author : a.findByBook(book.id()))
|
||||||
|
{
|
||||||
|
QJsonObject jj;
|
||||||
|
jj["id"] = QString::number(author.id());
|
||||||
|
jj["fullName"] = author.fullName();
|
||||||
|
authors.push_back(jj);
|
||||||
|
}
|
||||||
|
|
||||||
|
j["authors"] = authors;
|
||||||
|
j["title"] = book.title();
|
||||||
|
|
||||||
|
auto jDoc = QJsonDocument(j);
|
||||||
|
|
||||||
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);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (request.startsWith("GET /author"))
|
if (request.startsWith("GET /books"))
|
||||||
{
|
{
|
||||||
odb::transaction t(m_db.begin());
|
repository::BookRepository b(m_db);
|
||||||
odb::result<Author_S> res(m_db.query<Author_S>());
|
|
||||||
|
|
||||||
QJsonArray jArray;
|
QJsonArray jArray;
|
||||||
|
for (const auto& book : b.findAll())
|
||||||
|
{
|
||||||
|
QJsonObject j;
|
||||||
|
j["id"] = QString::number(book.id());
|
||||||
|
j["title"] = book.title();
|
||||||
|
|
||||||
|
QJsonArray authors;
|
||||||
|
repository::AuthorRepository a(m_db);
|
||||||
|
for (const auto& author : a.findByBook(book.id()))
|
||||||
|
{
|
||||||
|
QJsonObject jj;
|
||||||
|
jj["id"] = QString::number(author.id());
|
||||||
|
jj["fullName"] = author.fullName();
|
||||||
|
authors.push_back(jj);
|
||||||
|
}
|
||||||
|
j["authors"] = authors;
|
||||||
|
|
||||||
|
jArray.push_back(j);
|
||||||
|
}
|
||||||
|
auto jDoc = QJsonDocument(jArray);
|
||||||
|
|
||||||
|
return "HTTP/1.1 200 OK\r\nContent-Type: application/json\r\n\r\n" + jDoc.toJson(QJsonDocument::Indented);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (request.startsWith("GET /authors"))
|
||||||
|
{
|
||||||
|
repository::AuthorRepository a(m_db);
|
||||||
|
auto res = a.findAll();
|
||||||
|
|
||||||
|
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["fullName"] = author.fullName();
|
||||||
j["last"] = QString::fromStdString(author.last());
|
|
||||||
j["age"] = author.age();
|
QJsonArray books;
|
||||||
|
repository::BookRepository b(m_db);
|
||||||
|
for (const auto& book : b.findByAuthor(author.id()))
|
||||||
|
{
|
||||||
|
QJsonObject jj;
|
||||||
|
jj["id"] = QString::number(book.id());
|
||||||
|
jj["title"] = book.title();
|
||||||
|
books.push_back(jj);
|
||||||
|
}
|
||||||
|
j["books"] = books;
|
||||||
|
|
||||||
jArray.push_back(j);
|
jArray.push_back(j);
|
||||||
}
|
}
|
||||||
auto jDoc = QJsonDocument(jArray);
|
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 200 OK\r\nContent-Type: application/json\r\n\r\n" + jDoc.toJson(QJsonDocument::Indented);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
101
src/utils/fb2extractor.cpp
Normal file
101
src/utils/fb2extractor.cpp
Normal file
@@ -0,0 +1,101 @@
|
|||||||
|
#include "fb2extractor.h"
|
||||||
|
|
||||||
|
// FB2Extractor::FB2Extractor()
|
||||||
|
// {
|
||||||
|
// }
|
||||||
|
|
||||||
|
FB2Extractor::FB2Extractor(QuaZipFile& file) :
|
||||||
|
m_file(&file)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
FB2Extractor::~FB2Extractor()
|
||||||
|
{
|
||||||
|
m_file.close();
|
||||||
|
}
|
||||||
|
|
||||||
|
Fb2Metadata FB2Extractor::parse()
|
||||||
|
{
|
||||||
|
bool isOpen = m_file.open(QIODevice::ReadOnly);
|
||||||
|
// int zipError = fb2File.getZipError();
|
||||||
|
if (!isOpen)
|
||||||
|
{
|
||||||
|
qWarning() << "file in extractor is not open";
|
||||||
|
return {};
|
||||||
|
}
|
||||||
|
|
||||||
|
QXmlStreamReader xmlData(&m_file);
|
||||||
|
|
||||||
|
Fb2Metadata meta;
|
||||||
|
QString currentElement;
|
||||||
|
bool inTitleInfo = false;
|
||||||
|
bool inAuthor = false;
|
||||||
|
QString currentAuthor;
|
||||||
|
|
||||||
|
while (!xmlData.atEnd())
|
||||||
|
{
|
||||||
|
switch (xmlData.readNext())
|
||||||
|
{
|
||||||
|
case QXmlStreamReader::StartElement:
|
||||||
|
currentElement = xmlData.name().toString();
|
||||||
|
|
||||||
|
if (currentElement == "title-info")
|
||||||
|
{
|
||||||
|
inTitleInfo = true;
|
||||||
|
}
|
||||||
|
else if (inTitleInfo)
|
||||||
|
{
|
||||||
|
if (currentElement == "book-title")
|
||||||
|
{
|
||||||
|
meta.title = xmlData.readElementText();
|
||||||
|
}
|
||||||
|
else if (currentElement == "genre")
|
||||||
|
{
|
||||||
|
meta.genres << xmlData.readElementText();
|
||||||
|
}
|
||||||
|
else if (currentElement == "author")
|
||||||
|
{
|
||||||
|
inAuthor = true;
|
||||||
|
currentAuthor.clear();
|
||||||
|
}
|
||||||
|
else if (inAuthor && (currentElement == "first-name" || currentElement == "last-name" || currentElement == "middle-name"))
|
||||||
|
{
|
||||||
|
currentAuthor += xmlData.readElementText() + " ";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
|
||||||
|
case QXmlStreamReader::EndElement:
|
||||||
|
if (xmlData.name().toString() == "title-info")
|
||||||
|
{
|
||||||
|
inTitleInfo = false;
|
||||||
|
}
|
||||||
|
else if (xmlData.name().toString() == "author" && inAuthor)
|
||||||
|
{
|
||||||
|
meta.authors << currentAuthor.trimmed();
|
||||||
|
inAuthor = false;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
|
||||||
|
case QXmlStreamReader::Characters:
|
||||||
|
// Обработка текста уже делается в readElementText()
|
||||||
|
break;
|
||||||
|
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Прерываем парсинг, если нашли все метаданные
|
||||||
|
if (!meta.title.isEmpty() && !meta.authors.isEmpty() && !meta.genres.isEmpty())
|
||||||
|
{
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (xmlData.hasError())
|
||||||
|
{
|
||||||
|
qWarning() << "XML parsing error:" << xmlData.errorString();
|
||||||
|
}
|
||||||
|
|
||||||
|
return meta;
|
||||||
|
}
|
||||||
36
src/utils/fb2extractor.h
Normal file
36
src/utils/fb2extractor.h
Normal file
@@ -0,0 +1,36 @@
|
|||||||
|
#ifndef FB2EXTRACTOR_H
|
||||||
|
#define FB2EXTRACTOR_H
|
||||||
|
|
||||||
|
#include "utils_global.h"
|
||||||
|
|
||||||
|
#include <QDebug>
|
||||||
|
#include <QString>
|
||||||
|
#include <QXmlStreamReader>
|
||||||
|
|
||||||
|
#include <external_libs/quazip/quazip/quazipfile.h>
|
||||||
|
|
||||||
|
struct Fb2Metadata
|
||||||
|
{
|
||||||
|
QString title; // Название книги
|
||||||
|
QVector<QString> authors; // Авторы
|
||||||
|
QStringList genres; // Жанры
|
||||||
|
};
|
||||||
|
|
||||||
|
Fb2Metadata UTILS_EXPORT parseFb2Metadata(QXmlStreamReader& sr);
|
||||||
|
|
||||||
|
class UTILS_EXPORT FB2Extractor
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
FB2Extractor(QuaZipFile& file);
|
||||||
|
~FB2Extractor();
|
||||||
|
|
||||||
|
/*!
|
||||||
|
* \brief Распарсить инфу из содержимого
|
||||||
|
*/
|
||||||
|
Fb2Metadata parse();
|
||||||
|
|
||||||
|
private:
|
||||||
|
QuaZipFile m_file;
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // FB2EXTRACTOR_H
|
||||||
22
src/utils/utils.qbs
Normal file
22
src/utils/utils.qbs
Normal file
@@ -0,0 +1,22 @@
|
|||||||
|
/*!
|
||||||
|
\qmltype cpp-opds
|
||||||
|
\inherits Project
|
||||||
|
\brief Описание
|
||||||
|
*/
|
||||||
|
PSLibrary {
|
||||||
|
name: "utils"
|
||||||
|
cpp.defines: [
|
||||||
|
"UTILS_LIBRARY"
|
||||||
|
]
|
||||||
|
|
||||||
|
Depends { name: "Qt"; submodules: [ "core" ] }
|
||||||
|
Depends { name: "quazip" }
|
||||||
|
|
||||||
|
Group {
|
||||||
|
name: "cpp"
|
||||||
|
files: [
|
||||||
|
"**/*.h",
|
||||||
|
"**/*.cpp",
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
||||||
12
src/utils/utils_global.h
Normal file
12
src/utils/utils_global.h
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
#ifndef UTILS_GLOBAL_H
|
||||||
|
#define UTILS_GLOBAL_H
|
||||||
|
|
||||||
|
#include <QtCore/qglobal.h>
|
||||||
|
|
||||||
|
#if defined(UTILS_LIBRARY)
|
||||||
|
#define UTILS_EXPORT Q_DECL_EXPORT
|
||||||
|
#else
|
||||||
|
#define UTILS_EXPORT Q_DECL_IMPORT
|
||||||
|
#endif
|
||||||
|
|
||||||
|
#endif // UTILS_GLOBAL_H
|
||||||
142
src/utils/zipwrapper.cpp
Normal file
142
src/utils/zipwrapper.cpp
Normal file
@@ -0,0 +1,142 @@
|
|||||||
|
#include "zipwrapper.h"
|
||||||
|
|
||||||
|
#include "fb2extractor.h"
|
||||||
|
|
||||||
|
#include <external_libs/quazip/quazip/quazipfile.h>
|
||||||
|
|
||||||
|
namespace
|
||||||
|
{
|
||||||
|
Fb2Metadata parse(QuaZipFile& m_file)
|
||||||
|
{
|
||||||
|
bool isOpen = m_file.open(QIODevice::ReadOnly);
|
||||||
|
// int zipError = fb2File.getZipError();
|
||||||
|
if (!isOpen)
|
||||||
|
{
|
||||||
|
qWarning() << "file in extractor is not open";
|
||||||
|
return {};
|
||||||
|
}
|
||||||
|
|
||||||
|
QXmlStreamReader xmlData(&m_file);
|
||||||
|
|
||||||
|
Fb2Metadata meta;
|
||||||
|
QString currentElement;
|
||||||
|
bool inTitleInfo = false;
|
||||||
|
bool inAuthor = false;
|
||||||
|
QString currentAuthor;
|
||||||
|
|
||||||
|
while (!xmlData.atEnd())
|
||||||
|
{
|
||||||
|
switch (xmlData.readNext())
|
||||||
|
{
|
||||||
|
case QXmlStreamReader::StartElement:
|
||||||
|
currentElement = xmlData.name().toString();
|
||||||
|
|
||||||
|
if (currentElement == "title-info")
|
||||||
|
{
|
||||||
|
inTitleInfo = true;
|
||||||
|
}
|
||||||
|
else if (inTitleInfo)
|
||||||
|
{
|
||||||
|
if (currentElement == "book-title")
|
||||||
|
{
|
||||||
|
meta.title = xmlData.readElementText();
|
||||||
|
}
|
||||||
|
else if (currentElement == "genre")
|
||||||
|
{
|
||||||
|
meta.genres << xmlData.readElementText();
|
||||||
|
}
|
||||||
|
else if (currentElement == "author")
|
||||||
|
{
|
||||||
|
inAuthor = true;
|
||||||
|
currentAuthor.clear();
|
||||||
|
}
|
||||||
|
else if (inAuthor && (currentElement == "first-name" || currentElement == "last-name" || currentElement == "middle-name"))
|
||||||
|
{
|
||||||
|
currentAuthor += xmlData.readElementText() + " ";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
|
||||||
|
case QXmlStreamReader::EndElement:
|
||||||
|
if (xmlData.name().toString() == "title-info")
|
||||||
|
{
|
||||||
|
inTitleInfo = false;
|
||||||
|
}
|
||||||
|
else if (xmlData.name().toString() == "author" && inAuthor)
|
||||||
|
{
|
||||||
|
meta.authors << currentAuthor.trimmed();
|
||||||
|
inAuthor = false;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
|
||||||
|
case QXmlStreamReader::Characters:
|
||||||
|
// Обработка текста уже делается в readElementText()
|
||||||
|
break;
|
||||||
|
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Прерываем парсинг, если нашли все метаданные
|
||||||
|
if (!meta.title.isEmpty() && !meta.authors.isEmpty() && !meta.genres.isEmpty())
|
||||||
|
{
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (xmlData.hasError())
|
||||||
|
{
|
||||||
|
qWarning() << "XML parsing error:" << xmlData.errorString();
|
||||||
|
}
|
||||||
|
|
||||||
|
return meta;
|
||||||
|
}
|
||||||
|
|
||||||
|
} // namespace
|
||||||
|
|
||||||
|
ZipWrapper::ZipWrapper(const QString& zipFilePath) :
|
||||||
|
m_zip(zipFilePath)
|
||||||
|
{
|
||||||
|
m_zip.open(QuaZip::mdUnzip);
|
||||||
|
isOpen();
|
||||||
|
}
|
||||||
|
|
||||||
|
ZipWrapper::~ZipWrapper()
|
||||||
|
{
|
||||||
|
// В любом случае закрываем архив
|
||||||
|
m_zip.close();
|
||||||
|
}
|
||||||
|
|
||||||
|
QVector<Fb2Metadata> ZipWrapper::work()
|
||||||
|
{
|
||||||
|
if (!isOpen())
|
||||||
|
return {};
|
||||||
|
|
||||||
|
// int i = 0;
|
||||||
|
QVector<Fb2Metadata> parsedBooks;
|
||||||
|
for (bool more = m_zip.goToFirstFile(); more; more = m_zip.goToNextFile())
|
||||||
|
{
|
||||||
|
// ++i;
|
||||||
|
if (m_zip.getCurrentFileName().endsWith(".fb2"))
|
||||||
|
{
|
||||||
|
QuaZipFile fb2File(&m_zip);
|
||||||
|
|
||||||
|
auto fb2Extr = parse(fb2File);
|
||||||
|
// qWarning() << i << ":" << fb2Extr.title << fb2Extr.authors << fb2Extr.genres;
|
||||||
|
parsedBooks.push_back(fb2Extr);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
qWarning() << "Неизвестный файл" << &m_zip;
|
||||||
|
}
|
||||||
|
|
||||||
|
return parsedBooks;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool ZipWrapper::isOpen()
|
||||||
|
{
|
||||||
|
if (m_zip.isOpen())
|
||||||
|
return true;
|
||||||
|
|
||||||
|
qWarning() << "Не удалось открыть архив:" << m_zip.getZipName();
|
||||||
|
return false;
|
||||||
|
}
|
||||||
29
src/utils/zipwrapper.h
Normal file
29
src/utils/zipwrapper.h
Normal file
@@ -0,0 +1,29 @@
|
|||||||
|
#ifndef ZIPWRAPPER_H
|
||||||
|
#define ZIPWRAPPER_H
|
||||||
|
|
||||||
|
#include "utils_global.h"
|
||||||
|
|
||||||
|
#include <QDebug>
|
||||||
|
#include <QString>
|
||||||
|
#include <QXmlStreamReader>
|
||||||
|
|
||||||
|
#include <external_libs/quazip/quazip/quazip.h>
|
||||||
|
#include <external_libs/quazip/quazip/quazipfile.h> // TODO для совместимости. Временно
|
||||||
|
|
||||||
|
#include "fb2extractor.h"
|
||||||
|
|
||||||
|
class UTILS_EXPORT ZipWrapper
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
ZipWrapper(const QString& zipFilePath);
|
||||||
|
~ZipWrapper();
|
||||||
|
|
||||||
|
QVector<Fb2Metadata> work();
|
||||||
|
|
||||||
|
private:
|
||||||
|
bool isOpen();
|
||||||
|
|
||||||
|
QuaZip m_zip;
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // ZIPWRAPPER_H
|
||||||
Reference in New Issue
Block a user