Compare commits
1 Commits
00332b5b0e
...
multiLib
| Author | SHA1 | Date | |
|---|---|---|---|
| c34f3c2286 |
6
.gitmodules
vendored
Normal file
6
.gitmodules
vendored
Normal file
@@ -0,0 +1,6 @@
|
||||
[submodule "redkbuild"]
|
||||
path = redkbuild
|
||||
url = ssh://git@gitea.redkit-lab.work:57322/redkit-lab/redkbuild.git
|
||||
[submodule "redkitty"]
|
||||
path = redkitty
|
||||
url = git@gitea.redkit-lab.work:redkit-lab/redkitty.git
|
||||
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
|
||||
}
|
||||
17
project.qbs
17
project.qbs
@@ -3,17 +3,18 @@ import qbs
|
||||
Project {
|
||||
name: "opds++"
|
||||
qbsSearchPaths: [
|
||||
"qbs",
|
||||
// "redkitty/qbs",
|
||||
// // "guiness/qbs",
|
||||
// // "prerequisites/qbs",
|
||||
// // "report/qbs",
|
||||
// "redkbuild",
|
||||
// // "ext_libs/openssl/qbs",
|
||||
// "redkitty/lib/redkit-gen-integration/qbs",
|
||||
"redkitty/qbs",
|
||||
"redkbuild",
|
||||
"redkitty/lib/redkit-gen-integration/qbs",
|
||||
"prerequisites/qbs",
|
||||
]
|
||||
|
||||
references: [
|
||||
"redkitty/lib/rsc/libs_impl/rdbaseimpl/rdbaseimpl.qbs",
|
||||
"redkitty/lib/rcore/rcore.qbs",
|
||||
|
||||
"src/cpp-opds.qbs",
|
||||
"src/database/database.qbs",
|
||||
"src/restapi/restapi.qbs",
|
||||
]
|
||||
}
|
||||
|
||||
@@ -1,48 +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 + "/../"),
|
||||
input.filePath,
|
||||
]);
|
||||
cmd.description = "Generating ODB files for " + input.fileName;
|
||||
|
||||
console.error(cmd.arguments)
|
||||
|
||||
return [cmd];
|
||||
}
|
||||
}
|
||||
cpp.includePaths: [ project.sourceDirectory, product.Qt.core.qmDir ]
|
||||
}
|
||||
1
redkbuild
Submodule
1
redkbuild
Submodule
Submodule redkbuild added at 3adf92aad6
1
redkitty
Submodule
1
redkitty
Submodule
Submodule redkitty added at 2316ddea72
46
src/book_s.h
46
src/book_s.h
@@ -1,46 +0,0 @@
|
||||
// file : hello/person.hxx
|
||||
// copyright : not copyrighted - public domain
|
||||
|
||||
#ifndef BOOK_S_H
|
||||
#define BOOK_S_H
|
||||
|
||||
#include <memory>
|
||||
#include <string>
|
||||
|
||||
#include <odb/core.hxx>
|
||||
|
||||
#include "author_s.h"
|
||||
|
||||
#pragma db object
|
||||
class 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
|
||||
@@ -3,7 +3,7 @@
|
||||
\inherits Project
|
||||
\brief Описание
|
||||
*/
|
||||
Application {
|
||||
PSApplication {
|
||||
// CppApplication {
|
||||
cpp.defines: [
|
||||
// You can make your code fail to compile if it uses deprecated APIs.
|
||||
@@ -15,44 +15,28 @@ Application {
|
||||
|
||||
Depends { name: "Qt"; submodules: [ "core", "sql", "network" ] }
|
||||
Depends { name: "cpp" }
|
||||
Depends { name: "odbModule"}
|
||||
|
||||
// Depends { name: "redkit_gen" }
|
||||
Depends { name: "database" }
|
||||
Depends { name: "odb.gen" }
|
||||
Depends { name: "sqlite3" }
|
||||
Depends { name: "restapi" }
|
||||
Depends { name: "redkit_gen" }
|
||||
Depends { name: "rdbase" }
|
||||
|
||||
cpp.cxxLanguageVersion: "c++20"
|
||||
|
||||
Group {
|
||||
name: "cpp"
|
||||
files: [
|
||||
"books.*",
|
||||
"databasemanager.*",
|
||||
"main.cpp",
|
||||
"restapiserver.*",
|
||||
]
|
||||
}
|
||||
|
||||
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: [
|
||||
"odb-sqlite",
|
||||
"odb-qt",
|
||||
"odb",
|
||||
"odb-sqlite"
|
||||
"sqlite3"
|
||||
]
|
||||
|
||||
// }
|
||||
} // Project
|
||||
|
||||
@@ -4,47 +4,48 @@
|
||||
#ifndef AUTHOR_S_H
|
||||
#define AUTHOR_S_H
|
||||
|
||||
#include <cstddef> // std::size_t
|
||||
#include <memory>
|
||||
#include <string>
|
||||
#include "database_global.h"
|
||||
|
||||
#include <QString>
|
||||
|
||||
#include <odb/core.hxx>
|
||||
#include <odb/database.hxx>
|
||||
#include <odb/query.hxx>
|
||||
|
||||
#pragma db object
|
||||
class Author_S
|
||||
class DATABASE_EXPORT Author_S
|
||||
{
|
||||
public:
|
||||
Author_S() = default;
|
||||
|
||||
Author_S(const std::string& first,
|
||||
const std::string& last,
|
||||
Author_S(const QString& firstN,
|
||||
const QString& lastN,
|
||||
const unsigned short age) :
|
||||
m_first(first),
|
||||
m_last(last),
|
||||
m_firstName(firstN),
|
||||
m_lastName(lastN),
|
||||
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; }
|
||||
QString firstName() const { return m_firstName; }
|
||||
QString lastName() const { return m_lastName; }
|
||||
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; }
|
||||
|
||||
private:
|
||||
friend class odb::access;
|
||||
|
||||
private:
|
||||
#pragma db id auto
|
||||
unsigned long long m_id;
|
||||
quint64 m_id;
|
||||
|
||||
std::string m_first;
|
||||
std::string m_last;
|
||||
unsigned short m_age;
|
||||
QString m_firstName;
|
||||
QString m_lastName;
|
||||
quint8 m_age;
|
||||
};
|
||||
|
||||
#pragma db view object(Author_S)
|
||||
64
src/database/book_s.h
Normal file
64
src/database/book_s.h
Normal file
@@ -0,0 +1,64 @@
|
||||
// file : hello/person.hxx
|
||||
// copyright : not copyrighted - public domain
|
||||
|
||||
#ifndef BOOK_S_H
|
||||
#define BOOK_S_H
|
||||
|
||||
#include "database_global.h"
|
||||
|
||||
#include <QSharedPointer>
|
||||
#include <QString>
|
||||
#include <odb/core.hxx>
|
||||
#include <rcore/smarttypes.h>
|
||||
|
||||
#include "author_s.h"
|
||||
|
||||
#pragma db object
|
||||
class DATABASE_EXPORT Book_S
|
||||
{
|
||||
public:
|
||||
Book_S() = default;
|
||||
|
||||
Book_S(const QString& name,
|
||||
const SH<Author_S>& author,
|
||||
const int year)
|
||||
{
|
||||
m_author = author;
|
||||
m_name = name;
|
||||
m_year = year;
|
||||
};
|
||||
|
||||
unsigned long long id() const { return m_id; }
|
||||
SH<Author_S> author() const { return m_author; }
|
||||
QString name() const { return m_name; }
|
||||
int year() const { return m_year; }
|
||||
|
||||
private:
|
||||
friend class odb::access;
|
||||
|
||||
private:
|
||||
#pragma db id auto
|
||||
quint64 m_id;
|
||||
|
||||
SH<Author_S> m_author;
|
||||
QString m_name;
|
||||
quint8 m_year;
|
||||
};
|
||||
|
||||
// #pragma db view object(Book_S) object(Author_S = author:Book_S::m_author)
|
||||
// struct BookByAuthorView
|
||||
// {
|
||||
// #pragma db column(Book_S::m_id)
|
||||
// quint64 book_id;
|
||||
|
||||
// #pragma db column(Book_S::m_name)
|
||||
// QString book_name;
|
||||
|
||||
// #pragma db column(Book_S::m_year)
|
||||
// qint8 year;
|
||||
|
||||
// #pragma db column(Author_S::m_first + " " + Author_S::m_last)
|
||||
// QString author_full_name;
|
||||
// };
|
||||
|
||||
#endif // BOOK_S_H
|
||||
@@ -34,16 +34,20 @@
|
||||
|
||||
#include <filesystem>
|
||||
#include <random>
|
||||
#include <rcore/smarttypes.h>
|
||||
|
||||
using oDBase = odb::sqlite::database;
|
||||
using uDBase = U<oDBase>;
|
||||
|
||||
struct testData
|
||||
{
|
||||
std::string first;
|
||||
std::string last;
|
||||
QString first;
|
||||
QString last;
|
||||
int age;
|
||||
};
|
||||
|
||||
// Функция для генерации случайной строки (имени или фамилии)
|
||||
std::string generate_random_string(const std::vector<std::string>& pool)
|
||||
QString generate_random_string(const QVector<QString>& pool)
|
||||
{
|
||||
static std::random_device rd;
|
||||
static std::mt19937 gen(rd());
|
||||
@@ -60,16 +64,16 @@ int generate_random_year(int min_year = 1900, int max_year = 2020)
|
||||
return dis(gen);
|
||||
}
|
||||
|
||||
std::vector<testData> fillDB()
|
||||
QVector<testData> fillDB()
|
||||
{
|
||||
std::vector<std::string> first_names = {
|
||||
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"
|
||||
};
|
||||
std::vector<std::string> last_names = {
|
||||
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",
|
||||
@@ -77,12 +81,12 @@ std::vector<testData> fillDB()
|
||||
"Rogers", "Gutierrez", "Ramirez", "Diaz", "Perez", "Ross", "Sanders", "Price", "Howard", "Cooper"
|
||||
};
|
||||
|
||||
std::vector<testData> vecTest;
|
||||
QVector<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);
|
||||
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 });
|
||||
@@ -91,21 +95,23 @@ std::vector<testData> fillDB()
|
||||
return vecTest;
|
||||
}
|
||||
|
||||
inline std::unique_ptr<odb::database> openDB(std::string path_db)
|
||||
inline uDBase openDB(const std::string path_db)
|
||||
{
|
||||
// Открыть БД, если она существует
|
||||
auto db_ptr = new oDBase(path_db, SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE);
|
||||
|
||||
if (std::filesystem::is_regular_file(path_db))
|
||||
return 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");
|
||||
|
||||
odb::core::transaction tans(db->begin());
|
||||
odb::core::schema_catalog::create_schema(*db);
|
||||
odb::transaction tans(db->begin());
|
||||
odb::schema_catalog::create_schema(*db);
|
||||
tans.commit();
|
||||
|
||||
connect_ptr->execute("PRAGMA foreign_keys=ON");
|
||||
55
src/database/database.qbs
Normal file
55
src/database/database.qbs
Normal file
@@ -0,0 +1,55 @@
|
||||
/*!
|
||||
\qmltype cpp-opds
|
||||
\inherits Project
|
||||
\brief Описание
|
||||
*/
|
||||
PSLibrary {
|
||||
cpp.defines: [
|
||||
// You can make your code fail to compile if it uses deprecated APIs.
|
||||
// In order to do so, uncomment the following line.
|
||||
//"QT_DISABLE_DEPRECATED_BEFORE=0x060000" // disables all the APIs deprecated before Qt 6.0.0
|
||||
"DATABASE_SQLITE",
|
||||
"DATABASE_LIBRARY"
|
||||
]
|
||||
consoleApplication: true
|
||||
|
||||
Depends { name: "Qt"; submodules: [ "core", "sql", "network" ] }
|
||||
Depends { name: "cpp" }
|
||||
|
||||
Depends { name: "odb.gen" }
|
||||
Depends { name: "rdbase" }
|
||||
|
||||
Depends { name: "redkit_gen" }
|
||||
redkit_gen.includeModules: ["JsonSerializer"]
|
||||
|
||||
odb.gen.databases: "sqlite"
|
||||
cpp.cxxLanguageVersion: "c++17"
|
||||
|
||||
Group {
|
||||
name: "cpp"
|
||||
files: [
|
||||
"databasemanager.*",
|
||||
"*.cpp",
|
||||
"*.h",
|
||||
"*.hxx",
|
||||
]
|
||||
excludeFiles: odbs.files
|
||||
}
|
||||
|
||||
Group {
|
||||
id: odbs
|
||||
name: "odb"
|
||||
files: [
|
||||
"author_s.h",
|
||||
"book_s.h",
|
||||
]
|
||||
fileTags: ["hpp", "odbxx"]
|
||||
}
|
||||
|
||||
cpp.dynamicLibraries: [
|
||||
"odb-sqlite",
|
||||
"odb-qt",
|
||||
"odb",
|
||||
"sqlite3"
|
||||
]
|
||||
}
|
||||
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
|
||||
@@ -1,6 +1,8 @@
|
||||
#ifndef DATABASEMANAGER_H
|
||||
#define DATABASEMANAGER_H
|
||||
|
||||
#include "database_global.h"
|
||||
|
||||
#include <QDebug>
|
||||
#include <QtSql>
|
||||
|
||||
@@ -35,7 +37,7 @@ struct SelectBuilder
|
||||
}
|
||||
};
|
||||
|
||||
class DatabaseManager
|
||||
class DATABASE_EXPORT DatabaseManager
|
||||
{
|
||||
public:
|
||||
static DatabaseManager& instance(); // Singleton
|
||||
71
src/main.cpp
71
src/main.cpp
@@ -1,48 +1,50 @@
|
||||
#include <QCoreApplication>
|
||||
|
||||
#include "restapiserver.h"
|
||||
#include <QPointer>
|
||||
#include <QSharedPointer>
|
||||
#include <QString>
|
||||
#include <QVector>
|
||||
|
||||
#include <restapi/restapiserver.h>
|
||||
|
||||
/* Опыты с odb */
|
||||
#include "author_s-odb.hxx" // Должен быть здесь
|
||||
#include "author_s.h"
|
||||
|
||||
#include "book_s-odb.hxx" // Должен быть здесь
|
||||
#include "book_s.h"
|
||||
|
||||
#include <database/author_s-odb.hxx> // Должен быть здесь
|
||||
#include <database/author_s.h>
|
||||
#include <database/book_s-odb.hxx> // Должен быть здесь
|
||||
#include <database/book_s.h>
|
||||
#include <database/database.hxx> // create_database
|
||||
#include <odb/database.hxx>
|
||||
|
||||
#include "database.hxx" // create_database
|
||||
#include <iostream>
|
||||
|
||||
using unidb = std::unique_ptr<odb::database>;
|
||||
|
||||
void fillBooksBD(unidb& db)
|
||||
void fillBooksBD(uDBase& db)
|
||||
{
|
||||
try
|
||||
{
|
||||
std::vector<std::shared_ptr<Author_S>> authors = {
|
||||
std::make_shared<Author_S>("George", "Orwell", 142),
|
||||
std::make_shared<Author_S>("J.K.", "Rowling", 56),
|
||||
std::make_shared<Author_S>("J.R.R.", "Tolkien", 81),
|
||||
std::make_shared<Author_S>("Leo", "Tolstoy", 189),
|
||||
std::make_shared<Author_S>("Fyodor", "Dostoevsky", 174),
|
||||
std::make_shared<Author_S>("Mark", "Twain", 183),
|
||||
std::make_shared<Author_S>("Charles", "Dickens", 208),
|
||||
std::make_shared<Author_S>("Virginia", "Woolf", 134),
|
||||
std::make_shared<Author_S>("Ernest", "Hemingway", 122),
|
||||
std::make_shared<Author_S>("Gabriel", "García Márquez", 98),
|
||||
std::make_shared<Author_S>("Franz", "Kafka", 100),
|
||||
std::make_shared<Author_S>("Harper", "Lee", 64),
|
||||
std::make_shared<Author_S>("William", "Shakespeare", 459),
|
||||
std::make_shared<Author_S>("Oscar", "Wilde", 155),
|
||||
std::make_shared<Author_S>("Aldous", "Huxley", 123),
|
||||
std::make_shared<Author_S>("Jane", "Austen", 210),
|
||||
std::make_shared<Author_S>("John", "Steinbeck", 116),
|
||||
std::make_shared<Author_S>("Agatha", "Christie", 124),
|
||||
std::make_shared<Author_S>("Isaac", "Asimov", 105)
|
||||
QVector<SH<Author_S>> authors = {
|
||||
SH<Author_S>::create("George", "Orwell", 142),
|
||||
SH<Author_S>::create("J.K.", "Rowling", 56),
|
||||
SH<Author_S>::create("J.R.R.", "Tolkien", 81),
|
||||
SH<Author_S>::create("Leo", "Tolstoy", 189),
|
||||
SH<Author_S>::create("Fyodor", "Dostoevsky", 174),
|
||||
SH<Author_S>::create("Mark", "Twain", 183),
|
||||
SH<Author_S>::create("Charles", "Dickens", 208),
|
||||
SH<Author_S>::create("Virginia", "Woolf", 134),
|
||||
SH<Author_S>::create("Ernest", "Hemingway", 122),
|
||||
SH<Author_S>::create("Gabriel", "García Márquez", 98),
|
||||
SH<Author_S>::create("Franz", "Kafka", 100),
|
||||
SH<Author_S>::create("Harper", "Lee", 64),
|
||||
SH<Author_S>::create("William", "Shakespeare", 459),
|
||||
SH<Author_S>::create("Oscar", "Wilde", 155),
|
||||
SH<Author_S>::create("Aldous", "Huxley", 123),
|
||||
SH<Author_S>::create("Jane", "Austen", 210),
|
||||
SH<Author_S>::create("John", "Steinbeck", 116),
|
||||
SH<Author_S>::create("Agatha", "Christie", 124),
|
||||
SH<Author_S>::create("Isaac", "Asimov", 105)
|
||||
};
|
||||
|
||||
// Список книг
|
||||
std::vector<Book_S> books = {
|
||||
QVector<Book_S> books = {
|
||||
Book_S("1984", authors[0], 1949),
|
||||
Book_S("Harry Potter and the Philosopher's Stone", authors[1], 1997),
|
||||
Book_S("The Hobbit", authors[2], 1937),
|
||||
@@ -99,7 +101,7 @@ void fillBooksBD(unidb& db)
|
||||
{
|
||||
odb::core::transaction t(db->begin());
|
||||
for (auto& author : authors)
|
||||
db->persist(author.get()); // Используем get() для получения сырого указателя
|
||||
db->persist(author); // Используем get() для получения сырого указателя
|
||||
t.commit();
|
||||
}
|
||||
|
||||
@@ -124,8 +126,9 @@ int main(int argc, char* argv[])
|
||||
QCoreApplication a(argc, argv);
|
||||
|
||||
const std::string dbPath = "test_db.sqlite";
|
||||
std::unique_ptr<odb::database> db(openDB(dbPath));
|
||||
uDBase db(openDB(dbPath));
|
||||
|
||||
// TODO Как-то нужно выполнять лишь раз
|
||||
// fillBooksBD(db);
|
||||
|
||||
RestApiServer server(*db);
|
||||
|
||||
38
src/restapi/restapi.qbs
Normal file
38
src/restapi/restapi.qbs
Normal file
@@ -0,0 +1,38 @@
|
||||
/*!
|
||||
\qmltype cpp-opds
|
||||
\inherits Project
|
||||
\brief Описание
|
||||
*/
|
||||
WPSLibrary {
|
||||
cpp.defines: [
|
||||
// You can make your code fail to compile if it uses deprecated APIs.
|
||||
// In order to do so, uncomment the following line.
|
||||
//"QT_DISABLE_DEPRECATED_BEFORE=0x060000" // disables all the APIs deprecated before Qt 6.0.0
|
||||
"DATABASE_SQLITE"
|
||||
]
|
||||
consoleApplication: true
|
||||
|
||||
Depends { name: "Qt"; submodules: [ "core", "sql", "network" ] }
|
||||
Depends { name: "cpp" }
|
||||
Depends { name: "database" }
|
||||
Depends { name: "odb.gen" }
|
||||
Depends { name: "redkit_gen" }
|
||||
Depends { name: "rdbase" }
|
||||
|
||||
cpp.cxxLanguageVersion: "c++20"
|
||||
|
||||
Group {
|
||||
name: "cpp"
|
||||
files: [
|
||||
"restapiserver.*",
|
||||
]
|
||||
}
|
||||
|
||||
cpp.dynamicLibraries: [
|
||||
"odb-sqlite",
|
||||
"odb-qt",
|
||||
"odb",
|
||||
"sqlite3"
|
||||
]
|
||||
|
||||
} // Project
|
||||
@@ -5,15 +5,19 @@
|
||||
#include <QJsonObject>
|
||||
#include <QJsonValue>
|
||||
|
||||
#include "book_s-odb.hxx"
|
||||
#include "book_s.h"
|
||||
#include <database/author_s-odb.hxx> // Должен быть здесь
|
||||
#include <database/author_s.h>
|
||||
#include <database/book_s-odb.hxx> // Должен быть здесь
|
||||
#include <database/book_s.h>
|
||||
|
||||
#include <odb/core.hxx>
|
||||
#include <odb/database.hxx>
|
||||
#include <odb/query.hxx>
|
||||
|
||||
#include <redkit-gen-modules/json_serializer.h>
|
||||
|
||||
RestApiServer::RestApiServer(odb::database& db, QObject* parent) :
|
||||
m_db(db), QTcpServer(parent) {}
|
||||
QTcpServer(parent), m_db(db) {}
|
||||
|
||||
void RestApiServer::start(quint16 port)
|
||||
{
|
||||
@@ -23,7 +27,8 @@ void RestApiServer::start(quint16 port)
|
||||
}
|
||||
else
|
||||
{
|
||||
qDebug() << "REST API сервер запущен на порту:" << port;
|
||||
QString addrs = "http://127.0.0.1:" + QString::number(this->serverPort());
|
||||
qDebug() << "REST API сервер запущен по адресу:" << addrs;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -34,6 +39,8 @@ void RestApiServer::incomingConnection(qintptr socketDescriptor)
|
||||
|
||||
connect(socket, &QTcpSocket::readyRead, this, &RestApiServer::handleRequest);
|
||||
connect(socket, &QTcpSocket::disconnected, socket, &QTcpSocket::deleteLater);
|
||||
|
||||
qWarning() << "Есть входящее подключение" << socket->socketDescriptor();
|
||||
}
|
||||
|
||||
void RestApiServer::handleRequest()
|
||||
@@ -52,28 +59,41 @@ void RestApiServer::handleRequest()
|
||||
|
||||
QByteArray RestApiServer::processRequest(const QString& request)
|
||||
{
|
||||
qWarning() << request << "\n\n";
|
||||
|
||||
if (request.startsWith("GET /books/author/"))
|
||||
{
|
||||
QString author = request.section(' ', 1, 1).section('/', 3, 3).replace("%20", " ");
|
||||
quint64 ageReq = author.toInt();
|
||||
|
||||
// Books books;
|
||||
// QList<BookRecord> results = books.getBooksByAuthor(author);
|
||||
QStringList nameParts = author.split(' ');
|
||||
QString firstName = nameParts.size() > 0 ? nameParts[0] : "";
|
||||
QString lastName = nameParts.size() > 1 ? nameParts[1] : "";
|
||||
|
||||
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 += "] }";
|
||||
qWarning()
|
||||
<< "author:" << author << "\n"
|
||||
<< "firstName:" << firstName << "\n"
|
||||
<< "lastName:" << lastName << "\n";
|
||||
|
||||
return "HTTP/1.1 200 OK\r\nContent-Type: application/json\r\n\r\n" + jsonResponse;
|
||||
odb::transaction t(m_db.begin());
|
||||
|
||||
auto books = m_db.query<Book_S>(odb::query<Book_S>::author->id == ageReq);
|
||||
|
||||
QJsonArray jArray;
|
||||
for (const auto& book : books)
|
||||
{
|
||||
QJsonObject j;
|
||||
j["id"] = QString::number(book.id());
|
||||
j["name"] = book.name();
|
||||
j["author"] = book.author()->full_name();
|
||||
j["year"] = book.year();
|
||||
jArray.push_back(j);
|
||||
}
|
||||
auto jDoc = QJsonDocument(jArray);
|
||||
|
||||
t.commit();
|
||||
|
||||
return "HTTP/1.1 200 OK\r\nContent-Type: application/json\r\n\r\n" + jDoc.toJson(QJsonDocument::Indented);
|
||||
}
|
||||
|
||||
if (request.startsWith("GET /books"))
|
||||
@@ -89,8 +109,8 @@ QByteArray RestApiServer::processRequest(const QString& request)
|
||||
|
||||
QJsonObject j;
|
||||
j["id"] = QString::number(book.id());
|
||||
j["title"] = QString::fromStdString(book.name());
|
||||
j["author"] = QString::fromStdString(book.author()->full_name());
|
||||
j["title"] = book.name();
|
||||
j["author"] = book.author()->full_name();
|
||||
j["year"] = book.year();
|
||||
jArray.push_back(j);
|
||||
}
|
||||
@@ -114,8 +134,8 @@ QByteArray RestApiServer::processRequest(const QString& request)
|
||||
|
||||
QJsonObject j;
|
||||
j["id"] = QString::number(author.id());
|
||||
j["first"] = QString::fromStdString(author.first());
|
||||
j["last"] = QString::fromStdString(author.last());
|
||||
j["first"] = author.firstName();
|
||||
j["last"] = author.lastName();
|
||||
j["age"] = author.age();
|
||||
jArray.push_back(j);
|
||||
}
|
||||
@@ -3,10 +3,11 @@
|
||||
|
||||
#include <odb/database.hxx>
|
||||
|
||||
#include <QObject>
|
||||
#include <QTcpServer>
|
||||
#include <QTcpSocket>
|
||||
|
||||
class RestApiServer : public QTcpServer
|
||||
class Q_DECL_EXPORT RestApiServer : public QTcpServer
|
||||
{
|
||||
Q_OBJECT
|
||||
public:
|
||||
Reference in New Issue
Block a user