Добрый время суток. Только начал изучать многопоточность, сейчас мне нужно делать INSERT в одну таблицу большим количеством потоков, так как очень большой объем данных. Использую Lazarus, SQL server 2014, прочитал что нужно создавать для каждого потока свои компоненты подключения и прочитал вики страницу по использованию потоков по паскалю.
После этого сделал 2 потока и из метода Execute только вызываю одну и туже процедуру в которой идет обработка строк, создаются динамически компоненты подключения, в потоках указана 1 процедура в которой частями получаются данные с стороннего сервера, обрабатываются строки, происходит вставка INSERT SQL. В результате получаю ошибку RUNTIME 204, когда 1 поток, то все работает нормально. В процедуре вставки есть еще локальные строковые переменные процедуры (для будущей вставки) которые копируются из огромной строки и они в потоках не пересекаются, но SQL Insert дает сбой при 2 потоках и более. Привожу код, что мне надо сделать чтобы исправить ситуацию? Прошу ссылки на примеры использования баз данных в потоках и\или конкретные советы по задаче. Как правильно использовать переменные и компоненты в потоках - должны быть уникальные имена компонентов или 2 потока могут ссылаться на одну и туже внешнюю процедуру и данные не будут сбиваться (пример что будет если 2 потока ссылаюся на процедуру с sql_db:=tsqlquery.create(self) с разными запросами - будет ли это корректно работать? Потоки в программе только вставляют данные в одну таблицу, с интерфейсом не соприкасаются.
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
procedure Mythread.Execute;
begin
form1.GET_MAAINDATA('250','0','1');
end;
procedure Mythread2.Execute;
begin
form1.GET_MAAINDATA('500','250','2');
end;
procedure TForm1.GET_MAAINDATA(limit,offset,numpotok:string);
begin
//ПОЛУЧИЛ СОРС СТРАНИЦЫ С ИНТЕРНЕТА
temp:=PChar(HTTPs.Document.Memory);
while pos(',{"uuid"',temp)<>0 do
begin
get_main_data2(copy(temp,1,pos(',{"uuid"',temp)-1));
delete(temp,1,pos(',{"uuid"',temp)+9);
end;
end;
function TForm1.get_main_data2(input:string):string;
var
SQL_Database:tsqlconnector;
SQL_Transaction:tsqlTransaction;
SQL_Query:tsqlquery;
SQL_Datasource:tDatasource;
//СТРОКОВЫЕ ПЕРЕМЕННЫЕ ДЛЯ ОБРАБОТКИ
begin
SQL_Database:=tsqlconnector.Create(self);
SQL_Transaction:=tsqlTransaction.Create(self);
SQL_Datasource:=tDatasource.Create(self);
SQL_Query:=tsqlquery.Create(self);
SQL_Database.connectortype:='MSSQLServer';
SQL_Database.DatabaseName:='test';
SQL_Database.HostName:='хост';
SQL_Database.username:='пользователь';
SQL_Database.password:='пароль';
SQL_Database.Transaction:=SQL_Transaction;
SQL_Transaction.database:=SQL_Database;
SQL_Query.database:=SQL_Database;
SQL_Query.Transaction:=SQL_Transaction;
SQL_Query.PacketRecords:=-1;
SQL_Datasource.dataset:=SQL_Query;
SQL_Database.connected:=true;
//ОБРАБОТКА СТРОК
//SQL INSERT ВСТАВКА СТРОК В ТАБЛИЦУ
end;
