boost/mysql
2
0
Fork 0
mirror of https://github.com/boostorg/mysql.git synced 2026-02-14 12:52:17 +00:00
Code Issues Projects Releases Wiki Activity

resultset tests

Browse Source
This commit is contained in:
Ruben Perez
2022-10-07 23:18:28 +02:00
parent ec197e133c
commit 6cdcaeeb15
3 changed files with 70 additions and 58 deletions
Download Patch File Download Diff File Expand all files Collapse all files

121
test/unit/resultset.cpp
View File

@@ -5,96 +5,107 @@
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
#include <boost/mysql/resultset_base.hpp>
#include <boost/mysql/tcp.hpp>
#include <boost/mysql/detail/protocol/channel.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/strand.hpp>
#include <boost/mysql/resultset.hpp>
#include <boost/test/unit_test.hpp>
#include "boost/mysql/detail/protocol/common_messages.hpp"
#include "boost/mysql/detail/protocol/constants.hpp"
#include "boost/mysql/detail/protocol/resultset_encoding.hpp"
#include "boost/mysql/field_type.hpp"
#include "create_resultset.hpp"
#include "test_channel.hpp"
#include "test_stream.hpp"
using resultset_t = boost::mysql::resultset_base<boost::mysql::test::test_stream>;
using chan_t = boost::mysql::detail::channel<boost::mysql::test::test_stream>;
using namespace boost::mysql::test;
using resultset_t = boost::mysql::resultset<boost::mysql::test::test_stream>;
using boost::mysql::field_type;
using boost::mysql::detail::ok_packet;
using boost::mysql::detail::resultset_encoding;
using boost::mysql::detail::protocol_field_type;
using boost::mysql::detail::column_definition_packet;
namespace
{
BOOST_AUTO_TEST_SUITE(test_resultset)
// default ctor
test_channel chan = create_channel();
BOOST_AUTO_TEST_CASE(default_ctor)
{
resultset_t r;
BOOST_TEST(!r.valid());
}
// move ctor
BOOST_AUTO_TEST_CASE(member_fns)
{
// Construction
resultset_t r;
test_channel chan = create_channel();
BOOST_TEST(!r.valid());
// Reset
r.reset(&chan, resultset_encoding::binary);
BOOST_TEST(r.valid());
BOOST_TEST(!r.complete());
BOOST_TEST(r.meta().size() == 0);
// Add meta
column_definition_packet pack {};
pack.type = protocol_field_type::var_string;
r.add_meta(pack);
pack.type = protocol_field_type::bit;
r.add_meta(pack);
BOOST_TEST(!r.complete());
BOOST_TEST(r.meta().size() == 2);
BOOST_TEST(r.meta()[0].type() == field_type::varchar);
BOOST_TEST(r.meta()[1].type() == field_type::bit);
// Complete the resultset
r.complete(ok_packet{});
BOOST_TEST(r.complete());
// Reset
r.reset(&chan, resultset_encoding::binary);
BOOST_TEST(r.valid());
BOOST_TEST(!r.complete());
BOOST_TEST(r.meta().size() == 0);
}
BOOST_AUTO_TEST_CASE(move_ctor_from_invalid)
{
resultset_t r1;
resultset_t r2 (std::move(r1));
BOOST_TEST(!r1.valid());
BOOST_TEST(!r2.valid());
}
BOOST_AUTO_TEST_CASE(move_ctor_from_valid)
{
chan_t chan;
resultset_t r1 (chan, {}, {});
auto r1 = create_resultset<resultset_t>(resultset_encoding::binary, { protocol_field_type::varchar });
resultset_t r2 (std::move(r1));
BOOST_TEST(!r1.valid());
BOOST_TEST(r2.valid());
BOOST_TEST(!r2.complete());
BOOST_TEST(r2.meta().size() == 1);
}
// move assignment
BOOST_AUTO_TEST_CASE(move_assign_invalid_to_invalid)
BOOST_AUTO_TEST_CASE(move_assign_from_invalid)
{
resultset_t r1;
resultset_t r2;
auto r2 = create_resultset<resultset_t>(resultset_encoding::text, { protocol_field_type::bit });
r2 = std::move(r1);
BOOST_TEST(!r1.valid());
BOOST_TEST(!r2.valid());
}
BOOST_AUTO_TEST_CASE(move_assign_invalid_to_valid)
BOOST_AUTO_TEST_CASE(move_assign_from_valid)
{
chan_t chan;
resultset_t r1;
resultset_t r2 (chan, {}, {});
auto r1 = create_resultset<resultset_t>(resultset_encoding::binary, { protocol_field_type::varchar });
auto r2 = create_resultset<resultset_t>(resultset_encoding::text, { protocol_field_type::bit });
r2 = std::move(r1);
BOOST_TEST(!r1.valid());
BOOST_TEST(!r2.valid());
}
BOOST_AUTO_TEST_CASE(move_assign_valid_to_invalid)
{
chan_t chan;
resultset_t r1 (chan, {}, {});
resultset_t r2;
r2 = std::move(r1);
BOOST_TEST(!r1.valid());
BOOST_TEST(r2.valid());
BOOST_TEST(!r2.complete());
BOOST_TEST(r2.meta().size() == 1);
}
BOOST_AUTO_TEST_CASE(move_assign_valid_to_valid)
{
chan_t chan;
resultset_t r1 (chan, {}, {});
resultset_t r2 (chan, {}, {});
r2 = std::move(r1);
BOOST_TEST(!r1.valid());
BOOST_TEST(r2.valid());
}
BOOST_AUTO_TEST_SUITE_END()
// rebind executor
BOOST_AUTO_TEST_CASE(rebind_executor)
{
using other_executor = boost::asio::strand<boost::asio::io_context::executor_type>;
using rebound_type = boost::mysql::tcp_resultset::rebind_executor<other_executor>::other;
using expected_type = boost::mysql::resultset_base<
boost::asio::basic_stream_socket<
boost::asio::ip::tcp,
other_executor
>
>;
BOOST_TEST((std::is_same<rebound_type, expected_type>::value));
}
BOOST_AUTO_TEST_SUITE_END() // test_resultset