diff options
| author | Christian Grothoff <grothoff@gnunet.org> | 2022-07-25 20:18:08 +0200 |
|---|---|---|
| committer | Christian Grothoff <grothoff@gnunet.org> | 2022-07-25 20:18:08 +0200 |
| commit | 6d2e6d80613e6f45d207f89bc25f6f507a131504 (patch) | |
| tree | ff5b282025a1b58cec7ead1d91b3786776359f88 /src/exchangedb/plugin_exchangedb_postgres.c | |
| parent | de83b055d5c4bdbdebdc972e822ec9a4f5604bea (diff) | |
| download | exchange-6d2e6d80613e6f45d207f89bc25f6f507a131504.tar.gz exchange-6d2e6d80613e6f45d207f89bc25f6f507a131504.tar.bz2 exchange-6d2e6d80613e6f45d207f89bc25f6f507a131504.zip | |
-move everything into schema
Diffstat (limited to 'src/exchangedb/plugin_exchangedb_postgres.c')
| -rw-r--r-- | src/exchangedb/plugin_exchangedb_postgres.c | 28 |
1 files changed, 23 insertions, 5 deletions
diff --git a/src/exchangedb/plugin_exchangedb_postgres.c b/src/exchangedb/plugin_exchangedb_postgres.c index 127a41048..9fb9192c7 100644 --- a/src/exchangedb/plugin_exchangedb_postgres.c +++ b/src/exchangedb/plugin_exchangedb_postgres.c @@ -222,6 +222,11 @@ postgres_create_shard_tables (void *cls, GNUNET_PQ_query_param_uint32 (&idx), GNUNET_PQ_query_param_end }; + struct GNUNET_PQ_ExecuteStatement es[] = { + GNUNET_PQ_make_try_execute ("SET search_path TO exchange;"), + GNUNET_PQ_EXECUTE_STATEMENT_END + }; + struct GNUNET_PQ_PreparedStatement ps[] = { GNUNET_PQ_make_prepare ("create_shard_tables", "SELECT" @@ -234,7 +239,7 @@ postgres_create_shard_tables (void *cls, conn = GNUNET_PQ_connect_with_cfg (pg->cfg, "exchangedb-postgres", "shard-", - NULL, + es, ps); if (NULL == conn) return GNUNET_SYSERR; @@ -273,11 +278,15 @@ postgres_setup_partitions (void *cls, 1), GNUNET_PQ_PREPARED_STATEMENT_END }; + struct GNUNET_PQ_ExecuteStatement es[] = { + GNUNET_PQ_make_try_execute ("SET search_path TO exchange;"), + GNUNET_PQ_EXECUTE_STATEMENT_END + }; conn = GNUNET_PQ_connect_with_cfg (pg->cfg, "exchangedb-postgres", NULL, - NULL, + es, ps); if (NULL == conn) return GNUNET_SYSERR; @@ -353,7 +362,10 @@ postgres_setup_foreign_servers (void *cls, GNUNET_PQ_query_param_string (remote_user_pw), GNUNET_PQ_query_param_end }; - + struct GNUNET_PQ_ExecuteStatement es[] = { + GNUNET_PQ_make_try_execute ("SET search_path TO exchange;"), + GNUNET_PQ_EXECUTE_STATEMENT_END + }; struct GNUNET_PQ_PreparedStatement ps[] = { GNUNET_PQ_make_prepare ("create_foreign_servers", "SELECT" @@ -366,7 +378,7 @@ postgres_setup_foreign_servers (void *cls, conn = GNUNET_PQ_connect_with_cfg (pg->cfg, "exchangedb-postgres", NULL, - NULL, + es, ps); if (NULL == conn) { @@ -4455,6 +4467,7 @@ internal_setup (struct PostgresClosure *pg, "SET SESSION CHARACTERISTICS AS TRANSACTION ISOLATION LEVEL SERIALIZABLE;"), GNUNET_PQ_make_try_execute ("SET enable_sort=OFF;"), GNUNET_PQ_make_try_execute ("SET enable_seqscan=OFF;"), + GNUNET_PQ_make_try_execute ("SET search_path TO exchange;"), GNUNET_PQ_EXECUTE_STATEMENT_END }; #else @@ -4464,6 +4477,7 @@ internal_setup (struct PostgresClosure *pg, GNUNET_PQ_make_try_execute ("SET enable_sort=OFF;"), GNUNET_PQ_make_try_execute ("SET enable_seqscan=OFF;"), GNUNET_PQ_make_try_execute ("SET autocommit=OFF;"), + GNUNET_PQ_make_try_execute ("SET search_path TO exchange;"), GNUNET_PQ_EXECUTE_STATEMENT_END }; #endif @@ -10501,6 +10515,10 @@ postgres_gc (void *cls) GNUNET_TIME_UNIT_YEARS, 10)); { + struct GNUNET_PQ_ExecuteStatement es[] = { + GNUNET_PQ_make_try_execute ("SET search_path TO exchange;"), + GNUNET_PQ_EXECUTE_STATEMENT_END + }; struct GNUNET_PQ_PreparedStatement ps[] = { /* Used in #postgres_gc() */ GNUNET_PQ_make_prepare ("run_gc", @@ -10514,7 +10532,7 @@ postgres_gc (void *cls) conn = GNUNET_PQ_connect_with_cfg (pg->cfg, "exchangedb-postgres", NULL, - NULL, + es, ps); } if (NULL == conn) |