Skip to content

Commit

Permalink
wal2json: fix ENV["CI"] usage.
Browse files Browse the repository at this point in the history
Part of #70493.
  • Loading branch information
MikeMcQuaid committed Feb 8, 2021
1 parent 52f24aa commit a99cf77
Showing 1 changed file with 0 additions and 112 deletions.
112 changes: 0 additions & 112 deletions Formula/wal2json.rb
Original file line number Diff line number Diff line change
Expand Up @@ -26,116 +26,4 @@ def install
system "make", "install", "USE_PGXS=1", "DESTDIR=#{buildpath}/stage"
lib.install Dir["stage/#{HOMEBREW_PREFIX}/lib/*"]
end

test do
return if ENV["CI"]

system "initdb", testpath/"datadir"
mkdir testpath/"socket"
File.open(testpath/"datadir"/"postgresql.conf", "a") do |f|
f << "wal_level = logical\n"
f << "listen_addresses = ''\n"
f << "unix_socket_directories = '#{testpath}/socket'\n"
f << "dynamic_library_path = '$libdir:#{lib}/postgresql'\n"
end
pid = Process.fork { exec "postgres", "-D", testpath/"datadir" }
sleep 2
begin
system "createdb", "-h", testpath/"socket", "test"

input_sql = <<~EOS
CREATE TABLE table2_with_pk (a SERIAL, b VARCHAR(30), c TIMESTAMP NOT NULL, PRIMARY KEY(a, c));
CREATE TABLE table2_without_pk (a SERIAL, b NUMERIC(5,2), c TEXT);
SELECT 'init' FROM pg_create_logical_replication_slot('test_slot', 'wal2json');
BEGIN;
INSERT INTO table2_with_pk (b, c) VALUES('Backup and Restore', '2019-10-08 12:00:00');
INSERT INTO table2_with_pk (b, c) VALUES('Tuning', '2019-10-08 12:00:00');
INSERT INTO table2_with_pk (b, c) VALUES('Replication', '2019-10-08 12:00:00');
DELETE FROM table2_with_pk WHERE a < 3;
INSERT INTO table2_without_pk (b, c) VALUES(2.34, 'Tapir');
-- it is not added to stream because there isn't a pk or a replica identity
UPDATE table2_without_pk SET c = 'Anta' WHERE c = 'Tapir';
COMMIT;
SELECT data FROM pg_logical_slot_get_changes('test_slot', NULL, NULL, 'pretty-print', '1');
SELECT 'stop' FROM pg_drop_replication_slot('test_slot');
EOS

File.open(testpath/"input.sql", "w") do |f|
f.write(input_sql)
end

system "psql", "-h", testpath/"socket", "-f", testpath/"input.sql", "-o", testpath/"output.txt", "-Atq", "test"
actual_output = File.read(testpath/"output.txt")

expected_output = <<~EOS
init
{
"change": [
{
"kind": "insert",
"schema": "public",
"table": "table2_with_pk",
"columnnames": ["a", "b", "c"],
"columntypes": ["integer", "character varying(30)", "timestamp without time zone"],
"columnvalues": [1, "Backup and Restore", "2019-10-08 12:00:00"]
}
,{
"kind": "insert",
"schema": "public",
"table": "table2_with_pk",
"columnnames": ["a", "b", "c"],
"columntypes": ["integer", "character varying(30)", "timestamp without time zone"],
"columnvalues": [2, "Tuning", "2019-10-08 12:00:00"]
}
,{
"kind": "insert",
"schema": "public",
"table": "table2_with_pk",
"columnnames": ["a", "b", "c"],
"columntypes": ["integer", "character varying(30)", "timestamp without time zone"],
"columnvalues": [3, "Replication", "2019-10-08 12:00:00"]
}
,{
"kind": "delete",
"schema": "public",
"table": "table2_with_pk",
"oldkeys": {
"keynames": ["a", "c"],
"keytypes": ["integer", "timestamp without time zone"],
"keyvalues": [1, "2019-10-08 12:00:00"]
}
}
,{
"kind": "delete",
"schema": "public",
"table": "table2_with_pk",
"oldkeys": {
"keynames": ["a", "c"],
"keytypes": ["integer", "timestamp without time zone"],
"keyvalues": [2, "2019-10-08 12:00:00"]
}
}
,{
"kind": "insert",
"schema": "public",
"table": "table2_without_pk",
"columnnames": ["a", "b", "c"],
"columntypes": ["integer", "numeric(5,2)", "text"],
"columnvalues": [1, 2.34, "Tapir"]
}
]
}
stop
EOS

assert_equal(expected_output.gsub(/\s+/, ""), actual_output.gsub(/\s+/, ""))
ensure
Process.kill 9, pid
Process.wait pid
end
end
end

0 comments on commit a99cf77

Please sign in to comment.