Как подключиться к mysql базе паралельно на питоне?

Question

[zyusifov11]

Вопрос такой вопрос есть 2 программы которые параллельно работают с 1 базой библиотека import mysql.connector
как я понят база не дает доступа программе когда к ней подключена другая программа.
Подключаюсь я так:

db = mysql.connector.connect(
	host='localhost',
	user=config.user,
	passwd=config.password,
)
cursor = db.cursor()

Comments

[Tim]

создай другого пользователя

Answer 1

[aleks-th]

Сделай разных пользователей в MySQL

Comments

[zyusifov11]

не работает, точнее так в цикле программа проверяет изменение в базе но даже если они есть она их не видит а показывает старое значение которое было при запуска скрипта

[aleks-th]

Должно все работать.
С одной базой могут работать тыщи юзеров одновременно.
И Мускулю плевать на то сколько программ одну базу юзают.

[aleks-th]

Ты базу закрываешь после обращения с первой программы ?
Хотя говорят что енто не обязательно , типо само закроется.
Перед тем как считывать данные из нее ?

[zyusifov11]

aleks-th, нет там цикл именно об этом подумал если закрыл базу надо открывать заново и писать пароль и т.д или какойто командой открыть без записи кажный раз пароля и т.д

[zyusifov11]

да и кстати писать db.close() или cursor.close()?

[aleks-th]

Неа ты открыл базу, записал данные потом закрыл.
А если у тебя скрипт работает то вполне возможно когда считываешь записи то они еще не в базе а в скрипте который исполняется.

db.close() вроде бы

[zyusifov11]

aleks-th, я понял закрыть то легко db.close() а вот чтоб дальше в коде открыть надо заново писать пользователь пароль хост ? или можно уже к начальному обратится и открыть? и еще в базе у меня уже отображаются изменения а скрипт циклами показывает одно и тоже начальное значение

[aleks-th]

Но хотя ... cursor.close() закрывает объект не закрывая базу может его и достаточно чтобы все в базу попало

[zyusifov11]

aleks-th, я чет конкретно туплю или все же где-то ошибка

cursor = db.cursor()
sql = f"SELECT `price` FROM `statistic` WHERE `name` = '{name}'"
cursor.execute(sql)
res = cursor.fetchone()
cursor.close()

[aleks-th]

Скрипт как только взял объект из базы, работает с этим объектом.
Возможно нужно закрыть его.
А потом снова взять объект из базы, с уже обновленными значениями.
--
Если значения в базе уже есть то они должны из нее выбиратся.
Если не выбираются значит тот скрипт который читает их не считал.
Или считал ранее.
И не обновил.

[aleks-th]

zyusifov11,

Может так ?

cursor = connection.cursor()
cursor.execute(sql)
res= cursor.fetchone()

[o5a]

zyusifov11, а после изменений в базе не забываете коммит делать, чтобы они сохранились? В примерах про коммит ни разу не упомянули.
connection.commit()

[zyusifov11]

o5a, понимаете я написал коммит я же говорю я в базе то вижу изменения а 2 ой бот показывает каждый цикл значения которые были при 1 ом подключении

[zyusifov11]

главная проблема в том что когда запущенна 1 программа 2 рая дает mysql ошибку и наоборот а в одиночку все норм работает так вот как я понял надо закрывать базу при каждом обращении к ней можете в дефаултном коде показать как это правильно сделать

[zyusifov11]

можете обьяснить надо connection.close() или cursor.close()

[zyusifov11]

Dr. Bacon, я пишу

cursor = db.cursor()
cursor.execute(sql)
cursore.close()

и если это цикл то уже на 2 ой итерации пишет что mysql не получилось подключиться

[zyusifov11]

Dr. Bacon, Failed parsing column information
MySQL Connection not available.

[zyusifov11]

Dr. Bacon, сделал как вы сказали
Traceback (most recent call last):
File "C:\Users\zaman\AppData\Local\Programs\Python\Python38\lib\threading.py", line 932, in _bootstrap_inner
self.run()
File "C:\Users\zaman\AppData\Local\Programs\Python\Python38\lib\threading.py", line 870, in run
self._target(*self._args, **self._kwargs)
File "C:\Users\zaman\Desktop\analize bott\bot.py", line 87, in trading
cursor.execute(sql)
File "C:\Users\zaman\AppData\Local\Programs\Python\Python38\lib\site-packages\mysql\connector\cursor.py", line 577, in execute
self._handle_result(self._connection.cmd_query(stmt))
File "C:\Users\zaman\AppData\Local\Programs\Python\Python38\lib\site-packages\mysql\connector\connection.py", line 695, in cmd_query
result = self._handle_result(self._send_cmd(ServerCmd.QUERY, query))
File "C:\Users\zaman\AppData\Local\Programs\Python\Python38\lib\site-packages\mysql\connector\connection.py", line 591, in _handle_result
self._columns_desc[i] = self._protocol.parse_column(
File "C:\Users\zaman\AppData\Local\Programs\Python\Python38\lib\site-packages\mysql\connector\protocol.py", line 272, in parse_column
(packet, _) = utils.read_lc_string(packet) # db
File "C:\Users\zaman\AppData\Local\Programs\Python\Python38\lib\site-packages\mysql\connector\utils.py", line 211, in read_lc_string
if buf[0] == 251: # \xfb
IndexError: bytearray index out of range

[zyusifov11]

да. проблема не в этом у меня вопрос если работаю с базой с 2х программ как надо соеденятся с ней чтоб оба могли подключится