10
10
//
11
11
// ===----------------------------------------------------------------------===//
12
12
13
-
14
13
#include " common/harness.h"
15
14
16
15
#include " catalog/schema.h"
@@ -27,12 +26,15 @@ class TupleSchemaTests : public PelotonTests {};
27
26
TEST_F (TupleSchemaTests, ColumnInfoTest) {
28
27
std::vector<catalog::Column> columns;
29
28
30
- catalog::Column column1 (type::TypeId::INTEGER, type::Type::GetTypeSize (type::TypeId::INTEGER),
31
- " A" , true );
32
- catalog::Column column2 (type::TypeId::INTEGER, type::Type::GetTypeSize (type::TypeId::INTEGER),
33
- " B" , true );
34
- catalog::Column column3 (type::TypeId::TINYINT, type::Type::GetTypeSize (type::TypeId::TINYINT),
35
- " C" , true );
29
+ catalog::Column column1 (type::TypeId::INTEGER,
30
+ type::Type::GetTypeSize (type::TypeId::INTEGER), " A" ,
31
+ true );
32
+ catalog::Column column2 (type::TypeId::INTEGER,
33
+ type::Type::GetTypeSize (type::TypeId::INTEGER), " B" ,
34
+ true );
35
+ catalog::Column column3 (type::TypeId::TINYINT,
36
+ type::Type::GetTypeSize (type::TypeId::TINYINT), " C" ,
37
+ true );
36
38
37
39
columns.push_back (column1);
38
40
columns.push_back (column2);
@@ -48,12 +50,15 @@ TEST_F(TupleSchemaTests, ColumnInfoTest) {
48
50
TEST_F (TupleSchemaTests, TupleSchemaFilteringTest) {
49
51
std::vector<catalog::Column> columns;
50
52
51
- catalog::Column column1 (type::TypeId::INTEGER, type::Type::GetTypeSize (type::TypeId::INTEGER),
52
- " A" , true );
53
- catalog::Column column2 (type::TypeId::INTEGER, type::Type::GetTypeSize (type::TypeId::INTEGER),
54
- " B" , true );
55
- catalog::Column column3 (type::TypeId::TINYINT, type::Type::GetTypeSize (type::TypeId::TINYINT),
56
- " C" , true );
53
+ catalog::Column column1 (type::TypeId::INTEGER,
54
+ type::Type::GetTypeSize (type::TypeId::INTEGER), " A" ,
55
+ true );
56
+ catalog::Column column2 (type::TypeId::INTEGER,
57
+ type::Type::GetTypeSize (type::TypeId::INTEGER), " B" ,
58
+ true );
59
+ catalog::Column column3 (type::TypeId::TINYINT,
60
+ type::Type::GetTypeSize (type::TypeId::TINYINT), " C" ,
61
+ true );
57
62
catalog::Column column4 (type::TypeId::VARCHAR, 24 , " D" , false );
58
63
59
64
columns.push_back (column1);
@@ -70,39 +75,42 @@ TEST_F(TupleSchemaTests, TupleSchemaFilteringTest) {
70
75
// /////////////////////////////////////////////////////////////////
71
76
// Tests basic filterng
72
77
// /////////////////////////////////////////////////////////////////
73
-
78
+
74
79
std::vector<oid_t > subset{0 , 2 };
75
- std::unique_ptr<catalog::Schema> schema3_p (catalog::Schema::FilterSchema (&schema2, subset));
80
+ std::unique_ptr<catalog::Schema> schema3_p (
81
+ catalog::Schema::FilterSchema (&schema2, subset));
76
82
LOG_INFO (" %s" , schema3_p->GetInfo ().c_str ());
77
83
78
84
EXPECT_NE (schema1, (*schema3_p));
79
-
85
+
80
86
// /////////////////////////////////////////////////////////////////
81
87
// Tests out of order filtering (should not affected by order)
82
88
// /////////////////////////////////////////////////////////////////
83
-
89
+
84
90
subset = {2 , 0 };
85
- std::unique_ptr<catalog::Schema> schema4_p (catalog::Schema::FilterSchema (&schema2, subset));
91
+ std::unique_ptr<catalog::Schema> schema4_p (
92
+ catalog::Schema::FilterSchema (&schema2, subset));
86
93
LOG_INFO (" %s" , schema4_p->GetInfo ().c_str ());
87
94
88
95
EXPECT_EQ ((*schema4_p), (*schema3_p));
89
-
96
+
90
97
// /////////////////////////////////////////////////////////////////
91
98
// Tests duplicated indices & out of bound indices
92
99
// /////////////////////////////////////////////////////////////////
93
-
100
+
94
101
subset = {666 , 0 , 0 , 0 , 0 , 0 , 0 , 2 , 0 , 2 , 0 , 2 , 100 , 101 };
95
-
96
- std::unique_ptr<catalog::Schema> schema5_p (catalog::Schema::FilterSchema (&schema2, subset));
102
+
103
+ std::unique_ptr<catalog::Schema> schema5_p (
104
+ catalog::Schema::FilterSchema (&schema2, subset));
97
105
LOG_INFO (" %s" , schema5_p->GetInfo ().c_str ());
98
106
99
107
EXPECT_EQ (schema5_p->GetColumnCount (), 2 );
100
108
EXPECT_EQ ((*schema5_p), (*schema4_p));
101
-
109
+
102
110
// /////////////////////////////////////////////////////////////////
103
111
// All tests finished
104
112
// /////////////////////////////////////////////////////////////////./t
105
-
113
+
106
114
return ;
107
115
}
108
116
@@ -112,12 +120,15 @@ TEST_F(TupleSchemaTests, TupleSchemaFilteringTest) {
112
120
TEST_F (TupleSchemaTests, TupleSchemaCopyTest) {
113
121
std::vector<catalog::Column> columns;
114
122
115
- catalog::Column column1 (type::TypeId::INTEGER, type::Type::GetTypeSize (type::TypeId::INTEGER),
116
- " A" , true );
117
- catalog::Column column2 (type::TypeId::INTEGER, type::Type::GetTypeSize (type::TypeId::INTEGER),
118
- " B" , true );
119
- catalog::Column column3 (type::TypeId::TINYINT, type::Type::GetTypeSize (type::TypeId::TINYINT),
120
- " C" , true );
123
+ catalog::Column column1 (type::TypeId::INTEGER,
124
+ type::Type::GetTypeSize (type::TypeId::INTEGER), " A" ,
125
+ true );
126
+ catalog::Column column2 (type::TypeId::INTEGER,
127
+ type::Type::GetTypeSize (type::TypeId::INTEGER), " B" ,
128
+ true );
129
+ catalog::Column column3 (type::TypeId::TINYINT,
130
+ type::Type::GetTypeSize (type::TypeId::TINYINT), " C" ,
131
+ true );
121
132
catalog::Column column4 (type::TypeId::VARCHAR, 24 , " D" , false );
122
133
123
134
columns.push_back (column1);
@@ -132,7 +143,8 @@ TEST_F(TupleSchemaTests, TupleSchemaCopyTest) {
132
143
// /////////////////////////////////////////////////////////////////
133
144
134
145
std::vector<oid_t > subset{0 , 2 };
135
- std::unique_ptr<catalog::Schema> schema3_p (catalog::Schema::CopySchema (&schema1, subset));
146
+ std::unique_ptr<catalog::Schema> schema3_p (
147
+ catalog::Schema::CopySchema (&schema1, subset));
136
148
LOG_INFO (" %s" , schema3_p->GetInfo ().c_str ());
137
149
138
150
EXPECT_NE (schema1, (*schema3_p));
@@ -142,7 +154,8 @@ TEST_F(TupleSchemaTests, TupleSchemaCopyTest) {
142
154
// /////////////////////////////////////////////////////////////////
143
155
144
156
subset = {2 , 0 };
145
- std::unique_ptr<catalog::Schema> schema4_p (catalog::Schema::CopySchema (&schema1, subset));
157
+ std::unique_ptr<catalog::Schema> schema4_p (
158
+ catalog::Schema::CopySchema (&schema1, subset));
146
159
LOG_INFO (" %s" , schema4_p->GetInfo ().c_str ());
147
160
148
161
EXPECT_NE ((*schema4_p), (*schema3_p));
@@ -153,7 +166,8 @@ TEST_F(TupleSchemaTests, TupleSchemaCopyTest) {
153
166
154
167
subset = {0 , 0 , 0 , 0 , 0 , 0 , 2 , 0 , 2 , 0 , 2 , 1 };
155
168
156
- std::unique_ptr<catalog::Schema> schema5_p (catalog::Schema::CopySchema (&schema1, subset));
169
+ std::unique_ptr<catalog::Schema> schema5_p (
170
+ catalog::Schema::CopySchema (&schema1, subset));
157
171
LOG_INFO (" %s" , schema5_p->GetInfo ().c_str ());
158
172
159
173
EXPECT_EQ (schema5_p->GetColumnCount (), subset.size ());
0 commit comments