Объединить запрос к нескольким таблицам в один (php+MySql)

[mv28jam]

1)http://ru2.php.net/manual/en/function.fgetcsv.php
2)Всё это нужно "упаковать" в один скрипт
3)файл должен быть там где будет выполняться скрипт(те там где стоит клиент)
4)Ключ лучше составить из существующих полей, а не добавлять новый. Я просто так до конца и не понял какие значения у вас уникальны. Вообщем если у вас есть номер артикула постащика, который для него уникален, чтобы ключ в таблице был уникаден для всех поставщиков достаточно сделать составной ключ: артикул поставщика + название поставщика. revision в ключ включать не надо, он нам нужен только для очистки старых значений, которые не будут заменены при LOAD DATA.

[Maxx]

Уважаемый mv28jam, у меня опять затык

<form action="" method="post">
<select name="vendor">
<option name="vendor" value="" selected></option>
<option name="vendor" value="v1">Поставщик1</option>
<option name="vendor" value="v2">Поставщик2</option>
<option name="vendor" value="v3">Поставщик3</option>
<option name="vendor" value="v4">Поставщик4</option>
<option name="vendor" value="v5">Поставщик5</option>
<option name="vendor" value="v6">Поставщик6</option>
<option name="vendor" value="v7">Поставщик7</option>
<option name="vendor" value="v8">Поставщик8</option>
<option name="vendor" value="v9">Поставщик9</option>
<option name="vendor" value="v10">Поставщик10</option>
<option name="vendor" value="v11">Поставщик11</option>
<option name="vendor" value="v12">Поставщик12</option>
<option name="vendor" value="v13">Поставщик13</option>
</select>
<input type="submit" value="Start update">
</form>

<?php
if (isset($_POST['vendor']) && $_POST['vendor'] != "") {
	$vendor = $_POST['vendor'];
	$path = 'C:\pricelists\PriceForDBExport\\'. $vendor. '.csv';
	echo "$path <br />";
	echo "Обновление Прайс-листа $vendor <br />";

	if (($handle = fopen($path, "r")) !== FALSE) {
		if (($data = fgetcsv($handle, 1000, ";", " ")) !== FALSE) {
			$vendor_code = $data[10];

			if (!empty($vendor_code)) {
				echo "Код поставщика: $vendor_code <br />";
				$link = mysql_pconnect(localhost, root);
				mysql_select_db(dbparts);
				//mysql_query("set CHARACTER SET utf8");
				//mysql_query("SET OPTION SQL_BIG_SELECTS=1");
				
				// Запрос ревизии
				$query = "SELECT * FROM jos_parts_revision WHERE vendor_name = '$vendor_code'";
				$result = mysql_query($query);
				$f = mysql_fetch_array($result);
				$revision = $f[revision];
				$last_update = $f[idate];
				echo "Последнее обновление: $last_update | Ревизия: $revision <br />";
				mysql_free_result($result);
				

				// Загрузка новых данных
				echo "Start at <br />";
				$load = "LOAD DATA LOCAL INFILE '$path' INTO TABLE dbparts.jos_parts ";
				$load .= "REPLACE ";
				$load .= "FIELDS TERMINATED BY ';' ENCLOSED BY '' ";
				$load .= "LINES TERMINATED BY '\r\n' ";
				$load .= "SET revision = $revision + 1";
				mysql_query($load);
				echo "Stop at <br />";

				mysql_close($link);
    			} 
			else { 
				echo "File not found!!!";
				fclose($handle); 
				exit; 
			}
		}
		fclose($handle);
	}
} 
else { 
	echo "No vendor selected! Select vendor and try again"; 
}
?>

Никакого обновления не происходит. Что не так?

[mv28jam]

Ошибки mysql проверяли? http://ru2.php.net/manual/en/function.mysql-error.php
Что возвращает mysql_query($load);?

[Maxx]

Возвращает неверный путь к файлу. Не заметил, что надо писать С:/ вместо С:\
Все работает, вот итоговый код, может кому пригодится:

<form action="" method="post">
<select name="vendor">
<option name="vendor" value="" selected></option>
<option name="vendor" value="v1">Поставщик1</option>
<option name="vendor" value="v2">Поставщик2</option>
<option name="vendor" value="v3">Поставщик3</option>
<option name="vendor" value="v4">Поставщик4</option>
<option name="vendor" value="v5">Поставщик5</option>
<option name="vendor" value="v6">Поставщик6</option>
<option name="vendor" value="v7">Поставщик7</option>
<option name="vendor" value="v8">Поставщик8</option>
<option name="vendor" value="v9">Поставщик9</option>
<option name="vendor" value="v10">Поставщик10</option>
<option name="vendor" value="v11">Поставщик11</option>
<option name="vendor" value="v12">Поставщик12</option>
<option name="vendor" value="v13">Поставщик13</option>
</select>
<input type="submit" value="Обновить...">
</form>

