【发布时间】:2019-01-28 20:49:40
【问题描述】:
我想要实现的是在运行 相同 SQL Server 版本(SQL Server 2008 R2 RTM)的两个 不同 服务器上拥有两个不同的 SQL Server 数据库- 10.50.1600.1 )每天同步。同步意味着只是将新数据(甚至所有数据)从两个(“父”数据库)之一传输到另一个(“子”数据库)。我们希望父级将其 shema 以及所有数据强制提供给其子级。
我已经尝试过的
知道这两台机器在 windows server 2012 R2 上运行,我已经尝试使用以下工具实施解决方案(尽管我 不是 SQL Server 专家)。
- PHP v7.2
- ExeOutputforPHP (https://www.exeoutput.com/)
- WinSCP(用于内置 ftp 方法https://winscp.net)
- Schemazen (https://github.com/sethreno/schemazen)
所以我会这样做:
- 使用 PHP 读取配置文件(服务器、用户、通行证、数据库等)
- 当 PHP 不会产生任何错误时,我会触发 schemazen 脚本方法。
- 当一切顺利时,我将触发 winscp 的 ftp 方法到远程服务器
那就是出口方
现在是导入端
- 我会找到 ftp 目录并使用 Schemazen 创建方法,我会通过读取配置文件再次导入数据。
导出端代码
$iniConfig = parse_ini_file('..\conf.ini', true);
if ($iniConfig) {
echo PHP_EOL.'Configuration file found in '.realpath('..\conf.ini').PHP_EOL;
define('EXPORT_HOST', $iniConfig['export']['host']);
define('EXPORT_DB', $iniConfig['export']['db']);
define('EXPORT_DIR', $iniConfig['export']['dir']);
define('FTP_HOST', $iniConfig['ftp']['host']);
define('FTP_PATH_TO_SAVE', $iniConfig['ftp']['path']);
define('FTP_USERNAME', $iniConfig['ftp']['user']);
define('FTP_PASS', $iniConfig['ftp']['pass']);
define('PATH_TO_SAVE', $iniConfig['ftp']['path']);
$output = [];
$return_var = 0;
$credsFlag = '';
if ($iniConfig['export']['user'] && $iniConfig['export']['pass']) {
define('EXPORT_USER', $iniConfig['export']['user']);
define('EXPORT_PASS', $iniConfig['export']['pass']);
$credsFlag = ' -u '.EXPORT_USER.' -p '.EXPORT_PASS;
} else {
echo PHP_EOL.'Please Define the Username and Password for connection to the Database!'.PHP_EOL;
die();
}
$connArray = [
'Database' => EXPORT_DB,
'UID' => EXPORT_USER,
'PWD' => EXPORT_PASS,
];
$connection = sqlsrv_connect(EXPORT_HOST, $connArray);
if (!$connection) {
echo PHP_EOL.'Could not Connect to the Database!' . PHP_EOL . 'We received the following tried to connect:' . PHP_EOL;
print_r(sqlsrv_errors());
die();
}
$query = "select table_name from information_schema.tables where table_catalog = '" . EXPORT_DB . "'";
$tables = [];
$rs = sqlsrv_query($connection, $query);
while (($rd = sqlsrv_fetch_array($rs, SQLSRV_FETCH_ASSOC)) !== false) {
if ($rd) {
array_push($tables, $rd);
}
}
sqlsrv_close($connection);
$dataTablesString = '--dataTables=';
foreach ($tables as $table) {
$dataTablesString .= $table['table_name'].',';
}
exec('scriptor\SchemaZen.exe script -s '.EXPORT_HOST.' -b '.EXPORT_DB.$credsFlag.' -d '.EXPORT_DIR.' -o '.$dataTablesString, $output, $return_var);
if (-1 === $return_var) {
$file = fopen('ftp_script.txt', 'w+');
if ($file) {
$ftpStringToWrite = 'open ftp://'.FTP_USERNAME.':'.FTP_PASS.'@'.FTP_HOST.'/'.PHP_EOL.'cd '.FTP_PATH_TO_SAVE.PHP_EOL.'put '.EXPORT_DIR.'\*'.PHP_EOL.'exit';
$writer = fwrite($file, $ftpStringToWrite);
if ($writer) {
fclose($file);
unset($output);
exec('ftp\WinSCP.com /script=ftp_script.txt', $output, $return_var);
if (0 === $return_var) {
echo PHP_EOL.'Backup Exported and Transfered via FTP.'.PHP_EOL;
}
}
}
}
}
导入端代码
<?php
if ($iniConfig = parse_ini_file('../conf.ini', true)) {
define('IMPORT_HOST', $iniConfig['import']['host']);
define('IMPORT_DB', $iniConfig['import']['db']);
define('IMPORT_DB_AFTER', $iniConfig['settings']['databaseAfterFix']);
$credsFlags = '';
if ($iniConfig['import']['user'] && $iniConfig['import']['pass']) {
define('IMPORT_USER', $iniConfig['import']['user']);
define('IMPORT_PASS', $iniConfig['import']['pass']);
$credsFlags = ' -u '.IMPORT_USER.' -p '.IMPORT_PASS;
} else {
echo PHP_EOL.'Please Define the Username and Password for connection to the Database!'.PHP_EOL;
die();
}
$output = [];
$return_var = 0;
exec('scriptor\SchemaZen.exe create -s '.IMPORT_HOST.$credsFlags.' -o -b '.IMPORT_DB. ' -d ../../DBMigrate/'.$iniConfig['ftp']['path'].'', $output, $return_var);
foreach ($output as $message) {
echo $message.PHP_EOL;
}
if (0 !== $return_var) {
$error_log = fopen($iniConfig['settings']['errorlog'], 'a+');
if ($error_log) {
foreach ($output as $error) {
$writer = fwrite($error_log, '['.date('Y-m-d h:i:s').']'.$error.PHP_EOL);
}
$notify = mail($iniConfig['settings']['mail'], 'Import Error Encoutered!', 'Errors in Import of the Server.Please Check an error log should have been Created inside the folder /Data of the importer!');
if ($notify) {
echo PHP_EOL.'Mail sent about errors!'.PHP_EOL;
}
if ($writer) {
echo PHP_EOL.'Created Error LOg Please Check!'.PHP_EOL;
}
}
}
}
问题
最大的问题是我在运行不同 SQL Server 版本的本地环境中开发了这个测试,当我尝试在实时服务器内的暂存环境中进行测试时,我遇到了以下问题https://github.com/sethreno/schemazen/issues/141
我真的很感激任何好的替代方案(尤其是 SQL Server 管理工作室中的内置工具,但我需要一些指导),或者任何可以应用于 Schemazen 的更正,因为它是一个开源项目来纠正问题。
【问题讨论】:
-
您似乎正在寻找复制解决方案。其中一些是开源的。试试,例如:symmetricds.org/about/overview
-
非常感谢 Marc,您是否知道这些复制工具是否可以与 SQL Server 的 Express 版本一起使用?
-
我没有在 SQL Server 上尝试过它们,但如果它们与 Firebird 一起工作,那么是的,它们应该与 Express 版本一起工作。
标签: c# php sql-server synchronization winscp