Почему у меня после Update, Select возвращает старые данные?

Question

[re-incarnation]

code send message

//session /ответ
lp.MessageNew(func(_ context.Context, obj events.MessageNewObject) {
			msg := obj.Message.Text
			//prefix
			startWith := "/ответ"
			//check prefix
			starts := strings.HasPrefix(msg, startWith)
			if starts == true {
				//trim message
				res_trim := strings.Trim(msg, "/ответ ")
				//check empty text
				if res_trim != "" {
					//search note in table where asker -> answer = ask_id
					res_search_active_ask, err100 := db.Query(fmt.Sprintf("SELECT `asker`, `answer`, `closed` FROM `ucp` WHERE `closed` = '0' AND (`asker` = '%d' OR `answer` = '%d')", msg_from_id))
					if err100 != nil {
						panic(err100)
					}
					for res_search_active_ask.Next(){
						err := res_search_active_ask.Scan(&ucp.Asker, &ucp.Answer, &ucp.Closed)
						if err != nil {
							panic(err)
						}
					}
					if ucp.Closed == 0 {
					if msg_from_id == ucp.Answer {
						session_message_redirect, err11 := vk.MessagesSend(api.Params{
							"peer_id": ucp.Asker,
							"random_id": 0,
							"message": assistant + res_trim,
						})
						//err check
						if err11 != nil {
							panic(err11)
						}
								spew.Dump(session_message_redirect)
					}else{
						session_message_redirect2, err112 := vk.MessagesSend(api.Params{
							"peer_id": msg_from_id,
							"random_id": 0,
							"message": error_assistant_havent_ask,
						})
						//err check
						if err112 != nil {
							panic(err112)
						}
								spew.Dump(session_message_redirect2)
					}
				}else{
						session_message_redirect3, err1123 := vk.MessagesSend(api.Params{
							"peer_id": msg_from_id,
							"random_id": 0,
							"message": error_user_havent_ask,
						})
						//err check
						if err1123 != nil {
							panic(err1123)
						}
								spew.Dump(session_message_redirect3)
				}
}
}
})

code close session

//close ask
	lp.MessageNew(func(_ context.Context, obj events.MessageNewObject) {
			msg := obj.Message.Text
			//prefix
			startWith := "/close"
			//cheack prefix
			starts := strings.HasPrefix(msg, startWith)
			if starts == true {
				//trim message
				res_trim := strings.Trim(msg, "/close ")
				//cheack empty text
				if res_trim != "" {
					res_answer_active_status, err35 := db.Query(fmt.Sprintf("SELECT `answer`, `asker`, `closed` FROM `ucp` WHERE `closed` = '0' AND (`answer` = '%d' OR `asker` = '%d')", msg_from_id))
					if err35 != nil {
						panic(err35)
					}
					for res_answer_active_status.Next() {
						err36 := res_answer_active_status.Scan(&ucp.Answer, &ucp.Asker, &ucp.Closed)
						if err36 != nil {
							panic(err36)
						}
					}
					if ucp.Closed == 0 {
					if msg_from_id == ucp.Answer || msg_from_id == ucp.Asker {
						//revers string to int for req
					 res_trim_int, err34 := strconv.Atoi(res_trim)
					 if err34 != nil {
						 panic(err34)
					 }
										// update answer id
					update_answer_id_start, err33 := db.Query(fmt.Sprintf("UPDATE `ucp` SET `closed` = '1' WHERE `id` = '%d'", res_trim_int))
					if err33 != nil {
						panic(err33)
					}
					defer update_answer_id_start.Close()
					//send message
					send, err := vk.MessagesSend(api.Params{
						"peer_id": msg_from_id,
						"random_id": 0,
						"message": closed_ask + res_trim,
					})

					if err != nil {
						panic(err)
					}
					spew.Dump(send)
					spew.Dump(update_answer_id_start)
					}else{
						send, err := vk.MessagesSend(api.Params{
							"peer_id": msg_from_id,
							"random_id": 0,
							"message": "ERROR: You havenot active ask.",
						})

						if err != nil {
							panic(err)
						}
						spew.Dump(send)
					}
				}else{
					session_message_redirect3, err1123 := vk.MessagesSend(api.Params{
						"peer_id": msg_from_id,
						"random_id": 0,
						"message": error_user_havent_ask,
					})
					//err check
					if err1123 != nil {
						panic(err1123)
					}
							spew.Dump(session_message_redirect3)
				}
				}
			}
	})

Суть моего кода - приходит вопрос в личные сообщения сообществу, после оно переотправляется в беседу вк, и в беседе операторы поддержки берут его, и уже общаются, проще говоря чат бот, но когда "сессия" закрывается командой /close ID, данные вносятся в бд, всё хорошо, но "сессия" не обновляется, и возвращает что этот вопрос открыт, но в базе запись о том что он закрылся есть. Всё нормализуется когда я останавливаю бота, и после запускаю заново, и так по кругу.

