From b02335183f0985db4c4f4dce8e92f9396791d1a5 Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Fri, 18 Oct 2024 19:17:11 +0800 Subject: [PATCH] test fetch 100000 rows --- e2e_test/source_legacy/tvf/postgres_query.slt | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/e2e_test/source_legacy/tvf/postgres_query.slt b/e2e_test/source_legacy/tvf/postgres_query.slt index 0ce577535b923..61c492f6b279b 100644 --- a/e2e_test/source_legacy/tvf/postgres_query.slt +++ b/e2e_test/source_legacy/tvf/postgres_query.slt @@ -38,3 +38,13 @@ select * from postgres_query('db', '5432', 'postgres', 'postgres', 'cdc_test', ' 98 t 1 1 1 1 1 1.0 2021-01-01 00:00:00 2021-01-01 00:00:00 2021-01-01 08:00:00+00:00 text varchar 1 day {} \x01 99 t 1 1 1 1 1 1.0 2021-01-01 00:00:00 2021-01-01 00:00:00 2021-01-01 08:00:00+00:00 text varchar 1 day {} \x01 100 t 1 1 1 1 1 1.0 2021-01-01 00:00:00 2021-01-01 00:00:00 2021-01-01 08:00:00+00:00 text varchar 1 day {} \x01 + +system ok +PGHOST=db PGPORT=5432 PGUSER=postgres PGPASSWORD=postgres PGDATABASE=cdc_test psql -c " +INSERT INTO test SELECT generate_series(101, 100000), true, 1, 1, 1, 1.0, 1.0, 1.0, '2021-01-01', '00:00:00', '2021-01-01 00:00:00', '2021-01-01 00:00:00 pst', 'text', 'varchar', '1 day', '{}', '\x01'; +" + +query I +select count(*) from postgres_query('db', '5432', 'postgres', 'postgres', 'cdc_test', 'select * from test;'); +---- +100000 \ No newline at end of file