From 2afa3cbaa3672be53ebb6852941c0c87d71db915 Mon Sep 17 00:00:00 2001
From: Azat Khuzhin <a3at.mail@gmail.com>
Date: Thu, 16 Apr 2020 20:23:12 +0300
Subject: [PATCH] Add a test for Buffer flushing (direct, background min/max
 time)

---
 .../0_stateless/01246_buffer_flush.reference  | 10 +++++
 .../0_stateless/01246_buffer_flush.sql        | 44 +++++++++++++++++++
 2 files changed, 54 insertions(+)
 create mode 100644 tests/queries/0_stateless/01246_buffer_flush.reference
 create mode 100644 tests/queries/0_stateless/01246_buffer_flush.sql

diff --git a/tests/queries/0_stateless/01246_buffer_flush.reference b/tests/queries/0_stateless/01246_buffer_flush.reference
new file mode 100644
index 00000000000..a877e94b919
--- /dev/null
+++ b/tests/queries/0_stateless/01246_buffer_flush.reference
@@ -0,0 +1,10 @@
+min
+0
+5
+max
+5
+10
+direct
+20
+drop
+30
diff --git a/tests/queries/0_stateless/01246_buffer_flush.sql b/tests/queries/0_stateless/01246_buffer_flush.sql
new file mode 100644
index 00000000000..efe0adf703a
--- /dev/null
+++ b/tests/queries/0_stateless/01246_buffer_flush.sql
@@ -0,0 +1,44 @@
+drop table if exists data_01256;
+drop table if exists buffer_01256;
+
+create table data_01256 as system.numbers Engine=Memory();
+
+select 'min';
+create table buffer_01256 as system.numbers Engine=Buffer(currentDatabase(), data_01256, 1,
+    2, 100, /* time */
+    4, 100, /* rows */
+    1, 1e6  /* bytes */
+);
+insert into buffer_01256 select * from system.numbers limit 5;
+select count() from data_01256;
+-- sleep 2 (min time) + 1 (round up) + bias (1) = 4
+select sleepEachRow(2) from numbers(2) FORMAT Null;
+select count() from data_01256;
+drop table buffer_01256;
+
+select 'max';
+create table buffer_01256 as system.numbers Engine=Buffer(currentDatabase(), data_01256, 1,
+    100, 2,   /* time */
+    0,   100, /* rows */
+    0,   1e6  /* bytes */
+);
+insert into buffer_01256 select * from system.numbers limit 5;
+select count() from data_01256;
+-- sleep 2 (min time) + 1 (round up) + bias (1) = 4
+select sleepEachRow(2) from numbers(2) FORMAT Null;
+select count() from data_01256;
+drop table buffer_01256;
+
+select 'direct';
+create table buffer_01256 as system.numbers Engine=Buffer(currentDatabase(), data_01256, 1,
+    100, 100, /* time */
+    0,   9,   /* rows */
+    0,   1e6  /* bytes */
+);
+insert into buffer_01256 select * from system.numbers limit 10;
+select count() from data_01256;
+
+select 'drop';
+insert into buffer_01256 select * from system.numbers limit 10;
+drop table if exists buffer_01256;
+select count() from data_01256;