Answer 1

[Евгений Мамонов]

Проблема в этом участке, Query используется для извлечения данных, для изменения надо использовать Exec

update_answer_id_start, err33 := db.Query(fmt.Sprintf("UPDATE `ucp` SET `closed` = '1' WHERE `id` = '%d'", res_trim_int))
defer update_answer_id_start.Close()

Например вот так

update_answer_id_start, err33 := db.Exec("UPDATE `ucp` SET `closed` = '1' WHERE `id` = ?", res_trim_int)

Comments

[re-incarnation]

Понял, спасибо) Потерялся немного в коде)

[Евгений Мамонов]

Думаю нумерация ошибок приносит вам не мало головной боли, большого смысла нет так делать, можно почти везде писать просто err. Отдельные переменные есть смысл заводить если вам они нужны для дальнейшей обработки, а если вы её проверяет всего один раз и сразу после вызова функции - я бы везде писал err :)

Еще обратите внимание на то, что я убрал из запроса Sprintf, и использовал подход с правильной подстановкой данных. Запросы c Query тоже надо изменить.

db.Query("SELECT `answer`, `asker`, `closed` FROM `ucp` WHERE `closed` = '0' AND (`answer` = '? OR `asker` = ?)", ansewr, asker)

Подход со Sprintf очень опасен в этом случае, т.к. для строковых переменных можно сделать SQL инъекцию.

[Евгений Мамонов]

рад помочь :))
иногда ошибку трудно найти, взгляд со стороны, в этом плане, хорошо работает ))

[re-incarnation]

Евгений Мамонов, Спасибо за помощь)

[re-incarnation]

Евгений Мамонов, ошибка была походу не в этом... бот как принимал сообщения на закрытый вопрос, так и принимает, но ПОСЛЕ перезапуска бота, он видит что вопрос закрыт, и говорит об этом. Как я понимаю, в моём случае нужно получать информацию о вопросе из бд, и тогда бы он видил её изменения, но у меня в принципе по идеи так и сделано...

[Евгений Мамонов]

Какая задача стоит?
При получении сообщения нужно проверить открыт ли вопрос и, если нет - ответить, что вопрос закрыт?

[re-incarnation]

Евгений Мамонов, задача всего проекта:
Ассистент чат бот.
Когда пишешь боту /ask TEXT он переотправляет его в беседу ассистентов, и там когда один из ассистентов пишет /take ID, он берёт этот вопрос, после они общаются через бота способом /ответ / /вопрос, когда кто-то из участников диалога пишет /close ID, вносится запись в бд, что данный вопрос закрыт, и после этого когда кто-то из участников прошедшего диалога напишет /ответ / /вопрос ему бот выдаст ошибку. У меня всё кроме /close id работает. Мой аналог "сессии" почему-то не реагирует на смену записи в бд, что вопрос закрыт, но реагирует на него только после перезапуска. Думаю да, мне нужно что бы при получении сообщения проверялось открыт вопрос или нет, но у меня это и так сделано, но почему-то не работает))) :

код проверки

lp.MessageNew(func(_ context.Context, obj events.MessageNewObject) {
msg := obj.Message.Text
msg_from_id := obj.Message.FromID
startWith := "/close"
starts := strings.HasPrefix(msg, startWith)
if starts == true {
	res_trim := strings.Trim(msg, "/close ")
	if res_trim != "" {
		res_answer_active_status, err35 := db.Query("SELECT `answer`, `asker`, `closed` FROM `ucp` WHERE `closed` = '0' AND (`answer` = ? OR `asker` = ?)", msg_from_id, msg_from_id)
		if err35 != nil {
			panic(err35)
		}
		for res_answer_active_status.Next() {
			err36 := res_answer_active_status.Scan(&ucp.Answer, &ucp.Asker, &ucp.Closed)
			if err36 != nil {
				panic(err36)
			}
		}
		if ucp.Closed == 0 {
		//////////обработка сообщения
		}
	}
	}
		)}

[Евгений Мамонов]

Давайте начнём с того, что убедимся в настройках MySQL.
У вас же MySQL, я не ошибся?
Есть подозрения, что сохранение не отрабатывает из-за специфических настроек Isolation Level.

Добавьте в строку подключения параметр &sql_mode=TRADITIONAL
Т.е. ваш DSN должен выглядеть примерно так

"login:pass@tcp(localhost)/dbname?charset=utf8&sql_mode=TRADITIONAL"

Или вот так чтобы даты парсились сразу и работали emoji:

