|
| 1 | +create database jdbc_streaming_db; |
| 2 | + |
| 3 | +\c jdbc_streaming_db; |
| 4 | + |
| 5 | + |
| 6 | +create table reference_table ( |
| 7 | + ip VARCHAR(50) NOT NULL, |
| 8 | + name VARCHAR(50) NOT NULL, |
| 9 | + location VARCHAR(50) NOT NULL |
| 10 | +); |
| 11 | + |
| 12 | + |
| 13 | +DO $$ |
| 14 | + DECLARE |
| 15 | + counter INTEGER := 1 ; |
| 16 | + ipTemplate VARCHAR(50) := '10.%s.1.1'; |
| 17 | + nameTemplate VARCHAR(50) := 'ldn-server-%s'; |
| 18 | + locationTemplate VARCHAR(50) := 'LDN-%s-2-3'; |
| 19 | + BEGIN |
| 20 | + |
| 21 | + WHILE counter <= 250 |
| 22 | + LOOP |
| 23 | + INSERT INTO reference_table |
| 24 | + VALUES ((SELECT FORMAT(ipTemplate, counter)), |
| 25 | + (SELECT FORMAT(nameTemplate, counter)), |
| 26 | + (SELECT FORMAT(locationTemplate, counter))); |
| 27 | + counter = counter + 1; |
| 28 | + END LOOP; |
| 29 | +END $$; |
| 30 | + |
| 31 | + |
| 32 | +create database jdbc_static_db; |
| 33 | + |
| 34 | +\c jdbc_static_db; |
| 35 | + |
| 36 | + |
| 37 | +create table reference_table ( |
| 38 | + ip VARCHAR(50) NOT NULL, |
| 39 | + name VARCHAR(50) NOT NULL, |
| 40 | + location VARCHAR(50) NOT NULL |
| 41 | +); |
| 42 | + |
| 43 | + |
| 44 | +INSERT INTO reference_table VALUES ('10.1.1.1', 'ldn-server-1', 'LDN-2-3-4'); |
| 45 | +INSERT INTO reference_table VALUES ('10.2.1.1', 'nyc-server-1', 'NYC-5-2-8'); |
| 46 | +INSERT INTO reference_table VALUES ('10.3.1.1', 'mv-server-1', 'MV-9-6-4'); |
| 47 | + |
| 48 | +create DATABASE jdbc_input_db; |
| 49 | + |
| 50 | +\c jdbc_input_db; |
| 51 | + |
| 52 | +CREATE TABLE employee ( |
| 53 | + emp_no integer NOT NULL, |
| 54 | + first_name VARCHAR (50) NOT NULL, |
| 55 | + last_name VARCHAR (50) NOT NULL |
| 56 | +); |
| 57 | + |
| 58 | +INSERT INTO employee VALUES (1, 'David', 'Blenkinsop'); |
| 59 | +INSERT INTO employee VALUES (2, 'Mark', 'Guckenheimer'); |
0 commit comments