mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-21 05:43:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix table name

Browse source
This commit is contained in:
Neil Alexander 2020-06-30 13:35:11 +01:00
parent 4f206eb478
commit 56e3d51fa4
2 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
federationsender/storage/postgres/queue_json_table.go
View file

@ -27,7 +27,7 @@ import (
const queueJSONSchema = ` const queueJSONSchema = `
-- The queue_retry_json table contains event contents that -- The queue_retry_json table contains event contents that
-- we failed to send. -- we failed to send.
CREATE TABLE IF NOT EXISTS federationsender_queue_retry_json ( CREATE TABLE IF NOT EXISTS federationsender_queue_json (
-- The JSON NID. This allows the federationsender_queue_retry table to -- The JSON NID. This allows the federationsender_queue_retry table to
-- cross-reference to find the JSON blob. -- cross-reference to find the JSON blob.
json_nid BIGSERIAL, json_nid BIGSERIAL,
@ -37,15 +37,15 @@ CREATE TABLE IF NOT EXISTS federationsender_queue_retry_json (
` `
const insertJSONSQL = "" + const insertJSONSQL = "" +
"INSERT INTO federationsender_queue_retry_json (json_body)" + "INSERT INTO federationsender_queue_json (json_body)" +
" VALUES ($1)" + " VALUES ($1)" +
" ON CONFLICT DO NOTHING" " ON CONFLICT DO NOTHING"
const deleteJSONSQL = "" + const deleteJSONSQL = "" +
"DELETE FROM federationsender_queue_retry_json WHERE json_nid = ANY($1)" "DELETE FROM federationsender_queue_json WHERE json_nid = ANY($1)"
const selectJSONSQL = "" + const selectJSONSQL = "" +
"SELECT json_nid, json_body FROM federationsender_queue_retry_json" + "SELECT json_nid, json_body FROM federationsender_queue_json" +
" WHERE json_nid = ANY($1)" " WHERE json_nid = ANY($1)"
type queueJSONStatements struct { type queueJSONStatements struct {

8
federationsender/storage/sqlite3/queue_json_table.go
View file

@ -27,7 +27,7 @@ import (
const queueJSONSchema = ` const queueJSONSchema = `
-- The queue_retry_json table contains event contents that -- The queue_retry_json table contains event contents that
-- we failed to send. -- we failed to send.
CREATE TABLE IF NOT EXISTS federationsender_queue_retry_json ( CREATE TABLE IF NOT EXISTS federationsender_queue_json (
-- The JSON NID. This allows the federationsender_queue_retry table to -- The JSON NID. This allows the federationsender_queue_retry table to
-- cross-reference to find the JSON blob. -- cross-reference to find the JSON blob.
json_nid BIGSERIAL, json_nid BIGSERIAL,
@ -37,15 +37,15 @@ CREATE TABLE IF NOT EXISTS federationsender_queue_retry_json (
` `
const insertJSONSQL = "" + const insertJSONSQL = "" +
"INSERT INTO federationsender_queue_retry_json (json_body)" + "INSERT INTO federationsender_queue_json (json_body)" +
" VALUES ($1)" + " VALUES ($1)" +
" ON CONFLICT DO NOTHING" " ON CONFLICT DO NOTHING"
const deleteJSONSQL = "" + const deleteJSONSQL = "" +
"DELETE FROM federationsender_queue_retry_json WHERE json_nid = ANY($1)" "DELETE FROM federationsender_queue_json WHERE json_nid = ANY($1)"
const selectJSONSQL = "" + const selectJSONSQL = "" +
"SELECT json_nid, json_body FROM federationsender_queue_retry_json" + "SELECT json_nid, json_body FROM federationsender_queue_json" +
" WHERE json_nid = ANY($1)" " WHERE json_nid = ANY($1)"
type queueJSONStatements struct { type queueJSONStatements struct {