"login:pass@tcp(localhost)/dbname?charset=utf8mb4&collation=utf8mb4_unicode_ci&parseTime=true&sql_mode=TRADITIONAL"

Этот вариант на будущее, сейчас только просто добавьте sql_mode=TRADITIONAL

[re-incarnation]

Евгений Мамонов, всё так же продолжает игнорировать изменение в бд :(
UPD: Да, у меня MySQL

[Евгений Мамонов]

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

res_answer_active_status, err35 := db.Query("SELECT `answer`, `asker`, `closed` FROM `ucp` WHERE `closed` = '0' AND (`answer` = ? OR `asker` = ?)", msg_from_id, msg_from_id)
if err35 != nil {
    panic(err35)
}

for res_answer_active_status.Next() {
    err36 := res_answer_active_status.Scan(&ucp.Answer, &ucp.Asker, &ucp.Closed)
    if err36 != nil {
        panic(err36)
    }
    // TODO: добавьте вот тут spew.Dump
    fmt.Println("Got new row from database")
    spew.Dump(ucp)      
}

Покажите вывод при воспроизведении проблемы.

[re-incarnation]

Евгений Мамонов, вывод что он открыт.

(main.Ucp) {
 Id: (int) 59,
 Text: (string) (len=13) "tetatettttt/.",
 Closed: (int) 0,
 Asker: (int) 380236476,
 Answer: (int) 380236476
}

UPD: Ну возвращает он правильно, он берёт нужную запись, но после закрытия этой записи (

update code

update_answer_id_start, err33 := db.Exec("UPDATE `ucp` SET `closed` = '1' WHERE `id` = ?", res_trim_int)

) он всё так же возвращает closed = 0, но в бд запись closed = 1.

[Евгений Мамонов]

Отлично, теперь нужно убедиться, что всё отрабатывает в нужной последовательности.
Добавьте перед db.Exec
log.Printf("Close item: %v\n", res_trim_int)
И перед всеми Query

log.Printf("Query item (/close): %v\n", msg_from_id)
...
log.Printf("Query item (/ask): %v\n", msg_from_id)

Важно убедиться, что Update отрабатывает раньше, Select ну и за одно посмотрим какие и в какой последовательности срабатывают запросы

[re-incarnation]

Евгений Мамонов, всё срабатывает по мере установленных тригеров)
Сначала Select для проверки на "сессию", ну а после доп тригеров update

[Евгений Мамонов]

Покажите вывод, надо посмотреть :)
Иногда всплывает вариант, который мы не учитываем при проектировании/разработке.
Просто судя по участкам кода, которые вы показываете - я не вижу явной ошибки, надо понять что не так.
Когда не ясно где ошибка - остаётся только отлаживать код и проверять так ли всё работает, как мы того ожидаем.
Еще, как вариант, ниже Update добавьте Select с spew.Dump результата, тоже будет не лишним посмотреть.

[Евгений Мамонов]

Если Select сразу после Update не вернёт то, что нужно - это даст понимание того, что явно что-то не так на участке драйвера/настройки базы, а не в логике работы приложения.
Выглядит так, как будто бы Commit не делается.

[re-incarnation]

Евгений Мамонов, Вывод select после update
просто символов не хватает для отправки)

[re-incarnation]

Евгений Мамонов, лог принт перед запросами

[Евгений Мамонов]

Это очень большой вывод, я скорее имел ввиду вот такое

// тут Update
// тут Select
// потом Scan результатов Select'a
for res_answer_active_status.Next() {
    err36 := res_answer_active_status.Scan(&ucp.Answer, &ucp.Asker, &ucp.Closed)
    if err36 != nil {
        panic(err36)
    }
    // и вывод результата
    fmt.Println("Got new row from database")
    spew.Dump(ucp)      
}

Мне нужно отлучиться, сегодня смогу ответить уже ближе к ночи или завтра.

[Евгений Мамонов]

Сделайте вот такой вариант + добавьте такое же после всех селектов + сообщения с временем, чтобы можно было проверить последовательность вызовов, я как будет возможность посмотрю и подумаем как эту проблему решить

[re-incarnation]

Евгений Мамонов, порядок выполнения запросов, код, и т.д.

[Евгений Мамонов]

Была возможность бегло посмотреть код.
По хорошему его надо отрефакторить, там много чего в коде нужно сделать иначе, чтобы с ним можно было нормально работать и проще отлаживать.
Возможно у меня завтра будет окно, у вас завтра как со временем?

[re-incarnation]

Евгений Мамонов, я всегда свободен, пишите в любое время, отвечу как увижу комментарий)

[Евгений Мамонов]

получилось привести оставшиеся функции к тому виду, что на звонке сделали?