Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def isNewUser(msg):
- status = False
- try:
- mysql_info.debug('Подключение к базе')
- connection = pymysql.connect(
- host = config.mysql_host,
- user = config.mysql_user,
- password = config.mysql_password,
- db = config.mysql_db,
- charset = 'utf8mb4',
- cursorclass = pymysql.cursors.DictCursor,
- autocommit = True
- )
- mysql_info.debug('Подключение успешно')
- with connection.cursor as cursor:
- mysql_info.debug('Поиск пользователя в базе')
- findUserSQL = 'SELECT * FROM players WHERE userID = {}'.format(msg.chat.id)
- cursor.execute(findUserSQL)
- findUserSQLResult = cursor.fetchone()
- if findUserSQLResult == None:
- mysql_info.debug('Пользователь не найден. Регистрация')
- status = True
- currTime = curr_time_db()
- addUserSQL = 'INSERT INTO users (userID, username) VALUES ("{}","{}")'.format(msg.chat.id, msg.from_user.username)
- cursor.execute(addUserSQL)
- except Exception as e:
- logging.exception('Error: ')
- finally:
- mysql_info.debug('Закрытие соединения')
- connection.close()
- mysql_info.debug('Соединение закрыто')
- return status
Add Comment
Please, Sign In to add comment