You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
90 lines
2.6 KiB
90 lines
2.6 KiB
package allin.data.postgres
|
|
|
|
import allin.data.AllInDataSource
|
|
import allin.data.BetDataSource
|
|
import allin.data.ParticipationDataSource
|
|
import allin.data.UserDataSource
|
|
import allin.utils.Execute
|
|
import org.ktorm.database.Database
|
|
|
|
class PostgresDataSource : AllInDataSource() {
|
|
|
|
private val database: Database
|
|
|
|
init {
|
|
val dbDatabase = System.getenv()["POSTGRES_DB"]
|
|
val dbUser = System.getenv()["POSTGRES_USER"]
|
|
val dbPassword = System.getenv()["POSTGRES_PASSWORD"]
|
|
val dbHost = System.getenv()["POSTGRES_HOST"]
|
|
|
|
database = Database.connect(
|
|
url = "jdbc:postgresql://$dbHost/$dbDatabase",
|
|
user = dbUser,
|
|
password = dbPassword
|
|
)
|
|
|
|
database.Execute(
|
|
"""
|
|
CREATE TABLE IF not exists utilisateur (
|
|
id uuid PRIMARY KEY,
|
|
username VARCHAR(255),
|
|
password VARCHAR(255),
|
|
coins double precision,
|
|
email VARCHAR(255),
|
|
lastgift timestamp
|
|
)
|
|
""".trimIndent()
|
|
)
|
|
|
|
database.Execute(
|
|
"""
|
|
CREATE TABLE IF not exists bet (
|
|
id uuid PRIMARY KEY,
|
|
theme VARCHAR(255),
|
|
endregistration timestamp,
|
|
endbet timestamp,
|
|
sentencebet varchar(500),
|
|
isprivate boolean,
|
|
createdby varchar(250),
|
|
status varchar(20),
|
|
type varchar(20)
|
|
)
|
|
""".trimIndent()
|
|
)
|
|
|
|
database.Execute(
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS betresult (
|
|
betid uuid PRIMARY KEY REFERENCES bet,
|
|
result varchar(250),
|
|
)
|
|
""".trimIndent()
|
|
)
|
|
|
|
database.Execute(
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS participation (
|
|
id uuid PRIMARY KEY,
|
|
bet uuid,
|
|
username varchar(250),
|
|
answer varchar(250),
|
|
stake int
|
|
)
|
|
""".trimIndent()
|
|
)
|
|
|
|
database.Execute(
|
|
"""
|
|
CREATE TABLE IF NOT EXISTS response (
|
|
id UUID,
|
|
response VARCHAR(250),
|
|
CONSTRAINT pk_response_id PRIMARY KEY (id,response)
|
|
)
|
|
""".trimIndent()
|
|
)
|
|
}
|
|
|
|
override val userDataSource: UserDataSource = PostgresUserDataSource(database)
|
|
override val betDataSource: BetDataSource = PostgresBetDataSource(database)
|
|
override val participationDataSource: ParticipationDataSource = PostgresParticipationDataSource(database)
|
|
} |