From b188edd98dcf093ac7e404db76c519f1638ef6a4 Mon Sep 17 00:00:00 2001 From: Simple_Not <44047940+moonbaseDelta@users.noreply.github.com> Date: Sun, 21 Jan 2024 22:02:22 +1000 Subject: [PATCH] =?UTF-8?q?#7=20=D1=83=D0=B1=D0=B8=D1=80=D0=B0=D1=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- handlers/pipisa.py | 1 - handlers/sendalarm.py | 9 ++----- sqdb.py | 56 ------------------------------------------- 3 files changed, 2 insertions(+), 64 deletions(-) delete mode 100644 sqdb.py diff --git a/handlers/pipisa.py b/handlers/pipisa.py index b8360ae..d54e460 100644 --- a/handlers/pipisa.py +++ b/handlers/pipisa.py @@ -1,5 +1,4 @@ from aiogram import types, Dispatcher -#from sqlalchemy.orm.session import close_all_sessions from create_bot import bot, dp #from sqdb import user, session import random diff --git a/handlers/sendalarm.py b/handlers/sendalarm.py index 46b4811..9869eb9 100644 --- a/handlers/sendalarm.py +++ b/handlers/sendalarm.py @@ -1,9 +1,6 @@ from create_bot import dp, bot from aiogram import types, Dispatcher -from sqdb import user, session - - @dp.message_handler(commands=['sendall']) async def sendall(message: types.Message): @@ -19,10 +16,8 @@ async def sendall(message: types.Message): except: print('вероятно бота нет в чате') await bot.send_message(message.from_user.id, 'Сообщение успешно отправлено во все чаты') - except: - session.rollback() - print('eror sendall') - finally: session.close_all() + except: + print('eror sendall') # def register_handlers_test(dp: Dispatcher): diff --git a/sqdb.py b/sqdb.py deleted file mode 100644 index c4b169d..0000000 --- a/sqdb.py +++ /dev/null @@ -1,56 +0,0 @@ -from sqlalchemy import create_engine, MetaData, Table, Integer, String, BIGINT, \ - Column, DateTime, ForeignKey, Numeric -from sqlalchemy.ext.declarative import declarative_base -from sqlalchemy.orm import sessionmaker -from sqlalchemy import select, update - -engine = create_engine('postgresql+psycopg2://postgres:postgres@postgres.vdk2ch.ru:5432/jack_bot', echo=True) -Session = sessionmaker(bind=engine) -session = Session() - - - -Base = declarative_base() - - - -class user(Base): - __tablename__ = 'users' - - id = Column(Integer, primary_key=True) - user_id = Column(Integer) - user_fullname = Column(String) - dick_size = (Column(Integer)) - datetimes = (Column(DateTime)) - chat_id = Column(BIGINT) - - - - - -session.close() -engine.dispose() -# top = session.query(user.user_fullname, user.dick_size).order_by(user.dick_size.desc()).filter(user.chat_id == user.chat_id).limit(10).all() -# print(top) - - -#Base.metadata.create_all(engine) - -# int_table = user(user_id = 12345678, user_fullname = 'test', dick_size = 10) #импортирую юзер из sqdb -# session.add(int_table) -# session.commit() -# select user_id, name from employees limit 10 - -# def adding(): - -# session.add() -# session.commit() - - - - - - - - -