31 lines
601 B
Go
31 lines
601 B
Go
package scylla
|
|
|
|
import "github.com/scylladb/gocqlx/v2"
|
|
|
|
func Seed(session gocqlx.Session) error {
|
|
err := session.ExecStmt(`
|
|
CREATE KEYSPACE IF NOT EXISTS chat_service
|
|
WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1}`)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
err = session.ExecStmt(`
|
|
CREATE TABLE IF NOT EXISTS chat_service.messages (
|
|
message_id bigint,
|
|
from_user_id bigint,
|
|
from_user text,
|
|
to_user_id bigint,
|
|
to_user text,
|
|
content text,
|
|
created_at timestamp,
|
|
PRIMARY KEY (to_user_id, message_id)
|
|
)`)
|
|
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|