CREATE SCHEMA insert_select_into_local_table;
SET search_path TO insert_select_into_local_table;
SET citus.shard_count = 4;
SET citus.next_shard_id TO 11235800;
CREATE TABLE dist_table (a INT, b INT, c TEXT);
SELECT create_distributed_table('dist_table', 'a');
 create_distributed_table
---------------------------------------------------------------------

(1 row)

INSERT INTO dist_table VALUES (1, 6, 'txt1'), (2, 7, 'txt2'), (3, 8, 'txt3');
CREATE TABLE non_dist_1 (a INT, b INT, c TEXT);
CREATE TABLE non_dist_2 (a INT, c TEXT);
CREATE TABLE non_dist_3 (a INT);
-- test non-router queries
INSERT INTO non_dist_1 SELECT * FROM dist_table;
INSERT INTO non_dist_2 SELECT a, c FROM dist_table;
INSERT INTO non_dist_3 SELECT a FROM dist_table;
SELECT * FROM non_dist_1 ORDER BY 1, 2, 3;
 a | b |  c
---------------------------------------------------------------------
 1 | 6 | txt1
 2 | 7 | txt2
 3 | 8 | txt3
(3 rows)

SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | txt1
 2 | txt2
 3 | txt3
(3 rows)

SELECT * FROM non_dist_3 ORDER BY 1;
 a
---------------------------------------------------------------------
 1
 2
 3
(3 rows)

TRUNCATE non_dist_1, non_dist_2, non_dist_3;
-- test router queries
INSERT INTO non_dist_1 SELECT * FROM dist_table WHERE a = 1;
INSERT INTO non_dist_2 SELECT a, c FROM dist_table WHERE a = 1;
INSERT INTO non_dist_3 SELECT a FROM dist_table WHERE a = 1;
SELECT * FROM non_dist_1 ORDER BY 1, 2, 3;
 a | b |  c
---------------------------------------------------------------------
 1 | 6 | txt1
(1 row)

SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | txt1
(1 row)

SELECT * FROM non_dist_3 ORDER BY 1;
 a
---------------------------------------------------------------------
 1
(1 row)

TRUNCATE non_dist_1, non_dist_2, non_dist_3;
-- test columns in different order
INSERT INTO non_dist_1(b, a, c) SELECT a, b, c FROM dist_table;
SELECT * FROM non_dist_1 ORDER BY 1, 2, 3;
 a | b |  c
---------------------------------------------------------------------
 6 | 1 | txt1
 7 | 2 | txt2
 8 | 3 | txt3
(3 rows)

TRUNCATE non_dist_1;
-- test EXPLAIN
EXPLAIN (COSTS FALSE) INSERT INTO non_dist_1 SELECT * FROM dist_table;
                           QUERY PLAN
---------------------------------------------------------------------
 Insert on non_dist_1
   ->  Custom Scan (Citus Adaptive)
         Task Count: 4
         Tasks Shown: One of 4
         ->  Task
               Node: host=localhost port=xxxxx dbname=regression
               ->  Seq Scan on dist_table_11235800 dist_table
(7 rows)

EXPLAIN (COSTS FALSE) INSERT INTO non_dist_1 SELECT * FROM dist_table WHERE a = 1;
                           QUERY PLAN
---------------------------------------------------------------------
 Insert on non_dist_1
   ->  Custom Scan (Citus Adaptive)
         Task Count: 1
         Tasks Shown: All
         ->  Task
               Node: host=localhost port=xxxxx dbname=regression
               ->  Seq Scan on dist_table_11235800 dist_table
                     Filter: (a = 1)
(8 rows)

-- test RETURNING
INSERT INTO non_dist_1 SELECT * FROM dist_table ORDER BY 1, 2, 3 RETURNING *;
 a | b |  c
---------------------------------------------------------------------
 1 | 6 | txt1
 2 | 7 | txt2
 3 | 8 | txt3
(3 rows)

INSERT INTO non_dist_1 SELECT * FROM dist_table WHERE a = 1 ORDER BY 1, 2, 3 RETURNING *;
 a | b |  c