<?php
if (isset($_POST['vendor']) && $_POST['vendor'] != "") {
	$vendor = $_POST['vendor'];
	$path_csv = 'C:\pricelists\PriceForDBExport\\'. $vendor. '.csv';
	$path_load = 'C:/pricelists/PriceForDBExport/'. $vendor. '.csv';
	echo "$path_csv <br /> $path_load <br />";
	echo "Обновление Прайс-листа $vendor <br />";

	if (($handle = fopen($path_csv, "r")) !== FALSE) {
		if (($data = fgetcsv($handle, 1000, ";", " ")) !== FALSE) {
			$vendor_code = $data[10];

			if (!empty($vendor_code)) {
				echo "Код поставщика: $vendor_code <br />";
				$link = mysql_pconnect(localhost, root);
				mysql_select_db(dbparts);
				mysql_query("set CHARACTER SET utf8");
				//mysql_query("SET OPTION SQL_BIG_SELECTS=1");
				
				// Запрос ревизии
				$query = "SELECT * FROM jos_parts_revision WHERE vendor_name = '$vendor_code'";
				$result = mysql_query($query);
				$f = mysql_fetch_array($result);
				$revision = $f[revision];
				$last_update = $f[idate];
				$newrevision = $revision;
				$newrevision ++;
				echo "Последнее обновление: $last_update | Ревизия: $revision | Новая ревизия: $newrevision <br />";
				mysql_free_result($result);

				// Загрузка новых данных
				$load = "LOAD DATA LOCAL INFILE '$path_load' REPLACE INTO TABLE dbparts.jos_parts ";
				$load .= "FIELDS TERMINATED BY ';' ENCLOSED BY '' ";
				$load .= "LINES STARTING BY '\"' TERMINATED BY '\\n' ";
				$load .= "SET revision = $newrevision";
				mysql_query($load);
				
				if (mysql_errno()) {
					echo mysql_errno($link) . ": " . mysql_error($link) . "\n";
				}
				else {
					echo "Обновление выполнено! <br />";
					$result_update = mysql_affected_rows();
					echo "Обновлено $result_update записей <br />";

					//Обновление ревизии
					mysql_query("UPDATE jos_parts_revision SET revision = '$newrevision', idate = CURRENT_TIMESTAMP WHERE vendor_name = '$vendor_code'");
					$result_update_revision = mysql_affected_rows();
					echo "Обновлено $result_update_revision записей в таблице 'Ревизия' <br />";

					//Удаление старых данных
					mysql_query("DELETE FROM jos_parts WHERE vendor_name = '$vendor_code' AND revision <> '$newrevision'");
					$result_delete = mysql_affected_rows();
					echo "Удалено $result_delete старых записей в таблице 'Запчасти' <br />";
				}
				mysql_close($link);
    			} 
			else { 
				echo "Файл не найден!";
			}
		}
		fclose($handle);
	}
} 
else { 
	echo "Не выбран поставщик! Выберите поставщика и повторите снова!"; 
}
?>

Спасибо еще раз за советы. Скорость загрузки впечатляет

Осталась одна проблема - кодировка. Все таблицы utf8. В названиях деталей есть русские буквы. mysql_query("set CHARACTER SET utf8"); не помагает.

[mv28jam]

Попробуйте "SET NAMES utf8".
С кодировкой дистанционно сложно "побороться", поэтому метод "проб и ошибок".

[Maxx]

Не помогло. Но с этим я справлюсь. В екселе я умею создавать файлы txt в сразу в utf8.

Теперь я вспомнил, почему пошел по столь длинному пути (посты №4,6). По некоторым поставщикам прайсы содержат до 500000 поз. А txt и csv такой объем не поддерживают. Поэтому я сразу из xlsx гнал все это через migratinTool в базу. Видимо по таким прайсам придется создавать несколько csv файлов (file1, file2 и т.д.) и с помощью цикла в php перебирать их все.

Есть проблема: создал поддомен, туда залил скрипт. Выдает ошибку 1045: Access denied for user 'имя'@'localhost' (using password: YES)

[mv28jam]

Сообщение от Maxx

Есть проблема: создал поддомен, туда залил скрипт. Выдает ошибку 1045: Access denied for user 'имя'@'localhost' (using password: YES)

уберите LOCAL, те LOAD DATA INFILE

[Maxx]

Убрал сразу. Попытаюсь выяснить у хоста.
Вот что говорят:LOAD DATA INFILE у нас вообще не работает, Потому что нет таких прав для пользователя базы, мы их не даем.
используйте ssh