МногоПоток. Исключаем параллельное использование данных. (MySQL)

ShikoFess сказал(а):

А почему бы просто не сделать поле status, присвоить ему по умолчанию 0. Брать только WHERE status=0 и присваивать забранному аккаунту status = 1. Ты никак не возмешь этот же аккаунт в многопотоке

Нажмите, чтобы раскрыть...

AleXPrischepA сказал(а):

Jeronimo про

Согласен... , про блокировку и c# слышал, знаю... Но нужно знание c#, коих у меня маловато..., а стандартными кубиками блокировки нет, в рамках одного подключения к БД, два и более запроса не выполнить.

Нажмите, чтобы раскрыть...

AleXPrischepA сказал(а):

Согласен... , про блокировку и c# слышал, знаю... Но нужно знание c#, коих у меня маловато..., а стандартными кубиками блокировки нет, в рамках одного подключения к БД, два и более запроса не выполнить.

Нажмите, чтобы раскрыть...

AleXPrischepA сказал(а):

Согласен... , про блокировку и c# слышал, знаю... Но нужно знание c#, коих у меня маловато..., а стандартными кубиками блокировки нет, в рамках одного подключения к БД, два и более запроса не выполнить.

Нажмите, чтобы раскрыть...

project.Variables["username"].Value = null; //не обязательно!!! Только для обнуления переменной, если не перезапускаете шаблон полностью

Sql sqlConn = new Sql(project); //Подключаемся к БД
var cmd = sqlConn.Cmd();
cmd.Connection.Open(); //открываем сессию
cmd.DbLock("" + project.Variables["bd_tableName"].Value + " WRITE"); //Блокируем таблицу

var reader = cmd.ExReader(String.Format("SELECT username FROM "+ project.Variables["bd_tableName"].Value +" WHERE STATUS='free' LIMIT 1;")); //Получаем username аккаунта, подходящего по условиям запроса.

if(reader.HasRows) //проверяем имеются ли данные в ответе. Если имеются, то переходим к считыванию
{
    while (reader.Read()) // построчно в цикле (while) считываем данные. Получим максимум 1 строку, т.к. в запросе стоит LIMIT 1
    {
        string dbUsername = reader["username"].ToString(); //получаем задание. В нашем случае это ссылка для парсинга.
        project.Variables["username"].Value = dbUsername; //сохраняем link в переменную зеннопостера
    }
}
reader.Close();

//Обновление статуса. Выполняется только если было получено задание (если id не пустое!)
if(!string.IsNullOrEmpty(project.Variables["username"].Value))
{
    //после получения задания необходимо поменять статус задания, чтобы другие потоки больше его не видели после разблокировки таблицы
    cmd.ExNonQ(String.Format("UPDATE "+ project.Variables["bd_tableName"].Value +" SET status='busy' WHERE username= '" + project.Variables["username"].Value + "';"));
}
    
cmd.DbUnLock(); //разблокировка всех таблиц
cmd.Connection.Close(); //закрываем сессию

Jeronimo сказал(а):

Честно говоря, и я не знаток c#. Лет 5 назад мне за 20$ написали кусочек кода, который юзаю по сей день.
Готов поделиться им с комьюнити бесплатно:

Спойлер

C#:

project.Variables["username"].Value = null; //не обязательно!!! Только для обнуления переменной, если не перезапускаете шаблон полностью

Sql sqlConn = new Sql(project); //Подключаемся к БД
var cmd = sqlConn.Cmd();
cmd.Connection.Open(); //открываем сессию
cmd.DbLock("" + project.Variables["bd_tableName"].Value + " WRITE"); //Блокируем таблицу

var reader = cmd.ExReader(String.Format("SELECT username FROM "+ project.Variables["bd_tableName"].Value +" WHERE STATUS='free' LIMIT 1;")); //Получаем username аккаунта, подходящего по условиям запроса.

if(reader.HasRows) //проверяем имеются ли данные в ответе. Если имеются, то переходим к считыванию
{
    while (reader.Read()) // построчно в цикле (while) считываем данные. Получим максимум 1 строку, т.к. в запросе стоит LIMIT 1
    {
        string dbUsername = reader["username"].ToString(); //получаем задание. В нашем случае это ссылка для парсинга.
        project.Variables["username"].Value = dbUsername; //сохраняем link в переменную зеннопостера
    }
}
reader.Close();

//Обновление статуса. Выполняется только если было получено задание (если id не пустое!)
if(!string.IsNullOrEmpty(project.Variables["username"].Value))
{
    //после получения задания необходимо поменять статус задания, чтобы другие потоки больше его не видели после разблокировки таблицы
    cmd.ExNonQ(String.Format("UPDATE "+ project.Variables["bd_tableName"].Value +" SET status='busy' WHERE username= '" + project.Variables["username"].Value + "';"));
}
   
cmd.DbUnLock(); //разблокировка всех таблиц
cmd.Connection.Close(); //закрываем сессию

Нажмите, чтобы раскрыть...

WebBot сказал(а):

Все это делается в два запроса, без всяких блокировок таблиц и прочих танцев с бубном

первый запрос меняет статус строки .. при UPDATE происходит автоматическая блокировка на уровне строк таблицы (не всей таблицы, а только строки которая апдейтиться), поэтому 1 и ту же строку не могут апдейтить одновременно несколько потоков, а после апдейта и разблокировки строки она уже не будет подходить по параметрам ( status уже будет не 0 )

UPDATE tbl SET id=LAST_INSERT_ID(id), status=1 WHERE status=0 LIMIT 1

следующей функцией получаем id той строки статус которой был изменен

SELECT LAST_INSERT_ID()

такое работает если нужно что бы каждый поток брал 1 строку ... и UPDATE и SELECT должны выполняться в одной сессии

Нажмите, чтобы раскрыть...

AleXPrischepA сказал(а):

Благодарю за наводку...

Нажмите, чтобы раскрыть...

Petr_G сказал(а):

И open server совсем не нужен! Mysql прекрасно ставится на windows.

Нажмите, чтобы раскрыть...

marushin сказал(а):

быкапы только через сам мускул

Нажмите, чтобы раскрыть...