---------------------------------------------------------------------
 1 | 6 | txt1
(1 row)

-- test INSERT INTO a table with UNIQUE
CREATE TABLE non_dist_unique (a INT UNIQUE, b INT);
INSERT INTO non_dist_unique SELECT a, b FROM dist_table;
SELECT * FROM non_dist_unique ORDER BY 1;
 a | b
---------------------------------------------------------------------
 1 | 6
 2 | 7
 3 | 8
(3 rows)

INSERT INTO non_dist_unique SELECT a+1, b FROM dist_table ON CONFLICT (a) DO NOTHING;
SELECT * FROM non_dist_unique ORDER BY 1;
 a | b
---------------------------------------------------------------------
 1 | 6
 2 | 7
 3 | 8
 4 | 8
(4 rows)

INSERT INTO non_dist_unique SELECT a+2, b FROM dist_table ON CONFLICT (a) DO UPDATE SET b = EXCLUDED.b + non_dist_unique.b;
SELECT * FROM non_dist_unique ORDER BY 1;
 a | b
---------------------------------------------------------------------
 1 |  6
 2 |  7
 3 | 14
 4 | 15
 5 |  8
(5 rows)

INSERT INTO non_dist_unique
SELECT a+1, b FROM dist_table
UNION ALL
SELECT a+100, b FROM dist_table
ON CONFLICT (a) DO NOTHING;
SELECT * FROM non_dist_unique ORDER BY 1;
  a  | b
---------------------------------------------------------------------
   1 |  6
   2 |  7
   3 | 14
   4 | 15
   5 |  8
 101 |  6
 102 |  7
 103 |  8
(8 rows)

INSERT INTO non_dist_unique
SELECT a+1, b FROM dist_table
UNION ALL
SELECT a+100, b FROM dist_table
ON CONFLICT (a) DO UPDATE SET b = EXCLUDED.b + 1;
SELECT * FROM non_dist_unique ORDER BY 1;
  a  | b
---------------------------------------------------------------------
   1 | 6
   2 | 7
   3 | 8
   4 | 9
   5 | 8
 101 | 7
 102 | 8
 103 | 9
(8 rows)

WITH cte1 AS (SELECT s FROM generate_series(1,10) s)
INSERT INTO non_dist_unique
WITH cte2 AS (SELECT s FROM generate_series(1,10) s)
SELECT a+1, b FROM dist_table WHERE b IN (SELECT s FROM cte1)
UNION ALL
SELECT s, s FROM cte1
ON CONFLICT (a) DO NOTHING;
SELECT * FROM non_dist_unique ORDER BY 1;
  a  | b
---------------------------------------------------------------------
   1 |  6
   2 |  7
   3 |  8
   4 |  9
   5 |  8
   6 |  6
   7 |  7
   8 |  8
   9 |  9
  10 | 10
 101 |  7
 102 |  8
 103 |  9
(13 rows)

DROP TABLE non_dist_unique;
-- test INSERT INTO a table with DEFAULT
CREATE TABLE non_dist_default (a INT, c TEXT DEFAULT 'def');
INSERT INTO non_dist_default SELECT a FROM dist_table WHERE a = 1;
SELECT * FROM non_dist_default ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | def
(1 row)

INSERT INTO non_dist_default SELECT a FROM dist_table WHERE a > 1;
SELECT * FROM non_dist_default ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | def
 2 | def
 3 | def
(3 rows)

SELECT alter_table_set_access_method('non_dist_default', 'columnar');
NOTICE:  creating a new table for insert_select_into_local_table.non_dist_default
NOTICE:  moving the data of insert_select_into_local_table.non_dist_default
NOTICE:  dropping the old insert_select_into_local_table.non_dist_default
NOTICE:  renaming the new table to insert_select_into_local_table.non_dist_default
 alter_table_set_access_method
---------------------------------------------------------------------

(1 row)

INSERT INTO non_dist_default SELECT a, c FROM dist_table WHERE a = 1;
SELECT * FROM non_dist_default ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | def
 1 | txt1
 2 | def
 3 | def
(4 rows)

