Fixed database models
This commit is contained in:
parent
e3fdb19411
commit
1f37a589cc
2
.gitignore
vendored
2
.gitignore
vendored
@ -105,7 +105,7 @@ celerybeat.pid
|
|||||||
*.sage.py
|
*.sage.py
|
||||||
|
|
||||||
# Environments
|
# Environments
|
||||||
.env
|
source/.env
|
||||||
.venv
|
.venv
|
||||||
env/
|
env/
|
||||||
venv/
|
venv/
|
||||||
|
@ -2,3 +2,4 @@ pyTelegramBotAPI~=4.5.0
|
|||||||
python-dotenv~=0.20.0
|
python-dotenv~=0.20.0
|
||||||
APScheduler~=3.9.1
|
APScheduler~=3.9.1
|
||||||
SQLAlchemy~=1.4.36
|
SQLAlchemy~=1.4.36
|
||||||
|
mysqlclient~=1.4.6
|
@ -1,3 +1,5 @@
|
|||||||
# Bot API
|
# Bot
|
||||||
BOT_API_KEY=
|
BOT_API_KEY=
|
||||||
|
|
||||||
|
# Database
|
||||||
DATABASE_CONNECTION=mysql://scott:tiger@localhost/foo'
|
DATABASE_CONNECTION=mysql://scott:tiger@localhost/foo'
|
@ -17,7 +17,7 @@ import telebot
|
|||||||
from dotenv import load_dotenv
|
from dotenv import load_dotenv
|
||||||
from telebot import types
|
from telebot import types
|
||||||
|
|
||||||
from source.db import User, session
|
from db import User, session
|
||||||
|
|
||||||
load_dotenv(dotenv_path='.env') # load environment variables
|
load_dotenv(dotenv_path='.env') # load environment variables
|
||||||
|
|
||||||
|
17
source/db.py
17
source/db.py
@ -6,11 +6,14 @@ __version__ = "1.0.0"
|
|||||||
|
|
||||||
import os
|
import os
|
||||||
|
|
||||||
|
from dotenv import load_dotenv
|
||||||
from sqlalchemy import Column, Integer, String, ForeignKey, create_engine, Boolean, DateTime, Float
|
from sqlalchemy import Column, Integer, String, ForeignKey, create_engine, Boolean, DateTime, Float
|
||||||
from sqlalchemy.ext.declarative import declarative_base
|
from sqlalchemy.ext.declarative import declarative_base
|
||||||
from sqlalchemy.orm import sessionmaker
|
from sqlalchemy.orm import sessionmaker
|
||||||
|
|
||||||
engine = create_engine(os.getenv("DATABASE_CONNECTION"), echo=True)
|
load_dotenv()
|
||||||
|
|
||||||
|
engine = create_engine(os.getenv("DATABASE_CONNECTION"))
|
||||||
|
|
||||||
Base = declarative_base()
|
Base = declarative_base()
|
||||||
|
|
||||||
@ -18,7 +21,7 @@ Base = declarative_base()
|
|||||||
class User(Base):
|
class User(Base):
|
||||||
__tablename__ = 'user'
|
__tablename__ = 'user'
|
||||||
telegram_id = Column(Integer, primary_key=True)
|
telegram_id = Column(Integer, primary_key=True)
|
||||||
username = Column(String)
|
username = Column(String(50))
|
||||||
admin = Column(Boolean)
|
admin = Column(Boolean)
|
||||||
|
|
||||||
def __repr__(self):
|
def __repr__(self):
|
||||||
@ -29,7 +32,7 @@ class Score(Base):
|
|||||||
__tablename__ = 'score'
|
__tablename__ = 'score'
|
||||||
telegram_id = Column(Integer, ForeignKey('user.telegram_id'), primary_key=True)
|
telegram_id = Column(Integer, ForeignKey('user.telegram_id'), primary_key=True)
|
||||||
date = Column(DateTime, primary_key=True)
|
date = Column(DateTime, primary_key=True)
|
||||||
product_id = Column(String, ForeignKey('product.product_id'))
|
product_id = Column(String(50), ForeignKey('product.product_id'))
|
||||||
guess = Column(Float)
|
guess = Column(Float)
|
||||||
score = Column(Integer)
|
score = Column(Integer)
|
||||||
|
|
||||||
@ -39,11 +42,11 @@ class Score(Base):
|
|||||||
|
|
||||||
class Product(Base):
|
class Product(Base):
|
||||||
__tablename__ = 'product'
|
__tablename__ = 'product'
|
||||||
product_id = Column(String, primary_key=True)
|
product_id = Column(String(50), primary_key=True)
|
||||||
price = Column(Float)
|
price = Column(Float)
|
||||||
image_link = Column(String)
|
image_link = Column(String(5000))
|
||||||
title = Column(String)
|
title = Column(String(5000))
|
||||||
description = Column(String)
|
description = Column(String(5000))
|
||||||
date = Column(DateTime)
|
date = Column(DateTime)
|
||||||
|
|
||||||
def __repr__(self):
|
def __repr__(self):
|
||||||
|
Loading…
Reference in New Issue
Block a user