aboutsummaryrefslogtreecommitdiff
path: root/src/trace_processor/sqlite/span_join_operator_table_unittest.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/trace_processor/sqlite/span_join_operator_table_unittest.cc')
-rw-r--r--src/trace_processor/sqlite/span_join_operator_table_unittest.cc86
1 files changed, 0 insertions, 86 deletions
diff --git a/src/trace_processor/sqlite/span_join_operator_table_unittest.cc b/src/trace_processor/sqlite/span_join_operator_table_unittest.cc
index 4c2839720..87bb6454d 100644
--- a/src/trace_processor/sqlite/span_join_operator_table_unittest.cc
+++ b/src/trace_processor/sqlite/span_join_operator_table_unittest.cc
@@ -254,92 +254,6 @@ TEST_F(SpanJoinOperatorTableTest, NoPartitioning) {
ASSERT_EQ(sqlite3_step(stmt_.get()), SQLITE_DONE);
}
-TEST_F(SpanJoinOperatorTableTest, LeftJoinTwoSpanTables) {
- RunStatement(
- "CREATE TEMP TABLE f("
- "ts BIG INT PRIMARY KEY, "
- "dur BIG INT, "
- "cpu UNSIGNED INT"
- ");");
- RunStatement(
- "CREATE TEMP TABLE s("
- "ts BIG INT PRIMARY KEY, "
- "dur BIG INT, "
- "tid UNSIGNED INT"
- ");");
- RunStatement("CREATE VIRTUAL TABLE sp USING span_left_join(f, s);");
-
- RunStatement("INSERT INTO f VALUES(100, 10, 0);");
- RunStatement("INSERT INTO f VALUES(110, 50, 1);");
-
- RunStatement("INSERT INTO s VALUES(100, 5, 1);");
- RunStatement("INSERT INTO s VALUES(110, 40, 2);");
- RunStatement("INSERT INTO s VALUES(150, 50, 3);");
-
- PrepareValidStatement("SELECT * FROM sp");
-
- ASSERT_EQ(sqlite3_step(stmt_.get()), SQLITE_ROW);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 0), 100);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 1), 5);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 2), 0);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 3), 1);
-
- ASSERT_EQ(sqlite3_step(stmt_.get()), SQLITE_ROW);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 0), 105);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 1), 5);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 2), 0);
- ASSERT_EQ(sqlite3_column_type(stmt_.get(), 3), SQLITE_NULL);
-
- ASSERT_EQ(sqlite3_step(stmt_.get()), SQLITE_ROW);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 0), 110);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 1), 40);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 2), 1);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 3), 2);
-
- ASSERT_EQ(sqlite3_step(stmt_.get()), SQLITE_ROW);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 0), 150);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 1), 10);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 2), 1);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 3), 3);
-
- ASSERT_EQ(sqlite3_step(stmt_.get()), SQLITE_DONE);
-}
-
-TEST_F(SpanJoinOperatorTableTest, LeftJoinTwoSpanTables_EmptyRight) {
- RunStatement(
- "CREATE TEMP TABLE f("
- "ts BIG INT PRIMARY KEY, "
- "dur BIG INT, "
- "cpu UNSIGNED INT"
- ");");
- RunStatement(
- "CREATE TEMP TABLE s("
- "ts BIG INT PRIMARY KEY, "
- "dur BIG INT, "
- "tid UNSIGNED INT"
- ");");
- RunStatement("CREATE VIRTUAL TABLE sp USING span_left_join(f, s);");
-
- RunStatement("INSERT INTO f VALUES(100, 10, 0);");
- RunStatement("INSERT INTO f VALUES(110, 50, 1);");
-
- PrepareValidStatement("SELECT * FROM sp");
-
- ASSERT_EQ(sqlite3_step(stmt_.get()), SQLITE_ROW);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 0), 100);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 1), 10);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 2), 0);
- ASSERT_EQ(sqlite3_column_type(stmt_.get(), 3), SQLITE_NULL);
-
- ASSERT_EQ(sqlite3_step(stmt_.get()), SQLITE_ROW);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 0), 110);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 1), 50);
- ASSERT_EQ(sqlite3_column_int64(stmt_.get(), 2), 1);
- ASSERT_EQ(sqlite3_column_type(stmt_.get(), 3), SQLITE_NULL);
-
- ASSERT_EQ(sqlite3_step(stmt_.get()), SQLITE_DONE);
-}
-
} // namespace
} // namespace trace_processor
} // namespace perfetto