mirror/oatpp-postgresql
2
0
Fork 0
mirror of https://github.com/oatpp/oatpp-postgresql.git synced 2025-02-17 12:09:32 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add support for char type

Browse Source
This commit is contained in:
Dmitrii Burnaev 2022-07-18 16:10:15 +03:00
parent e131a87610
commit fc5d30c99f
6 changed files with 292 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/oatpp-postgresql/mapping/Deserializer.cpp
View File

@ -156,6 +156,8 @@ oatpp::Void Deserializer::deserializeString(const Deserializer* _this, const InD
switch(data.oid) {
case TEXTOID:
case CHAROID:
case BPCHAROID:
case VARCHAROID: return oatpp::String(data.data, data.size);
}

4
test/CMakeLists.txt
View File

@ -22,6 +22,8 @@ add_executable(module-tests
oatpp-postgresql/types/InterpretationTest.hpp
oatpp-postgresql/types/IntTest.cpp
oatpp-postgresql/types/IntTest.hpp
oatpp-postgresql/types/CharacterTest.cpp
oatpp-postgresql/types/CharacterTest.hpp
oatpp-postgresql/tests.cpp
)
@ -49,4 +51,4 @@ target_link_libraries(module-tests
## TODO link dependencies here (if some)
add_test(module-tests module-tests)
add_test(module-tests module-tests)

18
test/oatpp-postgresql/migration/CharacterTest.sql Normal file
View File

@ -0,0 +1,18 @@
DROP TABLE IF EXISTS test_characters;
CREATE TABLE test_characters (
f_char "char",
f_bpchar char,
f_bpchar4 char(4),
f_varchar varchar(4),
f_text text
);
INSERT INTO test_characters
(f_char, f_bpchar, f_bpchar4, f_varchar, f_text) VALUES (null, null, null, null, null);
INSERT INTO test_characters
(f_char, f_bpchar, f_bpchar4, f_varchar, f_text) VALUES ('#', '$', '%', '^', '&');
INSERT INTO test_characters
(f_char, f_bpchar, f_bpchar4, f_varchar, f_text) VALUES ('a', 'b', 'cccc', 'dddd', 'eeeee');

2
test/oatpp-postgresql/tests.cpp
View File

@ -5,6 +5,7 @@
#include "types/IntTest.hpp"
#include "types/FloatTest.hpp"
#include "types/InterpretationTest.hpp"
#include "types/CharacterTest.hpp"
#include "oatpp-postgresql/orm.hpp"
@ -40,6 +41,7 @@ void runTests() {
OATPP_RUN_TEST(oatpp::test::postgresql::types::FloatTest);
OATPP_RUN_TEST(oatpp::test::postgresql::types::ArrayTest);
OATPP_RUN_TEST(oatpp::test::postgresql::types::InterpretationTest);
OATPP_RUN_TEST(oatpp::test::postgresql::types::CharacterTest);
}

227
test/oatpp-postgresql/types/CharacterTest.cpp Normal file
View File

@ -0,0 +1,227 @@
/***************************************************************************
*
* Project _____ __ ____ _ _
* ( _ ) /__\ (_ _)_| |_ _| |_
* )(_)( /(__)\ )( (_ _)(_ _)
* (_____)(__)(__)(__) |_| |_|
*
*
* Copyright 2018-present, Leonid Stryzhevskyi <lganzzzo@gmail.com>
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
***************************************************************************/
#include "CharacterTest.hpp"
#include "oatpp-postgresql/orm.hpp"
#include "oatpp/parser/json/mapping/ObjectMapper.hpp"
#include <limits>
#include <cstdio>
namespace oatpp { namespace test { namespace postgresql { namespace types {
namespace {
#include OATPP_CODEGEN_BEGIN(DTO)
class Row : public oatpp::DTO {
DTO_INIT(Row, DTO);
DTO_FIELD(String, f_char);
DTO_FIELD(String, f_bpchar);
DTO_FIELD(String, f_bpchar4);
DTO_FIELD(String, f_varchar);
DTO_FIELD(String, f_text);
};
#include OATPP_CODEGEN_END(DTO)
#include OATPP_CODEGEN_BEGIN(DbClient)
class MyClient : public oatpp::orm::DbClient {
public:
MyClient(const std::shared_ptr<oatpp::orm::Executor>& executor)
: oatpp::orm::DbClient(executor)
{
executeQuery("DROP TABLE IF EXISTS oatpp_schema_version_CharacterTest;", {});
oatpp::orm::SchemaMigration migration(executor, "CharacterTest");
migration.addFile(1, TEST_DB_MIGRATION "CharacterTest.sql");
migration.migrate();
auto version = executor->getSchemaVersion("CharacterTest");
OATPP_LOGD("DbClient", "Migration - OK. Version=%d.", version);
}
QUERY(insertValues,
"INSERT INTO test_characters "
"(f_char, f_bpchar, f_bpchar4, f_varchar, f_text) "
"VALUES "
"(:row.f_char, :row.f_bpchar, :row.f_bpchar4, :row.f_varchar, :row.f_text);",
PARAM(oatpp::Object<Row>, row), PREPARE(true))
QUERY(deleteValues,
"DELETE FROM test_characters;")
QUERY(selectValues, "SELECT * FROM test_characters;")
};
#include OATPP_CODEGEN_END(DbClient)
}
void CharacterTest::onRun() {
OATPP_LOGI(TAG, "DB-URL='%s'", TEST_DB_URL);
auto connectionProvider = std::make_shared<oatpp::postgresql::ConnectionProvider>(TEST_DB_URL);
auto executor = std::make_shared<oatpp::postgresql::Executor>(connectionProvider);
auto client = MyClient(executor);
{
auto res = client.selectValues();
if(res->isSuccess()) {
OATPP_LOGD(TAG, "OK, knownCount=%d, hasMore=%d", res->getKnownCount(), res->hasMoreToFetch());
} else {
auto message = res->getErrorMessage();
OATPP_LOGD(TAG, "Error, message=%s", message->c_str());
}
auto dataset = res->fetch<oatpp::Vector<oatpp::Object<Row>>>();
oatpp::parser::json::mapping::ObjectMapper om;
om.getSerializer()->getConfig()->useBeautifier = true;
om.getSerializer()->getConfig()->enabledInterpretations = {"postgresql"};
auto str = om.writeToString(dataset);
OATPP_LOGD(TAG, "res=%s", str->c_str());
OATPP_ASSERT(dataset->size() == 3);
{
auto row = dataset[0];
OATPP_ASSERT(row->f_char == nullptr);
OATPP_ASSERT(row->f_bpchar == nullptr);
OATPP_ASSERT(row->f_bpchar4 == nullptr);
OATPP_ASSERT(row->f_varchar == nullptr);
OATPP_ASSERT(row->f_text == nullptr);
}
{
auto row = dataset[1];
OATPP_ASSERT(row->f_char == "#");
OATPP_ASSERT(row->f_bpchar == "$");
OATPP_ASSERT(row->f_bpchar4 == "% ");
OATPP_ASSERT(row->f_varchar == "^");
OATPP_ASSERT(row->f_text == "&");
}
{
auto row = dataset[2];
OATPP_ASSERT(row->f_char == "a");
OATPP_ASSERT(row->f_bpchar == "b");
OATPP_ASSERT(row->f_bpchar4 == "cccc");
OATPP_ASSERT(row->f_varchar == "dddd");
OATPP_ASSERT(row->f_text == "eeeee");
}
}
{
auto res = client.deleteValues();
if (res->isSuccess()) {
OATPP_LOGD(TAG, "OK, knownCount=%d, hasMore=%d", res->getKnownCount(), res->hasMoreToFetch());
} else {
auto message = res->getErrorMessage();
OATPP_LOGD(TAG, "Error, message=%s", message->c_str());
}
OATPP_ASSERT(res->isSuccess());
}
{
auto connection = client.getConnection();
{
auto row = Row::createShared();
row->f_char = nullptr;
row->f_bpchar = nullptr;
row->f_bpchar4= nullptr;
row->f_varchar = nullptr;
row->f_text = nullptr;
client.insertValues(row, connection);
}
{
auto row = Row::createShared();
row->f_char = "a";
row->f_bpchar = "b";
row->f_bpchar4= "ccc";
row->f_varchar = "dddd";
row->f_text = "eeeee";
client.insertValues(row, connection);
}
}
{
auto res = client.selectValues();
if(res->isSuccess()) {
OATPP_LOGD(TAG, "OK, knownCount=%d, hasMore=%d", res->getKnownCount(), res->hasMoreToFetch());
} else {
auto message = res->getErrorMessage();
OATPP_LOGD(TAG, "Error, message=%s", message->c_str());
}
auto dataset = res->fetch<oatpp::Vector<oatpp::Object<Row>>>();
oatpp::parser::json::mapping::ObjectMapper om;
om.getSerializer()->getConfig()->useBeautifier = true;
om.getSerializer()->getConfig()->enabledInterpretations = {"postgresql"};
auto str = om.writeToString(dataset);
OATPP_LOGD(TAG, "res=%s", str->c_str());
OATPP_ASSERT(dataset->size() == 2);
{
auto row = dataset[0];
OATPP_ASSERT(row->f_char == nullptr);
OATPP_ASSERT(row->f_bpchar == nullptr);
OATPP_ASSERT(row->f_bpchar4 == nullptr);
OATPP_ASSERT(row->f_varchar == nullptr);
OATPP_ASSERT(row->f_text == nullptr);
}
{
auto row = dataset[1];
OATPP_ASSERT(row->f_char == "a");
OATPP_ASSERT(row->f_bpchar == "b");
OATPP_ASSERT(row->f_bpchar4 == "ccc ");
OATPP_ASSERT(row->f_varchar == "dddd");
OATPP_ASSERT(row->f_text == "eeeee");
}
}
}
}}}}

40
test/oatpp-postgresql/types/CharacterTest.hpp Normal file
View File

@ -0,0 +1,40 @@
/***************************************************************************
*
* Project _____ __ ____ _ _
* ( _ ) /__\ (_ _)_| |_ _| |_
* )(_)( /(__)\ )( (_ _)(_ _)
* (_____)(__)(__)(__) |_| |_|
*
*
* Copyright 2018-present, Leonid Stryzhevskyi <lganzzzo@gmail.com>
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
***************************************************************************/
#ifndef oatpp_test_postgresql_types_CharacterTest_hpp
#define oatpp_test_postgresql_types_CharacterTest_hpp
#include "oatpp-test/UnitTest.hpp"
namespace oatpp { namespace test { namespace postgresql { namespace types {
class CharacterTest : public UnitTest {
public:
CharacterTest() : UnitTest("TEST[postgresql::types::CharacterTest]") {}
void onRun() override;
};
}}}}
#endif // oatpp_test_postgresql_types_CharacterTest_hpp