INSERT INTO non_dist_default SELECT a, c FROM dist_table WHERE a > 1;
SELECT * FROM non_dist_default ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | def
 1 | txt1
 2 | def
 2 | txt2
 3 | def
 3 | txt3
(6 rows)

DROP TABLE non_dist_default;
-- test CTEs
WITH with_table AS (SELECT a, c FROM dist_table ORDER BY a LIMIT 2) INSERT INTO non_dist_2 SELECT * FROM with_table;
SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | txt1
 2 | txt2
(2 rows)

INSERT INTO non_dist_2 WITH with_table AS (SELECT a, c FROM dist_table ORDER BY a LIMIT 2) SELECT * FROM with_table;
SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | txt1
 1 | txt1
 2 | txt2
 2 | txt2
(4 rows)

TRUNCATE non_dist_2;
WITH deleted_rows AS (DELETE FROM dist_table WHERE a < 3 RETURNING a, c) INSERT INTO non_dist_2 SELECT * FROM deleted_rows;
SELECT * FROM dist_table ORDER BY 1, 2, 3;
 a | b |  c
---------------------------------------------------------------------
 3 | 8 | txt3
(1 row)

SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | txt1
 2 | txt2
(2 rows)

TRUNCATE non_dist_2;
INSERT INTO dist_table VALUES (1, 6, 'txt1'), (2, 7, 'txt2');
WITH insert_table AS (INSERT INTO non_dist_2 SELECT a, c FROM dist_table RETURNING *) SELECT * FROM insert_table ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | txt1
 2 | txt2
 3 | txt3
(3 rows)

SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | txt1
 2 | txt2
 3 | txt3
(3 rows)

TRUNCATE non_dist_2;
-- test PREPARE
PREPARE insert_select_into_local AS INSERT INTO non_dist_2 SELECT a, c FROM dist_table WHERE a = 1;
EXECUTE insert_select_into_local;
EXECUTE insert_select_into_local;
EXECUTE insert_select_into_local;
EXECUTE insert_select_into_local;
EXECUTE insert_select_into_local;
SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | txt1
 1 | txt1
 1 | txt1
 1 | txt1
 1 | txt1
(5 rows)

EXECUTE insert_select_into_local;
SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | txt1
 1 | txt1
 1 | txt1
 1 | txt1
 1 | txt1
 1 | txt1
(6 rows)

TRUNCATE non_dist_2;
DEALLOCATE insert_select_into_local;
PREPARE insert_select_into_local(int) AS INSERT INTO non_dist_2 SELECT a, c FROM dist_table WHERE a = $1;
EXECUTE insert_select_into_local(2);
EXECUTE insert_select_into_local(2);
EXECUTE insert_select_into_local(2);
EXECUTE insert_select_into_local(2);
EXECUTE insert_select_into_local(2);
SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 2 | txt2
 2 | txt2
 2 | txt2
 2 | txt2
 2 | txt2
(5 rows)

EXECUTE insert_select_into_local(2);
SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 2 | txt2
 2 | txt2
 2 | txt2
 2 | txt2
 2 | txt2
 2 | txt2
(6 rows)

TRUNCATE non_dist_2;
DEALLOCATE insert_select_into_local;
PREPARE insert_select_into_local(int) AS INSERT INTO non_dist_2 SELECT a, c FROM dist_table WHERE b = $1;
EXECUTE insert_select_into_local(8);
EXECUTE insert_select_into_local(8);
EXECUTE insert_select_into_local(8);
EXECUTE insert_select_into_local(8);
EXECUTE insert_select_into_local(8);
SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 3 | txt3
 3 | txt3
 3 | txt3
 3 | txt3
 3 | txt3
(5 rows)

EXECUTE insert_select_into_local(8);
SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 3 | txt3
 3 | txt3
 3 | txt3
 3 | txt3
 3 | txt3
 3 | txt3
(6 rows)

TRUNCATE non_dist_2;
DEALLOCATE insert_select_into_local;
-- test reference table
CREATE TABLE ref_table (a INT, b INT, c TEXT);
SELECT create_reference_table('ref_table');
 create_reference_table
---------------------------------------------------------------------

