We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cb2632a commit 37f16e7Copy full SHA for 37f16e7
pgserver/subscription_handler.go
@@ -52,7 +52,7 @@ func (config *SubscriptionConfig) ToDNS() string {
52
func (config *SubscriptionConfig) ToDuckDBQuery() []string {
53
return []string{
54
fmt.Sprintf("ATTACH '%s' AS pg_postgres (TYPE POSTGRES);", config.ToConnectionInfo()),
55
- "BEGIN ISOLATION LEVEL REPEATABLE READ;",
+ "BEGIN;",
56
"COPY FROM DATABASE pg_postgres TO mysql;",
57
"SELECT * FROM postgres_query('pg_postgres', 'SELECT pg_current_wal_lsn()');",
58
"COMMIT;",
0 commit comments