<?php
ini_set('display_errors', 1);
ini_set('display_startup_errors', 1);
error_reporting(E_ALL);
#Connection variables for MYSQL:
$mysql_host = 'SERVER';
$mysql_user = 'haldur';
$mysql_password = 'PAROOL';
$mysql_database = 'test';
$mysql_link = new PDO(
  "mysql:host=$mysql_host;dbname=$mysql_database;charset=utf8",
  $mysql_user,
  $mysql_password
);

#Connection variables for MSSSQL:
$mssql_host = '213.168.13.18:1433';
$mssql_user = 'VAATAJA';
$mssql_password = 'PAROOL';
$mssql_database = 'BAAS';
$mssql_link = new PDO(
  "dblib:host=$mssql_host;dbname=$mssql_database",
  $mssql_user,
  $mssql_password
);

$tables = array('TABEL'); # tabeli nimed siia

#SET CHARACTER SET to utf8:
$mysql_link->prepare("SET NAMES 'utf8'")->execute();
$mysql_link->prepare("SET CHARACTER SET 'utf8'")->execute();

#Migrate the data:
foreach($tables as $table){
  $deleteQuery = "DELETE FROM $table";
  try{
    $mysql_link->prepare($deleteQuery)->execute();
  }
  catch (PDOException $e){
    echo $e->getMessage();
  }
  $mssql_selection = 'SELECT * FROM ' .$table;
  $m_res = $mssql_link->prepare($mssql_selection);
  $m_res->execute();

  $j = 0;
  $query = "";
  $sql = "";
  while( ($rec = $m_res->fetch(PDO::FETCH_NUM)) !== false) {
    $j = $j++;
    $cols = count($rec);
    for($i = 0; $i < $cols; $i++){
      if(is_string($rec[$i]))
      {
        $rec[$i] = $mysql_link->quote(trim($rec[$i]));
      }
      if(is_null($rec[$i]))
        $rec[$i] = 'NULL';
    }
    $query .= "(".implode(",", $rec)."),";
  }
  $query = rtrim($query, ",");
  $sql = "INSERT INTO `".$table."` VALUES ". $query;
  echo "<pre>",$table, ' >> ', $j, " kirjet
  ", $sql,"</pre>";

  $mysql_link->prepare($sql)->execute();
}
?>