(1 row)

INSERT INTO ref_table VALUES (1, 6, 'txt1'), (2, 7, 'txt2'), (3, 8, 'txt3');
INSERT INTO non_dist_2 SELECT a, c FROM ref_table;
SELECT * FROM non_dist_2 ORDER BY 1, 2;
 a |  c
---------------------------------------------------------------------
 1 | txt1
 2 | txt2
 3 | txt3
(3 rows)

TRUNCATE non_dist_2;
-- check issue https://github.com/citusdata/citus/issues/5858
CREATE TABLE local_dest_table(
  col_1 integer,
  col_2 integer,
  col_3 text,
  col_4 text,
  drop_col text,
  col_5 bigint,
  col_6 text,
  col_7 text default 'col_7',
  col_8 varchar
);
ALTER TABLE local_dest_table DROP COLUMN drop_col;
CREATE TABLE dist_source_table_1(
  int_col integer,
  drop_col text,
  text_col_1 text,
  dist_col integer,
  text_col_2 text
);
SELECT create_distributed_table('dist_source_table_1', 'dist_col');
 create_distributed_table
---------------------------------------------------------------------

(1 row)

ALTER TABLE dist_source_table_1 DROP COLUMN drop_col;
INSERT INTO dist_source_table_1 VALUES (1, 'value', 1, 'value');
INSERT INTO dist_source_table_1 VALUES (2, 'value2', 1, 'value');
INSERT INTO dist_source_table_1 VALUES (3, 'value', 3, 'value3');
CREATE TABLE dist_source_table_2(
  dist_col integer,
  int_col integer
);
SELECT create_distributed_table('dist_source_table_2', 'dist_col');
 create_distributed_table
---------------------------------------------------------------------

(1 row)

INSERT INTO dist_source_table_2 VALUES (1, 1);
INSERT INTO dist_source_table_2 VALUES (2, 2);
INSERT INTO dist_source_table_2 VALUES (4, 4);
CREATE TABLE local_source_table_1 AS SELECT * FROM dist_source_table_1;
CREATE TABLE local_source_table_2 AS SELECT * FROM dist_source_table_2;
/*
 * query_results_equal compares the effect of two queries on local_dest_table.
 * We use this to ensure that INSERT INTO local_dest_table SELECT behaves
 * the same when selecting from a regular table (postgres handles it) and
 * a distributed table (Citus handles it).
 *
 * The queries are generated by calling format() on query_table twice,
 * once for each source_table argument.
 */
CREATE OR REPLACE FUNCTION query_results_equal(query_template text, source_table_1 text, source_table_2 text)
RETURNS bool
AS $$
DECLARE
	l1 local_dest_table[];
	l2 local_dest_table[];
BEGIN
	/* get the results using source_table_1 as source */
    TRUNCATE local_dest_table;
	EXECUTE format(query_template, source_table_1);
	SELECT array_agg(l) INTO l1
	FROM (SELECT * FROM local_dest_table ORDER BY 1, 2, 3, 4, 5, 6, 7, 8) l;

	/* get the results using source_table_2 as source */
    TRUNCATE local_dest_table;
	EXECUTE format(query_template, source_table_2);
	SELECT array_agg(l) INTO l2
	FROM (SELECT * FROM local_dest_table ORDER BY 1, 2, 3, 4, 5, 6, 7, 8) l;

	RAISE NOTICE 'l2=%', l1;
	RAISE NOTICE 'l2=%', l2;
	RETURN l1 = l2;
END;
$$ LANGUAGE plpgsql;
SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table
  SELECT
    t1.dist_col,
    1,
    'string1',
    'string2',
    2,
    'string3',
    t1.text_col_1,
    t1.text_col_2
  FROM %1$s_1 t1
  WHERE t1.int_col IN (SELECT int_col FROM %1$s_2)
