Commit Graph

248 Commits

Author SHA1 Message Date
kssenii
a0f717619c Remove initial filling 2021-03-19 08:33:04 +00:00
kssenii
9057aad798 Better version 2021-03-19 08:11:36 +00:00
kssenii
f1ef87d966 Fix 2021-03-18 20:04:54 +00:00
kssenii
7847b78af9 Fix style, build 2021-03-17 20:49:56 +00:00
kssenii
3903d59d30 Better 2021-03-17 14:34:04 +00:00
kssenii
ae64a24844 Add connection pool 2021-03-17 13:55:47 +00:00
Kseniia Sumarokova
f8fc4281f2
Update PostgreSQLReplicaConnection.h 2021-03-17 15:56:47 +03:00
kssenii
87c740730b Rename to MaterializePostgreSQL 2021-03-17 10:52:12 +00:00
Kseniia Sumarokova
5b7ef512f5
Update PostgreSQLReplicaConnection.h 2021-03-15 09:14:30 +03:00
kssenii
6e69299191 Fix style 2021-03-14 10:43:23 +00:00
kssenii
8eea6a87e9 Support replicas priority for postgres dictionary source 2021-03-14 08:51:24 +00:00
kssenii
28c0a64c07 Comment 2021-02-22 13:05:29 +00:00
kssenii
ace76bb7fa Better, remove debug logs 2021-02-22 12:35:53 +00:00
kssenii
8a48bb24ce Fix typos, comments 2021-02-21 23:13:58 +00:00
kssenii
2e3bdd662e Handle ddl part 2 2021-02-21 22:41:18 +00:00
kssenii
427aad80a1 Avoid table does not exist errors if nested is unavailable 2021-02-21 11:48:13 +00:00
kssenii
883cc2c0ef Fixes 2021-02-20 18:37:54 +00:00
kssenii
d0d90538ea Tiny fix 2021-02-20 18:04:10 +00:00
kssenii
0424770f68 Handle ddl part 1 2021-02-20 16:21:53 +00:00
kssenii
ff8b54ffd4 Make sure postgres table schema changes do not break replication 2021-02-18 23:33:01 +00:00
kssenii
3107f82a3b Fix clang tidy 2021-02-18 18:25:49 +00:00
kssenii
9cc63780de More correct update query 2021-02-18 18:14:05 +00:00
kssenii
1480e95179 Fix build, fix arcadia 2021-02-18 06:06:37 +00:00
kssenii
46dd137a5a Fix tests 2021-02-17 21:15:06 +00:00
kssenii
44c39d4609 better 2021-02-16 19:00:28 +00:00
kssenii
272431bcae Fix types check, better tests, try fix build 2021-02-15 23:18:53 +00:00
kssenii
95c93aca41 Better table sync 2021-02-13 21:03:25 +00:00
kssenii
44f4f1a412 Allow to replicate a subset of database tables 2021-02-13 20:09:01 +00:00
kssenii
219dece1d0 Slightly better 2021-02-12 21:15:00 +00:00
kssenii
010a640ed8 Fix and test different data types 2021-02-12 21:14:47 +00:00
kssenii
5bc0010f94 Better 2021-02-12 21:14:36 +00:00
kssenii
ed6d19b8a6 Add PostgreSQLReplica database engine 2021-02-12 21:14:24 +00:00
kssenii
9c2c7be4cf Separate replication interface from single storage 2021-02-12 21:14:10 +00:00
kssenii
7ceb784d1e Better slot usage, some fixes 2021-02-12 21:13:54 +00:00
kssenii
d87bfef890 Read up to max_block_size rows 2021-02-12 21:13:43 +00:00
kssenii
02e19f9422 Better 2021-02-12 21:13:13 +00:00
kssenii
d255b63364 Slightly better 2021-02-12 21:13:01 +00:00
kssenii
8d0c28d470 Replicate update queries 2021-02-12 21:12:41 +00:00
kssenii
0d19992128 Replicate delete queries 2021-02-12 21:12:27 +00:00
kssenii
4aadd0c3f2 Replicate insert queries 2021-02-12 21:11:55 +00:00
kssenii
179a558a04 Setup connection in the background, better drop table 2021-02-12 21:11:35 +00:00
kssenii
b842ce114b Initial sync into ReplacingMergeTree table, select via nested table 2021-02-12 21:11:09 +00:00
kssenii
60ebb86d97 Add stream and buffer classes 2021-02-12 21:10:40 +00:00
kssenii
a1bcc5fb39 Decode replication messages 2021-02-12 21:10:10 +00:00
kssenii
84ffd76853 Initial table sync and replication pre-startup 2021-02-12 21:09:43 +00:00
alexey-milovidov
e67e4588e7
Update PostgreSQLConnection.h 2021-01-16 15:26:21 +03:00
Alexey Milovidov
67f207d8ca More safe connection string 2021-01-16 00:18:51 +03:00
Alexey Milovidov
ba1921f380 Minor changes 2021-01-15 22:59:49 +03:00