aboutsummaryrefslogtreecommitdiff
path: root/roomserver/storage/postgres/event_json_table.go
diff options
context:
space:
mode:
Diffstat (limited to 'roomserver/storage/postgres/event_json_table.go')
-rw-r--r--roomserver/storage/postgres/event_json_table.go12
1 files changed, 7 insertions, 5 deletions
diff --git a/roomserver/storage/postgres/event_json_table.go b/roomserver/storage/postgres/event_json_table.go
index 8f11d1d8..e0976b12 100644
--- a/roomserver/storage/postgres/event_json_table.go
+++ b/roomserver/storage/postgres/event_json_table.go
@@ -59,12 +59,14 @@ type eventJSONStatements struct {
bulkSelectEventJSONStmt *sql.Stmt
}
-func NewPostgresEventJSONTable(db *sql.DB) (tables.EventJSON, error) {
- s := &eventJSONStatements{}
+func createEventJSONTable(db *sql.DB) error {
_, err := db.Exec(eventJSONSchema)
- if err != nil {
- return nil, err
- }
+ return err
+}
+
+func prepareEventJSONTable(db *sql.DB) (tables.EventJSON, error) {
+ s := &eventJSONStatements{}
+
return s, shared.StatementList{
{&s.insertEventJSONStmt, insertEventJSONSQL},
{&s.bulkSelectEventJSONStmt, bulkSelectEventJSONSQL},