$$, 'local_source_table', 'dist_source_table');
NOTICE:  l2={"(1,1,string1,string2,2,string3,value,value)","(1,1,string1,string2,2,string3,value2,value)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,1,string1,string2,2,string3,value,value)","(1,1,string1,string2,2,string3,value2,value)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table
  SELECT
    t1.dist_col,
    1,
    'string1',
    'string2',
    2,
    'string3',
    t1.text_col_1,
    t1.text_col_2
  FROM %1$s t1
  returning *
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(1,1,string1,string2,2,string3,value,value)","(1,1,string1,string2,2,string3,value2,value)","(3,1,string1,string2,2,string3,value,value3)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,1,string1,string2,2,string3,value,value)","(1,1,string1,string2,2,string3,value2,value)","(3,1,string1,string2,2,string3,value,value3)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_3, col_4) SELECT
    'string1',
    'string2'::text
  FROM %1$s t1
  returning *;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,string1,string2,,,col_7,)","(,,string1,string2,,,col_7,)","(,,string1,string2,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,string1,string2,,,col_7,)","(,,string1,string2,,,col_7,)","(,,string1,string2,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_7, col_4) SELECT
    'string1',
    'string2'::text
  FROM %1$s t1
  returning *;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,,string2,,,string1,)","(,,,string2,,,string1,)","(,,,string2,,,string1,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,,string2,,,string1,)","(,,,string2,,,string1,)","(,,,string2,,,string1,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_4, col_3) SELECT
    'string1',
    'string2'::text
  FROM %1$s t1
  WHERE dist_col = 1
  returning *;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,string2,string1,,,col_7,)","(,,string2,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,string2,string1,,,col_7,)","(,,string2,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_4, col_1)
  SELECT
    'string1',
     dist_col
  FROM %1$s
  UNION ALL
  SELECT
    'string',
     int_col
  FROM %1$s;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(1,,,string,,,col_7,)","(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(2,,,string,,,col_7,)","(3,,,string,,,col_7,)","(3,,,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,,,string,,,col_7,)","(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(2,,,string,,,col_7,)","(3,,,string,,,col_7,)","(3,,,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  WITH cte1 AS (SELECT s FROM generate_series(1,10) s)
  INSERT INTO local_dest_table (col_4, col_1)
  SELECT
    'string1',
     dist_col
  FROM %1$s WHERE int_col IN (SELECT s FROM cte1)
  UNION ALL
  SELECT
    'string',
     int_col
  FROM %1$s WHERE int_col IN (SELECT s + 1 FROM cte1)
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(2,,,string,,,col_7,)","(3,,,string,,,col_7,)","(3,,,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(2,,,string,,,col_7,)","(3,,,string,,,col_7,)","(3,,,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  WITH cte1 AS (SELECT 'stringcte', s FROM generate_series(1,10) s)
  INSERT INTO local_dest_table (col_4, col_1)
  SELECT
    'string1',
     dist_col
  FROM %1$s WHERE int_col IN (SELECT s FROM cte1)
  UNION ALL
  SELECT
    *
  FROM cte1
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(1,,,stringcte,,,col_7,)","(2,,,stringcte,,,col_7,)","(3,,,string1,,,col_7,)","(3,,,stringcte,,,col_7,)","(4,,,stringcte,,,col_7,)","(5,,,stringcte,,,col_7,)","(6,,,stringcte,,,col_7,)","(7,,,stringcte,,,col_7,)","(8,,,stringcte,,,col_7,)","(9,,,stringcte,,,col_7,)","(10,,,stringcte,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(1,,,stringcte,,,col_7,)","(2,,,stringcte,,,col_7,)","(3,,,string1,,,col_7,)","(3,,,stringcte,,,col_7,)","(4,,,stringcte,,,col_7,)","(5,,,stringcte,,,col_7,)","(6,,,stringcte,,,col_7,)","(7,,,stringcte,,,col_7,)","(8,,,stringcte,,,col_7,)","(9,,,stringcte,,,col_7,)","(10,,,stringcte,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_3)
  SELECT t1.text_col_1
  FROM %1$s t1
  GROUP BY t1.text_col_1;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,value,,,,col_7,)","(,,value2,,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,value,,,,col_7,)","(,,value2,,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_1, col_2, col_3, col_5, col_6, col_7, col_8)
  SELECT
    max(t1.dist_col),
    3,
    'string_3',
    4,
    44,
    t1.text_col_1,
    'string_1000'
  FROM %1$s t1
  GROUP BY t1.text_col_2, t1.text_col_1;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(1,3,string_3,,4,44,value,string_1000)","(1,3,string_3,,4,44,value2,string_1000)","(3,3,string_3,,4,44,value,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,3,string_3,,4,44,value,string_1000)","(1,3,string_3,,4,44,value2,string_1000)","(3,3,string_3,,4,44,value,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_7, col_8)
  SELECT
    t1.text_col_1,
    'string_1000'
  FROM dist_source_table_1 t1
  GROUP BY t1.text_col_1;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,,,,,value,string_1000)","(,,,,,,value2,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,,,,,value,string_1000)","(,,,,,,value2,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_6, col_7, col_8)
  SELECT
    'string_4',
    t1.text_col_1,
    'string_1000'
  FROM %1$s t1
  GROUP BY t1.text_col_1;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,,,,string_4,value,string_1000)","(,,,,,string_4,value2,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,,,,string_4,value,string_1000)","(,,,,,string_4,value2,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_5, col_3)
  SELECT 12, 'string_11' FROM %1$s t1
  UNION
  SELECT int_col, 'string' FROM %1$s;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,string,,1,,col_7,)","(,,string,,2,,col_7,)","(,,string,,3,,col_7,)","(,,string_11,,12,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,string,,1,,col_7,)","(,,string,,2,,col_7,)","(,,string,,3,,col_7,)","(,,string_11,,12,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table(col_3, col_2)
  SELECT text_col_1, count(*) FROM %1$s GROUP BY 1
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,1,value2,,,,col_7,)","(,2,value,,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,1,value2,,,,col_7,)","(,2,value,,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table(col_3, col_5)
  SELECT text_col_1, count(*)::int FROM %1$s GROUP BY 1
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,value,,2,,col_7,)","(,,value2,,1,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,value,,2,,col_7,)","(,,value2,,1,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

-- repeat above tests with Citus local table
SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table
  SELECT
    t1.dist_col,
    1,
    'string1',
    'string2',
    2,
    'string3',
    t1.text_col_1,
    t1.text_col_2
  FROM %1$s_1 t1
  WHERE t1.int_col IN (SELECT int_col FROM %1$s_2)
$$, 'local_source_table', 'dist_source_table');
NOTICE:  l2={"(1,1,string1,string2,2,string3,value,value)","(1,1,string1,string2,2,string3,value2,value)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,1,string1,string2,2,string3,value,value)","(1,1,string1,string2,2,string3,value2,value)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table
  SELECT
    t1.dist_col,
    1,
    'string1',
    'string2',
    2,
    'string3',
    t1.text_col_1,
    t1.text_col_2
  FROM %1$s t1
  returning *
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(1,1,string1,string2,2,string3,value,value)","(1,1,string1,string2,2,string3,value2,value)","(3,1,string1,string2,2,string3,value,value3)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,1,string1,string2,2,string3,value,value)","(1,1,string1,string2,2,string3,value2,value)","(3,1,string1,string2,2,string3,value,value3)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_3, col_4) SELECT
    'string1',
    'string2'::text
  FROM %1$s t1
  returning *;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,string1,string2,,,col_7,)","(,,string1,string2,,,col_7,)","(,,string1,string2,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,string1,string2,,,col_7,)","(,,string1,string2,,,col_7,)","(,,string1,string2,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_7, col_4) SELECT
    'string1',
    'string2'::text
  FROM %1$s t1
  returning *;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,,string2,,,string1,)","(,,,string2,,,string1,)","(,,,string2,,,string1,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,,string2,,,string1,)","(,,,string2,,,string1,)","(,,,string2,,,string1,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_4, col_3) SELECT
    'string1',
    'string2'::text
  FROM %1$s t1
  WHERE dist_col = 1
  returning *;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,string2,string1,,,col_7,)","(,,string2,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,string2,string1,,,col_7,)","(,,string2,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_4, col_1)
  SELECT
    'string1',
     dist_col
  FROM %1$s
  UNION ALL
  SELECT
    'string',
     int_col
  FROM %1$s;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(1,,,string,,,col_7,)","(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(2,,,string,,,col_7,)","(3,,,string,,,col_7,)","(3,,,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,,,string,,,col_7,)","(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(2,,,string,,,col_7,)","(3,,,string,,,col_7,)","(3,,,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  WITH cte1 AS (SELECT s FROM generate_series(1,10) s)
  INSERT INTO local_dest_table (col_4, col_1)
  SELECT
    'string1',
     dist_col
  FROM %1$s WHERE int_col IN (SELECT s FROM cte1)
  UNION ALL
  SELECT
    'string',
     int_col
  FROM %1$s WHERE int_col IN (SELECT s + 1 FROM cte1)
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(2,,,string,,,col_7,)","(3,,,string,,,col_7,)","(3,,,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(2,,,string,,,col_7,)","(3,,,string,,,col_7,)","(3,,,string1,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  WITH cte1 AS (SELECT 'stringcte', s FROM generate_series(1,10) s)
  INSERT INTO local_dest_table (col_4, col_1)
  SELECT
    'string1',
     dist_col
  FROM %1$s WHERE int_col IN (SELECT s FROM cte1)
  UNION ALL
  SELECT
    *
  FROM cte1
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(1,,,stringcte,,,col_7,)","(2,,,stringcte,,,col_7,)","(3,,,string1,,,col_7,)","(3,,,stringcte,,,col_7,)","(4,,,stringcte,,,col_7,)","(5,,,stringcte,,,col_7,)","(6,,,stringcte,,,col_7,)","(7,,,stringcte,,,col_7,)","(8,,,stringcte,,,col_7,)","(9,,,stringcte,,,col_7,)","(10,,,stringcte,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,,,string1,,,col_7,)","(1,,,string1,,,col_7,)","(1,,,stringcte,,,col_7,)","(2,,,stringcte,,,col_7,)","(3,,,string1,,,col_7,)","(3,,,stringcte,,,col_7,)","(4,,,stringcte,,,col_7,)","(5,,,stringcte,,,col_7,)","(6,,,stringcte,,,col_7,)","(7,,,stringcte,,,col_7,)","(8,,,stringcte,,,col_7,)","(9,,,stringcte,,,col_7,)","(10,,,stringcte,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_3)
  SELECT t1.text_col_1
  FROM %1$s t1
  GROUP BY t1.text_col_1;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,value,,,,col_7,)","(,,value2,,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,value,,,,col_7,)","(,,value2,,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_1, col_2, col_3, col_5, col_6, col_7, col_8)
  SELECT
    max(t1.dist_col),
    3,
    'string_3',
    4,
    44,
    t1.text_col_1,
    'string_1000'
  FROM %1$s t1
  GROUP BY t1.text_col_2, t1.text_col_1;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(1,3,string_3,,4,44,value,string_1000)","(1,3,string_3,,4,44,value2,string_1000)","(3,3,string_3,,4,44,value,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(1,3,string_3,,4,44,value,string_1000)","(1,3,string_3,,4,44,value2,string_1000)","(3,3,string_3,,4,44,value,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_7, col_8)
  SELECT
    t1.text_col_1,
    'string_1000'
  FROM dist_source_table_1 t1
  GROUP BY t1.text_col_1;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,,,,,value,string_1000)","(,,,,,,value2,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,,,,,value,string_1000)","(,,,,,,value2,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_6, col_7, col_8)
  SELECT
    'string_4',
    t1.text_col_1,
    'string_1000'
  FROM %1$s t1
  GROUP BY t1.text_col_1;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,,,,string_4,value,string_1000)","(,,,,,string_4,value2,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,,,,string_4,value,string_1000)","(,,,,,string_4,value2,string_1000)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table (col_5, col_3)
  SELECT 12, 'string_11' FROM %1$s t1
  UNION
  SELECT int_col, 'string' FROM %1$s;
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,string,,1,,col_7,)","(,,string,,2,,col_7,)","(,,string,,3,,col_7,)","(,,string_11,,12,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,string,,1,,col_7,)","(,,string,,2,,col_7,)","(,,string,,3,,col_7,)","(,,string_11,,12,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table(col_3, col_2)
  SELECT text_col_1, count(*) FROM %1$s GROUP BY 1
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,1,value2,,,,col_7,)","(,2,value,,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,1,value2,,,,col_7,)","(,2,value,,,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

SELECT * FROM query_results_equal($$
  INSERT INTO local_dest_table(col_3, col_5)
  SELECT text_col_1, count(*)::int FROM %1$s GROUP BY 1
$$, 'local_source_table_1', 'dist_source_table_1');
NOTICE:  l2={"(,,value,,2,,col_7,)","(,,value2,,1,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
NOTICE:  l2={"(,,value,,2,,col_7,)","(,,value2,,1,,col_7,)"}
CONTEXT:  PL/pgSQL function query_results_equal(text,text,text) line XX at RAISE
 query_results_equal
---------------------------------------------------------------------
 t
(1 row)

-- go back to proper local table for remaining tests
TRUNCATE local_dest_table;
SELECT undistribute_table('local_source_table_1');
ERROR:  cannot undistribute table because the table is not distributed
-- use a sequence (cannot use query_results_equal, since sequence values would not match)
CREATE SEQUENCE seq;
BEGIN;
INSERT INTO local_dest_table (col_5, col_3)
SELECT 12, 'string_11' FROM dist_source_table_1
UNION
SELECT nextval('seq'), 'string' FROM dist_source_table_1;
SELECT * FROM local_dest_table ORDER BY 1,2,3,4,5,6,7,8;
 col_1 | col_2 |   col_3   | col_4 | col_5 | col_6 | col_7 | col_8
---------------------------------------------------------------------
       |       | string    |       |     1 |       | col_7 |
       |       | string    |       |     2 |       | col_7 |
       |       | string    |       |     3 |       | col_7 |
       |       | string_11 |       |    12 |       | col_7 |
(4 rows)

ROLLBACK;
-- add a bigserial column
ALTER TABLE local_dest_table ADD COLUMN col_9 bigserial;
-- not supported due to limitations in nextval handling
INSERT INTO local_dest_table (col_5, col_3)
SELECT 12, 'string_11' FROM dist_source_table_1
UNION
SELECT 11, 'string' FROM dist_source_table_1;
SELECT * FROM local_dest_table ORDER BY 1,2,3,4,5,6,7,8;
 col_1 | col_2 |   col_3   | col_4 | col_5 | col_6 | col_7 | col_8 | col_9
---------------------------------------------------------------------
       |       | string    |       |    11 |       | col_7 |       |     2
       |       | string_11 |       |    12 |       | col_7 |       |     1
(2 rows)

BEGIN;
INSERT INTO local_dest_table(col_3, col_2)
SELECT text_col_1, count(*) FROM dist_source_table_1 GROUP BY 1;
SELECT * FROM local_dest_table ORDER BY 1,2,3,4,5,6,7,8;
 col_1 | col_2 |   col_3   | col_4 | col_5 | col_6 | col_7 | col_8 | col_9
---------------------------------------------------------------------
       |     1 | value2    |       |       |       | col_7 |       |     3
       |     2 | value     |       |       |       | col_7 |       |     4
       |       | string    |       |    11 |       | col_7 |       |     2
       |       | string_11 |       |    12 |       | col_7 |       |     1
(4 rows)

ROLLBACK;
BEGIN;
INSERT INTO local_dest_table (col_4, col_3) SELECT
  'string1',
  'string2'::text
FROM dist_source_table_1 t1
WHERE dist_col = 1
RETURNING *;
 col_1 | col_2 |  col_3  |  col_4  | col_5 | col_6 | col_7 | col_8 | col_9
---------------------------------------------------------------------
       |       | string2 | string1 |       |       | col_7 |       |     5
       |       | string2 | string1 |       |       | col_7 |       |     6
(2 rows)

ROLLBACK;
\set VERBOSITY terse
DROP SCHEMA insert_select_into_local_table CASCADE;
NOTICE:  drop cascades to 12 other objects