mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-16 18:43:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Consolidate relay servers table prepare statements

Browse source
This commit is contained in:
Devon Hudson 2022-12-22 10:05:23 -07:00
parent 6c47069b0b
commit 9a159e3ae0
No known key found for this signature in database
GPG key ID: CD06B18E77F6A628
2 changed files with 12 additions and 26 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
federationapi/storage/postgres/relay_servers_table.go
View file

@ -66,19 +66,12 @@ func NewPostgresRelayServersTable(db *sql.DB) (s *relayServersStatements, err er
return
}
if s.insertRelayServersStmt, err = db.Prepare(insertRelayServersSQL); err != nil {
return
}
if s.selectRelayServersStmt, err = db.Prepare(selectRelayServersSQL); err != nil {
return
}
if s.deleteRelayServersStmt, err = db.Prepare(deleteRelayServersSQL); err != nil {
return
}
if s.deleteAllRelayServersStmt, err = db.Prepare(deleteAllRelayServersSQL); err != nil {
return
}
return
return s, sqlutil.StatementList{
{&s.insertRelayServersStmt, insertRelayServersSQL},
{&s.selectRelayServersStmt, selectRelayServersSQL},
{&s.deleteRelayServersStmt, deleteRelayServersSQL},
{&s.deleteAllRelayServersStmt, deleteAllRelayServersSQL},
}.Prepare(db)
}
func (s *relayServersStatements) InsertRelayServers(

19
federationapi/storage/sqlite3/relay_servers_table.go
View file

@ -66,19 +66,12 @@ func NewSQLiteRelayServersTable(db *sql.DB) (s *relayServersStatements, err erro
return
}
if s.insertRelayServersStmt, err = db.Prepare(insertRelayServersSQL); err != nil {
return
}
if s.selectRelayServersStmt, err = db.Prepare(selectRelayServersSQL); err != nil {
return
}
if s.deleteRelayServersStmt, err = db.Prepare(deleteRelayServersSQL); err != nil {
return
}
if s.deleteAllRelayServersStmt, err = db.Prepare(deleteAllRelayServersSQL); err != nil {
return
}
return
return s, sqlutil.StatementList{
{&s.insertRelayServersStmt, insertRelayServersSQL},
{&s.selectRelayServersStmt, selectRelayServersSQL},
{&s.deleteRelayServersStmt, deleteRelayServersSQL},
{&s.deleteAllRelayServersStmt, deleteAllRelayServersSQL},
}.Prepare(db)
}
func (s *relayServersStatements) InsertRelayServers(