Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <?php
- #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 RTRIM(*) 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] = $mssql_link->quote($rec[$i]);
- if(is_null($rec[$i]))
- $rec[$i] = 'NULL';
- }
- $query .= "(".implode(",", $rec)."),";
- }
- $sql = "INSERT INTO ".$table." VALUES ". $query;
- echo "<pre>",$table, ' >> ', $j, " kirjet
- ", $sql,"</pre>";
- try{
- $mysql_link->prepare($sql)->execute();
- }
- catch (PDOException $e)
- {
- echo $e->getMessage();
- }
- }
- ?>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement