Класс репликации данных между двумя базами MySql PHP.

class DatabaseReplicator {
  private $sourceDb;
  private $targetDb;

  public function __construct($sourceHost, $sourceDbName, $sourceUsername, $sourcePassword, $targetHost, $targetDbName, $targetUsername, $targetPassword) {
    try {
      // подключение к источнику данных
      $this->sourceDb = new PDO("mysql:host=$sourceHost;dbname=$sourceDbName", $sourceUsername, $sourcePassword);

      // подключение к целевой базе данных
      $this->targetDb = new PDO("mysql:host=$targetHost;dbname=$targetDbName", $targetUsername, $targetPassword);
    } catch (PDOException $e) {
      // обработка ошибок подключения
      die("Error connecting to the database: " . $e->getMessage());
    }
  }

  public function replicateData($token) {
    if ($this->validateToken($token)) {
      // выборка данных из источника
      $statement = $this->sourceDb->prepare("SELECT * FROM table");
      $statement->execute();
      $rows = $statement->fetchAll(PDO::FETCH_ASSOC);

      // вставка данных в целевую базу данных
      foreach ($rows as $row) {
        $insertStatement = $this->targetDb->prepare("INSERT INTO table (column1, column2, column3) VALUES (:column1, :column2, :column3)");
        $insertStatement->execute(array(
          ':column1' => $row['column1'],
          ':column2' => $row['column2'],
          ':column3' => $row['column3']
        ));
      }
    } else {
      die("Invalid token");
    }
  }

  private function validateToken($token) {
    // проверка токена - здесь можно использовать любой механизм авторизации,
    // например, проверку наличия токена в базе данных или сравнение с заданным значением
    return ($token == "mytoken");
  }
}

$replicator = new DatabaseReplicator($sourceHost, $sourceDbName, $sourceUsername, $sourcePassword, $targetHost, $targetDbName, $targetUsername, $targetPassword);
$replicator->replicateData("mytoken");

class MysqliReplicator {
    private $config;
    private $sourceConn;
    private $destinationConn;

    public function __construct() {
        $this->config = parse_ini_file('config.ini', true);

        // Establish source and destination MySQL connections using mysqli
        $this->sourceConn = new mysqli(
            $this->config['source']['host'],
            $this->config['source']['username'],
            $this->config['source']['password'],
            $this->config['source']['database']
        );

        if ($this->sourceConn->connect_error) {
            die("Source connection failed: " . $this->sourceConn->connect_error);
        }

        $this->destinationConn = new mysqli(
            $this->config['destination']['host'],
            $this->config['destination']['username'],
            $this->config['destination']['password'],
            $this->config['destination']['database']
        );

        if ($this->destinationConn->connect_error) {
            die("Destination connection failed: " . $this->destinationConn->connect_error);
        }
    }

    public function replicate() {
        $token = $this->config['token'];

        // Query source database for rows
        $result = $this->sourceConn->query("SELECT * FROM table");

        while ($row = $result->fetch_assoc()) {
            // Check if row already exists in destination database
            $exists = $this->destinationConn->query("SELECT * FROM table WHERE id = '{$row['id']}'")->num_rows > 0;

            if (!$exists) {
                // Send row data to destination database through CURL
                $ch = curl_init();
                curl_setopt($ch, CURLOPT_URL, "http://destination.com/api/insert");
                curl_setopt($ch, CURLOPT_POST, 1);
                curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($row));
                curl_setopt($ch, CURLOPT_HTTPHEADER, array("Authorization: Bearer $token"));
                curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
                $response = curl_exec ($ch);
                curl_close ($ch);
            }
        }

        // Query destination database for rows
        $result = $this->destinationConn->query("SELECT * FROM table");

        while ($row = $result->fetch_assoc()) {
            // Check if row already exists in source database
            $exists = $this->sourceConn->query("SELECT * FROM table WHERE id = '{$row['id']}'")->num_rows > 0;

            if (!$exists) {
                // Send row data to source database through CURL
                $ch = curl_init();
                curl_setopt($ch, CURLOPT_URL, "http://source.com/api/insert");
                curl_setopt($ch, CURLOPT_POST, 1);
                curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($row));
                curl_setopt($ch, CURLOPT_HTTPHEADER, array("Authorization: Bearer $token"));
                curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
                $response = curl_exec ($ch);
                curl_close ($ch);
            }
        }
    }
}

// Usage example:
$replicator = new MysqliReplicator();
$replicator->replicate();