Witam!
W jakiś sposób najlepiej będzie aktualizować bazę danych produktów z programu Subiekt GT który ma bazę MS SQL do aplikacji która wykorzystuje MySQL.

W aplikacji jest tylko część produktów (ok 2800) mają one dodaną komórkę w tabeli subject_id gdzie znajduję się id produktu z bazy Subiekt.

Aplikacja nie przechowuje stanów magazynowych produktów posiada tylko włącznik i wyłącznik produktu (1,0)

W jaki sposób najlepiej zaplanować cały proces aktualizacji stanów magazynowych?

Wyłączenie produktu np gdy jego ilość jest < 2

Stany codziennie się zmieniają.

Czy np najpierw wypadałoby znać całą listę produktów z bazy danych aplikacji potem zapytać o ich stany i gdy są <2 wyłączyć je?

U mnie osoba która zajmuje się Subiektem od strony handlowej stworzyła program do aktualizacji stanów na poziomie serwera.
Program w trybie live zbiera informacje o każdej zmianie stanu magazynowego oraz cenie i wysyła do bazy MySQL.

Można by zerknąć w bazę subiekta czy nie ma tam daty aktualizowanego przedmiotu, jeśli jest to robić update z delty czyli tylko tych które zmieniły się od ost. aktualizacji.

Ale fakt że większość rozwiązań integracji które widziałem to aplikacja w np. c# działająca po stronie subiekta i pchająca dane do serwera Web.

Ja sobie napisałem taki skrypt do aktualizacji stanów magazynowych w sklepie:

[PHP] pobierz, plaintext 
 
header('Content-Type: text/html; charset=utf-8');
ini_set( 'display_errors', 'On' ); 
error_reporting( E_ALL );
$serverName = "localhost\INSERTGT";
$connectionInfo = array( "Database"=>"nazwa bazy danych sql", "UID"=>"login do serwera sql", "PWD"=>"hasło", "CharacterSet" => "UTF-8");
$conn = sqlsrv_connect( $serverName, $connectionInfo);
if( $conn ) {
     echo "Połączony z Subiektem - wszystko ok!<br />";
}else{
     echo "Nie mogę się połączyć z Subiektem!<br />";
     die( print_r( sqlsrv_errors(), true));
}
$sql = "SELECT tw_symbol as Symbol, tw_nazwa as Nazwa, st_Stan as Stan FROM tw__towar INNER JOIN tw_Stan ON  tw_Id=st_TowId WHERE st_MagId=1";
$stmt = sqlsrv_query( $conn, $sql );
 
if( $stmt === false) {
    die( print_r( sqlsrv_errors(), true) );
}
 $adres_ip_serwera_mysql_z_baza_danych = '';
 $nazwa_bazy_danych = '';
 $login_bazy_danych = '';
 $haslo_bazy_danych = '';
 
 if ( !mysql_connect($adres_ip_serwera_mysql_z_baza_danych,
 
     $login_bazy_danych,$haslo_bazy_danych) ) {
     echo 'Nie moge polaczyc sie z baza danych';
 	 exit (0);
 }
 
 if ( !mysql_select_db($nazwa_bazy_danych) ) {
    echo 'Blad otwarcia bazy danych';
 	 exit (0);
 }                                                                                      
 
while( $row = sqlsrv_fetch_array( $stmt, SQLSRV_FETCH_ASSOC) ) {  
    $symbol = $row['Symbol'];
    $stan = round($row['Stan'], 0); 
    $zapytanie = "UPDATE products SET products_model = '$symbol', products_quantity = '$stan' WHERE products_model = '$symbol' "
	or die(mysql_error());
	$wynik = mysql_query($zapytanie);	
}
if ($wynik) {
		echo 'Zaktualizowałem stany magazynowe!';	
	}
sqlsrv_free_stmt($stmt);
[PHP] pobierz, plaintext 

Może ci się przyda

Dzięki za informacje.
Wow skrypt super.

Okazuje się że mam też dostęp do bazy MySQL w której te stany się aktualizują za pomocą zewnętrznego programu.
Czyli tak na prawdę mój problem zawęża się do aktualizacji produktów które maja ten sam indeks.

W jednej bazie jest 7000tyś obiektów w drugiej tylko 2600
Czy zrobić to za pomocą csv ?

Chodzi o to że w drugiej nie ma ilości jest tylko włącz wyłącz.


xaitras Wykorzystałem Twój pomysł stworzyłem skrypt który między dwoma bazami MySQL aktualizuje stany magazynowe. Czy mogę prosić o sprawdzenie czy może da się takowy skrypt usprawnić ponieważ jego wykonanie zajmuje dużo czasu ponad 300s i to w pierwszej części.

[SQL] pobierz, plaintext 
 
<?php
header('Content-Type: text/html; charset=utf-8');
ini_set( 'display_errors', 'On' ); 
error_reporting( E_ALL );
// serwer 1
$servername1 = "localhost";
$username1 = "root";
$password1 = "";
$dbname1 = "sklep";
//serwer 2
$servername2 = "localhost";
$username2 = "root";
$password2 = "";
$dbname2 = "test";
 
$connect1 = mysqli_connect($servername1, $username1, $password1, $dbname1);
$connect2 = mysqli_connect($servername2, $username2, $password2, $dbname2);
 
 
$query1 = "SELECT * FROM `sklep_towary` WHERE STAN < 3";
$query2 = "SELECT * FROM `sklep_towary` WHERE STAN > 2";
 
 
$result1 = mysqli_query($connect1, $query1);
$result2 = mysqli_query($connect1, $query2);
 
IF(mysqli_num_rows($result1) > 0){
    while($row = mysqli_fetch_assoc($result1))
 {  $indeks = $row['INDEKS'];
    $stan = $row['STAN'];
    $zapytanie = "UPDATE dimensions_available_phones SET avaiblable = 0 WHERE subiekt_id ='$indeks' " OR die(mysql_error());
      $wynik = mysqli_query($connect2, $zapytanie);
 
 }
 IF(mysqli_num_rows($result2)>0){
 while($row = mysqli_fetch_assoc($result2)){
    $indeks = $row['INDEKS'];
    $stan = $row['STAN'];
     $zapytanie2 = "UPDATE dimensions_available_phones SET avaiblable = 1 WHERE subiekt_id ='$indeks' " OR die(mysql_error());
     $wynik2 = mysqli_query($connect2, $zapytanie2);
 }
 
 }
 IF($wynik){
          echo 'Wyłączono';
      }
 IF($wynik2){
     echo 'Włączono';
 }    
}
 
 
 
 
 
 
?>
 
[SQL] pobierz, plaintext